[iotdb] branch optimize/ml_memory_control updated: add log

[xingtanzjr]

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

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


The following commit(s) were added to refs/heads/optimize/ml_memory_control by 
this push:
     new ab3f736a2b add log
ab3f736a2b is described below

commit ab3f736a2b3372485237826b82a2088b7e5c5632
Author: Jinrui.Zhang <xingtan...@gmail.com>
AuthorDate: Fri Sep 30 11:21:17 2022 +0800

    add log
---
 .../logdispatcher/MultiLeaderMemoryManager.java            | 14 ++++++++++----
 1 file changed, 10 insertions(+), 4 deletions(-)

diff --git 
a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/MultiLeaderMemoryManager.java
 
b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/MultiLeaderMemoryManager.java
index 83553a4a7c..84d3eabd4b 100644
--- 
a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/MultiLeaderMemoryManager.java
+++ 
b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/MultiLeaderMemoryManager.java
@@ -34,11 +34,16 @@ public class MultiLeaderMemoryManager {
   public boolean reserve(long size) {
     synchronized (this) {
       if (memorySizeInByte.get() < maxMemorySizeInByte - size) {
+        logger.info(
+            "consensus memory limited. required: {}, used: {}, total: {}",
+            size,
+            memorySizeInByte.get(),
+            maxMemorySizeInByte);
         return false;
       }
       memorySizeInByte.addAndGet(size);
     }
-    logger.debug(
+    logger.info(
         "{} add {} bytes, total memory size: {} bytes.",
         Thread.currentThread().getName(),
         size,
@@ -47,11 +52,12 @@ public class MultiLeaderMemoryManager {
   }
 
   public void free(long size) {
-    logger.debug(
-        "{} add {} bytes, total memory size: {} bytes.",
+    long currentUsedMemory = memorySizeInByte.addAndGet(-size);
+    logger.info(
+        "{} free {} bytes, total memory size: {} bytes.",
         Thread.currentThread().getName(),
         size,
-        memorySizeInByte.addAndGet(-size));
+        currentUsedMemory);
   }
 
   public void init(long maxMemorySize) {