vpnmanager/impl/src/test/java/org/opendaylight/netvirt/vpnmanager/test/VpnSubnetRouteHandlerTest.java

   1 /*
   2  * Copyright © 2016, 2017 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.netvirt.vpnmanager.test;
  10
  11 import static org.mockito.ArgumentMatchers.anyString;
  12 import static org.mockito.Mockito.doReturn;
  13 import static org.mockito.Mockito.verify;
  14 import static org.mockito.Mockito.when;
  15
  16 import com.google.common.util.concurrent.Futures;
  17 import java.util.ArrayList;
  18 import java.util.Arrays;
  19 import java.util.List;
  20 import java.util.Optional;
  21 import java.util.concurrent.Future;
  22 import javax.inject.Inject;
  23 import org.junit.Before;
  24 import org.junit.Ignore;
  25 import org.junit.Test;
  26 import org.junit.runner.RunWith;
  27 import org.mockito.Mock;
  28 import org.mockito.junit.MockitoJUnitRunner;
  29 import org.opendaylight.genius.interfacemanager.globals.IfmConstants;
  30 import org.opendaylight.mdsal.binding.api.DataBroker;
  31 import org.opendaylight.mdsal.binding.api.ReadTransaction;
  32 import org.opendaylight.mdsal.binding.api.WriteTransaction;
  33 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
  34 import org.opendaylight.netvirt.bgpmanager.api.IBgpManager;
  35 import org.opendaylight.netvirt.fibmanager.api.IFibManager;
  36 import org.opendaylight.netvirt.vpnmanager.SubnetOpDpnManager;
  37 import org.opendaylight.netvirt.vpnmanager.VpnInterfaceManager;
  38 import org.opendaylight.netvirt.vpnmanager.VpnNodeListener;
  39 import org.opendaylight.netvirt.vpnmanager.VpnOpDataSyncer;
  40 import org.opendaylight.netvirt.vpnmanager.VpnSubnetRouteHandler;
  41 import org.opendaylight.netvirt.vpnmanager.VpnUtil;
  42 import org.opendaylight.netvirt.vpnmanager.api.InterfaceUtils;
  43 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.iana._if.type.rev170119.L2vlan;
  44 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
  45 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddressBuilder;
  46 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface;
  47 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.InterfaceKey;
  48 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Uuid;
  49 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.AllocateIdInput;
  50 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.AllocateIdInputBuilder;
  51 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.AllocateIdOutput;
  52 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.AllocateIdOutputBuilder;
  53 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.IdManagerService;
  54 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.DpnEndpoints;
  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.lockmanager.rev160413.LockManagerService;
  61 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorId;
  62 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.PortOpData;
  63 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.PortOpDataBuilder;
  64 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.SubnetOpData;
  65 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.TaskState;
  66 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.VpnInstanceToVpnId;
  67 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.port.op.data.PortOpDataEntry;
  68 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.port.op.data.PortOpDataEntryBuilder;
  69 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.port.op.data.PortOpDataEntryKey;
  70 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.subnet.op.data.SubnetOpDataEntry;
  71 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.subnet.op.data.SubnetOpDataEntryBuilder;
  72 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.subnet.op.data.SubnetOpDataEntryKey;
  73 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.subnet.op.data.subnet.op.data.entry.SubnetToDpn;
  74 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.subnet.op.data.subnet.op.data.entry.SubnetToDpnBuilder;
  75 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.subnet.op.data.subnet.op.data.entry.SubnetToDpnKey;
  76 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.subnet.op.data.subnet.op.data.entry.subnet.to.dpn.VpnInterfaces;
  77 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.subnet.op.data.subnet.op.data.entry.subnet.to.dpn.VpnInterfacesBuilder;
  78 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.subnet.op.data.subnet.op.data.entry.subnet.to.dpn.VpnInterfacesKey;
  79 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.vpn.instance.to.vpn.id.VpnInstance;
  80 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.vpn.instance.to.vpn.id.VpnInstanceBuilder;
  81 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.vpn.instance.to.vpn.id.VpnInstanceKey;
  82 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.natservice.rev160111.ExternalNetworks;
  83 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.natservice.rev160111.external.networks.Networks;
  84 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.natservice.rev160111.external.networks.NetworksBuilder;
  85 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.natservice.rev160111.external.networks.NetworksKey;
  86 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.l3vpn.rev200204.VpnInstances;
  87 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.Subnetmaps;
  88 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.subnetmaps.Subnetmap;
  89 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.subnetmaps.SubnetmapBuilder;
  90 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.subnetmaps.SubnetmapKey;
  91 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  92 import org.opendaylight.yangtools.yang.common.RpcResult;
  93 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
  94 import org.opendaylight.yangtools.yang.common.Uint64;
  95
  96 @RunWith(MockitoJUnitRunner.class)
  97 public class VpnSubnetRouteHandlerTest {
  98
  99     Uint64 dpId = Uint64.valueOf(1);
 100     SubnetToDpn subnetToDpn = null;
 101     String subnetIp = "10.1.1.24";
 102     List<String> routeDistinguishers = Arrays.asList("100:1","100:2");
 103     String primaryRd = "100:1";
 104     String nexthopIp = null;
 105     String poolName = null;
 106     String interfaceName = "VPN";
 107     Uuid subnetId = Uuid.getDefaultInstance("067e6162-3b6f-4ae2-a171-2470b63dff00");
 108     Uuid portId = Uuid.getDefaultInstance("54947df8-0e9e-4471-a2f9-9af509fb5889");
 109     Uuid tenantId = Uuid.getDefaultInstance("54947df8-0e9e-4571-a2f9-9af509fb5889");
 110     String portKey = portId.getValue();
 111     Long elanTag = null;
 112     Long longId = null;
 113     PortOpDataEntry portOp = null;
 114     PortOpData portOpData = null;
 115     SubnetOpDataEntry subnetOp = null;
 116     org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface
 117         stateInterface;
 118     List<String> lowerLayerIfList = new ArrayList<>();
 119     NodeConnectorId nodeConnectorId = null;
 120     VpnInterfaces vpnIntfaces = null;
 121     VpnInstance vpnInstance = null;
 122     Subnetmap subnetmap = null;
 123     DPNTEPsInfo dpntePsInfo = null;
 124     TunnelEndPoints tunlEndPts = null;
 125     IpAddress ipAddress = null;
 126     String idKey = null;
 127     AllocateIdOutput allocateIdOutput = null;
 128     AllocateIdInput allocateIdInput = null;
 129     Networks networks = null;
 130     org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.l3vpn.rev200204
 131             .vpn.instances.VpnInstance vpnInstnce;
 132
 133     InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces
 134         .state.Interface> ifStateId = InterfaceUtils.buildStateInterfaceId(portKey);
 135     InstanceIdentifier<SubnetOpDataEntry> subOpIdentifier =
 136         InstanceIdentifier.builder(SubnetOpData.class).child(SubnetOpDataEntry.class,
 137             new SubnetOpDataEntryKey(subnetId)).build();
 138     InstanceIdentifier<SubnetToDpn> dpnOpId = subOpIdentifier.child(SubnetToDpn.class, new SubnetToDpnKey(dpId));
 139     InstanceIdentifier<DPNTEPsInfo> tunnelInfoId =
 140         InstanceIdentifier.builder(DpnEndpoints.class).child(DPNTEPsInfo.class, new DPNTEPsInfoKey(dpId)).build();
 141     InstanceIdentifier<PortOpDataEntry> portOpIdentifier =
 142         InstanceIdentifier.builder(PortOpData.class).child(PortOpDataEntry.class,
 143             new PortOpDataEntryKey(portKey)).build();
 144     InstanceIdentifier<PortOpDataEntry> instPortOp =
 145         InstanceIdentifier.builder(PortOpData.class).child(PortOpDataEntry.class,
 146             new PortOpDataEntryKey(interfaceName)).build();
 147     InstanceIdentifier<Subnetmap> subMapid = InstanceIdentifier.builder(Subnetmaps.class).child(Subnetmap.class, new
 148         SubnetmapKey(subnetId)).build();
 149     InstanceIdentifier<PortOpData> portOpIdentifr = InstanceIdentifier.builder(PortOpData.class).build();
 150     InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.vpn.instance.to.vpn.id
 151         .VpnInstance> instVpnInstance = getVpnInstanceToVpnIdIdentifier(interfaceName);
 152     InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.l3vpn.rev200204.vpn.instances
 153         .VpnInstance>
 154         vpnInstanceIdentifier = InstanceIdentifier.builder(VpnInstances.class).child(org.opendaylight.yang.gen.v1.urn
 155                     .opendaylight.netvirt.neutronvpn.l3vpn.rev200204.vpn.instances.VpnInstance.class,
 156         new org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.l3vpn.rev200204.vpn.instances
 157             .VpnInstanceKey(interfaceName)).build();
 158     InstanceIdentifier<Networks> netsIdentifier =
 159         InstanceIdentifier.builder(ExternalNetworks.class).child(Networks.class, new NetworksKey(portId)).build();
 160
 161     @Mock
 162     DataBroker dataBroker;
 163     @Mock
 164     ReadTransaction mockReadTx;
 165     @Mock
 166     WriteTransaction mockWriteTx;
 167     @Mock
 168     IBgpManager bgpManager;
 169     @Mock
 170     VpnInterfaceManager vpnInterfaceManager;
 171     @Mock
 172     IdManagerService idManager;
 173     @Mock
 174     LockManagerService lockManager;
 175     @Mock
 176     SubnetOpDpnManager subnetOpDpnManager;
 177     @Mock
 178     LockManagerService lockManagerService;
 179     @Mock
 180     VpnOpDataSyncer vpnOpDataSyncer;
 181     @Mock
 182     VpnNodeListener vpnNodeListener;
 183     @Mock
 184     IFibManager fibManager;
 185
 186     private @Inject VpnUtil vpnUtil;
 187
 188     VpnSubnetRouteHandler vpnSubnetRouteHandler;
 189
 190     Optional<Interface> optionalIfState;
 191     Optional<SubnetOpDataEntry> optionalSubs;
 192     Optional<SubnetToDpn> optionalSubDpn;
 193     Optional<DPNTEPsInfo> optionalTunnelInfo;
 194     Optional<PortOpDataEntry> optionalPortOp;
 195     Optional<PortOpData> optionalPtOp;
 196     Optional<Subnetmap> optionalSubnetMap;
 197     Optional<org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.vpn.instance.to.vpn.id.VpnInstance>
 198         optionalVpnInstnce;
 199     Optional<org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.l3vpn.rev200204.vpn.instances.VpnInstance>
 200         vpnInstanceOptional;
 201     Optional<Networks> optionalNetworks;
 202
 203
 204
 205     @Before
 206     public void setUp() throws Exception {
 207         setupMocks();
 208
 209         vpnSubnetRouteHandler = new VpnSubnetRouteHandler(dataBroker, subnetOpDpnManager, bgpManager, vpnOpDataSyncer,
 210                 vpnNodeListener, fibManager, vpnUtil);
 211         final Future<RpcResult<AllocateIdOutput>> idOutputOptional =
 212             RpcResultBuilder.success(allocateIdOutput).buildFuture();
 213
 214         optionalIfState = Optional.of(stateInterface);
 215         optionalSubs = Optional.of(subnetOp);
 216         optionalSubDpn = Optional.of(subnetToDpn);
 217         optionalTunnelInfo = Optional.of(dpntePsInfo);
 218         optionalPortOp = Optional.of(portOp);
 219         optionalPtOp = Optional.of(portOpData);
 220         optionalSubnetMap = Optional.of(subnetmap);
 221         optionalVpnInstnce = Optional.of(vpnInstance);
 222         vpnInstanceOptional = Optional.of(vpnInstnce);
 223         optionalNetworks = Optional.of(networks);
 224
 225         doReturn(Futures.immediateCheckedFuture(optionalIfState)).when(mockReadTx).read(LogicalDatastoreType
 226             .OPERATIONAL, ifStateId);
 227         doReturn(Futures.immediateCheckedFuture(optionalSubs)).when(mockReadTx).read(LogicalDatastoreType
 228             .OPERATIONAL, subOpIdentifier);
 229         doReturn(Futures.immediateCheckedFuture(optionalSubDpn)).when(mockReadTx).read(LogicalDatastoreType
 230             .OPERATIONAL, dpnOpId);
 231         doReturn(Futures.immediateCheckedFuture(optionalTunnelInfo)).when(mockReadTx).read(LogicalDatastoreType
 232             .CONFIGURATION, tunnelInfoId);
 233         doReturn(Futures.immediateCheckedFuture(optionalPortOp)).when(mockReadTx).read(LogicalDatastoreType
 234             .OPERATIONAL, portOpIdentifier);
 235         doReturn(Futures.immediateCheckedFuture(optionalPtOp)).when(mockReadTx).read(LogicalDatastoreType
 236             .OPERATIONAL, portOpIdentifr);
 237         doReturn(Futures.immediateCheckedFuture(optionalPortOp)).when(mockReadTx).read(LogicalDatastoreType
 238             .OPERATIONAL, instPortOp);
 239         doReturn(Futures.immediateCheckedFuture(optionalSubnetMap)).when(mockReadTx).read(LogicalDatastoreType
 240             .CONFIGURATION, subMapid);
 241         doReturn(Futures.immediateCheckedFuture(optionalVpnInstnce)).when(mockReadTx).read(LogicalDatastoreType
 242             .CONFIGURATION, instVpnInstance);
 243         doReturn(Futures.immediateCheckedFuture(vpnInstanceOptional)).when(mockReadTx).read(LogicalDatastoreType
 244             .CONFIGURATION, vpnInstanceIdentifier);
 245         doReturn(Futures.immediateCheckedFuture(Optional.empty())).when(mockReadTx).read(LogicalDatastoreType
 246             .CONFIGURATION, netsIdentifier);
 247         doReturn(idOutputOptional).when(idManager).allocateId(allocateIdInput);
 248
 249         when(subnetOpDpnManager.getPortOpDataEntry(anyString())).thenReturn(portOp);
 250     }
 251
 252     private void setupMocks() {
 253
 254         nexthopIp = "10.1.1.25";
 255         idKey = "100:1.10.1.1.24";
 256         poolName = "vpnservices";
 257         elanTag = 2L;
 258         longId = Long.valueOf("100");
 259         nodeConnectorId = buildNodeConnectorId(dpId, 2L);
 260         ipAddress = IpAddressBuilder.getDefaultInstance(nexthopIp);
 261         vpnIntfaces = new VpnInterfacesBuilder().setInterfaceName(interfaceName).withKey(
 262             new VpnInterfacesKey(interfaceName)).build();
 263         List<VpnInterfaces> vpnInterfaces = new ArrayList<>();
 264         final List<SubnetToDpn> subToDpn = new ArrayList<>();
 265         final List<Uuid> portList = new ArrayList<>();
 266         final List<PortOpDataEntry> listPortOpDataEntry = new ArrayList<>();
 267         final List<TunnelEndPoints> tunnelEndPoints = new ArrayList<>();
 268         List<Uuid> subnetIdList = new ArrayList<>();
 269         subnetIdList.add(subnetId);
 270         vpnInterfaces.add(vpnIntfaces);
 271         lowerLayerIfList.add(nodeConnectorId.getValue());
 272         portOp = new PortOpDataEntryBuilder().setDpnId(dpId).withKey(new PortOpDataEntryKey(tenantId.getValue()))
 273             .setSubnetIds(subnetIdList).setPortId(tenantId.getValue()).build();
 274         subnetToDpn = new SubnetToDpnBuilder().setDpnId(dpId).withKey(new SubnetToDpnKey(dpId)).setVpnInterfaces(
 275             vpnInterfaces).build();
 276         allocateIdOutput = new AllocateIdOutputBuilder().setIdValue(longId).build();
 277         allocateIdInput = new AllocateIdInputBuilder().setPoolName(poolName).setIdKey(idKey).build();
 278         subToDpn.add(subnetToDpn);
 279         portList.add(portId);
 280         listPortOpDataEntry.add(portOp);
 281         org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state
 282             .InterfaceBuilder ifaceBuilder = new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf
 283             .interfaces.rev140508.interfaces.state.InterfaceBuilder();
 284         ifaceBuilder.setLowerLayerIf(lowerLayerIfList).setType(L2vlan.class)
 285             .setAdminStatus(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508
 286                 .interfaces.state.Interface.AdminStatus.Up).setOperStatus(Interface.OperStatus.Up)
 287             .setIfIndex(100).withKey(new InterfaceKey(interfaceName)).setName(interfaceName)
 288             .setPhysAddress(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715
 289                 .PhysAddress.getDefaultInstance("AA:AA:AA:AA:AA:AA"));
 290         stateInterface = ifaceBuilder.build();
 291         subnetOp = new SubnetOpDataEntryBuilder().setElanTag(elanTag).setNhDpnId(dpId).setSubnetCidr(subnetIp)
 292             .setSubnetId(subnetId).withKey(new SubnetOpDataEntryKey(subnetId)).setVpnName(interfaceName)
 293             .setVrfId(primaryRd).setSubnetToDpn(subToDpn).setRouteAdvState(TaskState.Advertised).build();
 294         vpnInstance = new VpnInstanceBuilder().setVpnId(elanTag).setVpnInstanceName(interfaceName)
 295             .setVrfId(interfaceName).withKey(new VpnInstanceKey(interfaceName)).build();
 296         subnetmap = new SubnetmapBuilder().setSubnetIp(subnetIp).setId(subnetId).setNetworkId(portId).withKey(new
 297             SubnetmapKey(subnetId)).setRouterId(portId).setVpnId(subnetId)
 298             .setTenantId(tenantId).setPortList(portList).build();
 299         portOpData = new PortOpDataBuilder().setPortOpDataEntry(listPortOpDataEntry).build();
 300         dpntePsInfo = new DPNTEPsInfoBuilder().setDPNID(dpId).setUp(true).withKey(new DPNTEPsInfoKey(dpId))
 301             .setTunnelEndPoints(tunnelEndPoints).build();
 302         tunlEndPts =
 303             new TunnelEndPointsBuilder().setInterfaceName(interfaceName).setIpAddress(ipAddress).build();
 304         tunnelEndPoints.add(tunlEndPts);
 305         vpnInstnce = new org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.l3vpn.rev200204.vpn.instances
 306             .VpnInstanceBuilder().withKey(new org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.l3vpn
 307                 .rev200204.vpn.instances.VpnInstanceKey(interfaceName)).setVpnInstanceName(interfaceName)
 308             .setRouteDistinguisher(routeDistinguishers).build();
 309         networks = new NetworksBuilder().setId(portId).withKey(new NetworksKey(portId)).build();
 310         doReturn(mockReadTx).when(dataBroker).newReadOnlyTransaction();
 311         doReturn(mockWriteTx).when(dataBroker).newWriteOnlyTransaction();
 312         doReturn(Futures.immediateCheckedFuture(null)).when(mockWriteTx).commit();
 313     }
 314
 315     @Ignore
 316     @Test
 317     public void testOnPortAddedToSubnet() {
 318
 319         vpnSubnetRouteHandler.onPortAddedToSubnet(subnetmap, portId);
 320
 321         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, portOpIdentifier, portOp,
 322                 WriteTransaction.CREATE_MISSING_PARENTS);
 323         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, dpnOpId, subnetToDpn,
 324                 WriteTransaction.CREATE_MISSING_PARENTS);
 325         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, subOpIdentifier, subnetOp,
 326                 WriteTransaction.CREATE_MISSING_PARENTS);
 327     }
 328
 329     @Ignore
 330     @Test
 331     public void testOnPortRemovedFromSubnet() {
 332
 333         vpnSubnetRouteHandler.onPortRemovedFromSubnet(subnetmap, portId);
 334
 335         verify(mockWriteTx).delete(LogicalDatastoreType.OPERATIONAL, portOpIdentifier);
 336         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, dpnOpId, subnetToDpn,
 337                 WriteTransaction.CREATE_MISSING_PARENTS);
 338         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, subOpIdentifier, subnetOp,
 339                 WriteTransaction.CREATE_MISSING_PARENTS);
 340
 341     }
 342
 343     @Ignore
 344     @Test
 345     public void testOnInterfaceUp() {
 346
 347         vpnSubnetRouteHandler.onInterfaceUp(dpId, interfaceName, subnetId);
 348
 349         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, instPortOp, portOp,
 350                 WriteTransaction.CREATE_MISSING_PARENTS);
 351         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, dpnOpId, subnetToDpn,
 352                 WriteTransaction.CREATE_MISSING_PARENTS);
 353         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, subOpIdentifier, subnetOp,
 354                 WriteTransaction.CREATE_MISSING_PARENTS);
 355     }
 356
 357     @Ignore
 358     @Test
 359     public void testOnInterfaceDown() {
 360
 361         vpnSubnetRouteHandler.onInterfaceDown(dpId, interfaceName, subnetId);
 362
 363         // TODO: subnetOpDpnManager is mocked so not sure how this delete ever worked.
 364         //verify(mockWriteTx).delete(LogicalDatastoreType.OPERATIONAL, dpnOpId);
 365         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, subOpIdentifier, subnetOp,
 366                 WriteTransaction.CREATE_MISSING_PARENTS);
 367
 368     }
 369
 370     @Ignore
 371     @Test
 372     public void testOnSubnetAddedToVpn() {
 373
 374         doReturn(Futures.immediateCheckedFuture(Optional.empty())).when(mockReadTx).read(LogicalDatastoreType
 375             .OPERATIONAL, subOpIdentifier);
 376
 377         vpnSubnetRouteHandler.onSubnetAddedToVpn(subnetmap, true, elanTag);
 378
 379         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, dpnOpId, subnetToDpn,
 380                 WriteTransaction.CREATE_MISSING_PARENTS);
 381         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, portOpIdentifier, portOp,
 382                 WriteTransaction.CREATE_MISSING_PARENTS);
 383
 384
 385     }
 386
 387     @Ignore
 388     @Test
 389     public void testOnSubnetUpdatedInVpn() {
 390
 391         vpnSubnetRouteHandler.onSubnetUpdatedInVpn(subnetmap, elanTag);
 392
 393         verify(mockWriteTx).delete(LogicalDatastoreType.OPERATIONAL, portOpIdentifier);
 394         verify(mockWriteTx).delete(LogicalDatastoreType.OPERATIONAL, subOpIdentifier);
 395
 396     }
 397
 398     @Ignore
 399     @Test
 400     public void testOnSubnetDeletedFromVpn() {
 401
 402         vpnSubnetRouteHandler.onSubnetDeletedFromVpn(subnetmap, true);
 403
 404         verify(mockWriteTx).delete(LogicalDatastoreType.OPERATIONAL, portOpIdentifier);
 405         verify(mockWriteTx).delete(LogicalDatastoreType.OPERATIONAL, subOpIdentifier);
 406
 407     }
 408
 409     public static NodeConnectorId buildNodeConnectorId(Uint64 dpn, long portNo) {
 410         return new NodeConnectorId(buildNodeConnectorString(dpn, portNo));
 411     }
 412
 413     public static String buildNodeConnectorString(Uint64 dpn, long portNo) {
 414         return new StringBuilder().append(IfmConstants.OF_URI_PREFIX).append(dpn)
 415             .append(IfmConstants.OF_URI_SEPARATOR).append(portNo).toString();
 416     }
 417
 418     public static InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.vpn
 419         .instance.to
 420         .vpn.id.VpnInstance> getVpnInstanceToVpnIdIdentifier(String vpnName) {
 421         return InstanceIdentifier.builder(VpnInstanceToVpnId.class).child(org.opendaylight.yang.gen.v1.urn
 422                 .opendaylight.netvirt.l3vpn.rev130911.vpn.instance.to.vpn.id.VpnInstance.class,
 423             new org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.vpn.instance.to.vpn.id
 424                 .VpnInstanceKey(vpnName)).build();
 425     }
 426
 427 }