Show More
@@ -530,14 +530,8 b' class bundle20(object):' | |||
|
530 | 530 | yield _pack(_fstreamparamsize, len(param)) |
|
531 | 531 | if param: |
|
532 | 532 | yield param |
|
533 | ||
|
534 | outdebug(self.ui, 'start of parts') | |
|
535 | for part in self._parts: | |
|
536 | outdebug(self.ui, 'bundle part: "%s"' % part.type) | |
|
537 | for chunk in part.getchunks(ui=self.ui): | |
|
538 | yield chunk | |
|
539 | outdebug(self.ui, 'end of bundle') | |
|
540 | yield _pack(_fpartheadersize, 0) | |
|
533 | for chunk in self._getcorechunk(): | |
|
534 | yield chunk | |
|
541 | 535 | |
|
542 | 536 | def _paramchunk(self): |
|
543 | 537 | """return a encoded version of all stream parameters""" |
@@ -550,6 +544,19 b' class bundle20(object):' | |||
|
550 | 544 | blocks.append(par) |
|
551 | 545 | return ' '.join(blocks) |
|
552 | 546 | |
|
547 | def _getcorechunk(self): | |
|
548 | """yield chunk for the core part of the bundle | |
|
549 | ||
|
550 | (all but headers and parameters)""" | |
|
551 | outdebug(self.ui, 'start of parts') | |
|
552 | for part in self._parts: | |
|
553 | outdebug(self.ui, 'bundle part: "%s"' % part.type) | |
|
554 | for chunk in part.getchunks(ui=self.ui): | |
|
555 | yield chunk | |
|
556 | outdebug(self.ui, 'end of bundle') | |
|
557 | yield _pack(_fpartheadersize, 0) | |
|
558 | ||
|
559 | ||
|
553 | 560 | def salvageoutput(self): |
|
554 | 561 | """return a list with a copy of all output parts in the bundle |
|
555 | 562 |
General Comments 0
You need to be logged in to leave comments.
Login now