2 * Copyright © 2020 Orange. 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 com.google.common.collect.ImmutableMap;
12 import java.util.ArrayList;
13 import java.util.HashMap;
14 import java.util.List;
16 import java.util.stream.Collectors;
17 import org.eclipse.jdt.annotation.Nullable;
18 import org.opendaylight.transportpce.common.NetworkUtils;
19 import org.opendaylight.transportpce.networkmodel.dto.OtnTopoNode;
20 import org.opendaylight.transportpce.networkmodel.dto.TopologyShard;
21 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev210426.mapping.Mapping;
22 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev210426.network.Nodes;
23 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.state.types.rev191129.State;
24 import org.opendaylight.yang.gen.v1.http.org.openroadm.device.types.rev191129.XpdrNodeTypes;
25 import org.opendaylight.yang.gen.v1.http.org.openroadm.equipment.states.types.rev191129.AdminStates;
26 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev200327.xpdr.odu.switching.pools.OduSwitchingPools;
27 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev200327.xpdr.odu.switching.pools.OduSwitchingPoolsBuilder;
28 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev200327.xpdr.odu.switching.pools.OduSwitchingPoolsKey;
29 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev200327.xpdr.odu.switching.pools.odu.switching.pools.NonBlockingList;
30 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev200327.xpdr.odu.switching.pools.odu.switching.pools.NonBlockingListBuilder;
31 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev200327.xpdr.odu.switching.pools.odu.switching.pools.NonBlockingListKey;
32 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev200529.OpenroadmLinkType;
33 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev200529.OpenroadmNodeType;
34 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev200529.OpenroadmTpType;
35 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev200529.xpdr.tp.supported.interfaces.SupportedInterfaceCapability;
36 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev200529.xpdr.tp.supported.interfaces.SupportedInterfaceCapabilityBuilder;
37 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev200529.xpdr.tp.supported.interfaces.SupportedInterfaceCapabilityKey;
38 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev200327.ODTU4TsAllocated;
39 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev200327.ODTUCnTs;
40 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev200327.ODU0;
41 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev200327.ODU2;
42 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev200327.ODU2e;
43 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev200327.ODU4;
44 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev200327.OdtuTypeIdentity;
45 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev200327.OduRateIdentity;
46 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.Link1;
47 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.Link1Builder;
48 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.Node1;
49 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.Node1Builder;
50 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.TerminationPoint1;
51 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.TerminationPoint1Builder;
52 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.networks.network.node.SwitchingPools;
53 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.networks.network.node.SwitchingPoolsBuilder;
54 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.networks.network.node.TpBandwidthSharing;
55 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.networks.network.node.TpBandwidthSharingBuilder;
56 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.networks.network.node.XpdrAttributes;
57 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.networks.network.node.XpdrAttributesBuilder;
58 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.networks.network.node.termination.point.TpSupportedInterfaces;
59 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.networks.network.node.termination.point.TpSupportedInterfacesBuilder;
60 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.networks.network.node.termination.point.XpdrTpPortConnectionAttributesBuilder;
61 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.SupportedIfCapability;
62 import org.opendaylight.yang.gen.v1.http.org.openroadm.switching.pool.types.rev191129.SwitchingPoolTypes;
63 import org.opendaylight.yang.gen.v1.http.org.openroadm.xponder.rev200529.xpdr.otn.tp.attributes.OdtuTpnPool;
64 import org.opendaylight.yang.gen.v1.http.org.openroadm.xponder.rev200529.xpdr.otn.tp.attributes.OdtuTpnPoolBuilder;
65 import org.opendaylight.yang.gen.v1.http.transportpce.topology.rev210511.OtnLinkType;
66 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NetworkId;
67 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NodeId;
68 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.Node;
69 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.NodeBuilder;
70 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.NodeKey;
71 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.node.SupportingNode;
72 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.node.SupportingNodeBuilder;
73 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.node.SupportingNodeKey;
74 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.TpId;
75 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.Link;
76 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.LinkBuilder;
77 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPoint;
78 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPointBuilder;
79 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPointKey;
80 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.termination.point.SupportingTerminationPoint;
81 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.termination.point.SupportingTerminationPointBuilder;
82 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.termination.point.SupportingTerminationPointKey;
83 import org.opendaylight.yangtools.yang.common.Uint16;
84 import org.opendaylight.yangtools.yang.common.Uint32;
85 import org.slf4j.Logger;
86 import org.slf4j.LoggerFactory;
88 public final class OpenRoadmOtnTopology {
90 private static final Logger LOG = LoggerFactory.getLogger(OpenRoadmOtnTopology.class);
91 private static final String CLIENT = "-CLIENT";
92 private static final String NETWORK = "-NETWORK";
93 private static final String XPDR = "-XPDR";
94 private static final int NB_TRIB_PORTS = 80;
95 private static final int NB_TRIB_SLOTS = 80;
96 private static final int NB_TRIB_SLOT_PER_10GE = 8;
98 private OpenRoadmOtnTopology() {
101 public static TopologyShard createTopologyShard(Nodes mappingNode) {
102 List<Node> nodes = new ArrayList<>();
103 List<Link> links = new ArrayList<>();
104 Map<Integer, OtnTopoNode> xpdrMap = convertPortMappingToOtnNodeList(mappingNode);
105 for (OtnTopoNode node : xpdrMap.values()) {
106 switch (node.getNodeType()) {
108 nodes.add(createTpdr(node));
111 nodes.add(createMuxpdr(node));
114 nodes.add(createSwitch(node));
117 LOG.error("unknown otn node type {}", node.getNodeType().getName());
121 return new TopologyShard(nodes, links);
124 public static TopologyShard createOtnLinks(String nodeA, String tpA, String nodeZ, String tpZ,
125 OtnLinkType linkType) {
126 List<Link> links = null;
127 if (OtnLinkType.OTU4.equals(linkType) || OtnLinkType.OTUC4.equals(linkType)) {
128 links = initialiseOtnLinks(nodeA, tpA, nodeZ, tpZ, linkType);
130 return new TopologyShard(null, links);
133 public static TopologyShard createOtnLinks(List<Link> suppOtuLinks, List<TerminationPoint> oldTps,
134 OtnLinkType linkType) {
135 List<Link> links = new ArrayList<>();
136 for (Link link : suppOtuLinks) {
137 if (OtnLinkType.ODTU4.equals(linkType) && link.augmentation(Link1.class) != null
138 && link.augmentation(Link1.class).getAvailableBandwidth().equals(Uint32.valueOf(100000))) {
139 links.add(updateOtnLinkBwParameters(link, 0L, 100000L));
140 } else if (OtnLinkType.ODUC4.equals(linkType) && link.augmentation(Link1.class) != null
141 && link.augmentation(Link1.class).getAvailableBandwidth().equals(Uint32.valueOf(400000))) {
142 links.add(updateOtnLinkBwParameters(link, 0L, 400000L));
144 LOG.error("Error with otn parameters of supported link {}", link.getLinkId().getValue());
147 if (links.size() == 2) {
148 links.addAll(initialiseOtnLinks(suppOtuLinks.get(0).getSource().getSourceNode().getValue(),
149 suppOtuLinks.get(0).getSource().getSourceTp().toString(),
150 suppOtuLinks.get(0).getDestination().getDestNode().getValue(),
151 suppOtuLinks.get(0).getDestination().getDestTp().toString(),
154 List<TerminationPoint> tps = new ArrayList<>();
155 for (TerminationPoint tp : oldTps) {
156 tps.add(updateTp(tp, true, linkType));
158 if (links.size() == 4 && tps.size() == 2) {
159 return new TopologyShard(null, links, tps);
161 return new TopologyShard(null, null, null);
165 public static TopologyShard updateOtnLinks(List<Link> suppOduLinks, List<TerminationPoint> oldTps,
166 Uint32 serviceRate, Short tribPortNb, Short minTribSlotNb, Short maxTribSlotNb, boolean isDeletion) {
167 List<Link> links = new ArrayList<>();
169 switch (serviceRate.intValue()) {
180 LOG.warn("Error with not managed service rate {}", serviceRate.toString());
181 return new TopologyShard(null, null, null);
183 for (Link link : suppOduLinks) {
184 if (link.augmentation(Link1.class) != null && link.augmentation(Link1.class).getAvailableBandwidth() != null
185 && link.augmentation(Link1.class).getUsedBandwidth() != null) {
186 Uint32 avlBw = link.augmentation(Link1.class).getAvailableBandwidth();
187 Uint32 usedBw = link.augmentation(Link1.class).getUsedBandwidth();
188 if (avlBw.toJava() < bwIncr) {
192 links.add(updateOtnLinkBwParameters(link, avlBw.toJava() + bwIncr,
193 usedBw.toJava() - bwIncr));
195 links.add(updateOtnLinkBwParameters(link, avlBw.toJava() - bwIncr,
196 usedBw.toJava() + bwIncr));
199 LOG.error("Error with otn parameters of supported link {}", link.getLinkId().getValue());
202 List<TerminationPoint> tps = new ArrayList<>();
203 for (TerminationPoint tp : oldTps) {
205 tps.add(updateNodeTpTsPool(tp, serviceRate, tribPortNb, minTribSlotNb, maxTribSlotNb, isDeletion));
208 if (!links.isEmpty() && !tps.isEmpty()) {
209 return new TopologyShard(null, links, tps);
211 LOG.error("unable to update otn links");
212 return new TopologyShard(null, null, null);
216 public static TopologyShard deleteOtnLinks(List<Link> suppOtuLinks, List<TerminationPoint> oldTps,
217 OtnLinkType linkType) {
218 List<Link> links = new ArrayList<>();
219 OtnLinkType otnLinkType = null;
220 for (Link link : suppOtuLinks) {
221 if (link.augmentation(Link1.class) != null && link.augmentation(
222 org.opendaylight.yang.gen.v1.http.transportpce.topology.rev210511.Link1.class) != null) {
223 otnLinkType = link.augmentation(
224 org.opendaylight.yang.gen.v1.http.transportpce.topology.rev210511.Link1.class).getOtnLinkType();
225 if (OtnLinkType.OTU4.equals(otnLinkType)) {
226 links.add(updateOtnLinkBwParameters(link, 100000L, 0L));
227 } else if (OtnLinkType.OTUC4.equals(otnLinkType)) {
228 links.add(updateOtnLinkBwParameters(link, 400000L, 0L));
230 LOG.warn("Unexpected otn-link-type {} for link {}", otnLinkType, link.getLinkId());
233 LOG.error("Error with otn parameters of supported link {}", link.getLinkId().getValue());
234 return new TopologyShard(null, null, null);
237 List<TerminationPoint> tps = new ArrayList<>();
238 for (TerminationPoint tp : oldTps) {
239 tps.add(updateTp(tp, false, linkType));
241 if (links.size() == 2 && tps.size() == 2) {
242 return new TopologyShard(null, links, tps);
244 return new TopologyShard(null, null, null);
248 private static List<Link> initialiseOtnLinks(String nodeA, String tpA, String nodeZ, String tpZ,
249 OtnLinkType linkType) {
250 List<Link> links = new ArrayList<>();
251 String nodeATopo = formatNodeName(nodeA, tpA);
252 String nodeZTopo = formatNodeName(nodeZ, tpZ);
253 org.opendaylight.yang.gen.v1.http.transportpce.topology.rev210511.Link1 tpceLink1
254 = new org.opendaylight.yang.gen.v1.http.transportpce.topology.rev210511.Link1Builder()
255 .setOtnLinkType(linkType).build();
256 Link1Builder otnLink1Bldr = new Link1Builder()
257 .setUsedBandwidth(Uint32.valueOf(0));
261 otnLink1Bldr.setAvailableBandwidth(Uint32.valueOf(100000));
265 otnLink1Bldr.setAvailableBandwidth(Uint32.valueOf(400000));
268 LOG.error("unable to set available bandwidth to unknown link type");
272 LinkBuilder ietfLinkAZBldr = TopologyUtils.createLink(nodeATopo, nodeZTopo, tpA, tpZ, linkType.getName());
274 .addAugmentation(tpceLink1)
275 .addAugmentation(otnLink1Bldr.build())
277 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Link1Builder(
278 ietfLinkAZBldr.augmentation(
279 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Link1.class))
280 .setLinkType(OpenroadmLinkType.OTNLINK)
281 .setOperationalState(State.InService)
282 .setAdministrativeState(AdminStates.InService)
284 links.add(ietfLinkAZBldr.build());
286 LinkBuilder ietfLinkZABldr = TopologyUtils.createLink(nodeZTopo, nodeATopo, tpZ, tpA, linkType.getName());
288 .addAugmentation(tpceLink1)
289 .addAugmentation(otnLink1Bldr.build())
291 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Link1Builder(
292 ietfLinkZABldr.augmentation(
293 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Link1.class))
294 .setLinkType(OpenroadmLinkType.OTNLINK)
295 .setOperationalState(State.InService)
296 .setAdministrativeState(AdminStates.InService)
298 links.add(ietfLinkZABldr.build());
302 private static Link updateOtnLinkBwParameters(Link link, Long availBw, Long usedBw) {
303 LOG.debug("in updateOtnLinkBwParameters with availBw = {}, usedBw = {}", availBw, usedBw);
304 LinkBuilder updatedLinkBldr = new LinkBuilder(link);
305 Link1Builder updatedLink1Bldr = new Link1Builder(link.augmentation(Link1.class))
306 .setAvailableBandwidth(Uint32.valueOf(availBw))
307 .setUsedBandwidth(Uint32.valueOf(usedBw));
308 updatedLinkBldr.addAugmentation(updatedLink1Bldr.build());
309 return updatedLinkBldr.build();
312 private static TerminationPoint updateTp(TerminationPoint originalTp, boolean addingTsTpnPoolTermination,
313 OtnLinkType linkType) {
314 LOG.debug("in updateTp");
315 TerminationPointBuilder tpBldr = new TerminationPointBuilder(originalTp);
316 TerminationPoint1Builder otnTp1Bldr = new TerminationPoint1Builder(
317 tpBldr.augmentation(TerminationPoint1.class));
318 XpdrTpPortConnectionAttributesBuilder xtpcaBldr = new XpdrTpPortConnectionAttributesBuilder(otnTp1Bldr
319 .getXpdrTpPortConnectionAttributes());
320 if (addingTsTpnPoolTermination) {
321 List<Uint16> tsPool = new ArrayList<>();
322 for (int i = 1; i <= NB_TRIB_SLOTS; i++) {
323 tsPool.add(Uint16.valueOf(i));
325 xtpcaBldr.setTsPool(tsPool);
326 List<Uint16> tpnPool = new ArrayList<>();
327 int nbTribPort = NB_TRIB_PORTS;
328 if (OtnLinkType.ODUC4.equals(linkType)) {
331 for (int i = 1; i <= nbTribPort; i++) {
332 tpnPool.add(Uint16.valueOf(i));
334 OdtuTpnPool oduTpnPool = new OdtuTpnPoolBuilder().setOdtuType(ODTU4TsAllocated.class)
335 .setTpnPool(tpnPool).build();
336 xtpcaBldr.setOdtuTpnPool(ImmutableMap.of(oduTpnPool.key(),oduTpnPool));
338 xtpcaBldr.setTsPool(null);
339 xtpcaBldr.setOdtuTpnPool(ImmutableMap.of());
341 return tpBldr.addAugmentation(otnTp1Bldr.setXpdrTpPortConnectionAttributes(xtpcaBldr.build()).build()).build();
344 private static TerminationPoint updateNodeTpTsPool(TerminationPoint tp, Uint32 serviceRate, Short tribPortNb,
345 Short minTribSlotNb, Short maxTribSlotNb, boolean isDeletion) {
346 LOG.debug("in updateNodeTpTsPool");
347 TerminationPointBuilder tpBldr = new TerminationPointBuilder(tp);
349 XpdrTpPortConnectionAttributesBuilder xtpcaBldr = new XpdrTpPortConnectionAttributesBuilder(
350 tpBldr.augmentation(TerminationPoint1.class).getXpdrTpPortConnectionAttributes());
351 List<Uint16> tsPool = new ArrayList<>(xtpcaBldr.getTsPool());
353 for (int i = minTribSlotNb; i <= maxTribSlotNb; i++) {
354 tsPool.add(Uint16.valueOf(i));
357 for (int i = minTribSlotNb; i <= maxTribSlotNb; i++) {
358 tsPool.remove(Uint16.valueOf(i));
361 xtpcaBldr.setTsPool(tsPool);
362 List<Uint16> tpnPool;
363 List<OdtuTpnPool> odtuTpnPoolValues = new ArrayList<>(xtpcaBldr.getOdtuTpnPool().values());
364 if (odtuTpnPoolValues.get(0).getTpnPool() != null) {
365 tpnPool = new ArrayList<>(odtuTpnPoolValues.get(0).getTpnPool());
367 tpnPool.add(Uint16.valueOf(tribPortNb));
369 tpnPool.remove(Uint16.valueOf(tribPortNb));
372 tpnPool = new ArrayList<>();
374 Class<? extends OdtuTypeIdentity> odtuType = null;
375 switch (serviceRate.intValue()) {
378 odtuType = ODTU4TsAllocated.class;
381 odtuType = ODTUCnTs.class;
384 LOG.warn("Unable to set the odtu-type");
387 OdtuTpnPool odtuTpnPool = new OdtuTpnPoolBuilder().setOdtuType(odtuType)
388 .setTpnPool(tpnPool).build();
389 xtpcaBldr.setOdtuTpnPool(ImmutableMap.of(odtuTpnPool.key(),odtuTpnPool));
391 tpBldr.addAugmentation(new TerminationPoint1Builder(tp.augmentation(TerminationPoint1.class))
392 .setXpdrTpPortConnectionAttributes(xtpcaBldr.build()).build());
393 return tpBldr.build();
396 private static Map<Integer, OtnTopoNode> convertPortMappingToOtnNodeList(Nodes mappingNode) {
397 List<Mapping> networkMappings = mappingNode.nonnullMapping().values()
398 .stream().filter(k -> k.getLogicalConnectionPoint()
399 .contains("NETWORK")).collect(Collectors.toList());
400 Map<Integer, OtnTopoNode> xpdrMap = new HashMap<>();
401 for (Mapping mapping : networkMappings) {
402 Integer xpdrNb = Integer.parseInt(mapping.getLogicalConnectionPoint().split("XPDR")[1].split("-")[0]);
403 if (!xpdrMap.containsKey(xpdrNb)) {
404 List<Mapping> xpdrNetMaps = mappingNode.nonnullMapping().values()
405 .stream().filter(k -> k.getLogicalConnectionPoint()
406 .contains("XPDR" + xpdrNb + NETWORK)).collect(Collectors.toList());
407 List<Mapping> xpdrClMaps = mappingNode.nonnullMapping().values()
408 .stream().filter(k -> k.getLogicalConnectionPoint()
409 .contains("XPDR" + xpdrNb + CLIENT)).collect(Collectors.toList());
410 OtnTopoNode otnNode = null;
411 if (mapping.getXponderType() != null) {
412 otnNode = new OtnTopoNode(mappingNode.getNodeId(), mappingNode.getNodeInfo().getNodeClli(), xpdrNb,
413 mapping.getXponderType(), fillConnectionMapLcp(xpdrNetMaps), fillConnectionMapLcp(xpdrClMaps),
414 xpdrNetMaps, xpdrClMaps);
416 otnNode = new OtnTopoNode(mappingNode.getNodeId(), mappingNode.getNodeInfo().getNodeClli(), xpdrNb,
417 XpdrNodeTypes.Tpdr, fillConnectionMapLcp(xpdrNetMaps), fillConnectionMapLcp(xpdrClMaps),
418 xpdrNetMaps, xpdrClMaps);
420 xpdrMap.put(xpdrNb, otnNode);
423 LOG.debug("there are {} xpdr to build", xpdrMap.size());
424 xpdrMap.forEach((k, v) -> LOG.debug("xpdr {} = {} - {} - {} - {}", k, v.getNodeId(), v.getNodeType(),
425 v.getNbTpClient(), v.getNbTpNetwork()));
429 private static Map<String, String> fillConnectionMapLcp(List<Mapping> mappingList) {
430 Map<String, String> xpdrConnectionMap = new HashMap<>();
431 for (Mapping map : mappingList) {
432 if (map.getConnectionMapLcp() != null) {
433 xpdrConnectionMap.put(map.getLogicalConnectionPoint(), map.getConnectionMapLcp());
435 xpdrConnectionMap.put(map.getLogicalConnectionPoint(), null);
438 return xpdrConnectionMap;
441 private static Node createTpdr(OtnTopoNode node) {
442 // create otn-topology node augmentation
443 XpdrAttributes xpdrAttr = new XpdrAttributesBuilder()
444 .setXpdrNumber(Uint16.valueOf(node.getXpdrNb()))
446 Node1 otnNodeAug = new Node1Builder()
447 .setXpdrAttributes(xpdrAttr)
449 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Node1 ocnNodeAug =
450 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Node1Builder()
451 .setNodeType(OpenroadmNodeType.TPDR)
452 .setOperationalState(State.InService)
453 .setAdministrativeState(AdminStates.InService)
455 // create ietf node augmentation to add TP list
456 Map<TerminationPointKey,TerminationPoint> tpMap = new HashMap<>();
458 createTP(tpMap, node, OpenroadmTpType.XPONDERCLIENT, false);
459 createTP(tpMap, node, OpenroadmTpType.XPONDERNETWORK, true);
461 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1 ietfNodeAug =
462 new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1Builder()
463 .setTerminationPoint(tpMap)
467 return new NodeBuilder()
468 .setNodeId(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb()))
469 .withKey(new NodeKey(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb())))
470 .setSupportingNode(createSupportingNodes(node))
471 .addAugmentation(otnNodeAug)
472 .addAugmentation(ocnNodeAug)
473 .addAugmentation(ietfNodeAug)
477 private static Node createMuxpdr(OtnTopoNode node) {
478 // create otn-topology node augmentation
479 // TODO: will need to be completed
480 TpBandwidthSharing tpBwSh = new TpBandwidthSharingBuilder().build();
481 XpdrAttributes xpdrAttr = new XpdrAttributesBuilder()
482 .setXpdrNumber(Uint16.valueOf(node.getXpdrNb()))
485 Map<NonBlockingListKey, NonBlockingList> nbMap = new HashMap<>();
486 for (int i = 1; i <= node.getNbTpClient(); i++) {
487 List<TpId> tpList = new ArrayList<>();
488 TpId tpId = new TpId("XPDR" + node.getXpdrNb() + CLIENT + i);
490 tpId = new TpId("XPDR" + node.getXpdrNb() + "-NETWORK1");
492 NonBlockingList nbl = new NonBlockingListBuilder()
493 .setNblNumber(Uint16.valueOf(i))
495 .setAvailableInterconnectBandwidth(Uint32.valueOf(node.getNbTpNetwork() * 10L))
496 .setInterconnectBandwidthUnit(Uint32.valueOf(1000000000))
498 nbMap.put(nbl.key(),nbl);
500 OduSwitchingPools oduSwitchPool = new OduSwitchingPoolsBuilder()
501 .setSwitchingPoolNumber(Uint16.valueOf(1))
502 .setSwitchingPoolType(SwitchingPoolTypes.NonBlocking)
503 .setNonBlockingList(nbMap)
505 SwitchingPools switchingPools = new SwitchingPoolsBuilder()
506 .setOduSwitchingPools(Map.of(oduSwitchPool.key(),oduSwitchPool))
508 Node1 otnNodeAug = new Node1Builder()
509 .setTpBandwidthSharing(tpBwSh)
510 .setXpdrAttributes(xpdrAttr)
511 .setSwitchingPools(switchingPools)
513 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Node1 ocnNodeAug =
514 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Node1Builder()
515 .setNodeType(OpenroadmNodeType.MUXPDR)
516 .setAdministrativeState(AdminStates.InService)
517 .setOperationalState(State.InService)
520 // create ietf node augmentation to add TP list
521 Map<TerminationPointKey, TerminationPoint> tpMap = new HashMap<>();
523 createTP(tpMap, node, OpenroadmTpType.XPONDERCLIENT, true);
524 createTP(tpMap, node, OpenroadmTpType.XPONDERNETWORK, true);
526 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1 ietfNodeAug =
527 new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1Builder()
528 .setTerminationPoint(tpMap)
532 return new NodeBuilder()
533 .setNodeId(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb()))
534 .withKey(new NodeKey(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb())))
535 .setSupportingNode(createSupportingNodes(node))
536 .addAugmentation(otnNodeAug)
537 .addAugmentation(ocnNodeAug)
538 .addAugmentation(ietfNodeAug)
542 private static Node createSwitch(OtnTopoNode node) {
543 List<TpId> tpl = new ArrayList<>();
545 for (int i = 1; i <= node.getNbTpClient(); i++) {
546 tpId = new TpId("XPDR" + node.getXpdrNb() + CLIENT + i);
549 for (int i = 1; i <= node.getNbTpNetwork(); i++) {
550 tpId = new TpId("XPDR" + node.getXpdrNb() + NETWORK + i);
553 Map<NonBlockingListKey, NonBlockingList> nbMap = new HashMap<>();
554 NonBlockingList nbl = new NonBlockingListBuilder()
555 .setNblNumber(Uint16.valueOf(1))
558 nbMap.put(nbl.key(),nbl);
560 OduSwitchingPools oduSwitchPool = new OduSwitchingPoolsBuilder()
561 .setSwitchingPoolNumber(Uint16.valueOf(1))
562 .setSwitchingPoolType(SwitchingPoolTypes.NonBlocking)
563 .setNonBlockingList(nbMap)
565 Map<OduSwitchingPoolsKey, OduSwitchingPools> oduSwitchPoolList = new HashMap<>();
566 oduSwitchPoolList.put(oduSwitchPool.key(),oduSwitchPool);
567 SwitchingPools switchingPools = new SwitchingPoolsBuilder()
568 .setOduSwitchingPools(oduSwitchPoolList)
571 // create otn-topology node augmentation
572 // TODO: will need to be completed
573 TpBandwidthSharing tpBwSh = new TpBandwidthSharingBuilder().build();
574 XpdrAttributes xpdrAttr = new XpdrAttributesBuilder()
575 .setXpdrNumber(Uint16.valueOf(node.getXpdrNb()))
578 Node1 otnNodeAug = new Node1Builder()
579 .setTpBandwidthSharing(tpBwSh)
580 .setXpdrAttributes(xpdrAttr)
581 .setSwitchingPools(switchingPools)
583 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Node1 ocnNodeAug =
584 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Node1Builder()
585 .setNodeType(OpenroadmNodeType.SWITCH)
586 .setOperationalState(State.InService)
587 .setAdministrativeState(AdminStates.InService)
590 // create ietf node augmentation to add TP list
591 Map<TerminationPointKey, TerminationPoint> tpMap = new HashMap<>();
593 createTP(tpMap, node, OpenroadmTpType.XPONDERCLIENT, true);
594 createTP(tpMap, node, OpenroadmTpType.XPONDERNETWORK, true);
595 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1 ietfNodeAug =
596 new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1Builder()
597 .setTerminationPoint(tpMap)
601 return new NodeBuilder()
602 .setNodeId(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb()))
603 .withKey(new NodeKey(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb())))
604 .setSupportingNode(createSupportingNodes(node))
605 .addAugmentation(otnNodeAug)
606 .addAugmentation(ocnNodeAug)
607 .addAugmentation(ietfNodeAug)
611 private static void createTP(Map<TerminationPointKey, TerminationPoint> tpMap,
612 OtnTopoNode node, OpenroadmTpType tpType, boolean withRate) {
613 List<Mapping> mappings = null;
616 mappings = node.getXpdrNetMappings();
619 mappings = node.getXpdrClMappings();
622 LOG.error("Error with Termination Point type {}", tpType);
625 fillTpMap(tpMap, node, tpType, withRate, mappings);
628 private static void fillTpMap(Map<TerminationPointKey, TerminationPoint> tpMap, OtnTopoNode node,
629 OpenroadmTpType tpType, boolean withRate, List<Mapping> mappings) {
630 for (Mapping mapping : mappings) {
631 // openroadm-otn-topoology augmentation
632 Map<SupportedInterfaceCapabilityKey, SupportedInterfaceCapability> supIfMap = new HashMap<>();
633 TerminationPoint1Builder otnTp1Bldr = new TerminationPoint1Builder();
634 if (mapping.getSupportedInterfaceCapability() != null) {
635 XpdrTpPortConnectionAttributesBuilder xtpcaBldr = new XpdrTpPortConnectionAttributesBuilder();
636 for (Class<? extends SupportedIfCapability> supInterCapa : mapping.getSupportedInterfaceCapability()) {
637 SupportedInterfaceCapability supIfCapa = new SupportedInterfaceCapabilityBuilder()
638 .withKey(new SupportedInterfaceCapabilityKey(supInterCapa))
639 .setIfCapType(supInterCapa)
641 supIfMap.put(supIfCapa.key(), supIfCapa);
643 TpSupportedInterfaces tpSupIf = new TpSupportedInterfacesBuilder()
644 .setSupportedInterfaceCapability(supIfMap)
646 otnTp1Bldr.setTpSupportedInterfaces(tpSupIf);
648 xtpcaBldr.setRate(fixRate(mapping.getSupportedInterfaceCapability().get(0)));
649 otnTp1Bldr.setXpdrTpPortConnectionAttributes(xtpcaBldr.build());
652 LOG.warn("mapping {} of node {} has no if-cap-type", mapping.getLogicalConnectionPoint(),
655 org.opendaylight.yang.gen.v1.http.transportpce.topology.rev210511.TerminationPoint1Builder tpceTp1Bldr =
656 new org.opendaylight.yang.gen.v1.http.transportpce.topology.rev210511.TerminationPoint1Builder();
657 TpId tpId = new TpId(mapping.getLogicalConnectionPoint());
658 setclientNwTpAttr(tpMap, node, tpId, tpType, otnTp1Bldr.build(), tpceTp1Bldr, mapping);
662 private static void setclientNwTpAttr(Map<TerminationPointKey, TerminationPoint> tpMap, OtnTopoNode node, TpId tpId,
663 OpenroadmTpType tpType, TerminationPoint1 otnTp1,
664 org.opendaylight.yang.gen.v1.http.transportpce.topology.rev210511.TerminationPoint1Builder tpceTp1Bldr,
668 if (node.getXpdrNetConnectionMap().get(tpId.getValue()) != null) {
669 tpceTp1Bldr.setAssociatedConnectionMapPort(node.getXpdrNetConnectionMap().get(tpId.getValue()));
671 SupportingTerminationPoint stp = new SupportingTerminationPointBuilder()
672 .setNetworkRef(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID))
673 .setNodeRef(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb()))
674 .setTpRef(tpId.getValue())
676 TerminationPoint ietfTpNw = buildIetfTp(tpceTp1Bldr, otnTp1, tpType, tpId, Map.of(stp.key(), stp),
678 tpMap.put(ietfTpNw.key(),ietfTpNw);
681 if (node.getXpdrCliConnectionMap().get(tpId.getValue()) != null) {
682 tpceTp1Bldr.setAssociatedConnectionMapPort(node.getXpdrCliConnectionMap().get(tpId.getValue()));
684 TerminationPoint ietfTpCl = buildIetfTp(tpceTp1Bldr, otnTp1, tpType, tpId, null, mapping);
685 tpMap.put(ietfTpCl.key(),ietfTpCl);
688 LOG.error("Undefined tpType for Termination point {} of {}", tpId.getValue(), node.getNodeId());
693 private static Class<? extends OduRateIdentity> fixRate(Class<? extends
694 SupportedIfCapability> ifCapType) {
695 switch (ifCapType.getSimpleName()) {
697 case "IfOCHOTU4ODU4":
710 private static Map<SupportingNodeKey,SupportingNode> createSupportingNodes(OtnTopoNode node) {
711 SupportingNode suppNode1 = new SupportingNodeBuilder()
712 .setNetworkRef(new NetworkId(NetworkUtils.UNDERLAY_NETWORK_ID))
713 .setNodeRef(new NodeId(node.getNodeId()))
714 .withKey(new SupportingNodeKey(new NetworkId(NetworkUtils.UNDERLAY_NETWORK_ID),
715 new NodeId(node.getNodeId())))
717 SupportingNode suppNode2 = new SupportingNodeBuilder()
718 .setNetworkRef(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID))
719 .setNodeRef(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb()))
720 .withKey(new SupportingNodeKey(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID),
721 new NodeId(node.getNodeId() + XPDR + node.getXpdrNb())))
723 SupportingNode suppNode3 = new SupportingNodeBuilder()
724 .setNetworkRef(new NetworkId(NetworkUtils.CLLI_NETWORK_ID))
725 .setNodeRef(new NodeId(node.getClli()))
726 .withKey(new SupportingNodeKey(new NetworkId(NetworkUtils.CLLI_NETWORK_ID),
727 new NodeId(node.getClli())))
729 Map<SupportingNodeKey,SupportingNode> suppNodeMap = new HashMap<>();
730 suppNodeMap.put(suppNode1.key(),suppNode1);
731 suppNodeMap.put(suppNode2.key(),suppNode2);
732 suppNodeMap.put(suppNode3.key(),suppNode3);
736 private static TerminationPoint buildIetfTp(
737 org.opendaylight.yang.gen.v1.http.transportpce.topology.rev210511.TerminationPoint1Builder tpceTp1Bldr,
738 TerminationPoint1 otnTp1, OpenroadmTpType tpType, TpId tpId,
739 Map<SupportingTerminationPointKey, SupportingTerminationPoint> supportTpMap, Mapping mapping) {
741 TerminationPointBuilder ietfTpBldr = new TerminationPointBuilder();
742 if (tpceTp1Bldr.getAssociatedConnectionMapPort() != null) {
743 ietfTpBldr.addAugmentation(tpceTp1Bldr.build());
745 if (supportTpMap != null) {
746 ietfTpBldr.setSupportingTerminationPoint(supportTpMap);
748 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.TerminationPoint1 ocnTp =
749 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.TerminationPoint1Builder()
751 .setAdministrativeState(TopologyUtils.setNetworkAdminState(mapping.getPortAdminState()))
752 .setOperationalState(TopologyUtils.setNetworkOperState(mapping.getPortOperState()))
755 ietfTpBldr.setTpId(tpId)
756 .withKey(new TerminationPointKey(tpId))
757 .addAugmentation(otnTp1)
758 .addAugmentation(ocnTp);
759 return ietfTpBldr.build();
762 private static String formatNodeName(String nodeName, String tpName) {
763 String newNodeName = null;
764 if (nodeName.contains(XPDR)) {
765 newNodeName = nodeName;
767 newNodeName = new StringBuilder(nodeName).append("-").append(tpName.split("-")[0]).toString();