optimize: wakeup pusher after pending response

Change-Id: I0a5206902443bf8089abdab65713624f687c6ee6
openmessaging · Oct 17, 2023 · 80a729c · 80a729c
1 parent 9703558
commit 80a729c
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/dledger/src/main/java/io/openmessaging/storage/dledger/DLedgerEntryPusher.java b/dledger/src/main/java/io/openmessaging/storage/dledger/DLedgerEntryPusher.java
@@ -793,6 +793,7 @@ private void sendBatchAppendEntryRequest() throws Exception {
             responseFuture.whenComplete((x, ex) -> {
                 try {
                     pendingTotalSize.addAndGet(-1 * entriesSize);
+                    wakeup();
                     PreConditions.check(ex == null, DLedgerResponseCode.UNKNOWN);
                     DLedgerResponseCode responseCode = DLedgerResponseCode.valueOf(x.getCode());
                     switch (responseCode) {