X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Fpools%2Fselection-strategies%2Fweighted-round-robin-worker-choice-strategy.test.mjs;h=95f1397e6aafbd15ef66a6327fb3c0ab0ef9c75d;hb=a4d25410764bca884efaea4d46ed9bf83b8a8dbb;hp=a8c4bdd5eaabf9f0845e82d00d9a1bd9c2c2caa1;hpb=b2fd3f4a217ac09110da00b3b65dcdd36de4bf74;p=poolifier.git diff --git a/tests/pools/selection-strategies/weighted-round-robin-worker-choice-strategy.test.mjs b/tests/pools/selection-strategies/weighted-round-robin-worker-choice-strategy.test.mjs index a8c4bdd5..95f1397e 100644 --- a/tests/pools/selection-strategies/weighted-round-robin-worker-choice-strategy.test.mjs +++ b/tests/pools/selection-strategies/weighted-round-robin-worker-choice-strategy.test.mjs @@ -1,8 +1,7 @@ +import { randomInt } from 'node:crypto' import { expect } from 'expect' -import { restore } from 'sinon' -import { FixedThreadPool } from '../../../lib/index.js' -import { WeightedRoundRobinWorkerChoiceStrategy } from '../../../lib/pools/selection-strategies/weighted-round-robin-worker-choice-strategy.js' -import { generateRandomInteger } from '../../test-utils.js' +import { FixedThreadPool } from '../../../lib/index.cjs' +import { WeightedRoundRobinWorkerChoiceStrategy } from '../../../lib/pools/selection-strategies/weighted-round-robin-worker-choice-strategy.cjs' describe('Weighted round robin strategy worker choice strategy test suite', () => { // const min = 1 @@ -16,21 +15,14 @@ describe('Weighted round robin strategy worker choice strategy test suite', () = ) }) - afterEach(() => { - restore() - }) - after(async () => { await pool.destroy() }) it('Verify that reset() resets internals', () => { const strategy = new WeightedRoundRobinWorkerChoiceStrategy(pool) - strategy.currentWorkerId = generateRandomInteger(Number.MAX_SAFE_INTEGER, 1) - strategy.workerVirtualTaskRunTime = generateRandomInteger( - Number.MAX_SAFE_INTEGER, - 1 - ) + strategy.currentWorkerId = randomInt(281474976710655) + strategy.workerVirtualTaskRunTime = randomInt(281474976710655) expect(strategy.reset()).toBe(true) expect(strategy.nextWorkerNodeKey).toBe(0) expect(strategy.previousWorkerNodeKey).toBe(0)