Author: mreutegg
Date: Tue Sep 13 08:32:35 2016
New Revision: 1760494
URL: http://svn.apache.org/viewvc?rev=1760494&view=rev
Log:
OAK-4757: Adjust default timeout values for MongoDocumentStore
Modified:
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/util/MongoConnection.java
Modified:
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/util/MongoConnection.java
URL:
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/util/MongoConnection.java?rev=1760494&r1=1760493&r2=1760494&view=diff
==============================================================================
---
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/util/MongoConnection.java
(original)
+++
jackrabbit/oak/trunk/oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/util/MongoConnection.java
Tue Sep 13 08:32:35 2016
@@ -17,6 +17,7 @@
package org.apache.jackrabbit.oak.plugins.document.util;
import java.net.UnknownHostException;
+import java.util.concurrent.TimeUnit;
import javax.annotation.Nonnull;
@@ -34,6 +35,7 @@ import static com.google.common.base.Pre
*/
public class MongoConnection {
+ private static final int DEFAULT_MAX_WAIT_TIME = (int)
TimeUnit.MINUTES.toMillis(1);
private static final WriteConcern WC_UNKNOWN = new WriteConcern("unknown");
private final MongoClientURI mongoURI;
private final MongoClient mongo;
@@ -98,6 +100,7 @@ public class MongoConnection {
public static MongoClientOptions.Builder getDefaultBuilder() {
return new MongoClientOptions.Builder()
.description("MongoConnection for Oak DocumentMK")
+ .maxWaitTime(DEFAULT_MAX_WAIT_TIME)
.threadsAllowedToBlockForConnectionMultiplier(100);
}