Function main

lib/server.js:443–505

()

}

function main() {
    const workers = _config.clusters;
    if (!_config.isCluster) {
        process.env.REPORT_TOKEN = _config.reportToken;
        const server = new S3Server(_config);
        server.initiateStartup(logger.newRequestLogger());
    }
    if (_config.isCluster && cluster.isPrimary) {
        for (let n = 0; n < workers; n++) {
            const worker = cluster.fork();
            logger.info('new worker forked', {
                workerId: worker.id,
                workerPid: worker.process.pid,
            });
        }
        setInterval(() => {
            const len = Object.keys(cluster.workers).length;
            if (len < workers) {
                for (let i = len; i < workers; i++) {
                    const newWorker = cluster.fork();
                    logger.info('new worker forked', {
                        workerId: newWorker.id,
                        workerPid: newWorker.process.pid,
                    });
                }
            }
        }, 1000);
        cluster.on('disconnect', worker => {
            logger.error('worker disconnected. making sure exits', {
                workerId: worker.id,
                workerPid: worker.process.pid,
            });
            setTimeout(() => {
                if (!worker.isDead() && !worker.exitedAfterDisconnect) {
                    logger.error('worker not exiting. killing it', {
                        workerId: worker.id,
                        workerPid: worker.pid,
                    });
                    worker.process.kill('SIGKILL');
                }
            }, 2000);
        });
        cluster.on('exit', worker => {
            logger.error('worker exited.', {
                workerId: worker.id,
                workerPid: worker.process.pid,
            });
        });

        const metricServer = new S3Server(_config);
        metricServer.startServer(_config.metricsListenOn,
            _config.metricsPort, metricServer.routeAdminRequest);
    }
    if (_config.isCluster && cluster.isWorker) {
        const server = new S3Server(_config, cluster.worker);
        server.initiateStartup(logger.newRequestLogger());
    }