Ensure timeout works correctly #1032

Author: christkv

lib/mongodb/connection/server.js

@@ -623,6 +623,18 @@ Server.prototype.connect = function(dbInstance, options, callback) {
  // Emit error
  server._emitAcrossAllDbInstances(server, eventReceiver, "timeout", err, server, true);
  }
+
+ // If we have autoConnect enabled let's fire up an attempt to reconnect
+ if(server.isAutoReconnect() 
+ && !server.isSetMember()
+ && (server._serverState != 'destroyed')
+ && !server._reconnectInProgreess) {
+ // Set the number of retries
+ server._reconnect_retries = server.db.numberOfRetries;
+ // Attempt reconnect
+ server._reconnectInProgreess = true;
+ setTimeout(__attemptReconnect(server), server.db.retryMiliSeconds);
+ } 
  });
 
  // Handle errors

test/tools/replica_set_manager.js

@@ -576,7 +576,7 @@ ReplicaSetManager.prototype.addSecondary = function(options, callback) {
  // Get the configuration
  var connection = new Db("local", new Server(primary.split(":")[0], parseInt(primary.split(":")[1], 10), {
  ssl:self.ssl
- , auto_reconnect:true
+ , auto_reconnect:false
  , poolSize:1
  , socketOptions: {
  connectTimeoutMS: 30000
@@ -689,7 +689,7 @@ ReplicaSetManager.prototype.getConnection = function(node, callback) {
  var intervalId = setInterval(function() {
  var connection = new Db("replicaset_test", new Server(self.host, self.mongods[node]["port"], {
  ssl:self.ssl
- , auto_reconnect:true
+ , auto_reconnect:false
  , socketOptions: {
  connectTimeoutMS: 30000
  , socketTimeoutMS: 30000
@@ -745,7 +745,7 @@ ReplicaSetManager.prototype.reStartAndConfigure = function(node_configs, callbac
  // Get the configuration
  var connection = new Db("local", new Server(primary.split(":")[0], parseInt(primary.split(":")[1], 10), {
  ssl:self.ssl
- , auto_reconnect:true
+ , auto_reconnect:false
  , socketOptions: {
  connectTimeoutMS: 30000
  , socketTimeoutMS: 30000