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.node.attributes.AvailableWavelengthsBuilder;
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.types.rev170929.OpenroadmNodeType;
46 import org.opendaylight.yang.gen.v1.http.org.openroadm.network.types.rev170929.OpenroadmTpType;
47 import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev170426.PathDescription;
49 @RunWith(Parameterized.class)
50 public class NetworkModelWaveLengthServiceUseTest extends AbstractTest {
52 private NetworkModelWavelengthService networkModelWavelengthService;
53 private DeviceTransactionManager deviceTransactionManager;
55 private TerminationPoint1 terminationPoint1;
56 private PathDescription pathDescription;
60 public void setMountPoint() {
61 MountPointService mountPointService = new MountPointServiceStub(new MountPointStub(this.getDataBroker()));
62 this.deviceTransactionManager = new DeviceTransactionManagerImpl(mountPointService, 3000);
63 networkModelWavelengthService = new NetworkModelWavelengthServiceImpl(this.getDataBroker());
66 public NetworkModelWaveLengthServiceUseTest(PathDescription pathDescription, TerminationPoint1 terminationPoint1,
68 this.pathDescription = pathDescription;
69 this.terminationPoint1 = terminationPoint1;
73 @Parameterized.Parameters
74 public static Collection createParameters() {
75 List<Object[]> parameters = new ArrayList<>();
77 PathDescription pathDescription =
78 ServiceDeleteDataUtils.createTransactionPathDescription(OpenRoadmInterfacesImpl.TTP_TOKEN);
80 TerminationPoint1Builder terminationPoint1Builder = new TerminationPoint1Builder();
81 terminationPoint1Builder
82 .setCtpAttributes((new CtpAttributesBuilder()).setUsedWavelengths(new ArrayList<>()).build());
83 terminationPoint1Builder
84 .setCpAttributes((new CpAttributesBuilder()).setUsedWavelengths(new ArrayList<>()).build());
85 terminationPoint1Builder
86 .setTxTtpAttributes((new TxTtpAttributesBuilder()).setUsedWavelengths(new ArrayList<>()).build());
87 terminationPoint1Builder
88 .setRxTtpAttributes((new RxTtpAttributesBuilder()).setUsedWavelengths(new ArrayList<>()).build());
89 terminationPoint1Builder.setPpAttributes((new PpAttributesBuilder()).setUsedWavelength(new ArrayList<>())
91 terminationPoint1Builder.setXpdrClientAttributes((new XpdrClientAttributesBuilder()).build());
92 terminationPoint1Builder.setXpdrNetworkAttributes((new XpdrNetworkAttributesBuilder()).build());
93 terminationPoint1Builder.setXpdrPortAttributes((new XpdrPortAttributesBuilder()).build());
95 Node1Builder node1Builder = new Node1Builder();
96 node1Builder.setDegreeAttributes((new DegreeAttributesBuilder())
97 .setAvailableWavelengths(Collections.singletonList(new AvailableWavelengthsBuilder().setIndex(20L).build()))
99 node1Builder.setSrgAttributes((new SrgAttributesBuilder()).setAvailableWavelengths(Collections.singletonList(
100 new org.opendaylight.yang.gen.v1.http.org.openroadm.srg.rev170929.srg.node.attributes
101 .AvailableWavelengthsBuilder().setIndex(20L).build())).build());
103 for (OpenroadmNodeType nodeType : Arrays
104 .asList(OpenroadmNodeType.XPONDER, OpenroadmNodeType.DEGREE, OpenroadmNodeType.SRG)) {
105 node1Builder.setNodeType(nodeType);
106 terminationPoint1Builder.setTpType(OpenroadmTpType.DEGREETXTTP);
107 parameters.add(new Object[] { pathDescription, terminationPoint1Builder.build(), node1Builder.build() });
110 for (OpenroadmTpType tpType : OpenroadmTpType.values()) {
111 node1Builder.setNodeType(OpenroadmNodeType.DEGREE);
112 terminationPoint1Builder.setTpType(tpType);
113 parameters.add(new Object[] { pathDescription, terminationPoint1Builder.build(), node1Builder.build() });
120 public void freeWavelengthsTest() throws ExecutionException, InterruptedException {
121 WaveLengthServiceUtils
122 .putTerminationPoint1ToDatastore("node1" + OpenRoadmInterfacesImpl.TTP_TOKEN,
123 OpenRoadmInterfacesImpl.TTP_TOKEN,
124 this.terminationPoint1, this.deviceTransactionManager);
125 WaveLengthServiceUtils.putNode1ToDatastore("node1" + OpenRoadmInterfacesImpl.TTP_TOKEN, this.node1,
126 this.deviceTransactionManager);
127 this.networkModelWavelengthService.useWavelengths(this.pathDescription);
128 Node1 updatedNode1 = WaveLengthServiceUtils.getNode1FromDatastore("node1" + OpenRoadmInterfacesImpl.TTP_TOKEN,
129 this.deviceTransactionManager);
130 TerminationPoint1 updatedTerminationPoint1 = WaveLengthServiceUtils
131 .getTerminationPoint1FromDatastore("node1" + OpenRoadmInterfacesImpl.TTP_TOKEN,
132 OpenRoadmInterfacesImpl.TTP_TOKEN,
133 this.deviceTransactionManager);
135 switch (updatedTerminationPoint1.getTpType()) {
139 Assert.assertFalse(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
140 Assert.assertTrue(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
141 Assert.assertTrue(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
142 Assert.assertTrue(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
143 Assert.assertTrue(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
144 Assert.assertNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
145 Assert.assertNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
146 Assert.assertNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
151 Assert.assertTrue(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
152 Assert.assertFalse(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
153 Assert.assertTrue(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
154 Assert.assertTrue(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
155 Assert.assertTrue(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
156 Assert.assertNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
157 Assert.assertNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
158 Assert.assertNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
162 Assert.assertTrue(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
163 Assert.assertTrue(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
164 Assert.assertFalse(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
165 Assert.assertTrue(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
166 Assert.assertTrue(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
167 Assert.assertNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
168 Assert.assertNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
169 Assert.assertNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
172 Assert.assertTrue(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
173 Assert.assertTrue(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
174 Assert.assertTrue(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
175 Assert.assertFalse(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
176 Assert.assertTrue(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
177 Assert.assertNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
178 Assert.assertNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
179 Assert.assertNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
184 Assert.assertTrue(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
185 Assert.assertTrue(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
186 Assert.assertTrue(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
187 Assert.assertTrue(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
188 Assert.assertFalse(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
189 Assert.assertNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
190 Assert.assertNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
191 Assert.assertNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
194 Assert.assertTrue(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
195 Assert.assertTrue(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
196 Assert.assertTrue(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
197 Assert.assertTrue(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
198 Assert.assertTrue(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
199 Assert.assertNotNull(updatedTerminationPoint1.getXpdrClientAttributes());
200 Assert.assertNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
201 Assert.assertNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
204 Assert.assertTrue(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
205 Assert.assertTrue(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
206 Assert.assertTrue(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
207 Assert.assertTrue(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
208 Assert.assertTrue(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
209 Assert.assertNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
210 Assert.assertNotNull(updatedTerminationPoint1.getXpdrNetworkAttributes());
211 Assert.assertNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
214 Assert.assertTrue(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
215 Assert.assertTrue(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
216 Assert.assertTrue(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
217 Assert.assertTrue(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
218 Assert.assertTrue(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
219 Assert.assertNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
220 Assert.assertNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
221 Assert.assertNotNull(updatedTerminationPoint1.getXpdrPortAttributes());
224 Assert.assertTrue(updatedTerminationPoint1.getCtpAttributes().getUsedWavelengths().isEmpty());
225 Assert.assertTrue(updatedTerminationPoint1.getCpAttributes().getUsedWavelengths().isEmpty());
226 Assert.assertTrue(updatedTerminationPoint1.getTxTtpAttributes().getUsedWavelengths().isEmpty());
227 Assert.assertTrue(updatedTerminationPoint1.getRxTtpAttributes().getUsedWavelengths().isEmpty());
228 Assert.assertTrue(updatedTerminationPoint1.getPpAttributes().getUsedWavelength().isEmpty());
229 Assert.assertNull(updatedTerminationPoint1.getXpdrClientAttributes().getWavelength());
230 Assert.assertNull(updatedTerminationPoint1.getXpdrNetworkAttributes().getWavelength());
231 Assert.assertNull(updatedTerminationPoint1.getXpdrPortAttributes().getWavelength());
234 switch (updatedNode1.getNodeType()) {
236 Assert.assertTrue(updatedNode1.getDegreeAttributes().getAvailableWavelengths().isEmpty());
237 Assert.assertFalse(updatedNode1.getSrgAttributes().getAvailableWavelengths().isEmpty());
240 Assert.assertTrue(updatedNode1.getSrgAttributes().getAvailableWavelengths().isEmpty());
241 Assert.assertFalse(updatedNode1.getDegreeAttributes().getAvailableWavelengths().isEmpty());
244 Assert.assertFalse(updatedNode1.getDegreeAttributes().getAvailableWavelengths().isEmpty());
245 Assert.assertFalse(updatedNode1.getSrgAttributes().getAvailableWavelengths().isEmpty());