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.Matchers.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.base.Optional;
  17 import com.google.common.util.concurrent.Futures;
  18 import java.math.BigInteger;
  19 import java.util.ArrayList;
  20 import java.util.Arrays;
  21 import java.util.List;
  22 import java.util.concurrent.Future;
  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.runners.MockitoJUnitRunner;
  29 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  30 import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
  31 import org.opendaylight.controller.md.sal.binding.api.WriteTransaction;
  32 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  33 import org.opendaylight.genius.interfacemanager.globals.IfmConstants;
  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.api.InterfaceUtils;
  42 import org.opendaylight.yang.gen.v1.urn.huawei.params.xml.ns.yang.l3vpn.rev140815.VpnInstances;
  43 import org.opendaylight.yang.gen.v1.urn.huawei.params.xml.ns.yang.l3vpn.rev140815.vpn.instances.vpn.instance.Ipv4Family;
  44 import org.opendaylight.yang.gen.v1.urn.huawei.params.xml.ns.yang.l3vpn.rev140815.vpn.instances.vpn.instance.Ipv4FamilyBuilder;
  45 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.iana._if.type.rev140508.L2vlan;
  46 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
  47 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddressBuilder;
  48 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface;
  49 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.InterfaceKey;
  50 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Uuid;
  51 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.AllocateIdInput;
  52 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.AllocateIdInputBuilder;
  53 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.AllocateIdOutput;
  54 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.AllocateIdOutputBuilder;
  55 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.IdManagerService;
  56 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.DpnEndpoints;
  57 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.dpn.endpoints.DPNTEPsInfo;
  58 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.dpn.endpoints.DPNTEPsInfoBuilder;
  59 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.dpn.endpoints.DPNTEPsInfoKey;
  60 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.dpn.endpoints.dpn.teps.info.TunnelEndPoints;
  61 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.op.rev160406.dpn.endpoints.dpn.teps.info.TunnelEndPointsBuilder;
  62 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.lockmanager.rev160413.LockManagerService;
  63 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorId;
  64 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.PortOpData;
  65 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.PortOpDataBuilder;
  66 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.SubnetOpData;
  67 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.TaskState;
  68 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.VpnInstanceToVpnId;
  69 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.port.op.data.PortOpDataEntry;
  70 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.port.op.data.PortOpDataEntryBuilder;
  71 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.port.op.data.PortOpDataEntryKey;
  72 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.subnet.op.data.SubnetOpDataEntry;
  73 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.subnet.op.data.SubnetOpDataEntryBuilder;
  74 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.subnet.op.data.SubnetOpDataEntryKey;
  75 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.subnet.op.data.subnet.op.data.entry.SubnetToDpn;
  76 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.subnet.op.data.subnet.op.data.entry.SubnetToDpnBuilder;
  77 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.subnet.op.data.subnet.op.data.entry.SubnetToDpnKey;
  78 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.subnet.op.data.subnet.op.data.entry.subnet.to.dpn.VpnInterfaces;
  79 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.subnet.op.data.subnet.op.data.entry.subnet.to.dpn.VpnInterfacesBuilder;
  80 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.subnet.op.data.subnet.op.data.entry.subnet.to.dpn.VpnInterfacesKey;
  81 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.vpn.instance.to.vpn.id.VpnInstance;
  82 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.vpn.instance.to.vpn.id.VpnInstanceBuilder;
  83 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.vpn.instance.to.vpn.id.VpnInstanceKey;
  84 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.natservice.rev160111.ExternalNetworks;
  85 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.natservice.rev160111.external.networks.Networks;
  86 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.natservice.rev160111.external.networks.NetworksBuilder;
  87 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.natservice.rev160111.external.networks.NetworksKey;
  88 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.Subnetmaps;
  89 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.subnetmaps.Subnetmap;
  90 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.subnetmaps.SubnetmapBuilder;
  91 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.subnetmaps.SubnetmapKey;
  92 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  93 import org.opendaylight.yangtools.yang.common.RpcResult;
  94 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
  95
  96 @RunWith(MockitoJUnitRunner.class)
  97 public class VpnSubnetRouteHandlerTest {
  98
  99     BigInteger dpId = BigInteger.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     Ipv4Family ipv4Family = null;
 127     String idKey = null;
 128     AllocateIdOutput allocateIdOutput = null;
 129     AllocateIdInput allocateIdInput = null;
 130     Networks networks = null;
 131     org.opendaylight.yang.gen.v1.urn.huawei.params.xml.ns.yang.l3vpn.rev140815.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.huawei.params.xml.ns.yang.l3vpn.rev140815.vpn.instances
 153         .VpnInstance>
 154         vpnInstanceIdentifier = InstanceIdentifier.builder(VpnInstances.class).child(
 155         org.opendaylight.yang.gen.v1.urn.huawei.params.xml.ns.yang.l3vpn.rev140815.vpn.instances.VpnInstance.class,
 156         new org.opendaylight.yang.gen.v1.urn.huawei.params.xml.ns.yang.l3vpn.rev140815.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     ReadOnlyTransaction 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     VpnSubnetRouteHandler vpnSubnetRouteHandler;
 187
 188     Optional<Interface> optionalIfState;
 189     Optional<SubnetOpDataEntry> optionalSubs;
 190     Optional<SubnetToDpn> optionalSubDpn;
 191     Optional<DPNTEPsInfo> optionalTunnelInfo;
 192     Optional<PortOpDataEntry> optionalPortOp;
 193     Optional<PortOpData> optionalPtOp;
 194     Optional<Subnetmap> optionalSubnetMap;
 195     Optional<org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.vpn.instance.to.vpn.id.VpnInstance>
 196         optionalVpnInstnce;
 197     Optional<org.opendaylight.yang.gen.v1.urn.huawei.params.xml.ns.yang.l3vpn.rev140815.vpn.instances.VpnInstance>
 198         vpnInstanceOptional;
 199     Optional<Networks> optionalNetworks;
 200
 201     @Before
 202     public void setUp() throws Exception {
 203         setupMocks();
 204
 205         vpnSubnetRouteHandler = new VpnSubnetRouteHandler(dataBroker, subnetOpDpnManager, bgpManager,
 206             idManager, lockManagerService, vpnOpDataSyncer, vpnNodeListener, fibManager);
 207         final Future<RpcResult<AllocateIdOutput>> idOutputOptional =
 208             RpcResultBuilder.success(allocateIdOutput).buildFuture();
 209
 210         optionalIfState = Optional.of(stateInterface);
 211         optionalSubs = Optional.of(subnetOp);
 212         optionalSubDpn = Optional.of(subnetToDpn);
 213         optionalTunnelInfo = Optional.of(dpntePsInfo);
 214         optionalPortOp = Optional.of(portOp);
 215         optionalPtOp = Optional.of(portOpData);
 216         optionalSubnetMap = Optional.of(subnetmap);
 217         optionalVpnInstnce = Optional.of(vpnInstance);
 218         vpnInstanceOptional = Optional.of(vpnInstnce);
 219         optionalNetworks = Optional.of(networks);
 220
 221         doReturn(Futures.immediateCheckedFuture(optionalIfState)).when(mockReadTx).read(LogicalDatastoreType
 222             .OPERATIONAL, ifStateId);
 223         doReturn(Futures.immediateCheckedFuture(optionalSubs)).when(mockReadTx).read(LogicalDatastoreType
 224             .OPERATIONAL, subOpIdentifier);
 225         doReturn(Futures.immediateCheckedFuture(optionalSubDpn)).when(mockReadTx).read(LogicalDatastoreType
 226             .OPERATIONAL, dpnOpId);
 227         doReturn(Futures.immediateCheckedFuture(optionalTunnelInfo)).when(mockReadTx).read(LogicalDatastoreType
 228             .CONFIGURATION, tunnelInfoId);
 229         doReturn(Futures.immediateCheckedFuture(optionalPortOp)).when(mockReadTx).read(LogicalDatastoreType
 230             .OPERATIONAL, portOpIdentifier);
 231         doReturn(Futures.immediateCheckedFuture(optionalPtOp)).when(mockReadTx).read(LogicalDatastoreType
 232             .OPERATIONAL, portOpIdentifr);
 233         doReturn(Futures.immediateCheckedFuture(optionalPortOp)).when(mockReadTx).read(LogicalDatastoreType
 234             .OPERATIONAL, instPortOp);
 235         doReturn(Futures.immediateCheckedFuture(optionalSubnetMap)).when(mockReadTx).read(LogicalDatastoreType
 236             .CONFIGURATION, subMapid);
 237         doReturn(Futures.immediateCheckedFuture(optionalVpnInstnce)).when(mockReadTx).read(LogicalDatastoreType
 238             .CONFIGURATION, instVpnInstance);
 239         doReturn(Futures.immediateCheckedFuture(vpnInstanceOptional)).when(mockReadTx).read(LogicalDatastoreType
 240             .CONFIGURATION, vpnInstanceIdentifier);
 241         doReturn(Futures.immediateCheckedFuture(Optional.absent())).when(mockReadTx).read(LogicalDatastoreType
 242             .CONFIGURATION, netsIdentifier);
 243         doReturn(idOutputOptional).when(idManager).allocateId(allocateIdInput);
 244
 245         when(subnetOpDpnManager.getPortOpDataEntry(anyString())).thenReturn(portOp);
 246     }
 247
 248     private void setupMocks() {
 249
 250         nexthopIp = "10.1.1.25";
 251         idKey = "100:1.10.1.1.24";
 252         poolName = "vpnservices";
 253         elanTag = 2L;
 254         longId = Long.valueOf("100");
 255         nodeConnectorId = buildNodeConnectorId(dpId, 2L);
 256         ipAddress = IpAddressBuilder.getDefaultInstance(nexthopIp);
 257         vpnIntfaces = new VpnInterfacesBuilder().setInterfaceName(interfaceName).withKey(
 258             new VpnInterfacesKey(interfaceName)).build();
 259         List<VpnInterfaces> vpnInterfaces = new ArrayList<>();
 260         final List<SubnetToDpn> subToDpn = new ArrayList<>();
 261         final List<Uuid> portList = new ArrayList<>();
 262         final List<PortOpDataEntry> listPortOpDataEntry = new ArrayList<>();
 263         final List<TunnelEndPoints> tunnelEndPoints = new ArrayList<>();
 264         List<Uuid> subnetIdList = new ArrayList<>();
 265         subnetIdList.add(subnetId);
 266         vpnInterfaces.add(vpnIntfaces);
 267         lowerLayerIfList.add(nodeConnectorId.getValue());
 268         portOp = new PortOpDataEntryBuilder().setDpnId(dpId).withKey(new PortOpDataEntryKey(tenantId.getValue()))
 269             .setSubnetIds(subnetIdList).setPortId(tenantId.getValue()).build();
 270         subnetToDpn = new SubnetToDpnBuilder().setDpnId(dpId).withKey(new SubnetToDpnKey(dpId)).setVpnInterfaces(
 271             vpnInterfaces).build();
 272         allocateIdOutput = new AllocateIdOutputBuilder().setIdValue(longId).build();
 273         allocateIdInput = new AllocateIdInputBuilder().setPoolName(poolName).setIdKey(idKey).build();
 274         subToDpn.add(subnetToDpn);
 275         portList.add(portId);
 276         listPortOpDataEntry.add(portOp);
 277         org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state
 278             .InterfaceBuilder ifaceBuilder = new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf
 279             .interfaces.rev140508.interfaces.state.InterfaceBuilder();
 280         ifaceBuilder.setLowerLayerIf(lowerLayerIfList).setType(L2vlan.class)
 281             .setAdminStatus(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508
 282                 .interfaces.state.Interface.AdminStatus.Up).setOperStatus(Interface.OperStatus.Up)
 283             .setIfIndex(100).withKey(new InterfaceKey(interfaceName)).setName(interfaceName)
 284             .setPhysAddress(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715
 285                 .PhysAddress.getDefaultInstance("AA:AA:AA:AA:AA:AA"));
 286         stateInterface = ifaceBuilder.build();
 287         subnetOp = new SubnetOpDataEntryBuilder().setElanTag(elanTag).setNhDpnId(dpId).setSubnetCidr(subnetIp)
 288             .setSubnetId(subnetId).withKey(new SubnetOpDataEntryKey(subnetId)).setVpnName(interfaceName)
 289             .setVrfId(primaryRd).setSubnetToDpn(subToDpn).setRouteAdvState(TaskState.Advertised).build();
 290         vpnInstance = new VpnInstanceBuilder().setVpnId(elanTag).setVpnInstanceName(interfaceName)
 291             .setVrfId(interfaceName).withKey(new VpnInstanceKey(interfaceName)).build();
 292         subnetmap = new SubnetmapBuilder().setSubnetIp(subnetIp).setId(subnetId).setNetworkId(portId).withKey(new
 293             SubnetmapKey(subnetId)).setRouterId(portId).setVpnId(subnetId)
 294             .setTenantId(tenantId).setPortList(portList).build();
 295         portOpData = new PortOpDataBuilder().setPortOpDataEntry(listPortOpDataEntry).build();
 296         dpntePsInfo = new DPNTEPsInfoBuilder().setDPNID(dpId).setUp(true).withKey(new DPNTEPsInfoKey(dpId))
 297             .setTunnelEndPoints(tunnelEndPoints).build();
 298         tunlEndPts =
 299             new TunnelEndPointsBuilder().setInterfaceName(interfaceName).setVLANID(10).setIpAddress(ipAddress).build();
 300         tunnelEndPoints.add(tunlEndPts);
 301         ipv4Family = new Ipv4FamilyBuilder().setRouteDistinguisher(routeDistinguishers).build();
 302         vpnInstnce = new org.opendaylight.yang.gen.v1.urn.huawei.params.xml.ns.yang.l3vpn.rev140815.vpn.instances
 303             .VpnInstanceBuilder().withKey(new org.opendaylight.yang.gen.v1.urn.huawei.params.xml.ns.yang.l3vpn
 304             .rev140815.vpn.instances.VpnInstanceKey(interfaceName)).setVpnInstanceName(interfaceName)
 305             .setIpv4Family(ipv4Family).build();
 306         networks = new NetworksBuilder().setId(portId).withKey(new NetworksKey(portId)).build();
 307         doReturn(mockReadTx).when(dataBroker).newReadOnlyTransaction();
 308         doReturn(mockWriteTx).when(dataBroker).newWriteOnlyTransaction();
 309         doReturn(Futures.immediateCheckedFuture(null)).when(mockWriteTx).submit();
 310     }
 311
 312     @Ignore
 313     @Test
 314     public void testOnPortAddedToSubnet() {
 315
 316         vpnSubnetRouteHandler.onPortAddedToSubnet(subnetmap, portId);
 317
 318         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, portOpIdentifier, portOp,
 319                 WriteTransaction.CREATE_MISSING_PARENTS);
 320         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, dpnOpId, subnetToDpn,
 321                 WriteTransaction.CREATE_MISSING_PARENTS);
 322         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, subOpIdentifier, subnetOp,
 323                 WriteTransaction.CREATE_MISSING_PARENTS);
 324     }
 325
 326     @Ignore
 327     @Test
 328     public void testOnPortRemovedFromSubnet() {
 329
 330         vpnSubnetRouteHandler.onPortRemovedFromSubnet(subnetmap, portId);
 331
 332         verify(mockWriteTx).delete(LogicalDatastoreType.OPERATIONAL, portOpIdentifier);
 333         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, dpnOpId, subnetToDpn,
 334                 WriteTransaction.CREATE_MISSING_PARENTS);
 335         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, subOpIdentifier, subnetOp,
 336                 WriteTransaction.CREATE_MISSING_PARENTS);
 337
 338     }
 339
 340     @Ignore
 341     @Test
 342     public void testOnInterfaceUp() {
 343
 344         vpnSubnetRouteHandler.onInterfaceUp(dpId, interfaceName, subnetId);
 345
 346         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, instPortOp, portOp,
 347                 WriteTransaction.CREATE_MISSING_PARENTS);
 348         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, dpnOpId, subnetToDpn,
 349                 WriteTransaction.CREATE_MISSING_PARENTS);
 350         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, subOpIdentifier, subnetOp,
 351                 WriteTransaction.CREATE_MISSING_PARENTS);
 352     }
 353
 354     @Ignore
 355     @Test
 356     public void testOnInterfaceDown() {
 357
 358         vpnSubnetRouteHandler.onInterfaceDown(dpId, interfaceName, subnetId);
 359
 360         // TODO: subnetOpDpnManager is mocked so not sure how this delete ever worked.
 361         //verify(mockWriteTx).delete(LogicalDatastoreType.OPERATIONAL, dpnOpId);
 362         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, subOpIdentifier, subnetOp,
 363                 WriteTransaction.CREATE_MISSING_PARENTS);
 364
 365     }
 366
 367     @Ignore
 368     @Test
 369     public void testOnSubnetAddedToVpn() {
 370
 371         doReturn(Futures.immediateCheckedFuture(Optional.absent())).when(mockReadTx).read(LogicalDatastoreType
 372             .OPERATIONAL, subOpIdentifier);
 373
 374         vpnSubnetRouteHandler.onSubnetAddedToVpn(subnetmap, true, elanTag);
 375
 376         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, dpnOpId, subnetToDpn,
 377                 WriteTransaction.CREATE_MISSING_PARENTS);
 378         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, portOpIdentifier, portOp,
 379                 WriteTransaction.CREATE_MISSING_PARENTS);
 380
 381
 382     }
 383
 384     @Ignore
 385     @Test
 386     public void testOnSubnetUpdatedInVpn() {
 387
 388         vpnSubnetRouteHandler.onSubnetUpdatedInVpn(subnetmap, elanTag);
 389
 390         verify(mockWriteTx).delete(LogicalDatastoreType.OPERATIONAL, portOpIdentifier);
 391         verify(mockWriteTx).delete(LogicalDatastoreType.OPERATIONAL, subOpIdentifier);
 392
 393     }
 394
 395     @Ignore
 396     @Test
 397     public void testOnSubnetDeletedFromVpn() {
 398
 399         vpnSubnetRouteHandler.onSubnetDeletedFromVpn(subnetmap, true);
 400
 401         verify(mockWriteTx).delete(LogicalDatastoreType.OPERATIONAL, portOpIdentifier);
 402         verify(mockWriteTx).delete(LogicalDatastoreType.OPERATIONAL, subOpIdentifier);
 403
 404     }
 405
 406     public static NodeConnectorId buildNodeConnectorId(BigInteger dpn, long portNo) {
 407         return new NodeConnectorId(buildNodeConnectorString(dpn, portNo));
 408     }
 409
 410     public static String buildNodeConnectorString(BigInteger dpn, long portNo) {
 411         return new StringBuffer().append(IfmConstants.OF_URI_PREFIX).append(dpn)
 412             .append(IfmConstants.OF_URI_SEPARATOR).append(portNo).toString();
 413     }
 414
 415     public static InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.vpn
 416         .instance.to
 417         .vpn.id.VpnInstance> getVpnInstanceToVpnIdIdentifier(String vpnName) {
 418         return InstanceIdentifier.builder(VpnInstanceToVpnId.class).child(org.opendaylight.yang.gen.v1.urn
 419                 .opendaylight.netvirt.l3vpn.rev130911.vpn.instance.to.vpn.id.VpnInstance.class,
 420             new org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.vpn.instance.to.vpn.id
 421                 .VpnInstanceKey(vpnName)).build();
 422     }
 423
 424 }