[iotdb] branch multileader_restart_test updated: add more metrics tag

[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 7eeda77b10 add more metrics tag
7eeda77b10 is described below

commit 7eeda77b10227df83b558868e889250c174b8a70
Author: Jinrui.Zhang <xingtan...@gmail.com>
AuthorDate: Thu Jul 7 20:55:54 2022 +0800

    add more metrics tag
---
 .../consensus/multileader/client/DispatchLogHandler.java     | 12 ++++++++++--
 .../multileader/service/MultiLeaderRPCServiceProcessor.java  |  2 +-
 2 files changed, 11 insertions(+), 3 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 d10263b540..64b2adcfa9 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
@@ -61,8 +61,16 @@ public class DispatchLogHandler implements 
AsyncMethodCallback<TSyncLogRes> {
     } else {
       thread.getSyncStatus().removeBatch(batch);
     }
-    StepTracker.trace("dispatcherSendBatch", 10, startTime, System.nanoTime());
-    StepTracker.trace("dispatcherBatchSize", 10, 0, 
this.batch.getBatches().size() * 1000L);
+    StepTracker.trace(
+        "dispatcherSendBatch-" + this.thread.getPeer().getEndpoint().getIp(),
+        100,
+        startTime,
+        System.nanoTime());
+    StepTracker.trace(
+        "dispatcherBatchSize-" + this.thread.getPeer().getEndpoint().getIp(),
+        100,
+        0,
+        this.batch.getBatches().size() * 1000_000L);
   }
 
   @Override
diff --git 
a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/service/MultiLeaderRPCServiceProcessor.java
 
b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/service/MultiLeaderRPCServiceProcessor.java
index c8fe9fbfe2..8c54743097 100644
--- 
a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/service/MultiLeaderRPCServiceProcessor.java
+++ 
b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/service/MultiLeaderRPCServiceProcessor.java
@@ -85,7 +85,7 @@ public class MultiLeaderRPCServiceProcessor implements 
MultiLeaderConsensusIServ
     } catch (Exception e) {
       resultHandler.onError(e);
     } finally {
-      StepTracker.trace("ProcessSyncLog", 10, startTime, System.nanoTime());
+      StepTracker.trace("ProcessSyncLog", 100, startTime, System.nanoTime());
     }
   }