Synnefo

                    dest='fix_build_errors', default=False,

                    help='Fix (remove) instances with build errors'),

        make_option('--fix-unsynced-nics', action='store_true',

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

                    default=False, help='Enable all --fix-* arguments'),

        make_option('--backend-id', default=None, dest='backend-id',

        if options['detect_build_errors']:

            build_errors = reconciliation.instances_with_build_errors(D, G)

            if len(build_errors) > 0:

                print "    " + "\n    ".join(

                    ["%d" % x for x in build_errors])

            elif verbosity == 2:

                if not nics:

                    print ''.ljust(18) + 'None'

                for index, info in nics.items():

            unsynced_nics = reconciliation.unsynced_nics(DBNics, GNics)

            if len(unsynced_nics) > 0:

                for id, nics in unsynced_nics.items():

                    print ''.ljust(2) + '%6d:' % id

                    print ''.ljust(8) + '%8s:' % 'DB'

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

        if options['fix_build_errors'] and len(build_errors) > 0:

            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"

        if options['fix_unsynced_nics'] and len(unsynced_nics) > 0:

            print >> sys.stderr, "Setting the nics of %d out-of-sync VMs:" % \

            for id, nics in unsynced_nics.items():

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

                nics = nics[1]  # Ganeti nics

        if env.startswith("GANETI_INSTANCE_NIC"):

            s = env.replace("GANETI_INSTANCE_NIC", "").split('_', 1)

            if len(s) == 2 and s[0].isdigit() and\

                index = int(s[0])

                key = key_to_attr[s[1]]

    ganeti_nic_count = int(environ['GANETI_INSTANCE_NIC_COUNT'])

    if len(indexes) != ganeti_nic_count:

        logger.error("I have %d NICs, Ganeti says number of NICs is %d",

        raise Exception("Inconsistent number of NICs in Ganeti environment")

    if indexes != range(0, len(indexes)):

        raise Exception("Unexpected inconsistency in the Ganeti environment")

    # Construct the notification

    def run(self):

        if self.on_master():

            notifs = []

            self.publish_msgs(notifs)

        op = os.environ['GANETI_HOOKS_PATH']

        phase = os.environ['GANETI_HOOKS_PHASE']

    except KeyError:

    prefix = instance.split('-')[0]

    # FIXME: The hooks should only run for Synnefo instances.

    # Uncomment the following lines for a shared Ganeti deployment.

    # Currently, the following code is commented out because multiple

    #if not instance.startswith(settings.BACKEND_PREFIX_ID):

    #    logger.warning("Ignoring non-Synnefo instance %s", instance)

    #    return 0

    try:

        hook = hooks[(op, phase)](logger, os.environ, instance, prefix)

    except KeyError:

    return hook.run()

if __name__ == "__main__":