This is an automated email from the ASF dual-hosted git repository.
sammichen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/master by this push:
new 541a0dc HDDS-5640. Add scm ratis metrics (#2553)
541a0dc is described below
commit 541a0dc032939bc01f7ef01783dff5de5b0a5674
Author: Nibiru <[email protected]>
AuthorDate: Mon Aug 23 11:04:59 2021 +0800
HDDS-5640. Add scm ratis metrics (#2553)
Co-authored-by: xushaohong <[email protected]>
---
.../org/apache/hadoop/hdds/scm/server/StorageContainerManager.java | 6 ++++++
1 file changed, 6 insertions(+)
diff --git
a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/server/StorageContainerManager.java
b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/server/StorageContainerManager.java
index 9516f36..a37ec8a 100644
---
a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/server/StorageContainerManager.java
+++
b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/server/StorageContainerManager.java
@@ -65,6 +65,7 @@ import
org.apache.hadoop.hdds.security.x509.certificate.authority.PKIProfiles.De
import
org.apache.hadoop.hdds.security.x509.certificate.client.SCMCertificateClient;
import org.apache.hadoop.hdds.security.x509.certificate.utils.CertificateCodec;
import org.apache.hadoop.hdds.server.events.FixedThreadPoolExecutor;
+import org.apache.hadoop.hdds.server.http.RatisDropwizardExports;
import org.apache.hadoop.hdds.utils.HAUtils;
import org.apache.hadoop.hdds.utils.HddsServerUtil;
import org.apache.hadoop.hdds.scm.ScmConfig;
@@ -157,6 +158,7 @@ import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.UUID;
+import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
import java.util.concurrent.TimeUnit;
@@ -248,6 +250,8 @@ public final class StorageContainerManager extends
ServiceRuntimeInfoImpl
private SCMContainerMetrics scmContainerMetrics;
private SCMContainerPlacementMetrics placementMetrics;
private MetricsSystem ms;
+ private final Map<String, RatisDropwizardExports> ratisMetricsMap =
+ new ConcurrentHashMap<>();
private String primaryScmNodeId;
/**
@@ -1259,6 +1263,8 @@ public final class StorageContainerManager extends
ServiceRuntimeInfoImpl
ms = HddsServerUtil
.initializeMetrics(configuration, "StorageContainerManager");
+ RatisDropwizardExports.registerRatisMetricReporters(ratisMetricsMap);
+
commandWatcherLeaseManager.start();
getClientProtocolServer().start();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
