comparison mercurial/changegroup.py @ 46510:fa7ae7aa0efd

changegroup: don't convert revisions to node for duplicate handling

The only consumer can handle revision lists fine. Avoid
materializing a range if there are no duplicates as optimization.

Differential Revision: https://phab.mercurial-scm.org/D9884

46509:7a93b7b3dc2d

                _(b'changesets'), unit=_(b'chunks'), total=expectedtotal
            )
            self.callback = progress.increment

            efilesset = set()
            cgnodes = []

            def ondupchangelog(cl, rev):
                if rev < clstart:
                    cgnodes.append(cl.node(rev))

            def onchangelog(cl, rev):
                ctx = cl.changelogrevision(rev)
                efilesset.update(ctx.files)
                repo.register_changeset(rev, ctx)

                    # ignored.
                    targetphase = phaseall = phases.draft
            if added:
                phases.registernew(repo, tr, targetphase, added)
            if phaseall is not None:
                phases.advanceboundary(repo, tr, phaseall, cgnodes, revs=added)
                cgnodes = []

            if changesets > 0:

                def runhooks(unused_success):
                    # These hooks run when the lock releases, not when the

46510:fa7ae7aa0efd

                _(b'changesets'), unit=_(b'chunks'), total=expectedtotal
            )
            self.callback = progress.increment

            efilesset = set()
            duprevs = []

            def ondupchangelog(cl, rev):
                if rev < clstart:
                    duprevs.append(rev)

            def onchangelog(cl, rev):
                ctx = cl.changelogrevision(rev)
                efilesset.update(ctx.files)
                repo.register_changeset(rev, ctx)

                    # ignored.
                    targetphase = phaseall = phases.draft
            if added:
                phases.registernew(repo, tr, targetphase, added)
            if phaseall is not None:
                if duprevs:
                    duprevs.extend(added)
                else:
                    duprevs = added
                phases.advanceboundary(repo, tr, phaseall, [], revs=duprevs)
                duprevs = []

            if changesets > 0:

                def runhooks(unused_success):
                    # These hooks run when the lock releases, not when the