Show More
@@ -126,6 +126,13 b' def wirereposetup(ui, repo):' | |||||
126 | # SSH streams will block if reading more than length |
|
126 | # SSH streams will block if reading more than length | |
127 | for chunk in util.filechunkiter(stream, 128 * 1024, length): |
|
127 | for chunk in util.filechunkiter(stream, 128 * 1024, length): | |
128 | yield chunk |
|
128 | yield chunk | |
|
129 | # HTTP streams must hit the end to process the last empty | |||
|
130 | # chunk of Chunked-Encoding so the connection can be reused. | |||
|
131 | if issubclass(self.__class__, httppeer.httppeer): | |||
|
132 | chunk = stream.read(1) | |||
|
133 | if chunk: | |||
|
134 | self._abort(error.ResponseError(_("unexpected response:"), | |||
|
135 | chunk)) | |||
129 |
|
136 | |||
130 | @batchable |
|
137 | @batchable | |
131 | def statlfile(self, sha): |
|
138 | def statlfile(self, sha): |
General Comments 0
You need to be logged in to leave comments.
Login now