/lib/http/__init__.py - Diff - snf-ganeti - Greek Research and Technology Network's projects

Revision aea0ed67 lib/http/init.py

         return serializer.LoadJson(data)
     def WaitForSocketCondition(poller, sock, event, timeout):
     def WaitForSocketCondition(sock, event, timeout):
       """Waits for a condition to occur on the socket.
       @type poller: select.Poller
       @param poller: Poller object as created by select.poll()
       @type sock: socket
       @param sock: Wait for events on this socket
       @type event: int
-...
         # Poller object expects milliseconds
         timeout *= 1000
       poller = select.poll()
       poller.register(sock, event)
       try:
         while True:
-...
         poller.unregister(sock)
     def SocketOperation(poller, sock, op, arg1, timeout):
     def SocketOperation(sock, op, arg1, timeout):
       """Wrapper around socket functions.
       This function abstracts error handling for socket operations, especially
       for the complicated interaction with OpenSSL.
       @type poller: select.Poller
       @param poller: Poller object as created by select.poll()
       @type sock: socket
       @param sock: Socket for the operation
       @type op: int
-...
           else:
             wait_for_event = event_poll
           event = WaitForSocketCondition(poller, sock, wait_for_event, timeout)
           event = WaitForSocketCondition(sock, wait_for_event, timeout)
           if event is None:
             raise HttpSocketTimeout()
-...
           raise
     def ShutdownConnection(poller, sock, close_timeout, write_timeout, msgreader,
                            force):
     def ShutdownConnection(sock, close_timeout, write_timeout, msgreader, force):
       """Closes the connection.
       @type poller: select.Poller
       @param poller: Poller object as created by select.poll()
       @type sock: socket
       @param sock: Socket to be shut down
       @type close_timeout: float
-...
                     for peer
       """
       poller = select.poll()
       #print msgreader.peer_will_close, force
       if msgreader and msgreader.peer_will_close and not force:
         # Wait for peer to close
         try:
           # Check whether it's actually closed
           if not SocketOperation(poller, sock, SOCKOP_RECV, 1, close_timeout):
           if not SocketOperation(sock, SOCKOP_RECV, 1, close_timeout):
             return
         except (socket.error, HttpError, HttpSocketTimeout):
           # Ignore errors at this stage
-...
       # Close the connection from our side
       try:
         # We don't care about the return value, see NOTES in SSL_shutdown(3).
         SocketOperation(poller, sock, SOCKOP_SHUTDOWN, socket.SHUT_RDWR,
         SocketOperation(sock, SOCKOP_SHUTDOWN, socket.SHUT_RDWR,
                         write_timeout)
       except HttpSocketTimeout:
         raise HttpError("Timeout while shutting down connection")
-...
           raise HttpError("Error while shutting down connection: %s" % err)
     def Handshake(poller, sock, write_timeout):
     def Handshake(sock, write_timeout):
       """Shakes peer's hands.
       @type poller: select.Poller
       @param poller: Poller object as created by select.poll()
       @type sock: socket
       @param sock: Socket to be shut down
       @type write_timeout: float
-...
       """
       try:
         return SocketOperation(poller, sock, SOCKOP_HANDSHAKE, None, write_timeout)
         return SocketOperation(sock, SOCKOP_HANDSHAKE, None, write_timeout)
       except HttpSocketTimeout:
         raise HttpError("Timeout during SSL handshake")
       except socket.error, err:
-...
         buf = self._FormatMessage()
         poller = select.poll()
         pos = 0
         end = len(buf)
         while pos < end:
           # Send only SOCK_BUF_SIZE bytes at a time
           data = buf[pos:(pos + SOCK_BUF_SIZE)]
           sent = SocketOperation(poller, sock, SOCKOP_SEND, data,
                                  write_timeout)
           sent = SocketOperation(sock, SOCKOP_SEND, data, write_timeout)
           # Remove sent bytes
           pos += sent
-...
         self.sock = sock
         self.msg = msg
         self.poller = select.poll()
         self.start_line_buffer = None
         self.header_buffer = StringIO()
         self.body_buffer = StringIO()
-...
         while self.parser_status != self.PS_COMPLETE:
           # TODO: Don't read more than necessary (Content-Length), otherwise
           # data might be lost and/or an error could occur
           data = SocketOperation(self.poller, sock, SOCKOP_RECV, SOCK_BUF_SIZE,
                                  read_timeout)
           data = SocketOperation(sock, SOCKOP_RECV, SOCK_BUF_SIZE, read_timeout)
           if data:
             buf += data

Also available in: Unified diff

Synnefo » snf-ganeti

Revision aea0ed67 lib/http/__init__.py

Revision aea0ed67 lib/http/init.py