Skip to content

Commit

Permalink
Update messages
Browse files Browse the repository at this point in the history
  • Loading branch information
rmoreliovlabs committed Nov 29, 2023
1 parent 3d93954 commit e23bd46
Showing 1 changed file with 5 additions and 6 deletions.
11 changes: 5 additions & 6 deletions rskj-core/src/main/java/co/rsk/net/discovery/PeerExplorer.java
Original file line number Diff line number Diff line change
Expand Up @@ -161,10 +161,9 @@ void setUDPChannel(UDPChannel udpChannel) {

synchronized void handleMessage(DiscoveryEvent event) {
logger.debug("handleMessage - Handling message with " +
"state: [{}], " +
"type: [{}], " +
"networkId: [{}]",
state, event.getMessage().getMessageType(),
"type: [{}], " +
"networkId: [{}]",
event.getMessage().getMessageType(),
event.getMessage().getNetworkId());

if (state != ExecState.RUNNING) {
Expand Down Expand Up @@ -241,7 +240,7 @@ private void handleFindNode(FindNodePeerMessage message) {

if (connectedNode != null) {
List<Node> nodesToSend = this.distanceTable.getClosestNodes(nodeId);
logger.debug("handleFindNode - About to send [{}] neighbors to address[{}/{}], nodeId[{}] with messageId[{}]",
logger.debug("handleFindNode - About to send [{}] neighbors to address: [{}/{}], nodeId: [{}] with messageId: [{}]",
nodesToSend.size(), connectedNode.getHost(), connectedNode.getPort(), connectedNode.getHexId(), message.getMessageId());
this.sendNeighbors(connectedNode.getAddress(), nodesToSend, message.getMessageId());
updateEntry(connectedNode);
Expand All @@ -255,7 +254,7 @@ private void handleNeighborsMessage(InetSocketAddress neighborsResponseAddress,
Node connectedNode = this.establishedConnections.get(nodeId);

if (connectedNode != null) {
logger.debug("handleNeighborsMessage - Neighbors received from id[{}], ip[{}], port[{}] with " +
logger.debug("handleNeighborsMessage - Neighbors received from id: [{}], address: [{}/{}] with " +
"nodeId: [{}]," +
"messageId: [{}], " +
"nodesCount: [{}], " +
Expand Down

0 comments on commit e23bd46

Please sign in to comment.