/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/repofmt/knitrepo.py

  • Committer: Martin Pool
  • Date: 2011-04-19 03:23:05 UTC
  • mto: This revision was merged to the branch mainline in revision 5802.
  • Revision ID: mbp@sourcefrog.net-20110419032305-6qzm1yo30x56dnu2
Fix slightly broken test

Show diffs side-by-side

added added

removed removed

Lines of Context:
bzrlib/repofmt/knitrepo.py
32
32
    xml7,
33
33
    )
34
34
""")
35
 
from bzrlib import (
36
 
    symbol_versioning,
37
 
    )
38
35
from bzrlib.decorators import needs_read_lock, needs_write_lock
39
36
from bzrlib.repository import (
40
37
    CommitBuilder,
 
38
    InterRepository,
 
39
    InterSameDataRepository,
 
40
    IsInWriteGroupError,
41
41
    MetaDirRepository,
42
42
    MetaDirRepositoryFormat,
43
43
    RepositoryFormat,
44
44
    RootCommitBuilder,
45
45
    )
 
46
from bzrlib import symbol_versioning
46
47
 
47
48
 
48
49
class _KnitParentsProvider(object):
210
211
    def _refresh_data(self):
211
212
        if not self.is_locked():
212
213
            return
 
214
        if self.is_in_write_group():
 
215
            raise IsInWriteGroupError(self)
213
216
        # Create a new transaction to force all knits to see the scope change.
214
217
        # This is safe because we're outside a write group.
215
218
        self.control_files._finish_transaction()
260
263
            raise errors.BzrCheckError(
261
264
                "Revision knit has inconsistent parents.")
262
265
 
263
 
    def revision_graph_can_have_wrong_parents(self):
264
 
        # The revision.kndx could potentially claim a revision has a different
265
 
        # parent to the revision text.
266
 
        return True
267
 
 
268
266
 
269
267
class RepositoryFormatKnit(MetaDirRepositoryFormat):
270
268
    """Bzr repository knit format (generalized).
301
299
    _fetch_order = 'topological'
302
300
    _fetch_uses_deltas = True
303
301
    fast_deltas = False
 
302
    supports_funky_characters = True
 
303
    supports_full_versioned_files = True
 
304
    # The revision.kndx could potentially claim a revision has a different
 
305
    # parent to the revision text.
 
306
    revision_graph_can_have_wrong_parents = True
304
307
 
305
308
    def _get_inventories(self, repo_transport, repo, name='inventory'):
306
309
        mapper = versionedfile.ConstantMapper(name)
507
510
    def get_format_description(self):
508
511
        """See RepositoryFormat.get_format_description()."""
509
512
        return "Knit repository format 4"
 
513
 
 
514
 
 
515
class InterKnitRepo(InterSameDataRepository):
 
516
    """Optimised code paths between Knit based repositories."""
 
517
 
 
518
    @classmethod
 
519
    def _get_repo_format_to_test(self):
 
520
        return RepositoryFormatKnit1()
 
521
 
 
522
    @staticmethod
 
523
    def is_compatible(source, target):
 
524
        """Be compatible with known Knit formats.
 
525
 
 
526
        We don't test for the stores being of specific types because that
 
527
        could lead to confusing results, and there is no need to be
 
528
        overly general.
 
529
        """
 
530
        try:
 
531
            are_knits = (isinstance(source._format, RepositoryFormatKnit) and
 
532
                isinstance(target._format, RepositoryFormatKnit))
 
533
        except AttributeError:
 
534
            return False
 
535
        return are_knits and InterRepository._same_model(source, target)
 
536
 
 
537
    @needs_read_lock
 
538
    def search_missing_revision_ids(self,
 
539
            revision_id=symbol_versioning.DEPRECATED_PARAMETER,
 
540
            find_ghosts=True, revision_ids=None, if_present_ids=None):
 
541
        """See InterRepository.search_missing_revision_ids()."""
 
542
        if symbol_versioning.deprecated_passed(revision_id):
 
543
            symbol_versioning.warn(
 
544
                'search_missing_revision_ids(revision_id=...) was '
 
545
                'deprecated in 2.4.  Use revision_ids=[...] instead.',
 
546
                DeprecationWarning, stacklevel=2)
 
547
            if revision_ids is not None:
 
548
                raise AssertionError(
 
549
                    'revision_ids is mutually exclusive with revision_id')
 
550
            if revision_id is not None:
 
551
                revision_ids = [revision_id]
 
552
        del revision_id
 
553
        source_ids_set = self._present_source_revisions_for(
 
554
            revision_ids, if_present_ids)
 
555
        # source_ids is the worst possible case we may need to pull.
 
556
        # now we want to filter source_ids against what we actually
 
557
        # have in target, but don't try to check for existence where we know
 
558
        # we do not have a revision as that would be pointless.
 
559
        target_ids = set(self.target.all_revision_ids())
 
560
        possibly_present_revisions = target_ids.intersection(source_ids_set)
 
561
        actually_present_revisions = set(
 
562
            self.target._eliminate_revisions_not_present(possibly_present_revisions))
 
563
        required_revisions = source_ids_set.difference(actually_present_revisions)
 
564
        if revision_ids is not None:
 
565
            # we used get_ancestry to determine source_ids then we are assured all
 
566
            # revisions referenced are present as they are installed in topological order.
 
567
            # and the tip revision was validated by get_ancestry.
 
568
            result_set = required_revisions
 
569
        else:
 
570
            # if we just grabbed the possibly available ids, then
 
571
            # we only have an estimate of whats available and need to validate
 
572
            # that against the revision records.
 
573
            result_set = set(
 
574
                self.source._eliminate_revisions_not_present(required_revisions))
 
575
        return self.source.revision_ids_to_search_result(result_set)
 
576
 
 
577
 
 
578
InterRepository.register_optimiser(InterKnitRepo)