JAVA-362: IllegalArgumentException due to race condition in updated thread start

Author: agirbal

src/main/com/mongodb/DBTCPConnector.java

@@ -65,6 +65,11 @@ public DBTCPConnector( Mongo m , List<ServerAddress> all )
 
         _createLogger.info( all  + " -> " + getAddress() );
     }
+    
+    public void start() {
+        if (_rsStatus != null)
+            _rsStatus.start();
+    }
 
     private static ServerAddress _checkAddress( ServerAddress addr ){
         if ( addr == null )

src/main/com/mongodb/Mongo.java

@@ -190,6 +190,7 @@ public Mongo( ServerAddress addr , MongoOptions options )
         _options = options;
         _applyMongoOptions();
         _connector = new DBTCPConnector( this , _addr );
+        _connector.start();
         _cleaner = new DBCleanerThread();
         _cleaner.start();
     }
@@ -227,6 +228,7 @@ public Mongo( ServerAddress left , ServerAddress right , MongoOptions options )
         _options = options;
         _applyMongoOptions();
         _connector = new DBTCPConnector( this , _addrs );
+        _connector.start();
 
         _cleaner = new DBCleanerThread();
         _cleaner.start();
@@ -301,6 +303,7 @@ public Mongo( MongoURI uri )
             _connector = new DBTCPConnector( this , replicaSetSeeds );
         }
 
+        _connector.start();
         _cleaner = new DBCleanerThread();
         _cleaner.start();
     }

src/main/com/mongodb/ReplicaSetStatus.java

@@ -38,9 +38,12 @@ public class ReplicaSetStatus {
         _nextResolveTime = System.currentTimeMillis() + inetAddrCacheMS;
 
         _updater = new Updater();
-        _updater.start();
     }
 
+    void start() {
+        _updater.start();
+    }
+    
     boolean ready(){
         return _setName != null;
     }
@@ -435,6 +438,7 @@ public static void main( String args[] )
         Mongo m = new Mongo( addrs );
 
         ReplicaSetStatus status = new ReplicaSetStatus( m, addrs );
+        status.start();
         System.out.println( status.ensureMaster()._addr );
 
         while ( true ){