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/19 13:27:05 UTC

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

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 ce0161f341 Merge branch 'master' of github.com:Apache/iotdb into jira3188
     add f3c2fe0afb enhance logDispatcher && add clientManager

No new revisions were added by this update.

Summary of changes:
 .../exception/IllegalPeerNumException.java         |   4 +-
 .../multileader/MultiLeaderConsensus.java          |   9 ++
 .../multileader/MultiLeaderServerImpl.java         |  74 ++++++-----
 .../asyncLogAppender/AsyncLogAppender.java         |  39 ------
 .../client/AsyncMultiLeaderServiceClient.java      |  25 ++--
 .../client/MultiLeaderConsensusClientPool.java     |  54 ++++++++
 .../conf/MultiLeaderConsensusConfig.java           |  19 +--
 .../multileader/logdispatcher/LogDispatcher.java   | 138 +++++++++++++++++++++
 .../multileader/service/MultiLeaderRPCService.java |  12 +-
 .../service/MultiLeaderRPCServiceProcessor.java    |   4 +-
 .../multileader/wal/ConsensusReqReader.java        |   3 +
 11 files changed, 281 insertions(+), 100 deletions(-)
 delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/multileader/asyncLogAppender/AsyncLogAppender.java
 copy node-commons/src/main/java/org/apache/iotdb/commons/client/async/AsyncConfigNodeIServiceClient.java => consensus/src/main/java/org/apache/iotdb/consensus/multileader/client/AsyncMultiLeaderServiceClient.java (82%)
 create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/multileader/client/MultiLeaderConsensusClientPool.java
 copy cluster/src/main/java/org/apache/iotdb/cluster/exception/LeaderUnknownException.java => consensus/src/main/java/org/apache/iotdb/consensus/multileader/conf/MultiLeaderConsensusConfig.java (57%)
 create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/LogDispatcher.java