X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;ds=sidebyside;f=src%2Fpools%2Fselection-strategies%2Ffair-share-worker-choice-strategy.ts;h=7b3ad3f7516f2b9522aca6acf3ec6b0356aabac3;hb=cd9580e7fd7edad1758e8797f6168c05d6701621;hp=39da59a0f2c2d0a16c58e9f4f8b9ce91cc915b92;hpb=d33be4309c69e39da5e81479e40b1a5ec7078bd5;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 39da59a0..7b3ad3f7 100644 --- a/src/pools/selection-strategies/fair-share-worker-choice-strategy.ts +++ b/src/pools/selection-strategies/fair-share-worker-choice-strategy.ts @@ -66,6 +66,11 @@ export class FairShareWorkerChoiceStrategy< /** @inheritDoc */ public update (workerNodeKey: number): boolean { this.computeWorkerVirtualTaskEndTimestamp(workerNodeKey) + return true + } + + /** @inheritDoc */ + public choose (): number { let minWorkerVirtualTaskEndTimestamp = Infinity for (const [workerNodeKey] of this.pool.workerNodes.entries()) { if (this.workersVirtualTaskEndTimestamp[workerNodeKey] == null) { @@ -78,11 +83,6 @@ export class FairShareWorkerChoiceStrategy< this.nextWorkerNodeId = workerNodeKey } } - return true - } - - /** @inheritDoc */ - public choose (): number { return this.nextWorkerNodeId }