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; }