Revision e6fbada1 snf-cyclades-app/synnefo/logic/callbacks.py
| b/snf-cyclades-app/synnefo/logic/callbacks.py | ||
|---|---|---|
| 171 | 171 |
log.error("Message is of unknown type %s.", msg['type'])
|
| 172 | 172 |
return |
| 173 | 173 |
|
| 174 |
nics = msg.get("nics", None)
|
|
| 175 |
beparams = msg.get("beparams", None)
|
|
| 174 |
nics = msg.get("instance_nics", None)
|
|
| 175 |
job_fields = msg.get("job_fields", {})
|
|
| 176 | 176 |
backend_mod.process_op_status(vm, event_time, msg['jobId'], |
| 177 | 177 |
msg['operation'], msg['status'], |
| 178 | 178 |
msg['logmsg'], nics=nics, |
| 179 |
beparams=beparams)
|
|
| 179 |
job_fields=job_fields)
|
|
| 180 | 180 |
|
| 181 | 181 |
log.debug("Done processing ganeti-op-status msg for vm %s.",
|
| 182 | 182 |
msg['instance']) |
| ... | ... | |
| 195 | 195 |
opcode = msg['operation'] |
| 196 | 196 |
status = msg['status'] |
| 197 | 197 |
jobid = msg['jobId'] |
| 198 |
job_fields = msg.get('job_fields', {})
|
|
| 198 | 199 |
|
| 199 | 200 |
if opcode == "OP_NETWORK_SET_PARAMS": |
| 200 | 201 |
backend_mod.process_network_modify(network, event_time, jobid, opcode, |
| 201 |
status, msg['add_reserved_ips'])
|
|
| 202 |
status, job_fields)
|
|
| 202 | 203 |
else: |
| 203 | 204 |
backend_mod.process_network_status(network, event_time, jobid, opcode, |
| 204 | 205 |
status, msg['logmsg']) |
Also available in: Unified diff