1 package org.opendaylight.controller.sal.compatibility
3 import org.opendaylight.controller.sal.core.Node
4 import org.opendaylight.controller.sal.core.NodeConnector
5 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.node.NodeConnectorKey
6 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier.IdentifiableItem
8 import static com.google.common.base.Preconditions.*;
9 import static extension org.opendaylight.controller.sal.common.util.Arguments.*;
10 import static extension org.opendaylight.controller.sal.compatibility.ToSalConversionsUtils.*;
12 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier
13 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorRef
14 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorId
15 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeKey
16 import org.opendaylight.controller.sal.core.ConstructionException
17 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeRef
18 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.Nodes
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeId
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorUpdated
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNodeConnectorUpdated
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortFeatures
23 import org.opendaylight.controller.sal.core.Bandwidth
24 import org.opendaylight.controller.sal.core.AdvertisedBandwidth
25 import org.opendaylight.controller.sal.core.SupportedBandwidth
26 import org.opendaylight.controller.sal.core.PeerBandwidth
27 import org.opendaylight.controller.sal.core.Name
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortConfig
29 import org.opendaylight.controller.sal.core.Config
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.flow.capable.port.State
31 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeUpdated
32 import java.util.HashSet
33 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNodeUpdated
34 import org.opendaylight.controller.sal.core.Tables
36 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FeatureCapability
37 import org.opendaylight.controller.sal.core.Buffers
38 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowFeatureCapabilityFlowStats
39 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowFeatureCapabilityTableStats
40 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowFeatureCapabilityIpReasm
41 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowFeatureCapabilityPortStats
42 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowFeatureCapabilityStp
43 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowFeatureCapabilityQueueStats
44 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowFeatureCapabilityArpMatchIp
45 import org.opendaylight.controller.sal.core.Capabilities
46 import org.opendaylight.controller.sal.core.MacAddress
48 import org.opendaylight.controller.sal.core.TimeStamp
49 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowNodeConnector
50 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowNode
51 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNodeConnector
53 public class NodeMapping {
55 public static val MD_SAL_TYPE = "MD_SAL";
56 private static val NODE_CLASS = org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
57 private static val NODECONNECTOR_CLASS = org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.node.
61 throw new UnsupportedOperationException("Utility class. Instantiation is not allowed.");
64 public static def toADNode(InstanceIdentifier<?> node) throws ConstructionException {
65 return node.toNodeId.toADNode
68 public static def toADNode(NodeId id) {
69 return new Node(MD_SAL_TYPE, id.toADNodeId);
72 public static def toNodeId(InstanceIdentifier<?> node) {
74 checkNotNull(node.getPath());
75 checkArgument(node.getPath().size() >= 2);
76 val arg = node.getPath().get(1);
77 val item = arg.checkInstanceOf(IdentifiableItem);
78 val nodeKey = item.getKey().checkInstanceOf(NodeKey);
82 public static def toADNodeId(NodeId nodeId) {
87 public static def toADNodeConnector(NodeConnectorRef source) throws ConstructionException {
89 val InstanceIdentifier<?> path = checkNotNull(source.getValue());
90 checkArgument(path.path.size() >= 3);
91 val arg = path.getPath().get(2);
92 val item = arg.checkInstanceOf(IdentifiableItem);
93 val connectorKey = item.getKey().checkInstanceOf(NodeConnectorKey);
94 return connectorKey.id.toADNodeConnector(path.toNodeId)
97 public static def toADNodeConnector(org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorId ncid,
98 org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeId nid) {
99 return new NodeConnector(ncid.toNodeConnectorType(nid),
100 ncid.toADNodeConnectorId(nid), nid.toADNode);
103 public static def toNodeConnectorType(NodeConnectorId ncId, NodeId nodeId) {
104 if (ncId.equals(nodeId.toLocalNodeConnectorId)) {
105 return NodeConnector.NodeConnectorIDType.SWSTACK
106 } else if (ncId.equals(nodeId.toNormalNodeConnectorId)) {
107 return NodeConnector.NodeConnectorIDType.HWPATH
108 } else if (ncId.equals(nodeId.toControllerNodeConnectorId)) {
109 return NodeConnector.NodeConnectorIDType.CONTROLLER
114 public static def toADNodeConnectorId(NodeConnectorId nodeConnectorId, NodeId nodeId) {
115 if (nodeConnectorId.equals(nodeId.toLocalNodeConnectorId) ||
116 nodeConnectorId.equals(nodeId.toNormalNodeConnectorId) ||
117 nodeConnectorId.equals(nodeId.toControllerNodeConnectorId)) {
118 return NodeConnector.SPECIALNODECONNECTORID
120 return nodeConnectorId.value
123 public static def toControllerNodeConnectorId(NodeId node) {
124 return new NodeConnectorId(node.value + ":" + 4294967293L)
127 public static def toLocalNodeConnectorId(NodeId node) {
128 return new NodeConnectorId(node.value + ":" + 4294967294L)
131 public static def toNormalNodeConnectorId(NodeId node) {
132 return new NodeConnectorId(node.value + ":" + 4294967290L)
135 public static def toNodeRef(Node node) {
136 checkArgument(MD_SAL_TYPE.equals(node.getType()));
137 var nodeId = node.ID.checkInstanceOf(String)
138 val nodeKey = new NodeKey(new NodeId(nodeId));
139 val nodePath = InstanceIdentifier.builder().node(Nodes).child(NODE_CLASS, nodeKey).toInstance();
140 return new NodeRef(nodePath);
143 public static def toNodeConnectorRef(NodeConnector nodeConnector) {
144 val node = nodeConnector.node.toNodeRef();
145 val nodePath = node.getValue() as InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node>
146 var NodeConnectorId nodeConnectorId
147 if (nodeConnector.ID.equals(NodeConnector.SPECIALNODECONNECTORID)) {
148 if (nodeConnector.type.equals(NodeConnector.NodeConnectorIDType.SWSTACK)) {
149 nodeConnectorId = nodePath.toNodeId.toLocalNodeConnectorId
150 } else if (nodeConnector.type.equals(NodeConnector.NodeConnectorIDType.HWPATH)) {
151 nodeConnectorId = nodePath.toNodeId.toNormalNodeConnectorId
152 } else if (nodeConnector.type.equals(NodeConnector.NodeConnectorIDType.CONTROLLER)) {
153 nodeConnectorId = nodePath.toNodeId.toControllerNodeConnectorId
156 nodeConnectorId = new NodeConnectorId(nodeConnector.ID.checkInstanceOf(String))
158 val connectorKey = new NodeConnectorKey(nodeConnectorId);
159 val path = InstanceIdentifier.builder(nodePath).child(NODECONNECTOR_CLASS, connectorKey).toInstance();
160 return new NodeConnectorRef(path);
163 public static def toADNode(NodeRef node) throws ConstructionException {
164 return toADNode(node.getValue());
167 public static def toADNodeConnectorProperties(NodeConnectorUpdated nc) {
168 val fcncu = nc.getAugmentation(FlowCapableNodeConnectorUpdated)
170 return fcncu.toADNodeConnectorProperties
172 return new HashSet<org.opendaylight.controller.sal.core.Property>();
175 public static def toADNodeConnectorProperties(org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.node.NodeConnector nc) {
176 val fcnc = nc.getAugmentation(FlowCapableNodeConnector)
178 return fcnc.toADNodeConnectorProperties
180 return new HashSet<org.opendaylight.controller.sal.core.Property>();
183 public static def toADNodeConnectorProperties(FlowNodeConnector fcncu) {
184 val props = new HashSet<org.opendaylight.controller.sal.core.Property>();
186 if (fcncu.currentFeature != null && fcncu.currentFeature.toAdBandwidth != null) {
187 props.add(fcncu.currentFeature.toAdBandwidth)
189 if (fcncu.advertisedFeatures != null && fcncu.advertisedFeatures.toAdAdvertizedBandwidth != null) {
190 props.add(fcncu.advertisedFeatures.toAdAdvertizedBandwidth)
192 if (fcncu.supported != null && fcncu.supported.toAdSupportedBandwidth != null) {
193 props.add(fcncu.supported.toAdSupportedBandwidth)
195 if (fcncu.peerFeatures != null && fcncu.peerFeatures.toAdPeerBandwidth != null) {
196 props.add(fcncu.peerFeatures.toAdPeerBandwidth)
198 if (fcncu.name != null && fcncu.name.toAdName != null) {
199 props.add(fcncu.name.toAdName)
201 if (fcncu.configuration != null && fcncu.configuration.toAdConfig != null) {
202 props.add(fcncu.configuration.toAdConfig)
204 if (fcncu.state != null && fcncu.state.toAdState != null) {
205 props.add(fcncu.state.toAdState)
211 public static def toAdName(String name) {
212 return new Name(name)
215 public static def toAdConfig(PortConfig pc) {
218 config = new Config(Config.ADMIN_DOWN)
220 config = new Config(Config.ADMIN_UP)
225 public static def toAdState(State s) {
226 var org.opendaylight.controller.sal.core.State state
228 state = new org.opendaylight.controller.sal.core.State(org.opendaylight.controller.sal.core.State.EDGE_DOWN)
230 state = new org.opendaylight.controller.sal.core.State(org.opendaylight.controller.sal.core.State.EDGE_UP)
235 public static def toAdBandwidth(PortFeatures pf) {
236 var Bandwidth bw = null
237 if (pf.isTenMbHd || pf.isTenMbFd) {
238 bw = new Bandwidth(Bandwidth.BW10Mbps)
239 } else if (pf.isHundredMbHd || pf.isHundredMbFd) {
240 bw = new Bandwidth(Bandwidth.BW100Mbps)
241 } else if (pf.isOneGbHd || pf.isOneGbFd) {
242 bw = new Bandwidth(Bandwidth.BW1Gbps)
243 } else if (pf.isOneGbFd) {
244 bw = new Bandwidth(Bandwidth.BW10Gbps)
245 } else if (pf.isTenGbFd) {
246 bw = new Bandwidth(Bandwidth.BW10Gbps)
247 } else if (pf.isFortyGbFd) {
248 bw = new Bandwidth(Bandwidth.BW40Gbps)
249 } else if (pf.isHundredGbFd) {
250 bw = new Bandwidth(Bandwidth.BW100Gbps)
251 } else if (pf.isOneTbFd) {
252 bw = new Bandwidth(Bandwidth.BW1Tbps)
257 public static def toAdAdvertizedBandwidth(PortFeatures pf) {
258 var AdvertisedBandwidth abw
259 val bw = pf.toAdBandwidth
261 abw = new AdvertisedBandwidth(bw.value)
266 public static def toAdSupportedBandwidth(PortFeatures pf) {
267 var SupportedBandwidth sbw
268 val bw = pf.toAdBandwidth
270 sbw = new SupportedBandwidth(bw.value)
275 public static def toAdPeerBandwidth(PortFeatures pf) {
276 var PeerBandwidth pbw
277 val bw = pf.toAdBandwidth
279 pbw = new PeerBandwidth(bw.value)
284 public static def toADNodeProperties(NodeUpdated nu) {
285 val fcnu = nu.getAugmentation(FlowCapableNodeUpdated)
287 return fcnu.toADNodeProperties(nu.id)
289 return new HashSet<org.opendaylight.controller.sal.core.Property>();
293 public static def toADNodeProperties(FlowNode fcnu, NodeId id) {
294 val props = new HashSet<org.opendaylight.controller.sal.core.Property>();
296 props.add(toADTimestamp)
298 // props.add(fcnu.supportedActions.toADActions) - TODO
300 props.add(id.toADMacAddress)
302 if (fcnu.switchFeatures != null) {
303 if (fcnu.switchFeatures.maxTables != null) {
304 props.add(fcnu.switchFeatures.maxTables.toADTables)
306 if (fcnu.switchFeatures.capabilities != null) {
307 props.add(fcnu.switchFeatures.capabilities.toADCapabiliities)
309 if (fcnu.switchFeatures.maxBuffers != null) {
310 props.add(fcnu.switchFeatures.maxBuffers.toADBuffers)
317 public static def toADTimestamp() {
318 val date = new Date();
319 val timestamp = new TimeStamp(date.time, "connectedSince")
323 public static def toADMacAddress(NodeId id) {
324 return new MacAddress(Long.parseLong(id.value.replaceAll("openflow:", "")).longValue.bytesFromDpid)
327 public static def toADTables(Short tables) {
328 return new Tables(tables.byteValue)
331 public static def toADCapabiliities(List<Class<? extends FeatureCapability>> capabilities) {
333 for (capability : capabilities) {
334 if (capability.equals(FlowFeatureCapabilityFlowStats)) {
335 b = Capabilities.CapabilitiesType.FLOW_STATS_CAPABILITY.value.bitwiseOr(b)
336 } else if (capability.equals(FlowFeatureCapabilityTableStats)) {
337 b = Capabilities.CapabilitiesType.TABLE_STATS_CAPABILITY.value.bitwiseOr(b)
338 } else if (capability.equals(FlowFeatureCapabilityPortStats)) {
339 b = Capabilities.CapabilitiesType.PORT_STATS_CAPABILITY.value.bitwiseOr(b)
340 } else if (capability.equals(FlowFeatureCapabilityStp)) {
341 b = Capabilities.CapabilitiesType.STP_CAPABILITY.value.bitwiseOr(b)
342 } else if (capability.equals(FlowFeatureCapabilityIpReasm)) {
343 b = Capabilities.CapabilitiesType.IP_REASSEM_CAPABILITY.value.bitwiseOr(b)
344 } else if (capability.equals(FlowFeatureCapabilityQueueStats)) {
345 b = Capabilities.CapabilitiesType.QUEUE_STATS_CAPABILITY.value.bitwiseOr(b)
346 } else if (capability.equals(FlowFeatureCapabilityArpMatchIp)) {
347 b = Capabilities.CapabilitiesType.ARP_MATCH_IP_CAPABILITY.value.bitwiseOr(b)
350 return new Capabilities(b)
353 public static def toADBuffers(Long buffers) {
354 return new Buffers(buffers.intValue)