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;
20 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
21 import org.opendaylight.transportpce.common.NetworkUtils;
22 import org.opendaylight.transportpce.common.fixedflex.GridUtils;
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.rev220316.mapping.Mapping;
26 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220316.network.Nodes;
27 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.Link1;
28 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.Link1Builder;
29 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.state.types.rev191129.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.equipment.states.types.rev191129.AdminStates;
33 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev211210.Node1;
34 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev211210.Node1Builder;
35 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev211210.TerminationPoint1;
36 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev211210.networks.network.node.DegreeAttributes;
37 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev211210.networks.network.node.DegreeAttributesBuilder;
38 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev211210.networks.network.node.SrgAttributes;
39 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev211210.networks.network.node.SrgAttributesBuilder;
40 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev211210.OpenroadmLinkType;
41 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev211210.OpenroadmNodeType;
42 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev211210.OpenroadmTpType;
43 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NetworkId;
44 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.Networks;
45 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NodeId;
46 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.Network;
47 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.NetworkKey;
48 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.Node;
49 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.NodeBuilder;
50 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.NodeKey;
51 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.node.SupportingNode;
52 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.node.SupportingNodeBuilder;
53 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.node.SupportingNodeKey;
54 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.LinkId;
55 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Network1;
56 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.TpId;
57 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.Link;
58 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.LinkBuilder;
59 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.LinkKey;
60 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.link.DestinationBuilder;
61 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.link.SourceBuilder;
62 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPoint;
63 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPointBuilder;
64 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPointKey;
65 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
66 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier.InstanceIdentifierBuilder;
67 import org.opendaylight.yangtools.yang.common.Uint16;
68 import org.slf4j.Logger;
69 import org.slf4j.LoggerFactory;
71 public final class OpenRoadmTopology {
73 private static final Logger LOG = LoggerFactory.getLogger(OpenRoadmTopology.class);
75 private OpenRoadmTopology() {
78 public static TopologyShard createTopologyShard(Nodes mappingNode) {
79 return createTopologyShard(mappingNode, true);
82 public static TopologyShard createTopologyShard(Nodes mappingNode, boolean firstMount) {
85 List<Node> nodes = new ArrayList<>();
86 List<Link> links = new ArrayList<>();
88 // Check if node is ROADM
89 if (NodeTypes.Rdm.getIntValue() == mappingNode.getNodeInfo().getNodeType().getIntValue()) {
90 LOG.info("creating rdm node in openroadmtopology for node {}", mappingNode.getNodeId());
91 // transform flat mapping list to per degree and per srg mapping lists
92 Map<String, List<Mapping>> mapDeg = new HashMap<>();
93 Map<String, List<Mapping>> mapSrg = new HashMap<>();
94 List<Mapping> mappingList = new ArrayList<>(mappingNode.nonnullMapping().values());
95 mappingList.sort(Comparator.comparing(Mapping::getLogicalConnectionPoint));
97 List<String> nodeShardList = new ArrayList<>();
98 for (Mapping mapping : mappingList) {
99 String str = mapping.getLogicalConnectionPoint().split("-")[0];
100 if (!nodeShardList.contains(str)) {
101 nodeShardList.add(str);
104 for (String str : nodeShardList) {
105 List<Mapping> interList = mappingList.stream().filter(x -> x.getLogicalConnectionPoint().contains(str))
106 .collect(Collectors.toList());
107 if (str.contains("DEG")) {
108 mapDeg.put(str, interList);
109 } else if (str.contains("SRG")) {
110 mapSrg.put(str, interList);
112 LOG.error("unknown element");
115 // create degree nodes
116 for (Map.Entry<String, List<Mapping>> entry : mapDeg.entrySet()) {
117 NodeBuilder ietfNode = createDegree(entry.getKey(), entry.getValue(), mappingNode.getNodeId(),
118 mappingNode.getNodeInfo().getNodeClli(), firstMount);
119 nodes.add(ietfNode.build());
122 for (Map.Entry<String, List<Mapping>> entry : mapSrg.entrySet()) {
123 NodeBuilder ietfNode = createSrg(entry.getKey(), entry.getValue(), mappingNode.getNodeId(),
124 mappingNode.getNodeInfo().getNodeClli(), firstMount);
125 nodes.add(ietfNode.build());
128 numOfDegrees = mapDeg.size();
129 numOfSrgs = mapSrg.size();
131 LOG.info("adding links numOfDegrees={} numOfSrgs={}", numOfDegrees, numOfSrgs);
132 links.addAll(createNewLinks(nodes));
133 LOG.info("created nodes/links: {}/{}", nodes.size(), links.size());
134 return new TopologyShard(nodes, links);
135 } else if (NodeTypes.Xpdr.getIntValue() == mappingNode.getNodeInfo().getNodeType().getIntValue()) {
136 // Check if node is Xpdr is a Transponder
137 List<Mapping> networkMappings = mappingNode.nonnullMapping().values()
138 .stream().filter(k -> k.getLogicalConnectionPoint()
139 .contains("NETWORK")).collect(Collectors.toList());
140 List<Integer> tpdrList = new ArrayList<>();
141 for (Mapping mapping : networkMappings) {
142 List<Mapping> extractedMappings = null;
143 Integer xpdrNb = Integer.parseInt(mapping.getLogicalConnectionPoint().split("XPDR")[1].split("-")[0]);
144 if (!tpdrList.contains(xpdrNb)) {
145 tpdrList.add(xpdrNb);
146 extractedMappings = mappingNode.nonnullMapping().values().stream().filter(lcp -> lcp
147 .getLogicalConnectionPoint().contains("XPDR" + xpdrNb)).collect(Collectors.toList());
148 NodeBuilder ietfNode;
149 if (mapping.getXponderType() == null
150 || XpdrNodeTypes.Tpdr.getIntValue() == mapping.getXponderType().getIntValue()) {
151 LOG.info("creating xpdr node {} of type Tpdr in openroadm-topology",
152 mappingNode.getNodeId() + "-XPDR" + xpdrNb);
153 ietfNode = createXpdr(mappingNode.getNodeId(), mappingNode.getNodeInfo().getNodeClli(), xpdrNb,
154 extractedMappings, false);
155 nodes.add(ietfNode.build());
156 } else if (XpdrNodeTypes.Mpdr.getIntValue() == mapping.getXponderType().getIntValue()
157 || XpdrNodeTypes.Switch.getIntValue() == mapping.getXponderType().getIntValue()) {
158 LOG.info("creating xpdr node {} of type {} in openroadm-topology",
159 mappingNode.getNodeId() + "-XPDR" + xpdrNb, mapping.getXponderType().getName());
160 ietfNode = createXpdr(mappingNode.getNodeId(), mappingNode.getNodeInfo().getNodeClli(), xpdrNb,
161 extractedMappings, true);
162 nodes.add(ietfNode.build());
166 if (nodes.isEmpty()) {
169 return new TopologyShard(nodes, links);
172 LOG.error("Device node Type not managed yet");
176 private static NodeBuilder createXpdr(String nodeId, String clli, Integer xpdrNb, List<Mapping> mappings,
178 // Create openroadm-network-topo augmentation to set node type to Xponder
179 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.Node1 ocnNode1 =
180 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.Node1Builder()
181 .setNodeType(OpenroadmNodeType.XPONDER)
182 .setAdministrativeState(AdminStates.InService)
183 .setOperationalState(State.InService)
185 // Create ietf node setting supporting-node data
186 NodeBuilder ietfNodeBldr = createTopoLayerNode(nodeId, clli);
188 String nodeIdtopo = new StringBuilder().append(nodeId).append("-XPDR").append(xpdrNb).toString();
189 ietfNodeBldr.setNodeId(new NodeId(nodeIdtopo))
190 .withKey((new NodeKey(new NodeId(nodeIdtopo))))
191 .addAugmentation(ocnNode1);
194 Map<TerminationPointKey, TerminationPoint> tpMap = new HashMap<>();
195 TerminationPointBuilder ietfTpBldr;
196 for (Mapping m : mappings) {
198 ietfTpBldr = createTpBldr(m.getLogicalConnectionPoint());
199 // Add openroadm-network-topology tp augmentations
200 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.TerminationPoint1Builder
201 ocnTp1Bldr = new org.opendaylight.yang.gen.v1.http
202 .org.openroadm.common.network.rev211210.TerminationPoint1Builder()
203 .setAdministrativeState(TopologyUtils.setNetworkAdminState(m.getPortAdminState()))
204 .setOperationalState(TopologyUtils.setNetworkOperState(m.getPortOperState()));
205 if (m.getPortQual().equals("xpdr-network")) {
206 ocnTp1Bldr.setTpType(OpenroadmTpType.XPONDERNETWORK);
207 org.opendaylight.yang.gen.v1.http.transportpce.topology.rev220123.TerminationPoint1 tpceTp1 =
208 new org.opendaylight.yang.gen.v1.http.transportpce.topology.rev220123.TerminationPoint1Builder()
209 .setAssociatedConnectionMapPort(m.getConnectionMapLcp()).build();
211 .addAugmentation(ocnTp1Bldr.build())
212 .addAugmentation(tpceTp1);
213 TerminationPoint ietfTp = ietfTpBldr.build();
214 tpMap.put(ietfTp.key(),ietfTp);
215 } else if (m.getPortQual().equals("xpdr-client")) {
216 ocnTp1Bldr.setTpType(OpenroadmTpType.XPONDERCLIENT);
217 org.opendaylight.yang.gen.v1.http.transportpce.topology.rev220123.TerminationPoint1 tpceTp1 =
218 new org.opendaylight.yang.gen.v1.http.transportpce.topology.rev220123.TerminationPoint1Builder()
219 .setAssociatedConnectionMapPort(m.getConnectionMapLcp()).build();
221 .addAugmentation(ocnTp1Bldr.build())
222 .addAugmentation(tpceTp1);
223 TerminationPoint ietfTp = ietfTpBldr.build();
224 tpMap.put(ietfTp.key(),ietfTp);
227 if (m.getPortQual().equals("xpdr-network") || m.getPortQual().equals("switch-network")) {
228 ietfTpBldr = createTpBldr(m.getLogicalConnectionPoint());
229 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.TerminationPoint1Builder
230 ocnTp1Bldr = new org.opendaylight.yang.gen.v1.http
231 .org.openroadm.common.network.rev211210.TerminationPoint1Builder()
232 .setTpType(OpenroadmTpType.XPONDERNETWORK)
233 .setAdministrativeState(TopologyUtils.setNetworkAdminState(m.getPortAdminState()))
234 .setOperationalState(TopologyUtils.setNetworkOperState(m.getPortOperState()));
236 .addAugmentation(ocnTp1Bldr.build());
237 TerminationPoint ietfTp = ietfTpBldr.build();
238 tpMap.put(ietfTp.key(),ietfTp);
242 // Create ietf node augmentation to support ietf tp-list
243 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1Builder
244 ietfNode1 = new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
245 .Node1Builder().setTerminationPoint(tpMap);
246 ietfNodeBldr.addAugmentation(ietfNode1.build());
250 private static NodeBuilder createDegree(String degNb, List<Mapping> degListMap, String nodeId, String clli,
251 boolean firstMount) {
253 Map<TerminationPointKey,TerminationPoint> tpMap = new HashMap<>();
254 TerminationPointBuilder ietfTpBldr;
255 for (Mapping m : degListMap) {
256 ietfTpBldr = createTpBldr(m.getLogicalConnectionPoint());
257 // Add openroadm-common-network tp type augmentations
258 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.TerminationPoint1Builder
259 ocnTp1Bldr = new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210
260 .TerminationPoint1Builder()
261 .setAdministrativeState(TopologyUtils.setNetworkAdminState(m.getPortAdminState()))
262 .setOperationalState(TopologyUtils.setNetworkOperState(m.getPortOperState()));
264 // Added states to degree port. TODO: add to mapping relation between abstracted and physical node states
265 switch (m.getPortDirection()) {
266 case "bidirectional":
267 ocnTp1Bldr.setTpType(OpenroadmTpType.DEGREETXRXTTP);
270 ocnTp1Bldr.setTpType(OpenroadmTpType.DEGREETXTTP);
273 ocnTp1Bldr.setTpType(OpenroadmTpType.DEGREERXTTP);
276 LOG.error("impossible to set tp-type to {}", m.getLogicalConnectionPoint());
278 ietfTpBldr.addAugmentation(ocnTp1Bldr.build());
279 TerminationPoint ietfTp = ietfTpBldr.build();
280 tpMap.put(ietfTp.key(),ietfTp);
282 // Add CTP to tp-list + added states. TODO: same comment as before with the relation between states
283 ietfTpBldr = createTpBldr(degNb + "-CTP-TXRX");
284 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.TerminationPoint1 ocnTp1 =
285 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.TerminationPoint1Builder()
286 .setTpType(OpenroadmTpType.DEGREETXRXCTP)
287 .setAdministrativeState(AdminStates.InService)
288 .setOperationalState(State.InService)
290 ietfTpBldr.addAugmentation(ocnTp1);
291 TerminationPoint ietfTp = ietfTpBldr.build();
292 tpMap.put(ietfTp.key(),ietfTp);
293 // set degree-attributes
294 DegreeAttributesBuilder degAttBldr = new DegreeAttributesBuilder()
295 .setDegreeNumber(Uint16.valueOf(degNb.split("DEG")[1]));
297 degAttBldr.setAvailFreqMaps(GridUtils.initFreqMaps4FixedGrid2Available());
299 DegreeAttributes degAtt = degAttBldr.build();
300 // Create ietf node augmentation to support ietf tp-list
301 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1Builder
302 ietfNode1 = new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
303 .Node1Builder().setTerminationPoint(tpMap);
305 String nodeIdtopo = new StringBuilder().append(nodeId).append("-").append(degNb).toString();
306 Node1 ontNode1 = new Node1Builder().setDegreeAttributes(degAtt).build();
307 // Create openroadm-common-network augmentation to set node type to DEGREE
308 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.Node1 ocnNode1 =
309 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.Node1Builder()
310 .setNodeType(OpenroadmNodeType.DEGREE)
311 .setAdministrativeState(AdminStates.InService)
312 .setOperationalState(State.InService)
314 // Create ietf node setting supporting-node data
315 return createTopoLayerNode(nodeId, clli)
316 .setNodeId(new NodeId(nodeIdtopo))
317 .withKey((new NodeKey(new NodeId(nodeIdtopo))))
318 .addAugmentation(ontNode1)
319 .addAugmentation(ocnNode1)
320 .addAugmentation(ietfNode1.build());
323 private static NodeBuilder createSrg(String srgNb, List<Mapping> srgListMap, String nodeId, String clli,
324 boolean firstMount) {
326 Map<TerminationPointKey,TerminationPoint> tpMap = new HashMap<>();
327 TerminationPointBuilder ietfTpBldr;
328 for (Mapping m : srgListMap) {
329 ietfTpBldr = createTpBldr(m.getLogicalConnectionPoint());
330 // Add openroadm-common-network tp type augmentations
331 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210
332 .TerminationPoint1Builder ocnTp1Bldr = new org.opendaylight.yang.gen.v1.http
333 .org.openroadm.common.network.rev211210.TerminationPoint1Builder()
334 .setAdministrativeState(TopologyUtils.setNetworkAdminState(m.getPortAdminState()))
335 .setOperationalState(TopologyUtils.setNetworkOperState(m.getPortOperState()));
336 // Added states to srg port. TODO: add to mapping relation between abstracted and physical node states
337 switch (m.getPortDirection()) {
338 case "bidirectional":
339 ocnTp1Bldr.setTpType(OpenroadmTpType.SRGTXRXPP);
342 ocnTp1Bldr.setTpType(OpenroadmTpType.SRGTXPP);
345 ocnTp1Bldr.setTpType(OpenroadmTpType.SRGRXPP);
348 LOG.error("impossible to set tp-type to {}", m.getLogicalConnectionPoint());
350 ietfTpBldr.addAugmentation(ocnTp1Bldr.build());
351 TerminationPoint ietfTp = ietfTpBldr.build();
352 tpMap.put(ietfTp.key(),ietfTp);
354 // Add CP to tp-list + added states. TODO: same comment as before with the relation between states
355 ietfTpBldr = createTpBldr(srgNb + "-CP-TXRX");
356 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210
357 .TerminationPoint1 ocnTp1 = new org.opendaylight.yang.gen.v1
358 .http.org.openroadm.common.network.rev211210.TerminationPoint1Builder()
359 .setTpType(OpenroadmTpType.SRGTXRXCP)
360 .setAdministrativeState(AdminStates.InService)
361 .setOperationalState(State.InService)
363 ietfTpBldr.addAugmentation(ocnTp1);
364 TerminationPoint ietfTp = ietfTpBldr.build();
365 tpMap.put(ietfTp.key(),ietfTp);
366 // Create openroadm-common-network augmentation to set node type to SRG
367 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.Node1 ocnNode1 =
368 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.Node1Builder()
369 .setNodeType(OpenroadmNodeType.SRG)
370 .setAdministrativeState(AdminStates.InService)
371 .setOperationalState(State.InService)
373 // set srg-attributes
374 SrgAttributesBuilder srgAttrBldr = new SrgAttributesBuilder();
376 srgAttrBldr.setAvailFreqMaps(GridUtils.initFreqMaps4FixedGrid2Available());
378 SrgAttributes srgAttr = srgAttrBldr.build();
379 Node1 ontNode1 = new Node1Builder().setSrgAttributes(srgAttr).build();
380 // Create ietf node augmentation to support ietf tp-list
381 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1Builder
382 ietfNode1 = new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
383 .Node1Builder().setTerminationPoint(tpMap);
384 // Create ietf node setting supporting-node data
385 String nodeIdtopo = new StringBuilder().append(nodeId).append("-").append(srgNb).toString();
386 return createTopoLayerNode(nodeId, clli)
387 .setNodeId(new NodeId(nodeIdtopo))
388 .withKey((new NodeKey(new NodeId(nodeIdtopo))))
389 .addAugmentation(ontNode1)
390 .addAugmentation(ocnNode1)
391 .addAugmentation(ietfNode1.build());
394 private static NodeBuilder createTopoLayerNode(String nodeId, String clli) {
395 // Sets the value of Network-ref and Node-ref as a part of the supporting node
397 SupportingNodeBuilder support1bldr = new SupportingNodeBuilder()
398 .withKey(new SupportingNodeKey(new NetworkId(NetworkUtils.UNDERLAY_NETWORK_ID), new NodeId(nodeId)))
399 .setNetworkRef(new NetworkId(NetworkUtils.UNDERLAY_NETWORK_ID))
400 .setNodeRef(new NodeId(nodeId));
401 SupportingNodeBuilder support2bldr = new SupportingNodeBuilder()
402 .withKey(new SupportingNodeKey(new NetworkId(NetworkUtils.CLLI_NETWORK_ID), new NodeId(clli)))
403 .setNetworkRef(new NetworkId(NetworkUtils.CLLI_NETWORK_ID))
404 .setNodeRef(new NodeId(clli));
405 Map<SupportingNodeKey, SupportingNode> supportlist = new HashMap<>();
406 SupportingNode support1 = support1bldr.build();
407 supportlist.put(support1.key(),support1);
408 SupportingNode support2 = support2bldr.build();
409 supportlist.put(support2.key(),support2);
410 return new NodeBuilder().setSupportingNode(supportlist);
414 // This method returns a generic termination point builder for a given tpid
415 private static TerminationPointBuilder createTpBldr(String tpId) {
416 TpId tp = new TpId(tpId);
417 return new TerminationPointBuilder().withKey(new TerminationPointKey(tp)).setTpId(tp);
420 private static LinkBuilder createLink(String srcNode, String destNode, String srcTp, String destTp) {
422 SourceBuilder ietfSrcLinkBldr = new SourceBuilder().setSourceNode(new NodeId(srcNode))
423 .setSourceTp(new TpId(srcTp));
424 //create destination link
425 DestinationBuilder ietfDestLinkBldr = new DestinationBuilder().setDestNode(new NodeId(destNode))
426 .setDestTp(new TpId(destTp));
427 LinkId linkId = LinkIdUtil.buildLinkId(srcNode, srcTp, destNode, destTp);
428 return new LinkBuilder()
429 .setSource(ietfSrcLinkBldr.build())
430 .setDestination(ietfDestLinkBldr.build())
432 .withKey(new LinkKey(linkId));
435 private static List<Link> createNewLinks(List<Node> nodes) {
436 List<Link> links = new ArrayList<>();
441 for (int i = 0; i < nodes.size() - 1; i++) {
442 for (int j = i + 1; j < nodes.size(); j++) {
443 srcNode = nodes.get(i).getNodeId().getValue();
444 destNode = nodes.get(j).getNodeId().getValue();
447 .augmentation(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang
448 .ietf.network.topology.rev180226.Node1.class).nonnullTerminationPoint().values().stream()
449 .filter(tp -> tp.getTpId().getValue().contains("CP") || tp.getTpId().getValue().contains("CTP"))
450 .findFirst().get().getTpId().getValue();
451 destTp = nodes.get(j)
452 .augmentation(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang
453 .ietf.network.topology.rev180226.Node1.class)
454 .nonnullTerminationPoint().values().stream()
455 .filter(tp -> tp.getTpId().getValue().contains("CP") || tp.getTpId().getValue().contains("CTP"))
456 .findFirst().get().getTpId().getValue();
457 Link1Builder ocnAzLinkBldr = new Link1Builder();
458 int srcNodeType = nodes.get(i).augmentation(org.opendaylight.yang.gen.v1.http
459 .org.openroadm.common.network.rev211210.Node1.class).getNodeType().getIntValue();
460 int destNodeType = nodes.get(j).augmentation(org.opendaylight.yang.gen.v1.http
461 .org.openroadm.common.network.rev211210.Node1.class).getNodeType().getIntValue();
462 if (srcNodeType == 11 && destNodeType == 11) {
463 ocnAzLinkBldr.setLinkType(OpenroadmLinkType.EXPRESSLINK);
464 } else if (srcNodeType == 11 && destNodeType == 12) {
465 ocnAzLinkBldr.setLinkType(OpenroadmLinkType.DROPLINK);
466 } else if (srcNodeType == 12 && destNodeType == 11) {
467 ocnAzLinkBldr.setLinkType(OpenroadmLinkType.ADDLINK);
472 Link1Builder ocnZaLinkBldr = new Link1Builder();
473 if (srcNodeType == 11 && destNodeType == 11) {
474 ocnZaLinkBldr.setLinkType(OpenroadmLinkType.EXPRESSLINK);
475 } else if (destNodeType == 11 && srcNodeType == 12) {
476 ocnZaLinkBldr.setLinkType(OpenroadmLinkType.DROPLINK);
477 } else if (destNodeType == 12 && srcNodeType == 11) {
478 ocnZaLinkBldr.setLinkType(OpenroadmLinkType.ADDLINK);
482 // Add state to link. Based on the operational state of the TPs at the edge of the link.
483 // Similar to getting srcTp and destTp
484 State srcTpState = nodes.get(i).augmentation(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang
485 .ietf.network.topology.rev180226.Node1.class).getTerminationPoint().values().stream()
486 .filter(tp -> tp.getTpId().getValue().contains("CP") || tp.getTpId().getValue().contains("CTP"))
487 .findFirst().get().augmentation(org.opendaylight.yang.gen.v1.http
488 .org.openroadm.common.network.rev211210.TerminationPoint1.class).getOperationalState();
489 State destTpState = nodes.get(j).augmentation(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang
490 .ietf.network.topology.rev180226.Node1.class).getTerminationPoint().values().stream()
491 .filter(tp -> tp.getTpId().getValue().contains("CP") || tp.getTpId().getValue().contains("CTP"))
492 .findFirst().get().augmentation(org.opendaylight.yang.gen.v1.http
493 .org.openroadm.common.network.rev211210.TerminationPoint1.class).getOperationalState();
494 if (State.InService.equals(srcTpState) && State.InService.equals(destTpState)) {
495 ocnAzLinkBldr.setAdministrativeState(AdminStates.InService)
496 .setOperationalState(State.InService);
497 ocnZaLinkBldr.setAdministrativeState(AdminStates.InService)
498 .setOperationalState(State.InService);
500 ocnAzLinkBldr.setAdministrativeState(AdminStates.OutOfService)
501 .setOperationalState(State.OutOfService);
502 ocnZaLinkBldr.setAdministrativeState(AdminStates.OutOfService)
503 .setOperationalState(State.OutOfService);
505 // set opposite link augmentations
506 LinkBuilder ietfAzLinkBldr = createLink(srcNode, destNode, srcTp, destTp);
507 LinkBuilder ietfZaLinkBldr = createLink(destNode, srcNode, destTp, srcTp);
508 ocnAzLinkBldr.setOppositeLink(ietfZaLinkBldr.getLinkId());
509 ietfAzLinkBldr.addAugmentation(ocnAzLinkBldr.build());
510 ocnZaLinkBldr.setOppositeLink(ietfAzLinkBldr.getLinkId());
511 ietfZaLinkBldr.addAugmentation(ocnZaLinkBldr.build());
512 links.add(ietfAzLinkBldr.build());
513 links.add(ietfZaLinkBldr.build());
519 // This method returns the linkBuilder object for given source and destination
520 public static boolean deleteLink(String srcNode, String dstNode, String srcTp, String destTp,
521 NetworkTransactionService networkTransactionService) {
522 LOG.info("deleting link for {}-{}", srcNode, dstNode);
523 LinkId linkId = LinkIdUtil.buildLinkId(srcNode, srcTp, dstNode, destTp);
524 if (deleteLinkLinkId(linkId, networkTransactionService)) {
525 LOG.debug("Link Id {} updated to have admin state down", linkId);
528 LOG.debug("Link Id not found for Source {} and Dest {}", srcNode, dstNode);
533 // This method returns the linkBuilder object for given source and destination
534 public static boolean deleteLinkLinkId(LinkId linkId , NetworkTransactionService networkTransactionService) {
535 LOG.info("deleting link for LinkId: {}", linkId.getValue());
537 InstanceIdentifierBuilder<Link> linkIID = InstanceIdentifier.builder(Networks.class).child(Network.class,
538 new NetworkKey(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID))).augmentation(Network1.class)
539 .child(Link.class, new LinkKey(linkId));
540 java.util.Optional<Link> link =
541 networkTransactionService.read(LogicalDatastoreType.CONFIGURATION,linkIID.build()).get();
542 if (link.isPresent()) {
543 LinkBuilder linkBuilder = new LinkBuilder(link.get());
544 org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev211210.Link1Builder link1Builder =
545 new org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev211210.Link1Builder(
546 linkBuilder.augmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev211210
548 linkBuilder.removeAugmentation(Link1.class)
549 .addAugmentation(link1Builder.build());
550 networkTransactionService.merge(LogicalDatastoreType.CONFIGURATION, linkIID.build(),
551 linkBuilder.build());
552 networkTransactionService.commit().get(1, TimeUnit.SECONDS);
555 LOG.error("No link found for given LinkId: {}",
560 } catch (InterruptedException | ExecutionException | TimeoutException e) {
561 LOG.error("Error deleting link {}", linkId.getValue(), e);
567 * Get a builder for instance identifier related to common network termination point.
568 * @param nodeId String
570 * @return InstanceIdentifierBuilder
572 public static InstanceIdentifierBuilder<org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210
573 .TerminationPoint1> createCommonNetworkTerminationPointIIDBuilder(String nodeId, String tpId) {
574 return InstanceIdentifier
575 .builder(Networks.class).child(Network.class, new NetworkKey(
576 new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID)))
577 .child(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network
578 .Node.class, new NodeKey(new NodeId(nodeId)))
579 .augmentation(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
581 .child(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks
582 .network.node.TerminationPoint.class, new TerminationPointKey(new TpId(tpId)))
583 .augmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210
584 .TerminationPoint1.class);
588 * Get a builder for instance identifier related to network termination point.
589 * @param nodeId String
591 * @return InstanceIdentifierBuilder
593 public static InstanceIdentifierBuilder<TerminationPoint1> createNetworkTerminationPointIIDBuilder(String nodeId,
595 return InstanceIdentifier
596 .builder(Networks.class).child(Network.class, new NetworkKey(
597 new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID)))
598 .child(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network
599 .Node.class, new NodeKey(new NodeId(nodeId)))
600 .augmentation(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
602 .child(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks
603 .network.node.TerminationPoint.class, new TerminationPointKey(new TpId(tpId)))
604 .augmentation(TerminationPoint1.class);
608 * Get an instance identifier related to network node.
609 * @param nodeId String
610 * @return InstanceIdentifier
612 public static InstanceIdentifier<Node1> createNetworkNodeIID(String nodeId) {
613 return InstanceIdentifier
614 .builder(Networks.class).child(Network.class, new NetworkKey(
615 new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID)))
616 .child(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network
617 .Node.class, new NodeKey(new NodeId(nodeId))).augmentation(Node1.class).build();
621 * Get an instance identifier related to common network node.
622 * @param nodeId String
623 * @return InstanceIdentifier
625 public static InstanceIdentifier<org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210
626 .Node1> createCommonNetworkNodeIID(String nodeId) {
627 return InstanceIdentifier
628 .builder(Networks.class).child(Network.class, new NetworkKey(
629 new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID)))
630 .child(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network
631 .Node.class, new NodeKey(new NodeId(nodeId)))
632 .augmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.Node1.class)