[iotdb] branch iot_consensus updated: monitor the reactor epoll thread

[marklau99]

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

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


The following commit(s) were added to refs/heads/iot_consensus by this push:
     new e9f928f8bbe monitor the reactor epoll thread
e9f928f8bbe is described below

commit e9f928f8bbee28b0fd42ee141fe75a4099954b48
Author: Liu Xuxin <liuxu...@outlook.com>
AuthorDate: Wed Jun 21 16:04:06 2023 +0800

    monitor the reactor epoll thread
---
 .../main/java/org/apache/iotdb/commons/concurrent/ThreadName.java  | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git 
a/node-commons/src/main/java/org/apache/iotdb/commons/concurrent/ThreadName.java
 
b/node-commons/src/main/java/org/apache/iotdb/commons/concurrent/ThreadName.java
index 51783d4c281..90d447ca6be 100644
--- 
a/node-commons/src/main/java/org/apache/iotdb/commons/concurrent/ThreadName.java
+++ 
b/node-commons/src/main/java/org/apache/iotdb/commons/concurrent/ThreadName.java
@@ -18,6 +18,9 @@
  */
 package org.apache.iotdb.commons.concurrent;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 import java.util.Arrays;
 import java.util.HashSet;
 import java.util.Set;
@@ -132,6 +135,7 @@ public enum ThreadName {
   SYSTEM_SCHEDULE_METRICS("SystemScheduleMetrics"),
   RESOURCE_CONTROL_DISK_STATISTIC("ResourceControl-DataRegionDiskStatistics"),
   PROMETHEUS_REACTOR_HTTP_NIO("reactor-http-nio"),
+  PROMETHEUS_REACTOR_HTTP_EPOLL("reactor-http-epoll"),
   PROMETHEUS_BOUNDED_ELASTIC("boundedElastic-evictor"),
   // -------------------------- Other --------------------------
   TTL_CHECK("TTL-CHECK"),
@@ -146,6 +150,7 @@ public enum ThreadName {
   UNKOWN("UNKNOWN");
 
   private final String name;
+  private static final Logger log = LoggerFactory.getLogger(ThreadName.class);
   private static Set<ThreadName> queryThreadNames =
       new HashSet<>(
           Arrays.asList(
@@ -257,6 +262,7 @@ public enum ThreadName {
               SYSTEM_SCHEDULE_METRICS,
               RESOURCE_CONTROL_DISK_STATISTIC,
               PROMETHEUS_REACTOR_HTTP_NIO,
+              PROMETHEUS_REACTOR_HTTP_EPOLL,
               PROMETHEUS_BOUNDED_ELASTIC));
   private static Set<ThreadName> otherThreadNames =
       new HashSet<>(
@@ -351,6 +357,7 @@ public enum ThreadName {
         }
       }
     }
+    log.info("Unknown thread name: {}", givenThreadName);
     return ThreadName.UNKOWN;
   }
 }