[iotdb] branch multileader_restart_test updated: add more metrics

[xingtanzjr]

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

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


The following commit(s) were added to refs/heads/multileader_restart_test by 
this push:
     new 2b2f1203ed add more metrics
2b2f1203ed is described below

commit 2b2f1203ed6ea1f323e7e76602f5d4924a8c7093
Author: Jinrui.Zhang <xingtan...@gmail.com>
AuthorDate: Fri Jul 8 15:29:24 2022 +0800

    add more metrics
---
 .../consensus/multileader/client/DispatchLogHandler.java     | 12 ++++++------
 .../consensus/multileader/logdispatcher/LogDispatcher.java   |  6 ++++++
 2 files changed, 12 insertions(+), 6 deletions(-)

diff --git 
a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/client/DispatchLogHandler.java
 
b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/client/DispatchLogHandler.java
index 64b2adcfa9..e3d22b67da 100644
--- 
a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/client/DispatchLogHandler.java
+++ 
b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/client/DispatchLogHandler.java
@@ -48,6 +48,11 @@ public class DispatchLogHandler implements 
AsyncMethodCallback<TSyncLogRes> {
 
   @Override
   public void onComplete(TSyncLogRes response) {
+    StepTracker.trace(
+        "dispatcherSendBatch-" + this.thread.getPeer().getEndpoint().getIp(),
+        10,
+        startTime,
+        System.nanoTime());
     if (response.getStatus().size() == 1
         && response.getStatus().get(0).getCode()
             == TSStatusCode.INTERNAL_SERVER_ERROR.getStatusCode()) {
@@ -61,14 +66,9 @@ public class DispatchLogHandler implements 
AsyncMethodCallback<TSyncLogRes> {
     } else {
       thread.getSyncStatus().removeBatch(batch);
     }
-    StepTracker.trace(
-        "dispatcherSendBatch-" + this.thread.getPeer().getEndpoint().getIp(),
-        100,
-        startTime,
-        System.nanoTime());
     StepTracker.trace(
         "dispatcherBatchSize-" + this.thread.getPeer().getEndpoint().getIp(),
-        100,
+        10,
         0,
         this.batch.getBatches().size() * 1000_000L);
   }
diff --git 
a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/LogDispatcher.java
 
b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/LogDispatcher.java
index 811396c196..fbd1945536 100644
--- 
a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/LogDispatcher.java
+++ 
b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/LogDispatcher.java
@@ -186,6 +186,7 @@ public class LogDispatcher {
       try {
         PendingBatch batch;
         while (!Thread.interrupted() && !stopped) {
+          long prepareStartTime = System.nanoTime();
           while ((batch = getBatch()).isEmpty()) {
             // we may block here if there is no requests in the queue
             long startTime = System.nanoTime();
@@ -203,6 +204,11 @@ public class LogDispatcher {
           // we may block here if the synchronization pipeline is full
           syncStatus.addNextBatch(batch);
           // sends batch asynchronously and migrates the retry logic into the 
callback handler
+          StepTracker.trace(
+              "prepareBatch-" + this.getPeer().getEndpoint().getIp(),
+              10,
+              prepareStartTime,
+              System.nanoTime());
           sendBatchAsync(batch, new DispatchLogHandler(this, batch));
         }
       } catch (InterruptedException e) {