Synnefo

@transaction.commit_on_success

def process_op_status(vm, etime, jobid, opcode, status, logmsg, nics=None,

    """Process a job progress notification from the backend

    Process an incoming message from the backend (currently Ganeti).

        vm.save()

        return

    state_for_success = VirtualMachine.OPER_STATE_FROM_OPCODE.get(opcode)

    # Notifications of success change the operating state

    if status == "success":

        if state_for_success is not None:

            vm.operstate = state_for_success

        if beparams:

            # Change the flavor of the VM

            _process_resize(vm, beparams)

    if status in ["success", "error", "canceled"]:

        # Job is finalized: Handle quotas/commissioning

        vm = handle_vm_quotas(vm, job_id=jobid, job_opcode=opcode,

        # and clear task fields

        if vm.task_job_id == jobid:

            vm.task = None

@transaction.commit_on_success

def process_network_modify(back_network, etime, jobid, opcode, status,

    assert (opcode == "OP_NETWORK_SET_PARAMS")

    if status not in [x[0] for x in BACKEND_STATUSES]:

        raise Network.InvalidBackendMsgError(opcode, status)

    back_network.backendjobstatus = status

    back_network.opcode = opcode

    if add_reserved_ips:

        net = back_network.network

        pool = net.get_pool()