comparison mercurial/httpclient/__init__.py @ 15218:c81dce8a7bb6

httpclient: update to 07d8c356f4d1 of py-nonblocking-http

This addresses a defect when the server closes the socket before
finishing a response (if it crashes, for example) first spotted in
Issue2951.

15217:42d0d4f63bf0

                logger.info('timed out with timeout of %s', self._timeout)
                raise HTTPTimeoutException('timeout reading data')
            logger.info('cl: %r body: %r', self._content_len, self._body)
        try:
            data = self.sock.recv(INCOMING_BUFFER_SIZE)
        except socket.sslerror, e:
            if e.args[0] != socket.SSL_ERROR_WANT_READ:
                raise
            logger.debug('SSL_WANT_READ in _select, should retry later')
            return True

class HTTPProxyConnectFailedException(httplib.HTTPException):
    """Connecting to the HTTP proxy failed."""

class HTTPStateError(httplib.HTTPException):
    """Invalid internal state encountered."""
# no-check-code

15218:c81dce8a7bb6

                logger.info('timed out with timeout of %s', self._timeout)
                raise HTTPTimeoutException('timeout reading data')
            logger.info('cl: %r body: %r', self._content_len, self._body)
        try:
            data = self.sock.recv(INCOMING_BUFFER_SIZE)
            # If the socket was readable and no data was read, that
            # means the socket was closed. If this isn't a
            # _CLOSE_IS_END socket, then something is wrong if we're
            # here (we shouldn't enter _select() if the response is
            # complete), so abort.
            if not data and self._content_len != _LEN_CLOSE_IS_END:
                raise HTTPRemoteClosedError(
                    'server appears to have closed the socket mid-response')
        except socket.sslerror, e:
            if e.args[0] != socket.SSL_ERROR_WANT_READ:
                raise
            logger.debug('SSL_WANT_READ in _select, should retry later')
            return True

class HTTPProxyConnectFailedException(httplib.HTTPException):
    """Connecting to the HTTP proxy failed."""


class HTTPStateError(httplib.HTTPException):
    """Invalid internal state encountered."""


class HTTPRemoteClosedError(httplib.HTTPException):
    """The server closed the remote socket in the middle of a response."""
# no-check-code