X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fselection-strategies%2Fabstract-worker-choice-strategy.ts;h=ca3d9b9d640fc6bf0faedfe3105d5751802281e1;hb=516dcb0df1957823ec30f15db5f7585a7a302e8f;hp=2fba4e9fbd1a17be10fd9d6a86a6cb574a9ad03b;hpb=0fa1d6f0433baf6ff3f67fefdbdf610612a4f3e9;p=poolifier.git diff --git a/src/pools/selection-strategies/abstract-worker-choice-strategy.ts b/src/pools/selection-strategies/abstract-worker-choice-strategy.ts index 2fba4e9f..ca3d9b9d 100644 --- a/src/pools/selection-strategies/abstract-worker-choice-strategy.ts +++ b/src/pools/selection-strategies/abstract-worker-choice-strategy.ts @@ -194,18 +194,26 @@ export abstract class AbstractWorkerChoiceStrategy< : this.pool.workerNodes[workerNodeKey].usage.elu.active?.average ?? 0 } + /** + * Sets safely the previous worker node key. + * + * @param workerNodeKey - The worker node key. + */ + protected setPreviousWorkerNodeKey (workerNodeKey: number | undefined): void { + this.previousWorkerNodeKey = workerNodeKey ?? this.previousWorkerNodeKey + } + /** * Check the next worker node eligibility. * - * @param chosenNextWorkerNodeKey - The chosen worker node key. + * @param previousWorkerNodeKey - The previous worker node key. */ protected checkNextWorkerNodeEligibility ( - chosenNextWorkerNodeKey: number | undefined + previousWorkerNodeKey: number | undefined ): void { if (!this.isWorkerNodeEligible(this.nextWorkerNodeKey as number)) { this.nextWorkerNodeKey = undefined - this.previousWorkerNodeKey = - chosenNextWorkerNodeKey ?? this.previousWorkerNodeKey + this.setPreviousWorkerNodeKey(previousWorkerNodeKey) } }