738
740
paths = list(relpaths)
739
741
return set([self._mapper.unmap(path) for path in paths])
744
class InterWeaveRepo(InterSameDataRepository):
745
"""Optimised code paths between Weave based repositories.
747
This should be in bzrlib/repofmt/weaverepo.py but we have not yet
748
implemented lazy inter-object optimisation.
752
def _get_repo_format_to_test(self):
753
return RepositoryFormat7()
756
def is_compatible(source, target):
757
"""Be compatible with known Weave formats.
759
We don't test for the stores being of specific types because that
760
could lead to confusing results, and there is no need to be
764
return (isinstance(source._format, (RepositoryFormat5,
766
RepositoryFormat7)) and
767
isinstance(target._format, (RepositoryFormat5,
770
except AttributeError:
774
def copy_content(self, revision_id=None):
775
"""See InterRepository.copy_content()."""
776
# weave specific optimised path:
778
self.target.set_make_working_trees(self.source.make_working_trees())
779
except (errors.RepositoryUpgradeRequired, NotImplemented):
782
if self.source._transport.listable():
783
pb = ui.ui_factory.nested_progress_bar()
785
self.target.texts.insert_record_stream(
786
self.source.texts.get_record_stream(
787
self.source.texts.keys(), 'topological', False))
788
pb.update('Copying inventory', 0, 1)
789
self.target.inventories.insert_record_stream(
790
self.source.inventories.get_record_stream(
791
self.source.inventories.keys(), 'topological', False))
792
self.target.signatures.insert_record_stream(
793
self.source.signatures.get_record_stream(
794
self.source.signatures.keys(),
796
self.target.revisions.insert_record_stream(
797
self.source.revisions.get_record_stream(
798
self.source.revisions.keys(),
799
'topological', True))
803
self.target.fetch(self.source, revision_id=revision_id)
806
def search_missing_revision_ids(self, revision_id=None, find_ghosts=True):
807
"""See InterRepository.missing_revision_ids()."""
808
# we want all revisions to satisfy revision_id in source.
809
# but we don't want to stat every file here and there.
810
# we want then, all revisions other needs to satisfy revision_id
811
# checked, but not those that we have locally.
812
# so the first thing is to get a subset of the revisions to
813
# satisfy revision_id in source, and then eliminate those that
814
# we do already have.
815
# this is slow on high latency connection to self, but as this
816
# disk format scales terribly for push anyway due to rewriting
817
# inventory.weave, this is considered acceptable.
819
if revision_id is not None:
820
source_ids = self.source.get_ancestry(revision_id)
821
if source_ids[0] is not None:
822
raise AssertionError()
825
source_ids = self.source._all_possible_ids()
826
source_ids_set = set(source_ids)
827
# source_ids is the worst possible case we may need to pull.
828
# now we want to filter source_ids against what we actually
829
# have in target, but don't try to check for existence where we know
830
# we do not have a revision as that would be pointless.
831
target_ids = set(self.target._all_possible_ids())
832
possibly_present_revisions = target_ids.intersection(source_ids_set)
833
actually_present_revisions = set(
834
self.target._eliminate_revisions_not_present(possibly_present_revisions))
835
required_revisions = source_ids_set.difference(actually_present_revisions)
836
if revision_id is not None:
837
# we used get_ancestry to determine source_ids then we are assured all
838
# revisions referenced are present as they are installed in topological order.
839
# and the tip revision was validated by get_ancestry.
840
result_set = required_revisions
842
# if we just grabbed the possibly available ids, then
843
# we only have an estimate of whats available and need to validate
844
# that against the revision records.
846
self.source._eliminate_revisions_not_present(required_revisions))
847
return self.source.revision_ids_to_search_result(result_set)
741
850
_legacy_formats = [RepositoryFormat4(),
742
851
RepositoryFormat5(),
743
852
RepositoryFormat6()]
855
InterRepository.register_optimiser(InterWeaveRepo)
added
removed
bzrlib/repofmt/weaverepo.py
