Blame view
index.js
1.1 KB
ab5828535
|
1 |
process.chdir(__dirname); |
e57be634f
|
2 |
|
ab5828535
|
3 |
const fs = require('fs'); |
e57be634f
|
4 |
const numCPUs = require('os').cpus().length; |
ab5828535
|
5 |
|
ab5828535
|
6 7 8 9 |
const config = require('komodo-sdk/config'); global.KOMODO_LOG_LABEL = `KOMODO-CENTER@${config.name || 'HTTPGETX'}`; process.title = global.KOMODO_LOG_LABEL; |
360f77121
|
10 |
const cluster = require('cluster'); |
4978f3b37
|
11 |
const logger = require('tektrans-logger'); |
9742af5f7
|
12 |
const sdNotify = require('komodo-sdk/sd-notify'); |
ab5828535
|
13 |
|
360f77121
|
14 |
if (config.cluster && cluster.isMaster) { |
e57be634f
|
15 |
const numberOfChildren = config.cluster === true ? numCPUs + 1 : config.cluster; |
110669c26
|
16 17 18 19 20 |
logger.info('Running on cluster mode', { masterPid: process.pid, numberOfChildren, }); |
e57be634f
|
21 |
for (let i = 0; i < numberOfChildren; i += 1) { |
360f77121
|
22 23 24 25 26 27 28 29 |
cluster.fork(); } } else { if (config.cluster) { logger.info(`Worker ${process.pid} started`); } // eslint-disable-next-line global-require |
cd4feda87
|
30 31 |
require('./lib/apiserver'); // eslint-disable-next-line global-require |
f2c18879a
|
32 33 |
require('./lib/core-callback'); // eslint-disable-next-line global-require |
1ae80ad7f
|
34 |
require('./lib/partner-listener'); |
360f77121
|
35 |
} |
9742af5f7
|
36 37 38 39 |
fs.writeFileSync('pid.txt', process.pid.toString()); sdNotify(); |