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.ImmutableList;
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.rev200429.network.Nodes;
22 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev200429.network.nodes.Mapping;
23 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.types.rev181019.XpdrNodeTypes;
24 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev181130.xpdr.odu.switching.pools.OduSwitchingPools;
25 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev181130.xpdr.odu.switching.pools.OduSwitchingPoolsBuilder;
26 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev181130.xpdr.odu.switching.pools.odu.switching.pools.NonBlockingList;
27 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.types.rev181130.xpdr.odu.switching.pools.odu.switching.pools.NonBlockingListBuilder;
28 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev181130.OpenroadmLinkType;
29 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev181130.OpenroadmNodeType;
30 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev181130.OpenroadmTpType;
31 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev181130.xpdr.tp.supported.interfaces.SupportedInterfaceCapability;
32 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev181130.xpdr.tp.supported.interfaces.SupportedInterfaceCapabilityBuilder;
33 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev181130.ODTU4TsAllocated;
34 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev181130.ODU0;
35 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev181130.ODU2e;
36 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev181130.ODU4;
37 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev181130.OduRateIdentity;
38 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev181130.Link1;
39 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev181130.Link1Builder;
40 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev181130.Node1;
41 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev181130.Node1Builder;
42 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev181130.TerminationPoint1;
43 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev181130.TerminationPoint1Builder;
44 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev181130.networks.network.node.SwitchingPools;
45 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev181130.networks.network.node.SwitchingPoolsBuilder;
46 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev181130.networks.network.node.TpBandwidthSharing;
47 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev181130.networks.network.node.TpBandwidthSharingBuilder;
48 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev181130.networks.network.node.XpdrAttributes;
49 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev181130.networks.network.node.XpdrAttributesBuilder;
50 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev181130.networks.network.node.termination.point.TpSupportedInterfaces;
51 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev181130.networks.network.node.termination.point.TpSupportedInterfacesBuilder;
52 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev181130.networks.network.node.termination.point.XpdrTpPortConnectionAttributesBuilder;
53 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev181130.If100GE;
54 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev181130.If100GEODU4;
55 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev181130.If10GEODU2e;
56 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev181130.IfOCHOTU4ODU4;
57 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev181130.SupportedIfCapability;
58 import org.opendaylight.yang.gen.v1.http.org.openroadm.switching.pool.types.rev181130.SwitchingPoolTypes;
59 import org.opendaylight.yang.gen.v1.http.org.openroadm.xponder.rev181130.xpdr.otn.tp.attributes.OdtuTpnPoolBuilder;
60 import org.opendaylight.yang.gen.v1.http.transportpce.topology.rev200129.OtnLinkType;
61 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NetworkId;
62 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NodeId;
63 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.Node;
64 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.NodeBuilder;
65 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.NodeKey;
66 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.node.SupportingNode;
67 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.node.SupportingNodeBuilder;
68 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.networks.network.node.SupportingNodeKey;
69 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.TpId;
70 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.Link;
71 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.LinkBuilder;
72 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPoint;
73 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPointBuilder;
74 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPointKey;
75 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.termination.point.SupportingTerminationPoint;
76 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.termination.point.SupportingTerminationPointBuilder;
77 import org.opendaylight.yangtools.yang.common.Uint16;
78 import org.opendaylight.yangtools.yang.common.Uint32;
79 import org.slf4j.Logger;
80 import org.slf4j.LoggerFactory;
82 public final class OpenRoadmOtnTopology {
84 private static final Logger LOG = LoggerFactory.getLogger(OpenRoadmOtnTopology.class);
85 private static final String CLIENT = "-CLIENT";
86 private static final String NETWORK = "-NETWORK";
87 private static final String XPDR = "-XPDR";
88 private static final int NB_TRIB_PORTS = 80;
89 private static final int NB_TRIB_SLOTS = 80;
90 private static final int NB_TRIB_SLOT_PER_10GE = 8;
92 private OpenRoadmOtnTopology() {
95 public static TopologyShard createTopologyShard(Nodes mappingNode) {
96 List<Node> nodes = new ArrayList<>();
97 List<Link> links = new ArrayList<>();
98 Map<Integer, OtnTopoNode> xpdrMap = convertPortMappingToOtnNodeList(mappingNode);
99 for (OtnTopoNode node : xpdrMap.values()) {
100 switch (node.getNodeType()) {
102 nodes.add(createTpdr(node));
105 nodes.add(createMuxpdr(node));
108 nodes.add(createSwitch(node));
111 LOG.error("unknown otn node type {}", node.getNodeType().getName());
115 return new TopologyShard(nodes, links);
118 public static TopologyShard createOtnLinks(String nodeA, String tpA, String nodeZ, String tpZ,
119 OtnLinkType linkType) {
120 List<Link> links = null;
121 if (OtnLinkType.OTU4.equals(linkType)) {
122 links = initialiseOtnLinks(nodeA, tpA, nodeZ, tpZ, linkType, "OTU4");
124 return new TopologyShard(null, links);
127 public static TopologyShard createOtnLinks(List<Link> suppOtu4Links, List<TerminationPoint> oldTps) {
128 List<Link> links = new ArrayList<>();
129 for (Link link : suppOtu4Links) {
130 if (link.augmentation(Link1.class) != null
131 && link.augmentation(Link1.class).getAvailableBandwidth().equals(Uint32.valueOf(100000))) {
132 links.add(updateOtnLinkBwParameters(link, 0L, 100000L));
134 LOG.error("Error with otn parameters of supported link {}", link.getLinkId().getValue());
137 if (links.size() == 2) {
138 links.addAll(initialiseOtnLinks(suppOtu4Links.get(0).getSource().getSourceNode().getValue(),
139 suppOtu4Links.get(0).getSource().getSourceTp().toString(),
140 suppOtu4Links.get(0).getDestination().getDestNode().getValue(),
141 suppOtu4Links.get(0).getDestination().getDestTp().toString(),
142 OtnLinkType.ODTU4, "ODU4"));
144 List<TerminationPoint> tps = new ArrayList<>();
145 for (TerminationPoint tp : oldTps) {
146 tps.add(updateTp(tp, true));
148 if (links.size() == 4 && tps.size() == 2) {
149 return new TopologyShard(null, links, tps);
151 return new TopologyShard(null, null, null);
155 public static TopologyShard updateOtnLinks(List<Link> suppOdu4Links, List<TerminationPoint> oldTps,
156 String serviceRate, Short tribPortNb, Short tribSoltNb, boolean isDeletion) {
157 List<Link> links = new ArrayList<>();
158 Long bwIncr = 10000L;
159 if ("1G".equals(serviceRate)) {
162 for (Link link : suppOdu4Links) {
163 if (link.augmentation(Link1.class) != null && link.augmentation(Link1.class).getAvailableBandwidth() != null
164 && link.augmentation(Link1.class).getUsedBandwidth() != null) {
165 Uint32 avlBw = link.augmentation(Link1.class).getAvailableBandwidth();
166 Uint32 usedBw = link.augmentation(Link1.class).getUsedBandwidth();
167 if (avlBw.toJava() < bwIncr) {
171 links.add(updateOtnLinkBwParameters(link, avlBw.toJava() + bwIncr,
172 usedBw.toJava() - bwIncr));
174 links.add(updateOtnLinkBwParameters(link, avlBw.toJava() - bwIncr,
175 usedBw.toJava() + bwIncr));
178 LOG.error("Error with otn parameters of supported link {}", link.getLinkId().getValue());
181 List<TerminationPoint> tps = new ArrayList<>();
182 for (TerminationPoint tp : oldTps) {
184 tps.add(updateNodeTpTsPool(tp, serviceRate, tribPortNb, tribSoltNb, isDeletion));
187 if (!links.isEmpty() && !tps.isEmpty()) {
188 return new TopologyShard(null, links, tps);
190 LOG.error("unable to update otn links");
191 return new TopologyShard(null, null, null);
195 public static TopologyShard deleteOtnLinks(List<Link> suppOtu4Links, List<TerminationPoint> oldTps) {
196 List<Link> links = new ArrayList<>();
197 for (Link link : suppOtu4Links) {
198 if (link.augmentation(Link1.class) != null) {
199 links.add(updateOtnLinkBwParameters(link, 100000L, 0L));
201 LOG.error("Error with otn parameters of supported link {}", link.getLinkId().getValue());
204 List<TerminationPoint> tps = new ArrayList<>();
205 for (TerminationPoint tp : oldTps) {
206 tps.add(updateTp(tp, false));
208 if (links.size() == 2 && tps.size() == 2) {
209 return new TopologyShard(null, links, tps);
211 return new TopologyShard(null, null, null);
215 private static List<Link> initialiseOtnLinks(String nodeA, String tpA, String nodeZ, String tpZ,
216 OtnLinkType linkType, String linkIdPrefix) {
217 List<Link> links = new ArrayList<>();
218 org.opendaylight.yang.gen.v1.http.transportpce.topology.rev200129.Link1 tpceLink1
219 = new org.opendaylight.yang.gen.v1.http.transportpce.topology.rev200129.Link1Builder()
220 .setOtnLinkType(linkType).build();
221 Link1 otnLink1 = new Link1Builder()
222 .setAvailableBandwidth(Uint32.valueOf(100000))
223 .setUsedBandwidth(Uint32.valueOf(0))
228 if (nodeA.contains(XPDR) && nodeZ.contains(XPDR)) {
232 nodeATopo = nodeA + "-" + tpA.split("-")[0];
233 nodeZTopo = nodeZ + "-" + tpZ.split("-")[0];
235 LinkBuilder ietfLinkAZBldr = TopologyUtils.createLink(nodeATopo, nodeZTopo, tpA, tpZ, linkIdPrefix);
237 .addAugmentation(org.opendaylight.yang.gen.v1.http.transportpce.topology.rev200129.Link1.class, tpceLink1)
238 .addAugmentation(Link1.class, otnLink1)
240 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Link1.class,
241 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Link1Builder(
242 ietfLinkAZBldr.augmentation(
243 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Link1.class))
244 .setLinkType(OpenroadmLinkType.OTNLINK)
246 links.add(ietfLinkAZBldr.build());
248 LinkBuilder ietfLinkZABldr = TopologyUtils.createLink(nodeZTopo, nodeATopo, tpZ, tpA, linkIdPrefix);
250 .addAugmentation(org.opendaylight.yang.gen.v1.http.transportpce.topology.rev200129.Link1.class, tpceLink1)
251 .addAugmentation(Link1.class, otnLink1)
253 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Link1.class,
254 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Link1Builder(
255 ietfLinkZABldr.augmentation(
256 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Link1.class))
257 .setLinkType(OpenroadmLinkType.OTNLINK)
259 links.add(ietfLinkZABldr.build());
263 private static Link updateOtnLinkBwParameters(Link link, Long availBw, Long usedBw) {
264 LOG.debug("in updateOtnLinkBwParameters with availBw = {}, usedBw = {}", availBw, usedBw);
265 LinkBuilder updatedLinkBldr = new LinkBuilder(link);
266 Link1Builder updatedLink1Bldr = new Link1Builder(link.augmentation(Link1.class))
267 .setAvailableBandwidth(Uint32.valueOf(availBw))
268 .setUsedBandwidth(Uint32.valueOf(usedBw));
269 updatedLinkBldr.addAugmentation(Link1.class, updatedLink1Bldr.build());
270 return updatedLinkBldr.build();
273 private static TerminationPoint updateTp(TerminationPoint originalTp, boolean addingTsTpnPoolTermination) {
274 LOG.debug("in updateTp");
275 TerminationPointBuilder tpBldr = new TerminationPointBuilder(originalTp);
276 TerminationPoint1Builder otnTp1Bldr = new TerminationPoint1Builder(
277 tpBldr.augmentation(TerminationPoint1.class));
278 XpdrTpPortConnectionAttributesBuilder xtpcaBldr = new XpdrTpPortConnectionAttributesBuilder(otnTp1Bldr
279 .getXpdrTpPortConnectionAttributes());
280 if (addingTsTpnPoolTermination) {
281 List<Uint16> tsPool = new ArrayList<>();
282 for (int i = 0; i < NB_TRIB_SLOTS; i++) {
283 tsPool.add(Uint16.valueOf(i + 1));
285 xtpcaBldr.setTsPool(tsPool);
286 List<Uint16> tpnPool = new ArrayList<>();
287 for (int i = 1; i <= NB_TRIB_PORTS; i++) {
288 tpnPool.add(Uint16.valueOf(i));
290 xtpcaBldr.setOdtuTpnPool(ImmutableList.of(new OdtuTpnPoolBuilder().setOdtuType(ODTU4TsAllocated.class)
291 .setTpnPool(tpnPool).build()));
293 xtpcaBldr.setTsPool(null);
294 xtpcaBldr.setOdtuTpnPool(null);
296 return tpBldr.addAugmentation(TerminationPoint1.class,
297 otnTp1Bldr.setXpdrTpPortConnectionAttributes(xtpcaBldr.build()).build()).build();
300 private static TerminationPoint updateNodeTpTsPool(TerminationPoint tp, String serviceRate, Short tribPortNb,
301 Short tribSlotNb, boolean isDeletion) {
302 LOG.debug("in updateNodeTpTsPool");
303 TerminationPointBuilder tpBldr = new TerminationPointBuilder(tp);
305 XpdrTpPortConnectionAttributesBuilder xtpcaBldr = new XpdrTpPortConnectionAttributesBuilder(
306 tpBldr.augmentation(TerminationPoint1.class).getXpdrTpPortConnectionAttributes());
307 List<Uint16> tsPool = new ArrayList<>(xtpcaBldr.getTsPool());
308 switch (serviceRate) {
311 tsPool.add(Uint16.valueOf(tribSlotNb));
313 tsPool.remove(Uint16.valueOf(tribSlotNb));
318 for (int i = 0; i < NB_TRIB_SLOT_PER_10GE; i++) {
319 tsPool.add(Uint16.valueOf(tribSlotNb + i));
322 for (int i = 0; i < NB_TRIB_SLOT_PER_10GE; i++) {
323 tsPool.remove(Uint16.valueOf(tribSlotNb + i));
328 LOG.error("error updating tpn and ts pool for tp {}", tp.getTpId().getValue());
331 xtpcaBldr.setTsPool(tsPool);
332 List<Uint16> tpnPool;
333 if (xtpcaBldr.getOdtuTpnPool().get(0).getTpnPool() != null) {
334 tpnPool = new ArrayList<>(xtpcaBldr.getOdtuTpnPool().get(0).getTpnPool());
336 tpnPool.add(Uint16.valueOf(tribPortNb));
338 tpnPool.remove(Uint16.valueOf(tribPortNb));
341 tpnPool = new ArrayList<>();
343 xtpcaBldr.setOdtuTpnPool(ImmutableList.of(new OdtuTpnPoolBuilder().setOdtuType(ODTU4TsAllocated.class)
344 .setTpnPool(tpnPool).build()));
346 tpBldr.addAugmentation(TerminationPoint1.class,
347 new TerminationPoint1Builder().setXpdrTpPortConnectionAttributes(xtpcaBldr.build()).build());
348 return tpBldr.build();
351 private static Map<Integer, OtnTopoNode> convertPortMappingToOtnNodeList(Nodes mappingNode) {
352 List<Mapping> networkMappings = mappingNode.getMapping().stream().filter(k -> k.getLogicalConnectionPoint()
353 .contains("NETWORK")).collect(Collectors.toList());
354 Map<Integer, OtnTopoNode> xpdrMap = new HashMap<>();
355 for (Mapping mapping : networkMappings) {
356 Integer xpdrNb = Integer.parseInt(mapping.getLogicalConnectionPoint().split("XPDR")[1].split("-")[0]);
357 if (!xpdrMap.containsKey(xpdrNb)) {
358 List<Mapping> xpdrNetMaps = mappingNode.getMapping().stream().filter(k -> k.getLogicalConnectionPoint()
359 .contains("XPDR" + xpdrNb + NETWORK)).collect(Collectors.toList());
360 List<Mapping> xpdrClMaps = mappingNode.getMapping().stream().filter(k -> k.getLogicalConnectionPoint()
361 .contains("XPDR" + xpdrNb + CLIENT)).collect(Collectors.toList());
362 OtnTopoNode otnNode = null;
363 if (mapping.getXponderType() != null) {
364 otnNode = new OtnTopoNode(mappingNode.getNodeId(), mappingNode.getNodeInfo().getNodeClli(), xpdrNb,
365 mapping.getXponderType(), fillConnectionMapLcp(xpdrNetMaps), fillConnectionMapLcp(xpdrClMaps));
367 otnNode = new OtnTopoNode(mappingNode.getNodeId(), mappingNode.getNodeInfo().getNodeClli(), xpdrNb,
368 XpdrNodeTypes.Tpdr, fillConnectionMapLcp(xpdrNetMaps), fillConnectionMapLcp(xpdrClMaps));
370 xpdrMap.put(xpdrNb, otnNode);
373 LOG.debug("there are {} xpdr to build", xpdrMap.size());
374 xpdrMap.forEach((k, v) -> LOG.debug("xpdr {} = {} - {} - {} - {}", k, v.getNodeId(), v.getNodeType(),
375 v.getNbTpClient(), v.getNbTpNetwork()));
379 private static Map<String, String> fillConnectionMapLcp(List<Mapping> mappingList) {
380 Map<String, String> xpdrConnectionMap = new HashMap<>();
381 for (Mapping map : mappingList) {
382 if (map.getConnectionMapLcp() != null) {
383 xpdrConnectionMap.put(map.getLogicalConnectionPoint(), map.getConnectionMapLcp());
385 xpdrConnectionMap.put(map.getLogicalConnectionPoint(), null);
388 return xpdrConnectionMap;
391 private static Node createTpdr(OtnTopoNode node) {
392 // create otn-topology node augmentation
393 XpdrAttributes xpdrAttr = new XpdrAttributesBuilder()
394 .setXpdrNumber(Uint16.valueOf(node.getXpdrNb()))
396 Node1 otnNodeAug = new Node1Builder()
397 .setXpdrAttributes(xpdrAttr)
399 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1 ocnNodeAug =
400 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1Builder()
401 .setNodeType(OpenroadmNodeType.TPDR).build();
402 // create ietf node augmentation to add TP list
403 List<TerminationPoint> tpList = new ArrayList<>();
405 createTP(tpList, node, OpenroadmTpType.XPONDERCLIENT, If100GE.class, false);
406 createTP(tpList, node, OpenroadmTpType.XPONDERNETWORK, IfOCHOTU4ODU4.class, true);
408 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1 ietfNodeAug =
409 new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1Builder()
410 .setTerminationPoint(tpList)
414 return new NodeBuilder()
415 .setNodeId(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb()))
416 .withKey(new NodeKey(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb())))
417 .setSupportingNode(createSupportingNodes(node))
418 .addAugmentation(Node1.class, otnNodeAug)
419 .addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1.class,
422 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1.class,
427 private static Node createMuxpdr(OtnTopoNode node) {
428 // create otn-topology node augmentation
429 // TODO: will need to be completed
430 TpBandwidthSharing tpBwSh = new TpBandwidthSharingBuilder().build();
431 XpdrAttributes xpdrAttr = new XpdrAttributesBuilder()
432 .setXpdrNumber(Uint16.valueOf(node.getXpdrNb()))
435 List<NonBlockingList> nblList = new ArrayList<>();
436 for (int i = 1; i <= node.getNbTpClient(); i++) {
437 List<TpId> tpList = new ArrayList<>();
438 TpId tpId = new TpId("XPDR" + node.getXpdrNb() + CLIENT + i);
440 tpId = new TpId("XPDR" + node.getXpdrNb() + "-NETWORK1");
442 NonBlockingList nbl = new NonBlockingListBuilder()
443 .setNblNumber(Uint16.valueOf(i))
445 .setAvailableInterconnectBandwidth(Uint32.valueOf(node.getNbTpNetwork() * 10L))
446 .setInterconnectBandwidthUnit(Uint32.valueOf(1000000000))
450 OduSwitchingPools oduSwitchPool = new OduSwitchingPoolsBuilder()
451 .setSwitchingPoolNumber(Uint16.valueOf(1))
452 .setSwitchingPoolType(SwitchingPoolTypes.NonBlocking)
453 .setNonBlockingList(nblList)
455 List<OduSwitchingPools> oduSwitchPoolList = new ArrayList<>();
456 oduSwitchPoolList.add(oduSwitchPool);
457 SwitchingPools switchingPools = new SwitchingPoolsBuilder()
458 .setOduSwitchingPools(oduSwitchPoolList)
460 Node1 otnNodeAug = new Node1Builder()
461 .setTpBandwidthSharing(tpBwSh)
462 .setXpdrAttributes(xpdrAttr)
463 .setSwitchingPools(switchingPools)
465 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1 ocnNodeAug =
466 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1Builder()
467 .setNodeType(OpenroadmNodeType.MUXPDR).build();
469 // create ietf node augmentation to add TP list
470 List<TerminationPoint> tpList = new ArrayList<>();
472 createTP(tpList, node, OpenroadmTpType.XPONDERCLIENT, If10GEODU2e.class, true);
473 createTP(tpList, node, OpenroadmTpType.XPONDERNETWORK, IfOCHOTU4ODU4.class, true);
475 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1 ietfNodeAug =
476 new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1Builder()
477 .setTerminationPoint(tpList)
481 return new NodeBuilder()
482 .setNodeId(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb()))
483 .withKey(new NodeKey(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb())))
484 .setSupportingNode(createSupportingNodes(node))
485 .addAugmentation(Node1.class, otnNodeAug)
486 .addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1.class,
489 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1.class,
494 private static Node createSwitch(OtnTopoNode node) {
495 List<TpId> tpl = new ArrayList<>();
497 for (int i = 1; i <= node.getNbTpClient(); i++) {
498 tpId = new TpId("XPDR" + node.getXpdrNb() + CLIENT + i);
501 for (int i = 1; i <= node.getNbTpNetwork(); i++) {
502 tpId = new TpId("XPDR" + node.getXpdrNb() + NETWORK + i);
505 List<NonBlockingList> nblList = new ArrayList<>();
506 NonBlockingList nbl = new NonBlockingListBuilder()
507 .setNblNumber(Uint16.valueOf(1))
512 OduSwitchingPools oduSwitchPool = new OduSwitchingPoolsBuilder()
513 .setSwitchingPoolNumber(Uint16.valueOf(1))
514 .setSwitchingPoolType(SwitchingPoolTypes.NonBlocking)
515 .setNonBlockingList(nblList)
517 List<OduSwitchingPools> oduSwitchPoolList = new ArrayList<>();
518 oduSwitchPoolList.add(oduSwitchPool);
519 SwitchingPools switchingPools = new SwitchingPoolsBuilder()
520 .setOduSwitchingPools(oduSwitchPoolList)
523 // create otn-topology node augmentation
524 // TODO: will need to be completed
525 TpBandwidthSharing tpBwSh = new TpBandwidthSharingBuilder().build();
526 XpdrAttributes xpdrAttr = new XpdrAttributesBuilder()
527 .setXpdrNumber(Uint16.valueOf(node.getXpdrNb()))
530 Node1 otnNodeAug = new Node1Builder()
531 .setTpBandwidthSharing(tpBwSh)
532 .setXpdrAttributes(xpdrAttr)
533 .setSwitchingPools(switchingPools)
535 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1 ocnNodeAug =
536 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1Builder()
537 .setNodeType(OpenroadmNodeType.SWITCH).build();
539 // create ietf node augmentation to add TP list
540 List<TerminationPoint> tpList = new ArrayList<>();
542 createTP(tpList, node, OpenroadmTpType.XPONDERCLIENT, If100GEODU4.class, true);
543 createTP(tpList, node, OpenroadmTpType.XPONDERNETWORK, IfOCHOTU4ODU4.class, true);
544 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1 ietfNodeAug =
545 new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1Builder()
546 .setTerminationPoint(tpList)
550 return new NodeBuilder()
551 .setNodeId(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb()))
552 .withKey(new NodeKey(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb())))
553 .setSupportingNode(createSupportingNodes(node))
554 .addAugmentation(Node1.class, otnNodeAug)
555 .addAugmentation(org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.Node1.class,
558 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.Node1.class,
563 private static void createTP(List<TerminationPoint> tpList, OtnTopoNode node, OpenroadmTpType tpType,
564 Class<? extends SupportedIfCapability> ifCapType, boolean withRate) {
566 if (OpenroadmTpType.XPONDERCLIENT.equals(tpType)) {
567 nbTps = node.getNbTpClient();
568 } else if (OpenroadmTpType.XPONDERNETWORK.equals(tpType)) {
569 nbTps = node.getNbTpNetwork();
571 LOG.warn("Wrong tp-type {}, cannot create tp {}", tpType, tpType.getName());
574 for (int i = 1; i <= nbTps; i++) {
575 // openroadm-otn-topoology augmentation
576 SupportedInterfaceCapability supIfCapa = new SupportedInterfaceCapabilityBuilder()
577 .setIfCapType(ifCapType)
579 List<SupportedInterfaceCapability> supIfCapaList = new ArrayList<>();
580 supIfCapaList.add(supIfCapa);
581 TpSupportedInterfaces tpSupIf = new TpSupportedInterfacesBuilder()
582 .setSupportedInterfaceCapability(supIfCapaList)
585 XpdrTpPortConnectionAttributesBuilder xtpcaBldr = new XpdrTpPortConnectionAttributesBuilder();
587 xtpcaBldr.setRate(fixRate(ifCapType));
589 TerminationPoint1 otnTp1 = new TerminationPoint1Builder()
590 .setTpSupportedInterfaces(tpSupIf)
591 .setXpdrTpPortConnectionAttributes(xtpcaBldr.build())
593 org.opendaylight.yang.gen.v1.http.transportpce.topology.rev200129.TerminationPoint1Builder tpceTp1Bldr =
594 new org.opendaylight.yang.gen.v1.http.transportpce.topology.rev200129.TerminationPoint1Builder();
595 if (OpenroadmTpType.XPONDERNETWORK.equals(tpType)) {
596 TpId tpId = new TpId("XPDR" + node.getXpdrNb() + NETWORK + i);
597 if (node.getXpdrNetConnectionMap().get(tpId.getValue()) != null) {
598 tpceTp1Bldr.setAssociatedConnectionMapPort(node.getXpdrNetConnectionMap().get(tpId.getValue()));
600 SupportingTerminationPoint stp = new SupportingTerminationPointBuilder()
601 .setNetworkRef(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID))
602 .setNodeRef(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb()))
603 .setTpRef("XPDR" + node.getXpdrNb() + NETWORK + i)
605 List<SupportingTerminationPoint> supportTpList = new ArrayList<>();
606 supportTpList.add(stp);
607 tpList.add(buildIetfTp(tpceTp1Bldr, otnTp1, tpType, tpId, supportTpList));
608 } else if (OpenroadmTpType.XPONDERCLIENT.equals(tpType)) {
609 TpId tpId = new TpId("XPDR" + node.getXpdrNb() + CLIENT + i);
610 if (node.getXpdrCliConnectionMap().get(tpId.getValue()) != null) {
611 tpceTp1Bldr.setAssociatedConnectionMapPort(node.getXpdrCliConnectionMap().get(tpId.getValue()));
613 tpList.add(buildIetfTp(tpceTp1Bldr, otnTp1, tpType, tpId, null));
618 private static Class<? extends OduRateIdentity> fixRate(Class<? extends SupportedIfCapability> ifCapaType) {
619 switch (ifCapaType.getSimpleName()) {
621 case "IfOCHOTU4ODU4":
632 private static List<SupportingNode> createSupportingNodes(OtnTopoNode node) {
633 SupportingNode suppNode1 = new SupportingNodeBuilder()
634 .setNetworkRef(new NetworkId(NetworkUtils.UNDERLAY_NETWORK_ID))
635 .setNodeRef(new NodeId(node.getNodeId()))
636 .withKey(new SupportingNodeKey(new NetworkId(NetworkUtils.UNDERLAY_NETWORK_ID),
637 new NodeId(node.getNodeId())))
639 SupportingNode suppNode2 = new SupportingNodeBuilder()
640 .setNetworkRef(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID))
641 .setNodeRef(new NodeId(node.getNodeId() + XPDR + node.getXpdrNb()))
642 .withKey(new SupportingNodeKey(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID),
643 new NodeId(node.getNodeId() + XPDR + node.getXpdrNb())))
645 SupportingNode suppNode3 = new SupportingNodeBuilder()
646 .setNetworkRef(new NetworkId(NetworkUtils.CLLI_NETWORK_ID))
647 .setNodeRef(new NodeId(node.getClli()))
648 .withKey(new SupportingNodeKey(new NetworkId(NetworkUtils.CLLI_NETWORK_ID),
649 new NodeId(node.getClli())))
651 List<SupportingNode> suppNodeList = new ArrayList<>();
652 suppNodeList.add(suppNode1);
653 suppNodeList.add(suppNode2);
654 suppNodeList.add(suppNode3);
658 private static TerminationPoint buildIetfTp(
659 org.opendaylight.yang.gen.v1.http.transportpce.topology.rev200129.TerminationPoint1Builder tpceTp1Bldr,
660 TerminationPoint1 otnTp1, OpenroadmTpType tpType, TpId tpId,
661 List<SupportingTerminationPoint> supportTpList) {
663 TerminationPointBuilder ietfTpBldr = new TerminationPointBuilder();
664 if (tpceTp1Bldr.getAssociatedConnectionMapPort() != null) {
665 ietfTpBldr.addAugmentation(
666 org.opendaylight.yang.gen.v1.http.transportpce.topology.rev200129.TerminationPoint1.class,
667 tpceTp1Bldr.build());
669 if (supportTpList != null) {
670 ietfTpBldr.setSupportingTerminationPoint(supportTpList);
672 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.TerminationPoint1 ocnTp =
673 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.TerminationPoint1Builder()
674 .setTpType(tpType).build();
676 ietfTpBldr.setTpId(tpId)
677 .withKey(new TerminationPointKey(tpId))
678 .addAugmentation(TerminationPoint1.class, otnTp1)
680 org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev181130.TerminationPoint1.class,
682 return ietfTpBldr.build();