Synnefo

"""

from django.core.management import setup_environ

import sys

import os

path = os.path.normpath(os.path.join(os.getcwd(), '..'))

from synnefo import settings

setup_environ(settings)

import logging

import time

# Take care of differences between python-daemon versions.

try:

except:

    from daemon import pidlockfile

from synnefo.logic import callbacks

from synnefo.util.dictconfig import dictConfig

    # Queue                   # Exchange                # RouteKey              # Handler

    (QUEUE_GANETI_EVENTS_OP,  settings.EXCHANGE_GANETI, DB_HANDLER_KEY_OP,      'update_db'),

    (QUEUE_GANETI_EVENTS_NET, settings.EXCHANGE_GANETI, DB_HANDLER_KEY_NET,     'update_net'),

    ]

    if settings.DEBUG is True:

    """"Catch exit signal in parent process and forward it to children."""

    global children

    log.info("Caught signal %d, sending SIGTERM to children %s",

    [os.kill(pid, SIGTERM) for pid in children]

def parse_arguments(args):

    from optparse import OptionParser

    parser = OptionParser()

    parser.add_option("-d", "--debug", action="store_true", default=False,

                      dest="debug", help="Enable debug mode")

    global children

    # Create pidfile,

    log.info("Became a daemon")

def main():

    dictConfig(settings.DISPATCHER_LOGGING)

    global log

    # Init the global variables containing the queues

    _init_queues()

        if stream and hasattr(stream, 'fileno'):

            files_preserve.append(handler.stream)

        files_preserve=files_preserve,

        umask=022)

import pyinotify

import daemon

import daemon.pidlockfile

from signal import signal, SIGINT, SIGTERM

from ganeti import utils

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

    # Initialize logger

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

    logger.addHandler(handler)

    handler_logger = logger

    # Become a daemon:

    # Redirect stdout and stderr to handler.stream to catch

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

            stdout=handler.stream,

            stderr=handler.stream,

            files_preserve=[handler.stream])

    logger.info("Became a daemon")

    # Catch signals to ensure graceful shutdown