openstack/net-virt/src/main/java/org/opendaylight/ovsdb/openstack/netvirt/impl/OvsdbDataChangeListener.java

   1 package org.opendaylight.ovsdb.openstack.netvirt.impl;
   2
   3 import java.net.UnknownHostException;
   4 import java.util.Map;
   5 import java.util.Set;
   6 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
   7 import org.opendaylight.controller.md.sal.binding.api.DataChangeListener;
   8 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataBroker.DataChangeScope;
   9 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataChangeEvent;
  10 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  11 import org.opendaylight.ovsdb.lib.OvsdbClient;
  12 import org.opendaylight.ovsdb.openstack.netvirt.api.OvsdbInventoryListener;
  13 import org.opendaylight.ovsdb.southbound.SouthboundConstants;
  14 import org.opendaylight.ovsdb.southbound.SouthboundMapper;
  15 import org.opendaylight.ovsdb.southbound.SouthboundProvider;
  16 import org.opendaylight.ovsdb.southbound.ovsdb.transact.TransactUtils;
  17 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.Uri;
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeId;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeBuilder;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeKey;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbBridgeAugmentation;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbNodeAugmentation;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.ovsdb.node.attributes.ConnectionInfo;
  24 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NetworkTopology;
  25 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.TopologyId;
  26 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
  27 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.TopologyKey;
  28 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
  29 import org.opendaylight.yangtools.concepts.ListenerRegistration;
  30 import org.opendaylight.yangtools.yang.binding.DataObject;
  31 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  32 import org.slf4j.Logger;
  33 import org.slf4j.LoggerFactory;
  34
  35 /**
  36  * MDSAL dataChangeListener for the OVSDB Southbound
  37  *
  38  * @author Sam Hague (shague@redhat.com)
  39  */
  40 public class OvsdbDataChangeListener implements DataChangeListener, AutoCloseable {
  41     private static final Logger LOG = LoggerFactory.getLogger(OvsdbDataChangeListener.class);
  42     private DataBroker dataBroker = null;
  43     private ListenerRegistration<DataChangeListener> registration;
  44
  45     public OvsdbDataChangeListener (DataBroker dataBroker) {
  46         LOG.info(">>>>> Registering OvsdbNodeDataChangeListener: dataBroker= {}", dataBroker);
  47         this.dataBroker = dataBroker;
  48         //this.dataBroker = SouthboundProvider.getDb();
  49         InstanceIdentifier<Node> path = InstanceIdentifier
  50                 .create(NetworkTopology.class)
  51                 .child(Topology.class, new TopologyKey(SouthboundConstants.OVSDB_TOPOLOGY_ID))
  52                 .child(Node.class);
  53         registration = dataBroker.registerDataChangeListener(LogicalDatastoreType.OPERATIONAL, path, this,
  54                 DataChangeScope.SUBTREE);
  55         LOG.info("netvirt OvsdbDataChangeListener: registration= {}", registration);
  56     }
  57
  58     @Override
  59     public void close () throws Exception {
  60         registration.close();
  61     }
  62
  63     @Override
  64     public void onDataChanged(AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> changes) {
  65         LOG.info(">>>>> onDataChanged: {}", changes);
  66
  67         updateConnections(changes);
  68     }
  69
  70     private Node getOvsdbNode(ConnectionInfo connectionInfo) {
  71         Node node = MdsalUtils.read(LogicalDatastoreType.OPERATIONAL,
  72                 SouthboundMapper.createInstanceIdentifier(connectionInfo));
  73         return node;
  74     }
  75
  76     public static <T extends DataObject> Map<InstanceIdentifier<T>,T> extractCreated(
  77             AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> changes,Class<T> klazz) {
  78         return TransactUtils.extract(changes.getCreatedData(), klazz);
  79     }
  80
  81     private void updateConnections(AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> changes) {
  82         for (Map.Entry<InstanceIdentifier<?>, DataObject> created : changes.getCreatedData().entrySet()) {
  83             // TODO validate we have the correct kind of InstanceIdentifier
  84             if (created.getValue() instanceof OvsdbNodeAugmentation) {
  85                 Map<InstanceIdentifier<Node>,Node> nodeMap = extractCreated(changes, Node.class);
  86                 LOG.info("nodeMap: {}", nodeMap);
  87                 for (Map.Entry<InstanceIdentifier<Node>, Node> ovsdbNode: nodeMap.entrySet()) {
  88                     notifyNodeAdded(ovsdbNode.getValue());
  89                 }
  90             }
  91         }
  92     }
  93
  94     private void notifyNodeAdded(Node node) {
  95         Set<OvsdbInventoryListener> mdsalConsumerListeners = OvsdbInventoryServiceImpl.getMdsalConsumerListeners();
  96         for (OvsdbInventoryListener mdsalConsumerListener : mdsalConsumerListeners) {
  97             mdsalConsumerListener.ovsdbNodeAdded(node);
  98         }
  99     }
 100
 101     private org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node
 102             inventoryNodeFromTopology(Node topologyNode) {
 103         OvsdbNodeAugmentation ovsdbNodeAugmentation = topologyNode.getAugmentation(OvsdbNodeAugmentation.class);
 104         String addrPort = ovsdbNodeAugmentation.getConnectionInfo().getRemoteIp().getValue() + ":"
 105                 + ovsdbNodeAugmentation.getConnectionInfo().getRemotePort().getValue();
 106         NodeId nodeId = new NodeId("OVS" + "|" + addrPort);
 107         NodeKey nodeKey = new NodeKey(nodeId);
 108         org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node inventoryNode = new NodeBuilder()
 109                 .setId(nodeId)
 110                 .setKey(nodeKey)
 111                 .build();
 112         return inventoryNode;
 113     }
 114 }