2 * Copyright © 2018 Orange Systems, 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.renderer;
10 import java.math.BigDecimal;
11 import java.util.ArrayList;
12 import java.util.Arrays;
13 import java.util.Collection;
14 import java.util.Collections;
15 import java.util.List;
16 import java.util.concurrent.ExecutionException;
17 import org.junit.Assert;
18 import org.junit.Before;
19 import org.junit.Test;
20 import org.junit.runner.RunWith;
21 import org.junit.runners.Parameterized;
22 import org.opendaylight.transportpce.common.StringConstants;
23 import org.opendaylight.transportpce.common.device.DeviceTransactionManager;
24 import org.opendaylight.transportpce.common.device.DeviceTransactionManagerImpl;
25 import org.opendaylight.transportpce.common.fixedflex.FixedFlexImpl;
26 import org.opendaylight.transportpce.renderer.stub.MountPointServiceStub;
27 import org.opendaylight.transportpce.renderer.stub.MountPointStub;
28 import org.opendaylight.transportpce.renderer.utils.ServiceDeleteDataUtils;
29 import org.opendaylight.transportpce.renderer.utils.WaveLengthServiceUtils;
30 import org.opendaylight.transportpce.test.AbstractTest;
31 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.optical.channel.types.rev181130.FrequencyGHz;
32 import org.opendaylight.yang.gen.v1.http.org.openroadm.common.optical.channel.types.rev181130.FrequencyTHz;
33 import org.opendaylight.yang.gen.v1.http.org.openroadm.degree.rev181130.degree.used.wavelengths.UsedWavelengthsBuilder;
34 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.Node1;
35 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.Node1Builder;
36 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.TerminationPoint1;
37 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.TerminationPoint1Builder;
38 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.DegreeAttributesBuilder;
39 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.SrgAttributesBuilder;
40 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.termination.point.CpAttributesBuilder;
41 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.termination.point.CtpAttributesBuilder;
42 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.termination.point.PpAttributesBuilder;
43 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.termination.point.RxTtpAttributesBuilder;
44 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.termination.point.TxTtpAttributesBuilder;
45 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.termination.point.XpdrClientAttributesBuilder;
46 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.termination.point.XpdrNetworkAttributesBuilder;
47 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.termination.point.XpdrPortAttributesBuilder;
48 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks.network.node.termination.point.pp.attributes.UsedWavelengthBuilder;
49 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev181130.OpenroadmNodeType;
50 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev181130.OpenroadmTpType;
51 import org.opendaylight.yang.gen.v1.http.org.openroadm.xponder.rev181130.xpdr.port.connection.attributes.WavelengthBuilder;
52 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev171017.PathDescription;
54 @RunWith(Parameterized.class)
55 public class NetworkModelWaveLengthServiceFreeTest extends AbstractTest {
57 private static final Long WAVE_LENGTH = 20L;
58 private NetworkModelWavelengthService networkModelWavelengthService;
59 private DeviceTransactionManager deviceTransactionManager;
60 private TerminationPoint1 terminationPoint1;
61 private PathDescription pathDescription;
64 public NetworkModelWaveLengthServiceFreeTest(PathDescription pathDescription, TerminationPoint1 terminationPoint1,
66 this.pathDescription = pathDescription;
67 this.terminationPoint1 = terminationPoint1;
71 @Parameterized.Parameters
72 public static Collection createParameters() {
73 List<Object[]> parameters = new ArrayList<>();
75 PathDescription pathDescription =
76 ServiceDeleteDataUtils.createTransactionPathDescription(StringConstants.TTP_TOKEN);
78 TerminationPoint1Builder terminationPoint1Builder = new TerminationPoint1Builder();
79 terminationPoint1Builder.setCtpAttributes((new CtpAttributesBuilder()).setUsedWavelengths(Collections
80 .singletonList((new UsedWavelengthsBuilder()).setIndex(WAVE_LENGTH).build())).build());
81 terminationPoint1Builder.setCpAttributes((new CpAttributesBuilder()).setUsedWavelengths(Collections
82 .singletonList((new org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev181130.networks
83 .network.node.termination.point.cp.attributes.UsedWavelengthsBuilder())
84 .setIndex(WAVE_LENGTH).build())).build());
85 terminationPoint1Builder.setTxTtpAttributes((new TxTtpAttributesBuilder()).setUsedWavelengths(Collections
86 .singletonList((new UsedWavelengthsBuilder()).setIndex(WAVE_LENGTH).build())).build());
87 terminationPoint1Builder.setRxTtpAttributes((new RxTtpAttributesBuilder()).setUsedWavelengths(Collections
88 .singletonList((new UsedWavelengthsBuilder()).setIndex(WAVE_LENGTH).build())).build());
89 terminationPoint1Builder.setPpAttributes((new PpAttributesBuilder()).setUsedWavelength(Collections
90 .singletonList((new UsedWavelengthBuilder()).setIndex(WAVE_LENGTH).build())).build());
92 FixedFlexImpl fixedFlex = new FixedFlexImpl();
93 fixedFlex = fixedFlex.getFixedFlexWaveMapping(WAVE_LENGTH);
94 FrequencyGHz frequencyGHz = new FrequencyGHz(new BigDecimal(fixedFlex.getWavelength()));
95 FrequencyTHz frequencyTHz = new FrequencyTHz(new BigDecimal(fixedFlex.getCenterFrequency()));
97 terminationPoint1Builder.setXpdrClientAttributes((new XpdrClientAttributesBuilder())
98 .setWavelength((new WavelengthBuilder()).setFrequency(frequencyTHz).setWidth(frequencyGHz)
100 terminationPoint1Builder.setXpdrNetworkAttributes((new XpdrNetworkAttributesBuilder())
101 .setWavelength((new WavelengthBuilder()).setFrequency(frequencyTHz).setWidth(frequencyGHz)
103 terminationPoint1Builder.setXpdrPortAttributes((new XpdrPortAttributesBuilder())
104 .setWavelength((new WavelengthBuilder()).setFrequency(frequencyTHz).setWidth(frequencyGHz)
107 Node1Builder node1Builder = new Node1Builder();
108 node1Builder.setDegreeAttributes((new DegreeAttributesBuilder()).setAvailableWavelengths(new ArrayList<>())
110 node1Builder.setSrgAttributes((new SrgAttributesBuilder()).setAvailableWavelengths(new ArrayList<>()).build());
112 for (OpenroadmNodeType nodeType : Arrays.asList(OpenroadmNodeType.XPONDER, OpenroadmNodeType.DEGREE,
113 OpenroadmNodeType.SRG)) {
114 node1Builder.setNodeType(nodeType);
115 terminationPoint1Builder.setTpType(OpenroadmTpType.DEGREETXTTP);
116 parameters.add(new Object[] { pathDescription, terminationPoint1Builder.build(), node1Builder.build() });
119 for (OpenroadmTpType tpType : OpenroadmTpType.values()) {
120 node1Builder.setNodeType(OpenroadmNodeType.DEGREE);
121 node1Builder.setDegreeAttributes(null);
122 terminationPoint1Builder.setTpType(tpType);
123 parameters.add(new Object[] { pathDescription, terminationPoint1Builder.build(), node1Builder.build() });
126 node1Builder.setNodeType(OpenroadmNodeType.SRG);
127 node1Builder.setDegreeAttributes((new DegreeAttributesBuilder()).setAvailableWavelengths(new ArrayList<>())
129 node1Builder.setSrgAttributes(null);
130 terminationPoint1Builder.setTpType(OpenroadmTpType.DEGREETXTTP);
131 parameters.add(new Object[] { pathDescription, terminationPoint1Builder.build(), node1Builder.build() });
137 public void setMountPoint() {
138 MountPointServiceStub mountPointService = new MountPointServiceStub(new MountPointStub(this.getDataBroker()));
139 this.deviceTransactionManager = new DeviceTransactionManagerImpl(mountPointService, 3000);
140 networkModelWavelengthService = new NetworkModelWavelengthServiceImpl(this.getDataBroker());
144 public void freeWavelengthsTest() throws ExecutionException, InterruptedException {
145 WaveLengthServiceUtils.putTerminationPoint1ToDatastore("node1" + StringConstants.TTP_TOKEN,
146 StringConstants.TTP_TOKEN, this.terminationPoint1, this.deviceTransactionManager);
147 WaveLengthServiceUtils.putNode1ToDatastore("node1" + StringConstants.TTP_TOKEN, this.node1,
148 this.deviceTransactionManager);
149 this.networkModelWavelengthService.freeWavelengths(this.pathDescription);
150 Node1 updatedNode1 = WaveLengthServiceUtils.getNode1FromDatastore("node1" + StringConstants.TTP_TOKEN,
151 this.deviceTransactionManager);
152 TerminationPoint1 updatedTerminationPoint1 =
153 WaveLengthServiceUtils.getTerminationPoint1FromDatastore("node1" + StringConstants.TTP_TOKEN,
154 StringConstants.TTP_TOKEN, this.deviceTransactionManager);
155 switch (updatedTerminationPoint1.getTpType()) {
159 Assert.assertNull(updatedTerminationPoint1.getCtpAttributes());
160 Assert.assertFalse(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
161 Assert.assertFalse(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
162 Assert.assertFalse(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
163 Assert.assertFalse(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
164 Assert.assertNotNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
165 Assert.assertNotNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
166 Assert.assertNotNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
171 Assert.assertFalse(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
172 Assert.assertNull(updatedTerminationPoint1.getCpAttributes());
173 Assert.assertFalse(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
174 Assert.assertFalse(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
175 Assert.assertFalse(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
176 Assert.assertNotNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
177 Assert.assertNotNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
178 Assert.assertNotNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
182 Assert.assertFalse(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
183 Assert.assertFalse(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
184 Assert.assertNull(updatedTerminationPoint1.getTxTtpAttributes());
185 Assert.assertFalse(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
186 Assert.assertFalse(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
187 Assert.assertNotNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
188 Assert.assertNotNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
189 Assert.assertNotNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
192 Assert.assertFalse(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
193 Assert.assertFalse(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
194 Assert.assertFalse(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
195 Assert.assertNull(updatedTerminationPoint1.getRxTtpAttributes());
196 Assert.assertFalse(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
197 Assert.assertNotNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
198 Assert.assertNotNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
199 Assert.assertNotNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
204 Assert.assertFalse(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
205 Assert.assertFalse(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
206 Assert.assertFalse(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
207 Assert.assertFalse(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
208 Assert.assertNull(updatedTerminationPoint1.getPpAttributes());
209 Assert.assertNotNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
210 Assert.assertNotNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
211 Assert.assertNotNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
214 Assert.assertFalse(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
215 Assert.assertFalse(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
216 Assert.assertFalse(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
217 Assert.assertFalse(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
218 Assert.assertFalse(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
219 Assert.assertNull(updatedTerminationPoint1.getXpdrClientAttributes());
220 Assert.assertNotNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
221 Assert.assertNotNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
224 Assert.assertFalse(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
225 Assert.assertFalse(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
226 Assert.assertFalse(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
227 Assert.assertFalse(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
228 Assert.assertFalse(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
229 Assert.assertNotNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
230 Assert.assertNull(updatedTerminationPoint1.getXpdrNetworkAttributes());
231 Assert.assertNotNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
234 Assert.assertFalse(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
235 Assert.assertFalse(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
236 Assert.assertFalse(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
237 Assert.assertFalse(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
238 Assert.assertFalse(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
239 Assert.assertNotNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
240 Assert.assertNotNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
241 Assert.assertNull(updatedTerminationPoint1.getXpdrPortAttributes());
244 Assert.assertFalse(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
245 Assert.assertFalse(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
246 Assert.assertFalse(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
247 Assert.assertFalse(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
248 Assert.assertFalse(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
249 Assert.assertNotNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
250 Assert.assertNotNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
251 Assert.assertNotNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
254 switch (updatedNode1.getNodeType()) {
256 Assert.assertEquals(1, updatedNode1.getDegreeAttributes().getAvailableWavelengths().size());
257 Assert.assertEquals(WAVE_LENGTH,
258 updatedNode1.getDegreeAttributes().getAvailableWavelengths().get(0).getIndex());
259 Assert.assertTrue(updatedNode1.getSrgAttributes().getAvailableWavelengths().isEmpty());
262 Assert.assertEquals(1, updatedNode1.getSrgAttributes().getAvailableWavelengths().size());
263 Assert.assertEquals(WAVE_LENGTH,
264 updatedNode1.getSrgAttributes().getAvailableWavelengths().get(0).getIndex());
265 Assert.assertTrue(updatedNode1.getDegreeAttributes().getAvailableWavelengths().isEmpty());
268 Assert.assertTrue(updatedNode1.getDegreeAttributes().getAvailableWavelengths().isEmpty());
269 Assert.assertTrue(updatedNode1.getSrgAttributes().getAvailableWavelengths().isEmpty());