comparison mercurial/merge.py @ 34124:b90e5b2a9c82

merge: flush any deferred writes before, and after, running any workers

Since we fork to create workers, any changes they queue up will be lost after
the worker terminates, so the easiest solution is to have each worker flush
the writes they accumulate--we are close to the end of the merge in any case.

To prevent duplicated writes, we also have the master processs flush before
forking.

In an in-memory merge (M2), we'll instead disable the use of workers.

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

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: