X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Futils.test.js;h=93e9e5c2e9b17f99165beb29e028239c7328dfa9;hb=155bb3deed7d21089eba1ea650fe1a9d2c25132e;hp=18f266e2c2e8712483ec3946065c40e0cb3cfc28;hpb=4f37eb675971d5e79730442f189d3cd02ed61155;p=poolifier.git diff --git a/tests/utils.test.js b/tests/utils.test.js index 18f266e2..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(999.9) + expect(elapsed).toBeGreaterThanOrEqual(999) }) it('Verify exponentialDelay() behavior', () => {