734 # methods used to generates the bundle2 stream |
734 # methods used to generates the bundle2 stream |
735 def getchunks(self, ui): |
735 def getchunks(self, ui): |
736 if self._generated is not None: |
736 if self._generated is not None: |
737 raise RuntimeError('part can only be consumed once') |
737 raise RuntimeError('part can only be consumed once') |
738 self._generated = False |
738 self._generated = False |
|
739 |
|
740 if ui.debugflag: |
|
741 msg = ['bundle2-output-part: "%s"' % self.type] |
|
742 if not self.mandatory: |
|
743 msg.append(' (advisory)') |
|
744 nbmp = len(self.mandatoryparams) |
|
745 nbap = len(self.advisoryparams) |
|
746 if nbmp or nbap: |
|
747 msg.append(' (params:') |
|
748 if nbmp: |
|
749 msg.append(' %i mandatory' % nbmp) |
|
750 if nbap: |
|
751 msg.append(' %i advisory' % nbmp) |
|
752 msg.append(')') |
|
753 if not self.data: |
|
754 msg.append(' empty payload') |
|
755 elif util.safehasattr(self.data, 'next'): |
|
756 msg.append(' streamed payload') |
|
757 else: |
|
758 msg.append(' %i bytes payload' % len(self.data)) |
|
759 msg.append('\n') |
|
760 ui.debug(''.join(msg)) |
|
761 |
739 #### header |
762 #### header |
740 if self.mandatory: |
763 if self.mandatory: |
741 parttype = self.type.upper() |
764 parttype = self.type.upper() |
742 else: |
765 else: |
743 parttype = self.type.lower() |
766 parttype = self.type.lower() |