repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
refactor: cleanup worker usage properties namespace
[poolifier.git]
/
tests
/
pools
/
abstract
/
abstract-pool.test.js
diff --git
a/tests/pools/abstract/abstract-pool.test.js
b/tests/pools/abstract/abstract-pool.test.js
index b5a53487a490dd32b3d460389e25de7c5993feeb..424ad352e198c9356950248ca9b6296964acfa50 100644
(file)
--- a/
tests/pools/abstract/abstract-pool.test.js
+++ b/
tests/pools/abstract/abstract-pool.test.js
@@
-432,7
+432,7
@@
describe('Abstract pool test suite', () => {
it('Simulate worker not found', async () => {
const pool = new StubPoolWithRemoveAllWorker(
numberOfWorkers,
it('Simulate worker not found', async () => {
const pool = new StubPoolWithRemoveAllWorker(
numberOfWorkers,
- './tests/worker-files/
cluster
/testWorker.js',
+ './tests/worker-files/
thread
/testWorker.js',
{
errorHandler: e => console.error(e)
}
{
errorHandler: e => console.error(e)
}
@@
-450,7
+450,7
@@
describe('Abstract pool test suite', () => {
'./tests/worker-files/cluster/testWorker.js'
)
for (const workerNode of pool.workerNodes) {
'./tests/worker-files/cluster/testWorker.js'
)
for (const workerNode of pool.workerNodes) {
- expect(workerNode.
workerU
sage).toStrictEqual({
+ expect(workerNode.
u
sage).toStrictEqual({
tasks: {
executed: 0,
executing: 0,
tasks: {
executed: 0,
executing: 0,
@@
-515,7
+515,7
@@
describe('Abstract pool test suite', () => {
promises.add(pool.execute())
}
for (const workerNode of pool.workerNodes) {
promises.add(pool.execute())
}
for (const workerNode of pool.workerNodes) {
- expect(workerNode.
workerU
sage).toStrictEqual({
+ expect(workerNode.
u
sage).toStrictEqual({
tasks: {
executed: 0,
executing: maxMultiplier,
tasks: {
executed: 0,
executing: maxMultiplier,
@@
-554,7
+554,7
@@
describe('Abstract pool test suite', () => {
}
await Promise.all(promises)
for (const workerNode of pool.workerNodes) {
}
await Promise.all(promises)
for (const workerNode of pool.workerNodes) {
- expect(workerNode.
workerU
sage).toStrictEqual({
+ expect(workerNode.
u
sage).toStrictEqual({
tasks: {
executed: maxMultiplier,
executing: 0,
tasks: {
executed: maxMultiplier,
executing: 0,
@@
-607,7
+607,7
@@
describe('Abstract pool test suite', () => {
}
await Promise.all(promises)
for (const workerNode of pool.workerNodes) {
}
await Promise.all(promises)
for (const workerNode of pool.workerNodes) {
- expect(workerNode.
workerU
sage).toStrictEqual({
+ expect(workerNode.
u
sage).toStrictEqual({
tasks: {
executed: expect.any(Number),
executing: 0,
tasks: {
executed: expect.any(Number),
executing: 0,
@@
-643,14
+643,12
@@
describe('Abstract pool test suite', () => {
utilization: 0
}
})
utilization: 0
}
})
- expect(workerNode.workerUsage.tasks.executed).toBeGreaterThan(0)
- expect(workerNode.workerUsage.tasks.executed).toBeLessThanOrEqual(
- maxMultiplier
- )
+ expect(workerNode.usage.tasks.executed).toBeGreaterThan(0)
+ expect(workerNode.usage.tasks.executed).toBeLessThanOrEqual(maxMultiplier)
}
pool.setWorkerChoiceStrategy(WorkerChoiceStrategies.FAIR_SHARE)
for (const workerNode of pool.workerNodes) {
}
pool.setWorkerChoiceStrategy(WorkerChoiceStrategies.FAIR_SHARE)
for (const workerNode of pool.workerNodes) {
- expect(workerNode.
workerU
sage).toStrictEqual({
+ expect(workerNode.
u
sage).toStrictEqual({
tasks: {
executed: 0,
executing: 0,
tasks: {
executed: 0,
executing: 0,
@@
-686,8
+684,8
@@
describe('Abstract pool test suite', () => {
utilization: 0
}
})
utilization: 0
}
})
- expect(workerNode.
workerU
sage.runTime.history.length).toBe(0)
- expect(workerNode.
workerU
sage.waitTime.history.length).toBe(0)
+ expect(workerNode.
u
sage.runTime.history.length).toBe(0)
+ expect(workerNode.
u
sage.waitTime.history.length).toBe(0)
}
await pool.destroy()
})
}
await pool.destroy()
})