-
Notifications
You must be signed in to change notification settings - Fork 29.6k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
benchmark: make benchmarks runnable in older versions of Node.js
Also remove the require-cachable.js benchmarks because now all builtin modules are cacheable, it would be comparing oranges to apples when we try to compare the performance of loading all cacheable modules in different Node.js binaries since the set of modules are just different. Comparison of startup performance that involves loading of the long-standing, stable builtins is already covered by the require-builtins benchmark. PR-URL: #45746 Reviewed-By: Chengzhong Wu <legendecas@gmail.com> Reviewed-By: Yagiz Nizipli <yagiz@nizipli.com> Reviewed-By: Anna Henningsen <anna@addaleax.net>
- Loading branch information
1 parent
b9c2fc7
commit 102c2dc
Showing
3 changed files
with
43 additions
and
64 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file was deleted.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,80 +1,69 @@ | ||
'use strict'; | ||
const common = require('../common.js'); | ||
const { spawn } = require('child_process'); | ||
const { spawnSync } = require('child_process'); | ||
const path = require('path'); | ||
|
||
let Worker; // Lazy loaded in main | ||
|
||
const bench = common.createBenchmark(main, { | ||
dur: [1], | ||
script: [ | ||
'benchmark/fixtures/require-builtins', | ||
'benchmark/fixtures/require-cachable', | ||
'test/fixtures/semicolon', | ||
], | ||
mode: ['process', 'worker'] | ||
}, { | ||
flags: ['--expose-internals'] | ||
mode: ['process', 'worker'], | ||
count: [30], | ||
}); | ||
|
||
function spawnProcess(script) { | ||
function spawnProcess(script, bench, state) { | ||
const cmd = process.execPath || process.argv[0]; | ||
const argv = ['--expose-internals', script]; | ||
return spawn(cmd, argv); | ||
} | ||
while (state.finished < state.count) { | ||
const child = spawnSync(cmd, [script]); | ||
if (child.status !== 0) { | ||
console.log('---- STDOUT ----'); | ||
console.log(child.stdout.toString()); | ||
console.log('---- STDERR ----'); | ||
console.log(child.stderr.toString()); | ||
throw new Error(`Child process stopped with exit code ${child.status}`); | ||
} | ||
state.finished++; | ||
if (state.finished === 0) { | ||
// Finished warmup. | ||
bench.start(); | ||
} | ||
|
||
function spawnWorker(script) { | ||
return new Worker(script, { stderr: true, stdout: true }); | ||
if (state.finished === state.count) { | ||
bench.end(state.count); | ||
} | ||
} | ||
} | ||
|
||
function start(state, script, bench, getNode) { | ||
const node = getNode(script); | ||
let stdout = ''; | ||
let stderr = ''; | ||
|
||
node.stdout.on('data', (data) => { | ||
stdout += data; | ||
}); | ||
|
||
node.stderr.on('data', (data) => { | ||
stderr += data; | ||
}); | ||
|
||
node.on('exit', (code) => { | ||
function spawnWorker(script, bench, state) { | ||
const child = new Worker(script); | ||
child.on('exit', (code) => { | ||
if (code !== 0) { | ||
console.error('------ stdout ------'); | ||
console.error(stdout); | ||
console.error('------ stderr ------'); | ||
console.error(stderr); | ||
throw new Error(`Error during node startup, exit code ${code}`); | ||
throw new Error(`Worker stopped with exit code ${code}`); | ||
} | ||
state.throughput++; | ||
|
||
if (state.go) { | ||
start(state, script, bench, getNode); | ||
state.finished++; | ||
if (state.finished === 0) { | ||
// Finished warmup. | ||
bench.start(); | ||
} | ||
if (state.finished < state.count) { | ||
spawnProcess(script, bench, state); | ||
} else { | ||
bench.end(state.throughput); | ||
bench.end(state.count); | ||
} | ||
}); | ||
} | ||
|
||
function main({ dur, script, mode }) { | ||
const state = { | ||
go: true, | ||
throughput: 0 | ||
}; | ||
|
||
setTimeout(() => { | ||
state.go = false; | ||
}, dur * 1000); | ||
|
||
function main({ count, script, mode }) { | ||
script = path.resolve(__dirname, '../../', `${script}.js`); | ||
const warmup = 3; | ||
const state = { count, finished: -warmup }; | ||
if (mode === 'worker') { | ||
Worker = require('worker_threads').Worker; | ||
bench.start(); | ||
start(state, script, bench, spawnWorker); | ||
spawnWorker(script, bench, state); | ||
} else { | ||
bench.start(); | ||
start(state, script, bench, spawnProcess); | ||
spawnProcess(script, bench, state); | ||
} | ||
} |