[iotdb] branch ml_0729_test updated: add counter for put request into queue

[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 9bd347b968 add counter for put request into queue
9bd347b968 is described below

commit 9bd347b9688684e9a03e0d70990d68a02f453a14
Author: Jinrui.Zhang <xi...@gmail.com>
AuthorDate: Tue Aug 2 21:44:10 2022 +0800

    add counter for put request into queue
---
 .../apache/iotdb/consensus/multileader/logdispatcher/LogDispatcher.java | 2 ++
 1 file changed, 2 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 ba32bb8f79..13b2191484 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
@@ -118,6 +118,8 @@ public class LogDispatcher {
                 "{}: Log queue of {} is full, ignore the log to this node",
                 impl.getThisNode().getGroupId(),
                 thread.getPeer());
+          } else {
+            thread.countQueue();
           }
         });
   }