Rewind cursor to correctly force reconnect on capped collections when first query comes back empty.

Author: christkv

HISTORY.md

@@ -2,9 +2,10 @@
 -----------------
 * Bug fixes for APM upconverting of legacy INSERT/UPDATE/REMOVE wire protocol messages.
 * NODE-562, fixed issue where a Replicaset MongoDB URI with a single seed and replSet name set would cause a single direct connection instead of topology discovery.
-* Updated mongodb-core to 1.2.13.
+* Updated mongodb-core to 1.2.14.
 * NODE-563 Introduced options.ignoreUndefined for db class and MongoClient db options, made serialize undefined to null default again but allowing for overrides on insert/update/delete operations.
 * Use handleCallback if result is an error for count queries. (Issue #1298, https://github.com/agclever)
+* Rewind cursor to correctly force reconnect on capped collections when first query comes back empty.
 
 2.0.43 09-14-2015
 -----------------

lib/cursor.js

@@ -641,6 +641,7 @@ var nextObject = function(self, callback) {
       self.s.currentNumberOfRetries = self.s.currentNumberOfRetries - 1;
 
       return setTimeout(function() {
+        self.rewind();
         self.nextObject(callback);
       }, self.s.tailableRetryInterval);
     }

package.json

@@ -13,7 +13,7 @@
     "legacy"
   ],
   "dependencies": {
-      "mongodb-core": "1.2.13"
+      "mongodb-core": "1.2.14"
     , "readable-stream": "1.0.31"
     , "es6-promise": "2.1.1"
   },

test/functional/mongo_client_tests.js

@@ -366,12 +366,44 @@ exports["correctly timeout MongoClient connect using custom connectTimeoutMS"] =
     var start = new Date();
 
     MongoClient.connect('mongodb://example.com/test?connectTimeoutMS=1000&maxPoolSize=1', function(err, db) {
-      // db.close();
+      test.ok(err != null);
+      test.ok((new Date().getTime() - start.getTime()) >= 1000)
+      test.done();
+    });
+  }
+}
 
-      var end = new Date();
-      console.dir(end.getTime() - start.getTime())
+/**
+ * @ignore
+ */
+exports["correctly error out when no socket available on MongoClient.connect"] = {
+  metadata: { requires: { topology: ['single', 'replicaset', 'sharded', 'ssl', 'heap', 'wiredtiger'] } },
+
+  // The actual test we wish to run
+  test: function(configuration, test) {
+    var MongoClient = configuration.require.MongoClient;
+    MongoClient.connect('mongodb://localhost:27088/test', function(err, db) {
+      test.ok(err != null);
 
       test.done();
     });
   }
 }
+
+/**
+ * @ignore
+ */
+exports["correctly error out when no socket available on MongoClient.connect with domain"] = {
+  metadata: { requires: { topology: ['single', 'replicaset', 'sharded', 'ssl', 'heap', 'wiredtiger'] } },
+
+  // The actual test we wish to run
+  test: function(configuration, test) {
+    var MongoClient = configuration.require.MongoClient;
+
+    MongoClient.connect('mongodb://test.com:80/test', function(err, db) {
+      test.ok(err != null);
+
+      test.done();
+    });
+  }
+}