mdf pong msg

tronprotocol · Mar 29, 2018 · 7829583 · 7829583
1 parent 90740a8
commit 7829583
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/src/main/java/org/tron/common/overlay/discover/NodeHandler.java b/src/main/java/org/tron/common/overlay/discover/NodeHandler.java
@@ -281,7 +281,7 @@ void sendPing() {
     }
 
     void sendPong() {
-        Message pong = new PongMessage(node);
+        Message pong = new PongMessage(nodeManager.getPublicHomeNode());
         logMessage(pong, false);
         sendMessage(pong);
         getNodeStatistics().discoverOutPong.add();

diff --git a/src/main/java/org/tron/common/overlay/server/HandshakeHandler.java b/src/main/java/org/tron/common/overlay/server/HandshakeHandler.java
@@ -83,6 +83,8 @@ protected void decode(ChannelHandlerContext ctx, ByteBuf buffer, List<Object> ou
     final HelloMessage helloMessage = (HelloMessage) msg;
 
     if (helloMessage.getVersion() != Args.getInstance().getNodeP2pVersion()) {
+      logger.info("version not support, you[{}] version[{}], my version[{}]",
+              ctx.channel().remoteAddress(), helloMessage.getVersion(), Args.getInstance().getNodeP2pVersion());
       ctx.close();
       return;
     }