opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-30 18:10:44 +08:00
Code Issues Packages Projects Releases Wiki Activity

Improve IO for asynchronous delivery processes (#8954)

Browse Source 
Co-authored-by: wanghuaiyuan <wanghuaiyuan@xiaomi.com>
This commit is contained in:
hqbfz
2024-11-20 11:13:12 +08:00
committed by GitHub
parent ae7179d75e
commit c13f051eb8
1 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
store/src/main/java/org/apache/rocketmq/store/CommitLog.java
+9 -3
View File
@@ -2179,7 +2179,9 @@ public class CommitLog implements Swappable {
// Asynchronous flush
else {
if (!CommitLog.this.defaultMessageStore.isTransientStorePoolEnable()) {
flushCommitLogService.wakeup();
if (defaultMessageStore.getMessageStoreConfig().isWakeFlushWhenPutMessage()) {
flushCommitLogService.wakeup();
}
} else {
if (defaultMessageStore.getMessageStoreConfig().isWakeCommitWhenPutMessage()) {
commitRealTimeService.wakeup();
@@ -2206,9 +2208,13 @@ public class CommitLog implements Swappable {
// Asynchronous flush
else {
if (!CommitLog.this.defaultMessageStore.isTransientStorePoolEnable()) {
flushCommitLogService.wakeup();
if (defaultMessageStore.getMessageStoreConfig().isWakeFlushWhenPutMessage()) {
flushCommitLogService.wakeup();
}
} else {
commitRealTimeService.wakeup();
if (defaultMessageStore.getMessageStoreConfig().isWakeCommitWhenPutMessage()) {
commitRealTimeService.wakeup();
}
}
return CompletableFuture.completedFuture(PutMessageStatus.PUT_OK);
}