Synnefo » snf-ganeti

from ganeti import errors

from ganeti import daemon

from ganeti import netutils

class ConfdAsyncUDPServer(daemon.AsyncUDPSocket):

    self.last_notification = 0

    # Asyncronous inotify handler for config changes

    self.wm = pyinotify.WatchManager()

    self.inotify_handler = asyncnotifier.SingleFileEventHandler(self.wm,

                                                                self.OnInotify,

  # TODO: collapse HMAC daemons handling in daemons GenericMain, when we'll

  # have more than one.

    sys.exit(constants.EXIT_FAILURE)

  # TODO: once we have a cluster param specifying the address family

from ganeti import objects

from ganeti import query

from ganeti import runtime

CLIENT_REQUEST_WORKERS = 16

  """

  if until is None:

  else:

                    data="%d\n" % (until, ))

  return until

  """

  # This is safe to do as the pid file guarantees against

  # concurrent execution.

  mainloop = daemon.Mainloop()

  return (mainloop, master)

    finally:

      rpc.Shutdown()

  finally:

  logging.info("Clean master daemon shutdown")

from ganeti import storage

from ganeti import serializer

from ganeti import netutils

import ganeti.http.server # pylint: disable=W0611

    Note that as opposed to export_info, which may query data about an

    export in any path, this only queries the standard Ganeti path

    """

    return backend.ListExports()

                    default=True, action="store_false")

  daemon.GenericMain(constants.NODED, parser, CheckNoded, PrepNoded, ExecNoded,

                     console_logging=True)

from ganeti import serializer

from ganeti import compat

from ganeti import utils

from ganeti.rapi import connector

import ganeti.http.auth   # pylint: disable=W0611

  handler = RemoteApiHandler(users.Get)

  # Setup file watcher (it'll be driven by asyncore)

  server = \

    http.server.HttpServer(mainloop, options.bind_address, options.port,

                                 constants.RELEASE_VERSION)

  daemon.GenericMain(constants.RAPI, parser, CheckRapi, PrepRapi, ExecRapi,