[bookkeeper] branch master updated: Add read failed log for ledger checker. (#4010)

[lushiji]

This is an automated email from the ASF dual-hosted git repository.

lushiji pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/bookkeeper.git


The following commit(s) were added to refs/heads/master by this push:
     new fb0d3d6faa Add read failed log for ledger checker. (#4010)
fb0d3d6faa is described below

commit fb0d3d6faab3f9703c7f63b280f1f9c2e18f966d
Author: Yan Zhao <horizo...@apache.org>
AuthorDate: Fri Jul 7 15:14:24 2023 +0800

    Add read failed log for ledger checker. (#4010)
    
    Add read failed log for ledger checker.
---
 .../src/main/java/org/apache/bookkeeper/client/LedgerChecker.java | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git 
a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerChecker.java
 
b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerChecker.java
index 6bbdc098de..9364b8563c 100644
--- 
a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerChecker.java
+++ 
b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerChecker.java
@@ -87,6 +87,9 @@ public class LedgerChecker {
                     cb.operationComplete(rc, fragment);
                 }
             } else if (!completed.getAndSet(true)) {
+                if (LOG.isDebugEnabled()) {
+                    LOG.debug("Read {}:{} from {} failed, the error code: {}", 
ledgerId, entryId, ctx, rc);
+                }
                 cb.operationComplete(rc, fragment);
             }
         }
@@ -254,7 +257,7 @@ public class LedgerChecker {
             ReadManyEntriesCallback manycb = new ReadManyEntriesCallback(1,
                     fragment, cb);
             bookieClient.readEntry(bookie, fragment.getLedgerId(), firstStored,
-                                   manycb, null, BookieProtocol.FLAG_NONE);
+                                   manycb, bookie, BookieProtocol.FLAG_NONE);
         } else {
             if (lastStored <= firstStored) {
                 cb.operationComplete(Code.IncorrectParameterException, null);
@@ -296,7 +299,8 @@ public class LedgerChecker {
                     fragment, cb);
             for (Long entryID: entriesToBeVerified) {
                 acquirePermit();
-                bookieClient.readEntry(bookie, fragment.getLedgerId(), 
entryID, manycb, null, BookieProtocol.FLAG_NONE);
+                bookieClient.readEntry(bookie, fragment.getLedgerId(), 
entryID, manycb, bookie,
+                        BookieProtocol.FLAG_NONE);
             }
         }
     }