File tree Expand file tree Collapse file tree 2 files changed +5
-3
lines changed
Expand file tree Collapse file tree 2 files changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -385,17 +385,19 @@ Process.prototype.listen = function() {
385385 self . emitter . emit ( 'died' , worker . pid ) ;
386386 self . stats . workersKilled ++ ;
387387 self . stats . noWorkers -- ;
388+ delete self . workers [ worker . pid + '' ] ;
389+ delete self . stats . workers [ worker . pid ] ;
388390 return ;
389391 }
390392
391393 self . emitter . emit ( 'died' , worker . pid ) ;
392394 self . stats . workersKilled ++ ;
393395 self . stats . noWorkers -- ;
396+ delete self . workers [ worker . pid + '' ] ;
397+ delete self . stats . workers [ worker . pid ] ;
394398 //bugfix by huzhou@ebay .com, worker & replacement name collision
395399 var replacement = self . createWorker ( ) ;
396400 self . workers [ replacement . pid + '' ] = replacement ;
397- delete self . workers [ worker . pid + '' ] ;
398- delete self . stats . workers [ worker . pid ] ;
399401
400402 log ( '[cluster2] updated worker list:' + _ . keys ( self . workers ) ) ;
401403 } ;
Original file line number Diff line number Diff line change 55 "email" : " subbu@ebaysf.com"
66 }],
77 "name" : " cluster2" ,
8- "version" : " 0.4.16 " ,
8+ "version" : " 0.4.17 " ,
99 "repository" : {
1010 "type" : " git" ,
1111 "url" : " https://github.com/ql-io/cluster2"
You can’t perform that action at this time.
0 commit comments