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