Show More
@@ -828,7 +828,11 b' class unbundle20(unpackermixin):' | |||||
828 | while headerblock is not None: |
|
828 | while headerblock is not None: | |
829 | part = unbundlepart(self.ui, headerblock, self._fp) |
|
829 | part = unbundlepart(self.ui, headerblock, self._fp) | |
830 | yield part |
|
830 | yield part | |
|
831 | # Seek to the end of the part to force it's consumption so the next | |||
|
832 | # part can be read. But then seek back to the beginning so the | |||
|
833 | # code consuming this generator has a part that starts at 0. | |||
831 | part.seek(0, 2) |
|
834 | part.seek(0, 2) | |
|
835 | part.seek(0) | |||
832 | headerblock = self._readpartheader() |
|
836 | headerblock = self._readpartheader() | |
833 | indebug(self.ui, 'end of bundle2 stream') |
|
837 | indebug(self.ui, 'end of bundle2 stream') | |
834 |
|
838 |
@@ -301,7 +301,6 b' class bundlerepository(localrepo.localre' | |||||
301 |
|
301 | |||
302 | if cgstream is None: |
|
302 | if cgstream is None: | |
303 | raise error.Abort(_('No changegroups found')) |
|
303 | raise error.Abort(_('No changegroups found')) | |
304 | cgstream.seek(0) |
|
|||
305 |
|
304 | |||
306 | self.bundle = changegroup.getunbundler(version, cgstream, 'UN') |
|
305 | self.bundle = changegroup.getunbundler(version, cgstream, 'UN') | |
307 |
|
306 |
General Comments 0
You need to be logged in to leave comments.
Login now