opendaylight/md-sal/topology-manager/src/main/java/org/opendaylight/md/controller/topology/manager/FlowCapableTopologyExporter.xtend

   1 package org.opendaylight.md.controller.topology.manager
   2
   3 import com.google.common.collect.FluentIterable
   4 import org.opendaylight.controller.md.sal.binding.util.TypeSafeDataReader
   5 import org.opendaylight.controller.sal.binding.api.data.DataModificationTransaction
   6 import org.opendaylight.controller.sal.binding.api.data.DataProviderService
   7 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNodeConnectorUpdated
   8 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNodeUpdated
   9 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.topology.discovery.rev130819.FlowTopologyDiscoveryListener
  10 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.topology.discovery.rev130819.LinkDiscovered
  11 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.topology.discovery.rev130819.LinkOverutilized
  12 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.topology.discovery.rev130819.LinkRemoved
  13 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.topology.discovery.rev130819.LinkUtilizationNormal
  14 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorRef
  15 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorRemoved
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorUpdated
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeRef
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeRemoved
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeUpdated
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.OpendaylightInventoryListener
  21 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.NetworkTopology
  22 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.NodeId
  23 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.TopologyId
  24 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.TpId
  25 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.network.topology.Topology
  26 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.network.topology.TopologyBuilder
  27 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.network.topology.TopologyKey
  28 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.network.topology.topology.Link
  29 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.network.topology.topology.Node
  30 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.network.topology.topology.NodeKey
  31 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.network.topology.topology.node.TerminationPoint
  32 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.network.topology.topology.node.TerminationPointKey
  33 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier
  34
  35 import static extension org.opendaylight.md.controller.topology.manager.FlowCapableNodeMapping.*
  36
  37 class FlowCapableTopologyExporter implements //
  38 FlowTopologyDiscoveryListener, //
  39 OpendaylightInventoryListener //
  40 {
  41
  42     var TopologyKey topology = new TopologyKey(new TopologyId("flow:1"));
  43
  44     @Property
  45     var DataProviderService dataService;
  46
  47     def start() {
  48         val tb = new TopologyBuilder();
  49         tb.setKey(topology);
  50         val path = InstanceIdentifier.builder(NetworkTopology).child(Topology,topology).toInstance;
  51         val top = tb.build();
  52         val it = dataService.beginTransaction
  53         putOperationalData(path,top);
  54         commit()
  55     }
  56
  57     override onNodeRemoved(NodeRemoved notification) {
  58         val nodeId = notification.nodeRef.nodeKey.id.toToplogyNodeId()
  59         val nodeInstance = notification.nodeRef.toNodeIdentifier()
  60
  61         val it = dataService.beginTransaction
  62         removeOperationalData(nodeInstance);
  63         removeAffectedLinks(it,nodeId)
  64         commit()
  65
  66     }
  67
  68     override onNodeUpdated(NodeUpdated notification) {
  69         val fcnu = notification.getAugmentation(FlowCapableNodeUpdated)
  70         if(fcnu != null) {
  71             val node = notification.id.toToplogyNodeId.toTopologyNode(notification.nodeRef)
  72             val path = notification.id.toToplogyNodeId.nodePath;
  73             val it = dataService.beginTransaction
  74             putOperationalData(path, node);
  75             commit()
  76         }
  77     }
  78
  79     override onNodeConnectorRemoved(NodeConnectorRemoved notification) {
  80         val tpInstance = notification.nodeConnectorRef.toTerminationPointIdentifier;
  81         val tpId = notification.nodeConnectorRef.nodeConnectorKey.id.toTerminationPointId;
  82         val it = dataService.beginTransaction
  83         removeOperationalData(tpInstance);
  84         removeAffectedLinks(it,tpId)
  85         commit()
  86
  87     }
  88
  89     override onNodeConnectorUpdated(NodeConnectorUpdated notification) {
  90         val fcncu = notification.getAugmentation(FlowCapableNodeConnectorUpdated)
  91         if(fcncu != null) {
  92             val nodeId = notification.nodeConnectorRef.nodeKey.id.toToplogyNodeId;
  93             val TerminationPoint point = notification.id.toTerminationPointId.toTerminationPoint(notification.nodeConnectorRef);
  94             val path = tpPath(nodeId, point.key.tpId);
  95
  96             val it = dataService.beginTransaction
  97             putOperationalData(path, point);
  98             commit()
  99        }
 100     }
 101
 102     override onLinkDiscovered(LinkDiscovered notification) {
 103         val link = notification.toTopologyLink;
 104         val path = link.linkPath;
 105         val it = dataService.beginTransaction
 106         putOperationalData(path, link);
 107         commit()
 108     }
 109
 110     override onLinkOverutilized(LinkOverutilized notification) {
 111         // NOOP
 112     }
 113
 114     override onLinkRemoved(LinkRemoved notification) {
 115         val path = notification.toTopologyLink.linkPath
 116         val it = dataService.beginTransaction
 117         removeOperationalData(path);
 118         commit()
 119     }
 120
 121     override onLinkUtilizationNormal(LinkUtilizationNormal notification) {
 122         // NOOP
 123     }
 124
 125     def InstanceIdentifier<Node> toNodeIdentifier(NodeRef ref) {
 126         val invNodeKey = ref.nodeKey
 127
 128         val nodeKey = new NodeKey(invNodeKey.id.toToplogyNodeId);
 129         return InstanceIdentifier.builder(NetworkTopology).child(Topology, topology).child(Node, nodeKey).
 130             toInstance;
 131     }
 132
 133     def InstanceIdentifier<TerminationPoint> toTerminationPointIdentifier(NodeConnectorRef ref) {
 134         val invNodeKey = ref.nodeKey
 135         val invNodeConnectorKey = ref.nodeConnectorKey
 136         return tpPath(invNodeKey.id.toToplogyNodeId(), invNodeConnectorKey.id.toTerminationPointId())
 137     }
 138
 139     private def void removeAffectedLinks(DataModificationTransaction transaction, NodeId id) {
 140         val reader = TypeSafeDataReader.forReader(transaction)
 141         val topologyPath = InstanceIdentifier.builder(NetworkTopology).child(Topology, topology).toInstance;
 142         val topologyData = reader.readOperationalData(topologyPath);
 143         if (topologyData === null) {
 144             return;
 145         }
 146         val affectedLinkInstances = FluentIterable.from(topologyData.link).filter[
 147             source.sourceNode == id || destination.destNode == id].transform [
 148             //
 149             InstanceIdentifier.builder(NetworkTopology).child(Topology, topology).child(Link, key).toInstance
 150         //
 151         ]
 152         for(affectedLink : affectedLinkInstances) {
 153             transaction.removeOperationalData(affectedLink);
 154         }
 155     }
 156
 157     private def void removeAffectedLinks(DataModificationTransaction transaction, TpId id) {
 158         val reader = TypeSafeDataReader.forReader(transaction)
 159         val topologyPath = InstanceIdentifier.builder(NetworkTopology).child(Topology, topology).toInstance;
 160         val topologyData = reader.readOperationalData(topologyPath);
 161         if (topologyData === null) {
 162             return;
 163         }
 164         val affectedLinkInstances = FluentIterable.from(topologyData.link).filter[
 165             source.sourceTp == id || destination.destTp == id].transform [
 166             //
 167             InstanceIdentifier.builder(NetworkTopology).child(Topology, topology).child(Link, key).toInstance
 168         //
 169         ]
 170         for(affectedLink : affectedLinkInstances) {
 171             transaction.removeOperationalData(affectedLink);
 172         }
 173     }
 174
 175     private def InstanceIdentifier<Node> nodePath(NodeId nodeId) {
 176         val nodeKey = new NodeKey(nodeId);
 177         return InstanceIdentifier.builder(NetworkTopology)
 178             .child(Topology, topology)
 179             .child(Node, nodeKey)
 180             .toInstance;
 181     }
 182
 183     private def InstanceIdentifier<TerminationPoint> tpPath(NodeId nodeId, TpId tpId) {
 184         val nodeKey = new NodeKey(nodeId);
 185         val tpKey = new TerminationPointKey(tpId)
 186         return InstanceIdentifier.builder(NetworkTopology).child(Topology, topology).child(Node, nodeKey).
 187             child(TerminationPoint, tpKey).toInstance;
 188     }
 189
 190     private def InstanceIdentifier<Link> linkPath(Link link) {
 191         val linkInstanceId = InstanceIdentifier.builder(NetworkTopology)
 192             .child(Topology, topology)
 193             .child(Link, link.key)
 194             .toInstance;
 195         return linkInstanceId;
 196     }
 197 }