Bug 1484 - StatisticManager performance improvement refactoring

[controller.git] / opendaylight / md-sal / statistics-manager / src / main / java / org / opendaylight / controller / md / statistics / manager / StatisticsListener.java

diff --git a/opendaylight/md-sal/statistics-manager/src/main/java/org/opendaylight/controller/md/statistics/manager/StatisticsListener.java b/opendaylight/md-sal/statistics-manager/src/main/java/org/opendaylight/controller/md/statistics/manager/StatisticsListener.java
deleted file mode 100644 (file)
index a06f7ef..0000000
--- a/opendaylight/md-sal/statistics-manager/src/main/java/org/opendaylight/controller/md/statistics/manager/StatisticsListener.java
+++ /dev/null
@@ -1,144 +0,0 @@
-/*
- * Copyright IBM Corporation, 2013.  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.controller.md.statistics.manager;
-
-import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.statistics.rev130819.AggregateFlowStatisticsUpdate;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.statistics.rev130819.FlowsStatisticsUpdate;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.statistics.rev130819.OpendaylightFlowStatisticsListener;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.table.statistics.rev131215.FlowTableStatisticsUpdate;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.table.statistics.rev131215.OpendaylightFlowTableStatisticsListener;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.group.statistics.rev131111.GroupDescStatsUpdated;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.group.statistics.rev131111.GroupFeaturesUpdated;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.group.statistics.rev131111.GroupStatisticsUpdated;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.group.statistics.rev131111.OpendaylightGroupStatisticsListener;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.statistics.rev131111.MeterConfigStatsUpdated;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.statistics.rev131111.MeterFeaturesUpdated;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.statistics.rev131111.MeterStatisticsUpdated;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.statistics.rev131111.OpendaylightMeterStatisticsListener;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.NodeConnectorStatisticsUpdate;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.OpendaylightPortStatisticsListener;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.OpendaylightQueueStatisticsListener;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.QueueStatisticsUpdate;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * This class is responsible for listening for statistics update notifications and
- * routing them to the appropriate NodeStatisticsHandler.
-
- * TODO: Need to add error message listener and clean-up the associated tx id
- * if it exists in the tx-id cache.
- * @author vishnoianil
- */
-public class StatisticsListener implements OpendaylightGroupStatisticsListener,
-        OpendaylightMeterStatisticsListener,
-        OpendaylightFlowStatisticsListener,
-        OpendaylightPortStatisticsListener,
-        OpendaylightFlowTableStatisticsListener,
-        OpendaylightQueueStatisticsListener{
-
-    private final static Logger sucLogger = LoggerFactory.getLogger(StatisticsListener.class);
-    private final StatisticsProvider statisticsManager;
-
-    /**
-     * default ctor
-     * @param manager
-     */
-    public StatisticsListener(final StatisticsProvider manager){
-        this.statisticsManager = manager;
-    }
-
-    @Override
-    public void onMeterConfigStatsUpdated(final MeterConfigStatsUpdated notification) {
-        final NodeStatisticsHandler handler = this.statisticsManager.getStatisticsHandler(notification.getId());
-        if (handler != null) {
-            handler.updateMeterConfigStats(notification, notification.getMeterConfigStats());
-        }
-    }
-
-    @Override
-    public void onMeterStatisticsUpdated(MeterStatisticsUpdated notification) {
-        final NodeStatisticsHandler handler = this.statisticsManager.getStatisticsHandler(notification.getId());
-        if (handler != null) {
-            handler.updateMeterStats(notification, notification.getMeterStats());
-        }
-    }
-
-    @Override
-    public void onGroupDescStatsUpdated(GroupDescStatsUpdated notification) {
-        final NodeStatisticsHandler handler = statisticsManager.getStatisticsHandler(notification.getId());
-        if (handler != null) {
-            handler.updateGroupDescStats(notification, notification.getGroupDescStats());
-        }
-    }
-
-    @Override
-    public void onGroupStatisticsUpdated(GroupStatisticsUpdated notification) {
-        final NodeStatisticsHandler handler = statisticsManager.getStatisticsHandler(notification.getId());
-        if (handler != null) {
-            handler.updateGroupStats(notification, notification.getGroupStats());
-        }
-    }
-
-    @Override
-    public void onMeterFeaturesUpdated(MeterFeaturesUpdated notification) {
-        final NodeStatisticsHandler sna = this.statisticsManager.getStatisticsHandler(notification.getId());
-        if (sna != null) {
-            sna.updateMeterFeatures(notification);
-        }
-    }
-
-    @Override
-    public void onGroupFeaturesUpdated(GroupFeaturesUpdated notification) {
-        final NodeStatisticsHandler sna = this.statisticsManager.getStatisticsHandler(notification.getId());
-        if (sna != null) {
-            sna.updateGroupFeatures(notification);
-        }
-    }
-
-    @Override
-    public void onFlowsStatisticsUpdate(final FlowsStatisticsUpdate notification) {
-        sucLogger.debug("Received flow stats update : {}",notification.toString());
-        final NodeStatisticsHandler sna = this.statisticsManager.getStatisticsHandler(notification.getId());
-        if (sna != null) {
-            sna.updateFlowStats(notification, notification.getFlowAndStatisticsMapList());
-        }
-    }
-
-    @Override
-    public void onAggregateFlowStatisticsUpdate(AggregateFlowStatisticsUpdate notification) {
-        final NodeStatisticsHandler handler = this.statisticsManager.getStatisticsHandler(notification.getId());
-        if (handler != null) {
-            handler.updateAggregateFlowStats(notification, notification);
-        }
-    }
-
-    @Override
-    public void onNodeConnectorStatisticsUpdate(NodeConnectorStatisticsUpdate notification) {
-        final NodeStatisticsHandler handler = this.statisticsManager.getStatisticsHandler(notification.getId());
-        if (handler != null) {
-            handler.updateNodeConnectorStats(notification, notification.getNodeConnectorStatisticsAndPortNumberMap());
-        }
-    }
-
-    @Override
-    public void onFlowTableStatisticsUpdate(FlowTableStatisticsUpdate notification) {
-        final NodeStatisticsHandler handler = this.statisticsManager.getStatisticsHandler(notification.getId());
-        if (handler != null) {
-            handler.updateFlowTableStats(notification, notification.getFlowTableAndStatisticsMap());
-        }
-    }
-
-    @Override
-    public void onQueueStatisticsUpdate(QueueStatisticsUpdate notification) {
-        final NodeStatisticsHandler handler = this.statisticsManager.getStatisticsHandler(notification.getId());
-        if (handler != null) {
-            handler.updateQueueStats(notification, notification.getQueueIdAndStatisticsMap());
-        }
-    }
-}