resync hydra with upstream #4
@ -540,6 +540,7 @@ void State::buildRemote(ref<Store> destStore,
|
|||||||
/* Throttle CPU-bound work. Opportunistically skip updating the current
|
/* Throttle CPU-bound work. Opportunistically skip updating the current
|
||||||
* step, since this requires a DB roundtrip. */
|
* step, since this requires a DB roundtrip. */
|
||||||
if (!localWorkThrottler.try_acquire()) {
|
if (!localWorkThrottler.try_acquire()) {
|
||||||
|
MaintainCount<counter> mc(nrStepsWaitingForDownloadSlot);
|
||||||
updateStep(ssWaitingForLocalSlot);
|
updateStep(ssWaitingForLocalSlot);
|
||||||
localWorkThrottler.acquire();
|
localWorkThrottler.acquire();
|
||||||
}
|
}
|
||||||
|
@ -573,6 +573,7 @@ void State::dumpStatus(Connection & conn)
|
|||||||
{"nrActiveSteps", activeSteps_.lock()->size()},
|
{"nrActiveSteps", activeSteps_.lock()->size()},
|
||||||
{"nrStepsBuilding", nrStepsBuilding.load()},
|
{"nrStepsBuilding", nrStepsBuilding.load()},
|
||||||
{"nrStepsCopyingTo", nrStepsCopyingTo.load()},
|
{"nrStepsCopyingTo", nrStepsCopyingTo.load()},
|
||||||
|
{"nrStepsWaitingForDownloadSlot", nrStepsWaitingForDownloadSlot.load()},
|
||||||
{"nrStepsCopyingFrom", nrStepsCopyingFrom.load()},
|
{"nrStepsCopyingFrom", nrStepsCopyingFrom.load()},
|
||||||
{"nrStepsWaiting", nrStepsWaiting.load()},
|
{"nrStepsWaiting", nrStepsWaiting.load()},
|
||||||
{"nrUnsupportedSteps", nrUnsupportedSteps.load()},
|
{"nrUnsupportedSteps", nrUnsupportedSteps.load()},
|
||||||
|
@ -369,6 +369,7 @@ private:
|
|||||||
counter nrStepsDone{0};
|
counter nrStepsDone{0};
|
||||||
counter nrStepsBuilding{0};
|
counter nrStepsBuilding{0};
|
||||||
counter nrStepsCopyingTo{0};
|
counter nrStepsCopyingTo{0};
|
||||||
|
counter nrStepsWaitingForDownloadSlot{0};
|
||||||
counter nrStepsCopyingFrom{0};
|
counter nrStepsCopyingFrom{0};
|
||||||
counter nrStepsWaiting{0};
|
counter nrStepsWaiting{0};
|
||||||
counter nrUnsupportedSteps{0};
|
counter nrUnsupportedSteps{0};
|
||||||
|
Loading…
x
Reference in New Issue
Block a user