@@ -221,12 +221,12 @@ function emitForkNT(worker) {
|
221 | 221 | } |
222 | 222 | |
223 | 223 | cluster.disconnect = function(cb) { |
224 | | -const workers = ObjectKeys(cluster.workers); |
| 224 | +const workers = ObjectValues(cluster.workers); |
225 | 225 | |
226 | 226 | if (workers.length === 0) { |
227 | 227 | process.nextTick(() => intercom.emit('disconnect')); |
228 | 228 | } else { |
229 | | -for (const worker of ObjectValues(cluster.workers)) { |
| 229 | +for (const worker of workers) { |
230 | 230 | if (worker.isConnected()) { |
231 | 231 | worker.disconnect(); |
232 | 232 | } |
@@ -358,8 +358,6 @@ Worker.prototype.disconnect = function() {
|
358 | 358 | }; |
359 | 359 | |
360 | 360 | Worker.prototype.destroy = function(signo) { |
361 | | -const proc = this.process; |
362 | 361 | const signal = signo || 'SIGTERM'; |
363 | | - |
364 | | -proc.kill(signal); |
| 362 | +this.process.kill(signal); |
365 | 363 | }; |