| Alphare |
| hg-reviewers |
| Automatic diff as part of commit; lint not applicable. |
| Automatic diff as part of commit; unit tests not applicable. |
| Path | Packages | |||
|---|---|---|---|---|
| M | mercurial/keepalive.py (6 lines) |
| # the buffer. | # the buffer. | ||||
| # the read method wraps the original to accommodate buffering, | # the read method wraps the original to accommodate buffering, | ||||
| # although read() never adds to the buffer. | # although read() never adds to the buffer. | ||||
| # Both readline and readlines have been stolen with almost no | # Both readline and readlines have been stolen with almost no | ||||
| # modification from socket.py | # modification from socket.py | ||||
| def __init__(self, sock, debuglevel=0, strict=0, method=None): | def __init__(self, sock, debuglevel=0, strict=0, method=None): | ||||
| extrakw = {} | |||||
| if not pycompat.ispy3: | |||||
| extrakw['strict'] = True | |||||
| extrakw['buffering'] = True | |||||
| httplib.HTTPResponse.__init__( | httplib.HTTPResponse.__init__( | ||||
| self, sock, debuglevel=debuglevel, method=method, **extrakw | self, sock, debuglevel=debuglevel, method=method | ||||
| ) | ) | ||||
| self.fileno = sock.fileno | self.fileno = sock.fileno | ||||
| self.code = None | self.code = None | ||||
| self.receivedbytescount = 0 | self.receivedbytescount = 0 | ||||
| self._rbuf = b'' | self._rbuf = b'' | ||||
| self._rbufsize = 8096 | self._rbufsize = 8096 | ||||
| self._handler = None # inserted by the handler later | self._handler = None # inserted by the handler later | ||||
| self._host = None # (same) | self._host = None # (same) | ||||