mercurial/merge.py

34123:9c07cff039bc

            # Print a warning if cwd was deleted
            repo.ui.warn(_("current directory was removed\n"
                           "(consider changing to repo root: %s)\n") %
                         repo.root)

def batchget(repo, mctx, wctx, actions):
    """apply gets to the working directory

    mctx is the context to get from

                yield i, f
                i = 0
            i += 1
    if i > 0:
        yield i, f

def applyupdates(repo, actions, wctx, mctx, overwrite, labels=None):
    """apply the merge action list to the working directory

    wctx is the working copy context

                         actions['r'])
    for i, item in prog:
        z += i
        progress(_updating, z, item=item, total=numupdates, unit=_files)
    removed = len(actions['r'])

    # get in parallel
    prog = worker.worker(repo.ui, 0.001, batchget, (repo, mctx, wctx),
                         actions['g'])
    for i, item in prog:

34124:b90e5b2a9c82

            # Print a warning if cwd was deleted
            repo.ui.warn(_("current directory was removed\n"
                           "(consider changing to repo root: %s)\n") %
                         repo.root)

    # It's necessary to flush here in case we're inside a worker fork and will
    # quit after this function.
    wctx.flushall()

def batchget(repo, mctx, wctx, actions):
    """apply gets to the working directory

    mctx is the context to get from

                yield i, f
                i = 0
            i += 1
    if i > 0:
        yield i, f

    # It's necessary to flush here in case we're inside a worker fork and will
    # quit after this function.
    wctx.flushall()

def applyupdates(repo, actions, wctx, mctx, overwrite, labels=None):
    """apply the merge action list to the working directory

    wctx is the working copy context

                         actions['r'])
    for i, item in prog:
        z += i
        progress(_updating, z, item=item, total=numupdates, unit=_files)
    removed = len(actions['r'])

    # We should flush before forking into worker processes, since those workers
    # flush when they complete, and we don't want to duplicate work.
    wctx.flushall()

    # get in parallel
    prog = worker.worker(repo.ui, 0.001, batchget, (repo, mctx, wctx),
                         actions['g'])
    for i, item in prog: