Skip to content

Commit

Permalink
child_process: refactor internal/child_process.js
Browse files Browse the repository at this point in the history
* Prefer === to == where possible
* Remove condition that will always be false
* Prefer for-loop statements to forEach where possible for perfomance reasons

PR-URL: #11366
Reviewed-By: Colin Ihrig <cjihrig@gmail.com>
Reviewed-By: Sam Roberts <vieuxtech@gmail.com>
Reviewed-By: Michaël Zasso <targos@protonmail.com>
Reviewed-By: Brian White <mscdex@mscdex.net>
  • Loading branch information
notarseniy authored and addaleax committed Feb 22, 2017
1 parent b457f38 commit c942e20
Showing 1 changed file with 27 additions and 19 deletions.
46 changes: 27 additions & 19 deletions lib/internal/child_process.js
Original file line number Diff line number Diff line change
Expand Up @@ -230,12 +230,16 @@ util.inherits(ChildProcess, EventEmitter);


function flushStdio(subprocess) {
if (subprocess.stdio == null) return;
subprocess.stdio.forEach(function(stream, fd, stdio) {
const stdio = subprocess.stdio;

if (stdio == null) return;

for (var i = 0; i < stdio.length; i++) {
const stream = stdio[i];
if (!stream || !stream.readable || stream._readableState.readableListening)
return;
continue;
stream.resume();
});
}
}


Expand Down Expand Up @@ -268,6 +272,7 @@ ChildProcess.prototype.spawn = function(options) {
const self = this;
var ipc;
var ipcFd;
var i;
// If no `stdio` option was given - use default
var stdio = options.stdio || 'pipe';

Expand Down Expand Up @@ -302,11 +307,12 @@ ChildProcess.prototype.spawn = function(options) {
if (err !== uv.UV_ENOENT) return err;
} else if (err) {
// Close all opened fds on error
stdio.forEach(function(stdio) {
if (stdio.type === 'pipe') {
stdio.handle.close();
for (i = 0; i < stdio.length; i++) {
const stream = stdio[i];
if (stream.type === 'pipe') {
stream.handle.close();
}
});
}

this._handle.close();
this._handle = null;
Expand All @@ -315,27 +321,29 @@ ChildProcess.prototype.spawn = function(options) {

this.pid = this._handle.pid;

stdio.forEach(function(stdio, i) {
if (stdio.type === 'ignore') return;
for (i = 0; i < stdio.length; i++) {
const stream = stdio[i];
if (stream.type === 'ignore') continue;

if (stdio.ipc) {
if (stream.ipc) {
self._closesNeeded++;
return;
continue;
}

if (stdio.handle) {
if (stream.handle) {
// when i === 0 - we're dealing with stdin
// (which is the only one writable pipe)
stdio.socket = createSocket(self.pid !== 0 ? stdio.handle : null, i > 0);
stream.socket = createSocket(self.pid !== 0 ?
stream.handle : null, i > 0);

if (i > 0 && self.pid !== 0) {
self._closesNeeded++;
stdio.socket.on('close', function() {
stream.socket.on('close', function() {
maybeClose(self);
});
}
}
});
}

this.stdin = stdio.length >= 1 && stdio[0].socket !== undefined ?
stdio[0].socket : null;
Expand Down Expand Up @@ -797,11 +805,11 @@ function _validateStdio(stdio, sync) {
}

// Defaults
if (stdio === null || stdio === undefined) {
if (stdio == null) {
stdio = i < 3 ? 'pipe' : 'ignore';
}

if (stdio === null || stdio === 'ignore') {
if (stdio === 'ignore') {
acc.push({type: 'ignore'});
} else if (stdio === 'pipe' || typeof stdio === 'number' && stdio < 0) {
var a = {
Expand Down Expand Up @@ -887,7 +895,7 @@ function getSocketList(type, slave, key) {
function maybeClose(subprocess) {
subprocess._closesGot++;

if (subprocess._closesGot == subprocess._closesNeeded) {
if (subprocess._closesGot === subprocess._closesNeeded) {
subprocess.emit('close', subprocess.exitCode, subprocess.signalCode);
}
}

0 comments on commit c942e20

Please sign in to comment.