X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fselection-strategies%2Fworker-choice-strategy-context.ts;h=5d26f82ba4f5784873c18eb037beed9b26a5e2f5;hb=fa418e129ade4cd910e34e9d41c3dfa5cac9b2de;hp=0a488549f9f9d7240b8d4fd421d64b89ada5401b;hpb=138d29a820e8a61d10ba03fe42c5d77596ef788c;p=poolifier.git diff --git a/src/pools/selection-strategies/worker-choice-strategy-context.ts b/src/pools/selection-strategies/worker-choice-strategy-context.ts index 0a488549..5d26f82b 100644 --- a/src/pools/selection-strategies/worker-choice-strategy-context.ts +++ b/src/pools/selection-strategies/worker-choice-strategy-context.ts @@ -115,33 +115,38 @@ export class WorkerChoiceStrategyContext< } /** - * Updates the worker choice strategy internals in the context. + * Updates the worker node key in the worker choice strategy internals in the context. * * @returns `true` if the update is successful, `false` otherwise. */ - public update (): boolean { + public update (workerNodeKey: number): boolean { return ( this.workerChoiceStrategies.get( this.workerChoiceStrategy ) as IWorkerChoiceStrategy - ).update() + ).update(workerNodeKey) } /** * Executes the worker choice strategy algorithm in the context. * * @returns The key of the worker node. + * @throws {@link https://nodejs.org/api/errors.html#class-error} If the worker node key is null or undefined. */ public execute (): number { - return ( + const workerNodeKey = ( this.workerChoiceStrategies.get( this.workerChoiceStrategy ) as IWorkerChoiceStrategy ).choose() + if (workerNodeKey == null) { + throw new Error('Worker node key chosen is null or undefined') + } + return workerNodeKey } /** - * Removes a worker node key from the worker choice strategy in the context. + * Removes the worker node key from the worker choice strategy in the context. * * @param workerNodeKey - The key of the worker node. * @returns `true` if the removal is successful, `false` otherwise.