vpnservice/vpnmanager/vpnmanager-impl/src/test/java/org/opendaylight/netvirt/vpnmanager/test/VpnSubnetRouteHandlerTest.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.netvirt.vpnmanager.test;
  10
  11 import com.google.common.base.Optional;
  12 import com.google.common.util.concurrent.Futures;
  13
  14 import org.junit.Before;
  15 import org.junit.Test;
  16 import org.junit.runner.RunWith;
  17 import org.mockito.Mock;
  18 import org.mockito.runners.MockitoJUnitRunner;
  19 import org.opendaylight.netvirt.bgpmanager.api.IBgpManager;
  20 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  21 import org.opendaylight.controller.md.sal.binding.api.DataChangeListener;
  22 import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
  23 import org.opendaylight.controller.md.sal.binding.api.WriteTransaction;
  24 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataBroker;
  25 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  26 import org.opendaylight.vpnservice.interfacemgr.globals.IfmConstants;
  27 import org.opendaylight.netvirt.vpnmanager.VpnInterfaceManager;
  28 import org.opendaylight.netvirt.vpnmanager.VpnSubnetRouteHandler;
  29 import org.opendaylight.netvirt.vpnmanager.utilities.InterfaceUtils;
  30 import org.opendaylight.yang.gen.v1.urn.huawei.params.xml.ns.yang.l3vpn.rev140815.VpnInstances;
  31 import org.opendaylight.yang.gen.v1.urn.huawei.params.xml.ns.yang.l3vpn.rev140815.vpn.instances.vpn.instance.Ipv4Family;
  32 import org.opendaylight.yang.gen.v1.urn.huawei.params.xml.ns.yang.l3vpn.rev140815.vpn.instances.vpn.instance
  33         .Ipv4FamilyBuilder;
  34 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.iana._if.type.rev140508.L2vlan;
  35 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.IpAddress;
  36 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.IpAddressBuilder;
  37 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface;
  38 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.InterfaceKey;
  39 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Uuid;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorId;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.PortOpData;
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.PortOpDataBuilder;
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.SubnetOpData;
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.RdToElanOp;
  45 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.VpnInstanceToVpnId;
  46 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.TaskState;
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.port.op.data.PortOpDataEntry;
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.port.op.data.PortOpDataEntryBuilder;
  49 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.port.op.data.PortOpDataEntryKey;
  50 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.rd.to.elan.op.RdToElanOpEntry;
  51 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.rd.to.elan.op.RdToElanOpEntryBuilder;
  52 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.rd.to.elan.op.RdToElanOpEntryKey;
  53 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.subnet.op.data.SubnetOpDataEntry;
  54 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.subnet.op.data.SubnetOpDataEntryBuilder;
  55 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.subnet.op.data.SubnetOpDataEntryKey;
  56 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.subnet.op.data.subnet.op.data.entry.SubnetToDpn;
  57 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.subnet.op.data.subnet.op.data.entry.SubnetToDpnBuilder;
  58 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.subnet.op.data.subnet.op.data.entry.SubnetToDpnKey;
  59 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.subnet.op.data.subnet.op.data.entry.subnet.to.dpn.VpnInterfaces;
  60 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.subnet.op.data.subnet.op.data.entry.subnet.to.dpn.VpnInterfacesBuilder;
  61 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.subnet.op.data.subnet.op.data.entry.subnet.to.dpn.VpnInterfacesKey;
  62 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.vpn.instance.to.vpn.id.VpnInstance;
  63 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.vpn.instance.to.vpn.id.VpnInstanceBuilder;
  64 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.vpn.instance.to.vpn.id.VpnInstanceKey;
  65 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.idmanager.rev150403.AllocateIdInput;
  66 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.idmanager.rev150403.AllocateIdInputBuilder;
  67 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.idmanager.rev150403.AllocateIdOutput;
  68 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.idmanager.rev150403.AllocateIdOutputBuilder;
  69 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.idmanager.rev150403.IdManagerService;
  70 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.itm.op.rev150701.DpnEndpoints;
  71 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.itm.op.rev150701.dpn.endpoints.DPNTEPsInfo;
  72 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.itm.op.rev150701.dpn.endpoints.DPNTEPsInfoBuilder;
  73 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.itm.op.rev150701.dpn.endpoints.DPNTEPsInfoKey;
  74 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.itm.op.rev150701.dpn.endpoints.dpn.teps.info.TunnelEndPoints;
  75 import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.itm.op.rev150701.dpn.endpoints.dpn.teps.info.TunnelEndPointsBuilder;
  76 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.PortAddedToSubnet;
  77 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.PortRemovedFromSubnet;
  78 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.PortAddedToSubnetBuilder;
  79 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.PortRemovedFromSubnetBuilder;
  80 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.SubnetAddedToVpn;
  81 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.SubnetUpdatedInVpn;
  82 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.SubnetDeletedFromVpn;
  83 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.SubnetAddedToVpnBuilder;
  84 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.SubnetUpdatedInVpnBuilder;
  85 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.SubnetDeletedFromVpnBuilder;
  86 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.Subnetmaps;
  87 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.subnetmaps.Subnetmap;
  88 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.subnetmaps.SubnetmapBuilder;
  89 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.neutronvpn.rev150602.subnetmaps.SubnetmapKey;
  90 import org.opendaylight.yangtools.concepts.ListenerRegistration;
  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
  95 import java.math.BigInteger;
  96 import java.util.ArrayList;
  97 import java.util.List;
  98 import java.util.concurrent.Future;
  99
 100 import static org.mockito.Matchers.any;
 101 import static org.mockito.Mockito.doReturn;
 102 import static org.mockito.Mockito.verify;
 103 import static org.mockito.Mockito.when;
 104
 105 @RunWith(MockitoJUnitRunner.class)
 106 public class VpnSubnetRouteHandlerTest {
 107
 108     BigInteger dpId = BigInteger.valueOf(1);
 109     PortAddedToSubnet portAddedToSubnet = null;
 110     PortRemovedFromSubnet portRemovedFromSubnet = null;
 111     SubnetAddedToVpn subnetAddedToVpn = null;
 112     SubnetUpdatedInVpn subnetUpdatedInVpn = null;
 113     SubnetDeletedFromVpn subnetDeletedFromVpn = null;
 114     SubnetToDpn subnetToDpn = null;
 115     RdToElanOpEntry rdToElanOpEntry = null;
 116     String subnetIp = "10.1.1.24";
 117     String routeDistinguisher = "100:1";
 118     String nexthopIp = null;
 119     String poolName = null;
 120     String interfaceName = "VPN";
 121     Uuid subnetId = Uuid.getDefaultInstance("067e6162-3b6f-4ae2-a171-2470b63dff00");
 122     Uuid portId = Uuid.getDefaultInstance("54947df8-0e9e-4471-a2f9-9af509fb5889");
 123     Uuid tenantId = Uuid.getDefaultInstance("54947df8-0e9e-4571-a2f9-9af509fb5889");
 124     String portKey = portId.getValue();
 125     Long elanTag = null;
 126     Long longId = null;
 127     PortOpDataEntry portOp = null;
 128     PortOpData portOpData = null;
 129     SubnetOpDataEntry subnetOp = null;
 130     org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface
 131             stateInterface;
 132     List<String> lowerLayerIfList = new ArrayList<>();
 133     NodeConnectorId nodeConnectorId = null;
 134     VpnInterfaces vpnIntfaces = null;
 135     VpnInstance vpnInstance = null;
 136     Subnetmap subnetmap = null;
 137     DPNTEPsInfo dpntePsInfo = null;
 138     TunnelEndPoints tunlEndPts = null;
 139     IpAddress ipAddress = null;
 140     Ipv4Family ipv4Family = null;
 141     String idKey = null;
 142     AllocateIdOutput allocateIdOutput = null;
 143     AllocateIdInput allocateIdInput = null;
 144     org.opendaylight.yang.gen.v1.urn.huawei.params.xml.ns.yang.l3vpn.rev140815.vpn.instances.VpnInstance vpnInstnce;
 145
 146     InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces
 147             .state.Interface> ifStateId = InterfaceUtils.buildStateInterfaceId(portKey);
 148     InstanceIdentifier<SubnetOpDataEntry> subOpIdentifier = InstanceIdentifier.builder(SubnetOpData.class).
 149             child(SubnetOpDataEntry.class, new SubnetOpDataEntryKey(subnetId)).build();
 150     InstanceIdentifier<SubnetToDpn> dpnOpId = subOpIdentifier.child(SubnetToDpn.class, new SubnetToDpnKey(dpId));
 151     InstanceIdentifier<DPNTEPsInfo> tunnelInfoId =
 152             InstanceIdentifier.builder(DpnEndpoints.class).child(DPNTEPsInfo.class, new DPNTEPsInfoKey(dpId)).build();
 153     InstanceIdentifier<PortOpDataEntry> portOpIdentifier = InstanceIdentifier.builder(PortOpData.class).
 154             child(PortOpDataEntry.class, new PortOpDataEntryKey(portKey)).build();
 155     InstanceIdentifier<PortOpDataEntry> instPortOp = InstanceIdentifier.builder(PortOpData.class).
 156             child(PortOpDataEntry.class, new PortOpDataEntryKey(interfaceName)).build();
 157     InstanceIdentifier<Subnetmap> subMapid = InstanceIdentifier.builder(Subnetmaps.class).child(Subnetmap.class, new
 158             SubnetmapKey(subnetId)).build();
 159     InstanceIdentifier<PortOpData> portOpIdentifr = InstanceIdentifier.builder(PortOpData.class).build();
 160     InstanceIdentifier<RdToElanOpEntry> rdIdentifier = InstanceIdentifier.builder(RdToElanOp.class).
 161             child(RdToElanOpEntry.class, new RdToElanOpEntryKey(interfaceName, subnetIp)).build();
 162     InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.vpn.instance.to.vpn.id
 163             .VpnInstance> instVpnInstance = getVpnInstanceToVpnIdIdentifier(interfaceName);
 164     InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.huawei.params.xml.ns.yang.l3vpn.rev140815.vpn.instances.
 165             VpnInstance> vpnInstanceIdentifier = InstanceIdentifier.builder(VpnInstances.class).child(org.opendaylight
 166             .yang.gen.v1.urn.huawei.params.xml.ns.yang.l3vpn.rev140815.vpn.instances.VpnInstance.class,
 167             new org.opendaylight.yang.gen.v1.urn.huawei.params.xml.ns.yang.l3vpn.rev140815.vpn.instances
 168                     .VpnInstanceKey(interfaceName)).build();
 169
 170     @Mock DataBroker dataBroker;
 171     @Mock ListenerRegistration<DataChangeListener> dataChangeListenerRegistration;
 172     @Mock ReadOnlyTransaction mockReadTx;
 173     @Mock WriteTransaction mockWriteTx;
 174     @Mock IBgpManager bgpManager;
 175     @Mock
 176     VpnInterfaceManager vpnInterfaceManager;
 177     @Mock IdManagerService idManager;
 178
 179     VpnSubnetRouteHandler vpnSubnetRouteHandler;
 180
 181     Optional<Interface> optionalIfState;
 182     Optional<SubnetOpDataEntry> optionalSubs;
 183     Optional<SubnetToDpn> optionalSubDpn;
 184     Optional<DPNTEPsInfo> optionalTunnelInfo;
 185     Optional<PortOpDataEntry> optionalPortOp;
 186     Optional<PortOpData> optionalPtOp;
 187     Optional<Subnetmap> optionalSubnetMap;
 188     Optional<RdToElanOpEntry> optionalRd;
 189     Optional<org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.vpn.instance.to.vpn.id.VpnInstance>
 190             optionalVpnInstnce;
 191     Optional<org.opendaylight.yang.gen.v1.urn.huawei.params.xml.ns.yang.l3vpn.rev140815.vpn.instances.VpnInstance>
 192             vpnInstanceOptional;
 193
 194     @Before
 195     public void setUp() throws Exception {
 196         when(dataBroker.registerDataChangeListener(
 197                 any(LogicalDatastoreType.class),
 198                 any(InstanceIdentifier.class),
 199                 any(DataChangeListener.class),
 200                 any(AsyncDataBroker.DataChangeScope.class)))
 201                 .thenReturn(dataChangeListenerRegistration);
 202         setupMocks();
 203
 204         vpnSubnetRouteHandler = new VpnSubnetRouteHandler(dataBroker, bgpManager, vpnInterfaceManager);
 205         vpnSubnetRouteHandler.setIdManager(idManager);
 206         Future<RpcResult<AllocateIdOutput>> idOutputOptional = RpcResultBuilder.success(allocateIdOutput).buildFuture();
 207
 208         optionalIfState = Optional.of(stateInterface);
 209         optionalSubs = Optional.of(subnetOp);
 210         optionalSubDpn = Optional.of(subnetToDpn);
 211         optionalTunnelInfo = Optional.of(dpntePsInfo);
 212         optionalPortOp = Optional.of(portOp);
 213         optionalPtOp = Optional.of(portOpData);
 214         optionalSubnetMap = Optional.of(subnetmap);
 215         optionalRd = Optional.of(rdToElanOpEntry);
 216         optionalVpnInstnce = Optional.of(vpnInstance);
 217         vpnInstanceOptional = Optional.of(vpnInstnce);
 218
 219         doReturn(Futures.immediateCheckedFuture(optionalRd)).when(mockReadTx).read(LogicalDatastoreType.OPERATIONAL,
 220                 rdIdentifier);
 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(idOutputOptional).when(idManager).allocateId(allocateIdInput);
 242     }
 243
 244     private void setupMocks() {
 245
 246         nexthopIp = "10.1.1.25";
 247         idKey = "100:1.10.1.1.24";
 248         poolName = "vpnservices";
 249         elanTag = Long.valueOf(2);
 250         longId = Long.valueOf("100");
 251         nodeConnectorId = buildNodeConnectorId(dpId, Long.valueOf(2));
 252         ipAddress = IpAddressBuilder.getDefaultInstance(nexthopIp);
 253         vpnIntfaces = new VpnInterfacesBuilder().setInterfaceName(interfaceName).setKey(new VpnInterfacesKey
 254                 (interfaceName)).build();
 255         List<VpnInterfaces> vpnInterfaces = new ArrayList<>();
 256         List<SubnetToDpn> subToDpn = new ArrayList<>();
 257         List<Uuid> portList = new ArrayList<>();
 258         List<PortOpDataEntry> listPortOpDataEntry = new ArrayList<>();
 259         List<TunnelEndPoints> tunnelEndPoints = new ArrayList<>();
 260         vpnInterfaces.add(vpnIntfaces);
 261         lowerLayerIfList.add(nodeConnectorId.getValue());
 262         portOp = new PortOpDataEntryBuilder().setDpnId(dpId).setKey(new PortOpDataEntryKey(tenantId.getValue()))
 263                 .setSubnetId(subnetId).setPortId(tenantId.getValue()).build();
 264         subnetToDpn = new SubnetToDpnBuilder().setDpnId(dpId).setKey(new SubnetToDpnKey(dpId)).setVpnInterfaces
 265                 (vpnInterfaces).build();
 266         allocateIdOutput = new AllocateIdOutputBuilder().setIdValue(longId).build();
 267         allocateIdInput = new AllocateIdInputBuilder().setPoolName(poolName).setIdKey(idKey).build();
 268         subToDpn.add(subnetToDpn);
 269         portList.add(portId);
 270         listPortOpDataEntry.add(portOp);
 271         org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state
 272                 .InterfaceBuilder ifaceBuilder = new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf
 273                 .interfaces.rev140508.interfaces.state.InterfaceBuilder();
 274         ifaceBuilder.setLowerLayerIf(lowerLayerIfList).setType(L2vlan.class)
 275                 .setAdminStatus(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508
 276                         .interfaces.state.Interface.AdminStatus.Up).setOperStatus(Interface.OperStatus.Up)
 277                 .setIfIndex(100).setKey(new InterfaceKey(interfaceName)).setName(interfaceName)
 278                 .setPhysAddress(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715
 279                         .PhysAddress.getDefaultInstance("AA:AA:AA:AA:AA:AA"));
 280         stateInterface = ifaceBuilder.build();
 281         portAddedToSubnet = new PortAddedToSubnetBuilder().setSubnetIp(subnetIp).setPortId(portId).setSubnetId
 282                 (subnetId).setElanTag(elanTag).build();
 283         portRemovedFromSubnet = new PortRemovedFromSubnetBuilder().setPortId(portId).setSubnetId(subnetId)
 284                 .setSubnetIp(subnetIp).setElanTag(elanTag).build();
 285         subnetAddedToVpn = new SubnetAddedToVpnBuilder().setElanTag(elanTag).setSubnetId(subnetId).setVpnName
 286                 (interfaceName).setExternalVpn(true).setSubnetIp(subnetIp).build();
 287         subnetUpdatedInVpn = new SubnetUpdatedInVpnBuilder().setElanTag(elanTag).setSubnetIp(subnetIp).setSubnetId
 288                 (subnetId).setVpnName(interfaceName).setExternalVpn(false).build();
 289         subnetDeletedFromVpn = new SubnetDeletedFromVpnBuilder().setExternalVpn(true).setSubnetId(subnetId)
 290                 .setSubnetIp(subnetIp).setVpnName(interfaceName).setElanTag(elanTag).build();
 291         subnetOp = new SubnetOpDataEntryBuilder().setElanTag(elanTag).setNhDpnId(dpId).setSubnetCidr(subnetIp)
 292                 .setSubnetId(subnetId).setKey(new SubnetOpDataEntryKey(subnetId)).setVpnName(interfaceName)
 293                 .setVrfId(routeDistinguisher).setSubnetToDpn(subToDpn).setRouteAdvState(TaskState.Done).build();
 294         vpnInstance = new VpnInstanceBuilder().setVpnId(elanTag).setVpnInstanceName(interfaceName).setVrfId
 295                 (interfaceName).setKey(new VpnInstanceKey(interfaceName)).build();
 296         subnetmap = new SubnetmapBuilder().setSubnetIp(subnetIp).setId(subnetId).setNetworkId(portId).setKey(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).setKey(new DPNTEPsInfoKey(dpId))
 301                 .setTunnelEndPoints(tunnelEndPoints).build();
 302         tunlEndPts = new TunnelEndPointsBuilder().setInterfaceName(interfaceName).setVLANID(10).setIpAddress
 303                 (ipAddress).build();
 304         tunnelEndPoints.add(tunlEndPts);
 305         rdToElanOpEntry = new RdToElanOpEntryBuilder().setElanTag(elanTag).setRd(interfaceName).setVpnName
 306                 (interfaceName).setNextHopIp(nexthopIp)
 307                 .setKey(new RdToElanOpEntryKey(interfaceName, subnetIp)).setSubnetIp(subnetIp).build();
 308         ipv4Family = new Ipv4FamilyBuilder().setRouteDistinguisher(routeDistinguisher).build();
 309         vpnInstnce = new org.opendaylight.yang.gen.v1.urn.huawei.params.xml.ns.yang.l3vpn.rev140815.vpn.instances
 310                 .VpnInstanceBuilder().setKey(new org.opendaylight.yang.gen.v1.urn.huawei.params.xml.ns.yang.l3vpn
 311                 .rev140815.vpn.instances.VpnInstanceKey(interfaceName)).setVpnInstanceName(interfaceName)
 312                 .setIpv4Family(ipv4Family).build();
 313         doReturn(mockReadTx).when(dataBroker).newReadOnlyTransaction();
 314         doReturn(mockWriteTx).when(dataBroker).newWriteOnlyTransaction();
 315         doReturn(Futures.immediateCheckedFuture(null)).when(mockWriteTx).submit();
 316
 317     }
 318
 319     @Test
 320     public void testOnPortAddedToSubnet() {
 321
 322         vpnSubnetRouteHandler.onPortAddedToSubnet(portAddedToSubnet);
 323
 324         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, portOpIdentifier, portOp, true);
 325         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, dpnOpId, subnetToDpn, true);
 326         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, subOpIdentifier, subnetOp, true);
 327     }
 328
 329     @Test
 330     public void testOnPortRemovedFromSubnet() {
 331
 332         vpnSubnetRouteHandler.onPortRemovedFromSubnet(portRemovedFromSubnet);
 333
 334         verify(mockWriteTx).delete(LogicalDatastoreType.OPERATIONAL, portOpIdentifier);
 335         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, dpnOpId, subnetToDpn, true);
 336         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, subOpIdentifier, subnetOp, true);
 337
 338     }
 339
 340     @Test
 341     public void testOnInterfaceUp() {
 342
 343         vpnSubnetRouteHandler.onInterfaceUp(stateInterface);
 344
 345         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, instPortOp, portOp, true);
 346         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, dpnOpId, subnetToDpn, true);
 347         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, subOpIdentifier, subnetOp, true);
 348     }
 349
 350     @Test
 351     public void testOnInterfaceDown() {
 352
 353         vpnSubnetRouteHandler.onInterfaceDown(stateInterface);
 354
 355         verify(mockWriteTx).delete(LogicalDatastoreType.OPERATIONAL, dpnOpId);
 356         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, subOpIdentifier, subnetOp, true);
 357
 358     }
 359
 360     @Test
 361     public void testOnSubnetAddedToVpn() {
 362
 363         doReturn(Futures.immediateCheckedFuture(Optional.absent())).when(mockReadTx).read(LogicalDatastoreType
 364                 .OPERATIONAL, subOpIdentifier);
 365
 366         vpnSubnetRouteHandler.onSubnetAddedToVpn(subnetAddedToVpn);
 367
 368         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, dpnOpId, subnetToDpn, true);
 369         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, portOpIdentifier, portOp, true);
 370         verify(mockWriteTx).put(LogicalDatastoreType.OPERATIONAL, subOpIdentifier, subnetOp, true);
 371
 372
 373     }
 374
 375     @Test
 376     public void testOnSubnetUpdatedInVpn() {
 377
 378         vpnSubnetRouteHandler.onSubnetUpdatedInVpn(subnetUpdatedInVpn);
 379
 380         verify(mockWriteTx).delete(LogicalDatastoreType.OPERATIONAL, instPortOp);
 381         verify(mockWriteTx).delete(LogicalDatastoreType.OPERATIONAL, subOpIdentifier);
 382
 383     }
 384
 385     @Test
 386     public void testOnSubnetDeletedFromVpn() {
 387
 388         vpnSubnetRouteHandler.onSubnetDeletedFromVpn(subnetDeletedFromVpn);
 389
 390         verify(mockWriteTx).delete(LogicalDatastoreType.OPERATIONAL, instPortOp);
 391         verify(mockWriteTx).delete(LogicalDatastoreType.OPERATIONAL, subOpIdentifier);
 392
 393     }
 394
 395     public static NodeConnectorId buildNodeConnectorId(BigInteger dpn, long portNo) {
 396         return new NodeConnectorId(buildNodeConnectorString(dpn, portNo));
 397     }
 398
 399     public static String buildNodeConnectorString(BigInteger dpn, long portNo) {
 400         return new StringBuffer().append(IfmConstants.OF_URI_PREFIX).append(dpn)
 401                 .append(IfmConstants.OF_URI_SEPARATOR).append(portNo).toString();
 402     }
 403
 404     public static InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.vpn.instance.to
 405             .vpn.id.VpnInstance> getVpnInstanceToVpnIdIdentifier(String vpnName) {
 406         return InstanceIdentifier.builder(VpnInstanceToVpnId.class).child(org.opendaylight.yang.gen.v1.urn
 407                 .opendaylight.netvirt.l3vpn.rev130911.vpn.instance.to.vpn.id.VpnInstance.class,
 408                         new org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.l3vpn.rev130911.vpn.instance.to.vpn.id.VpnInstanceKey(vpnName)).build();
 409     }
 410
 411 }