Merge "Integration of fcaps applications"

[vpnservice.git] / fcapsapplication / fcapsapplication-impl / src / main / java / org / opendaylight / vpnservice / fcapsapp / performancecounter / PMAgent.java

diff --git a/fcapsapplication/fcapsapplication-impl/src/main/java/org/opendaylight/vpnservice/fcapsapp/performancecounter/PMAgent.java b/fcapsapplication/fcapsapplication-impl/src/main/java/org/opendaylight/vpnservice/fcapsapp/performancecounter/PMAgent.java
new file mode 100644 (file)
index 0000000..1a50311
--- /dev/null
+++ b/fcapsapplication/fcapsapplication-impl/src/main/java/org/opendaylight/vpnservice/fcapsapp/performancecounter/PMAgent.java
@@ -0,0 +1,93 @@
+/*
+ * Copyright (c) 2016 Ericsson India Global Services Pvt Ltd. and others.  All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
+package org.opendaylight.vpnservice.fcapsapp.performancecounter;
+
+
+import org.opendaylight.vpnservice.fcapsappjmx.NumberOfOFPorts;
+import org.opendaylight.vpnservice.fcapsappjmx.NumberOfOFSwitchCounter;
+import org.opendaylight.vpnservice.fcapsappjmx.PacketInCounter;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import javax.management.*;
+import java.lang.String;
+import java.lang.management.ManagementFactory;
+import java.util.Map;
+
+public class PMAgent {
+    private static Logger s_logger = LoggerFactory.getLogger(PMAgent.class);
+    private MBeanServer mbs = null;
+    private ObjectName switch_mbeanName = null;
+    private ObjectName port_mbeanName = null;
+    private ObjectName pktIn_mbeanName = null;
+    private static final String SWITCH_BEANNAME = "SDNC.PM:type=NumberOfOFSwitchCounter";
+    private static final String PORTS_BEANNAME = "SDNC.PM:type=NumberOfOFPortsCounter";
+    private static final String PKTIN_BEANNAME = "SDNC.PM:type=InjectedPacketInCounter";
+
+    private static NumberOfOFSwitchCounter switchCounterBean = new NumberOfOFSwitchCounter();
+    private static NumberOfOFPorts PortcounterBean = new NumberOfOFPorts();
+    private static PacketInCounter packetInCounter = new PacketInCounter();
+
+    public PMAgent() {
+        mbs = ManagementFactory.getPlatformMBeanServer();
+        try {
+            switch_mbeanName = new ObjectName(SWITCH_BEANNAME);
+            port_mbeanName = new ObjectName(PORTS_BEANNAME);
+            pktIn_mbeanName = new ObjectName(PKTIN_BEANNAME);
+        } catch (MalformedObjectNameException e) {
+            s_logger.error("ObjectName instance creation failed for BEANAME {}", e);
+
+        }
+    }
+
+    public void registerMbeanForEFS() {
+        try {
+            if (!mbs.isRegistered(switch_mbeanName)) {
+                mbs.registerMBean(switchCounterBean, switch_mbeanName);
+                s_logger.info("Registered Mbean {} successfully", switch_mbeanName);
+            }
+
+        } catch (Exception e) {
+            s_logger.error("Registeration failed for Mbean {} :{}", switch_mbeanName, e);
+        }
+    }
+
+    public void registerMbeanForPorts() {
+        try {
+            if (!mbs.isRegistered(port_mbeanName)) {
+                mbs.registerMBean(PortcounterBean, port_mbeanName);
+                s_logger.info("Registered Mbean {} successfully", port_mbeanName);
+            }
+        } catch (Exception e) {
+            s_logger.error("Registeration failed for Mbean {} :{}", port_mbeanName, e);
+        }
+    }
+
+    public void registerMbeanForPacketIn() {
+        try {
+            if (!mbs.isRegistered(pktIn_mbeanName)) {
+                mbs.registerMBean(packetInCounter,pktIn_mbeanName);
+                s_logger.info("Registered Mbean {} successfully",pktIn_mbeanName );
+            }
+        } catch (Exception e) {
+            s_logger.error("Registeration failed for Mbean {} :{}",pktIn_mbeanName , e);
+        }
+    }
+
+    public void connectToPMAgent(Map map) {
+        switchCounterBean.updateCounter(map);
+    }
+
+    public void connectToPMAgentForNOOfPorts(Map map) {
+        PortcounterBean.updateCounter(map);
+    }
+
+    public void sendPacketInCounterUpdate(Map map){
+        packetInCounter.updateCounter(map);
+    }
+}