1 package org.opendaylight.md.controller.topology.manager
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
35 import static extension org.opendaylight.md.controller.topology.manager.FlowCapableNodeMapping.*
37 class FlowCapableTopologyExporter implements //
38 FlowTopologyDiscoveryListener, //
39 OpendaylightInventoryListener //
42 var TopologyKey topology = new TopologyKey(new TopologyId("flow:1"));
45 var DataProviderService dataService;
48 val tb = new TopologyBuilder();
50 val path = InstanceIdentifier.builder(NetworkTopology).child(Topology,topology).toInstance;
52 val it = dataService.beginTransaction
53 putOperationalData(path,top);
57 override onNodeRemoved(NodeRemoved notification) {
58 val nodeId = notification.nodeRef.nodeKey.id.toToplogyNodeId()
59 val nodeInstance = notification.nodeRef.toNodeIdentifier()
61 val it = dataService.beginTransaction
62 removeOperationalData(nodeInstance);
63 removeAffectedLinks(it,nodeId)
68 override onNodeUpdated(NodeUpdated notification) {
69 val fcnu = notification.getAugmentation(FlowCapableNodeUpdated)
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);
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)
89 override onNodeConnectorUpdated(NodeConnectorUpdated notification) {
90 val fcncu = notification.getAugmentation(FlowCapableNodeConnectorUpdated)
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);
96 val it = dataService.beginTransaction
97 putOperationalData(path, point);
102 override onLinkDiscovered(LinkDiscovered notification) {
103 val link = notification.toTopologyLink;
104 val path = link.linkPath;
105 val it = dataService.beginTransaction
106 putOperationalData(path, link);
110 override onLinkOverutilized(LinkOverutilized notification) {
114 override onLinkRemoved(LinkRemoved notification) {
115 val path = notification.toTopologyLink.linkPath
116 val it = dataService.beginTransaction
117 removeOperationalData(path);
121 override onLinkUtilizationNormal(LinkUtilizationNormal notification) {
125 def InstanceIdentifier<Node> toNodeIdentifier(NodeRef ref) {
126 val invNodeKey = ref.nodeKey
128 val nodeKey = new NodeKey(invNodeKey.id.toToplogyNodeId);
129 return InstanceIdentifier.builder(NetworkTopology).child(Topology, topology).child(Node, nodeKey).
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())
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) {
146 val affectedLinkInstances = FluentIterable.from(topologyData.link).filter[
147 source.sourceNode == id || destination.destNode == id].transform [
149 InstanceIdentifier.builder(NetworkTopology).child(Topology, topology).child(Link, key).toInstance
152 for(affectedLink : affectedLinkInstances) {
153 transaction.removeOperationalData(affectedLink);
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) {
164 val affectedLinkInstances = FluentIterable.from(topologyData.link).filter[
165 source.sourceTp == id || destination.destTp == id].transform [
167 InstanceIdentifier.builder(NetworkTopology).child(Topology, topology).child(Link, key).toInstance
170 for(affectedLink : affectedLinkInstances) {
171 transaction.removeOperationalData(affectedLink);
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)
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;
190 private def InstanceIdentifier<Link> linkPath(Link link) {
191 val linkInstanceId = InstanceIdentifier.builder(NetworkTopology)
192 .child(Topology, topology)
193 .child(Link, link.key)
195 return linkInstanceId;