log

AnonHxy · AnonHxy · commit ecaea19c06f0 · 2026-01-22T09:08:50.000+08:00
diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/EntryLocationIndex.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/storage/ldb/EntryLocationIndex.java
@@ -68,8 +68,10 @@ public EntryLocationIndex(ServerConfiguration conf, KeyValueStorageFactory stora
 
     @Override
     public void close() throws IOException {
+        log.info("Closing EntryLocationIndex");
         while (!compacting.compareAndSet(false, true)) {
             // Wait till the locationsDb stops compacting
+            log.info("Waiting the locationsDb stops compacting");
             try {
                 Thread.sleep(100);
             } catch (InterruptedException e) {
@@ -78,6 +80,7 @@ public void close() throws IOException {
             }
         }
         locationsDb.close();
+        log.info("Closed EntryLocationIndex");
     }
 
     public long getLocation(long ledgerId, long entryId) throws IOException {

Original file line number	Diff line number	Diff line change
`@@ -68,8 +68,10 @@ public EntryLocationIndex(ServerConfiguration conf, KeyValueStorageFactory stora`
`68`	`68`
`69`	`69`	`@Override`
`70`	`70`	`public void close() throws IOException {`
	`71`	`+ log.info("Closing EntryLocationIndex");`
`71`	`72`	`while (!compacting.compareAndSet(false, true)) {`
`72`	`73`	`// Wait till the locationsDb stops compacting`
	`74`	`+ log.info("Waiting the locationsDb stops compacting");`
`73`	`75`	`try {`
`74`	`76`	`Thread.sleep(100);`
`75`	`77`	`} catch (InterruptedException e) {`
`@@ -78,6 +80,7 @@ public void close() throws IOException {`
`78`	`80`	`}`
`79`	`81`	`}`
`80`	`82`	`locationsDb.close();`
	`83`	`+ log.info("Closed EntryLocationIndex");`
`81`	`84`	`}`
`82`	`85`
`83`	`86`	`public long getLocation(long ledgerId, long entryId) throws IOException {`