You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tinkerpop.apache.org by sp...@apache.org on 2015/06/30 14:49:58 UTC
incubator-tinkerpop git commit: Add maxWaitForConnection as a
configuration option.
Repository: incubator-tinkerpop
Updated Branches:
refs/heads/master fe61a67e0 -> 99e0920b9
Add maxWaitForConnection as a configuration option.
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/99e0920b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/99e0920b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/99e0920b
Branch: refs/heads/master
Commit: 99e0920b990a7dbeff49fda966100c5dbdd4693e
Parents: fe61a67
Author: Stephen Mallette <sp...@genoprime.com>
Authored: Tue Jun 30 08:49:34 2015 -0400
Committer: Stephen Mallette <sp...@genoprime.com>
Committed: Tue Jun 30 08:49:34 2015 -0400
----------------------------------------------------------------------
.../apache/tinkerpop/gremlin/driver/util/ProfilingApplication.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/99e0920b/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/util/ProfilingApplication.java
----------------------------------------------------------------------
diff --git a/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/util/ProfilingApplication.java b/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/util/ProfilingApplication.java
index 36b4fe1..000ac29 100644
--- a/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/util/ProfilingApplication.java
+++ b/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/util/ProfilingApplication.java
@@ -126,6 +126,7 @@ public class ProfilingApplication {
final int maxSimultaneousUsagePerConnection = Integer.parseInt(options.getOrDefault("maxSimultaneousUsagePerConnection", "32").toString());
final int maxInProcessPerConnection = Integer.parseInt(options.getOrDefault("maxInProcessPerConnection", "64").toString());
final int minInProcessPerConnection = Integer.parseInt(options.getOrDefault("minInProcessPerConnection", "16").toString());
+ final int maxWaitForConnection = Integer.parseInt(options.getOrDefault("maxWaitForConnection", "3000").toString());
final int workerPoolSize = Integer.parseInt(options.getOrDefault("workerPoolSize", "2").toString());
final int tooSlowThreshold = Integer.parseInt(options.getOrDefault("tooSlowThreshold", "125").toString());
final String serializer = options.getOrDefault("serializer", Serializers.GRYO_V1D0.name()).toString();
@@ -140,6 +141,7 @@ public class ProfilingApplication {
.minInProcessPerConnection(minInProcessPerConnection)
.maxInProcessPerConnection(maxInProcessPerConnection)
.nioPoolSize(nioPoolSize)
+ .maxWaitForConnection(maxWaitForConnection)
.serializer(Serializers.valueOf(serializer))
.workerPoolSize(workerPoolSize).create();