itm/itm-impl/src/test/java/org/opendaylight/genius/itm/impl/ItmExternalTunnelDeleteTest.java

   1 /*
   2  * Copyright (c) 2016 Ericsson India Global Services Pvt Ltd. and others.  All rights reserved.
   3  *
   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
   7  */
   8
   9 package org.opendaylight.genius.itm.impl;
  10
  11 import static org.mockito.Matchers.any;
  12 import static org.mockito.Mockito.doReturn;
  13 import static org.mockito.Mockito.times;
  14 import static org.mockito.Mockito.verify;
  15 import static org.mockito.Mockito.when;
  16
  17 import com.google.common.base.Optional;
  18 import com.google.common.util.concurrent.Futures;
  19 import java.math.BigInteger;
  20 import java.util.ArrayList;
  21 import java.util.List;
  22 import java.util.concurrent.Future;
  23 import org.junit.After;
  24 import org.junit.Before;
  25 import org.junit.Test;
  26 import org.junit.runner.RunWith;
  27 import org.mockito.Mock;
  28 import org.mockito.runners.MockitoJUnitRunner;
  29 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  30 import org.opendaylight.controller.md.sal.binding.api.DataChangeListener;
  31 import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
  32 import org.opendaylight.controller.md.sal.binding.api.WriteTransaction;
  33 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataBroker;
  34 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  35 import org.opendaylight.genius.itm.confighelpers.HwVtep;
  36 import org.opendaylight.genius.itm.confighelpers.ItmExternalTunnelDeleteWorker;
  37 import org.opendaylight.genius.itm.globals.ITMConstants;
  38 import org.opendaylight.genius.utils.cache.DataStoreCache;
  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.interfacemanager.rev160406.TunnelTypeBase;
  51 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.TunnelTypeVxlan;
  52 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.ExternalTunnelList;
  53 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.dpn.endpoints.DPNTEPsInfo;
  54 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.dpn.endpoints.DPNTEPsInfoBuilder;
  55 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.dpn.endpoints.DPNTEPsInfoKey;
  56 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.dpn.endpoints.dpn.teps.info
  57         .TunnelEndPoints;
  58 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.dpn.endpoints.dpn.teps.info
  59         .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
  62         .ExternalTunnelBuilder;
  63 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.external.tunnel.list.ExternalTunnelKey;
  64 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.TransportZones;
  65 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.TransportZone;
  66 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.TransportZoneBuilder;
  67 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.TransportZoneKey;
  68 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.transport.zone.Subnets;
  69 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.transport.zone
  70         .SubnetsBuilder;
  71 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.transport.zone.SubnetsKey;
  72 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.transport.zone.subnets.DeviceVteps;
  73 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.transport.zone.subnets.DeviceVtepsBuilder;
  74 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.transport.zone.subnets.DeviceVtepsKey;
  75 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.transport.zone.subnets.Vteps;
  76 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.transport.zone.subnets.VtepsBuilder;
  77 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.transport.zone.subnets.VtepsKey;
  78 import org.opendaylight.yangtools.concepts.ListenerRegistration;
  79 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  80 import org.opendaylight.yangtools.yang.common.RpcResult;
  81 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
  82
  83 @RunWith(MockitoJUnitRunner.class)
  84 public class ItmExternalTunnelDeleteTest {
  85
  86     int vlanId = 100 ;
  87     String portName1 = "phy0";
  88     String parentInterfaceName = "1:phy0:100" ;
  89     String transportZone1 = "TZA" ;
  90     String subnetIp = "10.1.1.24";
  91     String tepIp1 = "192.168.56.30";
  92     String tepIp2 = "192.168.56.40";
  93     String tepIp3 = "192.168.56.101";
  94     String gwyIp1 = "0.0.0.0";
  95     String gwyIp2 = "0.0.0.1";
  96     String trunkInterfaceName = null;
  97     IpAddress ipAddress1 = null;
  98     IpAddress ipAddress2 = null;
  99     IpAddress ipAddress3 = null;
 100     IpAddress gtwyIp1 = null;
 101     IpAddress gtwyIp2 = null;
 102     IpPrefix ipPrefixTest = null;
 103     BigInteger dpId2 = BigInteger.valueOf(1);
 104     DPNTEPsInfo dpntePsInfoVxlan = null;
 105     TunnelEndPoints tunnelEndPointsVxlan = null;
 106     HwVtep hwVtep1  = null;
 107     Subnets subnets = null;
 108     DeviceVteps deviceVteps1 = null;
 109     DeviceVteps deviceVteps2 = null;
 110     Vteps vteps = null;
 111     TransportZone transportZone = null;
 112     AllocateIdInput getIdInput1 = null;
 113     AllocateIdInput getIdInput2 = null;
 114     AllocateIdInput getIdInput3 = null;
 115     AllocateIdInput getIdInput4 = null;
 116     AllocateIdInput getIdInput5 = null;
 117     AllocateIdInput getIdInput6 = null;
 118     AllocateIdInput getIdInput7 = null;
 119     AllocateIdInput getIdInput8 = null;
 120     ExternalTunnel externalTunnel = null;
 121     List<TunnelEndPoints> tunnelEndPointsListVxlan = new ArrayList<>();
 122     List<DPNTEPsInfo> dpnTepsList = new ArrayList<>() ;
 123     List<HwVtep> cfgdHwVtepsList = new ArrayList<>();
 124     List<Subnets> subnetsList = new ArrayList<>();
 125     List<DeviceVteps> deviceVtepsList = new ArrayList<>();
 126     List<Vteps> vtepsList = new ArrayList<>();
 127     java.lang.Class<? extends TunnelTypeBase> tunnelType1 = TunnelTypeVxlan.class;
 128
 129     AllocateIdOutput expectedId1 = new AllocateIdOutputBuilder().setIdValue(Long.valueOf("100")).build();
 130     Future<RpcResult<AllocateIdOutput>> idOutputOptional1 ;
 131     AllocateIdOutput expectedId2 = new AllocateIdOutputBuilder().setIdValue(Long.valueOf("101")).build();
 132     Future<RpcResult<AllocateIdOutput>> idOutputOptional2 ;
 133     AllocateIdOutput expectedId3 = new AllocateIdOutputBuilder().setIdValue(Long.valueOf("102")).build();
 134     Future<RpcResult<AllocateIdOutput>> idOutputOptional3 ;
 135     AllocateIdOutput expectedId4 = new AllocateIdOutputBuilder().setIdValue(Long.valueOf("103")).build();
 136     Future<RpcResult<AllocateIdOutput>> idOutputOptional4 ;
 137     AllocateIdOutput expectedId5 = new AllocateIdOutputBuilder().setIdValue(Long.valueOf("104")).build();
 138     Future<RpcResult<AllocateIdOutput>> idOutputOptional5 ;
 139     AllocateIdOutput expectedId6 = new AllocateIdOutputBuilder().setIdValue(Long.valueOf("105")).build();
 140     Future<RpcResult<AllocateIdOutput>> idOutputOptional6 ;
 141     AllocateIdOutput expectedId7 = new AllocateIdOutputBuilder().setIdValue(Long.valueOf("105")).build();
 142     Future<RpcResult<AllocateIdOutput>> idOutputOptional7 ;
 143     AllocateIdOutput expectedId8 = new AllocateIdOutputBuilder().setIdValue(Long.valueOf("106")).build();
 144     Future<RpcResult<AllocateIdOutput>> idOutputOptional8 ;
 145     InstanceIdentifier<Interface> trunkIdentifier ;
 146     InstanceIdentifier<ExternalTunnel> path ;
 147
 148     @Mock DataBroker dataBroker;
 149     @Mock ListenerRegistration<DataChangeListener> dataChangeListenerRegistration;
 150     @Mock ReadOnlyTransaction mockReadTx;
 151     @Mock WriteTransaction mockWriteTx;
 152     @Mock IdManagerService idManagerService;
 153
 154     ItmExternalTunnelDeleteWorker itmExternalTunnelDeleteWorker = new ItmExternalTunnelDeleteWorker();
 155
 156     @Before
 157     public void setUp() throws Exception {
 158         when(dataBroker.registerDataChangeListener(
 159                 any(LogicalDatastoreType.class),
 160                 any(InstanceIdentifier.class),
 161                 any(DataChangeListener.class),
 162                 any(AsyncDataBroker.DataChangeScope.class)))
 163                 .thenReturn(dataChangeListenerRegistration);
 164         setupMocks();
 165         DataStoreCache.create(ITMConstants.ITM_MONIRORING_PARAMS_CACHE_NAME);
 166
 167         when(idManagerService.releaseId(any(ReleaseIdInput.class))).thenReturn(Futures.immediateFuture(RpcResultBuilder
 168                 .<Void>success().build()));
 169     }
 170
 171     @After
 172     public void cleanUp() {
 173     }
 174
 175     private void setupMocks(){
 176
 177         ipAddress1 = IpAddressBuilder.getDefaultInstance(tepIp1);
 178         ipAddress2 = IpAddressBuilder.getDefaultInstance(tepIp2);
 179         ipAddress3 = IpAddressBuilder.getDefaultInstance(tepIp3);
 180         ipPrefixTest = IpPrefixBuilder.getDefaultInstance(subnetIp + "/24");
 181         gtwyIp1 = IpAddressBuilder.getDefaultInstance(gwyIp1);
 182         gtwyIp2 = IpAddressBuilder.getDefaultInstance(gwyIp2);
 183         deviceVteps1 = new DeviceVtepsBuilder().setIpAddress(ipAddress1).setKey(new DeviceVtepsKey(ipAddress1, "hwvtep:1"))
 184                 .setNodeId("hwvtep://192.168.101.30:6640/physicalswitch/s3").setTopologyId("hwvtep:1").build();
 185         deviceVteps2 = new DeviceVtepsBuilder().setIpAddress(ipAddress2).setKey(new DeviceVtepsKey(ipAddress2, "hwvtep:1"))
 186                 .setNodeId("hwvtep://192.168.101.30:6640/physicalswitch/s3").setTopologyId("hwvtep:1").build();
 187         deviceVtepsList.add(deviceVteps1);
 188         deviceVtepsList.add(deviceVteps2);
 189         hwVtep1 = new HwVtep();
 190         hwVtep1.setTransportZone(transportZone1);
 191         hwVtep1.setGatewayIP(gtwyIp1);
 192         hwVtep1.setHwIp(ipAddress2);
 193         hwVtep1.setTunnel_type(tunnelType1);
 194         hwVtep1.setVlanID(vlanId);
 195         hwVtep1.setTopo_id("hwvtep:1");
 196         hwVtep1.setNode_id("hwvtep://192.168.101.30:6640/physicalswitch/s3");
 197         hwVtep1.setIpPrefix(ipPrefixTest);
 198         vteps = new VtepsBuilder().setDpnId(dpId2).setIpAddress(ipAddress1).setPortname(portName1).setKey(new
 199                 VtepsKey(dpId2,portName1)).build();
 200         vtepsList.add(vteps);
 201         idOutputOptional1 = RpcResultBuilder.success(expectedId1).buildFuture();
 202         getIdInput1 = new AllocateIdInputBuilder()
 203                 .setPoolName(ITMConstants.ITM_IDPOOL_NAME)
 204                 .setIdKey("1:phy0:100:192.168.56.101:192.168.56.30:VXLAN").build();
 205         doReturn(idOutputOptional1).when(idManagerService).allocateId(getIdInput1);
 206         idOutputOptional2 = RpcResultBuilder.success(expectedId2).buildFuture();
 207         getIdInput2 = new AllocateIdInputBuilder()
 208                 .setPoolName(ITMConstants.ITM_IDPOOL_NAME)
 209                 .setIdKey("hwvtep:1:hwvtep:1:192.168.56.30:192.168.56.101:VXLAN").build();
 210         doReturn(idOutputOptional2).when(idManagerService).allocateId(getIdInput2);
 211         idOutputOptional3 = RpcResultBuilder.success(expectedId3).buildFuture();
 212         getIdInput3 = new AllocateIdInputBuilder()
 213                 .setPoolName(ITMConstants.ITM_IDPOOL_NAME)
 214                 .setIdKey("1:phy0:100:192.168.56.101:192.168.56.40:VXLAN").build();
 215         doReturn(idOutputOptional3).when(idManagerService).allocateId(getIdInput3);
 216         idOutputOptional4 = RpcResultBuilder.success(expectedId4).buildFuture();
 217         getIdInput4 = new AllocateIdInputBuilder()
 218                 .setPoolName(ITMConstants.ITM_IDPOOL_NAME)
 219                 .setIdKey("hwvtep:1:hwvtep:1:192.168.56.40:192.168.56.101:VXLAN").build();
 220         doReturn(idOutputOptional4).when(idManagerService).allocateId(getIdInput4);
 221         idOutputOptional5 = RpcResultBuilder.success(expectedId5).buildFuture();
 222         getIdInput5 = new AllocateIdInputBuilder()
 223                 .setPoolName(ITMConstants.ITM_IDPOOL_NAME)
 224                 .setIdKey("hwvtep:1:hwvtep://192.168.101.30:6640/physicalswitch/s3:192.168.56.40:192.168.56.101:VXLAN").build();
 225         doReturn(idOutputOptional5).when(idManagerService).allocateId(getIdInput5);
 226         idOutputOptional6 = RpcResultBuilder.success(expectedId6).buildFuture();
 227         getIdInput6 = new AllocateIdInputBuilder()
 228                 .setPoolName(ITMConstants.ITM_IDPOOL_NAME)
 229                 .setIdKey("hwvtep:1:hwvtep://192.168.101.30:6640/physicalswitch/s3:192.168.56.40:192.168.56.30:VXLAN")
 230                 .build();
 231         doReturn(idOutputOptional6).when(idManagerService).allocateId(getIdInput6);
 232         idOutputOptional7 = RpcResultBuilder.success(expectedId7).buildFuture();
 233         getIdInput7 = new AllocateIdInputBuilder()
 234                 .setPoolName(ITMConstants.ITM_IDPOOL_NAME)
 235                 .setIdKey("hwvtep:1:hwvtep:1:192.168.56.30:192.168.56.40:VXLAN").build();
 236         doReturn(idOutputOptional7).when(idManagerService).allocateId(getIdInput7);
 237         idOutputOptional8 = RpcResultBuilder.success(expectedId8).buildFuture();
 238         getIdInput8 = new AllocateIdInputBuilder()
 239                 .setPoolName(ITMConstants.ITM_IDPOOL_NAME)
 240                 .setIdKey("1:phy0:100:192.168.56.30:192.168.56.40:VXLAN").build();
 241         doReturn(idOutputOptional8).when(idManagerService).allocateId(getIdInput8);
 242         tunnelEndPointsVxlan = new TunnelEndPointsBuilder().setVLANID(vlanId).setPortname(portName1).setIpAddress
 243                 (ipAddress3).setGwIpAddress(gtwyIp1).setInterfaceName(parentInterfaceName).setTzMembership
 244                 (ItmUtils.createTransportZoneMembership(transportZone1)).setTunnelType(tunnelType1).setSubnetMask
 245                 (ipPrefixTest).build();
 246         tunnelEndPointsListVxlan.add(tunnelEndPointsVxlan);
 247         dpntePsInfoVxlan = new DPNTEPsInfoBuilder().setDPNID(dpId2).setUp(true).setKey(new DPNTEPsInfoKey(dpId2))
 248                 .setTunnelEndPoints(tunnelEndPointsListVxlan).build();
 249         dpnTepsList.add(dpntePsInfoVxlan);
 250         cfgdHwVtepsList.add(hwVtep1);
 251         subnets = new SubnetsBuilder().setGatewayIp(gtwyIp1).setVlanId(vlanId).setKey(new SubnetsKey(ipPrefixTest))
 252                 .setDeviceVteps(deviceVtepsList).setVteps(vtepsList).build();
 253         subnetsList.add(subnets);
 254         transportZone = new TransportZoneBuilder().setTunnelType(tunnelType1).setZoneName(transportZone1).setKey(new
 255                 TransportZoneKey(transportZone1)).setSubnets(subnetsList).build();
 256         externalTunnel = new ExternalTunnelBuilder().setTunnelInterfaceName(parentInterfaceName).setTransportType
 257                 (tunnelType1).setDestinationDevice("hwvtep:1").setSourceDevice(dpId2.toString()).setKey(new
 258                 ExternalTunnelKey(dpId2.toString() , hwVtep1.getNode_id() , tunnelType1)).build();
 259         trunkInterfaceName = ItmUtils.getTrunkInterfaceName( idManagerService, parentInterfaceName,
 260                 tunnelEndPointsVxlan.getIpAddress().getIpv4Address().getValue(), ipAddress1.getIpv4Address().getValue(),
 261                 tunnelType1.getName());
 262         trunkIdentifier = ItmUtils.buildId(trunkInterfaceName);
 263         path = InstanceIdentifier.create(ExternalTunnelList.class)
 264                 .child(ExternalTunnel.class, ItmUtils.getExternalTunnelKey(ipAddress1.toString(), dpId2.toString(),
 265                         tunnelType1));
 266
 267         doReturn(mockReadTx).when(dataBroker).newReadOnlyTransaction();
 268         doReturn(mockWriteTx).when(dataBroker).newWriteOnlyTransaction();
 269         doReturn(Futures.immediateCheckedFuture(null)).when(mockWriteTx).submit();
 270     }
 271
 272     @Test
 273     public void testDeleteTunnels(){
 274
 275         itmExternalTunnelDeleteWorker.deleteTunnels(dataBroker,idManagerService,dpnTepsList,ipAddress1,tunnelType1);
 276
 277         verify(mockWriteTx).delete(LogicalDatastoreType.CONFIGURATION,trunkIdentifier);
 278         verify(mockWriteTx).delete(LogicalDatastoreType.CONFIGURATION,path);
 279
 280     }
 281
 282     @Test
 283     public void testDeleteHwVtepsTunnels(){
 284
 285         InstanceIdentifier<TransportZone> transportZoneIdentifier = InstanceIdentifier.builder(TransportZones.class).child
 286                 (TransportZone.class, new TransportZoneKey(transportZone1)).build();
 287         InstanceIdentifier<ExternalTunnel> externalTunnelIdentifier1 = InstanceIdentifier.create(ExternalTunnelList
 288                 .class).child(ExternalTunnel.class, ItmUtils.getExternalTunnelKey(hwVtep1.getTopo_id(), dpId2.toString(),
 289                         tunnelType1));
 290         InstanceIdentifier<ExternalTunnel> externalTunnelIdentifier2 = InstanceIdentifier.create(ExternalTunnelList
 291                 .class).child(ExternalTunnel.class, ItmUtils.getExternalTunnelKey(dpId2.toString(), hwVtep1.getTopo_id(),
 292                 tunnelType1));
 293         InstanceIdentifier<ExternalTunnel> externalTunnelIdentifier3 = InstanceIdentifier.create(ExternalTunnelList
 294                 .class).child(ExternalTunnel.class, ItmUtils.getExternalTunnelKey(hwVtep1.getNode_id(), dpId2.toString(),
 295                 tunnelType1));
 296         InstanceIdentifier<ExternalTunnel> externalTunnelIdentifier4 = InstanceIdentifier.create(ExternalTunnelList
 297                 .class).child(ExternalTunnel.class, ItmUtils.getExternalTunnelKey(dpId2.toString(), hwVtep1.getNode_id(),
 298                 tunnelType1));
 299         InstanceIdentifier<ExternalTunnel> externalTunnelIdentifier5 = InstanceIdentifier.create(ExternalTunnelList
 300                 .class).child(ExternalTunnel.class, ItmUtils.getExternalTunnelKey(hwVtep1.getTopo_id(), hwVtep1.getNode_id(),
 301                 tunnelType1));
 302         InstanceIdentifier<ExternalTunnel> externalTunnelIdentifier6 = InstanceIdentifier.create(ExternalTunnelList
 303                 .class).child(ExternalTunnel.class, ItmUtils.getExternalTunnelKey( hwVtep1.getNode_id(), hwVtep1.getTopo_id(),
 304                 tunnelType1));
 305
 306         Optional<TransportZone> optionalTransportZone = Optional.of(transportZone);
 307         Optional<ExternalTunnel> exTunnels = Optional.of(externalTunnel);
 308
 309         doReturn(Futures.immediateCheckedFuture(optionalTransportZone)).when(mockReadTx).read(LogicalDatastoreType
 310                 .CONFIGURATION,transportZoneIdentifier);
 311         doReturn(Futures.immediateCheckedFuture(exTunnels)).when(mockReadTx).read(LogicalDatastoreType.CONFIGURATION,
 312                 externalTunnelIdentifier1);
 313         doReturn(Futures.immediateCheckedFuture(exTunnels)).when(mockReadTx).read(LogicalDatastoreType.CONFIGURATION,
 314                 externalTunnelIdentifier2);
 315         doReturn(Futures.immediateCheckedFuture(exTunnels)).when(mockReadTx).read(LogicalDatastoreType.CONFIGURATION,
 316                 externalTunnelIdentifier3);
 317         doReturn(Futures.immediateCheckedFuture(exTunnels)).when(mockReadTx).read(LogicalDatastoreType.CONFIGURATION,
 318                 externalTunnelIdentifier4);
 319         doReturn(Futures.immediateCheckedFuture(exTunnels)).when(mockReadTx).read(LogicalDatastoreType.CONFIGURATION,
 320                 externalTunnelIdentifier5);
 321         doReturn(Futures.immediateCheckedFuture(exTunnels)).when(mockReadTx).read(LogicalDatastoreType.CONFIGURATION,
 322                 externalTunnelIdentifier6);
 323
 324         itmExternalTunnelDeleteWorker.deleteHwVtepsTunnels(dataBroker, idManagerService, dpnTepsList, cfgdHwVtepsList,
 325                 transportZone);
 326
 327         verify(mockWriteTx).delete(LogicalDatastoreType.CONFIGURATION,trunkIdentifier);
 328         verify(mockWriteTx, times(2)).delete(LogicalDatastoreType.CONFIGURATION,externalTunnelIdentifier1);
 329         verify(mockWriteTx, times(2)).delete(LogicalDatastoreType.CONFIGURATION,externalTunnelIdentifier2);
 330         verify(mockWriteTx, times(2)).delete(LogicalDatastoreType.CONFIGURATION,externalTunnelIdentifier3);
 331         verify(mockWriteTx, times(2)).delete(LogicalDatastoreType.CONFIGURATION,externalTunnelIdentifier4);
 332         verify(mockWriteTx).delete(LogicalDatastoreType.CONFIGURATION,externalTunnelIdentifier5);
 333         verify(mockWriteTx).delete(LogicalDatastoreType.CONFIGURATION,externalTunnelIdentifier6);
 334
 335     }
 336
 337 }