X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fselection-strategies%2Fleast-elu-worker-choice-strategy.ts;h=30491dce6fd6962c11547a7fd2494e9a733775da;hb=2c039e4373e86714cdf27e77440b12ee8eb2e4db;hp=9f6ddbf3f407658ea32046af66dfe294bb8f45df;hpb=dd38581f5c4724c7fc431bcfd42106bbc8c8dd17;p=poolifier.git diff --git a/src/pools/selection-strategies/least-elu-worker-choice-strategy.ts b/src/pools/selection-strategies/least-elu-worker-choice-strategy.ts index 9f6ddbf3..30491dce 100644 --- a/src/pools/selection-strategies/least-elu-worker-choice-strategy.ts +++ b/src/pools/selection-strategies/least-elu-worker-choice-strategy.ts @@ -34,7 +34,11 @@ export class LeastEluWorkerChoiceStrategy< average: false, median: false }, - elu: true + elu: { + aggregate: true, + average: false, + median: false + } } /** @inheritDoc */ @@ -59,18 +63,18 @@ export class LeastEluWorkerChoiceStrategy< /** @inheritDoc */ public choose (): number { let minWorkerElu = Infinity - let leastEluWorkerNodeKey!: number for (const [workerNodeKey, workerNode] of this.pool.workerNodes.entries()) { const workerUsage = workerNode.workerUsage - const workerElu = workerUsage.elu?.active ?? 0 + const workerElu = workerUsage.elu?.active.aggregate ?? 0 if (workerElu === 0) { - return workerNodeKey + this.nextWorkerNodeId = workerNodeKey + break } else if (workerElu < minWorkerElu) { minWorkerElu = workerElu - leastEluWorkerNodeKey = workerNodeKey + this.nextWorkerNodeId = workerNodeKey } } - return leastEluWorkerNodeKey + return this.nextWorkerNodeId } /** @inheritDoc */