Revision c4e55622 snf-cyclades-app/synnefo/logic/backend.py
| b/snf-cyclades-app/synnefo/logic/backend.py | ||
|---|---|---|
| 56 | 56 |
|
| 57 | 57 |
|
| 58 | 58 |
@transaction.commit_on_success |
| 59 |
def process_op_status(vm, jobid, opcode, status, logmsg): |
|
| 59 |
def process_op_status(vm, etime, jobid, opcode, status, logmsg):
|
|
| 60 | 60 |
"""Process a job progress notification from the backend |
| 61 | 61 |
|
| 62 | 62 |
Process an incoming message from the backend (currently Ganeti). |
| ... | ... | |
| 96 | 96 |
vm.deleted = True |
| 97 | 97 |
vm.nics.all().delete() |
| 98 | 98 |
|
| 99 |
vm.backendtime = etime |
|
| 99 | 100 |
# Any other notification of failure leaves the operating state unchanged |
| 100 | 101 |
|
| 101 | 102 |
vm.save() |
| 102 | 103 |
|
| 103 | 104 |
|
| 104 | 105 |
@transaction.commit_on_success |
| 105 |
def process_net_status(vm, nics): |
|
| 106 |
def process_net_status(vm, etime, nics):
|
|
| 106 | 107 |
"""Process a net status notification from the backend |
| 107 | 108 |
|
| 108 | 109 |
Process an incoming message from the Ganeti backend, |
| ... | ... | |
| 145 | 146 |
# network nics modified, update network object |
| 146 | 147 |
net.save() |
| 147 | 148 |
|
| 149 |
vm.backendtime = etime |
|
| 148 | 150 |
vm.save() |
| 149 | 151 |
|
| 150 | 152 |
|
| 151 | 153 |
@transaction.commit_on_success |
| 152 |
def process_create_progress(vm, rprogress, wprogress): |
|
| 154 |
def process_create_progress(vm, etime, rprogress, wprogress):
|
|
| 153 | 155 |
|
| 154 | 156 |
# XXX: This only uses the read progress for now. |
| 155 | 157 |
# Explore whether it would make sense to use the value of wprogress |
| ... | ... | |
| 180 | 182 |
# raise VirtualMachine.IllegalState("VM is not in building state")
|
| 181 | 183 |
|
| 182 | 184 |
vm.buildpercentage = percentage |
| 185 |
vm.backendtime = etime |
|
| 183 | 186 |
vm.save() |
| 184 | 187 |
|
| 185 | 188 |
|
Also available in: Unified diff