1 package org.opendaylight.md.controller.topology.manager
3 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.topology.discovery.rev130819.FlowTopologyDiscoveryListener
4 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.topology.discovery.rev130819.LinkDiscovered
5 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.topology.discovery.rev130819.LinkOverutilized
6 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.topology.discovery.rev130819.LinkRemoved
7 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.topology.discovery.rev130819.LinkUtilizationNormal
8 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.OpendaylightInventoryListener
9 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorRemoved
10 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorUpdated
11 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeRemoved
12 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeUpdated
13 import org.opendaylight.controller.sal.binding.api.data.DataProviderService
14 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.network.topology.Topology
15 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier
16 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorRef
17 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.network.topology.topology.node.TerminationPoint
18 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.network.topology.TopologyKey
19 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.NetworkTopology
20 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.network.topology.topology.Node
22 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.network.topology.topology.NodeKey
23 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.NodeId
24 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.network.topology.topology.node.TerminationPointKey
25 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.TpId
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeRef
27 import static extension org.opendaylight.md.controller.topology.manager.FlowCapableNodeMapping.*
28 import org.opendaylight.controller.sal.binding.api.data.DataModificationTransaction
29 import org.opendaylight.controller.md.sal.binding.util.TypeSafeDataReader
30 import com.google.common.collect.FluentIterable
31 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev130712.network.topology.topology.Link
33 class FlowCapableTopologyExporter implements //
34 FlowTopologyDiscoveryListener, //
35 OpendaylightInventoryListener //
38 var TopologyKey topology;
41 var DataProviderService dataService;
43 override onNodeRemoved(NodeRemoved notification) {
44 val invNodeKey = notification.nodeRef.nodeKey
45 val tpNodeId = invNodeKey.id.toToplogyNodeId()
46 val tpNodeInstance = notification.nodeRef.toNodeIdentifier()
48 val it = dataService.beginTransaction
49 removeRuntimeData(tpNodeInstance);
50 removeAffectedLinks(tpNodeId)
55 override onNodeUpdated(NodeUpdated notification) {
56 throw new UnsupportedOperationException("TODO: auto-generated method stub")
59 override onNodeConnectorRemoved(NodeConnectorRemoved notification) {
60 val tpRef = notification.nodeConnectorRef.toTerminationPointIdentifier();
61 val it = dataService.beginTransaction
62 removeRuntimeData(tpRef);
67 override onNodeConnectorUpdated(NodeConnectorUpdated notification) {
68 val nodeId = notification.nodeConnectorRef.nodeKey.id.toToplogyNodeId();
69 val TerminationPoint point = notification.toTerminationPoint();
70 val path = tpPath(nodeId, point.key.tpId);
72 val it = dataService.beginTransaction
73 putRuntimeData(path, point);
77 override onLinkDiscovered(LinkDiscovered notification) {
78 throw new UnsupportedOperationException("TODO: auto-generated method stub")
81 override onLinkOverutilized(LinkOverutilized notification) {
82 throw new UnsupportedOperationException("TODO: auto-generated method stub")
85 override onLinkRemoved(LinkRemoved notification) {
86 throw new UnsupportedOperationException("TODO: auto-generated method stub")
90 override onLinkUtilizationNormal(LinkUtilizationNormal notification) {
91 throw new UnsupportedOperationException("TODO: auto-generated method stub")
94 def InstanceIdentifier<Node> toNodeIdentifier(NodeRef ref) {
95 val invNodeKey = ref.nodeKey
97 val nodeKey = new NodeKey(invNodeKey.id.toToplogyNodeId);
98 return InstanceIdentifier.builder.node(NetworkTopology).child(Topology, topology).child(Node, nodeKey).
102 def InstanceIdentifier<TerminationPoint> toTerminationPointIdentifier(NodeConnectorRef ref) {
103 val invNodeKey = ref.nodeKey
104 val invNodeConnectorKey = ref.nodeConnectorKey
105 return tpPath(invNodeKey.id.toToplogyNodeId(), invNodeConnectorKey.id.toTerminationPointId())
108 private def void removeAffectedLinks(DataModificationTransaction transaction, NodeId id) {
109 val reader = TypeSafeDataReader.forReader(transaction)
110 val topologyPath = InstanceIdentifier.builder().node(NetworkTopology).child(Topology, topology).toInstance;
111 val topologyData = reader.readOperationalData(topologyPath);
112 if (topologyData === null) {
115 val affectedLinkInstances = FluentIterable.from(topologyData.link).filter[
116 source.sourceNode == id || destination.destNode == id].transform [
118 InstanceIdentifier.builder().node(NetworkTopology).child(Topology, topology).child(Link, key).toInstance
121 for(affectedLink : affectedLinkInstances) {
122 transaction.removeRuntimeData(affectedLink);
126 private def InstanceIdentifier<TerminationPoint> tpPath(NodeId nodeId, TpId tpId) {
127 val nodeKey = new NodeKey(nodeId);
128 val tpKey = new TerminationPointKey(tpId)
129 return InstanceIdentifier.builder.node(NetworkTopology).child(Topology, topology).child(Node, nodeKey).
130 child(TerminationPoint, tpKey).toInstance;