X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Futils.test.js;h=93e9e5c2e9b17f99165beb29e028239c7328dfa9;hb=47bbac7dec41b3ebed83eed3a7fb9c9333b3d3f7;hp=57bd2611ba9d517a0af1a458301b8fe090c633a9;hpb=bb9423b78d11f9420b9b2a8cb865ea8c1315e642;p=poolifier.git diff --git a/tests/utils.test.js b/tests/utils.test.js index 57bd2611..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', () => { @@ -49,7 +85,7 @@ describe('Utils test suite', () => { const start = performance.now() await sleep(1000) const elapsed = performance.now() - start - expect(elapsed).toBeGreaterThanOrEqual(1000) + expect(elapsed).toBeGreaterThanOrEqual(999) }) it('Verify exponentialDelay() behavior', () => {