diff --git a/ethereum/p2p/src/main/java/org/hyperledger/besu/ethereum/p2p/discovery/internal/PeerDiscoveryController.java b/ethereum/p2p/src/main/java/org/hyperledger/besu/ethereum/p2p/discovery/internal/PeerDiscoveryController.java index 0df580859f..314e28be15 100644 --- a/ethereum/p2p/src/main/java/org/hyperledger/besu/ethereum/p2p/discovery/internal/PeerDiscoveryController.java +++ b/ethereum/p2p/src/main/java/org/hyperledger/besu/ethereum/p2p/discovery/internal/PeerDiscoveryController.java @@ -436,10 +436,10 @@ public class PeerDiscoveryController { private void refreshTableIfRequired() { final long now = System.currentTimeMillis(); if (lastRefreshTime + tableRefreshIntervalMs <= now) { - LOG.debug("Peer table refresh triggered by timer expiry"); + LOG.debug("Refreshing peer table after {} ms", tableRefreshIntervalMs); refreshTable(); } else if (!peerRequirement.hasSufficientPeers()) { - LOG.debug("Peer table refresh triggered by insufficient peers"); + LOG.debug("Refreshing peer table: seeking more peers. peer count < max"); refreshTable(); } } diff --git a/ethereum/p2p/src/main/java/org/hyperledger/besu/ethereum/p2p/discovery/internal/RecursivePeerRefreshState.java b/ethereum/p2p/src/main/java/org/hyperledger/besu/ethereum/p2p/discovery/internal/RecursivePeerRefreshState.java index dbbe594d38..70b1552e01 100644 --- a/ethereum/p2p/src/main/java/org/hyperledger/besu/ethereum/p2p/discovery/internal/RecursivePeerRefreshState.java +++ b/ethereum/p2p/src/main/java/org/hyperledger/besu/ethereum/p2p/discovery/internal/RecursivePeerRefreshState.java @@ -191,7 +191,10 @@ public class RecursivePeerRefreshState { if (metadataPeer == null) { return; } - LOG.debug("Received neighbours packet with {} neighbours", peers.size()); + LOG.debug( + "Received neighbours packet with {} neighbours from {}", + peers.size(), + peer.getEnodeURLString()); for (final DiscoveryPeer receivedDiscoPeer : peers) { if (satisfiesMapAdditionCriteria(receivedDiscoPeer)) { final MetadataPeer receivedMetadataPeer =