equal
deleted
inserted
replaced
470 self.addpart(part) |
470 self.addpart(part) |
471 return part |
471 return part |
472 |
472 |
473 # methods used to generate the bundle2 stream |
473 # methods used to generate the bundle2 stream |
474 def getchunks(self): |
474 def getchunks(self): |
|
475 if self.ui.debugflag: |
|
476 msg = ['bundle2-output-bundle: "%s",' % self._magicstring] |
|
477 if self._params: |
|
478 msg.append(' (%i params)' % len(self._params)) |
|
479 msg.append(' %i parts total\n' % len(self._parts)) |
|
480 self.ui.debug(''.join(msg)) |
475 outdebug(self.ui, 'start emission of %s stream' % self._magicstring) |
481 outdebug(self.ui, 'start emission of %s stream' % self._magicstring) |
476 yield self._magicstring |
482 yield self._magicstring |
477 param = self._paramchunk() |
483 param = self._paramchunk() |
478 outdebug(self.ui, 'bundle parameter: %s' % param) |
484 outdebug(self.ui, 'bundle parameter: %s' % param) |
479 yield _pack(_fstreamparamsize, len(param)) |
485 yield _pack(_fstreamparamsize, len(param)) |