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=af56a84db5611974d0537d65b914df6acbf4adc0;hb=e640f23d9c37afac9ca51f48e155302bc65327ed;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..af56a84db5 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,39 @@ +/* + * 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.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.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 +49,16 @@ public class StatisticsProvider implements AutoCloseable { private OpendaylightMeterStatisticsService meterStatsService; + private Thread statisticsRequesterThread; + + private final InstanceIdentifier nodesIdentifier = InstanceIdentifier.builder(Nodes.class).toInstance(); + + private final int STATS_THREAD_EXECUTION_TIME= 50000; + //Local caching of stats + + private final ConcurrentMap statisticsCache = + new ConcurrentHashMap(); + public DataProviderService getDataService() { return this.dps; } @@ -50,10 +86,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(STATS_THREAD_EXECUTION_TIME); + }catch (Exception e){ + spLogger.error("Exception occurred while sending stats request : {}",e); + } + } + } + }); + + spLogger.debug("Statistics requester thread started with timer interval : {}",STATS_THREAD_EXECUTION_TIME); + + statisticsRequesterThread.start(); + spLogger.info("Statistics Provider started."); } @@ -63,6 +121,100 @@ 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){ + + + //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:")){ + spLogger.info("Send request for stats collection to node : {})",targetNode.getId()); + InstanceIdentifier targetInstanceId = InstanceIdentifier.builder(Nodes.class).child(Node.class,targetNode.getKey()).toInstance(); + NodeRef targetNodeRef = new NodeRef(targetInstanceId); + + try{ + sendAllGroupStatisticsRequest(targetNodeRef); + Thread.sleep(1000); + sendAllMeterStatisticsRequest(targetNodeRef); + Thread.sleep(1000); + sendGroupDescriptionRequest(targetNodeRef); + Thread.sleep(1000); + sendMeterConfigStatisticsRequest(targetNodeRef); + Thread.sleep(1000); + }catch(Exception e){ + spLogger.error("Exception occured while sending statistics request : {}", e); + } + } + } + } + + 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 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()); + + } + + 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 +223,13 @@ public class StatisticsProvider implements AutoCloseable { if (this.listenerRegistration != null) { this.listenerRegistration.close(); + + this.statisticsRequesterThread.destroy(); } } catch (Throwable e) { throw Exceptions.sneakyThrow(e); } - } }