|
|
@ -93,7 +93,7 @@ public abstract class AbstractRetryingPeerTask<T> extends AbstractEthTask<T> { |
|
|
|
if (error != null) { |
|
|
|
if (error != null) { |
|
|
|
handleTaskError(error); |
|
|
|
handleTaskError(error); |
|
|
|
} else { |
|
|
|
} 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)) { |
|
|
|
if (!isEmptyResponse.test(peerResult)) { |
|
|
|
retryCount = 0; |
|
|
|
retryCount = 0; |
|
|
|
} |
|
|
|
} |
|
|
@ -114,7 +114,7 @@ public abstract class AbstractRetryingPeerTask<T> extends AbstractEthTask<T> { |
|
|
|
|
|
|
|
|
|
|
|
if (cause instanceof NoAvailablePeersException) { |
|
|
|
if (cause instanceof NoAvailablePeersException) { |
|
|
|
LOG.info( |
|
|
|
LOG.info( |
|
|
|
"No useful peer available, waiting for more peers: {}", |
|
|
|
"No useful peer found, checking remaining current peers for usefulness: {}", |
|
|
|
ethContext.getEthPeers().peerCount()); |
|
|
|
ethContext.getEthPeers().peerCount()); |
|
|
|
// Wait for new peer to connect
|
|
|
|
// Wait for new peer to connect
|
|
|
|
final WaitForPeerTask waitTask = WaitForPeerTask.create(ethContext, metricsSystem); |
|
|
|
final WaitForPeerTask waitTask = WaitForPeerTask.create(ethContext, metricsSystem); |
|
|
|