Skip to content

Commit 8441225

Browse files
committed
add udp log
1 parent ed3bab7 commit 8441225

File tree

3 files changed

+5
-4
lines changed

3 files changed

+5
-4
lines changed

src/main/java/org/tron/common/net/udp/handler/MessageHandler.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ public void channelActive(ChannelHandlerContext ctx) throws Exception {
5050

5151
@Override
5252
public void channelRead0(ChannelHandlerContext ctx, UdpEvent udpEvent) {
53-
logger.debug("rcv udp msg type {}, len {} from {} ",
53+
logger.info("rcv udp msg type {}, len {} from {} ",
5454
udpEvent.getMessage().getType(),
5555
udpEvent.getMessage().getSendData().length,
5656
udpEvent.getAddress());
@@ -59,7 +59,7 @@ public void channelRead0(ChannelHandlerContext ctx, UdpEvent udpEvent) {
5959

6060
@Override
6161
public void accept(UdpEvent udpEvent) {
62-
logger.debug("send udp msg type {}, len {} to {} ",
62+
logger.info("send udp msg type {}, len {} to {} ",
6363
udpEvent.getMessage().getType(),
6464
udpEvent.getMessage().getSendData().length,
6565
udpEvent.getAddress());

src/main/java/org/tron/common/overlay/discover/node/NodeHandler.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -127,6 +127,7 @@ private void challengeWith(NodeHandler replaceCandidate) {
127127

128128
// Manages state transfers
129129
public void changeState(State newState) {
130+
logger.info("Node {} change status {} to {}", node.getHost(), state, newState);
130131
State oldState = state;
131132
if (newState == State.Discovered) {
132133
sendPing();
@@ -225,7 +226,7 @@ public void handleFindNode(FindNodeMessage msg) {
225226
}
226227

227228
public void handleTimedOut() {
228-
logger.debug("ping timeout {}", node);
229+
logger.info("ping timeout {}", node);
229230
waitForPong = false;
230231
if (--pingTrials > 0) {
231232
sendPing();

src/main/java/org/tron/core/config/args/Args.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -716,7 +716,7 @@ private static void logConfig(){
716716
logger.info("Discover enable: {}", args.isNodeDiscoveryEnable());
717717
logger.info("Active node size: {}", args.getActiveNodes().size());
718718
logger.info("Passive node size: {}", args.getPassiveNodes().size());
719-
logger.info("Seed node size: {}", args.getSeedNodes().size());
719+
logger.info("Seed node size: {}", args.getSeedNode().getIpList().size());
720720
logger.info("Max connection: {}", args.getNodeMaxActiveNodes());
721721
logger.info("Max connection with same IP: {}", args.getNodeMaxActiveNodesWithSameIp());
722722
logger.info("************************ Backup config ************************");

0 commit comments

Comments
 (0)