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