| /third_party/node/test/parallel/ |
| D | test-runner-concurrency.js | 14 describe('Concurrency option (boolean) = true', { concurrency: true }, () => { property
26 'Concurrency option (boolean) = false',
27 { concurrency: false }, property
39 // Despite the docs saying so at some point, setting concurrency to true should
40 // not limit concurrency to the number of available CPU cores.
41 describe('concurrency: true implies Infinity', { concurrency: true }, () => { property
56 // Make sure tests run in order when root concurrency is 1 (default)
91 await fs.writeFile(path.resolve(tmpdir.path, 'test-runner-concurrency'), '');
94 fixtures.path('test-runner', 'concurrency', 'a.mjs'),
95 fixtures.path('test-runner', 'concurrency', 'b.mjs'),
|
| D | test-runner-cli-concurrency.js | 10 test('default concurrency', async () => {
13 assert.match(cp.stderr.toString(), /concurrency: true,/);
16 test('concurrency of one', async () => {
17 const args = ['--test', '--test-concurrency=1'];
19 assert.match(cp.stderr.toString(), /concurrency: 1,/);
22 test('concurrency of two', async () => {
23 const args = ['--test', '--test-concurrency=2'];
25 assert.match(cp.stderr.toString(), /concurrency: 2,/);
|
| D | test-runner-option-validation.js | 17 [Symbol(), {}, [], () => {}, 1n, '1'].forEach((concurrency) => {
18 assert.throws(() => test({ concurrency }), { code: 'ERR_INVALID_ARG_TYPE' }); field
20 [-1, 0, 1.1, -Infinity, NaN, 2 ** 33, Number.MAX_SAFE_INTEGER].forEach((concurrency) => {
21 assert.throws(() => test({ concurrency }), { code: 'ERR_OUT_OF_RANGE' }); field
23 [null, undefined, 1, 2 ** 31, true, false].forEach((concurrency) => {
25 test({ concurrency }); field
|
| D | test-runner-inspect.mjs | 33 …inspector with --test forces running at a concurrency of 1\. Use the inspectPort option to run wit…
42 …inspector with --test forces running at a concurrency of 1\. Use the inspectPort option to run wit…
56 …inspector with --test forces running at a concurrency of 1\. Use the inspectPort option to run wit…
|
| D | test-stream-map.js | 159 // Concurrency + AbortSignal
165 }, 2), { signal: ac.signal, concurrency: 2, highWaterMark: 0 }); property
181 // Concurrency result order
185 }, { concurrency: 2 }); property
197 // highWaterMark with small concurrency
210 }, { concurrency: 2 }); property
220 // highWaterMark with a lot of items and large concurrency
257 }, { concurrency: 6 }); property
268 // Custom highWaterMark with a lot of items and large concurrency
305 }, { concurrency: 5, highWaterMark: 7 }); property
[all …]
|
| D | test-stream-filter.js | 118 // Concurrency + AbortSignal
124 }, { signal: ac.signal, concurrency: 2 }); property
142 // Concurrency result order
146 }, { concurrency: 2 }); property
160 concurrency: 'Foo' property
|
| D | test-stream-some-find-every.mjs | 108 // Concurrency doesn't affect which value is found.
114 }, { concurrency: 2 }); property
150 concurrency: 'Foo'
152 }, /ERR_OUT_OF_RANGE/, `${op} should throw for invalid concurrency`).then(common.mustCall());
155 … }, /ERR_INVALID_ARG_TYPE/, `${op} should throw for invalid concurrency`).then(common.mustCall());
|
| D | test-stream-flatMap.js | 74 // Concurrency + AbortSignal
78 }), { signal: ac.signal, concurrency: 2 }); property
114 concurrency: 'Foo' property
|
| D | test-stream-forEach.js | 92 // Concurrency + AbortSignal
99 }, { signal: ac.signal, concurrency: 2, highWaterMark: 0 }); property
120 concurrency: 'Foo' property
|
| /third_party/node/deps/npm/node_modules/p-map/ |
| D | index.js | 8 concurrency = Infinity, argument
17 if (!((Number.isSafeInteger(concurrency) || concurrency === Infinity) && concurrency >= 1)) {
18 … TypeError(`Expected \`concurrency\` to be an integer from 1 and up or \`Infinity\`, got \`${concu…
73 for (let i = 0; i < concurrency; i++) {
|
| /third_party/node/benchmark/test_runner/ |
| D | suite-tests.js | 13 concurrency: ['yes', 'no'], property
19 async function run({ numberOfSuites, testsPerSuite, testType, concurrency }) { field
20 concurrency = concurrency === 'yes';
28 describe(`${i}`, { concurrency }, () => { field
42 describe(`${i}`, { concurrency }, () => { field
|
| /third_party/node/lib/internal/main/ |
| D | test_runner.js | 27 let concurrency = getOptionValue('--test-concurrency') || true; variable
31 process.emitWarning('Using the inspector with --test forces running at a concurrency of 1. ' +
32 'Use the inspectPort option to run with concurrency');
33 concurrency = 1;
63 concurrency, property
|
| /third_party/node/benchmark/tls/ |
| D | tls-connect.js | 7 concurrency: [1, 10], property
14 let concurrency; variable
19 concurrency = conf.concurrency;
35 for (let i = 0; i < concurrency; i++)
|
| /third_party/node/lib/internal/streams/ |
| D | operators.js | 81 let concurrency = 1;
82 if (options?.concurrency != null) {
83 concurrency = MathFloor(options.concurrency);
86 let highWaterMark = concurrency - 1;
91 validateInteger(concurrency, 'options.concurrency', 1);
94 highWaterMark += concurrency;
121 cnt < concurrency &&
162 if (!done && (queue.length >= highWaterMark || cnt >= concurrency)) {
|
| /third_party/node/lib/internal/test_runner/ |
| D | test.js | 212 const { concurrency, loc, only, timeout, todo, signal } = options;
227 this.concurrency = 1;
246 this.concurrency = parent.concurrency;
263 switch (typeof concurrency) {
265 validateUint32(concurrency, 'options.concurrency', 1);
266 this.concurrency = concurrency;
270 if (concurrency) {
271 this.concurrency = parent === null ?
274 this.concurrency = 1;
279 if (concurrency != null)
[all …]
|
| /third_party/node/test/pummel/ |
| D | test-net-many-clients.js | 29 const concurrency = 50; constant
90 for (let i = 0; i < concurrency; i++) {
92 if (++finished_clients === concurrency) server.close();
98 assert.strictEqual(total_connections, connections_per_client * concurrency);
|
| /third_party/node/test/es-module/ |
| D | test-esm-extensionless-esm-and-wasm.mjs | 7 describe('extensionless ES modules within a "type": "module" package scope', { concurrency: true },… property
32 describe('extensionless Wasm modules within a "type": "module" package scope', { concurrency: true … property
58 describe('extensionless ES modules within no package scope', { concurrency: true }, () => { property
82 describe('extensionless Wasm within no package scope', { concurrency: true }, () => { property
|
| /third_party/node/deps/npm/node_modules/cacache/lib/ |
| D | verify.js | 23 concurrency: 20, property
151 { concurrency: opts.concurrency } property
211 { concurrency: opts.concurrency } property
|
| /third_party/node/test/fixtures/test-runner/concurrency/ |
| D | b.mjs | 7 const file = await fs.readFile(path.resolve(tmpdir.path, 'test-runner-concurrency'), 'utf8');
9 await fs.writeFile(path.resolve(tmpdir.path, 'test-runner-concurrency'), 'b.mjs');
|
| D | a.mjs | 6 await fs.writeFile(path.resolve(tmpdir.path, 'test-runner-concurrency'), 'a.mjs');
8 const file = await fs.readFile(path.resolve(tmpdir.path, 'test-runner-concurrency'), 'utf8');
|
| /third_party/typescript/tests/cases/docker/pyright/ |
| D | Dockerfile | 7 RUN npx lerna exec --stream --concurrency 1 -- npm install /typescript.tgz --exact --ignore-scripts…
9 CMD [ "lerna", "exec", "--stream", "--concurrency", "1", "--no-bail", "--", "tsc", "--noEmit" ]
|
| /third_party/libuv/test/ |
| D | benchmark-pound.c | 271 static int pound_it(int concurrency, in pound_it() argument
290 do_setup(concurrency, arg); in pound_it()
292 r = do_connect(concurrency, make_connect, arg); in pound_it()
304 concurrency, in pound_it()
|
| /third_party/skia/experimental/wasm-skp-debugger/ |
| D | karma.conf.js | 54 // Concurrency level
56 concurrency: Infinity, property
|
| /third_party/skia/modules/pathkit/ |
| D | karma.bench.conf.js | 52 // Concurrency level
54 concurrency: Infinity, property
|
| /third_party/skia/modules/canvaskit/ |
| D | karma.conf.js | 55 // Concurrency level
57 concurrency: Infinity, property
|