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 2021/04/30 10:25:24 UTC
[tinkerpop] 01/01: Hardcode threadpool size to 2.
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 e69a17d5c98c0b685206f5a3c7148bb55110ade8
Author: Stephen Mallette <st...@amazon.com>
AuthorDate: Fri Apr 30 06:23:37 2021 -0400
Hardcode threadpool size to 2.
Travis likely sets the thread pool to 1 for the test client and that may create hanging situations for some reason internal to netty.CTR
---
.../java/org/apache/tinkerpop/gremlin/driver/simple/AbstractClient.java | 2 +-
.../org/apache/tinkerpop/gremlin/driver/simple/WebSocketClient.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/simple/AbstractClient.java b/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/simple/AbstractClient.java
index 270277b..6fd5a6d 100644
--- a/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/simple/AbstractClient.java
+++ b/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/simple/AbstractClient.java
@@ -42,7 +42,7 @@ public abstract class AbstractClient implements SimpleClient {
public AbstractClient(final String threadPattern) {
final BasicThreadFactory threadFactory = new BasicThreadFactory.Builder().namingPattern(threadPattern).build();
- group = new NioEventLoopGroup(1, threadFactory);
+ group = new NioEventLoopGroup(2, threadFactory);
}
public abstract void writeAndFlush(final RequestMessage requestMessage) throws Exception;
diff --git a/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/simple/WebSocketClient.java b/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/simple/WebSocketClient.java
index 767f5a8..68d1639 100644
--- a/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/simple/WebSocketClient.java
+++ b/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/simple/WebSocketClient.java
@@ -69,7 +69,7 @@ public class WebSocketClient extends AbstractClient {
try {
final WebSocketClientHandler wsHandler = new WebSocketClientHandler(WebSocketClientHandshakerFactory.newHandshaker(
- uri, WebSocketVersion.V13, null, true, EmptyHttpHeaders.INSTANCE, 65536), 10000);
+ uri, WebSocketVersion.V13, null, true, EmptyHttpHeaders.INSTANCE, 65536), 15000);
final MessageSerializer<GraphBinaryMapper> serializer = new GraphBinaryMessageSerializerV1();
b.channel(NioSocketChannel.class)
.handler(new ChannelInitializer<SocketChannel>() {