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/06/29 02:49:34 UTC
[rocketmq] branch 5.0.0-beta-dledger-controller updated (c58a022bc -> 555026676)
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 c58a022bc Remove debug log output
add 555026676 1.Rename BrokerRegisterRequestHeader to RegisterBrokerToControllerRequestHeader 2.Make ChangeToMaster do all things even if it is already master
No new revisions were added by this update.
Summary of changes:
.../broker/controller/ReplicasManager.java | 31 +++++++++++-----------
.../apache/rocketmq/broker/out/BrokerOuterAPI.java | 10 +++----
...> RegisterBrokerToControllerRequestHeader.java} | 6 ++---
... RegisterBrokerToControllerResponseHeader.java} | 4 +--
.../org/apache/rocketmq/controller/Controller.java | 4 +--
.../controller/impl/DLedgerController.java | 4 +--
.../impl/manager/ReplicasInfoManager.java | 10 +++----
.../processor/ControllerRequestProcessor.java | 8 +++---
.../impl/controller/ControllerManagerTest.java | 14 +++++-----
.../controller/impl/DLedgerControllerTest.java | 22 +++++++--------
.../impl/manager/ReplicasInfoManagerTest.java | 12 ++++-----
.../processor/ControllerRequestProcessor.java | 4 +--
.../ha/autoswitch/AutoSwitchHAConnection.java | 1 -
.../store/ha/autoswitch/AutoSwitchHAService.java | 1 -
14 files changed, 64 insertions(+), 67 deletions(-)
rename common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/controller/{BrokerRegisterRequestHeader.java => RegisterBrokerToControllerRequestHeader.java} (90%)
rename common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/controller/{BrokerRegisterResponseHeader.java => RegisterBrokerToControllerResponseHeader.java} (94%)