[iotdb] branch ml_0729_test updated: add count for queue usage

[xi...@apache.org]

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

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


The following commit(s) were added to refs/heads/ml_0729_test by this push:
     new 5bf98344ae add count for queue usage
5bf98344ae is described below

commit 5bf98344ae3d2d7b6ee2038dc2cfc40d548839eb
Author: Jinrui.Zhang <xi...@gmail.com>
AuthorDate: Tue Aug 2 21:34:26 2022 +0800

    add count for queue usage
---
 .../iotdb/consensus/multileader/logdispatcher/LogDispatcher.java | 9 +++++++++
 1 file changed, 9 insertions(+)

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 ef667cefd0..ba32bb8f79 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
@@ -140,6 +140,7 @@ public class LogDispatcher {
 
     private ConsensusReqReader.ReqIterator walEntryiterator;
     private long iteratorIndex = 1;
+    private long queueCount = 0;
 
     public LogDispatcherThread(Peer peer, MultiLeaderConfig config) {
       this.peer = peer;
@@ -169,6 +170,14 @@ public class LogDispatcher {
       return config;
     }
 
+    public void countQueue() {
+      queueCount++;
+      logger.info(
+          String.format(
+              "DataRegion[%s]->%s: put request to queue: %d",
+              peer.getGroupId().getId(), peer.getEndpoint().ip, queueCount));
+    }
+
     public BlockingQueue<IndexedConsensusRequest> getPendingRequest() {
       return pendingRequest;
     }