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.ODU0;
40 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev200327.ODU2;
41 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev200327.ODU2e;
42 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev200327.ODU4;
43 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev200327.OduRateIdentity;
44 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.Link1;
45 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.Link1Builder;
46 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.Node1;
47 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.Node1Builder;
48 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.TerminationPoint1;
49 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.TerminationPoint1Builder;
50 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.networks.network.node.SwitchingPools;
51 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.networks.network.node.SwitchingPoolsBuilder;
52 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.networks.network.node.TpBandwidthSharing;
53 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.networks.network.node.TpBandwidthSharingBuilder;
54 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.networks.network.node.XpdrAttributes;
55 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.networks.network.node.XpdrAttributesBuilder;
56 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.networks.network.node.termination.point.TpSupportedInterfaces;
57 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.networks.network.node.termination.point.TpSupportedInterfacesBuilder;
58 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev200529.networks.network.node.termination.point.XpdrTpPortConnectionAttributesBuilder;
59 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev200327.SupportedIfCapability;
60 import org.opendaylight.yang.gen.v1.http.org.openroadm.switching.pool.types.rev191129.SwitchingPoolTypes;
61 import org.opendaylight.yang.gen.v1.http.org.openroadm.xponder.rev200529.xpdr.otn.tp.attributes.OdtuTpnPool;
62 import org.opendaylight.yang.gen.v1.http.org.openroadm.xponder.rev200529.xpdr.otn.tp.attributes.OdtuTpnPoolBuilder;
63 import org.opendaylight.yang.gen.v1.http.transportpce.topology.rev210511.OtnLinkType;
64 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NetworkId;
65 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NodeId;
66 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.Node;
67 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.NodeBuilder;
68 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.NodeKey;
69 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.node.SupportingNode;
70 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.node.SupportingNodeBuilder;
71 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.node.SupportingNodeKey;
72 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.TpId;
73 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.Link;
74 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.LinkBuilder;
75 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPoint;
76 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPointBuilder;
77 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPointKey;
78 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.termination.point.SupportingTerminationPoint;
79 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.termination.point.SupportingTerminationPointBuilder;
80 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.termination.point.SupportingTerminationPointKey;
81 import org.opendaylight.yangtools.yang.common.Uint16;
82 import org.opendaylight.yangtools.yang.common.Uint32;
83 import org.slf4j.Logger;
84 import org.slf4j.LoggerFactory;
86 public final class OpenRoadmOtnTopology {
88 private static final Logger LOG = LoggerFactory.getLogger(OpenRoadmOtnTopology.class);
89 private static final String CLIENT = "-CLIENT";
90 private static final String NETWORK = "-NETWORK";
91 private static final String XPDR = "-XPDR";
92 private static final int NB_TRIB_PORTS = 80;
93 private static final int NB_TRIB_SLOTS = 80;
94 private static final int NB_TRIB_SLOT_PER_10GE = 8;
96 private OpenRoadmOtnTopology() {
99 public static TopologyShard createTopologyShard(Nodes mappingNode) {
100 List<Node> nodes = new ArrayList<>();
101 List<Link> links = new ArrayList<>();
102 Map<Integer, OtnTopoNode> xpdrMap = convertPortMappingToOtnNodeList(mappingNode);
103 for (OtnTopoNode node : xpdrMap.values()) {
104 switch (node.getNodeType()) {
106 nodes.add(createTpdr(node));
109 nodes.add(createMuxpdr(node));
112 nodes.add(createSwitch(node));
115 LOG.error("unknown otn node type {}", node.getNodeType().getName());
119 return new TopologyShard(nodes, links);
122 public static TopologyShard createOtnLinks(String nodeA, String tpA, String nodeZ, String tpZ,
123 OtnLinkType linkType) {
124 List<Link> links = null;
125 if (OtnLinkType.OTU4.equals(linkType)) {
126 links = initialiseOtnLinks(nodeA, tpA, nodeZ, tpZ, linkType, "OTU4");
128 return new TopologyShard(null, links);
131 public static TopologyShard createOtnLinks(List<Link> suppOtu4Links, List<TerminationPoint> oldTps) {
132 List<Link> links = new ArrayList<>();
133 for (Link link : suppOtu4Links) {
134 if (link.augmentation(Link1.class) != null
135 && link.augmentation(Link1.class).getAvailableBandwidth().equals(Uint32.valueOf(100000))) {
136 links.add(updateOtnLinkBwParameters(link, 0L, 100000L));
138 LOG.error("Error with otn parameters of supported link {}", link.getLinkId().getValue());
141 if (links.size() == 2) {
142 links.addAll(initialiseOtnLinks(suppOtu4Links.get(0).getSource().getSourceNode().getValue(),
143 suppOtu4Links.get(0).getSource().getSourceTp().toString(),
144 suppOtu4Links.get(0).getDestination().getDestNode().getValue(),
145 suppOtu4Links.get(0).getDestination().getDestTp().toString(),
146 OtnLinkType.ODTU4, "ODU4"));
148 List<TerminationPoint> tps = new ArrayList<>();
149 for (TerminationPoint tp : oldTps) {
150 tps.add(updateTp(tp, true));
152 if (links.size() == 4 && tps.size() == 2) {
153 return new TopologyShard(null, links, tps);
155 return new TopologyShard(null, null, null);
159 public static TopologyShard updateOtnLinks(List<Link> suppOdu4Links, List<TerminationPoint> oldTps,
160 String serviceRate, Short tribPortNb, Short tribSoltNb, boolean isDeletion) {
161 List<Link> links = new ArrayList<>();
162 Long bwIncr = 10000L;
163 if ("1G".equals(serviceRate)) {
166 for (Link link : suppOdu4Links) {
167 if (link.augmentation(Link1.class) != null && link.augmentation(Link1.class).getAvailableBandwidth() != null
168 && link.augmentation(Link1.class).getUsedBandwidth() != null) {
169 Uint32 avlBw = link.augmentation(Link1.class).getAvailableBandwidth();
170 Uint32 usedBw = link.augmentation(Link1.class).getUsedBandwidth();
171 if (avlBw.toJava() < bwIncr) {
175 links.add(updateOtnLinkBwParameters(link, avlBw.toJava() + bwIncr,
176 usedBw.toJava() - bwIncr));
178 links.add(updateOtnLinkBwParameters(link, avlBw.toJava() - bwIncr,
179 usedBw.toJava() + bwIncr));
182 LOG.error("Error with otn parameters of supported link {}", link.getLinkId().getValue());
185 List<TerminationPoint> tps = new ArrayList<>();
186 for (TerminationPoint tp : oldTps) {
188 tps.add(updateNodeTpTsPool(tp, serviceRate, tribPortNb, tribSoltNb, isDeletion));
191 if (!links.isEmpty() && !tps.isEmpty()) {
192 return new TopologyShard(null, links, tps);
194 LOG.error("unable to update otn links");
195 return new TopologyShard(null, null, null);
199 public static TopologyShard deleteOtnLinks(List<Link> suppOtu4Links, List<TerminationPoint> oldTps) {
200 List<Link> links = new ArrayList<>();
201 for (Link link : suppOtu4Links) {
202 if (link.augmentation(Link1.class) != null) {
203 links.add(updateOtnLinkBwParameters(link, 100000L, 0L));
205 LOG.error("Error with otn parameters of supported link {}", link.getLinkId().getValue());
208 List<TerminationPoint> tps = new ArrayList<>();
209 for (TerminationPoint tp : oldTps) {
210 tps.add(updateTp(tp, false));
212 if (links.size() == 2 && tps.size() == 2) {
213 return new TopologyShard(null, links, tps);
215 return new TopologyShard(null, null, null);
219 private static List<Link> initialiseOtnLinks(String nodeA, String tpA, String nodeZ, String tpZ,
220 OtnLinkType linkType, String linkIdPrefix) {
221 List<Link> links = new ArrayList<>();
222 org.opendaylight.yang.gen.v1.http.transportpce.topology.rev210511.Link1 tpceLink1
223 = new org.opendaylight.yang.gen.v1.http.transportpce.topology.rev210511.Link1Builder()
224 .setOtnLinkType(linkType).build();
225 Link1 otnLink1 = new Link1Builder()
226 .setAvailableBandwidth(Uint32.valueOf(100000))
227 .setUsedBandwidth(Uint32.valueOf(0))
232 if (nodeA.contains(XPDR) && nodeZ.contains(XPDR)) {
236 nodeATopo = nodeA + "-" + tpA.split("-")[0];
237 nodeZTopo = nodeZ + "-" + tpZ.split("-")[0];
239 LinkBuilder ietfLinkAZBldr = TopologyUtils.createLink(nodeATopo, nodeZTopo, tpA, tpZ, linkIdPrefix);
241 .addAugmentation(tpceLink1)
242 .addAugmentation(otnLink1)
244 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Link1Builder(
245 ietfLinkAZBldr.augmentation(
246 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Link1.class))
247 .setLinkType(OpenroadmLinkType.OTNLINK)
248 .setOperationalState(State.InService)
249 .setAdministrativeState(AdminStates.InService)
251 links.add(ietfLinkAZBldr.build());
253 LinkBuilder ietfLinkZABldr = TopologyUtils.createLink(nodeZTopo, nodeATopo, tpZ, tpA, linkIdPrefix);
255 .addAugmentation(tpceLink1)
256 .addAugmentation(otnLink1)
258 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Link1Builder(
259 ietfLinkZABldr.augmentation(
260 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Link1.class))
261 .setLinkType(OpenroadmLinkType.OTNLINK)
262 .setOperationalState(State.InService)
263 .setAdministrativeState(AdminStates.InService)
265 links.add(ietfLinkZABldr.build());
269 private static Link updateOtnLinkBwParameters(Link link, Long availBw, Long usedBw) {
270 LOG.debug("in updateOtnLinkBwParameters with availBw = {}, usedBw = {}", availBw, usedBw);
271 LinkBuilder updatedLinkBldr = new LinkBuilder(link);
272 Link1Builder updatedLink1Bldr = new Link1Builder(link.augmentation(Link1.class))
273 .setAvailableBandwidth(Uint32.valueOf(availBw))
274 .setUsedBandwidth(Uint32.valueOf(usedBw));
275 updatedLinkBldr.addAugmentation(updatedLink1Bldr.build());
276 return updatedLinkBldr.build();
279 private static TerminationPoint updateTp(TerminationPoint originalTp, boolean addingTsTpnPoolTermination) {
280 LOG.debug("in updateTp");
281 TerminationPointBuilder tpBldr = new TerminationPointBuilder(originalTp);
282 TerminationPoint1Builder otnTp1Bldr = new TerminationPoint1Builder(
283 tpBldr.augmentation(TerminationPoint1.class));
284 XpdrTpPortConnectionAttributesBuilder xtpcaBldr = new XpdrTpPortConnectionAttributesBuilder(otnTp1Bldr
285 .getXpdrTpPortConnectionAttributes());
286 if (addingTsTpnPoolTermination) {
287 List<Uint16> tsPool = new ArrayList<>();
288 for (int i = 0; i < NB_TRIB_SLOTS; i++) {
289 tsPool.add(Uint16.valueOf(i + 1));
291 xtpcaBldr.setTsPool(tsPool);
292 List<Uint16> tpnPool = new ArrayList<>();
293 for (int i = 1; i <= NB_TRIB_PORTS; i++) {
294 tpnPool.add(Uint16.valueOf(i));
296 OdtuTpnPool oduTpnPool = new OdtuTpnPoolBuilder().setOdtuType(ODTU4TsAllocated.class)
297 .setTpnPool(tpnPool).build();
298 xtpcaBldr.setOdtuTpnPool(ImmutableMap.of(oduTpnPool.key(),oduTpnPool));
300 xtpcaBldr.setTsPool(null);
301 xtpcaBldr.setOdtuTpnPool(ImmutableMap.of());
303 return tpBldr.addAugmentation(otnTp1Bldr.setXpdrTpPortConnectionAttributes(xtpcaBldr.build()).build()).build();
306 private static TerminationPoint updateNodeTpTsPool(TerminationPoint tp, String serviceRate, Short tribPortNb,
307 Short tribSlotNb, boolean isDeletion) {
308 LOG.debug("in updateNodeTpTsPool");
309 TerminationPointBuilder tpBldr = new TerminationPointBuilder(tp);
311 XpdrTpPortConnectionAttributesBuilder xtpcaBldr = new XpdrTpPortConnectionAttributesBuilder(
312 tpBldr.augmentation(TerminationPoint1.class).getXpdrTpPortConnectionAttributes());
313 List<Uint16> tsPool = new ArrayList<>(xtpcaBldr.getTsPool());
314 switch (serviceRate) {
317 tsPool.add(Uint16.valueOf(tribSlotNb));
319 tsPool.remove(Uint16.valueOf(tribSlotNb));
324 for (int i = 0; i < NB_TRIB_SLOT_PER_10GE; i++) {
325 tsPool.add(Uint16.valueOf(tribSlotNb + i));
328 for (int i = 0; i < NB_TRIB_SLOT_PER_10GE; i++) {
329 tsPool.remove(Uint16.valueOf(tribSlotNb + i));
334 LOG.error("error updating tpn and ts pool for tp {}", tp.getTpId().getValue());
337 xtpcaBldr.setTsPool(tsPool);
338 List<Uint16> tpnPool;
339 List<OdtuTpnPool> odtuTpnPoolValues = new ArrayList<>(xtpcaBldr.getOdtuTpnPool().values());
340 if (odtuTpnPoolValues.get(0).getTpnPool() != null) {
341 tpnPool = new ArrayList<>(odtuTpnPoolValues.get(0).getTpnPool());
343 tpnPool.add(Uint16.valueOf(tribPortNb));
345 tpnPool.remove(Uint16.valueOf(tribPortNb));
348 tpnPool = new ArrayList<>();
350 OdtuTpnPool odtuTpnPool = new OdtuTpnPoolBuilder().setOdtuType(ODTU4TsAllocated.class)
351 .setTpnPool(tpnPool).build();
352 xtpcaBldr.setOdtuTpnPool(ImmutableMap.of(odtuTpnPool.key(),odtuTpnPool));
354 tpBldr.addAugmentation(new TerminationPoint1Builder(tp.augmentation(TerminationPoint1.class))
355 .setXpdrTpPortConnectionAttributes(xtpcaBldr.build()).build());
356 return tpBldr.build();
359 private static Map<Integer, OtnTopoNode> convertPortMappingToOtnNodeList(Nodes mappingNode) {
360 List<Mapping> networkMappings = mappingNode.nonnullMapping().values()
361 .stream().filter(k -> k.getLogicalConnectionPoint()
362 .contains("NETWORK")).collect(Collectors.toList());
363 Map<Integer, OtnTopoNode> xpdrMap = new HashMap<>();
364 for (Mapping mapping : networkMappings) {
365 Integer xpdrNb = Integer.parseInt(mapping.getLogicalConnectionPoint().split("XPDR")[1].split("-")[0]);
366 if (!xpdrMap.containsKey(xpdrNb)) {
367 List<Mapping> xpdrNetMaps = mappingNode.nonnullMapping().values()
368 .stream().filter(k -> k.getLogicalConnectionPoint()
369 .contains("XPDR" + xpdrNb + NETWORK)).collect(Collectors.toList());
370 List<Mapping> xpdrClMaps = mappingNode.nonnullMapping().values()
371 .stream().filter(k -> k.getLogicalConnectionPoint()
372 .contains("XPDR" + xpdrNb + CLIENT)).collect(Collectors.toList());
373 OtnTopoNode otnNode = null;
374 if (mapping.getXponderType() != null) {
375 otnNode = new OtnTopoNode(mappingNode.getNodeId(), mappingNode.getNodeInfo().getNodeClli(), xpdrNb,
376 mapping.getXponderType(), fillConnectionMapLcp(xpdrNetMaps), fillConnectionMapLcp(xpdrClMaps),
377 xpdrNetMaps, xpdrClMaps);
379 otnNode = new OtnTopoNode(mappingNode.getNodeId(), mappingNode.getNodeInfo().getNodeClli(), xpdrNb,
380 XpdrNodeTypes.Tpdr, fillConnectionMapLcp(xpdrNetMaps), fillConnectionMapLcp(xpdrClMaps),
381 xpdrNetMaps, xpdrClMaps);
383 xpdrMap.put(xpdrNb, otnNode);
386 LOG.debug("there are {} xpdr to build", xpdrMap.size());
387 xpdrMap.forEach((k, v) -> LOG.debug("xpdr {} = {} - {} - {} - {}", k, v.getNodeId(), v.getNodeType(),
388 v.getNbTpClient(), v.getNbTpNetwork()));
392 private static Map<String, String> fillConnectionMapLcp(List<Mapping> mappingList) {
393 Map<String, String> xpdrConnectionMap = new HashMap<>();
394 for (Mapping map : mappingList) {
395 if (map.getConnectionMapLcp() != null) {
396 xpdrConnectionMap.put(map.getLogicalConnectionPoint(), map.getConnectionMapLcp());
398 xpdrConnectionMap.put(map.getLogicalConnectionPoint(), null);
401 return xpdrConnectionMap;
404 private static Node createTpdr(OtnTopoNode node) {
405 // create otn-topology node augmentation
406 XpdrAttributes xpdrAttr = new XpdrAttributesBuilder()
407 .setXpdrNumber(Uint16.valueOf(node.getXpdrNb()))
409 Node1 otnNodeAug = new Node1Builder()
410 .setXpdrAttributes(xpdrAttr)
412 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Node1 ocnNodeAug =
413 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Node1Builder()
414 .setNodeType(OpenroadmNodeType.TPDR)
415 .setOperationalState(State.InService)
416 .setAdministrativeState(AdminStates.InService)
418 // create ietf node augmentation to add TP list
419 Map<TerminationPointKey,TerminationPoint> tpMap = new HashMap<>();
421 createTP(tpMap, node, OpenroadmTpType.XPONDERCLIENT, false);
422 createTP(tpMap, node, OpenroadmTpType.XPONDERNETWORK, true);
424 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1 ietfNodeAug =
425 new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1Builder()
426 .setTerminationPoint(tpMap)
430 return new NodeBuilder()
431 .setNodeId(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb()))
432 .withKey(new NodeKey(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb())))
433 .setSupportingNode(createSupportingNodes(node))
434 .addAugmentation(otnNodeAug)
435 .addAugmentation(ocnNodeAug)
436 .addAugmentation(ietfNodeAug)
440 private static Node createMuxpdr(OtnTopoNode node) {
441 // create otn-topology node augmentation
442 // TODO: will need to be completed
443 TpBandwidthSharing tpBwSh = new TpBandwidthSharingBuilder().build();
444 XpdrAttributes xpdrAttr = new XpdrAttributesBuilder()
445 .setXpdrNumber(Uint16.valueOf(node.getXpdrNb()))
448 Map<NonBlockingListKey, NonBlockingList> nbMap = new HashMap<>();
449 for (int i = 1; i <= node.getNbTpClient(); i++) {
450 List<TpId> tpList = new ArrayList<>();
451 TpId tpId = new TpId("XPDR" + node.getXpdrNb() + CLIENT + i);
453 tpId = new TpId("XPDR" + node.getXpdrNb() + "-NETWORK1");
455 NonBlockingList nbl = new NonBlockingListBuilder()
456 .setNblNumber(Uint16.valueOf(i))
458 .setAvailableInterconnectBandwidth(Uint32.valueOf(node.getNbTpNetwork() * 10L))
459 .setInterconnectBandwidthUnit(Uint32.valueOf(1000000000))
461 nbMap.put(nbl.key(),nbl);
463 OduSwitchingPools oduSwitchPool = new OduSwitchingPoolsBuilder()
464 .setSwitchingPoolNumber(Uint16.valueOf(1))
465 .setSwitchingPoolType(SwitchingPoolTypes.NonBlocking)
466 .setNonBlockingList(nbMap)
468 SwitchingPools switchingPools = new SwitchingPoolsBuilder()
469 .setOduSwitchingPools(Map.of(oduSwitchPool.key(),oduSwitchPool))
471 Node1 otnNodeAug = new Node1Builder()
472 .setTpBandwidthSharing(tpBwSh)
473 .setXpdrAttributes(xpdrAttr)
474 .setSwitchingPools(switchingPools)
476 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Node1 ocnNodeAug =
477 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Node1Builder()
478 .setNodeType(OpenroadmNodeType.MUXPDR)
479 .setAdministrativeState(AdminStates.InService)
480 .setOperationalState(State.InService)
483 // create ietf node augmentation to add TP list
484 Map<TerminationPointKey, TerminationPoint> tpMap = new HashMap<>();
486 createTP(tpMap, node, OpenroadmTpType.XPONDERCLIENT, true);
487 createTP(tpMap, node, OpenroadmTpType.XPONDERNETWORK, true);
489 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1 ietfNodeAug =
490 new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1Builder()
491 .setTerminationPoint(tpMap)
495 return new NodeBuilder()
496 .setNodeId(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb()))
497 .withKey(new NodeKey(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb())))
498 .setSupportingNode(createSupportingNodes(node))
499 .addAugmentation(otnNodeAug)
500 .addAugmentation(ocnNodeAug)
501 .addAugmentation(ietfNodeAug)
505 private static Node createSwitch(OtnTopoNode node) {
506 List<TpId> tpl = new ArrayList<>();
508 for (int i = 1; i <= node.getNbTpClient(); i++) {
509 tpId = new TpId("XPDR" + node.getXpdrNb() + CLIENT + i);
512 for (int i = 1; i <= node.getNbTpNetwork(); i++) {
513 tpId = new TpId("XPDR" + node.getXpdrNb() + NETWORK + i);
516 Map<NonBlockingListKey, NonBlockingList> nbMap = new HashMap<>();
517 NonBlockingList nbl = new NonBlockingListBuilder()
518 .setNblNumber(Uint16.valueOf(1))
521 nbMap.put(nbl.key(),nbl);
523 OduSwitchingPools oduSwitchPool = new OduSwitchingPoolsBuilder()
524 .setSwitchingPoolNumber(Uint16.valueOf(1))
525 .setSwitchingPoolType(SwitchingPoolTypes.NonBlocking)
526 .setNonBlockingList(nbMap)
528 Map<OduSwitchingPoolsKey, OduSwitchingPools> oduSwitchPoolList = new HashMap<>();
529 oduSwitchPoolList.put(oduSwitchPool.key(),oduSwitchPool);
530 SwitchingPools switchingPools = new SwitchingPoolsBuilder()
531 .setOduSwitchingPools(oduSwitchPoolList)
534 // create otn-topology node augmentation
535 // TODO: will need to be completed
536 TpBandwidthSharing tpBwSh = new TpBandwidthSharingBuilder().build();
537 XpdrAttributes xpdrAttr = new XpdrAttributesBuilder()
538 .setXpdrNumber(Uint16.valueOf(node.getXpdrNb()))
541 Node1 otnNodeAug = new Node1Builder()
542 .setTpBandwidthSharing(tpBwSh)
543 .setXpdrAttributes(xpdrAttr)
544 .setSwitchingPools(switchingPools)
546 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Node1 ocnNodeAug =
547 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.Node1Builder()
548 .setNodeType(OpenroadmNodeType.SWITCH)
549 .setOperationalState(State.InService)
550 .setAdministrativeState(AdminStates.InService)
553 // create ietf node augmentation to add TP list
554 Map<TerminationPointKey, TerminationPoint> tpMap = new HashMap<>();
556 createTP(tpMap, node, OpenroadmTpType.XPONDERCLIENT, true);
557 createTP(tpMap, node, OpenroadmTpType.XPONDERNETWORK, true);
558 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1 ietfNodeAug =
559 new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1Builder()
560 .setTerminationPoint(tpMap)
564 return new NodeBuilder()
565 .setNodeId(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb()))
566 .withKey(new NodeKey(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb())))
567 .setSupportingNode(createSupportingNodes(node))
568 .addAugmentation(otnNodeAug)
569 .addAugmentation(ocnNodeAug)
570 .addAugmentation(ietfNodeAug)
574 private static void createTP(Map<TerminationPointKey, TerminationPoint> tpMap,
575 OtnTopoNode node, OpenroadmTpType tpType, boolean withRate) {
576 List<Mapping> mappings = null;
579 mappings = node.getXpdrNetMappings();
582 mappings = node.getXpdrClMappings();
585 LOG.error("Error with Termination Point type {}", tpType);
588 fillTpMap(tpMap, node, tpType, withRate, mappings);
591 private static void fillTpMap(Map<TerminationPointKey, TerminationPoint> tpMap, OtnTopoNode node,
592 OpenroadmTpType tpType, boolean withRate, List<Mapping> mappings) {
593 for (Mapping mapping : mappings) {
594 // openroadm-otn-topoology augmentation
595 Map<SupportedInterfaceCapabilityKey, SupportedInterfaceCapability> supIfMap = new HashMap<>();
596 TerminationPoint1Builder otnTp1Bldr = new TerminationPoint1Builder();
597 if (mapping.getSupportedInterfaceCapability() != null) {
598 XpdrTpPortConnectionAttributesBuilder xtpcaBldr = new XpdrTpPortConnectionAttributesBuilder();
599 for (Class<? extends SupportedIfCapability> supInterCapa : mapping.getSupportedInterfaceCapability()) {
600 SupportedInterfaceCapability supIfCapa = new SupportedInterfaceCapabilityBuilder()
601 .withKey(new SupportedInterfaceCapabilityKey(supInterCapa))
602 .setIfCapType(supInterCapa)
604 supIfMap.put(supIfCapa.key(), supIfCapa);
606 TpSupportedInterfaces tpSupIf = new TpSupportedInterfacesBuilder()
607 .setSupportedInterfaceCapability(supIfMap)
609 otnTp1Bldr.setTpSupportedInterfaces(tpSupIf);
611 xtpcaBldr.setRate(fixRate(mapping.getSupportedInterfaceCapability().get(0)));
612 otnTp1Bldr.setXpdrTpPortConnectionAttributes(xtpcaBldr.build());
615 LOG.warn("mapping {} of node {} has no if-cap-type", mapping.getLogicalConnectionPoint(),
618 org.opendaylight.yang.gen.v1.http.transportpce.topology.rev210511.TerminationPoint1Builder tpceTp1Bldr =
619 new org.opendaylight.yang.gen.v1.http.transportpce.topology.rev210511.TerminationPoint1Builder();
620 TpId tpId = new TpId(mapping.getLogicalConnectionPoint());
621 setclientNwTpAttr(tpMap, node, tpId, tpType, otnTp1Bldr.build(), tpceTp1Bldr, mapping);
625 private static void setclientNwTpAttr(Map<TerminationPointKey, TerminationPoint> tpMap, OtnTopoNode node, TpId tpId,
626 OpenroadmTpType tpType, TerminationPoint1 otnTp1,
627 org.opendaylight.yang.gen.v1.http.transportpce.topology.rev210511.TerminationPoint1Builder tpceTp1Bldr,
631 if (node.getXpdrNetConnectionMap().get(tpId.getValue()) != null) {
632 tpceTp1Bldr.setAssociatedConnectionMapPort(node.getXpdrNetConnectionMap().get(tpId.getValue()));
634 SupportingTerminationPoint stp = new SupportingTerminationPointBuilder()
635 .setNetworkRef(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID))
636 .setNodeRef(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb()))
637 .setTpRef(tpId.getValue())
639 TerminationPoint ietfTpNw = buildIetfTp(tpceTp1Bldr, otnTp1, tpType, tpId, Map.of(stp.key(), stp),
641 tpMap.put(ietfTpNw.key(),ietfTpNw);
644 if (node.getXpdrCliConnectionMap().get(tpId.getValue()) != null) {
645 tpceTp1Bldr.setAssociatedConnectionMapPort(node.getXpdrCliConnectionMap().get(tpId.getValue()));
647 TerminationPoint ietfTpCl = buildIetfTp(tpceTp1Bldr, otnTp1, tpType, tpId, null, mapping);
648 tpMap.put(ietfTpCl.key(),ietfTpCl);
651 LOG.error("Undefined tpType for Termination point {} of {}", tpId.getValue(), node.getNodeId());
656 private static Class<? extends OduRateIdentity> fixRate(Class<? extends
657 SupportedIfCapability> ifCapType) {
658 switch (ifCapType.getSimpleName()) {
660 case "IfOCHOTU4ODU4":
673 private static Map<SupportingNodeKey,SupportingNode> createSupportingNodes(OtnTopoNode node) {
674 SupportingNode suppNode1 = new SupportingNodeBuilder()
675 .setNetworkRef(new NetworkId(NetworkUtils.UNDERLAY_NETWORK_ID))
676 .setNodeRef(new NodeId(node.getNodeId()))
677 .withKey(new SupportingNodeKey(new NetworkId(NetworkUtils.UNDERLAY_NETWORK_ID),
678 new NodeId(node.getNodeId())))
680 SupportingNode suppNode2 = new SupportingNodeBuilder()
681 .setNetworkRef(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID))
682 .setNodeRef(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb()))
683 .withKey(new SupportingNodeKey(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID),
684 new NodeId(node.getNodeId() + XPDR + node.getXpdrNb())))
686 SupportingNode suppNode3 = new SupportingNodeBuilder()
687 .setNetworkRef(new NetworkId(NetworkUtils.CLLI_NETWORK_ID))
688 .setNodeRef(new NodeId(node.getClli()))
689 .withKey(new SupportingNodeKey(new NetworkId(NetworkUtils.CLLI_NETWORK_ID),
690 new NodeId(node.getClli())))
692 Map<SupportingNodeKey,SupportingNode> suppNodeMap = new HashMap<>();
693 suppNodeMap.put(suppNode1.key(),suppNode1);
694 suppNodeMap.put(suppNode2.key(),suppNode2);
695 suppNodeMap.put(suppNode3.key(),suppNode3);
699 private static TerminationPoint buildIetfTp(
700 org.opendaylight.yang.gen.v1.http.transportpce.topology.rev210511.TerminationPoint1Builder tpceTp1Bldr,
701 TerminationPoint1 otnTp1, OpenroadmTpType tpType, TpId tpId,
702 Map<SupportingTerminationPointKey, SupportingTerminationPoint> supportTpMap, Mapping mapping) {
704 TerminationPointBuilder ietfTpBldr = new TerminationPointBuilder();
705 if (tpceTp1Bldr.getAssociatedConnectionMapPort() != null) {
706 ietfTpBldr.addAugmentation(tpceTp1Bldr.build());
708 if (supportTpMap != null) {
709 ietfTpBldr.setSupportingTerminationPoint(supportTpMap);
711 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.TerminationPoint1 ocnTp =
712 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev200529.TerminationPoint1Builder()
714 .setAdministrativeState(TopologyUtils.setNetworkAdminState(mapping.getPortAdminState()))
715 .setOperationalState(TopologyUtils.setNetworkOperState(mapping.getPortOperState()))
718 ietfTpBldr.setTpId(tpId)
719 .withKey(new TerminationPointKey(tpId))
720 .addAugmentation(otnTp1)
721 .addAugmentation(ocnTp);
722 return ietfTpBldr.build();