X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Futils.test.js;h=93e9e5c2e9b17f99165beb29e028239c7328dfa9;hb=472f3f1a5d003abdbb94c5ce808de7c44bfe90ab;hp=0fc6dc8ac968ba885eb44186f91377b2126d7964;hpb=4be58f3c4495ba79ee81aa32064bebea185a24b5;p=poolifier.git diff --git a/tests/utils.test.js b/tests/utils.test.js index 0fc6dc8a..93e9e5c2 100644 --- a/tests/utils.test.js +++ b/tests/utils.test.js @@ -1,12 +1,17 @@ const { randomInt } = require('crypto') const { Worker } = require('worker_threads') const cluster = require('cluster') +const os = require('os') const { expect } = require('expect') const { CircularArray, DEFAULT_CIRCULAR_ARRAY_SIZE } = require('../lib/circular-array') const { + DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS, + DEFAULT_TASK_NAME, + DEFAULT_WORKER_CHOICE_STRATEGY_OPTIONS, + EMPTY_FUNCTION, availableParallelism, average, exponentialDelay, @@ -24,11 +29,42 @@ const { const { KillBehaviors, WorkerTypes } = require('../lib') describe('Utils test suite', () => { + it('Verify DEFAULT_TASK_NAME value', () => { + expect(DEFAULT_TASK_NAME).toBe('default') + }) + + it('Verify EMPTY_FUNCTION value', () => { + expect(EMPTY_FUNCTION).toStrictEqual(expect.any(Function)) + }) + + it('Verify DEFAULT_WORKER_CHOICE_STRATEGY_OPTIONS values', () => { + expect(DEFAULT_WORKER_CHOICE_STRATEGY_OPTIONS).toStrictEqual({ + retries: 6, + runTime: { median: false }, + waitTime: { median: false }, + elu: { median: false } + }) + }) + + it('Verify DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS values', () => { + expect(DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS).toStrictEqual({ + aggregate: false, + average: false, + median: false + }) + }) + it('Verify availableParallelism() behavior', () => { const parallelism = availableParallelism() expect(typeof parallelism === 'number').toBe(true) - expect(parallelism).toBeGreaterThan(0) 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', () => {