repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
test: cleanup expected data structure
[poolifier.git]
/
tests
/
pools
/
selection-strategies
/
selection-strategies.test.mjs
diff --git
a/tests/pools/selection-strategies/selection-strategies.test.mjs
b/tests/pools/selection-strategies/selection-strategies.test.mjs
index e0eec68b714a3152e49ed6bfd3e26d50a06e8584..b7597b4c0c71d0f326fb866dbebb1d277474667f 100644
(file)
--- a/
tests/pools/selection-strategies/selection-strategies.test.mjs
+++ b/
tests/pools/selection-strategies/selection-strategies.test.mjs
@@
-277,6
+277,7
@@
describe('Selection strategies test suite', () => {
executing: 0,
queued: 0,
maxQueued: 0,
executing: 0,
queued: 0,
maxQueued: 0,
+ sequentiallyStolen: 0,
stolen: 0,
failed: 0
},
stolen: 0,
failed: 0
},
@@
-332,6
+333,7
@@
describe('Selection strategies test suite', () => {
executing: 0,
queued: 0,
maxQueued: 0,
executing: 0,
queued: 0,
maxQueued: 0,
+ sequentiallyStolen: 0,
stolen: 0,
failed: 0
},
stolen: 0,
failed: 0
},
@@
-378,7
+380,7
@@
describe('Selection strategies test suite', () => {
)
let results = new Set()
for (let i = 0; i < max; i++) {
)
let results = new Set()
for (let i = 0; i < max; i++) {
- results.add(pool.workerNodes[pool.chooseWorkerNode()].
worker
.id)
+ results.add(pool.workerNodes[pool.chooseWorkerNode()].
info
.id)
}
expect(results.size).toBe(max)
await pool.destroy()
}
expect(results.size).toBe(max)
await pool.destroy()
@@
-389,7
+391,7
@@
describe('Selection strategies test suite', () => {
)
results = new Set()
for (let i = 0; i < max; i++) {
)
results = new Set()
for (let i = 0; i < max; i++) {
- results.add(pool.workerNodes[pool.chooseWorkerNode()].
worker.threadI
d)
+ results.add(pool.workerNodes[pool.chooseWorkerNode()].
info.i
d)
}
expect(results.size).toBe(max)
await pool.destroy()
}
expect(results.size).toBe(max)
await pool.destroy()
@@
-557,6
+559,7
@@
describe('Selection strategies test suite', () => {
executing: 0,
queued: 0,
maxQueued: 0,
executing: 0,
queued: 0,
maxQueued: 0,
+ sequentiallyStolen: 0,
stolen: 0,
failed: 0
},
stolen: 0,
failed: 0
},
@@
-615,6
+618,7
@@
describe('Selection strategies test suite', () => {
executing: 0,
queued: 0,
maxQueued: 0,
executing: 0,
queued: 0,
maxQueued: 0,
+ sequentiallyStolen: 0,
stolen: 0,
failed: 0
},
stolen: 0,
failed: 0
},
@@
-754,6
+758,7
@@
describe('Selection strategies test suite', () => {
executing: 0,
queued: 0,
maxQueued: 0,
executing: 0,
queued: 0,
maxQueued: 0,
+ sequentiallyStolen: 0,
stolen: 0,
failed: 0
},
stolen: 0,
failed: 0
},
@@
-822,6
+827,7
@@
describe('Selection strategies test suite', () => {
executing: 0,
queued: 0,
maxQueued: 0,
executing: 0,
queued: 0,
maxQueued: 0,
+ sequentiallyStolen: 0,
stolen: 0,
failed: 0
},
stolen: 0,
failed: 0
},
@@
-971,6
+977,7
@@
describe('Selection strategies test suite', () => {
executing: 0,
queued: 0,
maxQueued: 0,
executing: 0,
queued: 0,
maxQueued: 0,
+ sequentiallyStolen: 0,
stolen: 0,
failed: 0
},
stolen: 0,
failed: 0
},
@@
-1045,6
+1052,7
@@
describe('Selection strategies test suite', () => {
executing: 0,
queued: 0,
maxQueued: 0,
executing: 0,
queued: 0,
maxQueued: 0,
+ sequentiallyStolen: 0,
stolen: 0,
failed: 0
},
stolen: 0,
failed: 0
},
@@
-1200,6
+1208,7
@@
describe('Selection strategies test suite', () => {
executing: 0,
queued: 0,
maxQueued: 0,
executing: 0,
queued: 0,
maxQueued: 0,
+ sequentiallyStolen: 0,
stolen: 0,
failed: 0
},
stolen: 0,
failed: 0
},
@@
-1285,6
+1294,7
@@
describe('Selection strategies test suite', () => {
executing: 0,
queued: 0,
maxQueued: 0,
executing: 0,
queued: 0,
maxQueued: 0,
+ sequentiallyStolen: 0,
stolen: 0,
failed: 0
},
stolen: 0,
failed: 0
},
@@
-1375,6
+1385,7
@@
describe('Selection strategies test suite', () => {
executing: 0,
queued: 0,
maxQueued: 0,
executing: 0,
queued: 0,
maxQueued: 0,
+ sequentiallyStolen: 0,
stolen: 0,
failed: 0
},
stolen: 0,
failed: 0
},
@@
-1575,6
+1586,7
@@
describe('Selection strategies test suite', () => {
executing: 0,
queued: 0,
maxQueued: 0,
executing: 0,
queued: 0,
maxQueued: 0,
+ sequentiallyStolen: 0,
stolen: 0,
failed: 0
},
stolen: 0,
failed: 0
},
@@
-1653,6
+1665,7
@@
describe('Selection strategies test suite', () => {
executing: 0,
queued: 0,
maxQueued: 0,
executing: 0,
queued: 0,
maxQueued: 0,
+ sequentiallyStolen: 0,
stolen: 0,
failed: 0
},
stolen: 0,
failed: 0
},
@@
-1736,6
+1749,7
@@
describe('Selection strategies test suite', () => {
executing: 0,
queued: 0,
maxQueued: 0,
executing: 0,
queued: 0,
maxQueued: 0,
+ sequentiallyStolen: 0,
stolen: 0,
failed: 0
},
stolen: 0,
failed: 0
},
@@
-1998,6
+2012,7
@@
describe('Selection strategies test suite', () => {
executing: 0,
queued: 0,
maxQueued: 0,
executing: 0,
queued: 0,
maxQueued: 0,
+ sequentiallyStolen: 0,
stolen: 0,
failed: 0
},
stolen: 0,
failed: 0
},
@@
-2083,6
+2098,7
@@
describe('Selection strategies test suite', () => {
executing: 0,
queued: 0,
maxQueued: 0,
executing: 0,
queued: 0,
maxQueued: 0,
+ sequentiallyStolen: 0,
stolen: 0,
failed: 0
},
stolen: 0,
failed: 0
},
@@
-2300,6
+2316,6
@@
describe('Selection strategies test suite', () => {
'./tests/worker-files/thread/testWorker.mjs',
{ workerChoiceStrategy: 'UNKNOWN_STRATEGY' }
)
'./tests/worker-files/thread/testWorker.mjs',
{ workerChoiceStrategy: 'UNKNOWN_STRATEGY' }
)
- ).toThrow
Error
("Invalid worker choice strategy 'UNKNOWN_STRATEGY'")
+ ).toThrow("Invalid worker choice strategy 'UNKNOWN_STRATEGY'")
})
})
})
})