The only consumer can handle revision lists fine. Avoid
materializing a range if there are no duplicates as optimization.
| No Linters Available |
| No Unit Test Coverage |
| Path | Packages | |||
|---|---|---|---|---|
| M | mercurial/changegroup.py (12 lines) |
| Commit | Parents | Author | Summary | Date |
|---|---|---|---|---|
| a65706c90e44 | e55bbe1e3536 | Joerg Sonnenberger | Jan 26 2021, 9:07 PM |
| Status | Author | Revision | |
|---|---|---|---|
| Closed | joerg.sonnenberger | ||
| Closed | joerg.sonnenberger | ||
| Closed | joerg.sonnenberger | ||
| Closed | joerg.sonnenberger | ||
| Closed | joerg.sonnenberger |
| repo.ui.status(_(b"adding changesets\n")) | repo.ui.status(_(b"adding changesets\n")) | ||||
| clstart = len(cl) | clstart = len(cl) | ||||
| progress = repo.ui.makeprogress( | progress = repo.ui.makeprogress( | ||||
| _(b'changesets'), unit=_(b'chunks'), total=expectedtotal | _(b'changesets'), unit=_(b'chunks'), total=expectedtotal | ||||
| ) | ) | ||||
| self.callback = progress.increment | self.callback = progress.increment | ||||
| efilesset = set() | efilesset = set() | ||||
| cgnodes = [] | duprevs = [] | ||||
| def ondupchangelog(cl, rev): | def ondupchangelog(cl, rev): | ||||
| if rev < clstart: | if rev < clstart: | ||||
| cgnodes.append(cl.node(rev)) | duprevs.append(rev) | ||||
| def onchangelog(cl, rev): | def onchangelog(cl, rev): | ||||
| ctx = cl.changelogrevision(rev) | ctx = cl.changelogrevision(rev) | ||||
| efilesset.update(ctx.files) | efilesset.update(ctx.files) | ||||
| repo.register_changeset(rev, ctx) | repo.register_changeset(rev, ctx) | ||||
| self.changelogheader() | self.changelogheader() | ||||
| deltas = self.deltaiter() | deltas = self.deltaiter() | ||||
| # Those changesets have been pushed from the | # Those changesets have been pushed from the | ||||
| # outside, their phases are going to be pushed | # outside, their phases are going to be pushed | ||||
| # alongside. Therefor `targetphase` is | # alongside. Therefor `targetphase` is | ||||
| # ignored. | # ignored. | ||||
| targetphase = phaseall = phases.draft | targetphase = phaseall = phases.draft | ||||
| if added: | if added: | ||||
| phases.registernew(repo, tr, targetphase, added) | phases.registernew(repo, tr, targetphase, added) | ||||
| if phaseall is not None: | if phaseall is not None: | ||||
| phases.advanceboundary(repo, tr, phaseall, cgnodes, revs=added) | if duprevs: | ||||
| cgnodes = [] | duprevs.extend(added) | ||||
| else: | |||||
| duprevs = added | |||||
| phases.advanceboundary(repo, tr, phaseall, [], revs=duprevs) | |||||
| duprevs = [] | |||||
| if changesets > 0: | if changesets > 0: | ||||
| def runhooks(unused_success): | def runhooks(unused_success): | ||||
| # These hooks run when the lock releases, not when the | # These hooks run when the lock releases, not when the | ||||
| # transaction closes. So it's possible for the changelog | # transaction closes. So it's possible for the changelog | ||||
| # to have changed since we last saw it. | # to have changed since we last saw it. | ||||
| if clstart >= len(repo): | if clstart >= len(repo): | ||||