X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;ds=sidebyside;f=src%2Fpools%2Fselection-strategies%2Fleast-elu-worker-choice-strategy.ts;h=30491dce6fd6962c11547a7fd2494e9a733775da;hb=cd9580e7fd7edad1758e8797f6168c05d6701621;hp=5cc02bffbc58997dc872ad023f13f7308a903640;hpb=e460940e8d2a41a846b2334d54410807ffc2f421;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 5cc02bff..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?.utilization ?? 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 */