Revision c3f0a12f daemons/ganeti-masterd
b/daemons/ganeti-masterd | ||
---|---|---|
208 | 208 |
|
209 | 209 |
if method == luxi.REQ_SUBMIT_JOB: |
210 | 210 |
ops = [opcodes.OpCode.LoadOpCode(state) for state in args] |
211 |
return queue.SubmitJob(ops) |
|
211 |
# we need to compute the node list here, since from now on all |
|
212 |
# operations require locks on the queue or the storage, and we |
|
213 |
# shouldn't get another lock |
|
214 |
node_list = self.server.context.cfg.GetNodeList() |
|
215 |
return queue.SubmitJob(ops, node_list) |
|
212 | 216 |
|
213 | 217 |
elif method == luxi.REQ_CANCEL_JOB: |
214 | 218 |
(job_id, ) = args |
Also available in: Unified diff