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.HashSet;
15 import java.util.List;
18 import java.util.stream.Collectors;
19 import org.eclipse.jdt.annotation.Nullable;
20 import org.opendaylight.transportpce.common.NetworkUtils;
21 import org.opendaylight.transportpce.networkmodel.dto.OtnTopoNode;
22 import org.opendaylight.transportpce.networkmodel.dto.TopologyShard;
23 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.networkutils.rev220630.OtnLinkType;
24 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev231221.mapping.Mapping;
25 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev231221.network.Nodes;
26 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.state.types.rev191129.State;
27 import org.opendaylight.yang.gen.v1.http.org.openroadm.device.types.rev191129.XpdrNodeTypes;
28 import org.opendaylight.yang.gen.v1.http.org.openroadm.equipment.states.types.rev191129.AdminStates;
29 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev230526.xpdr.odu.switching.pools.OduSwitchingPools;
30 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev230526.xpdr.odu.switching.pools.OduSwitchingPoolsBuilder;
31 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev230526.xpdr.odu.switching.pools.OduSwitchingPoolsKey;
32 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev230526.xpdr.odu.switching.pools.odu.switching.pools.NonBlockingList;
33 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev230526.xpdr.odu.switching.pools.odu.switching.pools.NonBlockingListBuilder;
34 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev230526.xpdr.odu.switching.pools.odu.switching.pools.NonBlockingListKey;
35 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev230526.OpenroadmLinkType;
36 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev230526.OpenroadmNodeType;
37 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev230526.OpenroadmTpType;
38 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev230526.xpdr.tp.supported.interfaces.SupportedInterfaceCapability;
39 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev230526.xpdr.tp.supported.interfaces.SupportedInterfaceCapabilityBuilder;
40 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev230526.xpdr.tp.supported.interfaces.SupportedInterfaceCapabilityKey;
41 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.ODTU4TsAllocated;
42 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.ODTUCnTs;
43 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.ODU0;
44 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.ODU2;
45 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.ODU2e;
46 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.ODU4;
47 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.OdtuTypeIdentity;
48 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.OduRateIdentity;
49 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev230526.Link1;
50 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev230526.Link1Builder;
51 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev230526.Node1Builder;
52 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev230526.TerminationPoint1;
53 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev230526.TerminationPoint1Builder;
54 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev230526.networks.network.node.SwitchingPoolsBuilder;
55 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev230526.networks.network.node.TpBandwidthSharingBuilder;
56 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev230526.networks.network.node.XpdrAttributesBuilder;
57 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev230526.networks.network.node.termination.point.TpSupportedInterfacesBuilder;
58 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev230526.networks.network.node.termination.point.XpdrTpPortConnectionAttributesBuilder;
59 import org.opendaylight.yang.gen.v1.http.org.openroadm.switching.pool.types.rev191129.SwitchingPoolTypes;
60 import org.opendaylight.yang.gen.v1.http.org.openroadm.xponder.rev230526.xpdr.otn.tp.attributes.OdtuTpnPool;
61 import org.opendaylight.yang.gen.v1.http.org.openroadm.xponder.rev230526.xpdr.otn.tp.attributes.OdtuTpnPoolBuilder;
62 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NetworkId;
63 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NodeId;
64 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.Node;
65 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.NodeBuilder;
66 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.NodeKey;
67 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.node.SupportingNode;
68 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.node.SupportingNodeBuilder;
69 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.node.SupportingNodeKey;
70 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.TpId;
71 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.Link;
72 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.LinkBuilder;
73 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPoint;
74 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPointBuilder;
75 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPointKey;
76 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.termination.point.SupportingTerminationPoint;
77 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.termination.point.SupportingTerminationPointBuilder;
78 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.termination.point.SupportingTerminationPointKey;
79 import org.opendaylight.yangtools.yang.common.Uint16;
80 import org.opendaylight.yangtools.yang.common.Uint32;
81 import org.slf4j.Logger;
82 import org.slf4j.LoggerFactory;
84 public final class OpenRoadmOtnTopology {
86 private static final Logger LOG = LoggerFactory.getLogger(OpenRoadmOtnTopology.class);
87 private static final String CLIENT = "-CLIENT";
88 private static final String NETWORK = "-NETWORK";
89 private static final String XPDR = "-XPDR";
90 private static final String OTN_PARAMS_ERROR = "Error with otn parameters of supported link {}";
91 private static final int NB_TRIB_PORTS = 80;
92 private static final int NB_TRIB_SLOTS = 80;
94 private static final Map<String, OduRateIdentity> RATE_MAP = Map.of(
95 "If100GEODU4", ODU4.VALUE,
96 "IfOCHOTU4ODU4", ODU4.VALUE,
97 "If1GEODU0", ODU0.VALUE,
98 "If10GEODU2", ODU2.VALUE,
99 "If10GEODU2e", ODU2e.VALUE);
100 private static final Map<OtnLinkType, Long> OTNLINKTYPE_BW_MAP = Map.of(
101 OtnLinkType.ODTU4, 100000L,
102 OtnLinkType.ODUC4, 400000L,
103 OtnLinkType.ODUC3, 300000L,
104 OtnLinkType.ODUC2, 200000L);
105 private static final Map<OtnLinkType, Long> OTNLINKTYPE_OTU_BW_MAP = Map.of(
106 OtnLinkType.OTU4, 100000L,
107 OtnLinkType.OTUC4, 400000L);
108 private static final Map<Uint32, Long> SERVICERATE_BWINCR_MAP = Map.of(
109 Uint32.valueOf(1), 1000L,
110 Uint32.valueOf(10), 10000L,
111 Uint32.valueOf(100), 100000L);
112 private static final Map<Uint32, OdtuTypeIdentity> SERVICERATE_ODTUTYPECLASS_MAP = Map.of(
113 Uint32.valueOf(1), ODTU4TsAllocated.VALUE,
114 Uint32.valueOf(10), ODTU4TsAllocated.VALUE,
115 Uint32.valueOf(100), ODTUCnTs.VALUE);
117 private OpenRoadmOtnTopology() {
120 public static TopologyShard createTopologyShard(Nodes mappingNode) {
121 List<Node> nodes = new ArrayList<>();
122 List<Link> links = new ArrayList<>();
123 Map<Integer, OtnTopoNode> xpdrMap = convertPortMappingToOtnNodeList(mappingNode);
124 for (OtnTopoNode node : xpdrMap.values()) {
125 switch (node.getNodeType()) {
127 nodes.add(createTpdr(node));
130 nodes.add(createMuxpdr(node));
133 nodes.add(createSwitch(node));
137 // TODO: Need to revisit this method
138 nodes.add(createRegen(node));
141 LOG.error("unknown otn node type {}", node.getNodeType().getName());
145 return new TopologyShard(nodes, links);
148 public static TopologyShard createOtnLinks(String nodeA, String tpA, String nodeZ, String tpZ,
149 OtnLinkType linkType) {
151 return new TopologyShard(
153 OTNLINKTYPE_OTU_BW_MAP.containsKey(linkType)
154 ? initialiseOtnLinks(nodeA, tpA, nodeZ, tpZ, linkType)
158 public static TopologyShard createOtnLinks(
159 org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev210915.renderer.rpc.result.sp
161 OtnLinkType linkType) {
163 return new TopologyShard(
165 initialiseOtnLinks(notifLink.getATermination().getNodeId(),
166 notifLink.getATermination().getTpId(),
167 notifLink.getZTermination().getNodeId(),
168 notifLink.getZTermination().getTpId(),
172 public static TopologyShard createOtnLinks(
173 org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.renderer.rev210915.renderer.rpc.result.sp
175 List<Link> supportedOtu4links, List<TerminationPoint> supportedTPs, OtnLinkType linkType) {
177 if (OTNLINKTYPE_OTU_BW_MAP.containsKey(linkType)) {
178 return new TopologyShard(
181 notifLink.getATermination().getNodeId(), notifLink.getATermination().getTpId(),
182 notifLink.getZTermination().getNodeId(), notifLink.getZTermination().getTpId(), linkType));
183 } else if (OTNLINKTYPE_BW_MAP.containsKey(linkType)) {
184 List<Link> links = initialiseOtnLinks(
185 notifLink.getATermination().getNodeId(), notifLink.getATermination().getTpId(),
186 notifLink.getZTermination().getNodeId(), notifLink.getZTermination().getTpId(), linkType);
187 links.addAll(updateOtnLinkBwParameters(supportedOtu4links, linkType));
188 List<TerminationPoint> updatedTPs = new ArrayList<>();
189 for (TerminationPoint tp : supportedTPs) {
190 updatedTPs.add(updateTp(tp, true, linkType));
192 return new TopologyShard(null, links, updatedTPs);
198 public static TopologyShard createOtnLinks(List<Link> suppOtuLinks, List<TerminationPoint> oldTps,
199 OtnLinkType linkType) {
201 List<Link> links = new ArrayList<>();
202 for (Link link : suppOtuLinks) {
203 if (link.augmentation(Link1.class) == null) {
204 LOG.error("Error with OTN parameters of supported link {}", link.getLinkId().getValue());
207 if (!OTNLINKTYPE_BW_MAP.containsKey(linkType)) {
208 LOG.error("Error with link {} : unsupported OTN link type", link.getLinkId().getValue());
211 if (link.augmentation(Link1.class).getAvailableBandwidth().longValue() < OTNLINKTYPE_BW_MAP.get(linkType)) {
212 LOG.error("Error with link {} : unsufficient available bandwith", link.getLinkId().getValue());
215 links.add(updateOtnLinkBwParameters(link, 0L, OTNLINKTYPE_BW_MAP.get(linkType)));
217 if (links.size() == 2) {
218 links.addAll(initialiseOtnLinks(suppOtuLinks.get(0).getSource().getSourceNode().getValue(),
219 suppOtuLinks.get(0).getSource().getSourceTp().getValue(),
220 suppOtuLinks.get(0).getDestination().getDestNode().getValue(),
221 suppOtuLinks.get(0).getDestination().getDestTp().getValue(),
224 List<TerminationPoint> tps = new ArrayList<>();
225 for (TerminationPoint tp : oldTps) {
226 tps.add(updateTp(tp, true, linkType));
228 return links.size() == 4 && tps.size() == 2
229 ? new TopologyShard(null, links, tps)
230 : new TopologyShard(null, null, null);
233 public static TopologyShard updateOtnLinks(List<Link> suppOduLinks, List<TerminationPoint> oldTps,
234 Uint32 serviceRate, Short tribPortNb, Short minTribSlotNb, Short maxTribSlotNb, boolean isDeletion) {
236 List<Link> links = new ArrayList<>();
237 if (!SERVICERATE_BWINCR_MAP.containsKey(serviceRate)) {
238 LOG.warn("Error with not managed service rate {}", serviceRate.toString());
239 return new TopologyShard(null, null, null);
241 Long bwIncr = SERVICERATE_BWINCR_MAP.get(serviceRate);
242 for (Link link : suppOduLinks) {
243 if (link.augmentation(Link1.class) == null
244 || link.augmentation(Link1.class).getAvailableBandwidth() == null
245 || link.augmentation(Link1.class).getUsedBandwidth() == null) {
246 LOG.error(OTN_PARAMS_ERROR, link.getLinkId().getValue());
248 Uint32 avlBw = link.augmentation(Link1.class).getAvailableBandwidth();
249 Uint32 usedBw = link.augmentation(Link1.class).getUsedBandwidth();
250 if (avlBw.toJava() < bwIncr) {
255 ? updateOtnLinkBwParameters(link, avlBw.toJava() + bwIncr, usedBw.toJava() - bwIncr)
256 : updateOtnLinkBwParameters(link, avlBw.toJava() - bwIncr, usedBw.toJava() + bwIncr)
260 List<TerminationPoint> tps = new ArrayList<>();
261 for (TerminationPoint tp : oldTps) {
263 tps.add(updateNodeTpTsPool(tp, serviceRate, tribPortNb, minTribSlotNb, maxTribSlotNb, isDeletion));
266 if (links.isEmpty() || tps.isEmpty()) {
267 LOG.error("unable to update otn links");
268 return new TopologyShard(null, null, null);
270 return new TopologyShard(null, links, tps);
274 public static TopologyShard updateOtnLinks(List<Link> suppOtuLinks, boolean isDeletion) {
276 List<Link> links = new ArrayList<>();
277 for (Link link : suppOtuLinks) {
278 if (link.augmentation(Link1.class) == null
279 || link.augmentation(Link1.class).getAvailableBandwidth() == null
280 || link.augmentation(Link1.class).getUsedBandwidth() == null) {
281 LOG.error(OTN_PARAMS_ERROR, link.getLinkId().getValue());
285 ? updateOtnLinkBwParameters(link, Long.valueOf(100000), Long.valueOf(0))
286 : updateOtnLinkBwParameters(link, Long.valueOf(0), Long.valueOf(100000))
290 if (links.isEmpty()) {
291 LOG.error("unable to update otn links");
292 return new TopologyShard(null, null, null);
294 return new TopologyShard(null, links, null);
298 public static TopologyShard deleteOtnLinks(List<Link> suppOtuLinks, List<TerminationPoint> oldTps,
299 OtnLinkType linkType) {
301 List<Link> links = new ArrayList<>();
302 for (Link link : suppOtuLinks) {
303 if (link.augmentation(Link1.class) == null
304 || link.augmentation(
305 org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.networkutils.rev220630
306 .Link1.class) == null) {
307 LOG.error(OTN_PARAMS_ERROR, link.getLinkId().getValue());
308 return new TopologyShard(null, null, null);
310 OtnLinkType otnLinkType = link.augmentation(
311 org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.networkutils.rev220630.Link1.class)
313 if (!OTNLINKTYPE_OTU_BW_MAP.containsKey(otnLinkType)) {
314 //TODO shouldn't other link type listed in OTNLINKTYPE_BW_MAP be handled too ?
315 LOG.warn("Unexpected otn-link-type {} for link {}", otnLinkType, link.getLinkId());
318 links.add(updateOtnLinkBwParameters(link, OTNLINKTYPE_OTU_BW_MAP.get(otnLinkType) , 0L));
320 List<TerminationPoint> tps = new ArrayList<>();
321 for (TerminationPoint tp : oldTps) {
322 tps.add(updateTp(tp, false, linkType));
325 links.isEmpty() || tps.isEmpty()
326 ? new TopologyShard(null, null, null)
327 : new TopologyShard(null, links, tps);
330 private static List<Link> initialiseOtnLinks(String nodeA, String tpA, String nodeZ, String tpZ,
331 OtnLinkType linkType) {
333 List<Link> links = new ArrayList<>();
334 String nodeATopo = formatNodeName(nodeA, tpA);
335 String nodeZTopo = formatNodeName(nodeZ, tpZ);
336 org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.networkutils.rev220630.Link1 tpceLink1
337 = new org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.networkutils.rev220630.Link1Builder()
338 .setOtnLinkType(linkType).build();
339 Link1Builder otnLink1Bldr = new Link1Builder()
340 .setUsedBandwidth(Uint32.valueOf(0));
341 if (OTNLINKTYPE_OTU_BW_MAP.containsKey(linkType)) {
342 otnLink1Bldr.setAvailableBandwidth(Uint32.valueOf(OTNLINKTYPE_OTU_BW_MAP.get(linkType)));
343 } else if (OTNLINKTYPE_BW_MAP.containsKey(linkType)) {
344 otnLink1Bldr.setAvailableBandwidth(Uint32.valueOf(OTNLINKTYPE_BW_MAP.get(linkType)));
346 LOG.error("unable to set available bandwidth to unknown link type");
349 LinkBuilder ietfLinkAZBldr = TopologyUtils.createLink(nodeATopo, nodeZTopo, tpA, tpZ, linkType.getName());
350 links.add(ietfLinkAZBldr
351 .addAugmentation(tpceLink1)
352 .addAugmentation(otnLink1Bldr.build())
354 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev230526.Link1Builder(
355 ietfLinkAZBldr.augmentation(
356 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev230526.Link1.class))
357 .setLinkType(OpenroadmLinkType.OTNLINK)
358 .setOperationalState(State.InService)
359 .setAdministrativeState(AdminStates.InService)
363 LinkBuilder ietfLinkZABldr = TopologyUtils.createLink(nodeZTopo, nodeATopo, tpZ, tpA, linkType.getName());
364 links.add(ietfLinkZABldr
365 .addAugmentation(tpceLink1)
366 .addAugmentation(otnLink1Bldr.build())
368 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev230526.Link1Builder(
369 ietfLinkZABldr.augmentation(
370 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev230526.Link1.class))
371 .setLinkType(OpenroadmLinkType.OTNLINK)
372 .setOperationalState(State.InService)
373 .setAdministrativeState(AdminStates.InService)
379 private static Link updateOtnLinkBwParameters(Link link, Long availBw, Long usedBw) {
381 LOG.debug("in updateOtnLinkBwParameters with availBw = {}, usedBw = {}", availBw, usedBw);
382 return new LinkBuilder(link)
384 new Link1Builder(link.augmentation(Link1.class))
385 .setAvailableBandwidth(Uint32.valueOf(availBw))
386 .setUsedBandwidth(Uint32.valueOf(usedBw))
391 private static List<Link> updateOtnLinkBwParameters(List<Link> supportedLinks, OtnLinkType linkType) {
393 LOG.debug("in updateOtnLinkBwParameters with supportedLinks = {}, linkType = {}", supportedLinks, linkType);
394 List<Link> updatedlinks = new ArrayList<>();
395 for (Link link : supportedLinks) {
397 new LinkBuilder(link)
398 .addAugmentation(new Link1Builder(link.augmentation(Link1.class))
399 .setAvailableBandwidth(Uint32.valueOf(0))
401 OTNLINKTYPE_BW_MAP.containsKey(linkType)
402 ? Uint32.valueOf(OTNLINKTYPE_BW_MAP.get(linkType))
410 private static TerminationPoint updateTp(TerminationPoint originalTp, boolean addingTsTpnPoolTermination,
411 OtnLinkType linkType) {
413 LOG.debug("in updateTp");
414 TerminationPointBuilder tpBldr = new TerminationPointBuilder(originalTp);
415 TerminationPoint1Builder otnTp1Bldr =
416 new TerminationPoint1Builder(tpBldr.augmentation(TerminationPoint1.class));
417 XpdrTpPortConnectionAttributesBuilder xtpcaBldr =
418 new XpdrTpPortConnectionAttributesBuilder(otnTp1Bldr.getXpdrTpPortConnectionAttributes());
419 if (addingTsTpnPoolTermination) {
420 Set<Uint16> tsPool = new HashSet<>();
421 for (int i = 1; i <= NB_TRIB_SLOTS; i++) {
422 tsPool.add(Uint16.valueOf(i));
424 xtpcaBldr.setTsPool(tsPool);
425 Set<Uint16> tpnPool = new HashSet<>();
426 int nbTribPort = NB_TRIB_PORTS;
427 if (OtnLinkType.ODUC4.equals(linkType)) {
430 for (int i = 1; i <= nbTribPort; i++) {
431 tpnPool.add(Uint16.valueOf(i));
433 OdtuTpnPool oduTpnPool = new OdtuTpnPoolBuilder()
434 .setOdtuType(ODTU4TsAllocated.VALUE)
437 xtpcaBldr.setOdtuTpnPool(ImmutableMap.of(oduTpnPool.key(),oduTpnPool));
439 xtpcaBldr.setTsPool(null);
440 xtpcaBldr.setOdtuTpnPool(ImmutableMap.of());
442 return tpBldr.addAugmentation(otnTp1Bldr.setXpdrTpPortConnectionAttributes(xtpcaBldr.build()).build()).build();
445 private static TerminationPoint updateNodeTpTsPool(TerminationPoint tp, Uint32 serviceRate, Short tribPortNb,
446 Short minTribSlotNb, Short maxTribSlotNb, boolean isDeletion) {
448 LOG.debug("in updateNodeTpTsPool");
449 TerminationPointBuilder tpBldr = new TerminationPointBuilder(tp);
451 XpdrTpPortConnectionAttributesBuilder xtpcaBldr =
452 new XpdrTpPortConnectionAttributesBuilder(
453 tpBldr.augmentation(TerminationPoint1.class).getXpdrTpPortConnectionAttributes());
454 Set<Uint16> tsPool = new HashSet<>(xtpcaBldr.getTsPool());
456 for (int i = minTribSlotNb; i <= maxTribSlotNb; i++) {
457 tsPool.add(Uint16.valueOf(i));
460 for (int i = minTribSlotNb; i <= maxTribSlotNb; i++) {
461 tsPool.remove(Uint16.valueOf(i));
464 xtpcaBldr.setTsPool(tsPool);
466 List<OdtuTpnPool> odtuTpnPoolValues = new ArrayList<>(xtpcaBldr.getOdtuTpnPool().values());
467 if (odtuTpnPoolValues.get(0).getTpnPool() == null) {
468 tpnPool = new HashSet<>();
470 tpnPool = new HashSet<>(odtuTpnPoolValues.get(0).getTpnPool());
472 tpnPool.add(Uint16.valueOf(tribPortNb));
474 tpnPool.remove(Uint16.valueOf(tribPortNb));
477 OdtuTypeIdentity odtuType;
478 if (SERVICERATE_ODTUTYPECLASS_MAP.containsKey(serviceRate)) {
479 odtuType = SERVICERATE_ODTUTYPECLASS_MAP.get(serviceRate);
482 LOG.warn("Unable to set the odtu-type");
484 OdtuTpnPool odtuTpnPool = new OdtuTpnPoolBuilder()
485 .setOdtuType(odtuType)
490 new TerminationPoint1Builder(tp.augmentation(TerminationPoint1.class))
491 .setXpdrTpPortConnectionAttributes(
493 .setOdtuTpnPool(ImmutableMap.of(odtuTpnPool.key(),odtuTpnPool))
499 private static Map<Integer, OtnTopoNode> convertPortMappingToOtnNodeList(Nodes mappingNode) {
501 List<Mapping> networkMappings =
502 mappingNode.nonnullMapping().values().stream()
503 .filter(k -> k.getLogicalConnectionPoint().contains("NETWORK"))
504 .collect(Collectors.toList());
505 Map<Integer, OtnTopoNode> xpdrMap = new HashMap<>();
506 for (Mapping mapping : networkMappings) {
507 Integer xpdrNb = Integer.parseInt(mapping.getLogicalConnectionPoint().split("XPDR")[1].split("-")[0]);
508 if (!xpdrMap.containsKey(xpdrNb)) {
509 List<Mapping> xpdrNetMaps =
510 mappingNode.nonnullMapping().values().stream()
511 .filter(k -> k.getLogicalConnectionPoint().contains("XPDR" + xpdrNb + NETWORK))
512 .collect(Collectors.toList());
513 List<Mapping> xpdrClMaps =
514 mappingNode.nonnullMapping().values().stream()
515 .filter(k -> k.getLogicalConnectionPoint().contains("XPDR" + xpdrNb + CLIENT))
516 .collect(Collectors.toList());
520 mappingNode.getNodeId(),
521 mappingNode.getNodeInfo().getNodeClli(),
523 mapping.getXpdrType() == null
525 : mapping.getXpdrType(),
526 fillConnectionMapLcp(xpdrNetMaps),
527 fillConnectionMapLcp(xpdrClMaps),
533 LOG.debug("there are {} xpdr to build", xpdrMap.size());
534 xpdrMap.forEach((k, v) -> LOG.debug("xpdr {} = {} - {} - {} - {}",
535 k, v.getNodeId(), v.getNodeType(), v.getNbTpClient(), v.getNbTpNetwork()));
539 private static Map<String, String> fillConnectionMapLcp(List<Mapping> mappingList) {
541 Map<String, String> xpdrConnectionMap = new HashMap<>();
542 for (Mapping map : mappingList) {
543 xpdrConnectionMap.put(map.getLogicalConnectionPoint(), map.getConnectionMapLcp());
545 return xpdrConnectionMap;
548 private static Node createTpdr(OtnTopoNode node) {
549 Map<TerminationPointKey,TerminationPoint> tpMap = new HashMap<>();
550 createTP(tpMap, node, OpenroadmTpType.XPONDERCLIENT, false);
551 createTP(tpMap, node, OpenroadmTpType.XPONDERNETWORK, true);
553 return new NodeBuilder()
554 .setNodeId(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb()))
555 .withKey(new NodeKey(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb())))
556 .setSupportingNode(createSupportingNodes(node))
560 new XpdrAttributesBuilder()
561 .setXpdrNumber(Uint16.valueOf(node.getXpdrNb()))
565 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev230526.Node1Builder()
566 .setNodeType(OpenroadmNodeType.TPDR)
567 .setOperationalState(State.InService)
568 .setAdministrativeState(AdminStates.InService)
571 new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
573 .setTerminationPoint(tpMap)
578 // TODO: This is same as createTpdr. After Open ROADM network models are updated,
579 // we will revisit this method to include regen based data.
580 private static Node createRegen(OtnTopoNode node) {
581 Map<TerminationPointKey,TerminationPoint> tpMap = new HashMap<>();
582 createTP(tpMap, node, OpenroadmTpType.XPONDERCLIENT, false);
583 createTP(tpMap, node, OpenroadmTpType.XPONDERNETWORK, true);
585 return new NodeBuilder()
586 .setNodeId(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb()))
587 .withKey(new NodeKey(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb())))
588 .setSupportingNode(createSupportingNodes(node))
592 new XpdrAttributesBuilder()
593 .setXpdrNumber(Uint16.valueOf(node.getXpdrNb()))
597 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev230526.Node1Builder()
598 .setNodeType(OpenroadmNodeType.TPDR)
599 .setOperationalState(State.InService)
600 .setAdministrativeState(AdminStates.InService)
603 new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
605 .setTerminationPoint(tpMap)
610 private static Node createMuxpdr(OtnTopoNode node) {
612 // prepare otn-topology node augmentation
613 // TODO: will need to be completed
614 Map<NonBlockingListKey, NonBlockingList> nbMap = new HashMap<>();
615 for (int i = 1; i <= node.getNbTpClient(); i++) {
616 Set<TpId> tpList = new HashSet<>();
617 tpList.add(new TpId("XPDR" + node.getXpdrNb() + CLIENT + i));
618 tpList.add(new TpId("XPDR" + node.getXpdrNb() + "-NETWORK1"));
619 NonBlockingList nbl = new NonBlockingListBuilder()
620 .setNblNumber(Uint16.valueOf(i))
622 .setAvailableInterconnectBandwidth(Uint32.valueOf(node.getNbTpNetwork() * 10L))
623 .setInterconnectBandwidthUnit(Uint32.valueOf(1000000000))
625 nbMap.put(nbl.key(),nbl);
627 OduSwitchingPools oduSwitchPool = new OduSwitchingPoolsBuilder()
628 .setSwitchingPoolNumber(Uint16.valueOf(1))
629 .setSwitchingPoolType(SwitchingPoolTypes.NonBlocking)
630 .setNonBlockingList(nbMap)
632 Map<TerminationPointKey, TerminationPoint> tpMap = new HashMap<>();
633 createTP(tpMap, node, OpenroadmTpType.XPONDERCLIENT, true);
634 createTP(tpMap, node, OpenroadmTpType.XPONDERNETWORK, true);
636 return new NodeBuilder()
637 .setNodeId(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb()))
638 .withKey(new NodeKey(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb())))
639 .setSupportingNode(createSupportingNodes(node))
642 .setTpBandwidthSharing(new TpBandwidthSharingBuilder().build())
644 new XpdrAttributesBuilder()
645 .setXpdrNumber(Uint16.valueOf(node.getXpdrNb()))
648 new SwitchingPoolsBuilder()
649 .setOduSwitchingPools(Map.of(oduSwitchPool.key(),oduSwitchPool))
653 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev230526.Node1Builder()
654 .setNodeType(OpenroadmNodeType.MUXPDR)
655 .setAdministrativeState(AdminStates.InService)
656 .setOperationalState(State.InService)
659 new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
661 .setTerminationPoint(tpMap)
666 private static Node createSwitch(OtnTopoNode node) {
668 Set<TpId> tpl = new HashSet<>();
669 for (int i = 1; i <= node.getNbTpClient(); i++) {
670 tpl.add(new TpId("XPDR" + node.getXpdrNb() + CLIENT + i));
672 for (int i = 1; i <= node.getNbTpNetwork(); i++) {
673 tpl.add(new TpId("XPDR" + node.getXpdrNb() + NETWORK + i));
675 Map<NonBlockingListKey, NonBlockingList> nbMap = new HashMap<>();
676 NonBlockingList nbl = new NonBlockingListBuilder()
677 .setNblNumber(Uint16.valueOf(1))
680 nbMap.put(nbl.key(),nbl);
681 OduSwitchingPools oduSwitchPool = new OduSwitchingPoolsBuilder()
682 .setSwitchingPoolNumber(Uint16.valueOf(1))
683 .setSwitchingPoolType(SwitchingPoolTypes.NonBlocking)
684 .setNonBlockingList(nbMap)
686 Map<OduSwitchingPoolsKey, OduSwitchingPools> oduSwitchPoolList = new HashMap<>();
687 oduSwitchPoolList.put(oduSwitchPool.key(),oduSwitchPool);
688 Map<TerminationPointKey, TerminationPoint> tpMap = new HashMap<>();
689 createTP(tpMap, node, OpenroadmTpType.XPONDERCLIENT, true);
690 createTP(tpMap, node, OpenroadmTpType.XPONDERNETWORK, true);
692 return new NodeBuilder()
693 .setNodeId(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb()))
694 .withKey(new NodeKey(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb())))
695 .setSupportingNode(createSupportingNodes(node))
698 .setTpBandwidthSharing(new TpBandwidthSharingBuilder().build())
700 new XpdrAttributesBuilder()
701 .setXpdrNumber(Uint16.valueOf(node.getXpdrNb()))
704 new SwitchingPoolsBuilder()
705 .setOduSwitchingPools(oduSwitchPoolList)
709 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev230526.Node1Builder()
710 .setNodeType(OpenroadmNodeType.SWITCH)
711 .setOperationalState(State.InService)
712 .setAdministrativeState(AdminStates.InService)
715 new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226
717 .setTerminationPoint(tpMap)
722 private static void createTP(Map<TerminationPointKey, TerminationPoint> tpMap,
723 OtnTopoNode node, OpenroadmTpType tpType, boolean withRate) {
725 List<Mapping> mappings = null;
728 mappings = node.getXpdrNetMappings();
731 mappings = node.getXpdrClMappings();
734 LOG.error("Error with Termination Point type {}", tpType);
737 fillTpMap(tpMap, node, tpType, withRate, mappings);
740 private static void fillTpMap(Map<TerminationPointKey, TerminationPoint> tpMap, OtnTopoNode node,
741 OpenroadmTpType tpType, boolean withRate, List<Mapping> mappings) {
743 for (Mapping mapping : mappings) {
744 // openroadm-otn-topoology augmentation
745 Map<SupportedInterfaceCapabilityKey, SupportedInterfaceCapability> supIfMap = new HashMap<>();
746 TerminationPoint1Builder otnTp1Bldr = new TerminationPoint1Builder();
747 if (mapping.getSupportedInterfaceCapability() == null) {
748 LOG.warn("mapping {} of node {} has no if-cap-type",
749 mapping.getLogicalConnectionPoint(), node.getNodeId());
751 XpdrTpPortConnectionAttributesBuilder xtpcaBldr = new XpdrTpPortConnectionAttributesBuilder();
752 for (org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev230526.SupportedIfCapability
753 supInterCapa : mapping.getSupportedInterfaceCapability()) {
754 SupportedInterfaceCapability supIfCapa = new SupportedInterfaceCapabilityBuilder()
755 .withKey(new SupportedInterfaceCapabilityKey(supInterCapa))
756 .setIfCapType(supInterCapa)
758 supIfMap.put(supIfCapa.key(), supIfCapa);
760 otnTp1Bldr.setTpSupportedInterfaces(
761 new TpSupportedInterfacesBuilder()
762 .setSupportedInterfaceCapability(supIfMap)
765 //TODO: It is not logical to assign a priori one of the possible rate to the TP.
766 //Would be worth assigning per default "unallocated" at the tp creation step,
767 //and updating it with correct rate when it supports a specific service.
769 otnTp1Bldr.setXpdrTpPortConnectionAttributes(
770 xtpcaBldr.setRate(fixRate(mapping.getSupportedInterfaceCapability())).build());
776 new TpId(mapping.getLogicalConnectionPoint()),
783 private static void setclientNwTpAttr(Map<TerminationPointKey, TerminationPoint> tpMap, OtnTopoNode node, TpId tpId,
784 OpenroadmTpType tpType, TerminationPoint1 otnTp1, Mapping mapping) {
785 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev230526.TerminationPoint1Builder cnTP1BLdr
786 = new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev230526
787 .TerminationPoint1Builder();
790 if (node.getXpdrNetConnectionMap().get(tpId.getValue()) != null) {
791 cnTP1BLdr.setAssociatedConnectionMapTp(Set.of(
792 new TpId(node.getXpdrNetConnectionMap().get(tpId.getValue()))));
794 SupportingTerminationPoint stp = new SupportingTerminationPointBuilder()
795 .setNetworkRef(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID))
796 .setNodeRef(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb()))
799 TerminationPoint ietfTpNw =
800 buildIetfTp(cnTP1BLdr, otnTp1, tpType, tpId, Map.of(stp.key(), stp), mapping);
801 tpMap.put(ietfTpNw.key(),ietfTpNw);
804 if (node.getXpdrCliConnectionMap().get(tpId.getValue()) != null) {
805 cnTP1BLdr.setAssociatedConnectionMapTp(Set.of(
806 new TpId(node.getXpdrCliConnectionMap().get(tpId.getValue()))));
808 TerminationPoint ietfTpCl = buildIetfTp(cnTP1BLdr, otnTp1, tpType, tpId, null, mapping);
809 tpMap.put(ietfTpCl.key(),ietfTpCl);
812 LOG.error("Undefined tpType for Termination point {} of {}", tpId.getValue(), node.getNodeId());
817 private static OduRateIdentity fixRate(
818 Set<org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev230526.SupportedIfCapability> list) {
819 for (org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev230526.SupportedIfCapability
821 String simpleName = supIfCap.toString().split("\\{")[0];
822 if (RATE_MAP.containsKey(simpleName)) {
823 return RATE_MAP.get(simpleName);
829 private static Map<SupportingNodeKey,SupportingNode> createSupportingNodes(OtnTopoNode node) {
831 SupportingNode suppNode1 = new SupportingNodeBuilder()
832 .setNetworkRef(new NetworkId(NetworkUtils.UNDERLAY_NETWORK_ID))
833 .setNodeRef(new NodeId(node.getNodeId()))
835 new SupportingNodeKey(
836 new NetworkId(NetworkUtils.UNDERLAY_NETWORK_ID),
837 new NodeId(node.getNodeId())))
839 SupportingNode suppNode2 = new SupportingNodeBuilder()
840 .setNetworkRef(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID))
841 .setNodeRef(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb()))
843 new SupportingNodeKey(
844 new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID),
845 new NodeId(node.getNodeId() + XPDR + node.getXpdrNb())))
847 SupportingNode suppNode3 = new SupportingNodeBuilder()
848 .setNetworkRef(new NetworkId(NetworkUtils.CLLI_NETWORK_ID))
849 .setNodeRef(new NodeId(node.getClli()))
851 new SupportingNodeKey(
852 new NetworkId(NetworkUtils.CLLI_NETWORK_ID),
853 new NodeId(node.getClli())))
855 Map<SupportingNodeKey,SupportingNode> suppNodeMap = new HashMap<>();
856 suppNodeMap.put(suppNode1.key(),suppNode1);
857 suppNodeMap.put(suppNode2.key(),suppNode2);
858 suppNodeMap.put(suppNode3.key(),suppNode3);
862 private static TerminationPoint buildIetfTp(
863 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev230526.TerminationPoint1Builder cnTP1BLdr,
864 TerminationPoint1 otnTp1, OpenroadmTpType tpType, TpId tpId,
865 Map<SupportingTerminationPointKey, SupportingTerminationPoint> supportTpMap, Mapping mapping) {
867 TerminationPointBuilder ietfTpBldr = new TerminationPointBuilder();
868 if (supportTpMap != null) {
869 ietfTpBldr.setSupportingTerminationPoint(supportTpMap);
873 .withKey(new TerminationPointKey(tpId))
874 .addAugmentation(otnTp1)
875 .addAugmentation(cnTP1BLdr.setTpType(tpType)
876 .setAdministrativeState(TopologyUtils.setNetworkAdminState(mapping.getPortAdminState()))
877 .setOperationalState(TopologyUtils.setNetworkOperState(mapping.getPortOperState()))
882 private static String formatNodeName(String nodeName, String tpName) {
884 return nodeName.contains(XPDR)
886 : new StringBuilder(nodeName).append("-").append(tpName.split("-")[0]).toString();