From 6fb84bc61c02862ecbac06502517f3b7b15d6e1c Mon Sep 17 00:00:00 2001 From: Eric Anderson Date: Thu, 3 Dec 2020 10:12:40 -0800 Subject: [PATCH] Call the HTTP/2 close() so that GOAWAY is issued --- netty/src/main/java/io/grpc/netty/NettyClientHandler.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/netty/src/main/java/io/grpc/netty/NettyClientHandler.java b/netty/src/main/java/io/grpc/netty/NettyClientHandler.java index 0fd61a4ff5..3a31498f0f 100644 --- a/netty/src/main/java/io/grpc/netty/NettyClientHandler.java +++ b/netty/src/main/java/io/grpc/netty/NettyClientHandler.java @@ -767,7 +767,6 @@ class NettyClientHandler extends AbstractNettyHandler { private void forcefulClose(final ChannelHandlerContext ctx, final ForcefulCloseCommand msg, ChannelPromise promise) throws Exception { - ctx.close(); connection().forEachActiveStream(new Http2StreamVisitor() { @Override public boolean visit(Http2Stream stream) throws Http2Exception { @@ -787,7 +786,7 @@ class NettyClientHandler extends AbstractNettyHandler { } } }); - promise.setSuccess(); + close(ctx, promise); } /**