You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@rocketmq.apache.org by ji...@apache.org on 2022/07/04 08:45:24 UTC

[rocketmq] branch 5.0.0-beta-dledger-controller updated (505cb2af9 -> e5c538a25)

This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a change to branch 5.0.0-beta-dledger-controller
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


    from 505cb2af9 Merge branch '5.0.0-beta' into 5.0.0-beta-dledger-controller
     add e5c538a25 When the size of syncStateSet is less than minInSyncReplicas, put message returns PutMessageStatus.IN_SYNC_REPLICAS_NOT_ENOUGH

No new revisions were added by this update.

Summary of changes:
 .../java/org/apache/rocketmq/store/CommitLog.java  | 37 ++++++++++---------
 .../rocketmq/store/config/MessageStoreConfig.java  |  4 ++-
 .../apache/rocketmq/store/ha/DefaultHAService.java |  4 +--
 .../rocketmq/store/ha/GroupTransferService.java    |  1 +
 .../org/apache/rocketmq/store/ha/HAService.java    |  5 +--
 .../store/ha/autoswitch/AutoSwitchHAService.java   | 41 ++++++++++++++++++++++
 .../org/apache/rocketmq/store/ha/HAServerTest.java | 10 +++---
 .../test/container/PullMultipleReplicasIT.java     |  2 +-
 .../rocketmq/test/container/SlaveBrokerIT.java     |  2 +-
 9 files changed, 75 insertions(+), 31 deletions(-)