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