Revision 3a24c527 scripts/gnt-debug
| b/scripts/gnt-debug | ||
|---|---|---|
| 30 | 30 |
|
| 31 | 31 |
from ganeti.cli import * |
| 32 | 32 |
from ganeti import opcodes |
| 33 |
from ganeti import logger |
|
| 34 | 33 |
from ganeti import constants |
| 35 | 34 |
from ganeti import utils |
| 36 | 35 |
from ganeti import errors |
| ... | ... | |
| 58 | 57 |
op_list = [opcodes.OpCode.LoadOpCode(val) for val in op_data] |
| 59 | 58 |
job = opcodes.Job(op_list=op_list) |
| 60 | 59 |
jid = SubmitJob(job) |
| 61 |
print "Job id:", jid
|
|
| 60 |
ToStdout("Job id: %s", jid)
|
|
| 62 | 61 |
query = {
|
| 63 | 62 |
"object": "jobs", |
| 64 | 63 |
"fields": ["status"], |
| ... | ... | |
| 70 | 69 |
jdata = SubmitQuery(query) |
| 71 | 70 |
if not jdata: |
| 72 | 71 |
# job not found, gone away! |
| 73 |
print "Job lost!"
|
|
| 72 |
ToStderr("Job lost!")
|
|
| 74 | 73 |
return 1 |
| 75 | 74 |
|
| 76 | 75 |
status = jdata[0][0] |
| 77 |
print status
|
|
| 76 |
ToStdout(status)
|
|
| 78 | 77 |
if status in (opcodes.Job.STATUS_SUCCESS, opcodes.Job.STATUS_FAIL): |
| 79 | 78 |
break |
| 80 | 79 |
|
| ... | ... | |
| 86 | 85 |
jdata = SubmitQuery(query) |
| 87 | 86 |
if not jdata: |
| 88 | 87 |
# job not found, gone away! |
| 89 |
print "Job lost!"
|
|
| 88 |
ToStderr("Job lost!")
|
|
| 90 | 89 |
return 1 |
| 91 |
print jdata[0]
|
|
| 90 |
ToStdout(jdata[0])
|
|
| 92 | 91 |
status, op_list, op_status, op_result = jdata[0] |
| 93 | 92 |
for idx, op in enumerate(op_list): |
| 94 |
print idx, op.OP_ID, op_status[idx], op_result[idx]
|
|
| 93 |
ToStdout("%s %s %s %s", idx, op.OP_ID, op_status[idx], op_result[idx])
|
|
| 95 | 94 |
return 0 |
| 96 | 95 |
|
| 97 | 96 |
|
| ... | ... | |
| 102 | 101 |
disks = [{"size": utils.ParseUnit(val), "mode": 'w'}
|
| 103 | 102 |
for val in opts.disks.split(",")]
|
| 104 | 103 |
except errors.UnitParseError, err: |
| 105 |
print >> sys.stderr, "Invalid disks parameter '%s': %s" % (opts.disks, err)
|
|
| 104 |
ToStderr("Invalid disks parameter '%s': %s", opts.disks, err)
|
|
| 106 | 105 |
return 1 |
| 107 | 106 |
|
| 108 | 107 |
nics = [val.split("/") for val in opts.nics.split(",")]
|
| ... | ... | |
| 132 | 131 |
allocator=opts.allocator, |
| 133 | 132 |
) |
| 134 | 133 |
result = SubmitOpCode(op) |
| 135 |
print result
|
|
| 134 |
ToStdout("%s" % result)
|
|
| 136 | 135 |
return 0 |
| 137 | 136 |
|
| 138 | 137 |
|
Also available in: Unified diff