To include internal tunnel fetch
[netvirt.git] / elanmanager / impl / src / test / java / org / opendaylight / netvirt / elanmanager / tests / ElanServiceTestBase.java
index e917cf2073211621ab5d3a3c4b35f6a570b5762b..84f1b4aaafc019153dfeb8e32601763fb350c6c1 100644 (file)
@@ -36,6 +36,7 @@ import org.opendaylight.netvirt.elanmanager.api.ElanHelper;
 import org.opendaylight.netvirt.elanmanager.tests.utils.InterfaceHelper;
 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Address;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Uri;
 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.PhysAddress;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.list.Action;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNode;
@@ -52,6 +53,7 @@ import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instru
 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.instruction.apply.actions._case.ApplyActions;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.instruction.apply.actions._case.ApplyActionsBuilder;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.list.InstructionBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rpcs.rev160406.OdlInterfaceRpcService;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeId;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.Nodes;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
@@ -63,6 +65,10 @@ import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.elan.rev150602.elan
 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.elan.rev150602.elan.interfaces.ElanInterfaceKey;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.elan.rev150602.elan.interfaces.elan._interface.StaticMacEntries;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.elan.rev150602.elan.interfaces.elan._interface.StaticMacEntriesBuilder;
+import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NetworkTopology;
+import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.TopologyId;
+import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
+import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.TopologyKey;
 import org.opendaylight.yangtools.yang.binding.DataObject;
 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
 
@@ -74,19 +80,24 @@ public class ElanServiceTestBase {
     protected  @Inject ElanInstanceManager elanInstanceManager;
     protected  @Inject ElanInstanceCache elanInstanceCache;
     protected @Inject SingleTransactionDataBroker singleTxdataBroker;
+    protected @Inject OdlInterfaceRpcService odlInterfaceRpcService;
     public static final String ELAN1 = "34701c04-1118-4c65-9425-78a80d49a211";
     public static final Long ELAN1_SEGMENT_ID = 100L;
 
     protected static final BigInteger DPN1_ID = new BigInteger("1");
     protected static final BigInteger DPN2_ID = new BigInteger("2");
+    protected static final BigInteger DPN3_ID = new BigInteger("3");
 
     protected static final String DPN1_ID_STR = "1";
     protected static final String DPN2_ID_STR = "2";
+    protected static final String DPN3_ID_STR = "3";
 
     protected static final String DPN1_TEPIP = "192.168.56.30";
     protected static final String DPN2_TEPIP = "192.168.56.40";
-    protected static final String TOR1_TEPIP = "192.168.56.50";
-    public static final String DCGW_TEPIP = "192.168.56.60";
+    protected static final String DPN3_TEPIP = "192.168.56.50";
+    protected static final String TOR1_TEPIP = "192.168.56.60";
+    protected static final String TOR2_TEPIP = "192.168.56.70";
+    public static final String DCGW_TEPIP = "192.168.56.80";
 
     protected static final String DPN1MAC1 = "10:00:00:00:00:01";
     protected static final String DPN1MAC2 = "10:00:00:00:00:02";
@@ -94,21 +105,42 @@ public class ElanServiceTestBase {
     protected static final String DPN2MAC1 = "10:00:00:00:00:03";
     protected static final String DPN2MAC2 = "10:00:00:00:00:04";
 
-    protected static final String TOR1MAC1 = "10:00:00:00:00:05";
-    protected static final String TOR1MAC2 = "10:00:00:00:00:06";
+    protected static final String DPN3MAC1 = "10:00:00:00:00:05";
+    protected static final String DPN3MAC2 = "10:00:00:00:00:06";
 
-    protected static final String DPN1TODPN2TNLMAC = "91:00:00:00:00:01";
-    protected static final String DPN1TOTOR1TNLMAC = "91:00:00:00:00:02";
-    protected static final String DPN1TODCGWTNLMAC = "91:00:00:00:00:03";
+    protected static final String TOR1_MAC1 = "10:00:00:00:00:07";
+    protected static final String TOR1_IP1 = "10.0.0.1";
+    protected static final String TOR1_MAC2 = "10:00:00:00:00:08";
+    protected static final String TOR1_IP2 = "10.0.0.2";
+
+    protected static final String TOR2_MAC1 = "10:00:00:00:00:09";
+    protected static final String TOR2_MAC2 = "10:00:00:00:00:10";
+
+    protected static final String DPN1_TO_DPN2TNL_MAC = "91:00:00:00:00:01";
+    protected static final String DPN1_TO_TOR1TNL_MAC = "91:00:00:00:00:02";
+    protected static final String DPN1_TO_DCGWTNL_MAC = "91:00:00:00:00:03";
+    protected static final String DPN1_TO_DPN3_TNL_MAC = "91:00:00:00:00:04";
+
+    protected static final String DPN2_TO_DPN1_TNL_MAC = "92:00:00:00:00:01";
+    protected static final String DPN2_TO_TOR1_TNL_MAC = "92:00:00:00:00:02";
+    protected static final String DPN2_TO_DCGW_TNL_MAC = "92:00:00:00:00:03";
+    protected static final String DPN2_TO_DPN3_TNL_MAC = "92:00:00:00:00:04";
+
+    protected static final String DPN3_TO_DPN1_TNL_MAC = "93:00:00:00:00:01";
+    protected static final String DPN3_TO_DPN2_TNL_MAC = "93:00:00:00:00:02";
+    protected static final String DPN3_TO_TOR1_TNL_MAC = "93:00:00:00:00:03";
+
+    protected static final String DPN1_TO_TOR2_TNL_MAC = "94:00:00:00:00:01";
+    protected static final String DPN2_TO_TOR2_TNL_MAC = "94:00:00:00:00:02";
+    protected static final String DPN3_TO_TOR2_TNL_MAC = "94:00:00:00:00:03";
 
-    protected static final String DPN2TODPN1TNLMAC = "92:00:00:00:00:01";
-    protected static final String DPN2TOTOR1TNLMAC = "92:00:00:00:00:02";
-    protected static final String DPN2TODCGWTNLMAC = "92:00:00:00:00:03";
 
     protected static final String DPN1IP1 = "10.0.0.11";
     protected static final String DPN1IP2 = "10.0.0.12";
     protected static final String DPN2IP1 = "10.0.0.13";
     protected static final String DPN2IP2 = "10.0.0.14";
+    protected static final String DPN3IP1 = "10.0.0.15";
+    protected static final String DPN3IP2 = "10.0.0.16";
 
     protected static final String EVPNRECVMAC1 = "10:00:00:00:00:51";
     protected static final String EVPNRECVMAC2 = "10:00:00:00:00:52";
@@ -116,7 +148,23 @@ public class ElanServiceTestBase {
     protected static final String EVPNRECVIP1 = "192.168.122.51";
     protected static final String EVPNRECVIP2 = "192.168.122.52";
 
-    protected static final String TOR1NODEID = "hwvtep://uuid/34701c04-1118-4c65-9425-78a80d49a211";
+    protected static final String TOR1_NODE_ID = "hwvtep://uuid/34701c04-1118-4c65-9425-78a80d49a211";
+    protected static final String TOR2_NODE_ID = "hwvtep://uuid/34701c04-1118-4c65-9425-78a80d49a212";
+
+    protected static final String L2GW1 = "l2gw1";
+    protected static final String L2GW2 = "l2gw2";
+    protected static final String L2GW_CONN1 = "l2gwConnection1";
+    protected static final String L2GW_CONN2 = "l2gwConnection2";
+    protected static final String PS1 = "ps1";
+    protected static final String PS2 = "ps2";
+
+    protected static InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.tbd.params
+            .xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>
+            TOR1_NODE_IID = createInstanceIdentifier(TOR1_NODE_ID);
+    protected static InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.tbd.params
+            .xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>
+            TOR2_NODE_IID = createInstanceIdentifier(TOR2_NODE_ID);
+
     protected static final String DCGWID = DCGW_TEPIP;
 
     public static final String RD = "100:1";
@@ -125,46 +173,89 @@ public class ElanServiceTestBase {
     protected static Map<String, Pair<InterfaceInfo, String>> ELAN_INTERFACES = new HashMap<>();
     protected static Map<String, TunnelInterfaceDetails> EXTN_INTFS = new HashMap<>();
 
-
     static {
         //Adding elan dpn macs
         /*ELAN1+":"+DPN1MAC1 ->
         (vlanInterfaceInfo(String interfaceName, BigInteger dpId, int portNo, int lportTag, String mac), vmPrefix)*/
         ELAN_INTERFACES.put(ELAN1 + ":" + DPN1MAC1 ,
-                new ImmutablePair(InterfaceHelper.buildVlanInterfaceInfo("23701c04-1118-4c65-9425-78a80d49a211",
+                new ImmutablePair(InterfaceHelper
+                        .buildVlanInterfaceInfo("23701c04-1118-4c65-9425-78a80d49a211",
                 DPN1_ID, 1, 10, DPN1MAC1), DPN1IP1));
 
         ELAN_INTERFACES.put(ELAN1 + ":" + DPN1MAC2 ,
-                new ImmutablePair(InterfaceHelper.buildVlanInterfaceInfo("23701c04-1218-4c65-9425-78a80d49a211",
+                new ImmutablePair(InterfaceHelper
+                        .buildVlanInterfaceInfo("23701c04-1218-4c65-9425-78a80d49a211",
                 DPN1_ID, 2, 11, DPN1MAC2), DPN1IP2));
 
         ELAN_INTERFACES.put(ELAN1 + ":" + DPN2MAC1 ,
-                new ImmutablePair(InterfaceHelper.buildVlanInterfaceInfo("23701c04-2118-4c65-9425-78a80d49a211",
-                DPN2_ID, 3, 12, DPN2MAC1), DPN2IP1));
+                new ImmutablePair(InterfaceHelper
+                        .buildVlanInterfaceInfo("23701c04-2118-4c65-9425-78a80d49a211",
+                        DPN2_ID, 3, 12, DPN2MAC1), DPN2IP1));
 
         ELAN_INTERFACES.put(ELAN1 + ":" + DPN2MAC2 ,
-                new ImmutablePair(InterfaceHelper.buildVlanInterfaceInfo("23701c04-2218-4c65-9425-78a80d49a211",
-                DPN2_ID, 4, 13, DPN2MAC2), DPN2IP2));
+                new ImmutablePair(InterfaceHelper
+                        .buildVlanInterfaceInfo("23701c04-2218-4c65-9425-78a80d49a211",
+                        DPN2_ID, 4, 13, DPN2MAC2), DPN2IP2));
+
+        ELAN_INTERFACES.put(ELAN1 + ":" + DPN3MAC1 ,
+                new ImmutablePair(InterfaceHelper
+                        .buildVlanInterfaceInfo("23701c04-3118-4c65-9425-78a80d49a211",
+                        DPN3_ID, 5, 14, DPN3MAC1), DPN3IP1));
+
+        ELAN_INTERFACES.put(ELAN1 + ":" + DPN3MAC2 ,
+                new ImmutablePair(InterfaceHelper
+                        .buildVlanInterfaceInfo("23701c04-3218-4c65-9425-78a80d49a211",
+                        DPN3_ID, 6, 15, DPN3MAC2), DPN3IP2));
 
         //Adding the external tunnel interfaces
         EXTN_INTFS.put(DPN1_ID_STR + ":" + DPN2_ID_STR, new TunnelInterfaceDetails(DPN1_TEPIP, DPN2_TEPIP, true,
-                InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-10", DPN1_ID, 5, 14, DPN1TODPN2TNLMAC)));
+                InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-10", DPN1_ID, 5, 14, DPN1_TO_DPN2TNL_MAC)));
 
-        EXTN_INTFS.put(DPN1_ID_STR + ":" + TOR1NODEID, new TunnelInterfaceDetails(DPN1_TEPIP, TOR1_TEPIP, true,
-                InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-12", DPN1_ID, 6, 15, DPN1TOTOR1TNLMAC)));
+        EXTN_INTFS.put(DPN1_ID_STR + ":" + TOR1_NODE_ID, new TunnelInterfaceDetails(DPN1_TEPIP, TOR1_TEPIP, true,
+                InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-12", DPN1_ID, 6, 15, DPN1_TO_TOR1TNL_MAC)));
+        EXTN_INTFS.put(DPN1_ID_STR + ":" + TOR1_TEPIP, EXTN_INTFS.get(DPN1_ID_STR + ":" + TOR1_NODE_ID));
 
         EXTN_INTFS.put(DPN2_ID_STR + ":" + DPN1_ID_STR, new TunnelInterfaceDetails(DPN2_TEPIP, DPN1_TEPIP, true,
-                InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-11", DPN2_ID, 7, 16, DPN2TODPN1TNLMAC)));
+                InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-11", DPN2_ID, 7, 16, DPN2_TO_DPN1_TNL_MAC)));
+
+        EXTN_INTFS.put(DPN2_ID_STR + ":" + TOR1_NODE_ID, new TunnelInterfaceDetails(DPN2_TEPIP, TOR1_TEPIP, true,
+                InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-13", DPN2_ID, 8, 17, DPN2_TO_TOR1_TNL_MAC)));
+        EXTN_INTFS.put(DPN2_ID_STR + ":" + TOR1_TEPIP, EXTN_INTFS.get(DPN2_ID_STR + ":" + TOR1_NODE_ID));
+
+        EXTN_INTFS.put(DPN1_ID_STR + ":" + DPN3_ID_STR, new TunnelInterfaceDetails(DPN1_TEPIP, DPN3_TEPIP, true,
+                InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-14", DPN1_ID, 9, 18, DPN1_TO_DPN3_TNL_MAC)));
+
+        EXTN_INTFS.put(DPN3_ID_STR + ":" + DPN1_ID_STR, new TunnelInterfaceDetails(DPN3_TEPIP, DPN1_TEPIP, true,
+                InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-15", DPN3_ID, 10, 19, DPN3_TO_DPN1_TNL_MAC)));
 
-        EXTN_INTFS.put(DPN2_ID_STR + ":" + TOR1NODEID, new TunnelInterfaceDetails(DPN2_TEPIP, TOR1_TEPIP, true,
-                InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-13", DPN2_ID, 8, 17, DPN2TOTOR1TNLMAC)));
+        EXTN_INTFS.put(DPN3_ID_STR + ":" + DPN2_ID_STR, new TunnelInterfaceDetails(DPN3_TEPIP, DPN2_TEPIP, true,
+                InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-16", DPN3_ID, 11, 20, DPN3_TO_DPN2_TNL_MAC)));
 
+        EXTN_INTFS.put(DPN2_ID_STR + ":" + DPN3_ID_STR, new TunnelInterfaceDetails(DPN2_TEPIP, DPN3_TEPIP, true,
+                InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-17", DPN2_ID, 12, 21, DPN2_TO_DPN3_TNL_MAC)));
+
+        EXTN_INTFS.put(DPN3_ID_STR + ":" + TOR1_NODE_ID, new TunnelInterfaceDetails(DPN3_TEPIP, TOR1_TEPIP, true,
+                InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-18", DPN3_ID, 13, 22, DPN3_TO_TOR1_TNL_MAC)));
+        EXTN_INTFS.put(DPN3_ID_STR + ":" + TOR1_TEPIP, EXTN_INTFS.get(DPN3_ID_STR + ":" + TOR1_NODE_ID));
+
+        EXTN_INTFS.put(DPN1_ID_STR + ":" + TOR2_NODE_ID, new TunnelInterfaceDetails(DPN1_TEPIP, TOR2_TEPIP, true,
+                InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-19", DPN1_ID, 14, 23, DPN1_TO_TOR2_TNL_MAC)));
+        EXTN_INTFS.put(DPN1_ID_STR + ":" + TOR2_TEPIP, EXTN_INTFS.get(DPN1_ID_STR + ":" + TOR2_NODE_ID));
+
+        EXTN_INTFS.put(DPN2_ID_STR + ":" + TOR2_NODE_ID, new TunnelInterfaceDetails(DPN2_TEPIP, TOR2_TEPIP, true,
+                InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-20", DPN2_ID, 15, 24, DPN2_TO_TOR2_TNL_MAC)));
+        EXTN_INTFS.put(DPN2_ID_STR + ":" + TOR2_TEPIP, EXTN_INTFS.get(DPN2_ID_STR + ":" + TOR2_NODE_ID));
+
+        EXTN_INTFS.put(DPN3_ID_STR + ":" + TOR2_NODE_ID, new TunnelInterfaceDetails(DPN3_TEPIP, TOR2_TEPIP, true,
+                InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-21", DPN3_ID, 16, 25, DPN3_TO_TOR2_TNL_MAC)));
+        EXTN_INTFS.put(DPN3_ID_STR + ":" + TOR2_TEPIP, EXTN_INTFS.get(DPN3_ID_STR + ":" + TOR2_NODE_ID));
 
         EXTN_INTFS.put(DPN1_ID_STR + ":" + DCGWID, new TunnelInterfaceDetails(DPN1_TEPIP, DCGW_TEPIP, true,
-                InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-14", DPN1_ID, 9, 18, DPN1TODCGWTNLMAC)));
+                InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-22", DPN1_ID, 17, 26, DPN1_TO_DCGWTNL_MAC)));
 
         EXTN_INTFS.put(DPN2_ID_STR + ":" + DCGWID, new TunnelInterfaceDetails(DPN2_TEPIP, DCGWID, true,
-                InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-15", DPN2_ID, 10, 19, DPN2TODCGWTNLMAC)));
+                InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-23", DPN2_ID, 18, 27, DPN2_TO_DCGW_TNL_MAC)));
+
     }
 
     protected ConditionFactory getAwaiter() {
@@ -208,27 +299,82 @@ public class ElanServiceTestBase {
         return null;
     }
 
+    protected static InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology
+            .rev131021.network.topology.topology.Node> createInstanceIdentifier(String nodeIdString) {
+        org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId nodeId
+                = new org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network
+                .topology.rev131021.NodeId(new Uri(nodeIdString));
+        org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology
+                .topology.NodeKey nodeKey = new org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang
+                .network.topology.rev131021.network.topology.topology.NodeKey(nodeId);
+        TopologyKey topoKey = new TopologyKey(new TopologyId(new Uri("hwvtep:1")));
+        return InstanceIdentifier.builder(NetworkTopology.class)
+                .child(Topology.class, topoKey)
+                .child(org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang
+                        .network.topology.rev131021.network.topology.topology.Node.class, nodeKey)
+                .build();
+    }
+
+
     protected void setupItm() throws TransactionCommitFailedException {
         /*Add tap port and tunnel ports in DPN1 and DPN2*/
         interfaceMgr.addInterfaceInfo(ELAN_INTERFACES.get(ELAN1 + ":" + DPN1MAC1).getLeft());
         interfaceMgr.addInterfaceInfo(ELAN_INTERFACES.get(ELAN1 + ":" + DPN1MAC2).getLeft());
         interfaceMgr.addInterfaceInfo(ELAN_INTERFACES.get(ELAN1 + ":" + DPN2MAC1).getLeft());
         interfaceMgr.addInterfaceInfo(ELAN_INTERFACES.get(ELAN1 + ":" + DPN2MAC2).getLeft());
+        interfaceMgr.addInterfaceInfo(ELAN_INTERFACES.get(ELAN1 + ":" + DPN3MAC1).getLeft());
+        interfaceMgr.addInterfaceInfo(ELAN_INTERFACES.get(ELAN1 + ":" + DPN3MAC2).getLeft());
+
         interfaceMgr.addTunnelInterface(EXTN_INTFS.get(DPN1_ID_STR + ":" + DPN2_ID_STR));
         interfaceMgr.addTunnelInterface(EXTN_INTFS.get(DPN2_ID_STR + ":" + DPN1_ID_STR));
+        interfaceMgr.addTunnelInterface(EXTN_INTFS.get(DPN1_ID_STR + ":" + DPN3_ID_STR));
+        interfaceMgr.addTunnelInterface(EXTN_INTFS.get(DPN3_ID_STR + ":" + DPN1_ID_STR));
+        interfaceMgr.addTunnelInterface(EXTN_INTFS.get(DPN2_ID_STR + ":" + DPN3_ID_STR));
+        interfaceMgr.addTunnelInterface(EXTN_INTFS.get(DPN3_ID_STR + ":" + DPN2_ID_STR));
+
+        interfaceMgr.addTunnelInterface(EXTN_INTFS.get(DPN1_ID_STR + ":" + TOR1_NODE_ID));
+        interfaceMgr.addTunnelInterface(EXTN_INTFS.get(DPN2_ID_STR + ":" + TOR1_NODE_ID));
+        interfaceMgr.addTunnelInterface(EXTN_INTFS.get(DPN3_ID_STR + ":" + TOR1_NODE_ID));
+        interfaceMgr.addTunnelInterface(EXTN_INTFS.get(DPN1_ID_STR + ":" + TOR2_NODE_ID));
+        interfaceMgr.addTunnelInterface(EXTN_INTFS.get(DPN2_ID_STR + ":" + TOR2_NODE_ID));
+        interfaceMgr.addTunnelInterface(EXTN_INTFS.get(DPN3_ID_STR + ":" + TOR2_NODE_ID));
 
         /*Add DPN1 and DPN2 TEPs*/
         itmRpc.addDpn(DPN1_ID, DPN1_TEPIP);
         itmRpc.addDpn(DPN2_ID, DPN2_TEPIP);
+        itmRpc.addDpn(DPN3_ID, DPN3_TEPIP);
 
         /*add external interface*/
         itmRpc.addInterface(DPN1_ID,
                 DPN2_TEPIP, EXTN_INTFS.get(DPN1_ID_STR + ":" + DPN2_ID_STR).getInterfaceInfo().getInterfaceName());
         itmRpc.addInterface(DPN2_ID,
                 DPN1_TEPIP, EXTN_INTFS.get(DPN2_ID_STR + ":" + DPN1_ID_STR).getInterfaceInfo().getInterfaceName());
+        itmRpc.addInterface(DPN1_ID,
+                DPN3_TEPIP, EXTN_INTFS.get(DPN1_ID_STR + ":" + DPN3_ID_STR).getInterfaceInfo().getInterfaceName());
+        itmRpc.addInterface(DPN3_ID,
+                DPN1_TEPIP, EXTN_INTFS.get(DPN3_ID_STR + ":" + DPN1_ID_STR).getInterfaceInfo().getInterfaceName());
+        itmRpc.addInterface(DPN2_ID,
+                DPN3_TEPIP, EXTN_INTFS.get(DPN2_ID_STR + ":" + DPN3_ID_STR).getInterfaceInfo().getInterfaceName());
+        itmRpc.addInterface(DPN3_ID,
+                DPN2_TEPIP, EXTN_INTFS.get(DPN3_ID_STR + ":" + DPN2_ID_STR).getInterfaceInfo().getInterfaceName());
 
-        itmRpc.addExternalInterface(DPN1_ID,
+
+        itmRpc.addL2GwInterface(DPN1_ID,
                 DCGWID, EXTN_INTFS.get(DPN1_ID_STR + ":" + DCGWID).getInterfaceInfo().getInterfaceName());
+        itmRpc.addL2GwInterface(DPN1_ID,
+                TOR1_NODE_ID, EXTN_INTFS.get(DPN1_ID_STR + ":" + TOR1_NODE_ID).getInterfaceInfo().getInterfaceName());
+        itmRpc.addL2GwInterface(DPN2_ID,
+                TOR1_NODE_ID, EXTN_INTFS.get(DPN2_ID_STR + ":" + TOR1_NODE_ID).getInterfaceInfo().getInterfaceName());
+        itmRpc.addL2GwInterface(DPN3_ID,
+                TOR1_NODE_ID, EXTN_INTFS.get(DPN3_ID_STR + ":" + TOR1_NODE_ID).getInterfaceInfo().getInterfaceName());
+        itmRpc.addL2GwInterface(DPN1_ID,
+                TOR2_NODE_ID, EXTN_INTFS.get(DPN1_ID_STR + ":" + TOR2_NODE_ID).getInterfaceInfo().getInterfaceName());
+        itmRpc.addL2GwInterface(DPN2_ID,
+                TOR2_NODE_ID, EXTN_INTFS.get(DPN2_ID_STR + ":" + TOR2_NODE_ID).getInterfaceInfo().getInterfaceName());
+        itmRpc.addL2GwInterface(DPN3_ID,
+                TOR2_NODE_ID, EXTN_INTFS.get(DPN3_ID_STR + ":" + TOR2_NODE_ID).getInterfaceInfo().getInterfaceName());
+
+
     }
 
     protected InstanceIdentifier<Flow> getFlowIid(short tableId, FlowId flowid, BigInteger dpnId) {
@@ -237,10 +383,10 @@ public class ElanServiceTestBase {
         NodeId nodeId =
                 new NodeId("openflow:" + dpnId);
         Node nodeDpn =
-                new NodeBuilder().setId(nodeId).setKey(new NodeKey(nodeId)).build();
+                new NodeBuilder().setId(nodeId).withKey(new NodeKey(nodeId)).build();
         return InstanceIdentifier.builder(Nodes.class)
                 .child(Node.class,
-                        nodeDpn.getKey()).augmentation(FlowCapableNode.class)
+                        nodeDpn.key()).augmentation(FlowCapableNode.class)
                 .child(Table.class, new TableKey(tableId)).child(Flow.class, flowKey).build();
     }
 
@@ -259,7 +405,7 @@ public class ElanServiceTestBase {
             ElanInterfaceBuilder elanInterfaceBuilder = new ElanInterfaceBuilder()
                     .setElanInstanceName(elanInstanceName)
                     .setName(interfaceName)
-                    .setKey(new ElanInterfaceKey(interfaceName));
+                    .withKey(new ElanInterfaceKey(interfaceName));
 
             StaticMacEntriesBuilder staticMacEntriesBuilder = new StaticMacEntriesBuilder();
             List<StaticMacEntries> staticMacEntries = new ArrayList<>();