Function runBenchmark

benchmark/lib/bench.js:10–76

(opts, handler, version, cb)

var pipeline = require('vasync').pipeline;

function runBenchmark(opts, handler, version, cb) {
    if (opts.track) {
        console.log(version.toUpperCase() + ':');
    }

    var spinner = ora('Started ' + version + '/' + handler).start();
    var modulePath = path.join(__dirname, '../benchmarks', handler);
    var url = require(modulePath).url;
    var forked = fork(modulePath, ['version=' + version]);

    pipeline(
        {
            funcs: [
                function warm(_, callback) {
                    spinner.color = 'magenta';
                    spinner.text =
                        'Warming ' + version + '/' + handler + ' for 5s';

                    var fireOpts = Object.assign({}, opts, {
                        duration: 5,
                        url: url
                    });
                    autocannon.fire(
                        fireOpts,
                        handler,
                        version,
                        false,
                        callback
                    );
                },

                function benchmark(_, callback) {
                    if (opts.track) {
                        spinner.stop();
                    } else {
                        spinner.color = 'yellow';
                        spinner.text =
                            'Benchmarking ' +
                            version +
                            '/' +
                            handler +
                            ' for ' +
                            opts.duration +
                            's';
                    }

                    var fireOpts = Object.assign({}, opts, { url: url });
                    autocannon.fire(fireOpts, handler, version, true, callback);
                }
            ]
        },
        function onPipelineFinished(err) {
            forked.kill('SIGINT');

            if (err) {
                spinner.fail();
                cb(err);
                return;