/brz/remove-bazaar

To get this branch, use:
bzr branch http://gegoxaren.bato24.eu/bzr/brz/remove-bazaar

« back to all changes in this revision

Viewing changes to bzrlib/fetch.py

  • Committer: Robert Collins
  • Date: 2007-10-15 05:23:29 UTC
  • mfrom: (2906 +trunk)
  • mto: This revision was merged to the branch mainline in revision 2907.
  • Revision ID: robertc@robertcollins.net-20071015052329-z5458xq9q2kq72mv
Merge bzr.dev

Show diffs side-by-side

added added

removed removed

Lines of Context:
127
127
        try:
128
128
            pp.next_phase()
129
129
            revs = self._revids_to_fetch()
 
130
            if revs is None:
 
131
                return
130
132
            self._fetch_everything_for_revisions(revs, pp)
131
133
        finally:
132
134
            self.pb.clear()
133
135
 
134
136
    def _fetch_everything_for_revisions(self, revs, pp):
135
137
        """Fetch all data for the given set of revisions."""
136
 
        if revs is None:
137
 
            return
138
138
        # The first phase is "file".  We pass the progress bar for it directly
139
139
        # into item_keys_introduced_by, which has more information about how
140
140
        # that phase is progressing than we do.  Progress updates for the other
193
193
            return None
194
194
            
195
195
        try:
 
196
            # XXX: this gets the full graph on both sides, and will make sure
 
197
            # that ghosts are filled whether or not you care about them.
196
198
            return self.to_repository.missing_revision_ids(self.from_repository,
197
199
                                                           self._last_revision)
198
200
        except errors.NoSuchRevision:
397
399
 
398
400
    def _fetch_inventory_weave(self, revs, pb):
399
401
        self.helper.regenerate_inventory(revs)
 
402
 
 
403
 
 
404
class RemoteToOtherFetcher(GenericRepoFetcher):
 
405
 
 
406
    def _fetch_everything_for_revisions(self, revs, pp):
 
407
        data_stream = self.from_repository.get_data_stream(revs)
 
408
        self.to_repository.insert_data_stream(data_stream)
 
409
 
 
410