Get rid of coupling for stdin

lib/fs.js

@@ -499,8 +499,11 @@ var FileReadStream = fs.FileReadStream = function(path, options) {
     this[key] = options[key];
   }
 
-  var self = this;
+  if (this.fd !== null) {
+    return;
+  }
 
+  var self = this;
   fs.open(this.path, this.flags, this.mode, function(err, fd) {
     if (err) {
       self.emit('error', err);

src/node.js

@@ -147,11 +147,20 @@ process.__defineGetter__('stdout', function () {
 var stdin;
 process.openStdin = function () {
   if (stdin) return stdin;
-  var net = module.requireNative('net');
-  var fd = process.binding('stdio').openStdin();
+
+  var net = module.requireNative('net')
+    , fs = module.requireNative('fs')
+    , fd = process.binding('stdio').openStdin();
+
+  if (process.binding('stdio').isStdinBlocking()) {
     stdin = new net.Stream(fd);
-  stdin.resume();
     stdin.readable = true;
+  } else {
+    stdin = new fs.FileReadStream(null, {fd: fd});
+  }
+
+  stdin.resume();
+
   return stdin;
 };
 

src/node_stdio.cc

@@ -1,6 +1,5 @@
 #include <node_stdio.h>
 #include <node_events.h>
-#include <coupling.h>
 
 #include <unistd.h>
 #include <fcntl.h>
@@ -11,8 +10,6 @@ using namespace v8;
 namespace node {
 
 
-static struct coupling *stdin_coupling = NULL;
-
 static int stdin_fd = -1;
 static int stdout_fd = -1;
 
@@ -56,15 +53,10 @@ static Handle<Value> OpenStdin(const Arguments& args) {
     return ThrowException(Exception::Error(String::New("stdin already open")));
   }
 
+  stdin_fd = STDIN_FILENO;
   if (isatty(STDIN_FILENO)) {
     // XXX selecting on tty fds wont work in windows.
     // Must ALWAYS make a coupling on shitty platforms.
-    stdin_fd = STDIN_FILENO;
-  } else {
-    stdin_coupling = coupling_new_pull(STDIN_FILENO);
-    stdin_fd = coupling_nonblocking_fd(stdin_coupling);
-  }
-
     stdin_flags = fcntl(stdin_fd, F_GETFL, 0);
     if (stdin_flags == -1) {
       // TODO DRY
@@ -76,10 +68,18 @@ static Handle<Value> OpenStdin(const Arguments& args) {
       // TODO DRY
       return ThrowException(Exception::Error(String::New("fcntl error!")));
     }
+  }
 
   return scope.Close(Integer::New(stdin_fd));
 }
 
+static Handle<Value>
+IsStdinBlocking (const Arguments& args)
+{
+  HandleScope scope;
+  return scope.Close(Boolean::New(isatty(STDIN_FILENO)));
+}
+
 static Handle<Value>
 IsStdoutBlocking (const Arguments& args)
 {
@@ -122,6 +122,7 @@ void Stdio::Initialize(v8::Handle<v8::Object> target) {
   NODE_SET_METHOD(target, "writeError", WriteError);
   NODE_SET_METHOD(target, "openStdin", OpenStdin);
   NODE_SET_METHOD(target, "isStdoutBlocking", IsStdoutBlocking);
+  NODE_SET_METHOD(target, "isStdinBlocking", IsStdinBlocking);
 }
 
 

test/simple/test-stdin-from-file.js

@@ -0,0 +1,26 @@
+require('../common');
+var TEST_STR = "abc\n123\nhello world\nsomething else"
+  , path = require('path')
+  , childProccess = require('child_process')
+  , fs = require('fs')
+  , stdoutScript = path.join(fixturesDir, 'echo.js')
+  , tmpFile = path.join(fixturesDir, 'stdin.txt')
+  , cmd = process.argv[0] + ' ' + stdoutScript + ' < ' + tmpFile
+  ;
+
+puts(cmd + "\n\n");
+
+try {
+  fs.unlinkSync(tmpFile);
+} catch (e) {}
+
+fs.writeFileSync(tmpFile, TEST_STR);
+
+childProccess.exec(cmd, function(err, stdout, stderr) {
+  fs.unlinkSync(tmpFile);
+
+  if (err) throw err;
+  puts(stdout);
+  assert.equal(stdout, "hello world\r\n" + TEST_STR);
+  assert.equal("", stderr);
+});