comparison hgext/fix.py @ 38537:a3be09e277e9

fix: add progress bar for number of file revisions processed

This ensures responsiveness when the configured tools are slow or numerous.

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

38536:5ffe2041d427

        # the tests deterministic. It might also be considered a feature since
        # it makes the results more easily reproducible.
        filedata = collections.defaultdict(dict)
        replacements = {}
        commitorder = sorted(revstofix, reverse=True)
        for rev, path, newdata in results:
            if newdata is not None:
                filedata[rev][path] = newdata
            numitems[rev] -= 1
            # Apply the fixes for this and any other revisions that are ready
            # and sitting at the front of the queue. Using a loop here prevents
            # the queue from being blocked by the first revision to be ready out
            # of order.
            while commitorder and not numitems[commitorder[-1]]:
                rev = commitorder.pop()
                ctx = repo[rev]
                if rev == wdirrev:
                    writeworkingdir(repo, ctx, filedata[rev], replacements)
                else:
                    replacerev(ui, repo, ctx, filedata[rev], replacements)
                del filedata[rev]

        replacements = {prec: [succ] for prec, succ in replacements.iteritems()}
        scmutil.cleanupnodes(repo, replacements, 'fix', fixphase=True)

def getworkqueue(ui, repo, pats, opts, revstofix, basectxs):

38537:a3be09e277e9

        # the tests deterministic. It might also be considered a feature since
        # it makes the results more easily reproducible.
        filedata = collections.defaultdict(dict)
        replacements = {}
        commitorder = sorted(revstofix, reverse=True)
        with ui.makeprogress(topic=_('fixing'), unit=_('files'),
                             total=sum(numitems.values())) as progress:
            for rev, path, newdata in results:
                progress.increment(item=path)
                if newdata is not None:
                    filedata[rev][path] = newdata
                numitems[rev] -= 1
                # Apply the fixes for this and any other revisions that are
                # ready and sitting at the front of the queue. Using a loop here
                # prevents the queue from being blocked by the first revision to
                # be ready out of order.
                while commitorder and not numitems[commitorder[-1]]:
                    rev = commitorder.pop()
                    ctx = repo[rev]
                    if rev == wdirrev:
                        writeworkingdir(repo, ctx, filedata[rev], replacements)
                    else:
                        replacerev(ui, repo, ctx, filedata[rev], replacements)
                    del filedata[rev]

        replacements = {prec: [succ] for prec, succ in replacements.iteritems()}
        scmutil.cleanupnodes(repo, replacements, 'fix', fixphase=True)

def getworkqueue(ui, repo, pats, opts, revstofix, basectxs):