You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ta...@apache.org on 2022/01/14 06:19:31 UTC
[iotdb] 06/13: add send log timer
This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a commit to branch master_performance
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 1d2431b6d65e1b114df0503482bc29b0fa1e0230
Author: LebronAl <TX...@gmail.com>
AuthorDate: Mon Nov 29 12:07:41 2021 +0800
add send log timer
---
.../main/java/org/apache/iotdb/cluster/server/member/RaftMember.java | 2 ++
1 file changed, 2 insertions(+)
diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMember.java b/cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMember.java
index 1e71fed..05ce76c 100644
--- a/cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMember.java
+++ b/cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMember.java
@@ -1898,7 +1898,9 @@ public abstract class RaftMember implements RaftMemberMBean {
getAppendNodeEntryHandler(log, voteCounter, node, leaderShipStale, newLeaderTerm, peer);
try {
logger.debug("{} sending a log to {}: {}", name, node, log);
+ long startTime = Timer.Statistic.RAFT_SENDER_SEND_LOG.getOperationStartTime();
long result = client.appendEntry(request);
+ Timer.Statistic.RAFT_SENDER_SEND_LOG.calOperationCostTimeFromStart(startTime);
handler.onComplete(result);
} catch (TException e) {
client.getInputProtocol().getTransport().close();