Show More
@@ -571,13 +571,8 b' class bundle20(object):' | |||
|
571 | 571 | yield _pack(_fstreamparamsize, len(param)) |
|
572 | 572 | if param: |
|
573 | 573 | yield param |
|
574 | # starting compression | |
|
575 | compressor = self._compengine.compressorobj() | |
|
576 | for chunk in self._getcorechunk(): | |
|
577 | data = compressor.compress(chunk) | |
|
578 | if data: | |
|
579 | yield data | |
|
580 | yield compressor.flush() | |
|
574 | for chunk in self._compengine.compressstream(self._getcorechunk()): | |
|
575 | yield chunk | |
|
581 | 576 | |
|
582 | 577 | def _paramchunk(self): |
|
583 | 578 | """return a encoded version of all stream parameters""" |
@@ -1323,15 +1318,10 b' def writebundle(ui, cg, filename, bundle' | |||
|
1323 | 1318 | raise error.Abort(_('unknown stream compression type: %s') |
|
1324 | 1319 | % comp) |
|
1325 | 1320 | compengine = util.compengines.forbundletype(comp) |
|
1326 | compressor = compengine.compressorobj() | |
|
1327 | subchunkiter = cg.getchunks() | |
|
1328 | 1321 | def chunkiter(): |
|
1329 | 1322 | yield header |
|
1330 |
for chunk in |
|
|
1331 |
d |
|
|
1332 | if data: | |
|
1333 | yield data | |
|
1334 | yield compressor.flush() | |
|
1323 | for chunk in compengine.compressstream(cg.getchunks()): | |
|
1324 | yield chunk | |
|
1335 | 1325 | chunkiter = chunkiter() |
|
1336 | 1326 | |
|
1337 | 1327 | # parse the changegroup data, otherwise we will block |
General Comments 0
You need to be logged in to leave comments.
Login now