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=bb7d6f71575d47949012b1f815c047ff54b9f565;hb=10ba5a102f9e15a24c3f5a355a44fafadbf2801f;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..bb7d6f7157 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,43 @@ +/* + * 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.NodeRef; +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 +53,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 +89,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 +124,119 @@ 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:")){ + InstanceIdentifier targetInstanceId = InstanceIdentifier.builder(Nodes.class).child(Node.class,targetNode.getKey()).toInstance(); + NodeRef targetNodeRef = new NodeRef(targetInstanceId); + + sendAllGroupStatisticsRequest(targetNodeRef); + + sendAllMeterStatisticsRequest(targetNodeRef); + + sendGroupDescriptionRequest(targetNodeRef); + + sendGroupFeaturesRequest(targetNodeRef); + + sendMeterConfigStatisticsRequest(targetNodeRef); + + sendMeterFeaturesRequest(targetNodeRef); + } + } + } + + private void sendAllGroupStatisticsRequest(NodeRef targetNode){ + + final GetAllGroupStatisticsInputBuilder input = new GetAllGroupStatisticsInputBuilder(); + + input.setNode(targetNode); + input.setNode(targetNode); + + @SuppressWarnings("unused") + Future> response = + groupStatsService.getAllGroupStatistics(input.build()); + } + + private void sendGroupDescriptionRequest(NodeRef targetNode){ + final GetGroupDescriptionInputBuilder input = new GetGroupDescriptionInputBuilder(); + + input.setNode(targetNode); + + @SuppressWarnings("unused") + Future> response = + groupStatsService.getGroupDescription(input.build()); + } + + private void sendGroupFeaturesRequest(NodeRef targetNode){ + + GetGroupFeaturesInputBuilder input = new GetGroupFeaturesInputBuilder(); + + input.setNode(targetNode); + + @SuppressWarnings("unused") + Future> response = + groupStatsService.getGroupFeatures(input.build()); + } + + private void sendAllMeterStatisticsRequest(NodeRef targetNode){ + + GetAllMeterStatisticsInputBuilder input = new GetAllMeterStatisticsInputBuilder(); + + input.setNode(targetNode); + + @SuppressWarnings("unused") + Future> response = + meterStatsService.getAllMeterStatistics(input.build()); + } + + private void sendMeterConfigStatisticsRequest(NodeRef targetNode){ + + GetAllMeterConfigStatisticsInputBuilder input = new GetAllMeterConfigStatisticsInputBuilder(); + + input.setNode(targetNode); + + @SuppressWarnings("unused") + Future> response = + meterStatsService.getAllMeterConfigStatistics(input.build()); + + } + private void sendMeterFeaturesRequest(NodeRef targetNode){ + + GetMeterFeaturesInputBuilder input = new GetMeterFeaturesInputBuilder(); + + input.setNode(targetNode); + + @SuppressWarnings("unused") + 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,12 +245,13 @@ public class StatisticsProvider implements AutoCloseable { if (this.listenerRegistration != null) { this.listenerRegistration.close(); + + this.statisticsRequesterThread.destroy(); } } catch (Throwable e) { throw Exceptions.sneakyThrow(e); } - } }