repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
build(examples): apply udpates
[poolifier.git]
/
tests
/
pools
/
worker-node.test.mjs
diff --git
a/tests/pools/worker-node.test.mjs
b/tests/pools/worker-node.test.mjs
index d524c464ee2d92139bb243b22b5b93749711e451..f70ce37bdba07f7e04370b7dd05544efe7f960da 100644
(file)
--- a/
tests/pools/worker-node.test.mjs
+++ b/
tests/pools/worker-node.test.mjs
@@
-58,6
+58,7
@@
describe('Worker node test suite', () => {
executing: 0,
queued: 0,
maxQueued: 0,
executing: 0,
queued: 0,
maxQueued: 0,
+ sequentiallyStolen: 0,
stolen: 0,
failed: 0
},
stolen: 0,
failed: 0
},
@@
-84,7
+85,6
@@
describe('Worker node test suite', () => {
threadWorkerNode.tasksQueue.size
)
expect(threadWorkerNode.onBackPressureStarted).toBe(false)
threadWorkerNode.tasksQueue.size
)
expect(threadWorkerNode.onBackPressureStarted).toBe(false)
- expect(threadWorkerNode.onEmptyQueueCount).toBe(0)
expect(threadWorkerNode.taskFunctionsUsage).toBeInstanceOf(Map)
expect(clusterWorkerNode).toBeInstanceOf(WorkerNode)
expect(threadWorkerNode.taskFunctionsUsage).toBeInstanceOf(Map)
expect(clusterWorkerNode).toBeInstanceOf(WorkerNode)
@@
-101,6
+101,7
@@
describe('Worker node test suite', () => {
executing: 0,
queued: 0,
maxQueued: 0,
executing: 0,
queued: 0,
maxQueued: 0,
+ sequentiallyStolen: 0,
stolen: 0,
failed: 0
},
stolen: 0,
failed: 0
},
@@
-127,7
+128,6
@@
describe('Worker node test suite', () => {
clusterWorkerNode.tasksQueue.size
)
expect(clusterWorkerNode.onBackPressureStarted).toBe(false)
clusterWorkerNode.tasksQueue.size
)
expect(clusterWorkerNode.onBackPressureStarted).toBe(false)
- expect(clusterWorkerNode.onEmptyQueueCount).toBe(0)
expect(clusterWorkerNode.taskFunctionsUsage).toBeInstanceOf(Map)
})
expect(clusterWorkerNode.taskFunctionsUsage).toBeInstanceOf(Map)
})
@@
-155,6
+155,7
@@
describe('Worker node test suite', () => {
executed: 0,
executing: 0,
queued: 0,
executed: 0,
executing: 0,
queued: 0,
+ sequentiallyStolen: 0,
stolen: 0,
failed: 0
},
stolen: 0,
failed: 0
},
@@
-178,6
+179,7
@@
describe('Worker node test suite', () => {
executed: 0,
executing: 0,
queued: 0,
executed: 0,
executing: 0,
queued: 0,
+ sequentiallyStolen: 0,
stolen: 0,
failed: 0
},
stolen: 0,
failed: 0
},
@@
-201,6
+203,7
@@
describe('Worker node test suite', () => {
executed: 0,
executing: 0,
queued: 0,
executed: 0,
executing: 0,
queued: 0,
+ sequentiallyStolen: 0,
stolen: 0,
failed: 0
},
stolen: 0,
failed: 0
},