aboutsummaryrefslogtreecommitdiffstats
path: root/ECOMP-PDP-REST/src/main/java/org/openecomp/policy/pdp/rest/jmx
diff options
context:
space:
mode:
authorGuo Ruijing <ruijing.guo@intel.com>2017-07-31 08:47:35 +0000
committerPamela Dragosh <pdragosh@research.att.com>2017-07-31 15:51:10 -0400
commit073cc188efe9abb4c010cf674e34e2cf46ef1c52 (patch)
tree155c23fbdf3a838ecb5f4183fc3bb6b09aac41eb /ECOMP-PDP-REST/src/main/java/org/openecomp/policy/pdp/rest/jmx
parent4ca818fdfb9b807562166800a086b413593d6894 (diff)
[POLICY-73] replace openecomp for policy-engine
Change-Id: I54072f6bcd388c0e05562614ee89b4ae7ad67004 Signed-off-by: Guo Ruijing <ruijing.guo@intel.com> Signed-off-by: Pamela Dragosh <pdragosh@research.att.com>
Diffstat (limited to 'ECOMP-PDP-REST/src/main/java/org/openecomp/policy/pdp/rest/jmx')
-rw-r--r--ECOMP-PDP-REST/src/main/java/org/openecomp/policy/pdp/rest/jmx/PdpRestMBeanListener.java85
-rw-r--r--ECOMP-PDP-REST/src/main/java/org/openecomp/policy/pdp/rest/jmx/PdpRestMonitor.java162
-rw-r--r--ECOMP-PDP-REST/src/main/java/org/openecomp/policy/pdp/rest/jmx/PdpRestMonitorMBean.java40
3 files changed, 0 insertions, 287 deletions
diff --git a/ECOMP-PDP-REST/src/main/java/org/openecomp/policy/pdp/rest/jmx/PdpRestMBeanListener.java b/ECOMP-PDP-REST/src/main/java/org/openecomp/policy/pdp/rest/jmx/PdpRestMBeanListener.java
deleted file mode 100644
index c56ddba9a..000000000
--- a/ECOMP-PDP-REST/src/main/java/org/openecomp/policy/pdp/rest/jmx/PdpRestMBeanListener.java
+++ /dev/null
@@ -1,85 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * ECOMP-PDP-REST
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package org.openecomp.policy.pdp.rest.jmx;
-
-import java.lang.management.ManagementFactory;
-
-import javax.management.MBeanServer;
-import javax.management.ObjectName;
-import javax.servlet.ServletContextEvent;
-import javax.servlet.ServletContextListener;
-import javax.servlet.annotation.WebListener;
-
-import org.openecomp.policy.common.logging.flexlogger.FlexLogger;
-import org.openecomp.policy.common.logging.flexlogger.Logger;
-import org.openecomp.policy.xacml.api.XACMLErrorConstants;
-/**
- *
- *
- */
-
-@WebListener
-public class PdpRestMBeanListener implements ServletContextListener {
- private static final String JMX_OBJECT_NAME = "PdpRest:type=PdpRestMonitor";
- private static final Logger LOGGER = FlexLogger.getLogger(PdpRestMBeanListener.class);
-
- private ObjectName objectName;
-
- @Override
- public void contextInitialized(ServletContextEvent contextEvent) {
- if (LOGGER.isInfoEnabled())
- LOGGER.info("Registering.");
-
- final MBeanServer server = ManagementFactory.getPlatformMBeanServer();
- try {
- objectName = new ObjectName(JMX_OBJECT_NAME);
- server.registerMBean(PdpRestMonitor.getSingleton(), objectName);
- LOGGER.info("MBean registered: " + objectName);
- } catch (Exception e) {
-
- LOGGER.warn(e.getMessage(), e);
-
- LOGGER.warn(XACMLErrorConstants.ERROR_SYSTEM_ERROR + "Unable to Register " +e.getMessage(), e);
-
- }
- }
- // mark
- @Override
- public void contextDestroyed(ServletContextEvent contextEvent) {
- if (LOGGER.isInfoEnabled())
- LOGGER.info("Unregistering");
- final MBeanServer server = ManagementFactory.getPlatformMBeanServer();
- try {
- objectName = new ObjectName(JMX_OBJECT_NAME);
- server.unregisterMBean(objectName);
- if (LOGGER.isInfoEnabled())
- LOGGER.info("MBean unregistered: " + objectName);
- } catch (Exception e) {
-
- LOGGER.warn(e.getMessage(), e);
-
- LOGGER.warn(XACMLErrorConstants.ERROR_SYSTEM_ERROR + "Unable to Destroy Context" +e.getMessage(), e);
-
- }
- }
-
-}
-
diff --git a/ECOMP-PDP-REST/src/main/java/org/openecomp/policy/pdp/rest/jmx/PdpRestMonitor.java b/ECOMP-PDP-REST/src/main/java/org/openecomp/policy/pdp/rest/jmx/PdpRestMonitor.java
deleted file mode 100644
index 1c088b24e..000000000
--- a/ECOMP-PDP-REST/src/main/java/org/openecomp/policy/pdp/rest/jmx/PdpRestMonitor.java
+++ /dev/null
@@ -1,162 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * ECOMP-PDP-REST
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package org.openecomp.policy.pdp.rest.jmx;
-
-import java.util.HashMap;
-import java.util.Map;
-import java.util.concurrent.atomic.AtomicLong;
-
-import org.openecomp.policy.xacml.util.MetricsUtil.AvgLatency;
-import org.openecomp.policy.xacml.util.MetricsUtil.MaxLatency;
-import org.openecomp.policy.xacml.util.MetricsUtil.MinLatency;
-
-public class PdpRestMonitor implements PdpRestMonitorMBean {
- private static PdpRestMonitor singleton = new PdpRestMonitor();
-
- private final AtomicLong pdpEvaluationAttempts = new AtomicLong();
- private final AtomicLong pdpEvaluationSuccesses = new AtomicLong();
- private final AtomicLong pdpEvaluationNA = new AtomicLong();
- private final AtomicLong pdpEvaluationPermit = new AtomicLong();
- private final AtomicLong pdpEvaluationDeny = new AtomicLong();
- private final Map<String, Integer> policyCount = new HashMap<>();
-
- private final MinLatency pdpEngineDecisionMinLatency = new MinLatency();
- private final MaxLatency pdpEngineDecisionMaxLatency = new MaxLatency();
- private final AvgLatency pdpEngineDecisionAvgLatency = new AvgLatency();
-
- private volatile long lastDecisionLatency = 0;
-
- @Override
- public long getPdpEvaluationAttempts() {
- return pdpEvaluationAttempts.longValue();
- }
- @Override
- public long getPdpEvaluationPermit() {
- return pdpEvaluationPermit.longValue();
- }
- @Override
- public long getPdpEvaluationDeny() {
- return pdpEvaluationDeny.longValue();
- }
- @Override
- public long getPdpEvaluationSuccesses() {
- return pdpEvaluationSuccesses.longValue();
- }
-
- @Override
- public long getpdpEvaluationNA() {
- return pdpEvaluationNA.longValue();
- }
- @Override
- public long getLastDecisionLatency() {
- return lastDecisionLatency;
- }
-
- /**
- * @return the pdpEngineDecisionMinLatency
- */
- @Override
- public long getPdpEngineDecisionMinLatency() {
- return pdpEngineDecisionMinLatency.min();
- }
-
- /**
- * @return the pdpEngineDecisionMaxLatency
- */
- @Override
- public long getPdpEngineDecisionMaxLatency() {
- return pdpEngineDecisionMaxLatency.max();
- }
-
- /**
- * @return the pdpEngineDecisionAvgLatency
- */
- @Override
- public long getPdpEngineDecisionAvgLatency() {
- return pdpEngineDecisionAvgLatency.avg();
- }
-
- @Override
- public synchronized void resetLatency() {
- this.lastDecisionLatency = 0;
- this.pdpEngineDecisionMinLatency.reset();
- this.pdpEngineDecisionMaxLatency.reset();
- this.pdpEngineDecisionAvgLatency.reset();
- }
-
- @Override
- public synchronized void resetCounters() {
- this.pdpEvaluationAttempts.set(0);
- this.pdpEvaluationSuccesses.set(0);
- this.pdpEvaluationNA.set(0);
- this.policyCount.clear();
- }
-
- public void pdpEvaluationAttempts() {
- pdpEvaluationAttempts.incrementAndGet();
- }
-
- public void pdpEvaluationSuccess() {
- pdpEvaluationSuccesses.incrementAndGet();
- }
-
- public void pdpEvaluationNA(){
- pdpEvaluationNA.incrementAndGet();
- }
- public void pdpEvaluationPermit(){
- pdpEvaluationPermit.incrementAndGet();
- }
- public void pdpEvaluationDeny(){
- pdpEvaluationDeny.incrementAndGet();
- }
-
- public synchronized void computeLatency(long latency) {
- this.lastDecisionLatency = latency;
- this.pdpEngineDecisionMinLatency.compute(latency);
- this.pdpEngineDecisionMaxLatency.compute(latency);
- this.pdpEngineDecisionAvgLatency.compute(latency);
- }
-
- public void policyCountAdd(String policyID, Integer count){
- int countValue = count;
- if (policyCount.containsKey(policyID)){
- countValue = countValue + policyCount.get(policyID);
- }
- policyCount.put(policyID, countValue);
- }
- public Map<String, Integer> getpolicyMap() {
- return policyCount;
- }
- public Integer getpolicyCount(String policyID) {
- if (policyCount.containsKey(policyID)){
- return policyCount.get(policyID);
- }
- return null;
- }
-
- public static PdpRestMonitor getSingleton() {
- return singleton;
- }
- public static void setSingleton(PdpRestMonitor singleton) {
- PdpRestMonitor.singleton = singleton;
- }
-
-}
diff --git a/ECOMP-PDP-REST/src/main/java/org/openecomp/policy/pdp/rest/jmx/PdpRestMonitorMBean.java b/ECOMP-PDP-REST/src/main/java/org/openecomp/policy/pdp/rest/jmx/PdpRestMonitorMBean.java
deleted file mode 100644
index e7db09d24..000000000
--- a/ECOMP-PDP-REST/src/main/java/org/openecomp/policy/pdp/rest/jmx/PdpRestMonitorMBean.java
+++ /dev/null
@@ -1,40 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * ECOMP-PDP-REST
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package org.openecomp.policy.pdp.rest.jmx;
-
-import java.util.Map;
-
-public interface PdpRestMonitorMBean {
- public long getPdpEvaluationAttempts();
- public long getPdpEvaluationSuccesses();
- public long getLastDecisionLatency();
- public long getPdpEngineDecisionMinLatency();
- public long getPdpEngineDecisionMaxLatency();
- public long getPdpEngineDecisionAvgLatency();
- public Integer getpolicyCount(String policyID);
-
- public void resetLatency();
- public void resetCounters();
- public long getpdpEvaluationNA();
- public long getPdpEvaluationPermit();
- public long getPdpEvaluationDeny();
- public Map<String, Integer> getpolicyMap();
-}