This is an automated email from the ASF dual-hosted git repository.
tigerlee pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git.
from 538b6b7 [ISSUE #1869] Delay message can't be consumed when delay
offset in delayOffset.json is wrong (#3358)
new a9a7dfa RIP-7 Multiple Directories Storage Suppor
new 8e19069 fix test error
new 9b0e31e 1. fix initial value of physicRatio in
org.apache.rocketmq.broker.processor.SendMessageProcessor#diskUtil 2. use
minPhysicsUsedRatio instead of max in
org.apache.rocketmq.store.DefaultMessageStore#getRuntimeInfo
new 466bb98 fix error in
org.apache.rocketmq.store.DefaultMessageStore.CleanCommitLogService#isSpaceFull
new 255a202 add path empty check to avoid error log in
org.apache.rocketmq.store.DefaultMessageStore#getRuntimeInfo
new f32406d change default value of
org.apache.rocketmq.store.config.MessageStoreConfig#MULTI_PATH_SPLITTER to ','
and can be changed by System.getProperty("rocketmq.broker.multiPathSplitter")
new 474c4eb Fix bug for multi path file loading. Opt code checking for
multi-path commitlog path in storePathCommitLog.
new 7d4e5cd fix compile error
new 14d50f9 fix a typo
new 4dbdbf0 Merge pull request #3357 from Jason918/RIP-7
The 1828 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../broker/processor/SendMessageProcessor.java | 11 +-
.../java/org/apache/rocketmq/common/UtilAll.java | 5 +
.../java/org/apache/rocketmq/store/CommitLog.java | 26 +++-
.../apache/rocketmq/store/DefaultMessageStore.java | 71 ++++++++--
.../org/apache/rocketmq/store/MappedFileQueue.java | 108 ++++++++-------
.../rocketmq/store/MultiPathMappedFileQueue.java | 127 +++++++++++++++++
.../rocketmq/store/config/MessageStoreConfig.java | 13 ++
.../store/DefaultMessageStoreCleanFilesTest.java | 42 ++++++
.../store/MultiPathMappedFileQueueTest.java | 154 +++++++++++++++++++++
9 files changed, 492 insertions(+), 65 deletions(-)
create mode 100644
store/src/main/java/org/apache/rocketmq/store/MultiPathMappedFileQueue.java
create mode 100644
store/src/test/java/org/apache/rocketmq/store/MultiPathMappedFileQueueTest.java
