Synnefo » snf-ganeti

    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):

    """

    arch_count, left_count = client.AutoArchiveJobs(age)

  def CheckDisks(self, notepad):

    """Check all nodes for restarted ones.

      network_link = None

      mode = constants.CONFD_REQQ_IP

    else:

      return QUERY_ARGUMENT_ERROR

    pnodes_list = []

    for instance_ip in instances_list:

      if not isinstance(instance_ip, basestring):

        return QUERY_ARGUMENT_ERROR

      instance = self.reader.GetInstanceByLinkIp(instance_ip, network_link)

      if not instance:

        pnodes_list.append(QUERY_UNKNOWN_ENTRY_ERROR)

        continue

      pnode = self.reader.GetInstancePrimaryNode(instance)

      if not pnode:

        logging.error("Instance '%s' doesn't have an associated primary"

        pnodes_list.append(QUERY_INTERNAL_ERROR)

        continue

      pnode_primary_ip = self.reader.GetNodePrimaryIp(pnode)

      if not pnode_primary_ip:

        logging.error("Primary node '%s' doesn't have an associated"

        pnodes_list.append(QUERY_INTERNAL_ERROR)

        continue

      pnodes_list.append((constants.CONFD_REPL_STATUS_OK, pnode_primary_ip))

    if mode == constants.CONFD_REQQ_IP:

      return pnodes_list[0]

      payload_out = self.PackReply(reply, rsalt)

      return payload_out

    except errors.ConfdRequestError, err:

      return None

  def ExtractRequest(self, payload):

    """

    current_time = time.time()

    try:

      (message, salt) = serializer.LoadSigned(payload, self.hmac_key)

    except errors.SignatureError, err:

    @return: tuple of reply and salt to add to the signature

    """

    if request.protocol != constants.CONFD_PROTOCOL_VERSION:

      msg = "wrong protocol version %d" % request.protocol

      raise errors.ConfdRequestError(msg)

              serial=self.reader.GetConfigSerialNo(),

              )

    return (reply, rsalt)

            vnc_arg = '%s:%d' % (vnc_bind_address, display)

        else:

          logging.error("Network port is not a valid VNC display (%d < %d)."

          vnc_arg = 'none'

        # Only allow tls and other option when not binding to a file, for now.

          raise errors.HypervisorError("Migration %s at the kvm level" %

                                       status)

        else:

          time.sleep(2)

    utils.KillProcess(pid)

    if vrfy:

      logging.error("Errors after conversion:")

      for item in vrfy:

    del cfg

    logging.info("File loaded successfully")