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

Posted to commits@iotdb.apache.org by ta...@apache.org on 2022/05/21 13:33:10 UTC

[iotdb] branch jira3188 updated (f3c2fe0afb -> d9e337875e)

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