X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Fpools%2Fcluster%2Fdynamic.test.js;h=c737c1d90ebc08743d5ae2a0af99c8957433376c;hb=ec3e56520d46660ea043d5184f5d8246c834d252;hp=02a022870d4911eced33b2dd529ae695c7280210;hpb=ef18443d24959faaf7da0bcd74d10dad43272005;p=poolifier.git diff --git a/tests/pools/cluster/dynamic.test.js b/tests/pools/cluster/dynamic.test.js index 02a02287..c737c1d9 100644 --- a/tests/pools/cluster/dynamic.test.js +++ b/tests/pools/cluster/dynamic.test.js @@ -1,34 +1,39 @@ const { expect } = require('expect') -const { DynamicClusterPool } = require('../../../lib/index') +const { DynamicClusterPool, PoolEvents } = require('../../../lib') +const { WorkerFunctions } = require('../../test-types') const TestUtils = require('../../test-utils') -const min = 1 -const max = 3 -const pool = new DynamicClusterPool( - min, - max, - './tests/worker-files/cluster/testWorker.js', - { - errorHandler: e => console.error(e) - } -) describe('Dynamic cluster pool test suite', () => { + const min = 1 + const max = 3 + const pool = new DynamicClusterPool( + min, + max, + './tests/worker-files/cluster/testWorker.js', + { + errorHandler: e => console.error(e) + } + ) + it('Verify that the function is executed in a worker cluster', async () => { - const result = await pool.execute({ test: 'test' }) - expect(result).toBeDefined() - expect(result).toBeFalsy() + let result = await pool.execute({ + function: WorkerFunctions.fibonacci + }) + expect(result).toBe(121393) + result = await pool.execute({ + function: WorkerFunctions.factorial + }) + expect(result).toBe(9.33262154439441e157) }) it('Verify that new workers are created when required, max size is not exceeded and that after a while new workers will die', async () => { - const promises = [] let poolBusy = 0 - pool.emitter.on('busy', () => poolBusy++) + pool.emitter.on(PoolEvents.busy, () => ++poolBusy) for (let i = 0; i < max * 2; i++) { - promises.push(pool.execute({ test: 'test' })) + pool.execute() } - // await Promise.all(promises) - expect(pool.workers.length).toBeLessThanOrEqual(max) - expect(pool.workers.length).toBeGreaterThan(min) + expect(pool.workerNodes.length).toBeLessThanOrEqual(max) + expect(pool.workerNodes.length).toBeGreaterThan(min) // The `busy` event is triggered when the number of submitted tasks at once reach the max number of workers in the dynamic pool. // So in total numberOfWorkers + 1 times for a loop submitting up to numberOfWorkers * 2 tasks to the dynamic pool. expect(poolBusy).toBe(max + 1) @@ -37,19 +42,19 @@ describe('Dynamic cluster pool test suite', () => { }) it('Verify scale worker up and down is working', async () => { - expect(pool.workers.length).toBe(min) - for (let i = 0; i < max * 10; i++) { - pool.execute({ test: 'test' }) + expect(pool.workerNodes.length).toBe(min) + for (let i = 0; i < max * 2; i++) { + pool.execute() } - expect(pool.workers.length).toBeGreaterThan(min) + expect(pool.workerNodes.length).toBeGreaterThan(min) await TestUtils.waitExits(pool, max - min) - expect(pool.workers.length).toBe(min) - for (let i = 0; i < max * 10; i++) { - pool.execute({ test: 'test' }) + expect(pool.workerNodes.length).toBe(min) + for (let i = 0; i < max * 2; i++) { + pool.execute() } - expect(pool.workers.length).toBeGreaterThan(min) + expect(pool.workerNodes.length).toBeGreaterThan(min) await TestUtils.waitExits(pool, max - min) - expect(pool.workers.length).toBe(min) + expect(pool.workerNodes.length).toBe(min) }) it('Shutdown test', async () => { @@ -61,19 +66,18 @@ describe('Dynamic cluster pool test suite', () => { it('Validation of inputs test', () => { expect(() => new DynamicClusterPool(min)).toThrowError( - new Error('Please specify a file with a worker implementation') + 'Please specify a file with a worker implementation' ) }) it('Should work even without opts in input', async () => { const pool1 = new DynamicClusterPool( - 1, - 1, + min, + max, './tests/worker-files/cluster/testWorker.js' ) - const result = await pool1.execute({ test: 'test' }) - expect(result).toBeDefined() - expect(result).toBeFalsy() + const result = await pool1.execute() + expect(result).toBe(false) // We need to clean up the resources after our test await pool1.destroy() }) @@ -89,14 +93,18 @@ describe('Dynamic cluster pool test suite', () => { exitHandler: () => console.log('long running worker exited') } ) - expect(longRunningPool.workers.length).toBe(min) - for (let i = 0; i < max * 10; i++) { - longRunningPool.execute({ test: 'test' }) + expect(longRunningPool.workerNodes.length).toBe(min) + for (let i = 0; i < max * 2; i++) { + longRunningPool.execute() } - expect(longRunningPool.workers.length).toBe(max) + expect(longRunningPool.workerNodes.length).toBe(max) await TestUtils.waitExits(longRunningPool, max - min) - // Here we expect the workers to be at the max size since that the task is still running - expect(longRunningPool.workers.length).toBe(min) + expect(longRunningPool.workerNodes.length).toBe(min) + expect( + longRunningPool.workerChoiceStrategyContext.workerChoiceStrategies.get( + longRunningPool.workerChoiceStrategyContext.workerChoiceStrategy + ).nextWorkerNodeId + ).toBeLessThan(longRunningPool.workerNodes.length) // We need to clean up the resources after our test await longRunningPool.destroy() }) @@ -112,14 +120,14 @@ describe('Dynamic cluster pool test suite', () => { exitHandler: () => console.log('long running worker exited') } ) - expect(longRunningPool.workers.length).toBe(min) - for (let i = 0; i < max * 10; i++) { - longRunningPool.execute({ test: 'test' }) + expect(longRunningPool.workerNodes.length).toBe(min) + for (let i = 0; i < max * 2; i++) { + longRunningPool.execute() } - expect(longRunningPool.workers.length).toBe(max) + expect(longRunningPool.workerNodes.length).toBe(max) await TestUtils.sleep(1500) - // Here we expect the workers to be at the max size since that the task is still running - expect(longRunningPool.workers.length).toBe(max) + // Here we expect the workerNodes to be at the max size since the task is still running + expect(longRunningPool.workerNodes.length).toBe(max) // We need to clean up the resources after our test await longRunningPool.destroy() })