mirror of
https://github.com/apache/rocketmq.git
synced 2026-08-28 20:09:14 +08:00
1e2a301266
* feat(controller): concurrent protect ReplicasInfoManager#replicaInfoTable and ReplicasInfoManager#syncStateSetInfoTable 1. concurrent protect ReplicasInfoManager#replicaInfoTable and ReplicasInfoManager#syncStateSetInfoTable * docs(controller): make statemachine thread-safe and support timed checking inactive master in each broker-set 1. make statemachine thread-safe 2. support timed checking inactive master in each broker-set * fix(controller): Add some logic when visit the BrokerReplicaInfo to avoid NPE 1. Add some logic when visit the BrokerReplicaInfo to avoid NPE * test(controller): polish some test logic 1. polish some test logic * fix(controller): Revise back the ControllerConfig#controllerStorePath to avoid the Incompatibility problems 1. Revise back the ControllerConfig#controllerStorePath to avoid the Incompatibility problems