133 lines
4.2 KiB
TypeScript
133 lines
4.2 KiB
TypeScript
import assert from 'node:assert/strict';
|
|
import { test } from 'node:test';
|
|
import Piscina from '..';
|
|
|
|
test('filename cannot be non-null/non-string',() => {
|
|
assert.throws(() => new Piscina(({
|
|
filename: 12
|
|
}) as any), /options.filename must be a string or null/);
|
|
});
|
|
|
|
test('name cannot be non-null/non-string', () => {
|
|
assert.throws(() => new Piscina(({
|
|
name: 12
|
|
}) as any), /options.name must be a string or null/);
|
|
});
|
|
|
|
test('minThreads must be non-negative integer', () => {
|
|
assert.throws(() => new Piscina(({
|
|
minThreads: -1
|
|
}) as any), /options.minThreads must be a non-negative integer/);
|
|
|
|
assert.throws(() => new Piscina(({
|
|
minThreads: 'string'
|
|
}) as any), /options.minThreads must be a non-negative integer/);
|
|
});
|
|
|
|
test('maxThreads must be positive integer', () => {
|
|
assert.throws(() => new Piscina(({
|
|
maxThreads: -1
|
|
}) as any), /options.maxThreads must be a positive integer/);
|
|
|
|
assert.throws(() => new Piscina(({
|
|
maxThreads: 0
|
|
}) as any), /options.maxThreads must be a positive integer/);
|
|
|
|
assert.throws(() => new Piscina(({
|
|
maxThreads: 'string'
|
|
}) as any), /options.maxThreads must be a positive integer/);
|
|
});
|
|
|
|
test('concurrentTasksPerWorker must be positive integer', () => {
|
|
assert.throws(() => new Piscina(({
|
|
concurrentTasksPerWorker: -1
|
|
}) as any), /options.concurrentTasksPerWorker must be a positive integer/);
|
|
|
|
assert.throws(() => new Piscina(({
|
|
concurrentTasksPerWorker: 0
|
|
}) as any), /options.concurrentTasksPerWorker must be a positive integer/);
|
|
|
|
assert.throws(() => new Piscina(({
|
|
concurrentTasksPerWorker: 'string'
|
|
}) as any), /options.concurrentTasksPerWorker must be a positive integer/);
|
|
});
|
|
|
|
test('idleTimeout must be non-negative integer', () => {
|
|
assert.throws(() => new Piscina(({
|
|
idleTimeout: -1
|
|
}) as any), /options.idleTimeout must be a non-negative integer/);
|
|
|
|
assert.throws(() => new Piscina(({
|
|
idleTimeout: 'string'
|
|
}) as any), /options.idleTimeout must be a non-negative integer/);
|
|
});
|
|
|
|
test('maxQueue must be non-negative integer', () => {
|
|
assert.throws(() => new Piscina(({
|
|
maxQueue: -1
|
|
}) as any), /options.maxQueue must be a non-negative integer/);
|
|
|
|
assert.throws(() => new Piscina(({
|
|
maxQueue: 'string'
|
|
}) as any), /options.maxQueue must be a non-negative integer/);
|
|
|
|
const p = new Piscina({ maxQueue: 'auto', maxThreads: 2 });
|
|
assert.strictEqual(p.options.maxQueue, 4);
|
|
});
|
|
|
|
test('atomics must be valid', () => {
|
|
assert.throws(() => new Piscina(({
|
|
atomics: -1
|
|
}) as any), /options.atomics should be a value of sync, sync or disabled./);
|
|
|
|
assert.throws(() => new Piscina(({
|
|
atomics: 'string'
|
|
}) as any), /options.atomics should be a value of sync, sync or disabled./);
|
|
});
|
|
|
|
test('resourceLimits must be an object', () => {
|
|
assert.throws(() => new Piscina(({
|
|
resourceLimits: 0
|
|
}) as any), /options.resourceLimits must be an object/);
|
|
});
|
|
|
|
test('taskQueue must be a TaskQueue object', () => {
|
|
assert.throws(() => new Piscina(({
|
|
taskQueue: 0
|
|
}) as any), /options.taskQueue must be a TaskQueue object/);
|
|
assert.throws(() => new Piscina(({
|
|
taskQueue: 'test'
|
|
}) as any), /options.taskQueue must be a TaskQueue object/);
|
|
assert.throws(() => new Piscina(({
|
|
taskQueue: null
|
|
}) as any), /options.taskQueue must be a TaskQueue object/);
|
|
assert.throws(() => new Piscina(({
|
|
taskQueue: new Date()
|
|
}) as any), /options.taskQueue must be a TaskQueue object/);
|
|
assert.throws(() => new Piscina(({
|
|
taskQueue: { } as any
|
|
}) as any), /options.taskQueue must be a TaskQueue object/);
|
|
});
|
|
|
|
test('niceIncrement must be non-negative integer on Unix', {
|
|
skip: process.platform === 'win32' ? 'Unix options validate' : false
|
|
}, () => {
|
|
assert.throws(() => new Piscina(({
|
|
niceIncrement: -1
|
|
}) as any), /options.niceIncrement must be a non-negative integer/);
|
|
|
|
assert.throws(() => new Piscina(({
|
|
niceIncrement: 'string'
|
|
}) as any), /options.niceIncrement must be a non-negative integer/);
|
|
});
|
|
|
|
test('trackUnmanagedFds must be a boolean', () => {
|
|
assert.throws(() => new Piscina(({
|
|
trackUnmanagedFds: -1
|
|
}) as any), /options.trackUnmanagedFds must be a boolean/);
|
|
|
|
assert.throws(() => new Piscina(({
|
|
trackUnmanagedFds: 'string'
|
|
}) as any), /options.trackUnmanagedFds must be a boolean/);
|
|
});
|