You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by do...@apache.org on 2019/03/07 08:46:38 UTC
[rocketmq] 01/01: Merge pull request #1046 from
apache/store_with_dledger
This is an automated email from the ASF dual-hosted git repository.
dongeforever pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
commit e90d20dd49338b8934b385413b5c74a509bb26b3
Merge: bf4ac79 1bc1f22
Author: Zhendong Liu <zh...@yeah.net>
AuthorDate: Thu Mar 7 16:46:26 2019 +0800
Merge pull request #1046 from apache/store_with_dledger
Add store with dledger
.gitignore | 6 +-
README.md | 2 +
.../apache/rocketmq/broker/BrokerController.java | 183 ++++-
.../broker/dledger/DLedgerRoleChangeHandler.java | 104 +++
.../apache/rocketmq/broker/out/BrokerOuterAPI.java | 2 +-
.../broker/processor/ClientManageProcessor.java | 2 +-
.../rocketmq/broker/slave/SlaveSynchronize.java | 8 +-
.../TransactionalMessageCheckService.java | 21 -
.../client/impl/factory/MQClientInstance.java | 18 +-
.../org/apache/rocketmq/common/ServiceThread.java | 35 +-
.../rocketmq/common/message/MessageDecoder.java | 1 +
distribution/bin/dledger/fast-try.sh | 102 +++
distribution/conf/dledger/broker-n0.conf | 27 +
distribution/conf/dledger/broker-n1.conf | 27 +
distribution/conf/dledger/broker-n2.conf | 27 +
distribution/release.xml | 2 +-
docs/cn/dledger/deploy_guide.md | 76 +++
docs/cn/dledger/quick_start.md | 61 ++
.../namesrv/routeinfo/RouteInfoManager.java | 11 +
pom.xml | 5 +-
store/pom.xml | 15 +
.../rocketmq/store/AllocateMappedFileService.java | 11 +-
.../java/org/apache/rocketmq/store/CommitLog.java | 26 +-
.../org/apache/rocketmq/store/ConsumeQueue.java | 15 +-
.../apache/rocketmq/store/DefaultMessageStore.java | 123 +++-
.../org/apache/rocketmq/store/DispatchRequest.java | 16 +-
.../org/apache/rocketmq/store/MappedFileQueue.java | 4 +-
.../org/apache/rocketmq/store/MessageStore.java | 7 +
.../rocketmq/store/SelectMappedBufferResult.java | 4 +-
.../rocketmq/store/config/MessageStoreConfig.java | 36 +
.../rocketmq/store/dledger/DLedgerCommitLog.java | 747 +++++++++++++++++++++
.../org/apache/rocketmq/store/ha/HAConnection.java | 4 +-
.../store/schedule/ScheduleMessageService.java | 81 ++-
.../apache/rocketmq/store/ConsumeQueueTest.java | 3 +-
.../store/DefaultMessageStoreShutDownTest.java | 2 +-
.../org/apache/rocketmq/store/StoreTestBase.java | 93 +++
.../store/dledger/DLedgerCommitlogTest.java | 213 ++++++
.../store/dledger/MessageStoreTestBase.java | 143 ++++
.../rocketmq/store/dledger/MixCommitlogTest.java | 193 ++++++
store/src/test/resources/logback-test.xml | 2 +-
.../rocketmq/test/factory/ConsumerFactory.java | 10 +
.../rocketmq/test/factory/ProducerFactory.java | 2 +
.../org/apache/rocketmq/test/util/MQAdmin.java | 2 +
.../org/apache/rocketmq/test/base/BaseConf.java | 4 +-
.../rocketmq/test/base/IntegrationTestBase.java | 40 +-
.../base/dledger/DLedgerProduceAndConsumeIT.java | 121 ++++
.../broadcast/order/OrderMsgBroadCastIT.java | 5 +
.../rocketmq/test/delay/NormalMsgDelayIT.java | 3 +-
48 files changed, 2444 insertions(+), 201 deletions(-)