Skip to content

Commit

Permalink
Code cleaning
Browse files Browse the repository at this point in the history
  • Loading branch information
rmoreliovlabs committed Dec 7, 2023
1 parent fde468e commit 8d7333e
Showing 1 changed file with 6 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -438,15 +438,17 @@ synchronized void update() {
private void checkPeersPulse(List<Node> closestNodes) {
List<Node> 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));
}

private void askForMoreNodes(List<Node> closestNodes) {
List<Node> 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);
}
Expand All @@ -456,7 +458,8 @@ private List<PeerDiscoveryRequest> removeExpiredRequests(Map<String, PeerDiscove
.filter(PeerDiscoveryRequest::hasExpired).collect(Collectors.toList());
requests.forEach(r -> 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;
}
Expand Down

0 comments on commit 8d7333e

Please sign in to comment.