Exits after everything written to stdout has been drained.

Author: Tjatse

lib/CLI.js

@@ -2043,7 +2043,7 @@ function speedList(code) {
         return setTimeout(speedList, 1400);
       }
       console.error('Error retrieving process list: %s.\nA process seems to be on infinite loop, retry in 5 seconds',err);
-      exitCli(cst.ERROR_EXIT);
+      return exitCli(cst.ERROR_EXIT);
     }
     if (commander.miniList && !commander.silent)
       UX.miniDisplay(list);
@@ -2061,7 +2061,7 @@ function speedList(code) {
       return CLI.streamLogs(null, 1);
     }
     else {
-      //return exitCli(code ? code : cst.SUCCESS_EXIT);
+      return exitCli(code ? code : cst.SUCCESS_EXIT);
     }
   });
 }

lib/Common.js

@@ -187,7 +187,33 @@ Common.formatCLU = function(csp) {
 Common.exitCli = function(code) {
   InteractorDaemonizer.disconnectRPC(function() {
     Satan.disconnectRPC(function() {
-      process.exit(code || 0);
+      code = code || 0;
+      // Safe exits process after all streams are drained.
+      // file descriptor flag.
+      var fds = 0; 
+      // exits process when stdout (1) and sdterr(2) are both drained.
+      function tryToExit() {
+        if ((fds & 1) && (fds & 2)) {
+          process.exit(code);
+        }
+      }
+
+      [process.stdout, process.stderr].forEach(function(std) {
+        var fd = std.fd;
+        if (!std.bufferSize) {
+          // bufferSize equals 0 means current stream is drained.
+          fds = fds | fd;
+        } else {
+          // Appends nothing to the std queue, but will trigger `tryToExit` event on `drain`.
+          std.write && std.write('', function() {
+            fds = fds | fd;
+            tryToExit();
+          });
+        }
+        // Does not write anything more.
+        delete std.write;
+      });
+      tryToExit();
     });
   });
 };