[fix][ml] Remove unnecessary return in ManagedLedgerImpl

apache · Oct 8, 2024 · 5cd8ee0 · 5cd8ee0
1 parent c598974
commit 5cd8ee0
Showing 1 changed file with 0 additions and 7 deletions.
diff --git a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java
@@ -2229,13 +2229,11 @@ public void readEntryComplete(Entry entry, Object ctx) {
  Object cbCtx = this.cntx;
  if (recycle(reOpCount)) {
  callback.readEntryComplete(entry, cbCtx);
- return;
  } else {
  if (log.isDebugEnabled()) {
  log.debug("[{}] read entry already completed for {}-{}", name, ledgerId, entryId);
  }
  entry.release();
- return;
  }
  }
 
@@ -2246,7 +2244,6 @@ public void readEntryFailed(ManagedLedgerException exception, Object ctx) {
  Object cbCtx = this.cntx;
  if (recycle(reOpCount)) {
  callback.readEntryFailed(exception, cbCtx);
- return;
  } else {
  if (log.isDebugEnabled()) {
  log.debug("[{}] read entry already completed for {}-{}", name, ledgerId, entryId);
@@ -2261,13 +2258,11 @@ public void readEntriesComplete(List<Entry> returnedEntries, Object ctx) {
  Object cbCtx = this.cntx;
  if (recycle(reOpCount)) {
  callback.readEntriesComplete(returnedEntries, cbCtx);
- return;
  } else {
  if (log.isDebugEnabled()) {
  log.debug("[{}] read entry already completed for {}-{}", name, ledgerId, entryId);
  }
  returnedEntries.forEach(Entry::release);
- return;
  }
  }
 
@@ -2278,12 +2273,10 @@ public void readEntriesFailed(ManagedLedgerException exception, Object ctx) {
  Object cbCtx = this.cntx;
  if (recycle(reOpCount)) {
  callback.readEntriesFailed(exception, cbCtx);
- return;
  } else {
  if (log.isDebugEnabled()) {
  log.debug("[{}] read entry already completed for {}-{}", name, ledgerId, entryId);
  }
- return;
  }
  }