This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch native_raft
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 194419cccb9 add cursor based dispatcher
add fd616d37a7f add min dispatcher thread num config refactor log manager
lock refactor log serialization fix nocompressor
No new revisions were added by this update.
Summary of changes:
.../consensus/natraft/protocol/RaftConfig.java | 32 ++++--
.../consensus/natraft/protocol/RaftMember.java | 20 ++--
.../protocol/heartbeat/HeartbeatReqHandler.java | 4 +-
.../protocol/heartbeat/HeartbeatThread.java | 8 +-
.../consensus/natraft/protocol/log/Entry.java | 58 ++---------
.../natraft/protocol/log/EntrySerialization.java | 108 +++++++++++++++++++++
.../protocol/log/appender/BlockingLogAppender.java | 4 +-
.../log/dispatch/CursorBasedDispatcherGroup.java | 4 +-
.../protocol/log/dispatch/DispatcherGroup.java | 7 +-
.../protocol/log/dispatch/LogDispatcher.java | 9 +-
.../log/dispatch/QueueBasedDispatcherGroup.java | 12 +--
.../log/dispatch/QueueBasedDispatcherThread.java | 44 +++++++--
.../manager/DirectorySnapshotRaftLogManager.java | 4 +-
.../protocol/log/manager/RaftLogManager.java | 56 +++++++----
.../log/sequencing/SynchronousSequencer.java | 13 ++-
.../client/property/ClientPoolProperty.java | 4 +-
.../iotdb/consensus/natraft/utils/Timer.java | 4 +
.../apache/iotdb/tsfile/compress/ICompressor.java | 11 ++-
.../iotdb/tsfile/compress/IUnCompressor.java | 4 +-
19 files changed, 277 insertions(+), 129 deletions(-)
create mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/log/EntrySerialization.java
