repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
fix: disable `tasksStealingOnBackPressure` by default
[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 d6339080b7b001862609ce1fe48366e9791f84f1..27ce3d2d4c66e27a6385a360c6efb12544099ac9 100644
(file)
--- a/
tests/pools/worker-node.test.mjs
+++ b/
tests/pools/worker-node.test.mjs
@@
-192,6
+192,7
@@
describe('Worker node test suite', () => {
type: WorkerTypes.thread,
dynamic: false,
ready: false,
type: WorkerTypes.thread,
dynamic: false,
ready: false,
+ backPressure: false,
stealing: false
})
expect(threadWorkerNode.usage).toStrictEqual({
stealing: false
})
expect(threadWorkerNode.usage).toStrictEqual({
@@
-227,7
+228,7
@@
describe('Worker node test suite', () => {
expect(threadWorkerNode.tasksQueueSize()).toBe(
threadWorkerNode.tasksQueue.size
)
expect(threadWorkerNode.tasksQueueSize()).toBe(
threadWorkerNode.tasksQueue.size
)
- expect(threadWorkerNode.
onBackPressureStarted
).toBe(false)
+ expect(threadWorkerNode.
setBackPressureFlag
).toBe(false)
expect(threadWorkerNode.taskFunctionsUsage).toBeInstanceOf(Map)
expect(clusterWorkerNode).toBeInstanceOf(WorkerNode)
expect(threadWorkerNode.taskFunctionsUsage).toBeInstanceOf(Map)
expect(clusterWorkerNode).toBeInstanceOf(WorkerNode)
@@
-237,6
+238,7
@@
describe('Worker node test suite', () => {
type: WorkerTypes.cluster,
dynamic: false,
ready: false,
type: WorkerTypes.cluster,
dynamic: false,
ready: false,
+ backPressure: false,
stealing: false
})
expect(clusterWorkerNode.usage).toStrictEqual({
stealing: false
})
expect(clusterWorkerNode.usage).toStrictEqual({
@@
-272,7
+274,7
@@
describe('Worker node test suite', () => {
expect(clusterWorkerNode.tasksQueueSize()).toBe(
clusterWorkerNode.tasksQueue.size
)
expect(clusterWorkerNode.tasksQueueSize()).toBe(
clusterWorkerNode.tasksQueue.size
)
- expect(clusterWorkerNode.
onBackPressureStarted
).toBe(false)
+ expect(clusterWorkerNode.
setBackPressureFlag
).toBe(false)
expect(clusterWorkerNode.taskFunctionsUsage).toBeInstanceOf(Map)
})
expect(clusterWorkerNode.taskFunctionsUsage).toBeInstanceOf(Map)
})