repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge dependabot/npm_and_yarn/examples/typescript/websocket-server-pool/ws-hybrid...
[poolifier.git]
/
tests
/
utils.test.js
diff --git
a/tests/utils.test.js
b/tests/utils.test.js
index b91929a6fb9414bbc778460825eecfb59302edbe..93e9e5c2e9b17f99165beb29e028239c7328dfa9 100644
(file)
--- a/
tests/utils.test.js
+++ b/
tests/utils.test.js
@@
-1,6
+1,7
@@
const { randomInt } = require('crypto')
const { Worker } = require('worker_threads')
const cluster = require('cluster')
const { randomInt } = require('crypto')
const { Worker } = require('worker_threads')
const cluster = require('cluster')
+const os = require('os')
const { expect } = require('expect')
const {
CircularArray,
const { expect } = require('expect')
const {
CircularArray,
@@
-56,8
+57,14
@@
describe('Utils test suite', () => {
it('Verify availableParallelism() behavior', () => {
const parallelism = availableParallelism()
expect(typeof parallelism === 'number').toBe(true)
it('Verify availableParallelism() behavior', () => {
const parallelism = availableParallelism()
expect(typeof parallelism === 'number').toBe(true)
- expect(parallelism).toBeGreaterThan(0)
expect(Number.isSafeInteger(parallelism)).toBe(true)
expect(Number.isSafeInteger(parallelism)).toBe(true)
+ let expectedParallelism = 1
+ try {
+ expectedParallelism = os.availableParallelism()
+ } catch {
+ expectedParallelism = os.cpus().length
+ }
+ expect(parallelism).toBe(expectedParallelism)
})
it('Verify getWorkerType() behavior', () => {
})
it('Verify getWorkerType() behavior', () => {