@@ -11,58 +11,58 @@ const WORKER_CNT = config.workerVal;
11
11
const activeWorkers = [ ] ;
12
12
13
13
const forceKill = ( worker ) => {
14
- if ( ! worker . isDead ( ) ) {
15
- logger . info ( `Worker ${ worker . process . pid } is ${ worker . state } , Killing it` ) ;
16
- worker . kill ( 'SIGUSR2' ) ;
17
- }
14
+ if ( ! worker . isDead ( ) ) {
15
+ logger . info ( `Worker ${ worker . process . pid } is ${ worker . state } , Killing it` ) ;
16
+ worker . kill ( 'SIGUSR2' ) ;
17
+ }
18
18
} ;
19
19
20
20
const disconnectOldWorkers = ( ) => {
21
- const len = activeWorkers . length ;
22
- for ( let i = 0 ; i < len ; i ++ ) {
23
- const oldWorker = activeWorkers . shift ( ) ;
24
- oldWorker . disconnect ( ) ;
25
- setTimeout ( ( ) => forceKill ( oldWorker ) , config . workerKillTimer ) ;
26
- }
21
+ const len = activeWorkers . length ;
22
+ for ( let i = 0 ; i < len ; i ++ ) {
23
+ const oldWorker = activeWorkers . shift ( ) ;
24
+ oldWorker . disconnect ( ) ;
25
+ setTimeout ( ( ) => forceKill ( oldWorker ) , config . workerKillTimer ) ;
26
+ }
27
27
} ;
28
28
29
29
const spawnNewWorkers = ( ) => {
30
- if ( cluster . isMaster ) {
31
- for ( let i = 0 ; i < WORKER_CNT ; ++ i ) {
32
- const worker = cluster . fork ( ) ;
33
- worker . on ( 'error' , ( err ) => {
34
- logger . error ( `Received error event on ${ worker . id } : ${ err } ` ) ;
35
- } ) ;
36
- logger . info ( `Created worker with id ${ worker . id } ` ) ;
37
- activeWorkers . push ( worker ) ;
38
- }
39
- }
30
+ if ( cluster . isMaster ) {
31
+ for ( let i = 0 ; i < WORKER_CNT ; ++ i ) {
32
+ const worker = cluster . fork ( ) ;
33
+ worker . on ( 'error' , ( err ) => {
34
+ logger . error ( `Received error event on ${ worker . id } : ${ err } ` ) ;
35
+ } ) ;
36
+ logger . info ( `Created worker with id ${ worker . id } ` ) ;
37
+ activeWorkers . push ( worker ) ;
38
+ }
39
+ }
40
40
} ;
41
41
42
42
if ( cluster . isMaster ) {
43
- cluster . on ( 'online' , function ( worker ) {
44
- logger . info ( `Worker ${ worker . process . pid } is online` ) ;
45
- } ) ;
43
+ cluster . on ( 'online' , function ( worker ) {
44
+ logger . info ( `Worker ${ worker . process . pid } is online` ) ;
45
+ } ) ;
46
46
47
- cluster . on ( 'exit' , ( worker , code , signal ) => {
48
- logger . info (
49
- `worker ${ worker . process . pid } died with signal ${ signal } code ${ code } `
50
- ) ;
51
- if ( activeWorkers . length == 0 ) spawnNewWorkers ( ) ;
52
- } ) ;
47
+ cluster . on ( 'exit' , ( worker , code , signal ) => {
48
+ logger . info (
49
+ `worker ${ worker . process . pid } died with signal ${ signal } code ${ code } `
50
+ ) ;
51
+ if ( activeWorkers . length == 0 ) spawnNewWorkers ( ) ;
52
+ } ) ;
53
53
54
- spawnNewWorkers ( ) ;
54
+ spawnNewWorkers ( ) ;
55
55
56
- let currTime = Date . now ( ) ;
57
- watch ( 'tmp/restart.txt' , ( ) => {
58
- if ( Date . now ( ) > currTime ) {
59
- currTime = Date . now ( ) ;
60
- disconnectOldWorkers ( ) ;
61
- spawnNewWorkers ( ) ;
62
- }
63
- } ) ;
56
+ let currTime = Date . now ( ) ;
57
+ watch ( 'tmp/restart.txt' , ( ) => {
58
+ if ( Date . now ( ) > currTime ) {
59
+ currTime = Date . now ( ) ;
60
+ disconnectOldWorkers ( ) ;
61
+ spawnNewWorkers ( ) ;
62
+ }
63
+ } ) ;
64
64
} else {
65
- new Proxy ( ) ;
65
+ new Proxy ( ) ;
66
66
}
67
67
68
68
process . on ( 'uncaughtException' , new ProcessHandler ( ) . onError ) ;
0 commit comments