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/03/31 14:06:23 UTC

[dubbo] branch 3.0 updated: Add remote address log (#9872)

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 d5f465c  Add remote address log (#9872)
d5f465c is described below

commit d5f465cef9db744409464ba617e0628956c36281
Author: GuoHao <gu...@gmail.com>
AuthorDate: Thu Mar 31 22:05:40 2022 +0800

    Add remote address log (#9872)
---
 .../org/apache/dubbo/remoting/api/PortUnificationServerHandler.java  | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/api/PortUnificationServerHandler.java b/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/api/PortUnificationServerHandler.java
index e42e052..4e15beb 100644
--- a/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/api/PortUnificationServerHandler.java
+++ b/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/api/PortUnificationServerHandler.java
@@ -102,8 +102,9 @@ public class PortUnificationServerHandler extends ByteToMessageDecoder {
         Set<String> supported = url.getApplicationModel()
             .getExtensionLoader(WireProtocol.class)
             .getSupportedExtensions();
-        LOGGER.error(String.format("Can not recognize protocol from downstream . "
-            + "preface=%s protocols=%s", Bytes.bytes2hex(preface), supported));
+        LOGGER.error(String.format("Can not recognize protocol from downstream=%s . "
+                + "preface=%s protocols=%s", ctx.channel().remoteAddress(), Bytes.bytes2hex(preface),
+            supported));
 
         // Unknown protocol; discard everything and close the connection.
         in.clear();