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 2023/06/15 01:21:37 UTC

[iotdb] branch native_raft updated (194419cccb9 -> fd616d37a7f)

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