You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by gu...@apache.org on 2022/04/14 03:05:02 UTC
[dubbo] branch 3.0 updated: Fix mem leak (#9919)
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 091168afca Fix mem leak (#9919)
091168afca is described below
commit 091168afcac1b532df12a063cc8bbcd0819665bb
Author: GuoHao <gu...@gmail.com>
AuthorDate: Thu Apr 14 11:04:30 2022 +0800
Fix mem leak (#9919)
---
.../org/apache/dubbo/rpc/protocol/tri/stream/TripleClientStream.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/stream/TripleClientStream.java b/dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/stream/TripleClientStream.java
index bdeeaac672..7024d61531 100644
--- a/dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/stream/TripleClientStream.java
+++ b/dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/stream/TripleClientStream.java
@@ -93,7 +93,8 @@ public class TripleClientStream extends AbstractStream implements ClientStream {
channel.pipeline()
.addLast(new TripleCommandOutBoundHandler())
.addLast(new TripleHttp2ClientResponseHandler(createTransportListener()));
- parent.closeFuture().addListener(f -> transportException(f.cause()));
+ channel.closeFuture()
+ .addListener(f -> transportException(f.cause()));
return new WriteQueue(channel);
}