From 8d7333ee45db216315c0062e35506448c4caf03b Mon Sep 17 00:00:00 2001 From: Reynold Morel Date: Thu, 7 Dec 2023 11:06:21 -0400 Subject: [PATCH] Code cleaning --- .../src/main/java/co/rsk/net/discovery/PeerExplorer.java | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/rskj-core/src/main/java/co/rsk/net/discovery/PeerExplorer.java b/rskj-core/src/main/java/co/rsk/net/discovery/PeerExplorer.java index 965c04f5e82..ce8ed79817c 100644 --- a/rskj-core/src/main/java/co/rsk/net/discovery/PeerExplorer.java +++ b/rskj-core/src/main/java/co/rsk/net/discovery/PeerExplorer.java @@ -438,7 +438,8 @@ synchronized void update() { private void checkPeersPulse(List closestNodes) { List nodesToCheck = this.getRandomizeLimitedList(closestNodes, MAX_NODES_TO_CHECK, 10); - logger.trace("checkPeersPulse - Checking peers pulse for nodes: [{}], nodesToCheck: [{}]", closestNodes, nodesToCheck); + logger.trace("checkPeersPulse - Checking peers pulse for nodes: [{}], nodesToCheck: [{}]" + , closestNodes, nodesToCheck); nodesToCheck.forEach(node -> sendPing(node.getAddress(), 1, node)); } @@ -446,7 +447,8 @@ private void checkPeersPulse(List closestNodes) { private void askForMoreNodes(List closestNodes) { List nodesToAsk = getRandomizeLimitedList(closestNodes, MAX_NODES_TO_ASK, 5); - logger.trace("askForMoreNodes - Asking for more nodes from closestNodes: [{}], nodesToAsk: [{}]", closestNodes, nodesToAsk); + logger.trace("askForMoreNodes - Asking for more nodes from closestNodes: [{}], nodesToAsk: [{}]" + , closestNodes, nodesToAsk); nodesToAsk.forEach(this::sendFindNode); } @@ -456,7 +458,8 @@ private List removeExpiredRequests(Map pendingRequests.remove(r.getMessageId())); - logger.trace("removeExpiredRequests - Removing expired requests from pendingRequests: [{}], requests: [{}]", pendingRequests, requests); + logger.trace("removeExpiredRequests - Removing expired requests from pendingRequests: [{}], requests: [{}]" + , pendingRequests, requests); return requests; }