bsc state error (#539)

drpcorg · Aug 1, 2024 · 91784fe · 91784fe
1 parent 09a6508
commit 91784fe
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 8 deletions.
diff --git a/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/EthereumLowerBoundStateDetector.kt b/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/EthereumLowerBoundStateDetector.kt
@@ -43,6 +43,7 @@ class EthereumLowerBoundStateDetector(
             "load state tree: failed to load state tree", // filecoin
             "purged for block", // erigon
             "No state data", // our own error if there is "null" in response
+            "state is not available", // bsc also can return this error along with "header not found"
         )
     }
 

diff --git a/src/main/kotlin/io/emeraldpay/dshackle/upstream/lowerbound/detector/RecursiveLowerBound.kt b/src/main/kotlin/io/emeraldpay/dshackle/upstream/lowerbound/detector/RecursiveLowerBound.kt
@@ -169,14 +169,24 @@ class RecursiveLowerBound(
                 !nonRetryableErrors.any { err -> it.message?.contains(err, true) ?: false }
             }
             .doAfterRetry {
-                log.debug(
-                    "Error in calculation of lower block {} of upstream {}, type - {}, retry attempt - {}, message - {}",
-                    block,
-                    upstream.getId(),
-                    type,
-                    it.totalRetries(),
-                    it.failure().message,
-                )
+                if (it.totalRetries() > 30) {
+                    log.warn(
+                        "There are too much retries to calculate {} lower bound of upstream {}, " +
+                            "probably this error with message `{}` is not retryable, please report it to dshackle devs",
+                        type,
+                        upstream.getId(),
+                        it.failure().message,
+                    )
+                } else {
+                    log.debug(
+                        "Error in calculation of lower block {} of upstream {}, type - {}, retry attempt - {}, message - {}",
+                        block,
+                        upstream.getId(),
+                        type,
+                        it.totalRetries(),
+                        it.failure().message,
+                    )
+                }
             }
     }