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%2FStatisticsProvider.java;h=d1ab3515035dfb0b5597c263c5f23ac29656d659;hb=99dc3fe7cc5b5a6540ef674ac4157d37449fafdf;hp=073d43ef60df3d944dda0da6512326267be114e5;hpb=4555aeef5d37c16e36d537c0ed26048ad85cd60f;p=controller.git diff --git a/opendaylight/md-sal/statistics-manager/src/main/java/org/opendaylight/controller/md/statistics/manager/StatisticsProvider.java b/opendaylight/md-sal/statistics-manager/src/main/java/org/opendaylight/controller/md/statistics/manager/StatisticsProvider.java index 073d43ef60..d1ab351503 100644 --- a/opendaylight/md-sal/statistics-manager/src/main/java/org/opendaylight/controller/md/statistics/manager/StatisticsProvider.java +++ b/opendaylight/md-sal/statistics-manager/src/main/java/org/opendaylight/controller/md/statistics/manager/StatisticsProvider.java @@ -1,13 +1,42 @@ +/* + * 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 java.util.List; +import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.ConcurrentMap; +import java.util.concurrent.Future; + import org.eclipse.xtext.xbase.lib.Exceptions; import org.opendaylight.controller.sal.binding.api.NotificationProviderService; import org.opendaylight.controller.sal.binding.api.data.DataModificationTransaction; import org.opendaylight.controller.sal.binding.api.data.DataProviderService; +import org.opendaylight.yang.gen.v1.urn.opendaylight.group.statistics.rev131111.GetAllGroupStatisticsInputBuilder; +import org.opendaylight.yang.gen.v1.urn.opendaylight.group.statistics.rev131111.GetAllGroupStatisticsOutput; +import org.opendaylight.yang.gen.v1.urn.opendaylight.group.statistics.rev131111.GetGroupDescriptionInputBuilder; +import org.opendaylight.yang.gen.v1.urn.opendaylight.group.statistics.rev131111.GetGroupDescriptionOutput; +import org.opendaylight.yang.gen.v1.urn.opendaylight.group.statistics.rev131111.GetGroupFeaturesInputBuilder; +import org.opendaylight.yang.gen.v1.urn.opendaylight.group.statistics.rev131111.GetGroupFeaturesOutput; import org.opendaylight.yang.gen.v1.urn.opendaylight.group.statistics.rev131111.OpendaylightGroupStatisticsService; +import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeId; +import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.Nodes; +import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node; +import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.statistics.rev131111.GetAllMeterConfigStatisticsInputBuilder; +import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.statistics.rev131111.GetAllMeterConfigStatisticsOutput; +import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.statistics.rev131111.GetAllMeterStatisticsInputBuilder; +import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.statistics.rev131111.GetAllMeterStatisticsOutput; +import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.statistics.rev131111.GetMeterFeaturesInputBuilder; +import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.statistics.rev131111.GetMeterFeaturesOutput; import org.opendaylight.yang.gen.v1.urn.opendaylight.meter.statistics.rev131111.OpendaylightMeterStatisticsService; import org.opendaylight.yangtools.concepts.Registration; +import org.opendaylight.yangtools.yang.binding.InstanceIdentifier; import org.opendaylight.yangtools.yang.binding.NotificationListener; +import org.opendaylight.yangtools.yang.common.RpcResult; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -23,6 +52,15 @@ public class StatisticsProvider implements AutoCloseable { private OpendaylightMeterStatisticsService meterStatsService; + private Thread statisticsRequesterThread; + + private final InstanceIdentifier nodesIdentifier = InstanceIdentifier.builder().node(Nodes.class).toInstance(); + + //Local caching of stats + + private final ConcurrentMap statisticsCache = + new ConcurrentHashMap(); + public DataProviderService getDataService() { return this.dps; } @@ -50,10 +88,32 @@ public class StatisticsProvider implements AutoCloseable { this.listenerRegistration = registerNotificationListener; // Get Group/Meter statistics service instance - groupStatsService = StatisticsManagerActivator.getProviderContext().getRpcService(OpendaylightGroupStatisticsService.class); + groupStatsService = StatisticsManagerActivator.getProviderContext(). + getRpcService(OpendaylightGroupStatisticsService.class); - meterStatsService = StatisticsManagerActivator.getProviderContext().getRpcService(OpendaylightMeterStatisticsService.class); + meterStatsService = StatisticsManagerActivator.getProviderContext(). + getRpcService(OpendaylightMeterStatisticsService.class); + + statisticsRequesterThread = new Thread( new Runnable(){ + @Override + public void run() { + while(true){ + try { + statsRequestSender(); + + Thread.sleep(5000); + }catch (Exception e){ + spLogger.error("Exception occurred while sending stats request : {}",e); + } + } + } + }); + + spLogger.debug("Statistics requester thread started with timer interval : {}",5000); + + statisticsRequesterThread.start(); + spLogger.info("Statistics Provider started."); } @@ -63,6 +123,109 @@ public class StatisticsProvider implements AutoCloseable { return dps.beginTransaction(); } + private void statsRequestSender(){ + + //Need to call API to receive all the nodes connected to controller. + List targetNodes = getAllConnectedNodes(); + + if(targetNodes == null) + return; + + for (Node targetNode : targetNodes){ + spLogger.info("Send request for stats collection to node : {})",targetNode.getId()); + + //We need to add check, so see if groups/meters are supported + //by the target node. Below check doesn't look good. + if(targetNode.getId().getValue().contains("openflow:")){ + sendAllGroupStatisticsRequest(targetNode); + + sendAllMeterStatisticsRequest(targetNode); + + sendGroupDescriptionRequest(targetNode); + + sendGroupFeaturesRequest(targetNode); + + sendMeterConfigStatisticsRequest(targetNode); + + sendMeterFeaturesRequest(targetNode); + } + } + } + + private void sendAllGroupStatisticsRequest(Node targetNode){ + + final GetAllGroupStatisticsInputBuilder input = new GetAllGroupStatisticsInputBuilder(); + + input.setId(targetNode.getId()); + + Future> response = + groupStatsService.getAllGroupStatistics(input.build()); + } + + private void sendGroupDescriptionRequest(Node targetNode){ + final GetGroupDescriptionInputBuilder input = new GetGroupDescriptionInputBuilder(); + + input.setId(targetNode.getId()); + + Future> response = + groupStatsService.getGroupDescription(input.build()); + } + + private void sendGroupFeaturesRequest(Node targetNode){ + + GetGroupFeaturesInputBuilder input = new GetGroupFeaturesInputBuilder(); + + input.setId(targetNode.getId()); + + Future> response = + groupStatsService.getGroupFeatures(input.build()); + } + + private void sendAllMeterStatisticsRequest(Node targetNode){ + + GetAllMeterStatisticsInputBuilder input = new GetAllMeterStatisticsInputBuilder(); + + input.setId(targetNode.getId()); + + Future> response = + meterStatsService.getAllMeterStatistics(input.build()); + } + + private void sendMeterConfigStatisticsRequest(Node targetNode){ + + GetAllMeterConfigStatisticsInputBuilder input = new GetAllMeterConfigStatisticsInputBuilder(); + + input.setId(targetNode.getId()); + + Future> response = + meterStatsService.getAllMeterConfigStatistics(input.build()); + + } + private void sendMeterFeaturesRequest(Node targetNode){ + + GetMeterFeaturesInputBuilder input = new GetMeterFeaturesInputBuilder(); + + input.setId(targetNode.getId()); + + Future> response = + meterStatsService.getMeterFeatures(input.build()); + } + + public ConcurrentMap getStatisticsCache() { + return statisticsCache; + } + + private List getAllConnectedNodes(){ + + Nodes nodes = (Nodes) dps.readOperationalData(nodesIdentifier); + if(nodes == null) + return null; + + spLogger.info("Number of connected nodes : {}",nodes.getNode().size()); + return nodes.getNode(); + } + + @SuppressWarnings("deprecation") @Override public void close(){ @@ -71,6 +234,8 @@ public class StatisticsProvider implements AutoCloseable { if (this.listenerRegistration != null) { this.listenerRegistration.close(); + + this.statisticsRequesterThread.destroy(); } } catch (Throwable e) {