2 * Copyright (c) 2016, 2017 Ericsson India Global Services Pvt Ltd. 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
9 package org.opendaylight.genius.itm.impl;
11 import static org.mockito.ArgumentMatchers.any;
12 import static org.mockito.Mockito.doReturn;
13 import static org.mockito.Mockito.lenient;
14 import static org.mockito.Mockito.times;
15 import static org.mockito.Mockito.verify;
17 import com.google.common.util.concurrent.Futures;
18 import java.util.ArrayList;
19 import java.util.List;
20 import java.util.Optional;
21 import java.util.concurrent.ExecutionException;
22 import java.util.concurrent.Future;
23 import junit.framework.TestCase;
24 import org.junit.After;
25 import org.junit.Before;
26 import org.junit.Test;
27 import org.junit.runner.RunWith;
28 import org.mockito.Mock;
29 import org.mockito.junit.MockitoJUnitRunner;
30 import org.opendaylight.genius.itm.confighelpers.HwVtep;
31 import org.opendaylight.genius.itm.confighelpers.ItmExternalTunnelDeleteWorker;
32 import org.opendaylight.genius.itm.globals.ITMConstants;
33 import org.opendaylight.mdsal.binding.api.DataBroker;
34 import org.opendaylight.mdsal.binding.api.ReadTransaction;
35 import org.opendaylight.mdsal.binding.api.WriteTransaction;
36 import org.opendaylight.mdsal.binding.util.Datastore;
37 import org.opendaylight.mdsal.binding.util.TypedReadWriteTransaction;
38 import org.opendaylight.mdsal.binding.util.TypedWriteTransaction;
39 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
40 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddressBuilder;
41 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpPrefix;
42 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpPrefixBuilder;
43 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface;
44 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.AllocateIdInput;
45 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.AllocateIdInputBuilder;
46 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.AllocateIdOutput;
47 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.AllocateIdOutputBuilder;
48 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.IdManagerService;
49 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.ReleaseIdInput;
50 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.ReleaseIdOutput;
51 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.TunnelTypeBase;
52 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.TunnelTypeVxlan;
53 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.config.rev160406.ItmConfig;
54 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.ExternalTunnelList;
55 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.dpn.endpoints.DPNTEPsInfo;
56 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.dpn.endpoints.DPNTEPsInfoBuilder;
57 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.dpn.endpoints.DPNTEPsInfoKey;
58 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.dpn.endpoints.dpn.teps.info.TunnelEndPoints;
59 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.dpn.endpoints.dpn.teps.info.TunnelEndPointsBuilder;
60 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.external.tunnel.list.ExternalTunnel;
61 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.external.tunnel.list.ExternalTunnelBuilder;
62 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.external.tunnel.list.ExternalTunnelKey;
63 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.TransportZones;
64 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.TransportZone;
65 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.TransportZoneBuilder;
66 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.TransportZoneKey;
67 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.transport.zone.DeviceVteps;
68 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.transport.zone.DeviceVtepsBuilder;
69 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.transport.zone.DeviceVtepsKey;
70 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.transport.zone.Vteps;
71 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.transport.zone.VtepsBuilder;
72 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.transport.zone.VtepsKey;
73 import org.opendaylight.yangtools.util.concurrent.FluentFutures;
74 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
75 import org.opendaylight.yangtools.yang.common.RpcResult;
76 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
77 import org.opendaylight.yangtools.yang.common.Uint16;
78 import org.opendaylight.yangtools.yang.common.Uint64;
80 @RunWith(MockitoJUnitRunner.class)
81 public class ItmExternalTunnelDeleteTest {
84 String portName1 = "phy0";
85 String parentInterfaceName = "1:phy0:100" ;
86 String transportZone1 = "TZA" ;
87 String subnetIp = "10.1.1.24";
88 String tepIp1 = "192.168.56.30";
89 String tepIp2 = "192.168.56.40";
90 String tepIp3 = "192.168.56.101";
91 String gwyIp1 = "0.0.0.0";
92 String gwyIp2 = "0.0.0.1";
93 String trunkInterfaceName = null;
94 IpAddress ipAddress1 = null;
95 IpAddress ipAddress2 = null;
96 IpAddress ipAddress3 = null;
97 IpAddress gtwyIp1 = null;
98 IpAddress gtwyIp2 = null;
99 IpPrefix ipPrefixTest = null;
100 Uint64 dpId2 = Uint64.ONE;
101 DPNTEPsInfo dpntePsInfoVxlan = null;
102 TunnelEndPoints tunnelEndPointsVxlan = null;
103 HwVtep hwVtep1 = null;
104 DeviceVteps deviceVteps1 = null;
105 DeviceVteps deviceVteps2 = null;
107 TransportZone transportZone = null;
108 AllocateIdInput getIdInput1 = null;
109 AllocateIdInput getIdInput2 = null;
110 AllocateIdInput getIdInput3 = null;
111 AllocateIdInput getIdInput4 = null;
112 AllocateIdInput getIdInput5 = null;
113 AllocateIdInput getIdInput6 = null;
114 AllocateIdInput getIdInput7 = null;
115 AllocateIdInput getIdInput8 = null;
116 ExternalTunnel externalTunnel = null;
117 List<TunnelEndPoints> tunnelEndPointsListVxlan = new ArrayList<>();
118 List<DPNTEPsInfo> dpnTepsList = new ArrayList<>() ;
119 List<HwVtep> cfgdHwVtepsList = new ArrayList<>();
120 List<DeviceVteps> deviceVtepsList = new ArrayList<>();
121 List<Vteps> vtepsList = new ArrayList<>();
122 java.lang.Class<? extends TunnelTypeBase> tunnelType1 = TunnelTypeVxlan.class;
124 AllocateIdOutput expectedId1 = new AllocateIdOutputBuilder().setIdValue(Long.valueOf("100")).build();
125 Future<RpcResult<AllocateIdOutput>> idOutputOptional1 ;
126 AllocateIdOutput expectedId2 = new AllocateIdOutputBuilder().setIdValue(Long.valueOf("101")).build();
127 Future<RpcResult<AllocateIdOutput>> idOutputOptional2 ;
128 AllocateIdOutput expectedId3 = new AllocateIdOutputBuilder().setIdValue(Long.valueOf("102")).build();
129 Future<RpcResult<AllocateIdOutput>> idOutputOptional3 ;
130 AllocateIdOutput expectedId4 = new AllocateIdOutputBuilder().setIdValue(Long.valueOf("103")).build();
131 Future<RpcResult<AllocateIdOutput>> idOutputOptional4 ;
132 AllocateIdOutput expectedId5 = new AllocateIdOutputBuilder().setIdValue(Long.valueOf("104")).build();
133 Future<RpcResult<AllocateIdOutput>> idOutputOptional5 ;
134 AllocateIdOutput expectedId6 = new AllocateIdOutputBuilder().setIdValue(Long.valueOf("105")).build();
135 Future<RpcResult<AllocateIdOutput>> idOutputOptional6 ;
136 AllocateIdOutput expectedId7 = new AllocateIdOutputBuilder().setIdValue(Long.valueOf("105")).build();
137 Future<RpcResult<AllocateIdOutput>> idOutputOptional7 ;
138 AllocateIdOutput expectedId8 = new AllocateIdOutputBuilder().setIdValue(Long.valueOf("106")).build();
139 Future<RpcResult<AllocateIdOutput>> idOutputOptional8 ;
140 InstanceIdentifier<Interface> trunkIdentifier ;
141 InstanceIdentifier<ExternalTunnel> path ;
143 @Mock DataBroker dataBroker;
144 @Mock ReadTransaction mockReadTx;
145 @Mock WriteTransaction mockWriteTx;
146 @Mock IdManagerService idManagerService;
147 @Mock TypedWriteTransaction<Datastore.Configuration> typedWriteTransaction;
148 @Mock TypedReadWriteTransaction<Datastore.Configuration> typedReadWriteTransaction;
149 @Mock ItmConfig itmConfig;
152 public void setUp() {
155 lenient().when(idManagerService.releaseId(any(ReleaseIdInput.class))).thenReturn(Futures.immediateFuture(
156 RpcResultBuilder.<ReleaseIdOutput>success().build()));
160 public void cleanUp() {
163 private void setupMocks() {
165 ipAddress1 = IpAddressBuilder.getDefaultInstance(tepIp1);
166 ipAddress2 = IpAddressBuilder.getDefaultInstance(tepIp2);
167 ipAddress3 = IpAddressBuilder.getDefaultInstance(tepIp3);
168 ipPrefixTest = IpPrefixBuilder.getDefaultInstance(subnetIp + "/24");
169 gtwyIp1 = IpAddressBuilder.getDefaultInstance(gwyIp1);
170 gtwyIp2 = IpAddressBuilder.getDefaultInstance(gwyIp2);
171 deviceVteps1 = new DeviceVtepsBuilder().setIpAddress(ipAddress1)
172 .withKey(new DeviceVtepsKey(ipAddress1, "hwvtep:1"))
173 .setNodeId("hwvtep://192.168.101.30:6640/physicalswitch/s3")
174 .setTopologyId("hwvtep:1").build();
175 deviceVteps2 = new DeviceVtepsBuilder().setIpAddress(ipAddress2)
176 .withKey(new DeviceVtepsKey(ipAddress2, "hwvtep:1"))
177 .setNodeId("hwvtep://192.168.101.30:6640/physicalswitch/s3")
178 .setTopologyId("hwvtep:1").build();
179 deviceVtepsList.add(deviceVteps1);
180 deviceVtepsList.add(deviceVteps2);
181 hwVtep1 = new HwVtep();
182 hwVtep1.setTransportZone(transportZone1);
183 hwVtep1.setGatewayIP(gtwyIp1);
184 hwVtep1.setHwIp(ipAddress2);
185 hwVtep1.setTunnelType(tunnelType1);
186 hwVtep1.setVlanID(vlanId);
187 hwVtep1.setTopoId("hwvtep:1");
188 hwVtep1.setNodeId("hwvtep://192.168.101.30:6640/physicalswitch/s3");
189 hwVtep1.setIpPrefix(ipPrefixTest);
190 vteps = new VtepsBuilder().setDpnId(dpId2).setIpAddress(ipAddress1).withKey(new
191 VtepsKey(dpId2)).build();
192 vtepsList.add(vteps);
193 idOutputOptional1 = RpcResultBuilder.success(expectedId1).buildFuture();
194 getIdInput1 = new AllocateIdInputBuilder()
195 .setPoolName(ITMConstants.ITM_IDPOOL_NAME)
196 .setIdKey("1:phy0:100:192.168.56.101:192.168.56.30:VXLAN").build();
197 lenient().doReturn(idOutputOptional1).when(idManagerService).allocateId(getIdInput1);
198 idOutputOptional2 = RpcResultBuilder.success(expectedId2).buildFuture();
199 getIdInput2 = new AllocateIdInputBuilder()
200 .setPoolName(ITMConstants.ITM_IDPOOL_NAME)
201 .setIdKey("hwvtep:1:hwvtep:1:192.168.56.30:192.168.56.101:VXLAN").build();
202 lenient().doReturn(idOutputOptional2).when(idManagerService).allocateId(getIdInput2);
203 idOutputOptional3 = RpcResultBuilder.success(expectedId3).buildFuture();
204 getIdInput3 = new AllocateIdInputBuilder()
205 .setPoolName(ITMConstants.ITM_IDPOOL_NAME)
206 .setIdKey("1:phy0:100:192.168.56.101:192.168.56.40:VXLAN").build();
207 lenient().doReturn(idOutputOptional3).when(idManagerService).allocateId(getIdInput3);
208 idOutputOptional4 = RpcResultBuilder.success(expectedId4).buildFuture();
209 getIdInput4 = new AllocateIdInputBuilder()
210 .setPoolName(ITMConstants.ITM_IDPOOL_NAME)
211 .setIdKey("hwvtep:1:hwvtep:1:192.168.56.40:192.168.56.101:VXLAN").build();
212 lenient().doReturn(idOutputOptional4).when(idManagerService).allocateId(getIdInput4);
213 idOutputOptional5 = RpcResultBuilder.success(expectedId5).buildFuture();
214 getIdInput5 = new AllocateIdInputBuilder()
215 .setPoolName(ITMConstants.ITM_IDPOOL_NAME)
216 .setIdKey("hwvtep:1:hwvtep://192.168.101.30:6640/physicalswitch/"
217 + "s3:192.168.56.40:192.168.56.101:VXLAN").build();
218 lenient().doReturn(idOutputOptional5).when(idManagerService).allocateId(getIdInput5);
219 idOutputOptional6 = RpcResultBuilder.success(expectedId6).buildFuture();
220 getIdInput6 = new AllocateIdInputBuilder()
221 .setPoolName(ITMConstants.ITM_IDPOOL_NAME)
222 .setIdKey("hwvtep:1:hwvtep://192.168.101.30:6640/physicalswitch/"
223 + "s3:192.168.56.40:192.168.56.30:VXLAN")
225 lenient().doReturn(idOutputOptional6).when(idManagerService).allocateId(getIdInput6);
226 idOutputOptional7 = RpcResultBuilder.success(expectedId7).buildFuture();
227 getIdInput7 = new AllocateIdInputBuilder()
228 .setPoolName(ITMConstants.ITM_IDPOOL_NAME)
229 .setIdKey("hwvtep:1:hwvtep:1:192.168.56.30:192.168.56.40:VXLAN").build();
230 lenient().doReturn(idOutputOptional7).when(idManagerService).allocateId(getIdInput7);
231 idOutputOptional8 = RpcResultBuilder.success(expectedId8).buildFuture();
232 getIdInput8 = new AllocateIdInputBuilder()
233 .setPoolName(ITMConstants.ITM_IDPOOL_NAME)
234 .setIdKey("1:phy0:100:192.168.56.30:192.168.56.40:VXLAN").build();
235 lenient().doReturn(idOutputOptional8).when(idManagerService).allocateId(getIdInput8);
236 tunnelEndPointsVxlan = new TunnelEndPointsBuilder()
237 .setIpAddress(ipAddress3).setInterfaceName(parentInterfaceName)
238 .setTzMembership(ItmUtils.createTransportZoneMembership(transportZone1)).setTunnelType(tunnelType1)
240 tunnelEndPointsListVxlan.add(tunnelEndPointsVxlan);
241 dpntePsInfoVxlan = new DPNTEPsInfoBuilder().setDPNID(dpId2).setUp(true).withKey(new DPNTEPsInfoKey(dpId2))
242 .setTunnelEndPoints(tunnelEndPointsListVxlan).build();
243 dpnTepsList.add(dpntePsInfoVxlan);
244 cfgdHwVtepsList.add(hwVtep1);
246 transportZone = new TransportZoneBuilder().setTunnelType(tunnelType1).setZoneName(transportZone1).withKey(new
247 TransportZoneKey(transportZone1)).setDeviceVteps(deviceVtepsList).setVteps(vtepsList).build();
248 externalTunnel = new ExternalTunnelBuilder().setTunnelInterfaceName(parentInterfaceName)
249 .setTransportType(tunnelType1).setDestinationDevice("hwvtep:1").setSourceDevice(dpId2.toString())
250 .withKey(new ExternalTunnelKey(dpId2.toString() , hwVtep1.getNodeId() , tunnelType1)).build();
251 trunkInterfaceName = ItmUtils.getTrunkInterfaceName(parentInterfaceName,
252 tunnelEndPointsVxlan.getIpAddress().stringValue(), ipAddress1.stringValue(), tunnelType1.getName());
253 trunkIdentifier = ItmUtils.buildId(trunkInterfaceName);
254 path = InstanceIdentifier.create(ExternalTunnelList.class)
255 .child(ExternalTunnel.class, ItmUtils.getExternalTunnelKey(ipAddress1.stringValue(),
256 dpId2.toString(), tunnelType1));
258 lenient().doReturn(mockReadTx).when(dataBroker).newReadOnlyTransaction();
259 lenient().doReturn(mockWriteTx).when(dataBroker).newWriteOnlyTransaction();
260 lenient().doReturn(FluentFutures.immediateNullFluentFuture()).when(mockWriteTx).commit();
261 doReturn("phy0").when(itmConfig).getPortname();
262 doReturn(Uint16.valueOf(100)).when(itmConfig).getVlanId();
266 public void testDeleteTunnels() {
267 ItmExternalTunnelDeleteWorker.deleteTunnels(dpnTepsList, ipAddress1, tunnelType1, typedWriteTransaction);
268 verify(typedWriteTransaction).delete(trunkIdentifier);
269 verify(typedWriteTransaction).delete(path);
273 public void testDeleteHwVtepsTunnels() {
275 InstanceIdentifier<TransportZone> transportZoneIdentifier = InstanceIdentifier.builder(TransportZones.class)
276 .child(TransportZone.class, new TransportZoneKey(transportZone1)).build();
277 InstanceIdentifier<ExternalTunnel> externalTunnelIdentifier1 = InstanceIdentifier.create(ExternalTunnelList
278 .class).child(ExternalTunnel.class, ItmUtils.getExternalTunnelKey(hwVtep1.getTopoId(),
279 dpId2.toString(), tunnelType1));
280 InstanceIdentifier<ExternalTunnel> externalTunnelIdentifier2 = InstanceIdentifier.create(ExternalTunnelList
281 .class).child(ExternalTunnel.class, ItmUtils.getExternalTunnelKey(dpId2.toString(),
282 hwVtep1.getTopoId(), tunnelType1));
283 InstanceIdentifier<ExternalTunnel> externalTunnelIdentifier3 = InstanceIdentifier.create(ExternalTunnelList
284 .class).child(ExternalTunnel.class, ItmUtils.getExternalTunnelKey(hwVtep1.getNodeId(),
285 dpId2.toString(), tunnelType1));
286 InstanceIdentifier<ExternalTunnel> externalTunnelIdentifier4 = InstanceIdentifier.create(ExternalTunnelList
287 .class).child(ExternalTunnel.class, ItmUtils.getExternalTunnelKey(dpId2.toString(),
288 hwVtep1.getNodeId(), tunnelType1));
289 InstanceIdentifier<ExternalTunnel> externalTunnelIdentifier5 = InstanceIdentifier.create(ExternalTunnelList
290 .class).child(ExternalTunnel.class, ItmUtils.getExternalTunnelKey(hwVtep1.getTopoId(),
291 hwVtep1.getNodeId(), tunnelType1));
292 InstanceIdentifier<ExternalTunnel> externalTunnelIdentifier6 = InstanceIdentifier.create(ExternalTunnelList
293 .class).child(ExternalTunnel.class, ItmUtils.getExternalTunnelKey(hwVtep1.getNodeId(),
294 hwVtep1.getTopoId(), tunnelType1));
296 Optional<TransportZone> optionalTransportZone = Optional.of(transportZone);
297 Optional<ExternalTunnel> exTunnels = Optional.of(externalTunnel);
299 doReturn(FluentFutures.immediateFluentFuture(optionalTransportZone))
300 .when(typedReadWriteTransaction).read(transportZoneIdentifier);
301 doReturn(FluentFutures.immediateTrueFluentFuture())
302 .when(typedReadWriteTransaction).exists(externalTunnelIdentifier1);
303 doReturn(FluentFutures.immediateTrueFluentFuture())
304 .when(typedReadWriteTransaction).exists(externalTunnelIdentifier2);
305 doReturn(FluentFutures.immediateTrueFluentFuture()).when(typedReadWriteTransaction)
306 .exists(externalTunnelIdentifier3);
307 doReturn(FluentFutures.immediateTrueFluentFuture()).when(typedReadWriteTransaction)
308 .exists(externalTunnelIdentifier4);
309 doReturn(FluentFutures.immediateTrueFluentFuture()).when(typedReadWriteTransaction)
310 .exists(externalTunnelIdentifier5);
311 doReturn(FluentFutures.immediateTrueFluentFuture()).when(typedReadWriteTransaction)
312 .exists(externalTunnelIdentifier6);
315 ItmExternalTunnelDeleteWorker
316 .deleteHwVtepsTunnels(dpnTepsList, cfgdHwVtepsList, transportZone, typedReadWriteTransaction,
318 verify(typedReadWriteTransaction).delete(trunkIdentifier);
319 verify(typedReadWriteTransaction, times(2)).delete(externalTunnelIdentifier1);
320 verify(typedReadWriteTransaction, times(2)).delete(externalTunnelIdentifier2);
321 verify(typedReadWriteTransaction, times(2)).delete(externalTunnelIdentifier3);
322 verify(typedReadWriteTransaction, times(2)).delete(externalTunnelIdentifier4);
323 verify(typedReadWriteTransaction).delete(externalTunnelIdentifier5);
324 verify(typedReadWriteTransaction).delete(externalTunnelIdentifier6);
325 } catch (ExecutionException | InterruptedException e) {
326 TestCase.fail();// Fail in case of an exception