Revision 363dc9d6
| b/src/Ganeti/JQueue.hs | ||
|---|---|---|
| 31 | 31 |
, InputOpCode(..) |
| 32 | 32 |
, queuedOpCodeFromMetaOpCode |
| 33 | 33 |
, queuedJobFromOpCodes |
| 34 |
, cancelQueuedJob |
|
| 34 | 35 |
, Timestamp |
| 35 | 36 |
, noTimestamp |
| 36 | 37 |
, currentTimestamp |
| ... | ... | |
| 195 | 196 |
setReceivedTimestamp :: Timestamp -> QueuedJob -> QueuedJob |
| 196 | 197 |
setReceivedTimestamp ts job = job { qjReceivedTimestamp = Just ts }
|
| 197 | 198 |
|
| 199 |
-- | Set the state of a QueuedOpCode to canceled. |
|
| 200 |
cancelOpCode :: Timestamp -> QueuedOpCode -> QueuedOpCode |
|
| 201 |
cancelOpCode now op = |
|
| 202 |
op { qoStatus = OP_STATUS_CANCELED, qoEndTimestamp = Just now }
|
|
| 203 |
|
|
| 204 |
-- | Transform a QueuedJob that has not been started into its canceled form. |
|
| 205 |
cancelQueuedJob :: Timestamp -> QueuedJob -> QueuedJob |
|
| 206 |
cancelQueuedJob now job = |
|
| 207 |
let ops' = map (cancelOpCode now) $ qjOps job |
|
| 208 |
in job { qjOps = ops', qjEndTimestamp = Just now}
|
|
| 209 |
|
|
| 198 | 210 |
-- | Job file prefix. |
| 199 | 211 |
jobFilePrefix :: String |
| 200 | 212 |
jobFilePrefix = "job-" |
Also available in: Unified diff