X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fselection-strategies%2Finterleaved-weighted-round-robin-worker-choice-strategy.ts;h=97a3aa04e5b941a31a053c53bf3f4416d15855f0;hb=e372f3935374fbbea3a5d3acc72813b36ced86ff;hp=2d604e71a97002ad0980da85f2799f232608b6d3;hpb=7f0e133432b540753bcdd06160d1363e9fe65437;p=poolifier.git diff --git a/src/pools/selection-strategies/interleaved-weighted-round-robin-worker-choice-strategy.ts b/src/pools/selection-strategies/interleaved-weighted-round-robin-worker-choice-strategy.ts index 2d604e71..97a3aa04 100644 --- a/src/pools/selection-strategies/interleaved-weighted-round-robin-worker-choice-strategy.ts +++ b/src/pools/selection-strategies/interleaved-weighted-round-robin-worker-choice-strategy.ts @@ -114,7 +114,9 @@ export class InterleavedWeightedRoundRobinWorkerChoiceStrategy< } private interleavedWeightedRoundRobinNextWorkerNodeId (): void { - if ( + if (this.pool.workerNodes.length === 0) { + this.workerNodeId = 0 + } else if ( this.roundId === this.roundWeights.length - 1 && this.workerNodeId === this.pool.workerNodes.length - 1 ) {