guard against sending IPC when not connected

Author: bjornstar

lib/index.js

@@ -102,7 +102,7 @@ module.exports = function (script, scriptArgs, nodeArgs, opts) {
 
   // Relay SIGTERM
   process.on('SIGTERM', function () {
-    if (child) {
+    if (child && child.connected) {
       if (cfg.graceful_ipc) {
         log.info('Sending IPC: ' + JSON.stringify(cfg.graceful_ipc));
         child.send(cfg.graceful_ipc);

test/fixture/cluster.js

@@ -1,17 +1,33 @@
 var cluster = require('cluster');
 
-if (cluster.isMaster) {
-  function createWorker(i) {
-    var worker = cluster.fork();
-    worker.on('message', function (msg) {
-      console.log('Message from worker' + i + ':', msg);
-    });
-    worker.on('exit', function (code) {
-      console.log(`Worker #${i} exited with code: ${code}`);
-    });
-    return worker;
-  }
+function createWorker(i) {
+  var worker = cluster.fork();
+
+  worker.on('message', function (msg) {
+    console.log('Message from worker' + i + ':', msg);
+  });
+
+  worker.on('exit', function (code) {
+    console.log('Worker', i, 'exited with code:', code);
+  });
 
+  return worker;
+}
+
+if (cluster.isWorker) {
+  var server = require('./server');
+
+  process.on('disconnect', function () {
+    console.log(process.pid, 'disconnect received, shutting down');
+    if (server.lisening) {
+      server.close();
+    }
+  });
+
+  process.send('Hello');
+}
+
+if (cluster.isMaster) {
   for (var i = 0; i < 2; i += 1) {
     console.log('Forking worker', i);
     createWorker(i);
@@ -22,13 +38,4 @@ if (cluster.isMaster) {
       console.log('All workers disconnected.');
     });
   });
-} else {
-  var server = require('./server');
-  process.on('disconnect', function () {
-    console.log(process.pid, 'disconnect received, shutting down');
-    if (server.lisening) {
-      server.close();
-    }
-  });
-  process.send('Hello');
 }

test/fixture/server.js

@@ -22,7 +22,7 @@ process.once('SIGTERM', function () {
   }
 });
 
-process.once('beforeExit', function() {
+process.once('beforeExit', function () {
   console.log('exit');
 });