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.md.sal.common.api.data.DataChangeEvent;
11 import org.opendaylight.controller.sal.binding.api.data.DataBrokerService;
12 import org.opendaylight.controller.sal.binding.api.data.DataModificationTransaction;
13 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNode;
14 import org.opendaylight.yang.gen.v1.urn.opendaylight.group.statistics.rev131111.GetGroupDescriptionInputBuilder;
15 import org.opendaylight.yang.gen.v1.urn.opendaylight.group.statistics.rev131111.NodeGroupDescStats;
16 import org.opendaylight.yang.gen.v1.urn.opendaylight.group.statistics.rev131111.NodeGroupDescStatsBuilder;
17 import org.opendaylight.yang.gen.v1.urn.opendaylight.group.statistics.rev131111.OpendaylightGroupStatisticsService;
18 import org.opendaylight.yang.gen.v1.urn.opendaylight.group.statistics.rev131111.group.desc.GroupDescBuilder;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.group.desc.stats.reply.GroupDescStats;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.groups.Group;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.groups.GroupBuilder;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.groups.GroupKey;
23 import org.opendaylight.yangtools.yang.binding.DataObject;
24 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
25 import org.slf4j.Logger;
26 import org.slf4j.LoggerFactory;
28 final class GroupDescStatsTracker extends AbstractListeningStatsTracker<GroupDescStats, GroupDescStats> {
29 private static final Logger logger = LoggerFactory.getLogger(GroupDescStatsTracker.class);
30 private final OpendaylightGroupStatisticsService groupStatsService;
32 public GroupDescStatsTracker(OpendaylightGroupStatisticsService groupStatsService, final FlowCapableContext context) {
34 this.groupStatsService = groupStatsService;
38 protected GroupDescStats updateSingleStat(DataModificationTransaction trans, GroupDescStats item) {
39 GroupBuilder groupBuilder = new GroupBuilder();
40 GroupKey groupKey = new GroupKey(item.getGroupId());
41 groupBuilder.setKey(groupKey);
43 InstanceIdentifier<Group> groupRef = getNodeIdentifierBuilder()
44 .augmentation(FlowCapableNode.class).child(Group.class,groupKey).build();
46 NodeGroupDescStatsBuilder groupDesc= new NodeGroupDescStatsBuilder();
47 groupDesc.setGroupDesc(new GroupDescBuilder(item).build());
49 //Update augmented data
50 groupBuilder.addAugmentation(NodeGroupDescStats.class, groupDesc.build());
52 trans.putOperationalData(groupRef, groupBuilder.build());
57 protected void cleanupSingleStat(DataModificationTransaction trans, GroupDescStats item) {
58 InstanceIdentifier<NodeGroupDescStats> groupRef = getNodeIdentifierBuilder().augmentation(FlowCapableNode.class)
59 .child(Group.class, new GroupKey(item.getGroupId())).augmentation(NodeGroupDescStats.class).build();
60 trans.removeOperationalData(groupRef);
64 protected InstanceIdentifier<?> listenPath() {
65 return getNodeIdentifierBuilder().augmentation(FlowCapableNode.class).child(Group.class).build();
69 protected String statName() {
70 return "Group Descriptor";
74 public void request() {
75 if (groupStatsService != null) {
76 final GetGroupDescriptionInputBuilder input = new GetGroupDescriptionInputBuilder();
77 input.setNode(getNodeRef());
79 requestHelper(groupStatsService.getGroupDescription(input.build()));
84 public void onDataChanged(DataChangeEvent<InstanceIdentifier<?>, DataObject> change) {
85 for (InstanceIdentifier<?> key : change.getCreatedConfigurationData().keySet()) {
86 if (Group.class.equals(key.getTargetType())) {
87 logger.debug("Key {} triggered request", key);
90 logger.debug("Ignoring key {}", key);
94 final DataModificationTransaction trans = startTransaction();
95 for (InstanceIdentifier<?> key : change.getRemovedConfigurationData()) {
96 if (Group.class.equals(key.getTargetType())) {
97 @SuppressWarnings("unchecked")
98 InstanceIdentifier<Group> group = (InstanceIdentifier<Group>)key;
99 InstanceIdentifier<?> del = group.augmentation(NodeGroupDescStats.class);
100 logger.debug("Key {} triggered remove of augmentation {}", key, del);
102 trans.removeOperationalData(del);
109 public void start(final DataBrokerService dbs) {
110 if (groupStatsService == null) {
111 logger.debug("No Group Statistics service, not subscribing to groups on node {}", getNodeIdentifier());
119 protected GroupDescStats createInvariantKey(GroupDescStats item) {
120 // No invariant data exist in the group description stats.