diff --git a/ethereum/eth/src/main/java/org/hyperledger/besu/ethereum/eth/manager/task/AbstractRetryingPeerTask.java b/ethereum/eth/src/main/java/org/hyperledger/besu/ethereum/eth/manager/task/AbstractRetryingPeerTask.java index 0f673c71a0..0e2d923ec1 100644 --- a/ethereum/eth/src/main/java/org/hyperledger/besu/ethereum/eth/manager/task/AbstractRetryingPeerTask.java +++ b/ethereum/eth/src/main/java/org/hyperledger/besu/ethereum/eth/manager/task/AbstractRetryingPeerTask.java @@ -93,7 +93,7 @@ public abstract class AbstractRetryingPeerTask extends AbstractEthTask { if (error != null) { handleTaskError(error); } else { - // If we get a partial success reset the retry counter. + // If we get a partial success, reset the retry counter. if (!isEmptyResponse.test(peerResult)) { retryCount = 0; } @@ -114,7 +114,7 @@ public abstract class AbstractRetryingPeerTask extends AbstractEthTask { if (cause instanceof NoAvailablePeersException) { LOG.info( - "No useful peer available, waiting for more peers: {}", + "No useful peer found, checking remaining current peers for usefulness: {}", ethContext.getEthPeers().peerCount()); // Wait for new peer to connect final WaitForPeerTask waitTask = WaitForPeerTask.create(ethContext, metricsSystem); diff --git a/ethereum/eth/src/main/java/org/hyperledger/besu/ethereum/eth/sync/fastsync/FastSyncTargetManager.java b/ethereum/eth/src/main/java/org/hyperledger/besu/ethereum/eth/sync/fastsync/FastSyncTargetManager.java index e1d0310fe7..30b0ee18d4 100644 --- a/ethereum/eth/src/main/java/org/hyperledger/besu/ethereum/eth/sync/fastsync/FastSyncTargetManager.java +++ b/ethereum/eth/src/main/java/org/hyperledger/besu/ethereum/eth/sync/fastsync/FastSyncTargetManager.java @@ -64,7 +64,9 @@ class FastSyncTargetManager extends SyncTargetManager { final BlockHeader pivotBlockHeader = fastSyncState.getPivotBlockHeader().get(); final Optional maybeBestPeer = ethContext.getEthPeers().bestPeerWithHeightEstimate(); if (!maybeBestPeer.isPresent()) { - LOG.info("No sync target, waiting for peers: {}", ethContext.getEthPeers().peerCount()); + LOG.info( + "No sync target, checking current peers for usefulness: {}", + ethContext.getEthPeers().peerCount()); return completedFuture(Optional.empty()); } else { final EthPeer bestPeer = maybeBestPeer.get();