This is an automated email from the ASF dual-hosted git repository.

guohao pushed a commit to branch 3.0
in repository https://gitbox.apache.org/repos/asf/dubbo.git


The following commit(s) were added to refs/heads/3.0 by this push:
     new 6da4c0c41c [3.0 Triple] Fix client on error (#9939)
6da4c0c41c is described below

commit 6da4c0c41ceb6647b368f51679834c945aaf243c
Author: GuoHao <[email protected]>
AuthorDate: Tue Apr 19 16:22:14 2022 +0800

    [3.0 Triple] Fix client on error (#9939)
    
    * Add notify when conneciton closed
    
    * Use constant
---
 .../protocol/tri/transport/TripleHttp2ClientResponseHandler.java    | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git 
a/dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/transport/TripleHttp2ClientResponseHandler.java
 
b/dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/transport/TripleHttp2ClientResponseHandler.java
index 8164354119..3fd99be7c6 100644
--- 
a/dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/transport/TripleHttp2ClientResponseHandler.java
+++ 
b/dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/transport/TripleHttp2ClientResponseHandler.java
@@ -75,6 +75,12 @@ public final class TripleHttp2ClientResponseHandler extends
         ctx.close();
     }
 
+    @Override
+    public void channelInactive(ChannelHandlerContext ctx) {
+        transportListener.cancelByRemote(Http2Error.NO_ERROR.code());
+        ctx.close();
+    }
+
     @Override
     public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
         final TriRpcStatus status = TriRpcStatus.INTERNAL

Reply via email to