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