@ -202,24 +202,24 @@ public class BackwardSyncContext {
backwardSyncException - > {
backwardSyncException - > {
if ( backwardSyncException . shouldRestart ( ) ) {
if ( backwardSyncException . shouldRestart ( ) ) {
LOG . info (
LOG . info (
"Backward sync failed ({}). Current Peers: {}. Retrying in "
"Backward sync failed ({}). Current Peers: {}. Retrying in {} milliseconds..." ,
+ millisBetweenRetries
throwable . getMessage ( ) ,
+ " milliseconds..." ,
ethContext . getEthPeers ( ) . peerCount ( ) ,
backwardSyncException . getMessage ( ) ,
millisBetweenRetries ) ;
ethContext . getEthPeers ( ) . peerCount ( ) ) ;
return ;
} else {
} else {
debugLambda (
debugLambda (
LOG , "Not recoverable backward sync exception {}" , throwable : : getMessage ) ;
LOG , "Not recoverable backward sync exception {}" , throwable : : getMessage ) ;
throw backwardSyncException ;
throw backwardSyncException ;
}
}
} ,
} ,
( ) - >
( ) - > {
LOG . warn (
LOG . warn (
"There was an uncaught exception during Backwards Sync. Retrying in "
"Backward sync failed ({}). Current Peers: {}. Retrying in {} milliseconds..." ,
+ millisBetweenRetries
throwable . getMessage ( ) ,
+ " milliseconds..." ,
ethContext . getEthPeers ( ) . peerCount ( ) ,
throwable ) ) ;
millisBetweenRetries ) ;
LOG . debug ( "Exception details:" , throwable ) ;
} ) ;
}
}
private Optional < BackwardSyncException > extractBackwardSyncException ( final Throwable throwable ) {
private Optional < BackwardSyncException > extractBackwardSyncException ( final Throwable throwable ) {