2 * Copyright IBM Corporation, 2013. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
8 package org.opendaylight.controller.md.statistics.manager;
10 import org.opendaylight.controller.sal.binding.api.data.DataModificationTransaction;
11 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNodeConnector;
12 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.transaction.rev131103.TransactionId;
13 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.queues.Queue;
14 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.queues.QueueBuilder;
15 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.queues.QueueKey;
16 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.queue.rev130925.QueueId;
17 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorId;
18 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.node.NodeConnector;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.node.NodeConnectorKey;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.FlowCapableNodeConnectorQueueStatisticsData;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.FlowCapableNodeConnectorQueueStatisticsDataBuilder;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.GetAllQueuesStatisticsFromAllPortsInputBuilder;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.GetQueueStatisticsFromGivenPortInputBuilder;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.OpendaylightQueueStatisticsService;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.flow.capable.node.connector.queue.statistics.FlowCapableNodeConnectorQueueStatisticsBuilder;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.queue.statistics.rev131216.queue.id.and.statistics.map.QueueIdAndStatisticsMap;
27 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
28 import org.slf4j.Logger;
29 import org.slf4j.LoggerFactory;
31 import com.google.common.base.Preconditions;
32 import com.google.common.util.concurrent.ListenableFuture;
34 final class QueueStatsTracker extends AbstractStatsTracker<QueueIdAndStatisticsMap, QueueStatsEntry> {
35 private static final Logger logger = LoggerFactory.getLogger(QueueStatsTracker.class);
36 private final OpendaylightQueueStatisticsService queueStatsService;
38 QueueStatsTracker(OpendaylightQueueStatisticsService queueStatsService, final FlowCapableContext context, long lifetimeNanos) {
39 super(context, lifetimeNanos);
40 this.queueStatsService = Preconditions.checkNotNull(queueStatsService);
44 protected void cleanupSingleStat(DataModificationTransaction trans, QueueStatsEntry item) {
45 InstanceIdentifier<?> queueRef
46 = getNodeIdentifierBuilder().child(NodeConnector.class, new NodeConnectorKey(item.getNodeConnectorId()))
47 .augmentation(FlowCapableNodeConnector.class)
48 .child(Queue.class, new QueueKey(item.getQueueId()))
49 .augmentation(FlowCapableNodeConnectorQueueStatisticsData.class).build();
50 trans.removeOperationalData(queueRef);
54 protected QueueStatsEntry updateSingleStat(DataModificationTransaction trans, QueueIdAndStatisticsMap item) {
56 QueueStatsEntry queueEntry = new QueueStatsEntry(item.getNodeConnectorId(), item.getQueueId());
58 FlowCapableNodeConnectorQueueStatisticsDataBuilder queueStatisticsDataBuilder = new FlowCapableNodeConnectorQueueStatisticsDataBuilder();
60 FlowCapableNodeConnectorQueueStatisticsBuilder queueStatisticsBuilder = new FlowCapableNodeConnectorQueueStatisticsBuilder();
62 queueStatisticsBuilder.fieldsFrom(item);
64 queueStatisticsDataBuilder.setFlowCapableNodeConnectorQueueStatistics(queueStatisticsBuilder.build());
66 InstanceIdentifier<Queue> queueRef = getNodeIdentifierBuilder().child(NodeConnector.class, new NodeConnectorKey(item.getNodeConnectorId()))
67 .augmentation(FlowCapableNodeConnector.class)
68 .child(Queue.class, new QueueKey(item.getQueueId())).toInstance();
70 QueueBuilder queueBuilder = new QueueBuilder();
71 FlowCapableNodeConnectorQueueStatisticsData qsd = queueStatisticsDataBuilder.build();
72 queueBuilder.addAugmentation(FlowCapableNodeConnectorQueueStatisticsData.class, qsd);
73 queueBuilder.setKey(new QueueKey(item.getQueueId()));
75 logger.debug("Augmenting queue statistics {} of queue {} to port {}",
78 item.getNodeConnectorId());
80 trans.putOperationalData(queueRef, queueBuilder.build());
84 public ListenableFuture<TransactionId> request() {
85 GetAllQueuesStatisticsFromAllPortsInputBuilder input = new GetAllQueuesStatisticsFromAllPortsInputBuilder();
86 input.setNode(getNodeRef());
88 return requestHelper(queueStatsService.getAllQueuesStatisticsFromAllPorts(input.build()));
91 public ListenableFuture<TransactionId> request(NodeConnectorId nodeConnectorId, QueueId queueId) {
92 GetQueueStatisticsFromGivenPortInputBuilder input = new GetQueueStatisticsFromGivenPortInputBuilder();
94 input.setNode(getNodeRef());
95 input.setNodeConnectorId(nodeConnectorId);
96 input.setQueueId(queueId);
98 return requestHelper(queueStatsService.getQueueStatisticsFromGivenPort(input.build()));