| // Copyright Joyent, Inc. and other Node contributors. |
| // |
| // Permission is hereby granted, free of charge, to any person obtaining a |
| // copy of this software and associated documentation files (the |
| // "Software"), to deal in the Software without restriction, including |
| // without limitation the rights to use, copy, modify, merge, publish, |
| // distribute, sublicense, and/or sell copies of the Software, and to permit |
| // persons to whom the Software is furnished to do so, subject to the |
| // following conditions: |
| // |
| // The above copyright notice and this permission notice shall be included |
| // in all copies or substantial portions of the Software. |
| // |
| // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS |
| // OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF |
| // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN |
| // NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, |
| // DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR |
| // OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE |
| // USE OR OTHER DEALINGS IN THE SOFTWARE. |
| |
| |
| var common = require('../common'); |
| var assert = require('assert'); |
| var cluster = require('cluster'); |
| |
| // Cluster setup |
| if (cluster.isWorker) { |
| var http = require('http'); |
| http.Server(function() { |
| |
| }).listen(common.PORT, '127.0.0.1'); |
| |
| } else if (process.argv[2] === 'cluster') { |
| |
| var totalWorkers = 2; |
| |
| // Send PID to testcase process |
| var forkNum = 0; |
| cluster.on('fork', function forkEvent(worker) { |
| |
| // Send PID |
| process.send({ |
| cmd: 'worker', |
| workerPID: worker.process.pid |
| }); |
| |
| // Stop listening when done |
| if (++forkNum === totalWorkers) { |
| cluster.removeListener('fork', forkEvent); |
| } |
| }); |
| |
| // Throw accidently error when all workers are listening |
| var listeningNum = 0; |
| cluster.on('listening', function listeningEvent() { |
| |
| // When all workers are listening |
| if (++listeningNum === totalWorkers) { |
| // Stop listening |
| cluster.removeListener('listening', listeningEvent); |
| |
| // throw accidently error |
| process.nextTick(function() { |
| console.error('about to throw'); |
| throw new Error('accidently error'); |
| }); |
| } |
| |
| }); |
| |
| // Startup a basic cluster |
| cluster.fork(); |
| cluster.fork(); |
| |
| } else { |
| // This is the testcase |
| |
| var fork = require('child_process').fork; |
| |
| var isAlive = function(pid) { |
| try { |
| //this will throw an error if the process is dead |
| process.kill(pid, 0); |
| |
| return true; |
| } catch (e) { |
| return false; |
| } |
| }; |
| |
| var existMaster = false; |
| var existWorker = false; |
| |
| // List all workers |
| var workers = []; |
| |
| // Spawn a cluster process |
| var master = fork(process.argv[1], ['cluster'], {silent: true}); |
| |
| // Handle messages from the cluster |
| master.on('message', function(data) { |
| |
| // Add worker pid to list and progress tracker |
| if (data.cmd === 'worker') { |
| workers.push(data.workerPID); |
| } |
| }); |
| |
| // When cluster is dead |
| master.on('exit', function(code) { |
| |
| // Check that the cluster died accidently |
| existMaster = !!code; |
| |
| // Give the workers time to shut down |
| setTimeout(checkWorkers, 200); |
| |
| function checkWorkers() { |
| // When master is dead all workers should be dead to |
| var alive = false; |
| workers.forEach(function(pid) { |
| if (isAlive(pid)) { |
| alive = true; |
| } |
| }); |
| |
| // If a worker was alive this did not act as expected |
| existWorker = !alive; |
| } |
| }); |
| |
| process.once('exit', function() { |
| var m = 'The master did not die after an error was throwed'; |
| assert.ok(existMaster, m); |
| m = 'The workers did not die after an error in the master'; |
| assert.ok(existWorker, m); |
| }); |
| |
| } |