repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
test: add tasks queuing tests
[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 a8f187eee6098fab5bb6c8ede3ec5cff434da3d3..23d954c9f13159940e542c8774a3d22feefeaaad 100644
(file)
--- a/
tests/pools/selection-strategies/worker-choice-strategy-context.test.js
+++ b/
tests/pools/selection-strategies/worker-choice-strategy-context.test.js
@@
-69,17
+69,17
@@
describe('Worker choice strategy context test suite', () => {
choose: sinon.stub().returns(0)
}
)
choose: sinon.stub().returns(0)
}
)
- expect(workerChoiceStrategyContext.workerChoiceStrategy
Type
).toBe(
+ expect(workerChoiceStrategyContext.workerChoiceStrategy).toBe(
WorkerChoiceStrategies.ROUND_ROBIN
)
workerChoiceStrategyContext.workerChoiceStrategies.set(
WorkerChoiceStrategies.ROUND_ROBIN
)
workerChoiceStrategyContext.workerChoiceStrategies.set(
- workerChoiceStrategyContext.workerChoiceStrategy
Type
,
+ workerChoiceStrategyContext.workerChoiceStrategy,
WorkerChoiceStrategyStub
)
const chosenWorkerKey = workerChoiceStrategyContext.execute()
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
WorkerChoiceStrategyStub
)
const chosenWorkerKey = workerChoiceStrategyContext.execute()
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
- workerChoiceStrategyContext.workerChoiceStrategy
Type
+ workerChoiceStrategyContext.workerChoiceStrategy
).choose.calledOnce
).toBe(true)
expect(chosenWorkerKey).toBe(0)
).choose.calledOnce
).toBe(true)
expect(chosenWorkerKey).toBe(0)
@@
-95,255
+95,245
@@
describe('Worker choice strategy context test suite', () => {
choose: sinon.stub().returns(0)
}
)
choose: sinon.stub().returns(0)
}
)
- expect(workerChoiceStrategyContext.workerChoiceStrategy
Type
).toBe(
+ expect(workerChoiceStrategyContext.workerChoiceStrategy).toBe(
WorkerChoiceStrategies.ROUND_ROBIN
)
workerChoiceStrategyContext.workerChoiceStrategies.set(
WorkerChoiceStrategies.ROUND_ROBIN
)
workerChoiceStrategyContext.workerChoiceStrategies.set(
- workerChoiceStrategyContext.workerChoiceStrategy
Type
,
+ workerChoiceStrategyContext.workerChoiceStrategy,
WorkerChoiceStrategyStub
)
const chosenWorkerKey = workerChoiceStrategyContext.execute()
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
WorkerChoiceStrategyStub
)
const chosenWorkerKey = workerChoiceStrategyContext.execute()
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
- workerChoiceStrategyContext.workerChoiceStrategy
Type
+ workerChoiceStrategyContext.workerChoiceStrategy
).choose.calledOnce
).toBe(true)
expect(chosenWorkerKey).toBe(0)
})
it('Verify that setWorkerChoiceStrategy() works with ROUND_ROBIN and fixed pool', () => {
).choose.calledOnce
).toBe(true)
expect(chosenWorkerKey).toBe(0)
})
it('Verify that setWorkerChoiceStrategy() works with ROUND_ROBIN and fixed pool', () => {
+ const workerChoiceStrategy = WorkerChoiceStrategies.ROUND_ROBIN
const workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
fixedPool
)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
const workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
fixedPool
)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
- WorkerChoiceStrategies.ROUND_ROBIN
+ workerChoiceStrategy
).isDynamicPool
).toBe(false)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
).isDynamicPool
).toBe(false)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
- WorkerChoiceStrategies.ROUND_ROBIN
+ workerChoiceStrategy
)
).toBeInstanceOf(RoundRobinWorkerChoiceStrategy)
)
).toBeInstanceOf(RoundRobinWorkerChoiceStrategy)
- expect(workerChoiceStrategyContext.workerChoiceStrategyType).toBe(
- WorkerChoiceStrategies.ROUND_ROBIN
- )
- workerChoiceStrategyContext.setWorkerChoiceStrategy(
- WorkerChoiceStrategies.ROUND_ROBIN
+ expect(workerChoiceStrategyContext.workerChoiceStrategy).toBe(
+ workerChoiceStrategy
)
)
+ workerChoiceStrategyContext.setWorkerChoiceStrategy(workerChoiceStrategy)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
- WorkerChoiceStrategies.ROUND_ROBIN
+ workerChoiceStrategy
)
).toBeInstanceOf(RoundRobinWorkerChoiceStrategy)
)
).toBeInstanceOf(RoundRobinWorkerChoiceStrategy)
- expect(workerChoiceStrategyContext.workerChoiceStrategy
Type
).toBe(
- WorkerChoiceStrategies.ROUND_ROBIN
+ expect(workerChoiceStrategyContext.workerChoiceStrategy).toBe(
+ workerChoiceStrategy
)
})
it('Verify that setWorkerChoiceStrategy() works with ROUND_ROBIN and dynamic pool', () => {
)
})
it('Verify that setWorkerChoiceStrategy() works with ROUND_ROBIN and dynamic pool', () => {
+ const workerChoiceStrategy = WorkerChoiceStrategies.ROUND_ROBIN
const workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
dynamicPool
)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
const workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
dynamicPool
)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
- WorkerChoiceStrategies.ROUND_ROBIN
+ workerChoiceStrategy
).isDynamicPool
).toBe(true)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
).isDynamicPool
).toBe(true)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
- WorkerChoiceStrategies.ROUND_ROBIN
+ workerChoiceStrategy
)
).toBeInstanceOf(RoundRobinWorkerChoiceStrategy)
)
).toBeInstanceOf(RoundRobinWorkerChoiceStrategy)
- expect(workerChoiceStrategyContext.workerChoiceStrategyType).toBe(
- WorkerChoiceStrategies.ROUND_ROBIN
- )
- workerChoiceStrategyContext.setWorkerChoiceStrategy(
- WorkerChoiceStrategies.ROUND_ROBIN
+ expect(workerChoiceStrategyContext.workerChoiceStrategy).toBe(
+ workerChoiceStrategy
)
)
+ workerChoiceStrategyContext.setWorkerChoiceStrategy(workerChoiceStrategy)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
- WorkerChoiceStrategies.ROUND_ROBIN
+ workerChoiceStrategy
)
).toBeInstanceOf(RoundRobinWorkerChoiceStrategy)
)
).toBeInstanceOf(RoundRobinWorkerChoiceStrategy)
- expect(workerChoiceStrategyContext.workerChoiceStrategy
Type
).toBe(
- WorkerChoiceStrategies.ROUND_ROBIN
+ expect(workerChoiceStrategyContext.workerChoiceStrategy).toBe(
+ workerChoiceStrategy
)
})
it('Verify that setWorkerChoiceStrategy() works with LESS_USED and fixed pool', () => {
)
})
it('Verify that setWorkerChoiceStrategy() works with LESS_USED and fixed pool', () => {
+ const workerChoiceStrategy = WorkerChoiceStrategies.LESS_USED
const workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
fixedPool
)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
const workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
fixedPool
)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
- WorkerChoiceStrategies.LESS_USED
+ workerChoiceStrategy
).isDynamicPool
).toBe(false)
).isDynamicPool
).toBe(false)
- workerChoiceStrategyContext.setWorkerChoiceStrategy(
- WorkerChoiceStrategies.LESS_USED
- )
+ workerChoiceStrategyContext.setWorkerChoiceStrategy(workerChoiceStrategy)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
- WorkerChoiceStrategies.LESS_USED
+ workerChoiceStrategy
)
).toBeInstanceOf(LessUsedWorkerChoiceStrategy)
)
).toBeInstanceOf(LessUsedWorkerChoiceStrategy)
- expect(workerChoiceStrategyContext.workerChoiceStrategy
Type
).toBe(
- WorkerChoiceStrategies.LESS_USED
+ expect(workerChoiceStrategyContext.workerChoiceStrategy).toBe(
+ workerChoiceStrategy
)
})
it('Verify that setWorkerChoiceStrategy() works with LESS_USED and dynamic pool', () => {
)
})
it('Verify that setWorkerChoiceStrategy() works with LESS_USED and dynamic pool', () => {
+ const workerChoiceStrategy = WorkerChoiceStrategies.LESS_USED
const workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
dynamicPool
)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
const workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
dynamicPool
)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
- WorkerChoiceStrategies.LESS_USED
+ workerChoiceStrategy
).isDynamicPool
).toBe(true)
).isDynamicPool
).toBe(true)
- workerChoiceStrategyContext.setWorkerChoiceStrategy(
- WorkerChoiceStrategies.LESS_USED
- )
+ workerChoiceStrategyContext.setWorkerChoiceStrategy(workerChoiceStrategy)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
- WorkerChoiceStrategies.LESS_USED
+ workerChoiceStrategy
)
).toBeInstanceOf(LessUsedWorkerChoiceStrategy)
)
).toBeInstanceOf(LessUsedWorkerChoiceStrategy)
- expect(workerChoiceStrategyContext.workerChoiceStrategy
Type
).toBe(
- WorkerChoiceStrategies.LESS_USED
+ expect(workerChoiceStrategyContext.workerChoiceStrategy).toBe(
+ workerChoiceStrategy
)
})
it('Verify that setWorkerChoiceStrategy() works with LESS_BUSY and fixed pool', () => {
)
})
it('Verify that setWorkerChoiceStrategy() works with LESS_BUSY and fixed pool', () => {
+ const workerChoiceStrategy = WorkerChoiceStrategies.LESS_BUSY
const workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
fixedPool
)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
const workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
fixedPool
)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
- WorkerChoiceStrategies.LESS_BUSY
+ workerChoiceStrategy
).isDynamicPool
).toBe(false)
).isDynamicPool
).toBe(false)
- workerChoiceStrategyContext.setWorkerChoiceStrategy(
- WorkerChoiceStrategies.LESS_BUSY
- )
+ workerChoiceStrategyContext.setWorkerChoiceStrategy(workerChoiceStrategy)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
- WorkerChoiceStrategies.LESS_BUSY
+ workerChoiceStrategy
)
).toBeInstanceOf(LessBusyWorkerChoiceStrategy)
)
).toBeInstanceOf(LessBusyWorkerChoiceStrategy)
- expect(workerChoiceStrategyContext.workerChoiceStrategy
Type
).toBe(
- WorkerChoiceStrategies.LESS_BUSY
+ expect(workerChoiceStrategyContext.workerChoiceStrategy).toBe(
+ workerChoiceStrategy
)
})
it('Verify that setWorkerChoiceStrategy() works with LESS_BUSY and dynamic pool', () => {
)
})
it('Verify that setWorkerChoiceStrategy() works with LESS_BUSY and dynamic pool', () => {
+ const workerChoiceStrategy = WorkerChoiceStrategies.LESS_BUSY
const workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
dynamicPool
)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
const workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
dynamicPool
)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
- WorkerChoiceStrategies.LESS_BUSY
+ workerChoiceStrategy
).isDynamicPool
).toBe(true)
).isDynamicPool
).toBe(true)
- workerChoiceStrategyContext.setWorkerChoiceStrategy(
- WorkerChoiceStrategies.LESS_BUSY
- )
+ workerChoiceStrategyContext.setWorkerChoiceStrategy(workerChoiceStrategy)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
- WorkerChoiceStrategies.LESS_BUSY
+ workerChoiceStrategy
)
).toBeInstanceOf(LessBusyWorkerChoiceStrategy)
)
).toBeInstanceOf(LessBusyWorkerChoiceStrategy)
- expect(workerChoiceStrategyContext.workerChoiceStrategy
Type
).toBe(
- WorkerChoiceStrategies.LESS_BUSY
+ expect(workerChoiceStrategyContext.workerChoiceStrategy).toBe(
+ workerChoiceStrategy
)
})
it('Verify that setWorkerChoiceStrategy() works with FAIR_SHARE and fixed pool', () => {
)
})
it('Verify that setWorkerChoiceStrategy() works with FAIR_SHARE and fixed pool', () => {
+ const workerChoiceStrategy = WorkerChoiceStrategies.FAIR_SHARE
const workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
fixedPool
)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
const workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
fixedPool
)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
- WorkerChoiceStrategies.FAIR_SHARE
+ workerChoiceStrategy
).isDynamicPool
).toBe(false)
).isDynamicPool
).toBe(false)
- workerChoiceStrategyContext.setWorkerChoiceStrategy(
- WorkerChoiceStrategies.FAIR_SHARE
- )
+ workerChoiceStrategyContext.setWorkerChoiceStrategy(workerChoiceStrategy)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
- WorkerChoiceStrategies.FAIR_SHARE
+ workerChoiceStrategy
)
).toBeInstanceOf(FairShareWorkerChoiceStrategy)
)
).toBeInstanceOf(FairShareWorkerChoiceStrategy)
- expect(workerChoiceStrategyContext.workerChoiceStrategy
Type
).toBe(
- WorkerChoiceStrategies.FAIR_SHARE
+ expect(workerChoiceStrategyContext.workerChoiceStrategy).toBe(
+ workerChoiceStrategy
)
})
it('Verify that setWorkerChoiceStrategy() works with FAIR_SHARE and dynamic pool', () => {
)
})
it('Verify that setWorkerChoiceStrategy() works with FAIR_SHARE and dynamic pool', () => {
+ const workerChoiceStrategy = WorkerChoiceStrategies.FAIR_SHARE
const workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
dynamicPool
)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
const workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
dynamicPool
)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
- WorkerChoiceStrategies.FAIR_SHARE
+ workerChoiceStrategy
).isDynamicPool
).toBe(true)
).isDynamicPool
).toBe(true)
- workerChoiceStrategyContext.setWorkerChoiceStrategy(
- WorkerChoiceStrategies.FAIR_SHARE
- )
+ workerChoiceStrategyContext.setWorkerChoiceStrategy(workerChoiceStrategy)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
- WorkerChoiceStrategies.FAIR_SHARE
+ workerChoiceStrategy
)
).toBeInstanceOf(FairShareWorkerChoiceStrategy)
)
).toBeInstanceOf(FairShareWorkerChoiceStrategy)
- expect(workerChoiceStrategyContext.workerChoiceStrategy
Type
).toBe(
- WorkerChoiceStrategies.FAIR_SHARE
+ expect(workerChoiceStrategyContext.workerChoiceStrategy).toBe(
+ workerChoiceStrategy
)
})
it('Verify that setWorkerChoiceStrategy() works with WEIGHTED_ROUND_ROBIN and fixed pool', () => {
)
})
it('Verify that setWorkerChoiceStrategy() works with WEIGHTED_ROUND_ROBIN and fixed pool', () => {
+ const workerChoiceStrategy = WorkerChoiceStrategies.WEIGHTED_ROUND_ROBIN
const workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
fixedPool
)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
const workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
fixedPool
)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
- WorkerChoiceStrategies.WEIGHTED_ROUND_ROBIN
+ workerChoiceStrategy
).isDynamicPool
).toBe(false)
).isDynamicPool
).toBe(false)
- workerChoiceStrategyContext.setWorkerChoiceStrategy(
- WorkerChoiceStrategies.WEIGHTED_ROUND_ROBIN
- )
+ workerChoiceStrategyContext.setWorkerChoiceStrategy(workerChoiceStrategy)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
- WorkerChoiceStrategies.WEIGHTED_ROUND_ROBIN
+ workerChoiceStrategy
)
).toBeInstanceOf(WeightedRoundRobinWorkerChoiceStrategy)
)
).toBeInstanceOf(WeightedRoundRobinWorkerChoiceStrategy)
- expect(workerChoiceStrategyContext.workerChoiceStrategy
Type
).toBe(
- WorkerChoiceStrategies.WEIGHTED_ROUND_ROBIN
+ expect(workerChoiceStrategyContext.workerChoiceStrategy).toBe(
+ workerChoiceStrategy
)
})
it('Verify that setWorkerChoiceStrategy() works with WEIGHTED_ROUND_ROBIN and dynamic pool', () => {
)
})
it('Verify that setWorkerChoiceStrategy() works with WEIGHTED_ROUND_ROBIN and dynamic pool', () => {
+ const workerChoiceStrategy = WorkerChoiceStrategies.WEIGHTED_ROUND_ROBIN
const workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
dynamicPool
)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
const workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
dynamicPool
)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
- WorkerChoiceStrategies.WEIGHTED_ROUND_ROBIN
+ workerChoiceStrategy
).isDynamicPool
).toBe(true)
).isDynamicPool
).toBe(true)
- workerChoiceStrategyContext.setWorkerChoiceStrategy(
- WorkerChoiceStrategies.WEIGHTED_ROUND_ROBIN
- )
+ workerChoiceStrategyContext.setWorkerChoiceStrategy(workerChoiceStrategy)
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
expect(
workerChoiceStrategyContext.workerChoiceStrategies.get(
- WorkerChoiceStrategies.WEIGHTED_ROUND_ROBIN
+ workerChoiceStrategy
)
).toBeInstanceOf(WeightedRoundRobinWorkerChoiceStrategy)
)
).toBeInstanceOf(WeightedRoundRobinWorkerChoiceStrategy)
- expect(workerChoiceStrategyContext.workerChoiceStrategy
Type
).toBe(
- WorkerChoiceStrategies.WEIGHTED_ROUND_ROBIN
+ expect(workerChoiceStrategyContext.workerChoiceStrategy).toBe(
+ workerChoiceStrategy
)
})
})
)
})
})