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.util.Map;
   4 import java.util.Set;
   5 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
   6 import org.opendaylight.controller.md.sal.binding.api.DataChangeListener;
   7 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataBroker;
   8 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataChangeEvent;
   9 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  10 import org.opendaylight.ovsdb.openstack.netvirt.api.OvsdbInventoryListener;
  11 import org.opendaylight.ovsdb.southbound.SouthboundConstants;
  12 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.Uri;
  13 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeId;
  14 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeBuilder;
  15 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeKey;
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbNodeAugmentation;
  17 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NetworkTopology;
  18 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.TopologyId;
  19 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
  20 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.TopologyKey;
  21 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
  22 import org.opendaylight.yangtools.concepts.ListenerRegistration;
  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;
  27
  28 /**
  29  * Integration tests for southbound-impl
  30  *
  31  * @author Sam Hague (shague@redhat.com)
  32  */
  33 public class OvsdbDataChangeListener implements DataChangeListener, AutoCloseable {
  34     private static final Logger LOG = LoggerFactory.getLogger(OvsdbDataChangeListener.class);
  35     private DataBroker dataBroker = null;
  36     private static final TopologyId OVSDB_TOPOLOGY_ID = new TopologyId(new Uri("ovsdb:1"));
  37     private ListenerRegistration<DataChangeListener> registration;
  38
  39     public OvsdbDataChangeListener (DataBroker dataBroker) {
  40         LOG.info(">>>>> Registering OvsdbNodeDataChangeListener");
  41         this.dataBroker = dataBroker;
  42         InstanceIdentifier<Node> path = InstanceIdentifier
  43                 .create(NetworkTopology.class)
  44                 .child(Topology.class, new TopologyKey(SouthboundConstants.OVSDB_TOPOLOGY_ID))
  45                 .child(Node.class);
  46         registration =
  47                 dataBroker.registerDataChangeListener(LogicalDatastoreType.OPERATIONAL, path, this,
  48                         AsyncDataBroker.DataChangeScope.SUBTREE);
  49     }
  50
  51     @Override
  52     public void close () throws Exception {
  53         registration.close();
  54     }
  55
  56     @Override
  57     public void onDataChanged(AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> changes) {
  58         for (Map.Entry<InstanceIdentifier<?>, DataObject> created : changes.getCreatedData().entrySet()) {
  59             if (created.getValue() instanceof Node) {
  60
  61             }
  62         }
  63     }
  64
  65     private void notifyNodeAdded(Node node) {
  66         Set<OvsdbInventoryListener> mdsalConsumerListeners = OvsdbInventoryServiceImpl.getMdsalConsumerListeners();
  67         for (OvsdbInventoryListener mdsalConsumerListener : mdsalConsumerListeners) {
  68             mdsalConsumerListener.ovsdbNodeAdded(node);
  69         }
  70     }
  71
  72     private org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node
  73             inventoryNodeFromTopology(Node topologyNode) {
  74         OvsdbNodeAugmentation ovsdbNodeAugmentation = topologyNode.getAugmentation(OvsdbNodeAugmentation.class);
  75         String addrPort = ovsdbNodeAugmentation.getConnectionInfo().getRemoteIp().getValue() + ":"
  76                 + ovsdbNodeAugmentation.getConnectionInfo().getRemotePort().getValue();
  77         NodeId nodeId = new NodeId("OVS" + "|" + addrPort);
  78         NodeKey nodeKey = new NodeKey(nodeId);
  79         org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node inventoryNode = new NodeBuilder()
  80                 .setId(nodeId)
  81                 .setKey(nodeKey)
  82                 .build();
  83         return inventoryNode;
  84     }
  85 }