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%)