Synnefo » snf-ganeti

class ClientRqHandler(SocketServer.BaseRequestHandler):

  """Client handler"""

  READ_SIZE = 4096

  def setup(self):

      data = self.request.recv(self.READ_SIZE)

      if not data:

        return None

      self._buffer = new_msgs.pop()

      self._msgs.extend(new_msgs)

    return self._msgs.popleft()

  def send_message(self, msg):

    #print "sending", msg

    # TODO: sendall is not guaranteed to send everything

class ClientOps:

DEV_CONSOLE = "/dev/console"

# one of 'no', 'yes', 'only'

SYSLOG_USAGE = _autoconf.SYSLOG_USAGE

SYSLOG_NO = "no"

INISECT_BEP = "backend"

# dynamic device modification

DDM_ADD = 'add'

DDM_REMOVE = 'remove'

  """

    """Constructor for the Client class.

    Arguments:

      - address: a valid address the the used transport class

      - timeout: a list of timeouts, to be used on connect and read/write

    There are two timeouts used since we might want to wait for a long

    time for a response, but the connect timeout should be lower.

    self._buffer = ""

    self._msgs = collections.deque()

    try:

      self.socket = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)

    This just sends a message and doesn't wait for the response.

    """

      raise EncodingError("Message terminator found in payload")

    self._CheckSocket()

    try:

      # TODO: sendall is not guaranteed to send everything

    except socket.timeout, err:

      raise TimeoutError("Sending timeout: %s" % str(err))

        break

      if not data:

        raise ConnectionClosedError("Connection closed while reading")

      self._buffer = new_msgs.pop()

      self._msgs.extend(new_msgs)

    return self._msgs.popleft()