repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
build(deps-dev): bump @types/node
[poolifier.git]
/
tests
/
pools
/
cluster
/
fixed.test.js
diff --git
a/tests/pools/cluster/fixed.test.js
b/tests/pools/cluster/fixed.test.js
index 335e6d131a9edf726e022120a197a062cc75374a..e563b0ba520c67f2f11b44221e61b88b098c6496 100644
(file)
--- a/
tests/pools/cluster/fixed.test.js
+++ b/
tests/pools/cluster/fixed.test.js
@@
-10,7
+10,7
@@
describe('Fixed cluster pool test suite', () => {
numberOfWorkers,
'./tests/worker-files/cluster/testWorker.js',
{
numberOfWorkers,
'./tests/worker-files/cluster/testWorker.js',
{
- errorHandler:
e
=> console.error(e)
+ errorHandler:
(e)
=> console.error(e)
}
)
const queuePool = new FixedClusterPool(
}
)
const queuePool = new FixedClusterPool(
@@
-21,7
+21,7
@@
describe('Fixed cluster pool test suite', () => {
tasksQueueOptions: {
concurrency: tasksConcurrency
},
tasksQueueOptions: {
concurrency: tasksConcurrency
},
- errorHandler:
e
=> console.error(e)
+ errorHandler:
(e)
=> console.error(e)
}
)
const emptyPool = new FixedClusterPool(
}
)
const emptyPool = new FixedClusterPool(
@@
-37,14
+37,14
@@
describe('Fixed cluster pool test suite', () => {
numberOfWorkers,
'./tests/worker-files/cluster/errorWorker.js',
{
numberOfWorkers,
'./tests/worker-files/cluster/errorWorker.js',
{
- errorHandler:
e
=> console.error(e)
+ errorHandler:
(e)
=> console.error(e)
}
)
const asyncErrorPool = new FixedClusterPool(
numberOfWorkers,
'./tests/worker-files/cluster/asyncErrorWorker.js',
{
}
)
const asyncErrorPool = new FixedClusterPool(
numberOfWorkers,
'./tests/worker-files/cluster/asyncErrorWorker.js',
{
- errorHandler:
e
=> console.error(e)
+ errorHandler:
(e)
=> console.error(e)
}
)
const asyncPool = new FixedClusterPool(
}
)
const asyncPool = new FixedClusterPool(
@@
-83,7
+83,7
@@
describe('Fixed cluster pool test suite', () => {
numberOfWorkers,
'./tests/worker-files/cluster/testWorker.js',
{
numberOfWorkers,
'./tests/worker-files/cluster/testWorker.js',
{
- errorHandler:
e
=> console.error(e)
+ errorHandler:
(e)
=> console.error(e)
}
)
let poolReady = 0
}
)
let poolReady = 0
@@
-111,6
+111,7
@@
describe('Fixed cluster pool test suite', () => {
}
expect(promises.size).toBe(numberOfWorkers * maxMultiplier)
for (const workerNode of queuePool.workerNodes) {
}
expect(promises.size).toBe(numberOfWorkers * maxMultiplier)
for (const workerNode of queuePool.workerNodes) {
+ expect(workerNode.usage.tasks.executing).toBeGreaterThanOrEqual(0)
expect(workerNode.usage.tasks.executing).toBeLessThanOrEqual(
queuePool.opts.tasksQueueOptions.concurrency
)
expect(workerNode.usage.tasks.executing).toBeLessThanOrEqual(
queuePool.opts.tasksQueueOptions.concurrency
)
@@
-158,7
+159,7
@@
describe('Fixed cluster pool test suite', () => {
it('Verify that error handling is working properly:sync', async () => {
const data = { f: 10 }
let taskError
it('Verify that error handling is working properly:sync', async () => {
const data = { f: 10 }
let taskError
- errorPool.emitter.on(PoolEvents.taskError,
e
=> {
+ errorPool.emitter.on(PoolEvents.taskError,
(e)
=> {
taskError = e
})
let inError
taskError = e
})
let inError
@@
-177,7
+178,7
@@
describe('Fixed cluster pool test suite', () => {
})
expect(
errorPool.workerNodes.some(
})
expect(
errorPool.workerNodes.some(
-
workerNode
=> workerNode.usage.tasks.failed === 1
+
(workerNode)
=> workerNode.usage.tasks.failed === 1
)
).toBe(true)
})
)
).toBe(true)
})
@@
-185,7
+186,7
@@
describe('Fixed cluster pool test suite', () => {
it('Verify that error handling is working properly:async', async () => {
const data = { f: 10 }
let taskError
it('Verify that error handling is working properly:async', async () => {
const data = { f: 10 }
let taskError
- asyncErrorPool.emitter.on(PoolEvents.taskError,
e
=> {
+ asyncErrorPool.emitter.on(PoolEvents.taskError,
(e)
=> {
taskError = e
})
let inError
taskError = e
})
let inError
@@
-204,7
+205,7
@@
describe('Fixed cluster pool test suite', () => {
})
expect(
asyncErrorPool.workerNodes.some(
})
expect(
asyncErrorPool.workerNodes.some(
-
workerNode
=> workerNode.usage.tasks.failed === 1
+
(workerNode)
=> workerNode.usage.tasks.failed === 1
)
).toBe(true)
})
)
).toBe(true)
})
@@
-220,9
+221,12
@@
describe('Fixed cluster pool test suite', () => {
it('Shutdown test', async () => {
const exitPromise = waitWorkerEvents(pool, 'exit', numberOfWorkers)
it('Shutdown test', async () => {
const exitPromise = waitWorkerEvents(pool, 'exit', numberOfWorkers)
+ let poolDestroy = 0
+ pool.emitter.on(PoolEvents.destroy, () => ++poolDestroy)
await pool.destroy()
const numberOfExitEvents = await exitPromise
expect(numberOfExitEvents).toBe(numberOfWorkers)
await pool.destroy()
const numberOfExitEvents = await exitPromise
expect(numberOfExitEvents).toBe(numberOfWorkers)
+ expect(poolDestroy).toBe(1)
})
it('Verify that cluster pool options are checked', async () => {
})
it('Verify that cluster pool options are checked', async () => {