2 * Copyright (c) 2014 Cisco Systems, Inc. and others. 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.compatibility.inventory;
10 import java.util.ArrayList;
13 import org.opendaylight.controller.sal.binding.api.data.RuntimeDataProvider;
14 import org.opendaylight.controller.sal.compatibility.InventoryMapping;
15 import org.opendaylight.controller.switchmanager.ISwitchManager;
16 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.Nodes;
17 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodesBuilder;
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.NodeConnectorBuilder;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeBuilder;
22 import org.opendaylight.yangtools.yang.binding.DataObject;
23 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
24 import org.slf4j.Logger;
25 import org.slf4j.LoggerFactory;
27 public class InventoryReader implements RuntimeDataProvider {
28 private static final Logger LOG = LoggerFactory.getLogger(InventoryReader.class);
29 private ISwitchManager switchManager;
31 public ISwitchManager getSwitchManager() {
35 public void setSwitchManager(final ISwitchManager switchManager) {
36 this.switchManager = switchManager;
40 public DataObject readConfigurationData(final InstanceIdentifier<? extends DataObject> path) {
41 // Topology and Inventory are operational only
45 @SuppressWarnings("unchecked")
47 public DataObject readOperationalData(final InstanceIdentifier<? extends DataObject> path) {
48 final Class<? extends DataObject> type = path.getTargetType();
49 if (Nodes.class.equals(type)) {
50 return readNodes(((InstanceIdentifier<Nodes>) path));
52 if (Node.class.equals(type)) {
53 return readNode(((InstanceIdentifier<Node>) path));
55 if (NodeConnector.class.equals(type)) {
56 return readNodeConnector(((InstanceIdentifier<NodeConnector>) path));
59 LOG.debug("Unsupported type {}", type);
63 private NodeConnector readNodeConnector(final InstanceIdentifier<NodeConnector> identifier) {
64 return constructNodeConnector(InventoryMapping.toAdNodeConnector(identifier));
67 private Node readNode(final InstanceIdentifier<Node> identifier) {
68 return constructNode(InventoryMapping.toAdNode(identifier));
71 private Node constructNode(final org.opendaylight.controller.sal.core.Node node) {
72 final Set<org.opendaylight.controller.sal.core.NodeConnector> connectors = getSwitchManager().getNodeConnectors(node);
73 final ArrayList<NodeConnector> tpList = new ArrayList<NodeConnector>(connectors.size());
74 for (final org.opendaylight.controller.sal.core.NodeConnector connector : connectors) {
75 tpList.add(constructNodeConnector(connector));
78 return new NodeBuilder()
79 .setKey(InventoryMapping.toNodeKey(node))
80 .setNodeConnector(tpList)
84 private Nodes readNodes(final InstanceIdentifier<Nodes> identifier) {
85 final Set<org.opendaylight.controller.sal.core.Node> nodes = getSwitchManager().getNodes();
86 final ArrayList<Node> nodeList = new ArrayList<Node>(nodes.size());
87 for (final org.opendaylight.controller.sal.core.Node node : nodes) {
88 nodeList.add(constructNode(node));
91 return new NodesBuilder().setNode(nodeList).build();
94 private static NodeConnector constructNodeConnector(final org.opendaylight.controller.sal.core.NodeConnector connector) {
95 return new NodeConnectorBuilder().setKey(InventoryMapping.toNodeConnectorKey(connector)).build();