Synnefo

#

# Copyright (c) 2010 Greek Research and Technology Network

#

A daemon to monitor the Ganeti job queue and publish job progress

and Ganeti VM state notifications over a 0mq PUB endpoint.

import daemon.pidlockfile

from signal import signal, SIGINT, SIGTERM

from threading import Thread, Event, currentThread

from ganeti import serializer

class JobFileHandler(pyinotify.ProcessEvent):

            pyinotify.ProcessEvent.__init__(self)

            self.logger = logger

    def process_IN_CLOSE_WRITE(self, event):

        jobfile = os.path.join(event.path, event.name)

                msg["message"] = logmsg

            self.logger.debug("PUSHing msg: %s", json.dumps(msg))

handler_logger = None

def fatal_signal_handler(signum, frame):

#    signal(SIGTERM, fatal_signal_handler)

    #Init connection to RabbitMQ

                            userid=settings.RABBIT_USERNAME,

                            password=settings.RABBIT_PASSWORD,

                            virtual_host=settings.RABBIT_VHOST)

    # Monitor the Ganeti job queue, create and push notifications

    wm = pyinotify.WatchManager()

    mask = pyinotify.EventsCodes.ALL_FLAGS["IN_CLOSE_WRITE"]

    notifier = pyinotify.Notifier(wm, handler)

    try:

    finally:

        # destroy the inotify's instance on this interrupt (stop monitoring)

        notifier.stop()

        raise

if __name__ == "__main__":