This is an automated email from the ASF dual-hosted git repository. kenhuuu pushed a commit to branch master-http-final in repository https://gitbox.apache.org/repos/asf/tinkerpop.git
commit 7614dff0d976ddb4abb13301b56e0af56269dd3c Author: Ken Hu <[email protected]> AuthorDate: Thu Oct 31 16:13:53 2024 -0700 Add signal that bytes were read in HttpGremlinResponseDecoder CTR --- .../tinkerpop/gremlin/driver/handler/HttpGremlinResponseDecoder.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/handler/HttpGremlinResponseDecoder.java b/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/handler/HttpGremlinResponseDecoder.java index 3bd1719342..0a512ae91e 100644 --- a/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/handler/HttpGremlinResponseDecoder.java +++ b/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/handler/HttpGremlinResponseDecoder.java @@ -56,6 +56,9 @@ public class HttpGremlinResponseDecoder extends MessageToMessageDecoder<FullHttp @Override protected void decode(ChannelHandlerContext ctx, FullHttpResponse msg, List<Object> out) throws Exception { + // A value must be set in order to signal to the InactiveChannelHandler that data has been received. + ctx.channel().attr(InactiveChannelHandler.BYTES_READ).set(0); + final ByteBuf content = msg.content(); ResponseMessage response;
