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.util.ArrayList;
11 import java.util.Arrays;
12 import java.util.Collection;
13 import java.util.Collections;
14 import java.util.List;
15 import java.util.concurrent.ExecutionException;
16 import org.junit.Assert;
17 import org.junit.Before;
18 import org.junit.Test;
19 import org.junit.runner.RunWith;
20 import org.junit.runners.Parameterized;
21 import org.opendaylight.controller.md.sal.binding.api.MountPointService;
22 import org.opendaylight.transportpce.common.device.DeviceTransactionManager;
23 import org.opendaylight.transportpce.common.device.DeviceTransactionManagerImpl;
24 import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfacesImpl;
25 import org.opendaylight.transportpce.renderer.stub.MountPointServiceStub;
26 import org.opendaylight.transportpce.renderer.stub.MountPointStub;
27 import org.opendaylight.transportpce.renderer.utils.ServiceDeleteDataUtils;
28 import org.opendaylight.transportpce.renderer.utils.WaveLengthServiceUtils;
29 import org.opendaylight.transportpce.test.AbstractTest;
30 import org.opendaylight.yang.gen.v1.http.org.openroadm.degree.rev170929.degree.used.wavelengths.UsedWavelengthsBuilder;
31 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev170929.Node1;
32 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev170929.Node1Builder;
33 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev170929.TerminationPoint1;
34 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev170929.TerminationPoint1Builder;
35 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev170929.network.node.DegreeAttributesBuilder;
36 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev170929.network.node.SrgAttributesBuilder;
37 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev170929.network.node.termination.point.CpAttributesBuilder;
38 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev170929.network.node.termination.point.CtpAttributesBuilder;
39 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev170929.network.node.termination.point.PpAttributesBuilder;
40 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev170929.network.node.termination.point.RxTtpAttributesBuilder;
41 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev170929.network.node.termination.point.TxTtpAttributesBuilder;
42 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev170929.network.node.termination.point.XpdrClientAttributesBuilder;
43 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev170929.network.node.termination.point.XpdrNetworkAttributesBuilder;
44 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev170929.network.node.termination.point.XpdrPortAttributesBuilder;
45 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev170929.network.node.termination.point.pp.attributes.UsedWavelengthBuilder;
46 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev170929.OpenroadmNodeType;
47 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev170929.OpenroadmTpType;
48 import org.opendaylight.yang.gen.v1.http.org.openroadm.xponder.rev170929.xpdr.port.connection.attributes.WavelengthBuilder;
49 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev170426.PathDescription;
51 @RunWith(Parameterized.class)
52 public class NetworkModelWaveLengthServiceFreeTest extends AbstractTest {
54 private static final Long WAVE_LENGTH = 20L;
55 private NetworkModelWavelengthService networkModelWavelengthService;
56 private DeviceTransactionManager deviceTransactionManager;
57 private TerminationPoint1 terminationPoint1;
58 private PathDescription pathDescription;
61 public NetworkModelWaveLengthServiceFreeTest(PathDescription pathDescription, TerminationPoint1 terminationPoint1,
63 this.pathDescription = pathDescription;
64 this.terminationPoint1 = terminationPoint1;
68 @Parameterized.Parameters
69 public static Collection primeNumbers() {
70 List<Object[]> parameters = new ArrayList<>();
72 PathDescription pathDescription =
73 ServiceDeleteDataUtils.createTransactionPathDescription(OpenRoadmInterfacesImpl.TTP_TOKEN);
75 TerminationPoint1Builder terminationPoint1Builder = new TerminationPoint1Builder();
76 terminationPoint1Builder.setCtpAttributes((new CtpAttributesBuilder()).setUsedWavelengths(Collections
77 .singletonList((new UsedWavelengthsBuilder()).setIndex(WAVE_LENGTH).build())).build());
78 terminationPoint1Builder.setCpAttributes((new CpAttributesBuilder()).setUsedWavelengths(Collections
79 .singletonList((new org.opendaylight.yang.gen.v1.http.org.openroadm.network.topology.rev170929.network
80 .node.termination.point.cp.attributes.UsedWavelengthsBuilder())
81 .setIndex(WAVE_LENGTH).build())).build());
82 terminationPoint1Builder.setTxTtpAttributes((new TxTtpAttributesBuilder()).setUsedWavelengths(Collections
83 .singletonList((new UsedWavelengthsBuilder()).setIndex(WAVE_LENGTH).build())).build());
84 terminationPoint1Builder.setRxTtpAttributes((new RxTtpAttributesBuilder()).setUsedWavelengths(Collections
85 .singletonList((new UsedWavelengthsBuilder()).setIndex(WAVE_LENGTH).build())).build());
86 terminationPoint1Builder.setPpAttributes((new PpAttributesBuilder()).setUsedWavelength(Collections
87 .singletonList((new UsedWavelengthBuilder()).setIndex(WAVE_LENGTH).build())).build());
88 terminationPoint1Builder.setXpdrClientAttributes((new XpdrClientAttributesBuilder())
89 .setWavelength((new WavelengthBuilder()).setIndex(WAVE_LENGTH).build()).build());
90 terminationPoint1Builder.setXpdrNetworkAttributes((new XpdrNetworkAttributesBuilder())
91 .setWavelength((new WavelengthBuilder()).setIndex(WAVE_LENGTH).build()).build());
92 terminationPoint1Builder.setXpdrPortAttributes((new XpdrPortAttributesBuilder())
93 .setWavelength((new WavelengthBuilder()).setIndex(WAVE_LENGTH).build()).build());
95 Node1Builder node1Builder = new Node1Builder();
96 node1Builder.setDegreeAttributes((new DegreeAttributesBuilder()).setAvailableWavelengths(new ArrayList<>())
98 node1Builder.setSrgAttributes((new SrgAttributesBuilder()).setAvailableWavelengths(new ArrayList<>()).build());
100 for (OpenroadmNodeType nodeType : Arrays.asList(OpenroadmNodeType.XPONDER, OpenroadmNodeType.DEGREE,
101 OpenroadmNodeType.SRG)) {
102 node1Builder.setNodeType(nodeType);
103 terminationPoint1Builder.setTpType(OpenroadmTpType.DEGREETXTTP);
104 parameters.add(new Object[] { pathDescription, terminationPoint1Builder.build(), node1Builder.build() });
107 for (OpenroadmTpType tpType : OpenroadmTpType.values()) {
108 node1Builder.setNodeType(OpenroadmNodeType.DEGREE);
109 node1Builder.setDegreeAttributes(null);
110 terminationPoint1Builder.setTpType(tpType);
111 parameters.add(new Object[] { pathDescription, terminationPoint1Builder.build(), node1Builder.build() });
114 node1Builder.setNodeType(OpenroadmNodeType.SRG);
115 node1Builder.setDegreeAttributes((new DegreeAttributesBuilder()).setAvailableWavelengths(new ArrayList<>())
117 node1Builder.setSrgAttributes(null);
118 terminationPoint1Builder.setTpType(OpenroadmTpType.DEGREETXTTP);
119 parameters.add(new Object[] { pathDescription, terminationPoint1Builder.build(), node1Builder.build() });
125 public void setMountPoint() {
126 MountPointService mountPointService = new MountPointServiceStub(new MountPointStub(this.getDataBroker()));
127 this.deviceTransactionManager = new DeviceTransactionManagerImpl(mountPointService, 3000);
128 networkModelWavelengthService = new NetworkModelWavelengthServiceImpl(this.getDataBroker());
132 public void freeWavelengthsTest() throws ExecutionException, InterruptedException {
133 WaveLengthServiceUtils.putTerminationPoint1ToDatastore("node1", "node1-" + OpenRoadmInterfacesImpl.TTP_TOKEN,
134 this.terminationPoint1, this.deviceTransactionManager);
135 WaveLengthServiceUtils.putNode1ToDatastore("node1", this.node1, this.deviceTransactionManager);
136 this.networkModelWavelengthService.freeWavelengths(this.pathDescription);
137 Node1 updatedNode1 = WaveLengthServiceUtils.getNode1FromDatastore("node1", this.deviceTransactionManager);
138 TerminationPoint1 updatedTerminationPoint1 = WaveLengthServiceUtils.getTerminationPoint1FromDatastore("node1",
139 "node1-" + OpenRoadmInterfacesImpl.TTP_TOKEN, this.deviceTransactionManager);
140 switch (updatedTerminationPoint1.getTpType()) {
144 Assert.assertTrue(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
145 Assert.assertFalse(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
146 Assert.assertFalse(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
147 Assert.assertFalse(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
148 Assert.assertFalse(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
149 Assert.assertNotNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
150 Assert.assertNotNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
151 Assert.assertNotNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
156 Assert.assertFalse(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
157 Assert.assertTrue(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
158 Assert.assertFalse(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
159 Assert.assertFalse(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
160 Assert.assertFalse(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
161 Assert.assertNotNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
162 Assert.assertNotNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
163 Assert.assertNotNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
167 Assert.assertFalse(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
168 Assert.assertFalse(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
169 Assert.assertTrue(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
170 Assert.assertFalse(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
171 Assert.assertFalse(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
172 Assert.assertNotNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
173 Assert.assertNotNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
174 Assert.assertNotNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
177 Assert.assertFalse(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
178 Assert.assertFalse(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
179 Assert.assertFalse(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
180 Assert.assertTrue(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
181 Assert.assertFalse(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
182 Assert.assertNotNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
183 Assert.assertNotNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
184 Assert.assertNotNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
189 Assert.assertFalse(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
190 Assert.assertFalse(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
191 Assert.assertFalse(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
192 Assert.assertFalse(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
193 Assert.assertTrue(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
194 Assert.assertNotNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
195 Assert.assertNotNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
196 Assert.assertNotNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
199 Assert.assertFalse(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
200 Assert.assertFalse(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
201 Assert.assertFalse(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
202 Assert.assertFalse(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
203 Assert.assertFalse(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
204 Assert.assertNull(updatedTerminationPoint1.getXpdrClientAttributes());
205 Assert.assertNotNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
206 Assert.assertNotNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
209 Assert.assertFalse(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
210 Assert.assertFalse(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
211 Assert.assertFalse(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
212 Assert.assertFalse(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
213 Assert.assertFalse(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
214 Assert.assertNotNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
215 Assert.assertNull(updatedTerminationPoint1.getXpdrNetworkAttributes());
216 Assert.assertNotNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
219 Assert.assertFalse(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
220 Assert.assertFalse(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
221 Assert.assertFalse(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
222 Assert.assertFalse(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
223 Assert.assertFalse(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
224 Assert.assertNotNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
225 Assert.assertNotNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
226 Assert.assertNull(updatedTerminationPoint1.getXpdrPortAttributes());
229 Assert.assertFalse(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
230 Assert.assertFalse(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
231 Assert.assertFalse(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
232 Assert.assertFalse(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
233 Assert.assertFalse(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
234 Assert.assertNotNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
235 Assert.assertNotNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
236 Assert.assertNotNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
239 switch (updatedNode1.getNodeType()) {
241 Assert.assertEquals(1, updatedNode1.getDegreeAttributes().getAvailableWavelengths().size());
242 Assert.assertEquals(WAVE_LENGTH,
243 updatedNode1.getDegreeAttributes().getAvailableWavelengths().get(0).getIndex());
244 Assert.assertTrue(updatedNode1.getSrgAttributes().getAvailableWavelengths().isEmpty());
247 Assert.assertEquals(1, updatedNode1.getSrgAttributes().getAvailableWavelengths().size());
248 Assert.assertEquals(WAVE_LENGTH,
249 updatedNode1.getSrgAttributes().getAvailableWavelengths().get(0).getIndex());
250 Assert.assertTrue(updatedNode1.getDegreeAttributes().getAvailableWavelengths().isEmpty());
253 Assert.assertTrue(updatedNode1.getDegreeAttributes().getAvailableWavelengths().isEmpty());
254 Assert.assertTrue(updatedNode1.getSrgAttributes().getAvailableWavelengths().isEmpty());