comparison mercurial/scmutil.py @ 39301:5763216ba311

transaction: remember original len(repo) instead of tracking added revs (API)

It's silly to keep updating xrange(len(changelog), len(changelog) + 1) for
each added revision. Instead, let's simply remember the first revision to
be added.

The test output slightly changed as the branch cache is also warmed up by
stream clone, which seems more consistent.

.. api::

   ``tr.changes['revs']`` is replaced by ``tr.changes['origrepolen']`` which
   is the first revision number to be added.

39300:52e6171ec822

    if txmatch(_reportnewcssource):
        @reportsummary
        def reportnewcs(repo, tr):
            """Report the range of new revisions pulled/unbundled."""
            newrevs = tr.changes.get('revs', pycompat.xrange(0, 0))
            if not newrevs:
                return

            # Compute the bounds of new revisions' range, excluding obsoletes.
            unfi = repo.unfiltered()
            revs = unfi.revs('%ld and not obsolete()', newrevs)
            if not revs:
                # Got only obsoletes.
                return
            minrev, maxrev = repo[revs.min()], repo[revs.max()]

        @reportsummary
        def reportphasechanges(repo, tr):
            """Report statistics of phase changes for changesets pre-existing
            pull/unbundle.
            """
            newrevs = tr.changes.get('revs', pycompat.xrange(0, 0))
            phasetracking = tr.changes.get('phases', {})
            if not phasetracking:
                return
            published = [
                rev for rev, (old, new) in phasetracking.iteritems()
                if new == phases.public and rev not in newrevs
            ]
            if not published:
                return
            repo.ui.status(_('%d local changesets published\n')
                           % len(published))

39301:5763216ba311

    if txmatch(_reportnewcssource):
        @reportsummary
        def reportnewcs(repo, tr):
            """Report the range of new revisions pulled/unbundled."""
            origrepolen = tr.changes.get('origrepolen', len(repo))
            if origrepolen >= len(repo):
                return

            # Compute the bounds of new revisions' range, excluding obsoletes.
            unfi = repo.unfiltered()
            revs = unfi.revs('%d: and not obsolete()', origrepolen)
            if not revs:
                # Got only obsoletes.
                return
            minrev, maxrev = repo[revs.min()], repo[revs.max()]

        @reportsummary
        def reportphasechanges(repo, tr):
            """Report statistics of phase changes for changesets pre-existing
            pull/unbundle.
            """
            origrepolen = tr.changes.get('origrepolen', len(repo))
            phasetracking = tr.changes.get('phases', {})
            if not phasetracking:
                return
            published = [
                rev for rev, (old, new) in phasetracking.iteritems()
                if new == phases.public and rev < origrepolen
            ]
            if not published:
                return
            repo.ui.status(_('%d local changesets published\n')
                           % len(published))