NODE-493 Added test to ensure we can connect using large poolSizes

Author: christkv

lib/cursor.js

@@ -119,7 +119,7 @@ var Cursor = function(bson, ns, cmd, options, topology, topologyOptions) {
     // Topology options
     , topologyOptions: topologyOptions
     // Promise library
-    , promiseLibrary: promiseLibrary 
+    , promiseLibrary: promiseLibrary
     // Current doc
     , currentDoc: null
   }
@@ -193,7 +193,7 @@ Cursor.prototype.hasNext = function(callback) {
       if(err) return reject(err);
       if(!doc) return resolve(false);
       self.s.currentDoc = doc;
-      resolve(true); 
+      resolve(true);
     });
   });
 }
@@ -234,7 +234,7 @@ Cursor.prototype.next = function(callback) {
 
     nextObject(self, function(err, r) {
       if(err) return reject(err);
-      resolve(r); 
+      resolve(r);
     });
   });
 }
@@ -502,6 +502,7 @@ var nextObject = function(self, callback) {
     if(err && err.tailable && self.s.currentNumberOfRetries == 0) return callback(err);
     if(err && err.tailable && self.s.currentNumberOfRetries > 0) {
       self.s.currentNumberOfRetries = self.s.currentNumberOfRetries - 1;
+
       return setTimeout(function() {
         self.nextObject(callback);
       }, self.s.tailableRetryInterval);
@@ -510,7 +511,7 @@ var nextObject = function(self, callback) {
     self.s.state = Cursor.OPEN;
     if(err) return handleCallback(callback, err);
     handleCallback(callback, null, doc);
-  });  
+  });
 }
 
 // Trampoline emptying the number of retrieved items
@@ -665,7 +666,7 @@ Cursor.prototype.toArray = function(callback) {
   return new this.s.promiseLibrary(function(resolve, reject) {
     toArray(self, function(err, r) {
       if(err) return reject(err);
-      resolve(r); 
+      resolve(r);
     });
   });
 }
@@ -707,7 +708,7 @@ var toArray = function(self, callback) {
     })
   }
 
-  fetchDocs();  
+  fetchDocs();
 }
 
 /**
@@ -743,7 +744,7 @@ Cursor.prototype.count = function(applySkipLimit, opts, callback) {
   return new this.s.promiseLibrary(function(resolve, reject) {
     count(self, applySkipLimit, opts, function(err, r) {
       if(err) return reject(err);
-      resolve(r); 
+      resolve(r);
     });
   });
 };
@@ -801,7 +802,7 @@ var count = function(self, applySkipLimit, opts, callback) {
   });
 
   // Write the initial command out
-  connection.write(query.toBin());  
+  connection.write(query.toBin());
 }
 
 /**
@@ -879,7 +880,7 @@ Cursor.prototype.explain = function(callback) {
   return new this.s.promiseLibrary(function(resolve, reject) {
     self._next(function(err, r) {
       if(err) return reject(err);
-      resolve(r); 
+      resolve(r);
     });
   });
 }

test/functional/connection_tests.js

@@ -45,6 +45,24 @@ exports['Should correctly connect to server using just events'] = {
   }
 }
 
+/**
+ * @ignore
+ */
+exports['Should correctly connect to server using big connection pool'] = {
+  metadata: { requires: { topology: ['single', 'replicaset', 'sharded', 'ssl', 'heap', 'wiredtiger'] } },
+
+  // The actual test we wish to run
+  test: function(configuration, test) {
+    var db = configuration.newDbInstance({w:1}, {poolSize:500, auto_reconnect:true});
+    db.on('open', function() {
+      db.close();
+      test.done();
+    });
+
+    db.open();
+  }
+}
+
 /**
  * @ignore
  */

test/functional/cursor_tests.js

@@ -1949,8 +1949,11 @@ exports.shouldCloseDeadTailableCursors = {
           test.ok(err != null);
         });
 
+        stream.on('end', function () {
+          closed = true;
+        });
+
         stream.on('close', function () {
-          // this is what we need
           closed = true;
         });
 
@@ -1963,9 +1966,11 @@ exports.shouldCloseDeadTailableCursors = {
 
         setTimeout(function () {
           db.close();
-          test.equal(true, closed);
-          db.close();
-          test.done();
+
+          setTimeout(function() {
+            test.equal(true, closed);
+            test.done();
+          }, 1000)
         }, 800);
       });
     });