2 * Copyright © 2016 AT&T and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
9 package org.opendaylight.transportpce.networkmodel.util;
11 import java.util.ArrayList;
12 import java.util.Collections;
13 import java.util.Comparator;
14 import java.util.HashMap;
15 import java.util.List;
17 import java.util.concurrent.ExecutionException;
18 import java.util.concurrent.TimeUnit;
19 import java.util.concurrent.TimeoutException;
20 import java.util.stream.Collectors;
22 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
23 import org.opendaylight.transportpce.common.NetworkUtils;
24 import org.opendaylight.transportpce.common.network.NetworkTransactionService;
25 import org.opendaylight.transportpce.networkmodel.dto.TopologyShard;
26 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev200113.network.Nodes;
27 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev200113.network.nodes.Mapping;
28 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Link1;
29 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Link1Builder;
30 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.NetworkTypes1;
31 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.NetworkTypes1Builder;
32 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.networks.network.network.types.OpenroadmCommonNetworkBuilder;
33 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.state.types.rev181130.State;
34 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.types.rev161014.NodeTypes;
35 import org.opendaylight.yang.gen.v1.http.org.openroadm.degree.rev181130.degree.node.attributes.AvailableWavelengths;
36 import org.opendaylight.yang.gen.v1.http.org.openroadm.degree.rev181130.degree.node.attributes.AvailableWavelengthsBuilder;
37 import org.opendaylight.yang.gen.v1.http.org.openroadm.degree.rev181130.degree.node.attributes.AvailableWavelengthsKey;
38 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.Node1;
39 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.Node1Builder;
40 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.TerminationPoint1;
41 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.TerminationPoint1Builder;
42 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.DegreeAttributesBuilder;
43 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.SrgAttributesBuilder;
44 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.termination.point.XpdrClientAttributesBuilder;
45 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.termination.point.XpdrNetworkAttributesBuilder;
46 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev181130.OpenroadmLinkType;
47 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev181130.OpenroadmNodeType;
48 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev181130.OpenroadmTpType;
49 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NetworkId;
50 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.Networks;
51 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NodeId;
52 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.Network;
53 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.NetworkBuilder;
54 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.NetworkKey;
55 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.NetworkTypesBuilder;
56 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.Node;
57 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.NodeBuilder;
58 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.NodeKey;
59 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.node.SupportingNode;
60 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.node.SupportingNodeBuilder;
61 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.node.SupportingNodeKey;
62 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.LinkId;
63 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Network1;
64 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Network1Builder;
65 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.TpId;
66 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.Link;
67 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.LinkBuilder;
68 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.LinkKey;
69 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.link.DestinationBuilder;
70 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.link.SourceBuilder;
71 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPoint;
72 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPointBuilder;
73 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPointKey;
74 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
75 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier.InstanceIdentifierBuilder;
76 import org.slf4j.Logger;
77 import org.slf4j.LoggerFactory;
79 public class OpenRoadmTopology22 {
81 private static final Logger LOG = LoggerFactory.getLogger(OpenRoadmTopology22.class);
83 private NetworkTransactionService networkTransactionService;
85 public OpenRoadmTopology22(NetworkTransactionService networkTransactionService) {
86 this.networkTransactionService = networkTransactionService;
90 * This public method creates the OpenROADM Topology
91 * Layer and posts it to the controller.
93 public void createTopoLayer() {
95 Network openRoadmTopology = createOpenRoadmTopology();
96 InstanceIdentifierBuilder<Network> nwIID = InstanceIdentifier.builder(Networks.class).child(Network.class,
97 new NetworkKey(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID)));
99 this.networkTransactionService.put(LogicalDatastoreType.CONFIGURATION, nwIID.build(), openRoadmTopology);
100 this.networkTransactionService.commit().get(1, TimeUnit.SECONDS);
101 LOG.info("OpenRoadm-Topology created successfully.");
102 } catch (ExecutionException | TimeoutException | InterruptedException e) {
103 LOG.warn("Failed to create OpenRoadm-Topology", e);
108 * Create empty OpenROADM topology.
110 private Network createOpenRoadmTopology() {
111 NetworkId nwId = new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID);
112 NetworkTypes1Builder topoNetworkTypesBldr = new NetworkTypes1Builder()
113 .setOpenroadmCommonNetwork(new OpenroadmCommonNetworkBuilder().build());
114 NetworkTypesBuilder nwTypeBuilder = new NetworkTypesBuilder()
115 .addAugmentation(NetworkTypes1.class, topoNetworkTypesBldr.build());
116 // Array to store nodes in the topolayer of a roadm/Xponder
117 Network1Builder nwBldr1 = new Network1Builder()
118 .setLink(Collections.emptyList());
119 NetworkBuilder nwBuilder = new NetworkBuilder()
121 .withKey(new NetworkKey(nwId))
122 .setNetworkTypes(nwTypeBuilder.build())
123 // adding expressLinks
124 .addAugmentation(Network1.class, nwBldr1.build())
125 .setNode(Collections.emptyList());
126 return nwBuilder.build();
129 public TopologyShard createTopologyShard(Nodes mappingNode) {
132 List<Node> nodes = new ArrayList<>();
133 List<Link> links = new ArrayList<>();
135 // Check if node is ROADM
136 if (NodeTypes.Rdm.getIntValue() == mappingNode.getNodeInfo().getNodeType().getIntValue()) {
137 LOG.info("creating rdm node in openroadmtopology for node {}", mappingNode.getNodeId());
138 // transform flat mapping list to per degree and per srg mapping lists
139 Map<String, List<Mapping>> mapDeg = new HashMap<>();
140 Map<String, List<Mapping>> mapSrg = new HashMap<>();
141 List<Mapping> mappingList = mappingNode.getMapping();
142 mappingList.sort(Comparator.comparing(Mapping::getLogicalConnectionPoint));
144 List<String> nodeShardList = new ArrayList<>();
145 for (Mapping mapping : mappingList) {
146 String str = mapping.getLogicalConnectionPoint().split("-")[0];
147 if (!nodeShardList.contains(str)) {
148 nodeShardList.add(str);
151 for (String str : nodeShardList) {
152 List<Mapping> interList = new ArrayList<>();
153 interList = mappingList.stream().filter(x -> x.getLogicalConnectionPoint().contains(str))
154 .collect(Collectors.toList());
155 if (str.contains("DEG")) {
156 mapDeg.put(str, interList);
157 } else if (str.contains("SRG")) {
158 mapSrg.put(str, interList);
160 LOG.error("unknown element");
163 // create degree nodes
164 for (String k : mapDeg.keySet()) {
165 NodeBuilder ietfNode = createDegree(k, mapDeg.get(k), mappingNode.getNodeId());
166 nodes.add(ietfNode.build());
169 for (String k : mapSrg.keySet()) {
170 NodeBuilder ietfNode = createSrg(k, mapSrg.get(k), mappingNode.getNodeId());
171 nodes.add(ietfNode.build());
174 numOfDegrees = mapDeg.size();
175 numOfSrgs = mapSrg.size();
177 LOG.info("adding links numOfDegrees={} numOfSrgs={}", numOfDegrees, numOfSrgs);
178 links.addAll(createNewLinks(nodes));
179 LOG.info("created nodes/links: {}/{}", nodes.size(), links.size());
180 return new TopologyShard(nodes, links);
181 } else if (NodeTypes.Xpdr.getIntValue() == mappingNode.getNodeInfo().getNodeType().getIntValue()) {
182 // Check if node is XPONDER
183 LOG.info("creating xpdr node in openroadmtopology for node {}", mappingNode.getNodeId());
184 NodeBuilder ietfNode = createXpdr(mappingNode);
185 nodes.add(ietfNode.build());
186 return new TopologyShard(nodes, links);
188 LOG.error("Device node Type not managed yet");
192 private NodeBuilder createXpdr(Nodes mappingNode) {
194 String nodeIdtopo = new StringBuilder().append(mappingNode.getNodeId()).append("-XPDR1").toString();
195 // Create openroadm-network-topo augmentation to set node type to Xponder
196 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
197 .Node1Builder ocnNode1Bldr = new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
198 .Node1Builder().setNodeType(OpenroadmNodeType.XPONDER);
199 // Create ietf node setting supporting-node data
200 NodeBuilder ietfNodeBldr = createTopoLayerNode(mappingNode.getNodeId())
201 .setNodeId(new NodeId(nodeIdtopo))
202 .withKey((new NodeKey(new NodeId(nodeIdtopo))))
203 .addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
204 .Node1.class, ocnNode1Bldr.build());
207 List<TerminationPoint> tpList = new ArrayList<>();
208 TerminationPointBuilder ietfTpBldr;
209 for (Mapping m : mappingNode.getMapping()) {
210 ietfTpBldr = createTpBldr(m.getLogicalConnectionPoint());
211 // Add openroadm-network-topology tp augmentations
212 TerminationPoint1Builder ontTp1Bldr = new TerminationPoint1Builder();
213 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
214 .TerminationPoint1Builder ocnTp1Bldr = new org.opendaylight.yang.gen.v1.http.org.openroadm.common
215 .network.rev181130.TerminationPoint1Builder();
216 if (m.getPortQual().equals("xpdr-network")) {
217 XpdrNetworkAttributesBuilder xpdrNwAttrBldr = new XpdrNetworkAttributesBuilder()
218 .setTailEquipmentId(m.getConnectionMapLcp());
219 ontTp1Bldr.setXpdrNetworkAttributes(xpdrNwAttrBldr.build());
220 ocnTp1Bldr.setTpType(OpenroadmTpType.XPONDERNETWORK);
221 org.opendaylight.yang.gen.v1.http.transportpce.topology.rev190625.TerminationPoint1Builder tpceTp1Bldr =
222 new org.opendaylight.yang.gen.v1.http.transportpce.topology.rev190625.TerminationPoint1Builder()
223 .setAssociatedConnectionMapPort(m.getConnectionMapLcp());
224 ietfTpBldr.addAugmentation(TerminationPoint1.class, ontTp1Bldr.build())
225 .addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
226 .TerminationPoint1.class, ocnTp1Bldr.build())
227 .addAugmentation(org.opendaylight.yang.gen.v1.http.transportpce.topology.rev190625
228 .TerminationPoint1.class, tpceTp1Bldr.build());
229 tpList.add(ietfTpBldr.build());
230 } else if (m.getPortQual().equals("xpdr-client")) {
231 XpdrClientAttributesBuilder xpdrNwAttrBldr = new XpdrClientAttributesBuilder()
232 .setTailEquipmentId(m.getConnectionMapLcp());
233 ontTp1Bldr.setXpdrClientAttributes(xpdrNwAttrBldr.build());
234 ocnTp1Bldr.setTpType(OpenroadmTpType.XPONDERCLIENT);
235 org.opendaylight.yang.gen.v1.http.transportpce.topology.rev190625.TerminationPoint1Builder tpceTp1Bldr =
236 new org.opendaylight.yang.gen.v1.http.transportpce.topology.rev190625.TerminationPoint1Builder()
237 .setAssociatedConnectionMapPort(m.getConnectionMapLcp());
238 ietfTpBldr.addAugmentation(TerminationPoint1.class, ontTp1Bldr.build())
239 .addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
240 .TerminationPoint1.class, ocnTp1Bldr.build())
241 .addAugmentation(org.opendaylight.yang.gen.v1.http.transportpce.topology.rev190625
242 .TerminationPoint1.class, tpceTp1Bldr.build());
243 tpList.add(ietfTpBldr.build());
247 // Create ietf node augmentation to support ietf tp-list
248 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
249 .Node1Builder ietfNode1 =
250 new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1Builder()
251 .setTerminationPoint(tpList);
252 ietfNodeBldr.addAugmentation(
253 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1.class,
258 private NodeBuilder createDegree(String degNb, List<Mapping> degListMap, String nodeId) {
260 List<TerminationPoint> tpList = new ArrayList<>();
261 TerminationPointBuilder ietfTpBldr;
262 for (Mapping m : degListMap) {
263 ietfTpBldr = createTpBldr(m.getLogicalConnectionPoint());
264 // Add openroadm-network-topology tp augmentations
265 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
266 .TerminationPoint1Builder ocnTp1Bldr = new org.opendaylight.yang.gen.v1.http.org.openroadm.common
267 .network.rev181130.TerminationPoint1Builder();
268 switch (m.getPortDirection()) {
269 case "bidirectional":
270 ocnTp1Bldr.setTpType(OpenroadmTpType.DEGREETXRXTTP);
273 ocnTp1Bldr.setTpType(OpenroadmTpType.DEGREETXTTP);
276 ocnTp1Bldr.setTpType(OpenroadmTpType.DEGREERXTTP);
279 LOG.error("impossible to set tp-type to {}", m.getLogicalConnectionPoint());
281 ietfTpBldr.addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
282 .TerminationPoint1.class, ocnTp1Bldr.build());
283 tpList.add(ietfTpBldr.build());
285 // Add CTP to tp-list
286 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.TerminationPoint1Builder ocnTp1Bldr =
287 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.TerminationPoint1Builder()
288 .setTpType(OpenroadmTpType.DEGREETXRXCTP);
289 ietfTpBldr = createTpBldr(degNb + "-CTP-TXRX").addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm
290 .common.network.rev181130.TerminationPoint1.class, ocnTp1Bldr.build());
291 tpList.add(ietfTpBldr.build());
293 // Create ietf node augmentation to support ietf tp-list
294 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
295 .Node1Builder ietfNode1 =
296 new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1Builder()
297 .setTerminationPoint(tpList);
300 String nodeIdtopo = new StringBuilder().append(nodeId).append("-").append(degNb).toString();
301 // set degree-attributes
302 DegreeAttributesBuilder degAttBldr = new DegreeAttributesBuilder()
303 .setDegreeNumber(new Integer(degNb.split("DEG")[1]))
304 .setAvailableWavelengths(create96AvalWaveDegree());
305 // Create openroadm-network-topo augmentation to set node type to DEGREE
306 Node1Builder ontNode1Bldr = new Node1Builder()
307 .setDegreeAttributes(degAttBldr.build());
308 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1Builder ocnNode1Bldr =
309 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1Builder()
310 .setNodeType(OpenroadmNodeType.DEGREE);
312 // Create ietf node setting supporting-node data
313 NodeBuilder ietfNodeBldr = createTopoLayerNode(nodeId)
314 .setNodeId(new NodeId(nodeIdtopo))
315 .withKey((new NodeKey(new NodeId(nodeIdtopo))))
316 .addAugmentation(Node1.class, ontNode1Bldr.build())
317 .addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
318 .Node1.class, ocnNode1Bldr.build())
320 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1.class,
325 private NodeBuilder createSrg(String srgNb, List<Mapping> srgListMap, String nodeId) {
327 List<TerminationPoint> tpList = new ArrayList<>();
328 TerminationPointBuilder ietfTpBldr;
329 for (Mapping m : srgListMap) {
330 ietfTpBldr = createTpBldr(m.getLogicalConnectionPoint());
331 // Add openroadm-network-topology tp augmentations
332 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
333 .TerminationPoint1Builder ocnTp1Bldr = new org.opendaylight.yang.gen.v1.http.org.openroadm.common
334 .network.rev181130.TerminationPoint1Builder();
335 switch (m.getPortDirection()) {
336 case "bidirectional":
337 ocnTp1Bldr.setTpType(OpenroadmTpType.SRGTXRXPP);
340 ocnTp1Bldr.setTpType(OpenroadmTpType.SRGTXPP);
343 ocnTp1Bldr.setTpType(OpenroadmTpType.SRGRXPP);
346 LOG.error("impossible to set tp-type to {}", m.getLogicalConnectionPoint());
348 ietfTpBldr.addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
349 .TerminationPoint1.class, ocnTp1Bldr.build());
350 tpList.add(ietfTpBldr.build());
353 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.TerminationPoint1Builder ocnTp1Bldr =
354 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.TerminationPoint1Builder()
355 .setTpType(OpenroadmTpType.SRGTXRXCP);
356 ietfTpBldr = createTpBldr(srgNb + "-CP-TXRX").addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm
357 .common.network.rev181130.TerminationPoint1.class, ocnTp1Bldr.build());
358 tpList.add(ietfTpBldr.build());
360 // Create ietf node augmentation to support ietf tp-list
361 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
362 .Node1Builder ietfNode1 =
363 new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1Builder()
364 .setTerminationPoint(tpList);
367 String nodeIdtopo = new StringBuilder().append(nodeId).append("-").append(srgNb).toString();
368 // set srg-attributes
369 SrgAttributesBuilder srgAttrBldr = new SrgAttributesBuilder().setAvailableWavelengths(create96AvalWaveSrg());
370 // Create openroadm-network-topo augmentation to set node type to DEGREE
371 Node1Builder ontNode1Bldr = new Node1Builder()
372 .setSrgAttributes(srgAttrBldr.build());
373 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1Builder ocnNode1Bldr =
374 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1Builder()
375 .setNodeType(OpenroadmNodeType.SRG);
377 // Create ietf node setting supporting-node data
378 NodeBuilder ietfNodeBldr = createTopoLayerNode(nodeId)
379 .setNodeId(new NodeId(nodeIdtopo))
380 .withKey((new NodeKey(new NodeId(nodeIdtopo))))
381 .addAugmentation(Node1.class, ontNode1Bldr.build())
382 .addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1.class,
383 ocnNode1Bldr.build())
385 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1.class,
390 private NodeBuilder createTopoLayerNode(String nodeId) {
391 // Sets the value of Network-ref and Node-ref as a part of the supporting node
393 SupportingNodeBuilder supportbldr = new SupportingNodeBuilder()
394 .withKey(new SupportingNodeKey(new NetworkId(NetworkUtils.UNDERLAY_NETWORK_ID), new NodeId(nodeId)))
395 .setNetworkRef(new NetworkId(NetworkUtils.UNDERLAY_NETWORK_ID))
396 .setNodeRef(new NodeId(nodeId));
397 ArrayList<SupportingNode> supportlist = new ArrayList<>();
398 supportlist.add(supportbldr.build());
399 NodeBuilder nodebldr = new NodeBuilder().setSupportingNode(supportlist);
404 // This method returns a generic termination point builder for a given tpid
405 private TerminationPointBuilder createTpBldr(String tpId) {
406 TpId tp = new TpId(tpId);
407 TerminationPointKey tpKey = new TerminationPointKey(tp);
408 TerminationPointBuilder tpBldr = new TerminationPointBuilder().withKey(tpKey).setTpId(tp);
412 private LinkBuilder createLink(String srcNode, String destNode, String srcTp, String destTp) {
414 SourceBuilder ietfSrcLinkBldr = new SourceBuilder().setSourceNode(new NodeId(srcNode)).setSourceTp(srcTp);
415 //create destination link
416 DestinationBuilder ietfDestLinkBldr = new DestinationBuilder()
417 .setDestNode(new NodeId(destNode))
419 LinkBuilder ietfLinkBldr = new LinkBuilder()
420 .setSource(ietfSrcLinkBldr.build())
421 .setDestination(ietfDestLinkBldr.build())
422 .setLinkId(LinkIdUtil.buildLinkId(srcNode, srcTp, destNode, destTp));
423 ietfLinkBldr.withKey(new LinkKey(ietfLinkBldr.getLinkId()));
427 private List<Link> createNewLinks(List<Node> nodes) {
428 List<Link> links = new ArrayList<>();
433 for (int i = 0; i < nodes.size() - 1; i++) {
434 for (int j = i + 1; j < nodes.size(); j++) {
435 srcNode = nodes.get(i).getNodeId().getValue();
436 destNode = nodes.get(j).getNodeId().getValue();
438 srcTp = nodes.get(i).augmentation(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf
439 .network.topology.rev180226.Node1.class).getTerminationPoint().stream()
440 .filter(tp -> tp.getTpId().getValue().contains("CP") || tp.getTpId().getValue().contains("CTP"))
441 .findFirst().get().getTpId().getValue();
442 destTp = nodes.get(j).augmentation(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf
443 .network.topology.rev180226.Node1.class).getTerminationPoint().stream()
444 .filter(tp -> tp.getTpId().getValue().contains("CP") || tp.getTpId().getValue().contains("CTP"))
445 .findFirst().get().getTpId().getValue();
446 Link1Builder ocnAzLinkBldr = new Link1Builder();
447 int srcNodeType = nodes.get(i).augmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common
448 .network.rev181130.Node1.class).getNodeType().getIntValue();
449 int destNodeType = nodes.get(j).augmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common
450 .network.rev181130.Node1.class).getNodeType().getIntValue();
451 //The previous 2 lines generate warnings.
452 //Casting (nodes.get(i or j).augmentation(Node1.class)) to
453 //(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1)
454 //breaks the portmapping
455 if (srcNodeType == 11 && destNodeType == 11) {
456 ocnAzLinkBldr.setLinkType(OpenroadmLinkType.EXPRESSLINK);
457 } else if (srcNodeType == 11 && destNodeType == 12) {
458 ocnAzLinkBldr.setLinkType(OpenroadmLinkType.DROPLINK);
459 } else if (srcNodeType == 12 && destNodeType == 11) {
460 ocnAzLinkBldr.setLinkType(OpenroadmLinkType.ADDLINK);
465 Link1Builder ocnZaLinkBldr = new Link1Builder();
466 if (srcNodeType == 11 && destNodeType == 11) {
467 ocnZaLinkBldr.setLinkType(OpenroadmLinkType.EXPRESSLINK);
468 } else if (destNodeType == 11 && srcNodeType == 12) {
469 ocnZaLinkBldr.setLinkType(OpenroadmLinkType.DROPLINK);
470 } else if (destNodeType == 12 && srcNodeType == 11) {
471 ocnZaLinkBldr.setLinkType(OpenroadmLinkType.ADDLINK);
475 // set opposite link augmentations
476 LinkBuilder ietfAzLinkBldr = createLink(srcNode, destNode, srcTp, destTp);
477 LinkBuilder ietfZaLinkBldr = createLink(destNode, srcNode, destTp, srcTp);
478 ocnAzLinkBldr.setOppositeLink(ietfZaLinkBldr.getLinkId());
479 ietfAzLinkBldr.addAugmentation(Link1.class, ocnAzLinkBldr.build())
480 .addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
481 .Link1.class, ocnAzLinkBldr.build());
482 ocnZaLinkBldr.setOppositeLink(ietfAzLinkBldr.getLinkId());
483 ietfZaLinkBldr.addAugmentation(Link1.class, ocnZaLinkBldr.build());
484 links.add(ietfAzLinkBldr.build());
485 links.add(ietfZaLinkBldr.build());
491 // This method returns the linkBuilder object for given source and destination
492 public static boolean deleteLink(String srcNode, String dstNode, String srcTp, String destTp,
493 NetworkTransactionService networkTransactionService) {
494 LOG.info("deleting link for {}-{}", srcNode, dstNode);
495 LinkId linkId = LinkIdUtil.buildLinkId(srcNode, srcTp, dstNode, destTp);
496 if (deleteLinkLinkId(linkId, networkTransactionService)) {
497 LOG.debug("Link Id {} updated to have admin state down");
500 LOG.debug("Link Id not found for Source {} and Dest {}", srcNode, dstNode);
505 // This method returns the linkBuilder object for given source and destination
506 public static boolean deleteLinkLinkId(LinkId linkId , NetworkTransactionService networkTransactionService) {
507 LOG.info("deleting link for LinkId: {}", linkId);
509 InstanceIdentifierBuilder<Link> linkIID = InstanceIdentifier.builder(Networks.class).child(Network.class,
510 new NetworkKey(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID))).augmentation(Network1.class)
511 .child(Link.class, new LinkKey(linkId));
512 java.util.Optional<Link> link =
513 networkTransactionService.read(LogicalDatastoreType.CONFIGURATION,linkIID.build()).get();
514 if (link.isPresent()) {
515 LinkBuilder linkBuilder = new LinkBuilder(link.get());
516 org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130
517 .Link1Builder link1Builder = new org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology
518 .rev181130.Link1Builder(linkBuilder.augmentation(org.opendaylight.yang.gen.v1.http.org.openroadm
519 .network.topology.rev181130.Link1.class)).setAdministrativeState(State.OutOfService);
520 linkBuilder.removeAugmentation(Link1.class).addAugmentation(org.opendaylight.yang.gen.v1.http.org
521 .openroadm.network.topology.rev181130.Link1.class,link1Builder.build());
522 networkTransactionService.merge(LogicalDatastoreType.CONFIGURATION, linkIID.build(),
523 linkBuilder.build());
524 networkTransactionService.commit().get(1, TimeUnit.SECONDS);
527 LOG.error("No link found for given LinkId: {}",
532 } catch (InterruptedException | ExecutionException | TimeoutException e) {
533 LOG.error(e.getMessage(), e);
538 private List<AvailableWavelengths> create96AvalWaveDegree() {
539 List<AvailableWavelengths> waveList = new ArrayList<>();
541 for (int i = 1; i < 97; i++) {
542 AvailableWavelengthsBuilder avalBldr = new AvailableWavelengthsBuilder()
544 .withKey(new AvailableWavelengthsKey((long) i));
545 waveList.add(avalBldr.build());
551 private List<org.opendaylight.yang.gen.v1.http.org.openroadm.srg.rev181130.srg.node
552 .attributes.AvailableWavelengths> create96AvalWaveSrg() {
554 List<org.opendaylight.yang.gen.v1.http.org.openroadm.srg.rev181130.srg.node.attributes
555 .AvailableWavelengths> waveList =
558 for (int i = 1; i < 97; i++) {
559 org.opendaylight.yang.gen.v1.http.org.openroadm.srg.rev181130.srg.node.attributes
560 .AvailableWavelengthsBuilder avalBldr =
561 new org.opendaylight.yang.gen.v1.http.org.openroadm.srg.rev181130.srg.node.attributes
562 .AvailableWavelengthsBuilder()
565 new org.opendaylight.yang.gen.v1.http.org.openroadm.srg.rev181130.srg.node.attributes
566 .AvailableWavelengthsKey((long) i));
567 waveList.add(avalBldr.build());