X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Fpools%2Fselection-strategies%2Fworker-choice-strategy-context.test.js;h=2070f8e03301aca85ac8215c52e96e11bb065acd;hb=52b71763f1a1240170e777049a80df0ad14ce496;hp=2c5b7abbcc78c1429e9f23d0a8a414a659232c52;hpb=f0bbd436ca3a985f79cf530ba82805d8d617d509;p=poolifier.git diff --git a/tests/pools/selection-strategies/worker-choice-strategy-context.test.js b/tests/pools/selection-strategies/worker-choice-strategy-context.test.js index 2c5b7abb..2070f8e0 100644 --- a/tests/pools/selection-strategies/worker-choice-strategy-context.test.js +++ b/tests/pools/selection-strategies/worker-choice-strategy-context.test.js @@ -17,6 +17,9 @@ const { const { LeastBusyWorkerChoiceStrategy } = require('../../../lib/pools/selection-strategies/least-busy-worker-choice-strategy') +const { + LeastEluWorkerChoiceStrategy +} = require('../../../lib/pools/selection-strategies/least-elu-worker-choice-strategy') const { FairShareWorkerChoiceStrategy } = require('../../../lib/pools/selection-strategies/fair-share-worker-choice-strategy') @@ -261,6 +264,38 @@ describe('Worker choice strategy context test suite', () => { ) }) + it('Verify that setWorkerChoiceStrategy() works with LEAST_ELU and fixed pool', () => { + const workerChoiceStrategy = WorkerChoiceStrategies.LEAST_ELU + const workerChoiceStrategyContext = new WorkerChoiceStrategyContext( + fixedPool + ) + workerChoiceStrategyContext.setWorkerChoiceStrategy(workerChoiceStrategy) + expect( + workerChoiceStrategyContext.workerChoiceStrategies.get( + workerChoiceStrategy + ) + ).toBeInstanceOf(LeastEluWorkerChoiceStrategy) + expect(workerChoiceStrategyContext.workerChoiceStrategy).toBe( + workerChoiceStrategy + ) + }) + + it('Verify that setWorkerChoiceStrategy() works with LEAST_ELU and dynamic pool', () => { + const workerChoiceStrategy = WorkerChoiceStrategies.LEAST_ELU + const workerChoiceStrategyContext = new WorkerChoiceStrategyContext( + dynamicPool + ) + workerChoiceStrategyContext.setWorkerChoiceStrategy(workerChoiceStrategy) + expect( + workerChoiceStrategyContext.workerChoiceStrategies.get( + workerChoiceStrategy + ) + ).toBeInstanceOf(LeastEluWorkerChoiceStrategy) + expect(workerChoiceStrategyContext.workerChoiceStrategy).toBe( + workerChoiceStrategy + ) + }) + it('Verify that setWorkerChoiceStrategy() works with FAIR_SHARE and fixed pool', () => { const workerChoiceStrategy = WorkerChoiceStrategies.FAIR_SHARE const workerChoiceStrategyContext = new WorkerChoiceStrategyContext( @@ -365,54 +400,58 @@ describe('Worker choice strategy context test suite', () => { fixedPool, wwrWorkerChoiceStrategy, { - medRunTime: true + runTime: { median: true } } ) expect( - workerChoiceStrategyContext.getTaskStatisticsRequirements().avgRunTime + workerChoiceStrategyContext.getTaskStatisticsRequirements().runTime + .average ).toBe(false) expect( - workerChoiceStrategyContext.getTaskStatisticsRequirements().medRunTime + workerChoiceStrategyContext.getTaskStatisticsRequirements().runTime.median ).toBe(true) workerChoiceStrategyContext = new WorkerChoiceStrategyContext( dynamicPool, wwrWorkerChoiceStrategy, { - medRunTime: true + runTime: { median: true } } ) expect( - workerChoiceStrategyContext.getTaskStatisticsRequirements().avgRunTime + workerChoiceStrategyContext.getTaskStatisticsRequirements().runTime + .average ).toBe(false) expect( - workerChoiceStrategyContext.getTaskStatisticsRequirements().medRunTime + workerChoiceStrategyContext.getTaskStatisticsRequirements().runTime.median ).toBe(true) const fsWorkerChoiceStrategy = WorkerChoiceStrategies.FAIR_SHARE workerChoiceStrategyContext = new WorkerChoiceStrategyContext( fixedPool, fsWorkerChoiceStrategy, { - medRunTime: true + runTime: { median: true } } ) expect( - workerChoiceStrategyContext.getTaskStatisticsRequirements().avgRunTime + workerChoiceStrategyContext.getTaskStatisticsRequirements().runTime + .average ).toBe(false) expect( - workerChoiceStrategyContext.getTaskStatisticsRequirements().medRunTime + workerChoiceStrategyContext.getTaskStatisticsRequirements().runTime.median ).toBe(true) workerChoiceStrategyContext = new WorkerChoiceStrategyContext( dynamicPool, fsWorkerChoiceStrategy, { - medRunTime: true + runTime: { median: true } } ) expect( - workerChoiceStrategyContext.getTaskStatisticsRequirements().avgRunTime + workerChoiceStrategyContext.getTaskStatisticsRequirements().runTime + .average ).toBe(false) expect( - workerChoiceStrategyContext.getTaskStatisticsRequirements().medRunTime + workerChoiceStrategyContext.getTaskStatisticsRequirements().runTime.median ).toBe(true) }) })