← Back to branch summary

~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/branch.py

  • Committer: Canonical.com Patch Queue Manager
  • Date: 2008-06-25 23:07:24 UTC
  • mfrom: (3441.5.33 smart-push-gpm)
  • Revision ID: pqm@pqm.ubuntu.com-20080625230724-lyux37pu8nx8tq34
Add Branch.set_last_revision_ex HPSS verb to accelerate push. (Andrew
        Bennetts)

Show diffs side-by-side

added added

removed removed

Lines of Context:
bzrlib/branch.py
85
85
        self.tags = self._make_tags()
86
86
        self._revision_history_cache = None
87
87
        self._revision_id_to_revno_cache = None
 
88
        self._last_revision_info_cache = None
88
89
 
89
90
    def break_lock(self):
90
91
        """Break a lock if one is present from another instance.
361
362
        """
362
363
        self._revision_history_cache = None
363
364
        self._revision_id_to_revno_cache = None
 
365
        self._last_revision_info_cache = None
364
366
 
365
367
    def _gen_revision_history(self):
366
368
        """Return sequence of revision hashes on to this branch.
413
415
        """Return last revision id, or NULL_REVISION."""
414
416
        return self.last_revision_info()[1]
415
417
 
 
418
    @needs_read_lock
416
419
    def last_revision_info(self):
417
420
        """Return information about the last revision.
418
421
 
419
 
        :return: A tuple (revno, last_revision_id).
 
422
        :return: A tuple (revno, revision_id).
420
423
        """
 
424
        if self._last_revision_info_cache is None:
 
425
            self._last_revision_info_cache = self._last_revision_info()
 
426
        return self._last_revision_info_cache
 
427
 
 
428
    def _last_revision_info(self):
421
429
        rh = self.revision_history()
422
430
        revno = len(rh)
423
431
        if revno:
484
492
            if not overwrite:
485
493
                if graph is None:
486
494
                    graph = self.repository.get_graph()
487
 
                heads = graph.heads([stop_revision, last_rev])
488
 
                if heads == set([last_rev]):
489
 
                    # The current revision is a decendent of the target,
490
 
                    # nothing to do
 
495
                if self._check_if_descendant_or_diverged(
 
496
                        stop_revision, last_rev, graph, other):
 
497
                    # stop_revision is a descendant of last_rev, but we aren't
 
498
                    # overwriting, so we're done.
491
499
                    return
492
 
                elif heads == set([stop_revision, last_rev]):
493
 
                    # These branches have diverged
494
 
                    raise errors.DivergedBranches(self, other)
495
 
                elif heads != set([stop_revision]):
496
 
                    raise AssertionError("invalid heads: %r" % heads)
497
500
            if stop_revno is None:
498
501
                if graph is None:
499
502
                    graph = self.repository.get_graph()
854
857
    def supports_tags(self):
855
858
        return self._format.supports_tags()
856
859
 
 
860
    def _check_if_descendant_or_diverged(self, revision_a, revision_b, graph,
 
861
                                         other_branch):
 
862
        """Ensure that revision_b is a descendant of revision_a.
 
863
 
 
864
        This is a helper function for update_revisions.
 
865
        
 
866
        :raises: DivergedBranches if revision_b has diverged from revision_a.
 
867
        :returns: True if revision_b is a descendant of revision_a.
 
868
        """
 
869
        relation = self._revision_relations(revision_a, revision_b, graph)
 
870
        if relation == 'b_descends_from_a':
 
871
            return True
 
872
        elif relation == 'diverged':
 
873
            raise errors.DivergedBranches(self, other_branch)
 
874
        elif relation == 'a_descends_from_b':
 
875
            return False
 
876
        else:
 
877
            raise AssertionError("invalid heads: %r" % heads)
 
878
 
 
879
    def _revision_relations(self, revision_a, revision_b, graph):
 
880
        """Determine the relationship between two revisions.
 
881
        
 
882
        :returns: One of: 'a_descends_from_b', 'b_descends_from_a', 'diverged'
 
883
        """
 
884
        heads = graph.heads([revision_a, revision_b])
 
885
        if heads == set([revision_b]):
 
886
            return 'b_descends_from_a'
 
887
        elif heads == set([revision_a, revision_b]):
 
888
            # These branches have diverged
 
889
            return 'diverged'
 
890
        elif heads == set([revision_a]):
 
891
            return 'a_descends_from_b'
 
892
        else:
 
893
            raise AssertionError("invalid heads: %r" % heads)
 
894
 
857
895
 
858
896
class BranchFormat(object):
859
897
    """An encapsulation of the initialization and open routines for a format.
1887
1925
 
1888
1926
    def __init__(self, *args, **kwargs):
1889
1927
        super(BzrBranch6, self).__init__(*args, **kwargs)
1890
 
        self._last_revision_info_cache = None
1891
1928
        self._partial_revision_history_cache = []
1892
1929
 
1893
1930
    def _clear_cached_state(self):
1894
1931
        super(BzrBranch6, self)._clear_cached_state()
1895
 
        self._last_revision_info_cache = None
1896
1932
        self._partial_revision_history_cache = []
1897
1933
 
1898
 
    @needs_read_lock
1899
 
    def last_revision_info(self):
1900
 
        """Return information about the last revision.
1901
 
 
1902
 
        :return: A tuple (revno, revision_id).
1903
 
        """
1904
 
        if self._last_revision_info_cache is None:
1905
 
            self._last_revision_info_cache = self._last_revision_info()
1906
 
        return self._last_revision_info_cache
1907
 
 
1908
1934
    def _last_revision_info(self):
1909
1935
        revision_string = self._transport.get_bytes('last-revision')
1910
1936
        revno, revision_id = revision_string.rstrip('\n').split(' ', 1)