You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2019/11/11 07:17:31 UTC
[incubator-iotdb] branch cluster_new updated (8a6389a -> c4720fd)
This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch cluster_new
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from 8a6389a refactor package structure
add c4720fd support adding new nodes
No new revisions were added by this update.
Summary of changes:
cluster/src/assembly/resources/conf/iotdb-env.bat | 67 -----
cluster/src/assembly/resources/conf/iotdb-env.sh | 146 -----------
.../sbin/{start-node.bat => add-node.bat} | 8 +-
.../resources/sbin/{start-node.sh => add-node.sh} | 6 +-
cluster/src/assembly/resources/sbin/start-node.bat | 6 +-
cluster/src/assembly/resources/sbin/start-node.sh | 4 +-
.../java/org/apache/iotdb/cluster/ClusterMain.java | 5 +-
.../org/apache/iotdb/cluster/log/LogManager.java | 5 +
.../org/apache/iotdb/cluster/log/LogParser.java | 6 +
.../apache/iotdb/cluster/log/MemoryLogManager.java | 9 +
.../apache/iotdb/cluster/log/meta/AddNodeLog.java | 10 +-
.../apache/iotdb/cluster/server/CatchUpTask.java | 107 ++++++++
.../server/{handlers => }/HeartBeatThread.java | 78 +++---
.../iotdb/cluster/server/MetaClusterServer.java | 225 +++++++++++++++--
.../apache/iotdb/cluster/server/RaftServer.java | 274 ++++++++++-----------
.../server/handlers/AppendEntryHandler.java | 6 +-
.../cluster/server/handlers/CatchUpHandler.java | 104 ++++++++
.../cluster/server/handlers/ElectionHandler.java | 10 +-
.../cluster/server/handlers/HeartBeatHandler.java | 149 +----------
.../server/handlers/JoinClusterHandler.java | 68 +++++
.../handlers/package-info.java} | 8 +-
service-rpc/src/main/thrift/cluster.thrift | 3 +-
22 files changed, 702 insertions(+), 602 deletions(-)
delete mode 100644 cluster/src/assembly/resources/conf/iotdb-env.bat
delete mode 100755 cluster/src/assembly/resources/conf/iotdb-env.sh
copy cluster/src/assembly/resources/sbin/{start-node.bat => add-node.bat} (94%)
copy cluster/src/assembly/resources/sbin/{start-node.sh => add-node.sh} (95%)
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/CatchUpTask.java
rename cluster/src/main/java/org/apache/iotdb/cluster/server/{handlers => }/HeartBeatThread.java (69%)
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/CatchUpHandler.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/JoinClusterHandler.java
copy cluster/src/main/java/org/apache/iotdb/cluster/{log/LogApplier.java => server/handlers/package-info.java} (87%)