[LOGGING] snap pipeline errors and peer reputation

ethereum/eth/src/main/java/org/hyperledger/besu/ethereum/eth/sync/snapsync/RequestDataStep.java

@@ -103,6 +103,14 @@ public CompletableFuture<Task<SnapDataRequest>> requestAccount(
                 accountDataRequest.addResponse(
                     worldStateProofProvider, response.accounts(), response.proofs());
               }
+              if (error != null) {
+                LOG.atWarn()
+                    .setMessage("Error handling account download accounts ({} - {}) task: {}")
+                    .addArgument(accountDataRequest.getStartKeyHash())
+                    .addArgument(accountDataRequest.getEndKeyHash())
+                    .addArgument(error)
+                    .log();
+              }
               return requestTask;
             });
   }
@@ -166,6 +174,12 @@ public CompletableFuture<List<Task<SnapDataRequest>>> requestStorage(
                   LOG.error("Error while processing storage range response", e);
                 }
               }
+              if (error != null) {
+                LOG.atWarn()
+                    .setMessage("Error handling storage range request task: {}")
+                    .addArgument(error)
+                    .log();
+              }
               return requestTasks;
             });
   }
@@ -198,6 +212,12 @@ public CompletableFuture<List<Task<SnapDataRequest>>> requestCode(
                   }
                 }
               }
+              if (error != null) {
+                LOG.atWarn()
+                    .setMessage("Error handling code request task: {}")
+                    .addArgument(error)
+                    .log();
+              }
               return requestTasks;
             });
   }
@@ -237,6 +257,12 @@ public CompletableFuture<List<Task<SnapDataRequest>>> requestTrieNodeByPath(
                   }
                 }
               }
+              if (error != null) {
+                LOG.atWarn()
+                    .setMessage("Error handling trie node request task: {}")
+                    .addArgument(error)
+                    .log();
+              }
               return requestTasks;
             });
   }