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

abhay 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 f9bfc90fb RANGER-4069: Add performance tracing instrumentation to Tag 
Enricher
f9bfc90fb is described below

commit f9bfc90fb53f06a752f4190e20be337ed70ec657
Author: Abhay Kulkarni <[email protected]>
AuthorDate: Sat Feb 4 11:25:16 2023 -0800

    RANGER-4069: Add performance tracing instrumentation to Tag Enricher
---
 .../apache/ranger/plugin/contextenricher/RangerTagEnricher.java  | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git 
a/agents-common/src/main/java/org/apache/ranger/plugin/contextenricher/RangerTagEnricher.java
 
b/agents-common/src/main/java/org/apache/ranger/plugin/contextenricher/RangerTagEnricher.java
index da06e4161..bbea4cec6 100644
--- 
a/agents-common/src/main/java/org/apache/ranger/plugin/contextenricher/RangerTagEnricher.java
+++ 
b/agents-common/src/main/java/org/apache/ranger/plugin/contextenricher/RangerTagEnricher.java
@@ -75,6 +75,7 @@ public class RangerTagEnricher extends 
RangerAbstractContextEnricher {
        private static final Logger PERF_CONTEXTENRICHER_INIT_LOG = 
RangerPerfTracer.getPerfLogger("contextenricher.init");
        private static final Logger PERF_TRIE_OP_LOG              = 
RangerPerfTracer.getPerfLogger("resourcetrie.retrieval");
        private static final Logger PERF_SET_SERVICETAGS_LOG      = 
RangerPerfTracer.getPerfLogger("tagenricher.setservicetags");
+       private static final Logger PERF_SERVICETAGS_RETRIEVAL_LOG = 
RangerPerfTracer.getPerfLogger("tagenricher.tags.retrieval");
 
 
        private static final String TAG_REFRESHER_POLLINGINTERVAL_OPTION = 
"tagRefresherPollingInterval";
@@ -665,6 +666,12 @@ public class RangerTagEnricher extends 
RangerAbstractContextEnricher {
 
                RangerAccessResource resource = request.getResource();
 
+               RangerPerfTracer perf = null;
+
+               if 
(RangerPerfTracer.isPerfTraceEnabled(PERF_SERVICETAGS_RETRIEVAL_LOG)) {
+                       perf = 
RangerPerfTracer.getPerfTracer(PERF_SERVICETAGS_RETRIEVAL_LOG, 
"RangerTagEnricher.findMatchingTags=" + resource.getAsString() + ")");
+               }
+
                if ((resource == null || resource.getKeys() == null || 
resource.getKeys().isEmpty()) && request.isAccessTypeAny()) {
                        ret = 
enrichedServiceTags.getTagsForEmptyResourceAndAnyAccess();
                } else {
@@ -698,6 +705,8 @@ public class RangerTagEnricher extends 
RangerAbstractContextEnricher {
                        }
                }
 
+               RangerPerfTracer.logAlways(perf);
+
                if (CollectionUtils.isEmpty(ret)) {
                        if (LOG.isDebugEnabled()) {
                                LOG.debug("RangerTagEnricher.findMatchingTags(" 
+ resource + ") - No tags Found ");

Reply via email to