2 * Copyright © 2020 Orange Labs, Inc. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
8 package org.opendaylight.transportpce.networkmodel.util.test;
10 import com.google.common.collect.ImmutableMap;
11 import java.util.ArrayList;
12 import java.util.HashMap;
13 import java.util.HashSet;
14 import java.util.List;
17 import org.opendaylight.transportpce.common.NetworkUtils;
18 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.networkutils.rev220630.OtnLinkType;
19 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220316.mapping.Mapping;
20 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220316.mapping.MappingBuilder;
21 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220316.mapping.MappingKey;
22 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220316.network.Nodes;
23 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220316.network.NodesBuilder;
24 import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.portmapping.rev220316.network.nodes.NodeInfoBuilder;
25 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.Link1Builder;
26 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.types.rev181019.PortQual;
27 import org.opendaylight.yang.gen.v1.http.org.openroadm.device.types.rev191129.NodeTypes;
28 import org.opendaylight.yang.gen.v1.http.org.openroadm.device.types.rev191129.XpdrNodeTypes;
29 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev211210.OpenroadmLinkType;
30 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev211210.OpenroadmTpType;
31 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev211210.xpdr.tp.supported.interfaces.SupportedInterfaceCapability;
32 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev211210.xpdr.tp.supported.interfaces.SupportedInterfaceCapabilityBuilder;
33 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev211210.xpdr.tp.supported.interfaces.SupportedInterfaceCapabilityKey;
34 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.ODTU4TsAllocated;
35 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.common.types.rev210924.ODU4;
36 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev211210.TerminationPoint1;
37 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev211210.TerminationPoint1Builder;
38 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev211210.networks.network.node.termination.point.TpSupportedInterfaces;
39 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev211210.networks.network.node.termination.point.TpSupportedInterfacesBuilder;
40 import org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev211210.networks.network.node.termination.point.XpdrTpPortConnectionAttributesBuilder;
41 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev201211.If100GE;
42 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev201211.IfOCH;
43 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev201211.IfOCHOTU4ODU4;
44 import org.opendaylight.yang.gen.v1.http.org.openroadm.port.types.rev201211.SupportedIfCapability;
45 import org.opendaylight.yang.gen.v1.http.org.openroadm.xponder.rev211210.xpdr.otn.tp.attributes.OdtuTpnPool;
46 import org.opendaylight.yang.gen.v1.http.org.openroadm.xponder.rev211210.xpdr.otn.tp.attributes.OdtuTpnPoolBuilder;
47 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NetworkId;
48 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NodeId;
49 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.LinkId;
50 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.TpId;
51 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.Link;
52 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.LinkBuilder;
53 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.link.DestinationBuilder;
54 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.link.SourceBuilder;
55 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPoint;
56 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.TerminationPointBuilder;
57 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.termination.point.SupportingTerminationPoint;
58 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.termination.point.SupportingTerminationPointBuilder;
59 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.topology.rev180226.networks.network.node.termination.point.SupportingTerminationPointKey;
60 import org.opendaylight.yangtools.yang.common.Uint16;
61 import org.opendaylight.yangtools.yang.common.Uint32;
62 import org.slf4j.Logger;
63 import org.slf4j.LoggerFactory;
65 public final class NetworkmodelTestUtil {
67 private static final Logger LOG = LoggerFactory.getLogger(NetworkmodelTestUtil.class);
69 public static Nodes createMappingForRdm(String nodeId, String clli, int degNb, List<Integer> srgNbs) {
70 Map<MappingKey,Mapping> mappingList = new HashMap<>();
71 createDegreeMappings(mappingList, 1, degNb);
72 for (Integer integer : srgNbs) {
73 createSrgMappings(mappingList, integer.intValue());
75 return new NodesBuilder()
77 .setNodeInfo(new NodeInfoBuilder().setNodeType(NodeTypes.Rdm).setNodeClli(clli).build())
78 .setMapping(mappingList)
82 public static Nodes createMappingForXpdr(String nodeId, String clli, int networkPortNb, int clientPortNb,
83 XpdrNodeTypes xpdrNodeType) {
84 Map<MappingKey,Mapping> mappingMap = new HashMap<>();
85 createXpdrMappings(mappingMap, networkPortNb, clientPortNb, xpdrNodeType);
86 Nodes mappingNode = new NodesBuilder()
88 .setNodeInfo(new NodeInfoBuilder().setNodeType(NodeTypes.Xpdr).setNodeClli(clli).build())
89 .setMapping(mappingMap)
91 LOG.info("mapping = {}", mappingNode.toString());
95 public static List<Link> createSuppOTNLinks(OtnLinkType type, Uint32 availBW) {
96 Link linkAZ = new LinkBuilder()
97 .setLinkId(new LinkId(type.getName() + "-SPDRA-XPDR1-XPDR1-NETWORK1toSPDRZ-XPDR1-XPDR1-NETWORK1"))
98 .setSource(new SourceBuilder()
99 .setSourceNode(new NodeId("SPDRA-XPDR1"))
100 .setSourceTp(new TpId("XPDR1-NETWORK1")).build())
101 .setDestination(new DestinationBuilder()
102 .setDestNode(new NodeId("SPDRZ-XPDR1"))
103 .setDestTp(new TpId("XPDR1-NETWORK1")).build())
106 .setLinkType(OpenroadmLinkType.OTNLINK)
107 .setOppositeLink(new LinkId(type.getName()
108 + "-SPDRZ-XPDR1-XPDR1-NETWORK1toSPDRA-XPDR1-XPDR1-NETWORK1"))
111 new org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev211210.Link1Builder()
112 .setAvailableBandwidth(availBW)
113 .setUsedBandwidth(Uint32.valueOf(100000 - availBW.intValue()))
116 new org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.networkutils.rev220630
118 .setOtnLinkType(type)
121 Link linkZA = new LinkBuilder()
122 .setLinkId(new LinkId(type.getName() + "-SPDRZ-XPDR1-XPDR1-NETWORK1toSPDRA-XPDR1-XPDR1-NETWORK1"))
123 .setSource(new SourceBuilder()
124 .setSourceNode(new NodeId("SPDRZ-XPDR1"))
125 .setSourceTp(new TpId("XPDR1-NETWORK1")).build())
126 .setDestination(new DestinationBuilder()
127 .setDestNode(new NodeId("SPDRA-XPDR1"))
128 .setDestTp(new TpId("XPDR1-NETWORK1")).build())
131 .setLinkType(OpenroadmLinkType.OTNLINK)
132 .setOppositeLink(new LinkId(type.getName()
133 + "-SPDRA-XPDR1-XPDR1-NETWORK1toSPDRZ-XPDR1-XPDR1-NETWORK1"))
136 new org.opendaylight.yang.gen.v1.http.org.openroadm.otn.network.topology.rev211210.Link1Builder()
137 .setAvailableBandwidth(availBW)
138 .setUsedBandwidth(Uint32.valueOf(100000 - availBW.intValue()))
141 new org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.networkutils.rev220630
143 .setOtnLinkType(type)
146 List<Link> links = new ArrayList<>();
152 public static List<TerminationPoint> createTpList(boolean withTpnTsPool) {
153 SupportedInterfaceCapability supCapa = new SupportedInterfaceCapabilityBuilder()
154 .setIfCapType(IfOCHOTU4ODU4.class)
156 Map<SupportedInterfaceCapabilityKey,SupportedInterfaceCapability> supInterCapaList =
158 supInterCapaList.put(supCapa.key(),supCapa);
159 TpSupportedInterfaces tpSuppInter = new TpSupportedInterfacesBuilder()
160 .setSupportedInterfaceCapability(supInterCapaList)
162 XpdrTpPortConnectionAttributesBuilder xtpcaBldr = new XpdrTpPortConnectionAttributesBuilder()
163 .setRate(ODU4.class);
165 Set<Uint16> tsPool = new HashSet<>();
166 for (int i = 0; i < 80; i++) {
167 tsPool.add(Uint16.valueOf(i + 1));
169 xtpcaBldr.setTsPool(tsPool);
170 Set<Uint16> tpnPool = new HashSet<>();
171 for (int i = 1; i <= 80; i++) {
172 tpnPool.add(Uint16.valueOf(i));
174 OdtuTpnPool odtuTpn = new OdtuTpnPoolBuilder()
175 .setOdtuType(ODTU4TsAllocated.class)
176 .setTpnPool(tpnPool).build();
177 xtpcaBldr.setOdtuTpnPool(ImmutableMap.of(odtuTpn.key(),odtuTpn));
179 TerminationPoint1 otnTp1 = new TerminationPoint1Builder()
180 .setTpSupportedInterfaces(tpSuppInter)
181 .setXpdrTpPortConnectionAttributes(xtpcaBldr.build())
183 SupportingTerminationPoint supTermPointA = new SupportingTerminationPointBuilder()
184 .setNetworkRef(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID))
185 .setNodeRef(new NodeId("SPDRA-XPDR1"))
186 .setTpRef(new TpId("XPDR1-NETWORK1"))
188 Map<SupportingTerminationPointKey,SupportingTerminationPoint> supTermPointMapA =
189 Map.of(supTermPointA.key(), supTermPointA);
190 TerminationPoint tpA = new TerminationPointBuilder()
191 .setTpId(new TpId("XPDR1-NETWORK1"))
192 .setSupportingTerminationPoint(supTermPointMapA)
193 .addAugmentation(otnTp1)
195 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.TerminationPoint1Builder()
196 .setTpType(OpenroadmTpType.XPONDERNETWORK)
199 SupportingTerminationPoint supTermPointZ = new SupportingTerminationPointBuilder()
200 .setNetworkRef(new NetworkId(NetworkUtils.OVERLAY_NETWORK_ID))
201 .setNodeRef(new NodeId("SPDRZ-XPDR1"))
202 .setTpRef(new TpId("XPDR1-NETWORK1"))
204 Map<SupportingTerminationPointKey,SupportingTerminationPoint> supTermPointMapZ =
205 Map.of(supTermPointZ.key(), supTermPointZ);
206 TerminationPoint tpZ = new TerminationPointBuilder()
207 .setTpId(new TpId("XPDR1-NETWORK1"))
208 .setSupportingTerminationPoint(supTermPointMapZ)
209 .addAugmentation(otnTp1)
211 new org.opendaylight.yang.gen.v1.http.org.openroadm.common.network.rev211210.TerminationPoint1Builder()
212 .setTpType(OpenroadmTpType.XPONDERNETWORK)
215 List<TerminationPoint> tps = new ArrayList<>();
221 private static Map<MappingKey,Mapping> createDegreeMappings(Map<MappingKey,Mapping> mappingMap,
222 int degNbStart, int degNbStop) {
223 for (int i = degNbStart; i <= degNbStop; i++) {
224 Mapping mapping = new MappingBuilder()
225 .setLogicalConnectionPoint("DEG" + i + "-TTP-TXRX")
226 .setPortDirection("bidirectional")
227 .setSupportingPort("L1")
228 .setSupportingCircuitPackName(i + "/0")
229 .setSupportingOts("OTS-DEG" + i + "-TTP-TXRX")
230 .setSupportingOms("OMS-DEG" + i + "-TTP-TXRX")
232 mappingMap.put(mapping.key(),mapping);
237 private static Map<MappingKey,Mapping> createSrgMappings(Map<MappingKey,Mapping> mappingMap, int srgNb) {
238 for (int j = 1; j <= 4; j++) {
239 Mapping mapping = new MappingBuilder()
240 .setLogicalConnectionPoint("SRG" + srgNb + "-PP" + j + "-TXRX")
241 .setPortDirection("bidirectional")
242 .setSupportingPort("C" + j)
243 .setSupportingCircuitPackName(3 + srgNb + "/0")
245 mappingMap.put(mapping.key(),mapping);
250 private static Map<MappingKey,Mapping> createXpdrMappings(Map<MappingKey,Mapping> mappingMap,
251 int networkPortNb, int clientPortNb,
252 XpdrNodeTypes xpdrNodeType) {
253 for (int i = 1; i <= networkPortNb; i++) {
254 Set<Class<? extends SupportedIfCapability>> supportedIntf = new HashSet<>();
255 supportedIntf.add(IfOCH.class);
256 MappingBuilder mappingBldr = new MappingBuilder()
257 .setLogicalConnectionPoint("XPDR1-NETWORK" + i)
258 .setPortDirection("bidirectional")
259 .setSupportingPort("1")
260 .setSupportedInterfaceCapability(supportedIntf)
261 .setConnectionMapLcp("XPDR1-CLIENT" + i)
262 .setPortQual(PortQual.XpdrNetwork.getName())
263 .setSupportingCircuitPackName("1/0/" + i + "-PLUG-NET");
264 if (xpdrNodeType != null) {
265 mappingBldr.setXponderType(xpdrNodeType);
267 Mapping mapping = mappingBldr.build();
268 mappingMap.put(mapping.key(),mapping);
270 for (int i = 1; i <= clientPortNb; i++) {
271 Set<Class<? extends SupportedIfCapability>> supportedIntf = new HashSet<>();
272 supportedIntf.add(If100GE.class);
273 Mapping mapping = new MappingBuilder()
274 .setLogicalConnectionPoint("XPDR1-CLIENT" + i)
275 .setPortDirection("bidirectional")
276 .setSupportingPort("C1")
277 .setSupportedInterfaceCapability(supportedIntf)
278 .setConnectionMapLcp("XPDR1-NETWORK" + i)
279 .setPortQual(PortQual.XpdrClient.getName())
280 .setSupportingCircuitPackName("1/0/" + i + "-PLUG-CLIENT")
282 mappingMap.put(mapping.key(),mapping);
287 private NetworkmodelTestUtil() {