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
The following commit(s) were added to refs/heads/master_performance by this
push:
new fb9dea9 add send log timer
fb9dea9 is described below
commit fb9dea94f078a3c3619146b765e952528e3efc67
Author: LebronAl <[email protected]>
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 ad356fb..9a9eeef 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
@@ -1889,7 +1889,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();