added socket timeouts to connections.

Ryan · Ryan · commit 1d00ea157c03 · 2012-01-06T12:53:40.000-05:00
diff --git a/src/test/com/mongodb/SecondaryReadTest.java b/src/test/com/mongodb/SecondaryReadTest.java
@@ -203,7 +203,7 @@ private boolean serverIsSecondary(final ServerAddress pServerAddr, final List<Te
     }
 
     private Mongo loadMongo() throws Exception {
-        return new Mongo(new MongoURI("mongodb://127.0.0.1:27017,127.0.0.1:27018"));
+        return new Mongo(new MongoURI("mongodb://127.0.0.1:27017,127.0.0.1:27018/?connectTimeoutMS=20000;socketTimeoutMS=20000;maxpoolsize=50;autoconnectretry=true"));
     }
 
     private CommandResult serverStatusCmd(final Mongo pMongo) {
@@ -308,7 +308,7 @@ private void verifySecondaryCounts(final int pSecondaryCount, final List<TestHos
 
     private static void loadQueryCount(final List<TestHost> pHosts, final boolean pBefore) throws Exception {
         for (final TestHost testHost : pHosts) {
-            final Mongo mongoHost = new Mongo(new MongoURI("mongodb://"+testHost.hostnameAndPort));
+            final Mongo mongoHost = new Mongo(new MongoURI("mongodb://"+testHost.hostnameAndPort+"/?connectTimeoutMS=20000;socketTimeoutMS=20000;maxpoolsize=50;autoconnectretry=true"));
             try {
                 final CommandResult serverStatusResult
                 = mongoHost.getDB("com_mongodb_unittest_SecondaryReadTest").command(new BasicDBObject("serverStatus", 1));

Original file line number	Diff line number	Diff line change
`@@ -203,7 +203,7 @@ private boolean serverIsSecondary(final ServerAddress pServerAddr, final List<Te`
`203`	`203`	`}`
`204`	`204`
`205`	`205`	`private Mongo loadMongo() throws Exception {`
`206`		`- return new Mongo(new MongoURI("mongodb://127.0.0.1:27017,127.0.0.1:27018"));`
	`206`	`+ return new Mongo(new MongoURI("mongodb://127.0.0.1:27017,127.0.0.1:27018/?connectTimeoutMS=20000;socketTimeoutMS=20000;maxpoolsize=50;autoconnectretry=true"));`
`207`	`207`	`}`
`208`	`208`
`209`	`209`	`private CommandResult serverStatusCmd(final Mongo pMongo) {`
`@@ -308,7 +308,7 @@ private void verifySecondaryCounts(final int pSecondaryCount, final List<TestHos`
`308`	`308`
`309`	`309`	`private static void loadQueryCount(final List<TestHost> pHosts, final boolean pBefore) throws Exception {`
`310`	`310`	`for (final TestHost testHost : pHosts) {`
`311`		`- final Mongo mongoHost = new Mongo(new MongoURI("mongodb://"+testHost.hostnameAndPort));`
	`311`	`+ final Mongo mongoHost = new Mongo(new MongoURI("mongodb://"+testHost.hostnameAndPort+"/?connectTimeoutMS=20000;socketTimeoutMS=20000;maxpoolsize=50;autoconnectretry=true"));`
`312`	`312`	`try {`
`313`	`313`	`final CommandResult serverStatusResult`
`314`	`314`	`= mongoHost.getDB("com_mongodb_unittest_SecondaryReadTest").command(new BasicDBObject("serverStatus", 1));`