This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a change to branch jira3188
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from f3c2fe0afb enhance logDispatcher && add clientManager
add d9e337875e almost finish
No new revisions were added by this update.
Summary of changes:
.../common/request/IndexedConsensusRequest.java | 17 ++--
.../consensus/multileader/IndexController.java | 2 +-
.../multileader/MultiLeaderServerImpl.java | 16 ++-
.../client/AsyncMultiLeaderServiceClient.java | 3 +-
.../multileader/client/DispatchLogHandler.java | 45 ++++----
.../conf/MultiLeaderConsensusConfig.java | 2 +
.../multileader/logdispatcher/LogDispatcher.java | 113 ++++++++++++++++++++-
.../multileader/logdispatcher/PendingBatch.java | 54 ++++++----
.../multileader/logdispatcher/SyncStatus.java | 64 ++++++++++++
.../service/MultiLeaderRPCServiceProcessor.java | 6 +-
.../statemachine/DataRegionStateMachine.java | 16 ++-
.../src/main/thrift/mutlileader.thrift | 12 ++-
12 files changed, 282 insertions(+), 68 deletions(-)
copy
cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/GetChildNodeNextLevelHandler.java
=>
consensus/src/main/java/org/apache/iotdb/consensus/multileader/client/DispatchLogHandler.java
(50%)
copy
schema-engine-rocksdb/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/mnode/RMNodeValueType.java
=>
consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/PendingBatch.java
(51%)
create mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/SyncStatus.java
