You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ne...@apache.org on 2022/07/22 08:47:40 UTC
[iotdb] branch master updated: update metric of confignode's number (#6754)
This is an automated email from the ASF dual-hosted git repository.
neuyilan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new e429f89e7a update metric of confignode's number (#6754)
e429f89e7a is described below
commit e429f89e7aa3e9e273573af84a3b867937769372
Author: 23931017wu <71...@users.noreply.github.com>
AuthorDate: Fri Jul 22 16:47:35 2022 +0800
update metric of confignode's number (#6754)
---
.../org/apache/iotdb/confignode/persistence/NodeInfo.java | 13 ++++++++++++-
1 file changed, 12 insertions(+), 1 deletion(-)
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/NodeInfo.java b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/NodeInfo.java
index f62ac14fe9..4e78dd3e67 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/persistence/NodeInfo.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/persistence/NodeInfo.java
@@ -110,7 +110,7 @@ public class NodeInfo implements SnapshotProcessor {
Metric.CONFIG_NODE.toString(),
MetricLevel.CORE,
registeredConfigNodes,
- o -> getRegisteredDataNodeCount(),
+ o -> getRegisteredConfigNodeCount(),
Tag.NAME.toString(),
"online");
MetricsService.getInstance()
@@ -250,6 +250,17 @@ public class NodeInfo implements SnapshotProcessor {
return result;
}
+ /** Return the number of registered ConfigNodes */
+ public int getRegisteredConfigNodeCount() {
+ int result;
+ configNodeInfoReadWriteLock.readLock().lock();
+ try {
+ result = registeredConfigNodes.size();
+ } finally {
+ configNodeInfoReadWriteLock.readLock().unlock();
+ }
+ return result;
+ }
/** Return the number of total cpu cores in online DataNodes */
public int getTotalCpuCoreCount() {
int result = 0;