|
1 | 1 | var common = require('../common');
|
2 | 2 | var assert = require('assert');
|
3 | 3 | var cluster = require('cluster');
|
4 |
| -var fs = require('fs'); |
5 |
| -var path = require('path'); |
6 | 4 |
|
7 | 5 | if (cluster.isWorker) {
|
8 | 6 | var http = require('http');
|
9 | 7 | http.Server(function() {
|
10 | 8 |
|
11 | 9 | }).listen(common.PORT, '127.0.0.1');
|
12 | 10 |
|
13 |
| - // Save flag-file on disconnect |
14 | 11 | cluster.worker.on('disconnect', function(){
|
15 |
| - fs.writeFileSync(path.join(__dirname, process.pid + ''), ''); |
| 12 | + process.exit(42); |
16 | 13 | });
|
17 | 14 |
|
18 | 15 | } else if (cluster.isMaster) {
|
@@ -67,17 +64,10 @@ if (cluster.isWorker) {
|
67 | 64 | });
|
68 | 65 |
|
69 | 66 | // Check that the worker died
|
70 |
| - worker.once('exit', function() { |
| 67 | + worker.once('exit', function(code) { |
71 | 68 | checks.worker.emitExit = true;
|
72 | 69 | checks.worker.died = !alive(worker.process.pid);
|
73 |
| - |
74 |
| - var flagFile = path.join(__dirname, worker.process.pid + ''); |
75 |
| - checks.worker.emitDisconnectInsideWorker = fs.existsSync(flagFile); |
76 |
| - |
77 |
| - // cleanup |
78 |
| - if (checks.worker.emitDisconnectInsideWorker) { |
79 |
| - fs.unlinkSync(flagFile); |
80 |
| - } |
| 70 | + checks.worker.emitDisconnectInsideWorker = code === 42; |
81 | 71 |
|
82 | 72 | process.nextTick(function() {
|
83 | 73 | process.exit(0);
|
|
0 commit comments