[iotdb] branch optimize/ml_memory_control updated: recover 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 efe35bab45 recover log
efe35bab45 is described below

commit efe35bab4537ca635f2f898996dfcbcc000e0e7d
Author: Jinrui.Zhang <xingtan...@gmail.com>
AuthorDate: Fri Sep 30 15:22:18 2022 +0800

    recover log
---
 .../logdispatcher/MultiLeaderMemoryManager.java    | 30 +++++++++++-----------
 1 file changed, 15 insertions(+), 15 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 1690583c94..8968bdeae0 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,30 +34,30 @@ public class MultiLeaderMemoryManager {
   public boolean reserve(long size) {
     synchronized (this) {
       if (size > maxMemorySizeInByte - memorySizeInByte.get()) {
-        //        logger.info(
-        //            "consensus memory limited. required: {}, used: {}, 
total: {}",
-        //            size,
-        //            memorySizeInByte.get(),
-        //            maxMemorySizeInByte);
+        logger.info(
+            "consensus memory limited. required: {}, used: {}, total: {}",
+            size,
+            memorySizeInByte.get(),
+            maxMemorySizeInByte);
         return false;
       }
       memorySizeInByte.addAndGet(size);
     }
-    //    logger.info(
-    //        "{} add {} bytes, total memory size: {} bytes.",
-    //        Thread.currentThread().getName(),
-    //        size,
-    //        memorySizeInByte.get());
+    logger.info(
+        "{} add {} bytes, total memory size: {} bytes.",
+        Thread.currentThread().getName(),
+        size,
+        memorySizeInByte.get());
     return true;
   }
 
   public void free(long size) {
     long currentUsedMemory = memorySizeInByte.addAndGet(-size);
-    //    logger.info(
-    //        "{} free {} bytes, total memory size: {} bytes.",
-    //        Thread.currentThread().getName(),
-    //        size,
-    //        currentUsedMemory);
+    logger.info(
+        "{} free {} bytes, total memory size: {} bytes.",
+        Thread.currentThread().getName(),
+        size,
+        currentUsedMemory);
   }
 
   public void init(long maxMemorySize) {