repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge dependabot/npm_and_yarn/examples/typescript/websocket-server-pool/ws-worker_thr...
[poolifier.git]
/
tests
/
pools
/
abstract-pool.test.mjs
diff --git
a/tests/pools/abstract-pool.test.mjs
b/tests/pools/abstract-pool.test.mjs
index ccd2423102427a40878faf2ee347aa20f3f58964..4b32e253a3aed5c203bfff7476d49a02a6b4488c 100644
(file)
--- a/
tests/pools/abstract-pool.test.mjs
+++ b/
tests/pools/abstract-pool.test.mjs
@@
-221,6
+221,7
@@
describe('Abstract pool test suite', () => {
'./tests/worker-files/thread/testWorker.mjs'
)
expect(pool.emitter).toBeInstanceOf(EventEmitterAsyncResource)
'./tests/worker-files/thread/testWorker.mjs'
)
expect(pool.emitter).toBeInstanceOf(EventEmitterAsyncResource)
+ expect(pool.emitter.eventNames()).toStrictEqual([])
expect(pool.opts).toStrictEqual({
startWorkers: true,
enableEvents: true,
expect(pool.opts).toStrictEqual({
startWorkers: true,
enableEvents: true,
@@
-703,6
+704,7
@@
describe('Abstract pool test suite', () => {
started: true,
ready: true,
strategy: WorkerChoiceStrategies.ROUND_ROBIN,
started: true,
ready: true,
strategy: WorkerChoiceStrategies.ROUND_ROBIN,
+ strategyRetries: 0,
minSize: numberOfWorkers,
maxSize: numberOfWorkers,
workerNodes: numberOfWorkers,
minSize: numberOfWorkers,
maxSize: numberOfWorkers,
workerNodes: numberOfWorkers,
@@
-725,6
+727,7
@@
describe('Abstract pool test suite', () => {
started: true,
ready: true,
strategy: WorkerChoiceStrategies.ROUND_ROBIN,
started: true,
ready: true,
strategy: WorkerChoiceStrategies.ROUND_ROBIN,
+ strategyRetries: 0,
minSize: Math.floor(numberOfWorkers / 2),
maxSize: numberOfWorkers,
workerNodes: Math.floor(numberOfWorkers / 2),
minSize: Math.floor(numberOfWorkers / 2),
maxSize: numberOfWorkers,
workerNodes: Math.floor(numberOfWorkers / 2),
@@
-861,8
+864,8
@@
describe('Abstract pool test suite', () => {
)
expect(pool.info.started).toBe(false)
expect(pool.info.ready).toBe(false)
)
expect(pool.info.started).toBe(false)
expect(pool.info.ready).toBe(false)
- expect(pool.readyEventEmitted).toBe(false)
expect(pool.workerNodes).toStrictEqual([])
expect(pool.workerNodes).toStrictEqual([])
+ expect(pool.readyEventEmitted).toBe(false)
await expect(pool.execute()).rejects.toThrow(
new Error('Cannot execute a task on not started pool')
)
await expect(pool.execute()).rejects.toThrow(
new Error('Cannot execute a task on not started pool')
)
@@
-1074,6
+1077,7
@@
describe('Abstract pool test suite', () => {
started: true,
ready: true,
strategy: WorkerChoiceStrategies.ROUND_ROBIN,
started: true,
ready: true,
strategy: WorkerChoiceStrategies.ROUND_ROBIN,
+ strategyRetries: expect.any(Number),
minSize: expect.any(Number),
maxSize: expect.any(Number),
workerNodes: expect.any(Number),
minSize: expect.any(Number),
maxSize: expect.any(Number),
workerNodes: expect.any(Number),
@@
-1114,6
+1118,7
@@
describe('Abstract pool test suite', () => {
started: true,
ready: true,
strategy: WorkerChoiceStrategies.ROUND_ROBIN,
started: true,
ready: true,
strategy: WorkerChoiceStrategies.ROUND_ROBIN,
+ strategyRetries: expect.any(Number),
minSize: expect.any(Number),
maxSize: expect.any(Number),
workerNodes: expect.any(Number),
minSize: expect.any(Number),
maxSize: expect.any(Number),
workerNodes: expect.any(Number),
@@
-1153,6
+1158,7
@@
describe('Abstract pool test suite', () => {
started: true,
ready: true,
strategy: WorkerChoiceStrategies.ROUND_ROBIN,
started: true,
ready: true,
strategy: WorkerChoiceStrategies.ROUND_ROBIN,
+ strategyRetries: expect.any(Number),
minSize: expect.any(Number),
maxSize: expect.any(Number),
workerNodes: expect.any(Number),
minSize: expect.any(Number),
maxSize: expect.any(Number),
workerNodes: expect.any(Number),
@@
-1195,6
+1201,7
@@
describe('Abstract pool test suite', () => {
started: true,
ready: true,
strategy: WorkerChoiceStrategies.ROUND_ROBIN,
started: true,
ready: true,
strategy: WorkerChoiceStrategies.ROUND_ROBIN,
+ strategyRetries: expect.any(Number),
minSize: expect.any(Number),
maxSize: expect.any(Number),
workerNodes: expect.any(Number),
minSize: expect.any(Number),
maxSize: expect.any(Number),
workerNodes: expect.any(Number),
@@
-1239,7
+1246,7
@@
describe('Abstract pool test suite', () => {
const elapsedTime = performance.now() - startTime
expect(tasksFinished).toBeLessThanOrEqual(numberOfWorkers * maxMultiplier)
expect(elapsedTime).toBeGreaterThanOrEqual(2000)
const elapsedTime = performance.now() - startTime
expect(tasksFinished).toBeLessThanOrEqual(numberOfWorkers * maxMultiplier)
expect(elapsedTime).toBeGreaterThanOrEqual(2000)
- expect(elapsedTime).toBeLessThanOrEqual(tasksFinishedTimeout +
4
00)
+ expect(elapsedTime).toBeLessThanOrEqual(tasksFinishedTimeout +
8
00)
})
it('Verify that destroy() waits until the tasks finished timeout is reached', async () => {
})
it('Verify that destroy() waits until the tasks finished timeout is reached', async () => {