X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fstatistics-manager%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fmd%2Fstatistics%2Fmanager%2FNodeStatisticsHandler.java;h=db216237d01f7f8fe40523c2c62c6b6ecb88abde;hb=48814d6a264b8f13e5db1422336d9ef25cb05fa9;hp=7d9cc7ecbd789634e96ddbf32153e534d594dbc4;hpb=e3b0eb3bd7f61ab9f54a61d8b8e2d37685262e2c;p=controller.git diff --git a/opendaylight/md-sal/statistics-manager/src/main/java/org/opendaylight/controller/md/statistics/manager/NodeStatisticsHandler.java b/opendaylight/md-sal/statistics-manager/src/main/java/org/opendaylight/controller/md/statistics/manager/NodeStatisticsHandler.java index 7d9cc7ecbd..db216237d0 100644 --- a/opendaylight/md-sal/statistics-manager/src/main/java/org/opendaylight/controller/md/statistics/manager/NodeStatisticsHandler.java +++ b/opendaylight/md-sal/statistics-manager/src/main/java/org/opendaylight/controller/md/statistics/manager/NodeStatisticsHandler.java @@ -103,7 +103,7 @@ public final class NodeStatisticsHandler implements AutoCloseable, FlowCapableCo final OpendaylightGroupStatisticsService groupStatsService, final OpendaylightMeterStatisticsService meterStatsService, final OpendaylightPortStatisticsService portStatsService, - final OpendaylightQueueStatisticsService queueStatsService, + final OpendaylightQueueStatisticsService queueStatsService, final StatisticsRequestScheduler srScheduler) { this.dps = Preconditions.checkNotNull(dps); this.targetNodeKey = Preconditions.checkNotNull(nodeKey); @@ -274,20 +274,20 @@ public final class NodeStatisticsHandler implements AutoCloseable, FlowCapableCo this.srScheduler.addRequestToSchedulerQueue(flowTableStats); this.srScheduler.addRequestToSchedulerQueue(flowStats); - + this.srScheduler.addRequestToSchedulerQueue(nodeConnectorStats); - + this.srScheduler.addRequestToSchedulerQueue(groupStats); - + this.srScheduler.addRequestToSchedulerQueue(groupDescStats); - + this.srScheduler.addRequestToSchedulerQueue(meterStats); - + this.srScheduler.addRequestToSchedulerQueue(meterConfigStats); - + this.srScheduler.addRequestToSchedulerQueue(queueStats); } - + public synchronized void start(final Timer timer) { flowStats.start(dps); groupDescStats.start(dps); @@ -313,7 +313,7 @@ public final class NodeStatisticsHandler implements AutoCloseable, FlowCapableCo meterStats.close(); queueStats.close(); - //Clean up queued statistics request from scheduler queue + //Clean up queued statistics request from scheduler queue srScheduler.removeRequestsFromSchedulerQueue(this.getNodeRef()); logger.debug("Statistics handler for {} shut down", targetNodeKey.getId());