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.controller.md.sal.common.api.data.LogicalDatastoreType;
23 import org.opendaylight.transportpce.common.NetworkUtils;
24 import org.opendaylight.transportpce.common.device.DeviceTransactionManager;
25 import org.opendaylight.transportpce.common.network.NetworkTransactionService;
26 import org.opendaylight.transportpce.networkmodel.dto.TopologyShard;
27 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev190702.network.Nodes;
28 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev190702.network.nodes.Mapping;
29 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.NetworkTypes1;
30 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.NetworkTypes1Builder;
31 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.networks.network.network.types.OpenroadmCommonNetworkBuilder;
32 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.state.types.rev181130.State;
33 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.types.rev161014.NodeTypes;
34 import org.opendaylight.yang.gen.v1.http.org.openroadm.degree.rev181130.degree.node.attributes.AvailableWavelengths;
35 import org.opendaylight.yang.gen.v1.http.org.openroadm.degree.rev181130.degree.node.attributes.AvailableWavelengthsBuilder;
36 import org.opendaylight.yang.gen.v1.http.org.openroadm.degree.rev181130.degree.node.attributes.AvailableWavelengthsKey;
37 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.Link1;
38 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.Link1Builder;
39 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.Node1;
40 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.Node1Builder;
41 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.TerminationPoint1;
42 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.TerminationPoint1Builder;
43 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.DegreeAttributesBuilder;
44 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.SrgAttributesBuilder;
45 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.termination.point.XpdrClientAttributesBuilder;
46 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.termination.point.XpdrNetworkAttributesBuilder;
47 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev181130.OpenroadmLinkType;
48 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev181130.OpenroadmNodeType;
49 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev181130.OpenroadmTpType;
50 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NetworkId;
51 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.Networks;
52 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NodeId;
53 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.Network;
54 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.NetworkBuilder;
55 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.NetworkKey;
56 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.NetworkTypesBuilder;
57 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.Node;
58 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.NodeBuilder;
59 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.NodeKey;
60 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.node.SupportingNode;
61 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.node.SupportingNodeBuilder;
62 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.node.SupportingNodeKey;
63 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.LinkId;
64 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Network1;
65 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Network1Builder;
66 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.TpId;
67 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.Link;
68 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.LinkBuilder;
69 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.LinkKey;
70 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.link.DestinationBuilder;
71 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.link.SourceBuilder;
72 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPoint;
73 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPointBuilder;
74 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPointKey;
75 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
76 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier.InstanceIdentifierBuilder;
77 import org.slf4j.Logger;
78 import org.slf4j.LoggerFactory;
80 public class OpenRoadmTopology22 {
82 private static final Logger LOG = LoggerFactory.getLogger(OpenRoadmTopology22.class);
84 private NetworkTransactionService networkTransactionService;
85 private final DeviceTransactionManager deviceTransactionManager;
87 public OpenRoadmTopology22(NetworkTransactionService networkTransactionService,
88 DeviceTransactionManager deviceTransactionManager) {
89 this.networkTransactionService = networkTransactionService;
90 this.deviceTransactionManager = deviceTransactionManager;
94 * This public method creates the OpenROADM Topology
95 * Layer and posts it to the controller.
97 public void createTopoLayer() {
99 Network openRoadmTopology = createOpenRoadmTopology();
100 InstanceIdentifierBuilder<Network> nwIID = InstanceIdentifier.builder(Networks.class).child(Network.class,
101 new NetworkKey(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID)));
103 this.networkTransactionService.put(LogicalDatastoreType.CONFIGURATION, nwIID.build(), openRoadmTopology);
104 this.networkTransactionService.commit().get(1, TimeUnit.SECONDS);
105 LOG.info("OpenRoadm-Topology created successfully.");
106 } catch (ExecutionException | TimeoutException | InterruptedException e) {
107 LOG.warn("Failed to create OpenRoadm-Topology", e);
112 * Create empty OpenROADM topology.
114 private Network createOpenRoadmTopology() {
115 NetworkBuilder nwBuilder = new NetworkBuilder();
116 NetworkId nwId = new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID);
117 nwBuilder.setNetworkId(nwId);
118 nwBuilder.withKey(new NetworkKey(nwId));
119 NetworkTypes1Builder topoNetworkTypesBldr = new NetworkTypes1Builder();
120 topoNetworkTypesBldr.setOpenroadmCommonNetwork(new OpenroadmCommonNetworkBuilder().build());
121 NetworkTypesBuilder nwTypeBuilder = new NetworkTypesBuilder();
122 nwTypeBuilder.addAugmentation(NetworkTypes1.class, topoNetworkTypesBldr.build());
123 nwBuilder.setNetworkTypes(nwTypeBuilder.build());
124 // Array to store nodes in the topolayer of a roadm/Xponder
125 Network1Builder nwBldr1 = new Network1Builder();
126 // adding expressLinks
127 nwBldr1.setLink(Collections.emptyList());
128 nwBuilder.addAugmentation(Network1.class, nwBldr1.build());
129 nwBuilder.setNode(Collections.emptyList());
130 return nwBuilder.build();
133 public TopologyShard createTopologyShard(Nodes mappingNode) {
136 List<Node> nodes = new ArrayList<>();
137 List<Link> links = new ArrayList<>();
139 // Check if node is ROADM
140 if (NodeTypes.Rdm.getIntValue() == mappingNode.getNodeInfo().getNodeType().getIntValue()) {
141 LOG.info("creating rdm node in openroadmtopology for node {}", mappingNode.getNodeId());
142 // transform flat mapping list to per degree and per srg mapping lists
143 Map<String, List<Mapping>> mapDeg = new HashMap();
144 Map<String, List<Mapping>> mapSrg = new HashMap();
145 List<Mapping> mappingList = mappingNode.getMapping();
146 mappingList.sort(Comparator.comparing(Mapping::getLogicalConnectionPoint));
148 List<String> nodeShardList = new ArrayList();
149 for (Mapping mapping : mappingList) {
150 String str = mapping.getLogicalConnectionPoint().split("-")[0];
151 if (!nodeShardList.contains(str)) {
152 nodeShardList.add(str);
155 for (String str : nodeShardList) {
156 List<Mapping> interList = new ArrayList();
157 interList = mappingList.stream().filter(x -> x.getLogicalConnectionPoint().contains(str))
158 .collect(Collectors.toList());
159 if (str.contains("DEG")) {
160 mapDeg.put(str, interList);
161 } else if (str.contains("SRG")) {
162 mapSrg.put(str, interList);
164 LOG.error("unknown element");
167 // create degree nodes
168 for (String k : mapDeg.keySet()) {
169 NodeBuilder ietfNode = createDegree(k, mapDeg.get(k), mappingNode.getNodeId());
170 nodes.add(ietfNode.build());
173 for (String k : mapSrg.keySet()) {
174 NodeBuilder ietfNode = createSrg(k, mapSrg.get(k), mappingNode.getNodeId());
175 nodes.add(ietfNode.build());
178 numOfDegrees = mapDeg.size();
179 numOfSrgs = mapSrg.size();
181 LOG.info("adding links numOfDegrees={} numOfSrgs={}", numOfDegrees, numOfSrgs);
182 links.addAll(createNewLinks(nodes));
183 LOG.info("created nodes/links: {}/{}", nodes.size(), links.size());
184 return new TopologyShard(nodes, links);
185 } else if (NodeTypes.Xpdr.getIntValue() == mappingNode.getNodeInfo().getNodeType().getIntValue()) {
186 // Check if node is XPONDER
187 LOG.info("creating xpdr node in openroadmtopology for node {}", mappingNode.getNodeId());
188 NodeBuilder ietfNode = createXpdr(mappingNode);
189 nodes.add(ietfNode.build());
190 return new TopologyShard(nodes, links);
192 LOG.error("Device node Type not managed yet");
196 private NodeBuilder createXpdr(Nodes mappingNode) {
197 // Create ietf node setting supporting-node data
198 NodeBuilder ietfNodeBldr = createTopoLayerNode(mappingNode.getNodeId());
200 String nodeIdtopo = new StringBuilder().append(mappingNode.getNodeId()).append("-XPDR1").toString();
201 ietfNodeBldr.setNodeId(new NodeId(nodeIdtopo));
202 ietfNodeBldr.withKey((new NodeKey(new NodeId(nodeIdtopo))));
203 // Create openroadm-network-topo augmentation to set node type to Xponder
204 Node1Builder ontNode1Bldr = new Node1Builder();
205 ontNode1Bldr.setNodeType(OpenroadmNodeType.XPONDER);
206 ietfNodeBldr.addAugmentation(Node1.class, ontNode1Bldr.build());
209 List<TerminationPoint> tpList = new ArrayList<>();
210 TerminationPointBuilder ietfTpBldr;
211 for (Mapping m : mappingNode.getMapping()) {
212 ietfTpBldr = createTpBldr(m.getLogicalConnectionPoint());
213 // Add openroadm-network-topology tp augmentations
214 TerminationPoint1Builder ontTp1Bldr = new TerminationPoint1Builder();
215 if (m.getPortQual().equals("xpdr-network")) {
216 ontTp1Bldr.setTpType(OpenroadmTpType.XPONDERNETWORK);
217 XpdrNetworkAttributesBuilder xpdrNwAttrBldr = new XpdrNetworkAttributesBuilder();
218 xpdrNwAttrBldr.setTailEquipmentId(m.getAssociatedLcp());
219 ontTp1Bldr.setXpdrNetworkAttributes(xpdrNwAttrBldr.build());
220 ietfTpBldr.addAugmentation(TerminationPoint1.class, ontTp1Bldr.build());
221 org.opendaylight.yang.gen.v1.http.transportpce.topology.rev190625
222 .TerminationPoint1Builder tpceTp1Bldr = new org.opendaylight.yang.gen.v1.http.transportpce
223 .topology.rev190625.TerminationPoint1Builder();
224 tpceTp1Bldr.setAssociatedConnectionMapPort(m.getAssociatedLcp());
225 ietfTpBldr.addAugmentation(org.opendaylight.yang.gen.v1.http.transportpce.topology.rev190625
226 .TerminationPoint1.class, tpceTp1Bldr.build());
227 tpList.add(ietfTpBldr.build());
228 } else if (m.getPortQual().equals("xpdr-client")) {
229 ontTp1Bldr.setTpType(OpenroadmTpType.XPONDERCLIENT);
230 XpdrClientAttributesBuilder xpdrNwAttrBldr = new XpdrClientAttributesBuilder();
231 xpdrNwAttrBldr.setTailEquipmentId(m.getAssociatedLcp());
232 ontTp1Bldr.setXpdrClientAttributes(xpdrNwAttrBldr.build());
233 ietfTpBldr.addAugmentation(TerminationPoint1.class, ontTp1Bldr.build());
234 org.opendaylight.yang.gen.v1.http.transportpce.topology.rev190625
235 .TerminationPoint1Builder tpceTp1Bldr = new org.opendaylight.yang.gen.v1.http.transportpce
236 .topology.rev190625.TerminationPoint1Builder();
237 tpceTp1Bldr.setAssociatedConnectionMapPort(m.getAssociatedLcp());
238 ietfTpBldr.addAugmentation(org.opendaylight.yang.gen.v1.http.transportpce.topology.rev190625
239 .TerminationPoint1.class, tpceTp1Bldr.build());
240 tpList.add(ietfTpBldr.build());
244 // Create ietf node augmentation to support ietf tp-list
245 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
246 .Node1Builder ietfNode1 = new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology
247 .rev180226.Node1Builder();
248 ietfNode1.setTerminationPoint(tpList);
249 ietfNodeBldr.addAugmentation(
250 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1.class,
255 private NodeBuilder createDegree(String degNb, List<Mapping> degListMap, String nodeId) {
256 // Create ietf node setting supporting-node data
257 NodeBuilder ietfNodeBldr = createTopoLayerNode(nodeId);
259 String nodeIdtopo = new StringBuilder().append(nodeId).append("-").append(degNb).toString();
260 ietfNodeBldr.setNodeId(new NodeId(nodeIdtopo));
261 ietfNodeBldr.withKey((new NodeKey(new NodeId(nodeIdtopo))));
262 // Create openroadm-network-topo augmentation to set node type to DEGREE
263 Node1Builder ontNode1Bldr = new Node1Builder();
264 ontNode1Bldr.setNodeType(OpenroadmNodeType.DEGREE);
265 // set degree-attributes
266 DegreeAttributesBuilder degAttBldr = new DegreeAttributesBuilder();
267 degAttBldr.setDegreeNumber(new Integer(degNb.split("DEG")[1]));
268 degAttBldr.setAvailableWavelengths(create96AvalWaveDegree());
269 ontNode1Bldr.setDegreeAttributes(degAttBldr.build());
270 ietfNodeBldr.addAugmentation(Node1.class, ontNode1Bldr.build());
273 List<TerminationPoint> tpList = new ArrayList<>();
274 TerminationPointBuilder ietfTpBldr;
275 for (Mapping m : degListMap) {
276 ietfTpBldr = createTpBldr(m.getLogicalConnectionPoint());
277 // Add openroadm-network-topology tp augmentations
278 TerminationPoint1Builder ontTp1Bldr = new TerminationPoint1Builder();
279 switch (m.getPortDirection()) {
280 case "bidirectional":
281 ontTp1Bldr.setTpType(OpenroadmTpType.DEGREETXRXTTP);
284 ontTp1Bldr.setTpType(OpenroadmTpType.DEGREETXTTP);
287 ontTp1Bldr.setTpType(OpenroadmTpType.DEGREERXTTP);
290 LOG.error("impossible to set tp-type to {}", m.getLogicalConnectionPoint());
292 ietfTpBldr.addAugmentation(TerminationPoint1.class, ontTp1Bldr.build());
293 tpList.add(ietfTpBldr.build());
295 // Add CTP to tp-list
296 ietfTpBldr = createTpBldr(degNb + "-CTP-TXRX");
297 TerminationPoint1Builder ontTp1Bldr = new TerminationPoint1Builder();
298 ontTp1Bldr.setTpType(OpenroadmTpType.DEGREETXRXCTP);
299 ietfTpBldr.addAugmentation(TerminationPoint1.class, ontTp1Bldr.build());
300 tpList.add(ietfTpBldr.build());
302 // Create ietf node augmentation to support ietf tp-list
303 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
304 .Node1Builder ietfNode1 = new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology
305 .rev180226.Node1Builder();
306 ietfNode1.setTerminationPoint(tpList);
307 ietfNodeBldr.addAugmentation(
308 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1.class,
313 private NodeBuilder createSrg(String srgNb, List<Mapping> srgListMap, String nodeId) {
314 // Create ietf node setting supporting-node data
315 NodeBuilder ietfNodeBldr = createTopoLayerNode(nodeId);
317 String nodeIdtopo = new StringBuilder().append(nodeId).append("-").append(srgNb).toString();
318 ietfNodeBldr.setNodeId(new NodeId(nodeIdtopo));
319 ietfNodeBldr.withKey((new NodeKey(new NodeId(nodeIdtopo))));
320 // Create openroadm-network-topo augmentation to set node type to DEGREE
321 Node1Builder ontNode1Bldr = new Node1Builder();
322 ontNode1Bldr.setNodeType(OpenroadmNodeType.SRG);
323 // set srg-attributes
324 SrgAttributesBuilder srgAttrBldr = new SrgAttributesBuilder();
325 srgAttrBldr.setAvailableWavelengths(create96AvalWaveSrg());
326 ontNode1Bldr.setSrgAttributes(srgAttrBldr.build());
327 ietfNodeBldr.addAugmentation(Node1.class, ontNode1Bldr.build());
330 List<TerminationPoint> tpList = new ArrayList<>();
331 TerminationPointBuilder ietfTpBldr;
332 for (Mapping m : srgListMap) {
333 ietfTpBldr = createTpBldr(m.getLogicalConnectionPoint());
334 // Add openroadm-network-topology tp augmentations
335 TerminationPoint1Builder ontTp1Bldr = new TerminationPoint1Builder();
336 switch (m.getPortDirection()) {
337 case "bidirectional":
338 ontTp1Bldr.setTpType(OpenroadmTpType.SRGTXRXPP);
341 ontTp1Bldr.setTpType(OpenroadmTpType.SRGTXPP);
344 ontTp1Bldr.setTpType(OpenroadmTpType.SRGRXPP);
347 LOG.error("impossible to set tp-type to {}", m.getLogicalConnectionPoint());
349 ietfTpBldr.addAugmentation(TerminationPoint1.class, ontTp1Bldr.build());
350 tpList.add(ietfTpBldr.build());
353 ietfTpBldr = createTpBldr(srgNb + "-CP-TXRX");
354 TerminationPoint1Builder ontTp1Bldr = new TerminationPoint1Builder();
355 ontTp1Bldr.setTpType(OpenroadmTpType.SRGTXRXCP);
356 ietfTpBldr.addAugmentation(TerminationPoint1.class, ontTp1Bldr.build());
357 tpList.add(ietfTpBldr.build());
359 // Create ietf node augmentation to support ietf tp-list
360 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
361 .Node1Builder ietfNode1 = new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology
362 .rev180226.Node1Builder();
363 ietfNode1.setTerminationPoint(tpList);
364 ietfNodeBldr.addAugmentation(
365 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1.class,
370 private NodeBuilder createTopoLayerNode(String nodeId) {
371 // Sets the value of Network-ref and Node-ref as a part of the supporting node
373 SupportingNodeBuilder supportbldr = new SupportingNodeBuilder();
374 supportbldr.withKey(new SupportingNodeKey(new NetworkId(NetworkUtils.UNDERLAY_NETWORK_ID), new NodeId(nodeId)));
375 supportbldr.setNetworkRef(new NetworkId(NetworkUtils.UNDERLAY_NETWORK_ID));
376 supportbldr.setNodeRef(new NodeId(nodeId));
377 ArrayList<SupportingNode> supportlist = new ArrayList<>();
378 supportlist.add(supportbldr.build());
379 NodeBuilder nodebldr = new NodeBuilder();
380 nodebldr.setSupportingNode(supportlist);
385 // This method returns a generic termination point builder for a given tpid
386 private TerminationPointBuilder createTpBldr(String tpId) {
387 TerminationPointBuilder tpBldr = new TerminationPointBuilder();
388 TpId tp = new TpId(tpId);
389 TerminationPointKey tpKey = new TerminationPointKey(tp);
390 tpBldr.withKey(tpKey);
395 private LinkBuilder createLink(String srcNode, String destNode, String srcTp, String destTp) {
396 LinkBuilder ietfLinkBldr = new LinkBuilder();
398 SourceBuilder ietfSrcLinkBldr = new SourceBuilder().setSourceNode(new NodeId(srcNode)).setSourceTp(srcTp);
399 //create destination link
400 DestinationBuilder ietfDestLinkBldr = new DestinationBuilder().setDestNode(new NodeId(destNode))
402 ietfLinkBldr.setSource(ietfSrcLinkBldr.build())
403 .setDestination(ietfDestLinkBldr.build())
404 .setLinkId(LinkIdUtil.buildLinkId(srcNode, srcTp, destNode, destTp))
405 .withKey(new LinkKey(ietfLinkBldr.getLinkId()));
409 private List<Link> createNewLinks(List<Node> nodes) {
410 List<Link> links = new ArrayList<>();
415 for (int i = 0; i < nodes.size() - 1; i++) {
416 for (int j = i + 1; j < nodes.size(); j++) {
417 srcNode = nodes.get(i).getNodeId().getValue();
418 destNode = nodes.get(j).getNodeId().getValue();
420 srcTp = nodes.get(i).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 destTp = nodes.get(j).augmentation(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf
425 .network.topology.rev180226.Node1.class).getTerminationPoint().stream()
426 .filter(tp -> tp.getTpId().getValue().contains("CP") || tp.getTpId().getValue().contains("CTP"))
427 .findFirst().get().getTpId().getValue();
428 LinkBuilder ietfAzLinkBldr = createLink(srcNode, destNode, srcTp, destTp);
429 Link1Builder ontAzLinkBldr = new Link1Builder();
430 int srcNodeType = nodes.get(i).augmentation(Node1.class).getNodeType().getIntValue();
431 int destNodeType = nodes.get(j).augmentation(Node1.class).getNodeType().getIntValue();
432 if (srcNodeType == 11 && destNodeType == 11) {
433 ontAzLinkBldr.setLinkType(OpenroadmLinkType.EXPRESSLINK);
434 } else if (srcNodeType == 11 && destNodeType == 12) {
435 ontAzLinkBldr.setLinkType(OpenroadmLinkType.DROPLINK);
436 } else if (srcNodeType == 12 && destNodeType == 11) {
437 ontAzLinkBldr.setLinkType(OpenroadmLinkType.ADDLINK);
442 LinkBuilder ietfZaLinkBldr = createLink(destNode, srcNode, destTp, srcTp);
443 Link1Builder ontZaLinkBldr = new Link1Builder();
444 if (srcNodeType == 11 && destNodeType == 11) {
445 ontZaLinkBldr.setLinkType(OpenroadmLinkType.EXPRESSLINK);
446 } else if (destNodeType == 11 && srcNodeType == 12) {
447 ontZaLinkBldr.setLinkType(OpenroadmLinkType.DROPLINK);
448 } else if (destNodeType == 12 && srcNodeType == 11) {
449 ontZaLinkBldr.setLinkType(OpenroadmLinkType.ADDLINK);
453 // set opposite link augmentations
454 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Link1Builder ocnAzLinkBldr =
455 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Link1Builder()
456 .setOppositeLink(ietfZaLinkBldr.getLinkId());
457 ietfAzLinkBldr.addAugmentation(Link1.class, ontAzLinkBldr.build());
458 ietfAzLinkBldr.addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
459 .Link1.class, ocnAzLinkBldr.build());
460 ietfZaLinkBldr.addAugmentation(Link1.class, ontZaLinkBldr.build());
461 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Link1Builder ocnZaLinkBldr =
462 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Link1Builder()
463 .setOppositeLink(ietfAzLinkBldr.getLinkId());
464 ietfZaLinkBldr.addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130
465 .Link1.class, ocnZaLinkBldr.build());
466 links.add(ietfAzLinkBldr.build());
467 links.add(ietfZaLinkBldr.build());
473 // This method returns the linkBuilder object for given source and destination
474 public static boolean deleteLink(String srcNode, String dstNode, String srcTp, String destTp,
475 NetworkTransactionService networkTransactionService) {
476 LOG.info("deleting link for {}-{}", srcNode, dstNode);
477 LinkId linkId = LinkIdUtil.buildLinkId(srcNode, srcTp, dstNode, destTp);
478 if (deleteLinkLinkId(linkId, networkTransactionService)) {
479 LOG.debug("Link Id {} updated to have admin state down");
482 LOG.debug("Link Id not found for Source {} and Dest {}", srcNode, dstNode);
487 // This method returns the linkBuilder object for given source and destination
488 public static boolean deleteLinkLinkId(LinkId linkId , NetworkTransactionService networkTransactionService) {
489 LOG.info("deleting link for LinkId: {}", linkId);
491 InstanceIdentifierBuilder<Link> linkIID = InstanceIdentifier.builder(Networks.class).child(Network.class,
492 new NetworkKey(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID))).augmentation(Network1.class)
493 .child(Link.class, new LinkKey(linkId));
494 com.google.common.base.Optional<Link> link =
495 networkTransactionService.read(LogicalDatastoreType.CONFIGURATION,linkIID.build()).get();
496 if (link.isPresent()) {
497 LinkBuilder linkBuilder = new LinkBuilder(link.get());
498 Link1Builder link1Builder = new Link1Builder(linkBuilder.augmentation(org.opendaylight
499 .yang.gen.v1.http.org.openroadm.network.topology.rev181130.Link1.class));
500 link1Builder.setAdministrativeState(State.OutOfService);
501 linkBuilder.removeAugmentation(Link1.class);
502 linkBuilder.addAugmentation(Link1.class,link1Builder.build());
503 networkTransactionService.merge(LogicalDatastoreType.CONFIGURATION, linkIID.build(),
504 linkBuilder.build());
505 networkTransactionService.commit().get(1, TimeUnit.SECONDS);
508 LOG.error("No link found for given LinkId: {}",
513 } catch (InterruptedException | ExecutionException | TimeoutException e) {
514 LOG.error(e.getMessage(), e);
519 private List<AvailableWavelengths> create96AvalWaveDegree() {
520 List<AvailableWavelengths> waveList = new ArrayList<>();
522 for (int i = 1; i < 97; i++) {
523 AvailableWavelengthsBuilder avalBldr = new AvailableWavelengthsBuilder();
524 avalBldr.setIndex((long) i);
525 avalBldr.withKey(new AvailableWavelengthsKey((long) i));
526 waveList.add(avalBldr.build());
532 private List<org.opendaylight.yang.gen.v1.http.org.openroadm.srg.rev181130.srg.node
533 .attributes.AvailableWavelengths> create96AvalWaveSrg() {
535 List<org.opendaylight.yang.gen.v1.http.org.openroadm.srg.rev181130.srg.node.attributes
536 .AvailableWavelengths> waveList =
539 for (int i = 1; i < 97; i++) {
540 org.opendaylight.yang.gen.v1.http.org.openroadm.srg.rev181130.srg.node.attributes
541 .AvailableWavelengthsBuilder avalBldr =
542 new org.opendaylight.yang.gen.v1.http.org.openroadm.srg.rev181130.srg.node
543 .attributes.AvailableWavelengthsBuilder();
544 avalBldr.setIndex((long) i);
546 new org.opendaylight.yang.gen.v1.http.org.openroadm.srg.rev181130.srg.node
547 .attributes.AvailableWavelengthsKey(
549 waveList.add(avalBldr.build());