tiny bugfix

Author: paulpflug

index.js

@@ -67,7 +67,7 @@ function status () {
 // closes all children and the process
 function close (code) {
     var i, len, close = 0, opened = 0;
-    if (children.length == 1) process.exit(code);
+
     for (i = 0, len = children.length; i < len; i++) {
         if (!children[i].exitCode) {
             opened++;
@@ -86,6 +86,7 @@ function close (code) {
             });
         }
     }
+    if (opened == closed) process.exit(code);
 
 }
 

test/out

@@ -0,0 +1,216 @@
+(function e(t,n,r){function s(o,u){if(!n[o]){if(!t[o]){var a=typeof require=="function"&&require;if(!u&&a)return a(o,!0);if(i)return i(o,!0);var f=new Error("Cannot find module '"+o+"'");throw f.code="MODULE_NOT_FOUND",f}var l=n[o]={exports:{}};t[o][0].call(l.exports,function(e){var n=t[o][1][e];return s(n?n:e)},l,l.exports,e,t,n,r)}return n[o].exports}var i=typeof require=="function"&&require;for(var o=0;o<r.length;o++)s(r[o]);return s})({1:[function(require,module,exports){
+(function (process){
+
+
+'use strict';
+var spawn = require('child_process').spawn;
+
+var sh, shFlag, children, args, wait, cmds, verbose, i ,len;
+// parsing argv
+cmds = [];
+args = process.argv.slice(2);
+for (i = 0, len = args.length; i < len; i++) {
+    if (args[i][0] === '-') {
+        switch (args[i]) {
+            case '-w':
+            case '--wait':
+                wait = true;
+                break;
+            case '-v':
+            case '--verbose':
+                verbose = true;
+                break;
+            case '-h':
+            case '--help':
+                console.log('-h, --help         output usage information');
+                console.log('-v, --verbose      verbose logging')
+                console.log('-w, --wait         will not close sibling processes on error')
+                process.exit();
+                break;
+        }
+    } else {
+        cmds.push(args[i]);
+    }
+}
+
+// called on close of a child process
+function childClose (code) {
+    var i, len;
+    code = code ? (code.code || code) : code;
+    if (verbose) {
+        if (code > 0) {
+            console.error('`' + this.cmd + '` failed with exit code ' + code);
+        } else {
+            console.log('`' + this.cmd + '` ended successfully');
+        }
+    }
+    if (code > 0 && !wait) close(code);
+    status();
+}
+
+function status () {
+    if (verbose) {
+        var i, len;
+        console.log('\n');
+        console.log('### Status ###');
+        for (i = 0, len = children.length; i < len; i++) {
+            if (children[i].exitCode === null) {
+                console.log('`' + children[i].cmd + '` is still running');
+            } else if (children[i].exitCode > 0) {
+                console.log('`' + children[i].cmd + '` errored');
+            } else {
+                console.log('`' + children[i].cmd + '` finished');
+            }
+        }
+        console.log('\n');
+    }
+}
+
+// closes all children and the process
+function close (code) {
+    var i, len, close = 0, opened = 0;
+
+    for (i = 0, len = children.length; i < len; i++) {
+        if (!children[i].exitCode) {
+            opened++;
+            children[i].removeAllListeners('close');
+            if (process.platform === 'win32') {
+                children[i].kill("SIGINT");
+            } else {
+                spawn(sh,[shFlag,'kill -TERM -'+children[i].pid]);
+            }
+            if (verbose) console.log('`' + children[i].cmd + '` will now be closed');
+            children[i].on('close', function() {
+                closed++;
+                if (opened == closed) {
+                    process.exit(code);
+                }
+            });
+        }
+    }
+    if (opened == closed) process.exit(code);
+
+}
+
+// cross platform compatibility
+if (process.platform === 'win32') {
+    sh = 'cmd';
+    shFlag = '/c';
+} else {
+    sh = 'sh';
+    shFlag = '-c';
+}
+
+// start the children
+children = [];
+cmds.forEach(function (cmd) {
+    var child = spawn(sh,[shFlag,cmd], {
+        cwd: process.cwd,
+        env: process.env,
+        detached: true,
+        stdio: ['pipe', process.stdout, process.stderr]
+    })
+    .on('close', childClose);
+    child.cmd = cmd
+    children.push(child)
+});
+
+// close all children on ctrl+c
+process.on('SIGINT', close)
+
+}).call(this,require('_process'))
+},{"_process":3,"child_process":2}],2:[function(require,module,exports){
+
+},{}],3:[function(require,module,exports){
+// shim for using process in browser
+
+var process = module.exports = {};
+var queue = [];
+var draining = false;
+var currentQueue;
+var queueIndex = -1;
+
+function cleanUpNextTick() {
+    draining = false;
+    if (currentQueue.length) {
+        queue = currentQueue.concat(queue);
+    } else {
+        queueIndex = -1;
+    }
+    if (queue.length) {
+        drainQueue();
+    }
+}
+
+function drainQueue() {
+    if (draining) {
+        return;
+    }
+    var timeout = setTimeout(cleanUpNextTick);
+    draining = true;
+
+    var len = queue.length;
+    while(len) {
+        currentQueue = queue;
+        queue = [];
+        while (++queueIndex < len) {
+            currentQueue[queueIndex].run();
+        }
+        queueIndex = -1;
+        len = queue.length;
+    }
+    currentQueue = null;
+    draining = false;
+    clearTimeout(timeout);
+}
+
+process.nextTick = function (fun) {
+    var args = new Array(arguments.length - 1);
+    if (arguments.length > 1) {
+        for (var i = 1; i < arguments.length; i++) {
+            args[i - 1] = arguments[i];
+        }
+    }
+    queue.push(new Item(fun, args));
+    if (queue.length === 1 && !draining) {
+        setTimeout(drainQueue, 0);
+    }
+};
+
+// v8 likes predictible objects
+function Item(fun, array) {
+    this.fun = fun;
+    this.array = array;
+}
+Item.prototype.run = function () {
+    this.fun.apply(null, this.array);
+};
+process.title = 'browser';
+process.browser = true;
+process.env = {};
+process.argv = [];
+process.version = ''; // empty string to avoid regexp issues
+process.versions = {};
+
+function noop() {}
+
+process.on = noop;
+process.addListener = noop;
+process.once = noop;
+process.off = noop;
+process.removeListener = noop;
+process.removeAllListeners = noop;
+process.emit = noop;
+
+process.binding = function (name) {
+    throw new Error('process.binding is not supported');
+};
+
+// TODO(shtylman)
+process.cwd = function () { return '/' };
+process.chdir = function (dir) {
+    throw new Error('process.chdir is not supported');
+};
+process.umask = function() { return 0; };
+
+},{}]},{},[1]);