Merge pull request brianc#388 from brianc/issues/320

Issues/320

Author: brianc

src/binding.cc

@@ -6,7 +6,7 @@
 #include <stdlib.h>
 
 #define LOG(msg) printf("%s\n",msg);
-#define TRACE(msg) //printf(%s\n, msg);
+#define TRACE(msg) //printf("%s\n", msg);
 
 
 #define THROW(msg) return ThrowException(Exception::Error(String::New(msg)));
@@ -251,6 +251,7 @@ class Connection : public ObjectWrap {
   bool copyInMode_;
   bool reading_;
   bool writing_;
+  bool ended_;
   Connection () : ObjectWrap ()
   {
     connection_ = NULL;
@@ -260,6 +261,7 @@ class Connection : public ObjectWrap {
     copyInMode_ = false;
     reading_ = false;
     writing_ = false;
+    ended_ = false;
     TRACE("Initializing ev watchers");
     read_watcher_.data = this;
     write_watcher_.data = this;
@@ -369,6 +371,7 @@ class Connection : public ObjectWrap {
   //and hands off control to libev
   bool Connect(const char* conninfo)
   {
+    if(ended_) return true;
     connection_ = PQconnectStart(conninfo);
 
     if (!connection_) {
@@ -660,6 +663,7 @@ class Connection : public ObjectWrap {
     StopWrite();
     DestroyConnection();
     Emit("_end");
+    ended_ = true;
   }
 
 private:

test/integration/client/quick-disconnect-tests.js

@@ -0,0 +1,7 @@
+//test for issue #320
+//
+var helper = require('./test-helper');
+
+var client = new helper.pg.Client(helper.config);
+client.connect();
+client.end();