Synnefo

# interpreted as representing official policies, either expressed

# or implied, of GRNET S.A.

from base64 import b64decode

from logging import getLogger

from synnefo.api import faults, util

from synnefo.api.actions import server_actions

from synnefo.api.common import method_not_allowed

from synnefo.logic.backend import create_instance, delete_instance

from synnefo.logic.utils import get_rsapi_state

from synnefo.util.rapi import GanetiApiError

    if count >= vms_limit_for_user:

        raise faults.OverLimit("Server count limit exceeded for your account.")

    # We must save the VM instance now, so that it gets a

    # valid vm.backend_vm_id.

    vm = VirtualMachine.objects.create(

        name=name,

        userid=request.user_uniq,

        imageid=image_id,

        flavor=flavor)

    @property

    def client(self):

            return get_client(self.backend_hash, self.backend_id)

        else:

            raise ServiceUnavailable

import json

from logging import getLogger

from django.conf import settings

from django.db import transaction

from synnefo.logic import utils

from synnefo.util.rapi import GanetiRapiClient

log = getLogger('synnefo.logic')

_firewall_tags = {

    'ENABLED': settings.GANETI_FIREWALL_ENABLED_TAG,

    # Defined in settings.GANETI_CREATEINSTANCE_KWARGS

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

def delete_instance(vm):

    start_action(vm, 'DESTROY')

def reboot_instance(vm, reboot_type):

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

    log.info('Rebooting instance %s', vm.backend_vm_id)

def startup_instance(vm):

    start_action(vm, 'START')

def shutdown_instance(vm):

    start_action(vm, 'STOP')

def get_instance_console(vm):

    #

    console = {}

    console['kind'] = 'vnc'

    if i['hvparams']['serial_console']:

        raise Exception("hv parameter serial_console cannot be true")

    console['host'] = i['pnode']

def request_status_update(vm):

def update_status(vm, status):

def connect_to_network(vm, net):

    nic = {'mode': 'bridged', 'link': net.link.name}

                        hotplug=True, dry_run=settings.TEST)

    ops = [('remove', nic.index, {}) for nic in nics if nic.network == net]

    if not ops:  # Vm not connected to network

        return

                        hotplug=True, dry_run=settings.TEST)

    except KeyError:

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

    # Delete all firewall tags

    for t in _firewall_tags.values():

    # XXX NOP ModifyInstance call to force process_net_status to run

    # on the dispatcher

                        os_name=settings.GANETI_CREATEINSTANCE_KWARGS['os'])

from synnefo.db.models import VirtualMachine

from synnefo.logic import reconciliation, backend

class Command(BaseCommand):

                "Issuing OP_INSTANCE_REMOVE for %d Ganeti instances:" % \

                len(orphans)

            for id in orphans:

                                    (settings.BACKEND_PREFIX_ID, str(id)))

            print >> sys.stderr, "    ...done"

from synnefo.db.models import VirtualMachine

from synnefo.util.dictconfig import dictConfig

log = logging.getLogger()

def get_instances_from_ganeti():

    snf_instances = {}

    prefix = settings.BACKEND_PREFIX_ID