[dubbo] branch 3.2 updated: Enhance logs following up #13228 (#13229)

[albumenj]

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

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


The following commit(s) were added to refs/heads/3.2 by this push:
     new 91594eccfa Enhance logs following up #13228 (#13229)
91594eccfa is described below

commit 91594eccfaf060af2c60f8c88c9fba2234538871
Author: Albumen Kevin <jhq0...@gmail.com>
AuthorDate: Wed Oct 18 11:51:40 2023 +0800

    Enhance logs following up #13228 (#13229)
---
 .../dubbo/rpc/protocol/tri/transport/TripleGoAwayHandler.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/TripleGoAwayHandler.java
 
b/dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/transport/TripleGoAwayHandler.java
index 234d9b341b..14e652adf4 100644
--- 
a/dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/transport/TripleGoAwayHandler.java
+++ 
b/dubbo-rpc/dubbo-rpc-triple/src/main/java/org/apache/dubbo/rpc/protocol/tri/transport/TripleGoAwayHandler.java
@@ -17,6 +17,8 @@
 
 package org.apache.dubbo.rpc.protocol.tri.transport;
 
+import org.apache.dubbo.common.logger.Logger;
+import org.apache.dubbo.common.logger.LoggerFactory;
 import org.apache.dubbo.remoting.Constants;
 import org.apache.dubbo.remoting.api.connection.ConnectionHandler;
 
@@ -27,6 +29,7 @@ import io.netty.util.ReferenceCountUtil;
 
 public class TripleGoAwayHandler extends ChannelDuplexHandler {
 
+    private static final Logger logger = 
LoggerFactory.getLogger(TripleGoAwayHandler.class);
 
     public TripleGoAwayHandler() {
     }
@@ -35,6 +38,9 @@ public class TripleGoAwayHandler extends ChannelDuplexHandler 
{
     public void channelRead(ChannelHandlerContext ctx, Object msg) throws 
Exception {
         if (msg instanceof Http2GoAwayFrame) {
             final ConnectionHandler connectionHandler = (ConnectionHandler) 
ctx.pipeline().get(Constants.CONNECTION_HANDLER_NAME);
+            if (logger.isInfoEnabled()) {
+                logger.info("Receive go away frame of " + 
ctx.channel().localAddress() + " -> " + ctx.channel().remoteAddress() + " and 
will reconnect later.");
+            }
             connectionHandler.onGoAway(ctx.channel());
         }
         ReferenceCountUtil.release(msg);