Revision 363dc9d6 src/Ganeti/JQueue.hs
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