Synnefo

            instances = get_field(input, 'instances')

            if not instances or len(instances) > 1:

                # Do not publish messages for jobs with no or multiple

                return None, None

            else:

                instances = instances[0]

               'group_name':   get_field(input, 'group_name')}

        if op_id == "OP_NETWORK_SET_PARAMS":

        routekey = "ganeti.%s.event.network" % prefix_from_name(network_name)

        return msg, routekey

    #     return None, None

def find_cluster_name():

    global handler_logger

    try:

    return name

handler_logger = None

def fatal_signal_handler(signum, frame):

    global handler_logger

                        signum)

    raise SystemExit

def parse_arguments(args):

    from optparse import OptionParser

                      default="/var/log/snf-ganeti-eventd.log",

                      metavar="FILE",

                      help="Write log to FILE instead of %s" %

    parser.add_option('--pid-file', dest="pid_file",

                      default="/var/run/snf-ganeti-eventd.pid",

                      metavar='PIDFILE',

                      help="Save PID to file (default: %s)" %

    return parser.parse_args(args)

def main():

    global handler_logger

    (opts, args) = parse_arguments(sys.argv[1:])

    # Initialize logger

    lvl = logging.DEBUG if opts.debug else logging.INFO

    logger = logging.getLogger("ganeti.eventd")

    # early errors in the daemonization process [e.g., pidfile creation]

    # which will otherwise go to /dev/null.

    daemon_context = daemon.DaemonContext(

    try:

        daemon_context.open()

    except (daemon.pidlockfile.AlreadyLocked, LockTimeout):

    # Monitor the Ganeti job queue, create and push notifications

    wm = pyinotify.WatchManager()

    cluster_name = find_cluster_name()

        if res[constants.QUEUE_DIR] < 0:

            raise Exception("pyinotify add_watch returned negative descriptor")

        while True:    # loop forever

            # process the queue of events as explained above