[incubator-iotdb] branch feature_async_close_tsfile updated: add log to print the size of closing processors if the size >5

[hx...@apache.org]

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

hxd pushed a commit to branch feature_async_close_tsfile
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git


The following commit(s) were added to refs/heads/feature_async_close_tsfile by this push:
     new c4e792b  add log to print the size of closing processors if the size >5
c4e792b is described below

commit c4e792b543c7edc590a4ec57afd23d2d19c0d6e3
Author: xiangdong huang <sa...@gmail.com>
AuthorDate: Thu Jun 6 10:17:29 2019 +0800

    add log to print the size of closing processors if the size >5
---
 .../org/apache/iotdb/db/engine/filenode/CopyOnWriteLinkedList.java | 4 ++++
 .../java/org/apache/iotdb/db/engine/filenode/FileNodeManager.java  | 7 +++++++
 2 files changed, 11 insertions(+)

diff --git a/iotdb/src/main/java/org/apache/iotdb/db/engine/filenode/CopyOnWriteLinkedList.java b/iotdb/src/main/java/org/apache/iotdb/db/engine/filenode/CopyOnWriteLinkedList.java
index 5021336..a412525 100644
--- a/iotdb/src/main/java/org/apache/iotdb/db/engine/filenode/CopyOnWriteLinkedList.java
+++ b/iotdb/src/main/java/org/apache/iotdb/db/engine/filenode/CopyOnWriteLinkedList.java
@@ -54,4 +54,8 @@ public class CopyOnWriteLinkedList<T> {
     }
     return readCopy;
   }
+
+  public int size() {
+    return data.size();
+  }
 }
diff --git a/iotdb/src/main/java/org/apache/iotdb/db/engine/filenode/FileNodeManager.java b/iotdb/src/main/java/org/apache/iotdb/db/engine/filenode/FileNodeManager.java
index 96aced1..b93bfe1 100644
--- a/iotdb/src/main/java/org/apache/iotdb/db/engine/filenode/FileNodeManager.java
+++ b/iotdb/src/main/java/org/apache/iotdb/db/engine/filenode/FileNodeManager.java
@@ -128,6 +128,13 @@ public class FileNodeManager implements IStatistic, IService {
     }
 
     closedProcessorCleaner.scheduleWithFixedDelay(()->{
+      int size = 0;
+      for (FileNodeProcessor fileNodeProcessor : processorMap.values()) {
+        size += fileNodeProcessor.getClosingBufferWriteProcessor().size();
+      }
+      if (size > 5) {
+        LOGGER.info("Current closing processor number is {}", size);
+      }
       for (FileNodeProcessor fileNodeProcessor : processorMap.values()) {
         Iterator<BufferWriteProcessor> iterator =
             fileNodeProcessor.getClosingBufferWriteProcessor().iterator();