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.Comparator;
13 import java.util.HashMap;
14 import java.util.List;
16 import java.util.concurrent.ExecutionException;
17 import java.util.concurrent.TimeUnit;
18 import java.util.concurrent.TimeoutException;
19 import java.util.stream.Collectors;
21 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
22 import org.opendaylight.transportpce.common.NetworkUtils;
23 import org.opendaylight.transportpce.common.network.NetworkTransactionService;
24 import org.opendaylight.transportpce.networkmodel.dto.TopologyShard;
25 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev200128.network.Nodes;
26 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev200128.network.nodes.Mapping;
27 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Link1;
28 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Link1Builder;
29 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.state.types.rev181130.State;
30 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.types.rev181019.NodeTypes;
31 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.types.rev181019.XpdrNodeTypes;
32 import org.opendaylight.yang.gen.v1.http.org.openroadm.degree.rev181130.degree.node.attributes.AvailableWavelengths;
33 import org.opendaylight.yang.gen.v1.http.org.openroadm.degree.rev181130.degree.node.attributes.AvailableWavelengthsBuilder;
34 import org.opendaylight.yang.gen.v1.http.org.openroadm.degree.rev181130.degree.node.attributes.AvailableWavelengthsKey;
35 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.Node1;
36 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.Node1Builder;
37 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.DegreeAttributes;
38 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.DegreeAttributesBuilder;
39 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.SrgAttributes;
40 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.SrgAttributesBuilder;
41 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev181130.OpenroadmLinkType;
42 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev181130.OpenroadmNodeType;
43 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev181130.OpenroadmTpType;
44 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NetworkId;
45 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.Networks;
46 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NodeId;
47 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.Network;
48 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.NetworkKey;
49 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.Node;
50 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.NodeBuilder;
51 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.NodeKey;
52 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.node.SupportingNode;
53 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.node.SupportingNodeBuilder;
54 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.node.SupportingNodeKey;
55 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.LinkId;
56 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Network1;
57 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.TpId;
58 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.Link;
59 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.LinkBuilder;
60 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.LinkKey;
61 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.link.DestinationBuilder;
62 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.link.SourceBuilder;
63 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPoint;
64 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPointBuilder;
65 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPointKey;
66 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
67 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier.InstanceIdentifierBuilder;
68 import org.opendaylight.yangtools.yang.common.Uint16;
69 import org.opendaylight.yangtools.yang.common.Uint32;
70 import org.slf4j.Logger;
71 import org.slf4j.LoggerFactory;
73 public final class OpenRoadmTopology {
75 private static final Logger LOG = LoggerFactory.getLogger(OpenRoadmTopology.class);
77 private OpenRoadmTopology() {
80 public static TopologyShard createTopologyShard(Nodes mappingNode) {
83 List<Node> nodes = new ArrayList<>();
84 List<Link> links = new ArrayList<>();
86 // Check if node is ROADM
87 if (NodeTypes.Rdm.getIntValue() == mappingNode.getNodeInfo().getNodeType().getIntValue()) {
88 LOG.info("creating rdm node in openroadmtopology for node {}", mappingNode.getNodeId());
89 // transform flat mapping list to per degree and per srg mapping lists
90 Map<String, List<Mapping>> mapDeg = new HashMap<>();
91 Map<String, List<Mapping>> mapSrg = new HashMap<>();
92 List<Mapping> mappingList = new ArrayList<>(mappingNode.getMapping());
93 mappingList.sort(Comparator.comparing(Mapping::getLogicalConnectionPoint));
95 List<String> nodeShardList = new ArrayList<>();
96 for (Mapping mapping : mappingList) {
97 String str = mapping.getLogicalConnectionPoint().split("-")[0];
98 if (!nodeShardList.contains(str)) {
99 nodeShardList.add(str);
102 for (String str : nodeShardList) {
103 List<Mapping> interList = mappingList.stream().filter(x -> x.getLogicalConnectionPoint().contains(str))
104 .collect(Collectors.toList());
105 if (str.contains("DEG")) {
106 mapDeg.put(str, interList);
107 } else if (str.contains("SRG")) {
108 mapSrg.put(str, interList);
110 LOG.error("unknown element");
113 // create degree nodes
114 for (Map.Entry<String, List<Mapping>> entry : mapDeg.entrySet()) {
115 NodeBuilder ietfNode = createDegree(entry.getKey(), entry.getValue(), mappingNode.getNodeId(),
116 mappingNode.getNodeInfo().getNodeClli());
117 nodes.add(ietfNode.build());
120 for (Map.Entry<String, List<Mapping>> entry : mapSrg.entrySet()) {
121 NodeBuilder ietfNode = createSrg(entry.getKey(), entry.getValue(), mappingNode.getNodeId(),
122 mappingNode.getNodeInfo().getNodeClli());
123 nodes.add(ietfNode.build());
126 numOfDegrees = mapDeg.size();
127 numOfSrgs = mapSrg.size();
129 LOG.info("adding links numOfDegrees={} numOfSrgs={}", numOfDegrees, numOfSrgs);
130 links.addAll(createNewLinks(nodes));
131 LOG.info("created nodes/links: {}/{}", nodes.size(), links.size());
132 return new TopologyShard(nodes, links);
133 } else if (NodeTypes.Xpdr.getIntValue() == mappingNode.getNodeInfo().getNodeType().getIntValue()) {
134 // Check if node is Xpdr is a Transponder
135 List<Mapping> networkMappings = mappingNode.getMapping().stream().filter(k -> k.getLogicalConnectionPoint()
136 .contains("NETWORK")).collect(Collectors.toList());
137 List<Integer> tpdrList = new ArrayList<>();
138 for (Mapping mapping : networkMappings) {
139 List<Mapping> extractedMappings = null;
140 Integer xpdrNb = Integer.parseInt(mapping.getLogicalConnectionPoint().split("XPDR")[1].split("-")[0]);
141 if (!tpdrList.contains(xpdrNb)) {
142 tpdrList.add(xpdrNb);
143 extractedMappings = mappingNode.getMapping().stream().filter(lcp -> lcp
144 .getLogicalConnectionPoint().contains("XPDR" + xpdrNb)).collect(Collectors.toList());
145 NodeBuilder ietfNode;
146 if (mapping.getXponderType() == null
147 || XpdrNodeTypes.Tpdr.getIntValue() == mapping.getXponderType().getIntValue()) {
148 LOG.info("creating xpdr node {} of type Tpdr in openroadm-topology",
149 mappingNode.getNodeId() + "-XPDR" + xpdrNb);
150 ietfNode = createXpdr(mappingNode.getNodeId(), mappingNode.getNodeInfo().getNodeClli(), xpdrNb,
151 extractedMappings, false);
152 nodes.add(ietfNode.build());
153 } else if (XpdrNodeTypes.Mpdr.getIntValue() == mapping.getXponderType().getIntValue()
154 || XpdrNodeTypes.Switch.getIntValue() == mapping.getXponderType().getIntValue()) {
155 LOG.info("creating xpdr node {} of type {} in openroadm-topology",
156 mappingNode.getNodeId() + "-XPDR" + xpdrNb, mapping.getXponderType().getName());
157 ietfNode = createXpdr(mappingNode.getNodeId(), mappingNode.getNodeInfo().getNodeClli(), xpdrNb,
158 extractedMappings, true);
159 nodes.add(ietfNode.build());
163 if (nodes.isEmpty()) {
166 return new TopologyShard(nodes, links);
169 LOG.error("Device node Type not managed yet");
173 private static NodeBuilder createXpdr(String nodeId, String clli, Integer xpdrNb, List<Mapping> mappings,
175 // Create openroadm-network-topo augmentation to set node type to Xponder
176 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1 ocnNode1 =
177 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1Builder()
178 .setNodeType(OpenroadmNodeType.XPONDER).build();
179 // Create ietf node setting supporting-node data
180 NodeBuilder ietfNodeBldr = createTopoLayerNode(nodeId, clli);
182 String nodeIdtopo = new StringBuilder().append(nodeId).append("-XPDR").append(xpdrNb).toString();
183 ietfNodeBldr.setNodeId(new NodeId(nodeIdtopo))
184 .withKey((new NodeKey(new NodeId(nodeIdtopo))))
185 .addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
186 .Node1.class, ocnNode1);
189 List<TerminationPoint> tpList = new ArrayList<>();
190 TerminationPointBuilder ietfTpBldr;
191 for (Mapping m : mappings) {
193 ietfTpBldr = createTpBldr(m.getLogicalConnectionPoint());
194 // Add openroadm-network-topology tp augmentations
195 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
196 .TerminationPoint1Builder ocnTp1Bldr = new org.opendaylight.yang.gen.v1.http.org.openroadm
197 .common.network.rev181130.TerminationPoint1Builder();
198 if (m.getPortQual().equals("xpdr-network")) {
199 ocnTp1Bldr.setTpType(OpenroadmTpType.XPONDERNETWORK);
200 org.opendaylight.yang.gen.v1.http.transportpce.topology.rev200129.TerminationPoint1 tpceTp1 =
201 new org.opendaylight.yang.gen.v1.http.transportpce.topology.rev200129
202 .TerminationPoint1Builder().setAssociatedConnectionMapPort(m.getConnectionMapLcp()).build();
204 .addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network
205 .rev181130.TerminationPoint1.class, ocnTp1Bldr.build())
206 .addAugmentation(org.opendaylight.yang.gen.v1.http.transportpce.topology.rev200129
207 .TerminationPoint1.class, tpceTp1);
208 tpList.add(ietfTpBldr.build());
209 } else if (m.getPortQual().equals("xpdr-client")) {
210 ocnTp1Bldr.setTpType(OpenroadmTpType.XPONDERCLIENT);
211 org.opendaylight.yang.gen.v1.http.transportpce.topology.rev200129.TerminationPoint1 tpceTp1 =
212 new org.opendaylight.yang.gen.v1.http.transportpce.topology.rev200129
213 .TerminationPoint1Builder().setAssociatedConnectionMapPort(m.getConnectionMapLcp()).build();
215 .addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
216 .TerminationPoint1.class, ocnTp1Bldr.build())
217 .addAugmentation(org.opendaylight.yang.gen.v1.http.transportpce.topology.rev200129
218 .TerminationPoint1.class, tpceTp1);
219 tpList.add(ietfTpBldr.build());
222 if (m.getPortQual().equals("xpdr-network") || m.getPortQual().equals("switch-network")) {
223 ietfTpBldr = createTpBldr(m.getLogicalConnectionPoint());
224 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
225 .TerminationPoint1Builder ocnTp1Bldr = new org.opendaylight.yang.gen.v1.http.org.openroadm
226 .common.network.rev181130.TerminationPoint1Builder().setTpType(OpenroadmTpType.XPONDERNETWORK);
228 .addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network
229 .rev181130.TerminationPoint1.class, ocnTp1Bldr.build());
230 tpList.add(ietfTpBldr.build());
234 // Create ietf node augmentation to support ietf tp-list
235 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
236 .Node1Builder ietfNode1 = new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology
237 .rev180226.Node1Builder()
238 .setTerminationPoint(tpList);
239 ietfNodeBldr.addAugmentation(
240 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1.class,
245 private static NodeBuilder createDegree(String degNb, List<Mapping> degListMap, String nodeId, String clli) {
247 List<TerminationPoint> tpList = new ArrayList<>();
248 TerminationPointBuilder ietfTpBldr;
249 for (Mapping m : degListMap) {
250 ietfTpBldr = createTpBldr(m.getLogicalConnectionPoint());
251 // Add openroadm-common-network tp type augmentations
252 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
253 .TerminationPoint1Builder ocnTp1Bldr = new org.opendaylight.yang.gen.v1.http.org.openroadm.common
254 .network.rev181130.TerminationPoint1Builder();
255 switch (m.getPortDirection()) {
256 case "bidirectional":
257 ocnTp1Bldr.setTpType(OpenroadmTpType.DEGREETXRXTTP);
260 ocnTp1Bldr.setTpType(OpenroadmTpType.DEGREETXTTP);
263 ocnTp1Bldr.setTpType(OpenroadmTpType.DEGREERXTTP);
266 LOG.error("impossible to set tp-type to {}", m.getLogicalConnectionPoint());
268 ietfTpBldr.addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
269 .TerminationPoint1.class, ocnTp1Bldr.build());
270 tpList.add(ietfTpBldr.build());
272 // Add CTP to tp-list
273 ietfTpBldr = createTpBldr(degNb + "-CTP-TXRX");
274 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.TerminationPoint1 ocnTp1 =
275 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.TerminationPoint1Builder()
276 .setTpType(OpenroadmTpType.DEGREETXRXCTP).build();
277 ietfTpBldr.addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
278 .TerminationPoint1.class, ocnTp1);
279 tpList.add(ietfTpBldr.build());
280 // set degree-attributes
281 DegreeAttributes degAtt = new DegreeAttributesBuilder()
282 .setDegreeNumber(Uint16.valueOf(degNb.split("DEG")[1]))
283 .setAvailableWavelengths(create96AvalWaveDegree()).build();
284 // Create ietf node augmentation to support ietf tp-list
285 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
286 .Node1Builder ietfNode1 = new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology
287 .rev180226.Node1Builder()
288 .setTerminationPoint(tpList);
290 String nodeIdtopo = new StringBuilder().append(nodeId).append("-").append(degNb).toString();
291 Node1 ontNode1 = new Node1Builder().setDegreeAttributes(degAtt).build();
292 // Create openroadm-common-network augmentation to set node type to DEGREE
293 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1 ocnNode1 =
294 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1Builder()
295 .setNodeType(OpenroadmNodeType.DEGREE).build();
296 // Create ietf node setting supporting-node data
297 return createTopoLayerNode(nodeId, clli)
298 .setNodeId(new NodeId(nodeIdtopo))
299 .withKey((new NodeKey(new NodeId(nodeIdtopo))))
300 .addAugmentation(Node1.class, ontNode1)
301 .addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
302 .Node1.class, ocnNode1)
303 .addAugmentation(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology
304 .rev180226.Node1.class,
308 private static NodeBuilder createSrg(String srgNb, List<Mapping> srgListMap, String nodeId, String clli) {
310 List<TerminationPoint> tpList = new ArrayList<>();
311 TerminationPointBuilder ietfTpBldr;
312 for (Mapping m : srgListMap) {
313 ietfTpBldr = createTpBldr(m.getLogicalConnectionPoint());
314 // Add openroadm-common-network tp type augmentations
315 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
316 .TerminationPoint1Builder ocnTp1Bldr = new org.opendaylight.yang.gen.v1.http.org.openroadm.common
317 .network.rev181130.TerminationPoint1Builder();
318 switch (m.getPortDirection()) {
319 case "bidirectional":
320 ocnTp1Bldr.setTpType(OpenroadmTpType.SRGTXRXPP);
323 ocnTp1Bldr.setTpType(OpenroadmTpType.SRGTXPP);
326 ocnTp1Bldr.setTpType(OpenroadmTpType.SRGRXPP);
329 LOG.error("impossible to set tp-type to {}", m.getLogicalConnectionPoint());
331 ietfTpBldr.addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
332 .TerminationPoint1.class, ocnTp1Bldr.build());
333 tpList.add(ietfTpBldr.build());
336 ietfTpBldr = createTpBldr(srgNb + "-CP-TXRX");
337 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
338 .TerminationPoint1 ocnTp1 = new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network
339 .rev181130.TerminationPoint1Builder().setTpType(OpenroadmTpType.SRGTXRXCP).build();
340 ietfTpBldr.addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
341 .TerminationPoint1.class, ocnTp1);
342 tpList.add(ietfTpBldr.build());
343 // Create openroadm-common-network augmentation to set node type to SRG
344 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1 ocnNode1 =
345 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1Builder()
346 .setNodeType(OpenroadmNodeType.SRG).build();
347 // set srg-attributes
348 SrgAttributes srgAttr = new SrgAttributesBuilder().setAvailableWavelengths(create96AvalWaveSrg()).build();
349 Node1 ontNode1 = new Node1Builder().setSrgAttributes(srgAttr).build();
350 // Create ietf node augmentation to support ietf tp-list
351 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
352 .Node1Builder ietfNode1 = new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology
353 .rev180226.Node1Builder()
354 .setTerminationPoint(tpList);
355 // Create ietf node setting supporting-node data
356 String nodeIdtopo = new StringBuilder().append(nodeId).append("-").append(srgNb).toString();
357 return createTopoLayerNode(nodeId, clli)
358 .setNodeId(new NodeId(nodeIdtopo))
359 .withKey((new NodeKey(new NodeId(nodeIdtopo))))
360 .addAugmentation(Node1.class, ontNode1)
361 .addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
362 .Node1.class, ocnNode1)
363 .addAugmentation(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
364 .Node1.class, ietfNode1.build());
367 private static NodeBuilder createTopoLayerNode(String nodeId, String clli) {
368 // Sets the value of Network-ref and Node-ref as a part of the supporting node
370 SupportingNodeBuilder support1bldr = new SupportingNodeBuilder()
371 .withKey(new SupportingNodeKey(new NetworkId(NetworkUtils.UNDERLAY_NETWORK_ID), new NodeId(nodeId)))
372 .setNetworkRef(new NetworkId(NetworkUtils.UNDERLAY_NETWORK_ID))
373 .setNodeRef(new NodeId(nodeId));
374 SupportingNodeBuilder support2bldr = new SupportingNodeBuilder()
375 .withKey(new SupportingNodeKey(new NetworkId(NetworkUtils.CLLI_NETWORK_ID), new NodeId(clli)))
376 .setNetworkRef(new NetworkId(NetworkUtils.CLLI_NETWORK_ID))
377 .setNodeRef(new NodeId(clli));
378 ArrayList<SupportingNode> supportlist = new ArrayList<>();
379 supportlist.add(support1bldr.build());
380 supportlist.add(support2bldr.build());
381 return new NodeBuilder().setSupportingNode(supportlist);
385 // This method returns a generic termination point builder for a given tpid
386 private static TerminationPointBuilder createTpBldr(String tpId) {
387 TpId tp = new TpId(tpId);
388 return new TerminationPointBuilder().withKey(new TerminationPointKey(tp)).setTpId(tp);
391 private static LinkBuilder createLink(String srcNode, String destNode, String srcTp, String destTp) {
393 SourceBuilder ietfSrcLinkBldr = new SourceBuilder().setSourceNode(new NodeId(srcNode)).setSourceTp(srcTp);
394 //create destination link
395 DestinationBuilder ietfDestLinkBldr = new DestinationBuilder().setDestNode(new NodeId(destNode))
397 LinkId linkId = LinkIdUtil.buildLinkId(srcNode, srcTp, destNode, destTp);
398 return new LinkBuilder()
399 .setSource(ietfSrcLinkBldr.build())
400 .setDestination(ietfDestLinkBldr.build())
402 .withKey(new LinkKey(linkId));
405 private static List<Link> createNewLinks(List<Node> nodes) {
406 List<Link> links = new ArrayList<>();
411 for (int i = 0; i < nodes.size() - 1; i++) {
412 for (int j = i + 1; j < nodes.size(); j++) {
413 srcNode = nodes.get(i).getNodeId().getValue();
414 destNode = nodes.get(j).getNodeId().getValue();
416 srcTp = nodes.get(i).augmentation(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf
417 .network.topology.rev180226.Node1.class).getTerminationPoint().stream()
418 .filter(tp -> tp.getTpId().getValue().contains("CP") || tp.getTpId().getValue().contains("CTP"))
419 .findFirst().get().getTpId().getValue();
420 destTp = nodes.get(j).augmentation(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf
421 .network.topology.rev180226.Node1.class).getTerminationPoint().stream()
422 .filter(tp -> tp.getTpId().getValue().contains("CP") || tp.getTpId().getValue().contains("CTP"))
423 .findFirst().get().getTpId().getValue();
424 Link1Builder ocnAzLinkBldr = new Link1Builder();
425 int srcNodeType = nodes.get(i).augmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common
426 .network.rev181130.Node1.class).getNodeType().getIntValue();
427 int destNodeType = nodes.get(j).augmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common
428 .network.rev181130.Node1.class).getNodeType().getIntValue();
429 if (srcNodeType == 11 && destNodeType == 11) {
430 ocnAzLinkBldr.setLinkType(OpenroadmLinkType.EXPRESSLINK);
431 } else if (srcNodeType == 11 && destNodeType == 12) {
432 ocnAzLinkBldr.setLinkType(OpenroadmLinkType.DROPLINK);
433 } else if (srcNodeType == 12 && destNodeType == 11) {
434 ocnAzLinkBldr.setLinkType(OpenroadmLinkType.ADDLINK);
439 Link1Builder ocnZaLinkBldr = new Link1Builder();
440 if (srcNodeType == 11 && destNodeType == 11) {
441 ocnZaLinkBldr.setLinkType(OpenroadmLinkType.EXPRESSLINK);
442 } else if (destNodeType == 11 && srcNodeType == 12) {
443 ocnZaLinkBldr.setLinkType(OpenroadmLinkType.DROPLINK);
444 } else if (destNodeType == 12 && srcNodeType == 11) {
445 ocnZaLinkBldr.setLinkType(OpenroadmLinkType.ADDLINK);
449 // set opposite link augmentations
450 LinkBuilder ietfAzLinkBldr = createLink(srcNode, destNode, srcTp, destTp);
451 LinkBuilder ietfZaLinkBldr = createLink(destNode, srcNode, destTp, srcTp);
452 ocnAzLinkBldr.setOppositeLink(ietfZaLinkBldr.getLinkId());
453 ietfAzLinkBldr.addAugmentation(Link1.class, ocnAzLinkBldr.build());
454 ocnZaLinkBldr.setOppositeLink(ietfAzLinkBldr.getLinkId());
455 ietfZaLinkBldr.addAugmentation(Link1.class, ocnZaLinkBldr.build());
456 links.add(ietfAzLinkBldr.build());
457 links.add(ietfZaLinkBldr.build());
463 // This method returns the linkBuilder object for given source and destination
464 public static boolean deleteLink(String srcNode, String dstNode, String srcTp, String destTp,
465 NetworkTransactionService networkTransactionService) {
466 LOG.info("deleting link for {}-{}", srcNode, dstNode);
467 LinkId linkId = LinkIdUtil.buildLinkId(srcNode, srcTp, dstNode, destTp);
468 if (deleteLinkLinkId(linkId, networkTransactionService)) {
469 LOG.debug("Link Id {} updated to have admin state down", linkId);
472 LOG.debug("Link Id not found for Source {} and Dest {}", srcNode, dstNode);
477 // This method returns the linkBuilder object for given source and destination
478 public static boolean deleteLinkLinkId(LinkId linkId , NetworkTransactionService networkTransactionService) {
479 LOG.info("deleting link for LinkId: {}", linkId.getValue());
481 InstanceIdentifierBuilder<Link> linkIID = InstanceIdentifier.builder(Networks.class).child(Network.class,
482 new NetworkKey(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID))).augmentation(Network1.class)
483 .child(Link.class, new LinkKey(linkId));
484 java.util.Optional<Link> link =
485 networkTransactionService.read(LogicalDatastoreType.CONFIGURATION,linkIID.build()).get();
486 if (link.isPresent()) {
487 LinkBuilder linkBuilder = new LinkBuilder(link.get());
488 org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.Link1Builder link1Builder =
489 new org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.Link1Builder(
490 linkBuilder.augmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130
492 .setAdministrativeState(State.OutOfService);
493 linkBuilder.removeAugmentation(Link1.class)
494 .addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130
495 .Link1.class,link1Builder.build());
496 networkTransactionService.merge(LogicalDatastoreType.CONFIGURATION, linkIID.build(),
497 linkBuilder.build());
498 networkTransactionService.commit().get(1, TimeUnit.SECONDS);
501 LOG.error("No link found for given LinkId: {}",
506 } catch (InterruptedException | ExecutionException | TimeoutException e) {
507 LOG.error("Error deleting link {}", linkId.getValue(), e);
512 private static List<AvailableWavelengths> create96AvalWaveDegree() {
513 List<AvailableWavelengths> waveList = new ArrayList<>();
515 for (int i = 1; i < 97; i++) {
516 AvailableWavelengthsBuilder avalBldr = new AvailableWavelengthsBuilder()
517 .setIndex(Uint32.valueOf(i))
518 .withKey(new AvailableWavelengthsKey(Uint32.valueOf(i)));
519 waveList.add(avalBldr.build());
525 private static List<org.opendaylight.yang.gen.v1.http.org.openroadm.srg.rev181130.srg.node
526 .attributes.AvailableWavelengths> create96AvalWaveSrg() {
528 List<org.opendaylight.yang.gen.v1.http.org.openroadm.srg.rev181130.srg.node.attributes
529 .AvailableWavelengths> waveList = new ArrayList<>();
531 for (int i = 1; i < 97; i++) {
532 org.opendaylight.yang.gen.v1.http.org.openroadm.srg.rev181130.srg.node.attributes
533 .AvailableWavelengthsBuilder avalBldr = new org.opendaylight.yang.gen.v1.http.org.openroadm.srg
534 .rev181130.srg.node.attributes.AvailableWavelengthsBuilder()
535 .setIndex(Uint32.valueOf(i))
536 .withKey(new org.opendaylight.yang.gen.v1.http.org.openroadm.srg.rev181130.srg.node.attributes
537 .AvailableWavelengthsKey(Uint32.valueOf(i)));
538 waveList.add(avalBldr.build());