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 <[email protected]> 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>() {
