Show More
@@ -1427,8 +1427,12 b' def applyupdates(repo, actions, wctx, mc' | |||||
1427 | z += 1 |
|
1427 | z += 1 | |
1428 | progress(_updating, z, item=f, total=numupdates, unit=_files) |
|
1428 | progress(_updating, z, item=f, total=numupdates, unit=_files) | |
1429 |
|
1429 | |||
|
1430 | # When merging in-memory, we can't support worker processes, so set the | |||
|
1431 | # per-item cost at 0 in that case. | |||
|
1432 | cost = 0 if wctx.isinmemory() else 0.001 | |||
|
1433 | ||||
1430 | # remove in parallel (must come before resolving path conflicts and getting) |
|
1434 | # remove in parallel (must come before resolving path conflicts and getting) | |
1431 |
prog = worker.worker(repo.ui, |
|
1435 | prog = worker.worker(repo.ui, cost, batchremove, (repo, wctx), | |
1432 | actions['r']) |
|
1436 | actions['r']) | |
1433 | for i, item in prog: |
|
1437 | for i, item in prog: | |
1434 | z += i |
|
1438 | z += i | |
@@ -1452,7 +1456,7 b' def applyupdates(repo, actions, wctx, mc' | |||||
1452 | wctx.flushall() |
|
1456 | wctx.flushall() | |
1453 |
|
1457 | |||
1454 | # get in parallel |
|
1458 | # get in parallel | |
1455 |
prog = worker.worker(repo.ui, |
|
1459 | prog = worker.worker(repo.ui, cost, batchget, (repo, mctx, wctx), | |
1456 | actions['g']) |
|
1460 | actions['g']) | |
1457 | for i, item in prog: |
|
1461 | for i, item in prog: | |
1458 | z += i |
|
1462 | z += i |
General Comments 0
You need to be logged in to leave comments.
Login now