← Back to branch summary

~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/smart/repository.py

  • Committer: Patch Queue Manager
  • Date: 2012-09-19 08:27:25 UTC
  • mfrom: (6562.1.1 2.6-merge-up-2.5)
  • Revision ID: pqm@pqm.ubuntu.com-20120919082725-dzvmca37zj5xx2hh
(jam) Merge bzr-2.5.2-dev into bzr trunk to get the ConnectionReset
        fixes.

Show diffs side-by-side

added added

removed removed

Lines of Context:
bzrlib/smart/repository.py
736
736
        self.seed_state()
737
737
        pb = ui.ui_factory.nested_progress_bar()
738
738
        rc = self._record_counter
739
 
        # Make and consume sub generators, one per substream type:
740
 
        while self.first_bytes is not None:
741
 
            substream = NetworkRecordStream(self.iter_substream_bytes())
742
 
            # after substream is fully consumed, self.current_type is set to
743
 
            # the next type, and self.first_bytes is set to the matching bytes.
744
 
            yield self.current_type, wrap_and_count(pb, rc, substream)
745
 
        if rc:
746
 
            pb.update('Done', rc.max, rc.max)
747
 
        pb.finished()
 
739
        try:
 
740
            # Make and consume sub generators, one per substream type:
 
741
            while self.first_bytes is not None:
 
742
                substream = NetworkRecordStream(self.iter_substream_bytes())
 
743
                # after substream is fully consumed, self.current_type is set
 
744
                # to the next type, and self.first_bytes is set to the matching
 
745
                # bytes.
 
746
                yield self.current_type, wrap_and_count(pb, rc, substream)
 
747
        finally:
 
748
            if rc:
 
749
                pb.update('Done', rc.max, rc.max)
 
750
            pb.finished()
748
751
 
749
752
    def seed_state(self):
750
753
        """Prepare the _ByteStreamDecoder to decode from the pack stream."""