| durin42 |
| hg-reviewers |
This is part of the standard I/O interface. It is used by the framing
protocol. So we need to implement it so frames can be decoded.
| Lint Skipped |
| Unit Tests Skipped |
| Path | Packages | |||
|---|---|---|---|---|
| M | mercurial/keepalive.py (10 lines) |
| if urllibcompat.hasdata(req): | if urllibcompat.hasdata(req): | ||||
| h.send(data) | h.send(data) | ||||
| class HTTPHandler(KeepAliveHandler, urlreq.httphandler): | class HTTPHandler(KeepAliveHandler, urlreq.httphandler): | ||||
| pass | pass | ||||
| class HTTPResponse(httplib.HTTPResponse): | class HTTPResponse(httplib.HTTPResponse): | ||||
| # we need to subclass HTTPResponse in order to | # we need to subclass HTTPResponse in order to | ||||
| # 1) add readline() and readlines() methods | # 1) add readline(), readlines(), and readinto() methods | ||||
| # 2) add close_connection() methods | # 2) add close_connection() methods | ||||
| # 3) add info() and geturl() methods | # 3) add info() and geturl() methods | ||||
| # in order to add readline(), read must be modified to deal with a | # in order to add readline(), read must be modified to deal with a | ||||
| # buffer. example: readline must read a buffer and then spit back | # buffer. example: readline must read a buffer and then spit back | ||||
| # one line at a time. The only real alternative is to read one | # one line at a time. The only real alternative is to read one | ||||
| # BYTE at a time (ick). Once something has been read, it can't be | # BYTE at a time (ick). Once something has been read, it can't be | ||||
| # put back (ok, maybe it can, but that's even uglier than this), | # put back (ok, maybe it can, but that's even uglier than this), | ||||
| if not line: | if not line: | ||||
| break | break | ||||
| list.append(line) | list.append(line) | ||||
| total += len(line) | total += len(line) | ||||
| if sizehint and total >= sizehint: | if sizehint and total >= sizehint: | ||||
| break | break | ||||
| return list | return list | ||||
| def readinto(self, dest): | |||||
| res = self.read(len(dest)) | |||||
| if not res: | |||||
| return 0 | |||||
| dest[0:len(res)] = res | |||||
| return len(res) | |||||
| def safesend(self, str): | def safesend(self, str): | ||||
| """Send `str' to the server. | """Send `str' to the server. | ||||
| Shamelessly ripped off from httplib to patch a bad behavior. | Shamelessly ripped off from httplib to patch a bad behavior. | ||||
| """ | """ | ||||
| # _broken_pipe_resp is an attribute we set in this function | # _broken_pipe_resp is an attribute we set in this function | ||||
| # if the socket is closed while we're sending data but | # if the socket is closed while we're sending data but | ||||
| # the server sent us a response before hanging up. | # the server sent us a response before hanging up. | ||||