Synnefo

def get_backends(backend=None):

    if backend:

        return [backend]

    return Backend.objects.filter(offline=False)

from django.core.management.base import BaseCommand, CommandError

from synnefo.db.models import VirtualMachine, Network, pooled_rapi_client

class Command(BaseCommand):

                    dest='fix_unsynced_nics', default=False,

                    help='Fix unsynced nics between DB and Ganeti'),

        make_option('--fix-all', action='store_true', dest='fix_all',

    def _process_args(self, options):

        keys_detect = [k for k in options.keys() if k.startswith('detect_')]

    def handle(self, **options):

        verbosity = int(options['verbosity'])

        self._process_args(options)

        #

        # Detect problems

                "servers in the DB:" % len(stale)

            for vm in VirtualMachine.objects.filter(pk__in=stale):

                event_time = datetime.datetime.now()

                    opcode='OP_INSTANCE_REMOVE', status='success',

                    logmsg='Reconciliation: simulated Ganeti event')

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

                opcode = "OP_INSTANCE_REBOOT" if ganeti_up \

                         else "OP_INSTANCE_SHUTDOWN"

                event_time = datetime.datetime.now()

                    opcode=opcode, status='success',

                    logmsg='Reconciliation: simulated Ganeti event')

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

            for id in build_errors:

                vm = VirtualMachine.objects.get(pk=id)

                event_time = datetime.datetime.now()

                    opcode="OP_INSTANCE_CREATE", status='error',

                    logmsg='Reconciliation: simulated Ganeti event')

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

                        print 'Network of nic %d of vm %s is None. ' \

                              'Can not reconcile' % (i, vm.backend_vm_id)

                event_time = datetime.datetime.now()

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

from synnefo.db.models import (VirtualMachine, pooled_rapi_client)

from synnefo.logic.rapi import GanetiApiError

from synnefo.logic import utils

    return failed

    return dict(map(lambda x: (x.id, x.operstate), vms))

    snf_instances = {}

    snf_nics = {}

#

# Nics

#

    """Get network interfaces for each ganeti instance.

    """

    prefix = settings.BACKEND_PREFIX_ID

    snf_instances_nics = {}

    return nics

    """Get network interfaces for each vm in DB.

    """

    instances_nics = {}

    for instance in instances:

        nics = {}