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/05/29 06:34:50 UTC
[iotdb] branch native_raft updated: record compression time
This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a commit to branch native_raft
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/native_raft by this push:
new bf7baa5b28c record compression time
bf7baa5b28c is described below
commit bf7baa5b28c0f4090aa053c45a8912f9674fde8a
Author: Tian Jiang <jt...@163.com>
AuthorDate: Mon May 29 14:37:38 2023 +0800
record compression time
---
.../consensus/natraft/protocol/log/dispatch/DispatcherThread.java | 2 ++
.../main/java/org/apache/iotdb/consensus/natraft/utils/Timer.java | 6 ++++++
2 files changed, 8 insertions(+)
diff --git a/consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/log/dispatch/DispatcherThread.java b/consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/log/dispatch/DispatcherThread.java
index 1c929ece745..79b4b159e3a 100644
--- a/consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/log/dispatch/DispatcherThread.java
+++ b/consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/log/dispatch/DispatcherThread.java
@@ -206,8 +206,10 @@ class DispatcherThread extends DynamicThread {
request.setLeaderId(logDispatcher.member.getThisNode().getNodeId());
request.setLeaderCommit(logDispatcher.member.getLogManager().getCommitLogIndex());
request.setTerm(logDispatcher.member.getStatus().getTerm().get());
+ long startTime = Statistic.RAFT_SENDER_COMPRESS_LOG.getOperationStartTime();
request.setEntryBytes(
LogUtils.compressEntries(logList, compressor, request, batchLogBuffer, compressionBuffer));
+ Statistic.RAFT_SENDER_COMPRESS_LOG.calOperationCostTimeFromStart(startTime);
request.setCompressionType((byte) compressor.getType().ordinal());
return request;
}
diff --git a/consensus/src/main/java/org/apache/iotdb/consensus/natraft/utils/Timer.java b/consensus/src/main/java/org/apache/iotdb/consensus/natraft/utils/Timer.java
index f05424d7066..642b7896275 100644
--- a/consensus/src/main/java/org/apache/iotdb/consensus/natraft/utils/Timer.java
+++ b/consensus/src/main/java/org/apache/iotdb/consensus/natraft/utils/Timer.java
@@ -103,6 +103,12 @@ public class Timer {
TIME_SCALE,
true,
DATA_GROUP_MEMBER_LOCAL_EXECUTION),
+ RAFT_SENDER_COMPRESS_LOG(
+ RAFT_MEMBER_SENDER,
+ "compress entries in dispatcher",
+ TIME_SCALE,
+ true,
+ DATA_GROUP_MEMBER_LOCAL_EXECUTION),
RAFT_SENDER_SEND_LOG(
RAFT_MEMBER_SENDER,
"send log to a follower",