repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
refactor: cleanups
[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 0415d9c1eaa7a94cdc1f1260a9bac060c5703c04..749cacaa4d4ade34727242e21caa1071be504b4c 100644
(file)
--- a/
tests/pools/cluster/fixed.test.js
+++ b/
tests/pools/cluster/fixed.test.js
@@
-1,6
+1,6
@@
const { expect } = require('expect')
const { FixedClusterPool, PoolEvents } = require('../../../lib')
const { expect } = require('expect')
const { FixedClusterPool, PoolEvents } = require('../../../lib')
-const {
Worker
Functions } = require('../../test-types')
+const {
Task
Functions } = require('../../test-types')
const { waitPoolEvents, waitWorkerEvents } = require('../../test-utils')
describe('Fixed cluster pool test suite', () => {
const { waitPoolEvents, waitWorkerEvents } = require('../../test-utils')
describe('Fixed cluster pool test suite', () => {
@@
-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,13
+21,13
@@
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(
numberOfWorkers,
'./tests/worker-files/cluster/emptyWorker.js',
}
)
const emptyPool = new FixedClusterPool(
numberOfWorkers,
'./tests/worker-files/cluster/emptyWorker.js',
- { exitHandler: () => console.
log
('empty pool worker exited') }
+ { exitHandler: () => console.
info
('empty pool worker exited') }
)
const echoPool = new FixedClusterPool(
numberOfWorkers,
)
const echoPool = new FixedClusterPool(
numberOfWorkers,
@@
-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(
@@
-64,11
+64,11
@@
describe('Fixed cluster pool test suite', () => {
it('Verify that the function is executed in a worker cluster', async () => {
let result = await pool.execute({
it('Verify that the function is executed in a worker cluster', async () => {
let result = await pool.execute({
- function:
Worker
Functions.fibonacci
+ function:
Task
Functions.fibonacci
})
expect(result).toBe(75025)
result = await pool.execute({
})
expect(result).toBe(75025)
result = await pool.execute({
- function:
Worker
Functions.factorial
+ function:
Task
Functions.factorial
})
expect(result).toBe(9.33262154439441e157)
})
})
expect(result).toBe(9.33262154439441e157)
})
@@
-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
@@
-158,7
+158,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
+177,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
+185,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
+204,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
+220,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 () => {