Function main

benchmark/http/cluster.js:20–44

({ type, len, c, duration })

}

function main({ type, len, c, duration }) {
  process.env.PORT = PORT;
  let workers = 0;
  const w1 = cluster.fork();
  const w2 = cluster.fork();

  cluster.on('listening', () => {
    workers++;
    if (workers < 2)
      return;

    setImmediate(() => {
      const path = `/${type}/${len}`;

      bench.http({
        path: path,
        connections: c,
        duration,
      }, () => {
        w1.destroy();
        w2.destroy();
      });
    });
  });
}