rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dongefore...@apache.org
Subject [rocketmq] 01/01: Merge pull request #1046 from apache/store_with_dledger
Date Thu, 07 Mar 2019 08:46:38 GMT
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 <zhendongliu92@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(-)



Mime
View raw message