[iotdb] branch expr_vgraft updated: record commit time

[jiangtian]

This is an automated email from the ASF dual-hosted git repository.

jiangtian pushed a commit to branch expr_vgraft
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/expr_vgraft by this push:
     new 84a7805722 record commit time
84a7805722 is described below

commit 84a780572219816b19bb1866d614b23359b17544
Author: Tian Jiang <jt2594...@163.com>
AuthorDate: Fri Oct 7 16:41:41 2022 +0800

    record commit time
---
 cluster/src/main/java/org/apache/iotdb/cluster/log/VotingLogList.java | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/cluster/src/main/java/org/apache/iotdb/cluster/log/VotingLogList.java 
b/cluster/src/main/java/org/apache/iotdb/cluster/log/VotingLogList.java
index 9b180d9073..fde20d18bf 100644
--- a/cluster/src/main/java/org/apache/iotdb/cluster/log/VotingLogList.java
+++ b/cluster/src/main/java/org/apache/iotdb/cluster/log/VotingLogList.java
@@ -37,6 +37,8 @@ import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
 
+import static 
org.apache.iotdb.cluster.server.monitor.Timer.Statistic.RAFT_SENDER_COMMIT_LOG_IN_MANAGER;
+
 public class VotingLogList {
 
   private static final Logger logger = 
LoggerFactory.getLogger(VotingLogList.class);
@@ -56,11 +58,13 @@ public class VotingLogList {
           long newCommitIndex = computeNewCommitIndex();
           if (newCommitIndex > member.getLogManager().getCommitLogIndex()) {
             synchronized (member.getLogManager()) {
+              long operationStartTime = 
RAFT_SENDER_COMMIT_LOG_IN_MANAGER.getOperationStartTime();
               try {
                 member.getLogManager().commitTo(newCommitIndex);
               } catch (LogExecutionException e) {
                 logger.error("Fail to commit {}", newCommitIndex, e);
               }
+              
RAFT_SENDER_COMMIT_LOG_IN_MANAGER.calOperationCostTimeFromStart(operationStartTime);
             }
           }
         },