'use strict';

const cfork = require('cfork');
const util = require('util');
const path = require('path');
const os = require('os');

// 获取 cpu 核数
const cpuNumbers = os.cpus().length;

cfork({
  exec: path.join(__dirname, './bootstrap.js'),
  count: cpuNumbers,
})
  .on('fork', worker => {
    console.warn(
      '[%s] [worker:%d] new worker start',
      Date(),
      worker.process.pid
    );
  })
  .on('disconnect', worker => {
    console.warn(
      '[%s] [master:%s] wroker:%s disconnect, exitedAfterDisconnect: %s, state: %s.',
      Date(),
      process.pid,
      worker.process.pid,
      worker.exitedAfterDisconnect,
      worker.state
    );
  })
  .on('exit', (worker, code, signal) => {
    const exitCode = worker.process.exitCode;
    const err = new Error(
      util.format(
        'worker %s died (code: %s, signal: %s, exitedAfterDisconnect: %s, state: %s)',
        worker.process.pid,
        exitCode,
        signal,
        worker.exitedAfterDisconnect,
        worker.state
      )
    );
    err.name = 'WorkerDiedError';
    console.error(
      '[%s] [master:%s] wroker exit: %s',
      Date(),
      process.pid,
      err.stack
    );
  });