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

abhi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ranger.git


The following commit(s) were added to refs/heads/master by this push:
     new 8b1d10863 RANGER-5211 : KMS Metric collection thread safety check 
should not parse config every time (#575)
8b1d10863 is described below

commit 8b1d10863488425c7bf87540deb875413a5ff68c
Author: Vikas Kumar <talktovikas...@gmail.com>
AuthorDate: Thu May 15 12:25:32 2025 +0530

    RANGER-5211 : KMS Metric collection thread safety check should not parse 
config every time (#575)
---
 .../main/java/org/apache/hadoop/crypto/key/kms/server/KMSWebApp.java  | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/kms/src/main/java/org/apache/hadoop/crypto/key/kms/server/KMSWebApp.java 
b/kms/src/main/java/org/apache/hadoop/crypto/key/kms/server/KMSWebApp.java
index f1880043b..06d865a8a 100755
--- a/kms/src/main/java/org/apache/hadoop/crypto/key/kms/server/KMSWebApp.java
+++ b/kms/src/main/java/org/apache/hadoop/crypto/key/kms/server/KMSWebApp.java
@@ -78,6 +78,7 @@ public class KMSWebApp implements ServletContextListener {
     private static KeyProviderCryptoExtension keyProviderCryptoExtension;
     private static KMSMetricsCollector        kmsMetricsCollector;
 
+    private static boolean isMetricsCollectionThreadsafe;
     private JmxReporter jmxReporter;
 
     public static Configuration getConfiguration() {
@@ -133,7 +134,7 @@ public static KMSAudit getKMSAudit() {
     }
 
     public static boolean isMetricCollectionThreadSafe() {
-        return 
Boolean.parseBoolean(KMSWebApp.getConfiguration().get(HADOOP_KMS_METRIC_COLLECTION_THREADSAFE,
 "false"));
+        return isMetricsCollectionThreadsafe;
     }
 
     public static KMSMetricsCollector getKmsMetricsCollector() {
@@ -181,6 +182,7 @@ public void contextInitialized(ServletContextEvent sce) {
 
             kmsAudit = new KMSAudit(kmsConf);
 
+            isMetricsCollectionThreadsafe = 
Boolean.valueOf(kmsConf.get(HADOOP_KMS_METRIC_COLLECTION_THREADSAFE, "false"));
             KMSMetricWrapper kmsMetricWrapper = 
KMSMetricWrapper.getInstance(isMetricCollectionThreadSafe());
 
             kmsMetricsCollector = kmsMetricWrapper.getKmsMetricsCollector();

Reply via email to