Synnefo

def start_action(vm, action):

    """Update the state of a VM when a new action is initiated."""

    if not action in [x[0] for x in VirtualMachine.ACTIONS]:

        raise VirtualMachine.InvalidActionError(action)

    # Defined in settings.GANETI_CREATEINSTANCE_KWARGS

    # kw['hvparams'] = dict(serial_console=False)

    with pooled_rapi_client(vm) as client:

        return client.CreateInstance(**kw)

def reboot_instance(vm, reboot_type):

    assert reboot_type in ('soft', 'hard')

    with pooled_rapi_client(vm) as client:

def startup_instance(vm):

    #          the instance's primary node, and is probably

    #          hypervisor-specific.

    #

    console = {}

    console['kind'] = 'vnc'

    if not backends:

        backends = Backend.objects.exclude(offline=True)

    for backend in backends:

        create_jobID = _create_network(network, backend)

        if connect:

def connect_network(network, backend, depend_job=None, group=None):

    """Connect a network to nodegroups."""

    mode = "routed" if "ROUTED" in network.type else "bridged"

    with pooled_rapi_client(backend) as client:

    if not backends:

        backends = Backend.objects.exclude(offline=True)

    for backend in backends:

        disconnect_jobIDs = []

        if disconnect:

def disconnect_network(network, backend, group=None):

    with pooled_rapi_client(backend) as client:

        if group:

            return [client.DisconnectNetwork(network.backend_id, group)]

def connect_to_network(vm, network, address):

    nic = {'ip': address, 'network': network.backend_id}

    with pooled_rapi_client(vm) as client:

        return client.ModifyInstance(vm.backend_vm_id, nics=[('add',  nic)],

                                     hotplug=settings.GANETI_USE_HOTPLUG,

def disconnect_from_network(vm, nic):

    op = [('remove', nic.index, {})]

    with pooled_rapi_client(vm) as client:

        return client.ModifyInstance(vm.backend_vm_id, nics=op,

                                     hotplug=settings.GANETI_USE_HOTPLUG,

    except KeyError:

        raise ValueError("Unsopported Firewall Profile: %s" % profile)

    with pooled_rapi_client(vm) as client:

        # Delete all firewall tags

        for t in _firewall_tags.values():