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 2019/11/14 00:08:44 UTC
[tinkerpop] 02/02: Increase default max wait time for a connection
with java driver
This is an automated email from the ASF dual-hosted git repository.
spmallette pushed a commit to branch travis-fix
in repository https://gitbox.apache.org/repos/asf/tinkerpop.git
commit 106b896c65879c0afb8924c6600896d829ef2ebf
Author: stephen <sp...@gmail.com>
AuthorDate: Wed Nov 13 19:07:44 2019 -0500
Increase default max wait time for a connection with java driver
Cleaned up some dead log messages from debugging
---
.../main/java/org/apache/tinkerpop/gremlin/driver/Connection.java | 2 +-
.../tinkerpop/gremlin/server/GremlinServerSessionIntegrateTest.java | 6 ------
2 files changed, 1 insertion(+), 7 deletions(-)
diff --git a/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/Connection.java b/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/Connection.java
index e700d49..aa0868f 100644
--- a/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/Connection.java
+++ b/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/Connection.java
@@ -61,7 +61,7 @@ final class Connection {
public static final int MAX_IN_PROCESS = 4;
public static final int MIN_IN_PROCESS = 1;
- public static final int MAX_WAIT_FOR_CONNECTION = 3000;
+ public static final int MAX_WAIT_FOR_CONNECTION = 16000;
public static final int MAX_WAIT_FOR_SESSION_CLOSE = 3000;
public static final int MAX_CONTENT_LENGTH = 65536;
diff --git a/gremlin-server/src/test/java/org/apache/tinkerpop/gremlin/server/GremlinServerSessionIntegrateTest.java b/gremlin-server/src/test/java/org/apache/tinkerpop/gremlin/server/GremlinServerSessionIntegrateTest.java
index 889228c..9a3e4ff 100644
--- a/gremlin-server/src/test/java/org/apache/tinkerpop/gremlin/server/GremlinServerSessionIntegrateTest.java
+++ b/gremlin-server/src/test/java/org/apache/tinkerpop/gremlin/server/GremlinServerSessionIntegrateTest.java
@@ -343,10 +343,8 @@ public class GremlinServerSessionIntegrateTest extends AbstractGremlinServerInt
}
});
- System.out.println("shouldEnsureSessionBindingsAreThreadSafe: sent 10000");
assertEquals(requests, futures.size());
- System.out.println("shouldEnsureSessionBindingsAreThreadSafe: asserting 10000");
int counter = 0;
for (CompletableFuture<ResultSet> f : futures) {
final Result r = f.get().all().get(30000, TimeUnit.MILLISECONDS).get(0);
@@ -355,14 +353,10 @@ public class GremlinServerSessionIntegrateTest extends AbstractGremlinServerInt
}
assertEquals(requests, counter);
- System.out.println("shouldEnsureSessionBindingsAreThreadSafe: asserted 10000");
-
} catch (Exception ex) {
fail(ex.getMessage());
} finally {
- System.out.println("shouldEnsureSessionBindingsAreThreadSafe: calling cluster.close");
cluster.close();
- System.out.println("shouldEnsureSessionBindingsAreThreadSafe: called cluster.close");
}
}