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/12 07:05:59 UTC
[incubator-iotdb] branch cluster_new updated (6ef9975 -> 2ea221c)
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 6ef9975 fix log manager
add 2ea221c add comments and refinements
No new revisions were added by this update.
Summary of changes:
.../resources/conf/iotdb-cluster.properties | 3 +
.../java/org/apache/iotdb/cluster/log/Log.java | 7 +
.../org/apache/iotdb/cluster/log/LogApplier.java | 3 +
.../org/apache/iotdb/cluster/log/LogManager.java | 26 ++--
.../org/apache/iotdb/cluster/log/LogParser.java | 6 +-
.../org/apache/iotdb/cluster/log/Snapshot.java | 28 +++-
.../apache/iotdb/cluster/log/meta/AddNodeLog.java | 14 +-
.../iotdb/cluster/server/HeartBeatThread.java | 52 +++++---
.../{CatchUpTask.java => LogCatchUpTask.java} | 20 ++-
.../iotdb/cluster/server/MetaClusterServer.java | 71 ++++++----
.../apache/iotdb/cluster/server/NodeStatus.java | 29 ----
.../apache/iotdb/cluster/server/RaftServer.java | 146 ++++++++++++---------
.../handlers/{ => caller}/AppendEntryHandler.java | 14 +-
.../handlers/{ => caller}/CatchUpHandler.java | 18 ++-
.../handlers/{ => caller}/ElectionHandler.java | 12 +-
.../handlers/{ => caller}/HeartBeatHandler.java | 9 +-
.../handlers/{ => caller}/JoinClusterHandler.java | 7 +-
.../server/handlers/{ => caller}/package-info.java | 2 +-
.../handlers/forwarder/ForwardAddNodeHandler.java | 40 +++---
19 files changed, 310 insertions(+), 197 deletions(-)
rename cluster/src/main/java/org/apache/iotdb/cluster/server/{CatchUpTask.java => LogCatchUpTask.java} (79%)
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/NodeStatus.java
rename cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/{ => caller}/AppendEntryHandler.java (88%)
rename cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/{ => caller}/CatchUpHandler.java (85%)
rename cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/{ => caller}/ElectionHandler.java (90%)
rename cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/{ => caller}/HeartBeatHandler.java (94%)
rename cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/{ => caller}/JoinClusterHandler.java (89%)
rename cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/{ => caller}/package-info.java (93%)
copy tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/basic/BinaryFilter.java => cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/forwarder/ForwardAddNodeHandler.java (53%)
mode change 100755 => 100644