Synnefo » snf-ganeti » ganeti-local

    self.port = port

    self.processor = processor

    self.bind((bind_address, port))

  # this method is overriding a daemon.AsyncUDPSocket method

  def handle_datagram(self, payload_in, ip, port):

    # IN_IGNORED event from inotify, because of the file removal (which is

    # contextual with the replacement). In such a case we need to create

    # another watcher for the "new" file.

    self.watch_handle = None

    try:

      # going to realod the file after setting up the new watch.

      self.callback(False)

    except errors.ConfdFatalError, err:

      sys.exit(constants.EXIT_FAILURE)

    except:

      # we need to catch any exception here, log it, but proceed, because even

    # usually happen in Ganeti, as the config file is normally replaced by a

    # new one, at filesystem level, rather than actually modified (see

    # utils.WriteFile)

    try:

      self.callback(True)

    except errors.ConfdFatalError, err:

      sys.exit(constants.EXIT_FAILURE)

    except:

      # we need to catch any exception here, log it, but proceed, because even

      logging.error("Unexpected exception", exc_info=True)

  def process_default(self, event):

class ConfdConfigurationReloader(object):