X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fselection-strategies%2Ffair-share-worker-choice-strategy.ts;h=e1d123a994aa77f5d41ce10ccf2a4f3584b6c926;hb=12ae3210477b0c54380db24470ff3b0e78926bd8;hp=c2f85f18ae911f0c8e35bbca6ff11712b360dff8;hpb=f06e48d8e14dcfe3277bd16b1bd2463136af13e6;p=poolifier.git diff --git a/src/pools/selection-strategies/fair-share-worker-choice-strategy.ts b/src/pools/selection-strategies/fair-share-worker-choice-strategy.ts index c2f85f18..e1d123a9 100644 --- a/src/pools/selection-strategies/fair-share-worker-choice-strategy.ts +++ b/src/pools/selection-strategies/fair-share-worker-choice-strategy.ts @@ -88,11 +88,12 @@ export class FairShareWorkerChoiceStrategy< performance.now(), this.workerLastVirtualTaskTimestamp.get(workerNodeKey)?.end ?? -Infinity ) + const workerVirtualTaskTRunTime = this.requiredStatistics.medRunTime + ? this.pool.workerNodes[workerNodeKey].tasksUsage.medRunTime + : this.pool.workerNodes[workerNodeKey].tasksUsage.avgRunTime this.workerLastVirtualTaskTimestamp.set(workerNodeKey, { start: workerVirtualTaskStartTimestamp, - end: - workerVirtualTaskStartTimestamp + - (this.pool.workerNodes[workerNodeKey].tasksUsage.avgRunTime ?? 0) + end: workerVirtualTaskStartTimestamp + (workerVirtualTaskTRunTime ?? 0) }) } }