repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
refactor: remove unneeded encapsulation around tasks usage handling
[poolifier.git]
/
tests
/
pools
/
selection-strategies
/
worker-choice-strategy-context.test.js
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 c33dad80dc885712e95cfa1945119ebf1b1f53ba..3ce8b9fe040218f9b8e3be0b7a184b87737af0a6 100644
(file)
--- a/
tests/pools/selection-strategies/worker-choice-strategy-context.test.js
+++ b/
tests/pools/selection-strategies/worker-choice-strategy-context.test.js
@@
-19,7
+19,7
@@
const {
} = require('../../../lib/pools/selection-strategies/fair-share-worker-choice-strategy')
const {
WeightedRoundRobinWorkerChoiceStrategy
} = require('../../../lib/pools/selection-strategies/fair-share-worker-choice-strategy')
const {
WeightedRoundRobinWorkerChoiceStrategy
-} = require('../../../lib/pools/selection-strategies/weighted-round-robin-choice-strategy')
+} = require('../../../lib/pools/selection-strategies/weighted-round-robin-
worker-
choice-strategy')
const {
DynamicPoolWorkerChoiceStrategy
} = require('../../../lib/pools/selection-strategies/dynamic-pool-worker-choice-strategy')
const {
DynamicPoolWorkerChoiceStrategy
} = require('../../../lib/pools/selection-strategies/dynamic-pool-worker-choice-strategy')
@@
-45,9
+45,9
@@
describe('Worker choice strategy context test suite', () => {
sinon.restore()
})
sinon.restore()
})
- after(() => {
- fixedPool.destroy()
- dynamicPool.destroy()
+ after(
async
() => {
+
await
fixedPool.destroy()
+
await
dynamicPool.destroy()
})
it('Verify that execute() return the worker chosen by the strategy with fixed pool', () => {
})
it('Verify that execute() return the worker chosen by the strategy with fixed pool', () => {
@@
-61,11
+61,11
@@
describe('Worker choice strategy context test suite', () => {
}
)
workerChoiceStrategyContext.workerChoiceStrategy = WorkerChoiceStrategyStub
}
)
workerChoiceStrategyContext.workerChoiceStrategy = WorkerChoiceStrategyStub
- const
w
orker = workerChoiceStrategyContext.execute()
+ const
chosenW
orker = workerChoiceStrategyContext.execute()
expect(
expect(
- workerChoiceStrategyContext.
workerChoiceStrategy
.choose.calledOnce
+ workerChoiceStrategyContext.
getWorkerChoiceStrategy()
.choose.calledOnce
).toBe(true)
).toBe(true)
- expect(
w
orker).toBe('worker')
+ expect(
chosenW
orker).toBe('worker')
})
it('Verify that execute() return the worker chosen by the strategy with dynamic pool', () => {
})
it('Verify that execute() return the worker chosen by the strategy with dynamic pool', () => {
@@
-79,11
+79,11
@@
describe('Worker choice strategy context test suite', () => {
}
)
workerChoiceStrategyContext.workerChoiceStrategy = WorkerChoiceStrategyStub
}
)
workerChoiceStrategyContext.workerChoiceStrategy = WorkerChoiceStrategyStub
- const
w
orker = workerChoiceStrategyContext.execute()
+ const
chosenW
orker = workerChoiceStrategyContext.execute()
expect(
expect(
- workerChoiceStrategyContext.
workerChoiceStrategy
.choose.calledOnce
+ workerChoiceStrategyContext.
getWorkerChoiceStrategy()
.choose.calledOnce
).toBe(true)
).toBe(true)
- expect(
w
orker).toBe('worker')
+ expect(
chosenW
orker).toBe('worker')
})
it('Verify that setWorkerChoiceStrategy() works with ROUND_ROBIN and fixed pool', () => {
})
it('Verify that setWorkerChoiceStrategy() works with ROUND_ROBIN and fixed pool', () => {
@@
-93,9
+93,9
@@
describe('Worker choice strategy context test suite', () => {
workerChoiceStrategyContext.setWorkerChoiceStrategy(
WorkerChoiceStrategies.ROUND_ROBIN
)
workerChoiceStrategyContext.setWorkerChoiceStrategy(
WorkerChoiceStrategies.ROUND_ROBIN
)
- expect(
workerChoiceStrategyContext.workerChoiceStrategy).toBeInstanceOf(
- RoundRobinWorkerChoiceStrategy
- )
+ expect(
+ workerChoiceStrategyContext.getWorkerChoiceStrategy()
+ )
.toBeInstanceOf(RoundRobinWorkerChoiceStrategy)
})
it('Verify that setWorkerChoiceStrategy() works with ROUND_ROBIN and dynamic pool', () => {
})
it('Verify that setWorkerChoiceStrategy() works with ROUND_ROBIN and dynamic pool', () => {
@@
-105,11
+105,11
@@
describe('Worker choice strategy context test suite', () => {
workerChoiceStrategyContext.setWorkerChoiceStrategy(
WorkerChoiceStrategies.ROUND_ROBIN
)
workerChoiceStrategyContext.setWorkerChoiceStrategy(
WorkerChoiceStrategies.ROUND_ROBIN
)
- expect(workerChoiceStrategyContext.workerChoiceStrategy).toBeInstanceOf(
- DynamicPoolWorkerChoiceStrategy
- )
expect(
expect(
- workerChoiceStrategyContext.workerChoiceStrategy.workerChoiceStrategy
+ workerChoiceStrategyContext.getWorkerChoiceStrategy()
+ ).toBeInstanceOf(DynamicPoolWorkerChoiceStrategy)
+ expect(
+ workerChoiceStrategyContext.getWorkerChoiceStrategy().workerChoiceStrategy
).toBeInstanceOf(RoundRobinWorkerChoiceStrategy)
})
).toBeInstanceOf(RoundRobinWorkerChoiceStrategy)
})
@@
-120,9
+120,9
@@
describe('Worker choice strategy context test suite', () => {
workerChoiceStrategyContext.setWorkerChoiceStrategy(
WorkerChoiceStrategies.LESS_RECENTLY_USED
)
workerChoiceStrategyContext.setWorkerChoiceStrategy(
WorkerChoiceStrategies.LESS_RECENTLY_USED
)
- expect(
workerChoiceStrategyContext.workerChoiceStrategy).toBeInstanceOf(
- LessRecentlyUsedWorkerChoiceStrategy
- )
+ expect(
+ workerChoiceStrategyContext.getWorkerChoiceStrategy()
+ )
.toBeInstanceOf(LessRecentlyUsedWorkerChoiceStrategy)
})
it('Verify that setWorkerChoiceStrategy() works with LESS_RECENTLY_USED and dynamic pool', () => {
})
it('Verify that setWorkerChoiceStrategy() works with LESS_RECENTLY_USED and dynamic pool', () => {
@@
-132,11
+132,11
@@
describe('Worker choice strategy context test suite', () => {
workerChoiceStrategyContext.setWorkerChoiceStrategy(
WorkerChoiceStrategies.LESS_RECENTLY_USED
)
workerChoiceStrategyContext.setWorkerChoiceStrategy(
WorkerChoiceStrategies.LESS_RECENTLY_USED
)
- expect(workerChoiceStrategyContext.workerChoiceStrategy).toBeInstanceOf(
- DynamicPoolWorkerChoiceStrategy
- )
expect(
expect(
- workerChoiceStrategyContext.workerChoiceStrategy.workerChoiceStrategy
+ workerChoiceStrategyContext.getWorkerChoiceStrategy()
+ ).toBeInstanceOf(DynamicPoolWorkerChoiceStrategy)
+ expect(
+ workerChoiceStrategyContext.getWorkerChoiceStrategy().workerChoiceStrategy
).toBeInstanceOf(LessRecentlyUsedWorkerChoiceStrategy)
})
).toBeInstanceOf(LessRecentlyUsedWorkerChoiceStrategy)
})
@@
-147,9
+147,9
@@
describe('Worker choice strategy context test suite', () => {
workerChoiceStrategyContext.setWorkerChoiceStrategy(
WorkerChoiceStrategies.FAIR_SHARE
)
workerChoiceStrategyContext.setWorkerChoiceStrategy(
WorkerChoiceStrategies.FAIR_SHARE
)
- expect(
workerChoiceStrategyContext.workerChoiceStrategy).toBeInstanceOf(
- FairShareWorkerChoiceStrategy
- )
+ expect(
+ workerChoiceStrategyContext.getWorkerChoiceStrategy()
+ )
.toBeInstanceOf(FairShareWorkerChoiceStrategy)
})
it('Verify that setWorkerChoiceStrategy() works with FAIR_SHARE and dynamic pool', () => {
})
it('Verify that setWorkerChoiceStrategy() works with FAIR_SHARE and dynamic pool', () => {
@@
-159,11
+159,11
@@
describe('Worker choice strategy context test suite', () => {
workerChoiceStrategyContext.setWorkerChoiceStrategy(
WorkerChoiceStrategies.FAIR_SHARE
)
workerChoiceStrategyContext.setWorkerChoiceStrategy(
WorkerChoiceStrategies.FAIR_SHARE
)
- expect(workerChoiceStrategyContext.workerChoiceStrategy).toBeInstanceOf(
- DynamicPoolWorkerChoiceStrategy
- )
expect(
expect(
- workerChoiceStrategyContext.workerChoiceStrategy.workerChoiceStrategy
+ workerChoiceStrategyContext.getWorkerChoiceStrategy()
+ ).toBeInstanceOf(DynamicPoolWorkerChoiceStrategy)
+ expect(
+ workerChoiceStrategyContext.getWorkerChoiceStrategy().workerChoiceStrategy
).toBeInstanceOf(FairShareWorkerChoiceStrategy)
})
).toBeInstanceOf(FairShareWorkerChoiceStrategy)
})
@@
-174,9
+174,9
@@
describe('Worker choice strategy context test suite', () => {
workerChoiceStrategyContext.setWorkerChoiceStrategy(
WorkerChoiceStrategies.WEIGHTED_ROUND_ROBIN
)
workerChoiceStrategyContext.setWorkerChoiceStrategy(
WorkerChoiceStrategies.WEIGHTED_ROUND_ROBIN
)
- expect(
workerChoiceStrategyContext.workerChoiceStrategy).toBeInstanceOf(
- WeightedRoundRobinWorkerChoiceStrategy
- )
+ expect(
+ workerChoiceStrategyContext.getWorkerChoiceStrategy()
+ )
.toBeInstanceOf(WeightedRoundRobinWorkerChoiceStrategy)
})
it('Verify that setWorkerChoiceStrategy() works with WEIGHTED_ROUND_ROBIN and dynamic pool', () => {
})
it('Verify that setWorkerChoiceStrategy() works with WEIGHTED_ROUND_ROBIN and dynamic pool', () => {
@@
-186,11
+186,11
@@
describe('Worker choice strategy context test suite', () => {
workerChoiceStrategyContext.setWorkerChoiceStrategy(
WorkerChoiceStrategies.WEIGHTED_ROUND_ROBIN
)
workerChoiceStrategyContext.setWorkerChoiceStrategy(
WorkerChoiceStrategies.WEIGHTED_ROUND_ROBIN
)
- expect(workerChoiceStrategyContext.workerChoiceStrategy).toBeInstanceOf(
- DynamicPoolWorkerChoiceStrategy
- )
expect(
expect(
- workerChoiceStrategyContext.workerChoiceStrategy.workerChoiceStrategy
+ workerChoiceStrategyContext.getWorkerChoiceStrategy()
+ ).toBeInstanceOf(DynamicPoolWorkerChoiceStrategy)
+ expect(
+ workerChoiceStrategyContext.getWorkerChoiceStrategy().workerChoiceStrategy
).toBeInstanceOf(WeightedRoundRobinWorkerChoiceStrategy)
})
})
).toBeInstanceOf(WeightedRoundRobinWorkerChoiceStrategy)
})
})