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 2020/04/27 03:30:45 UTC
[incubator-iotdb] branch cluster_new updated (9e09726 -> 014b227)
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 9e09726 Merge branch 'master' into cluster_new
add 014b227 [IOTDB-613] Add the ability to persist and maintain currentterm for the raft node (#1094)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/iotdb/cluster/ClientMain.java | 6 +-
.../org/apache/iotdb/cluster/log/HardState.java | 8 +
.../{LogApplier.java => StableEntryManager.java} | 19 +-
.../cluster/log/manage/CommittedEntryManager.java | 22 +-
.../iotdb/cluster/log/manage/DiskLogManager.java | 146 --
.../iotdb/cluster/log/manage/MemoryLogManager.java | 235 ---
.../log/manage/MetaSingleSnapshotLogManager.java | 3 +-
.../log/manage/PartitionedSnapshotLogManager.java | 4 +-
.../iotdb/cluster/log/manage/RaftLogManager.java | 86 +-
.../cluster/log/manage/StableEntryManager.java | 45 -
.../log/manage/UnCommittedEntryManager.java | 18 +-
.../manage/serializable/LogDequeSerializer.java | 79 -
.../log/manage/serializable/LogManagerMeta.java | 22 +-
.../serializable/SyncLogDequeSerializer.java | 87 +-
.../server/handlers/caller/ElectionHandler.java | 3 +-
.../server/handlers/caller/HeartbeatHandler.java | 2 +-
.../server/handlers/caller/LogCatchUpHandler.java | 1 -
.../cluster/server/heartbeat/HeartbeatThread.java | 1 +
.../cluster/server/member/DataGroupMember.java | 3 +
.../cluster/server/member/MetaGroupMember.java | 10 +-
.../iotdb/cluster/server/member/RaftMember.java | 62 +-
.../cluster/utils/nodetool/function/LogView.java | 5 +
.../iotdb/cluster/common/TestLogManager.java | 8 +-
.../iotdb/cluster/common/TestMetaGroupMember.java | 3 +
.../cluster/common/TestPartitionedLogManager.java | 4 +-
.../apache/iotdb/cluster/log/LogParserTest.java | 13 +
.../cluster/log/logtypes/SerializeLogTest.java | 13 +-
.../log/manage/CommittedEntryManagerTest.java | 84 +-
.../cluster/log/manage/DiskLogManagerTest.java | 132 --
.../cluster/log/manage/MemoryLogManagerTest.java | 166 --
.../cluster/log/manage/RaftLogManagerTest.java | 1631 ++++++++++----------
.../log/manage/UnCommittedEntryManagerTest.java | 12 +-
.../serializable/SyncLogDequeSerializerTest.java | 379 +----
.../handlers/caller/HeartbeatHandlerTest.java | 2 +-
.../server/heartbeat/DataHeartbeatThreadTest.java | 19 +-
.../server/heartbeat/HeartbeatThreadTest.java | 17 +-
.../cluster/server/member/DataGroupMemberTest.java | 4 +
.../iotdb/cluster/server/member/MemberTest.java | 2 +-
.../cluster/server/member/MetaGroupMemberTest.java | 3 +
39 files changed, 1203 insertions(+), 2156 deletions(-)
copy cluster/src/main/java/org/apache/iotdb/cluster/log/{LogApplier.java => StableEntryManager.java} (73%)
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/manage/DiskLogManager.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/manage/MemoryLogManager.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/manage/StableEntryManager.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/manage/serializable/LogDequeSerializer.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/manage/DiskLogManagerTest.java
delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/manage/MemoryLogManagerTest.java