elanmanager/impl/src/test/java/org/opendaylight/netvirt/elanmanager/tests/ElanServiceTestBase.java

   1 /*
   2  * Copyright © 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 package org.opendaylight.netvirt.elanmanager.tests;
   9
  10 import com.google.common.collect.Lists;
  11 import java.util.ArrayList;
  12 import java.util.Collections;
  13 import java.util.Comparator;
  14 import java.util.HashMap;
  15 import java.util.List;
  16 import java.util.Map;
  17 import java.util.concurrent.ExecutionException;
  18 import java.util.concurrent.TimeUnit;
  19 import javax.inject.Inject;
  20 import org.apache.commons.lang3.tuple.ImmutablePair;
  21 import org.apache.commons.lang3.tuple.Pair;
  22 import org.awaitility.Awaitility;
  23 import org.awaitility.core.ConditionFactory;
  24 import org.opendaylight.genius.datastoreutils.SingleTransactionDataBroker;
  25 import org.opendaylight.genius.interfacemanager.globals.InterfaceInfo;
  26 import org.opendaylight.genius.mdsalutil.MDSALUtil;
  27 import org.opendaylight.genius.testutils.TestInterfaceManager;
  28 import org.opendaylight.genius.testutils.interfacemanager.TunnelInterfaceDetails;
  29 import org.opendaylight.genius.testutils.itm.ItmRpcTestImpl;
  30 import org.opendaylight.mdsal.binding.api.DataBroker;
  31 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
  32 import org.opendaylight.mdsal.common.api.TransactionCommitFailedException;
  33 import org.opendaylight.netvirt.elan.cache.ElanInstanceCache;
  34 import org.opendaylight.netvirt.elan.internal.ElanInstanceManager;
  35 import org.opendaylight.netvirt.elan.utils.ElanUtils;
  36 import org.opendaylight.netvirt.elanmanager.api.ElanHelper;
  37 import org.opendaylight.netvirt.elanmanager.tests.utils.InterfaceHelper;
  38 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
  39 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Address;
  40 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Uri;
  41 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.PhysAddress;
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.Ordered;
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.list.Action;
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNode;
  45 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowId;
  46 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.Table;
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.TableKey;
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow;
  49 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.FlowBuilder;
  50 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.FlowKey;
  51 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.flow.Instructions;
  52 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.flow.InstructionsBuilder;
  53 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.instruction.ApplyActionsCase;
  54 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.instruction.ApplyActionsCaseBuilder;
  55 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.instruction.apply.actions._case.ApplyActions;
  56 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.instruction.apply.actions._case.ApplyActionsBuilder;
  57 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.list.InstructionBuilder;
  58 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rpcs.rev160406.OdlInterfaceRpcService;
  59 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeId;
  60 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.Nodes;
  61 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
  62 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeBuilder;
  63 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeKey;
  64 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.elan.rev150602.elan.instances.ElanInstance;
  65 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.elan.rev150602.elan.interfaces.ElanInterface;
  66 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.elan.rev150602.elan.interfaces.ElanInterfaceBuilder;
  67 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.elan.rev150602.elan.interfaces.ElanInterfaceKey;
  68 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.elan.rev150602.elan.interfaces.elan._interface.StaticMacEntries;
  69 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.elan.rev150602.elan.interfaces.elan._interface.StaticMacEntriesBuilder;
  70 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NetworkTopology;
  71 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.TopologyId;
  72 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
  73 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.TopologyKey;
  74 import org.opendaylight.yangtools.yang.binding.DataObject;
  75 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  76 import org.opendaylight.yangtools.yang.common.Uint32;
  77 import org.opendaylight.yangtools.yang.common.Uint64;
  78
  79 public class ElanServiceTestBase {
  80
  81     protected  @Inject DataBroker dataBroker;
  82     protected  @Inject TestInterfaceManager interfaceMgr;
  83     protected  @Inject ItmRpcTestImpl itmRpc;
  84     protected  @Inject ElanInstanceManager elanInstanceManager;
  85     protected  @Inject ElanInstanceCache elanInstanceCache;
  86     protected @Inject SingleTransactionDataBroker singleTxdataBroker;
  87     protected @Inject OdlInterfaceRpcService odlInterfaceRpcService;
  88     public static final String ELAN1 = "34701c04-1118-4c65-9425-78a80d49a211";
  89     public static final Uint32 ELAN1_SEGMENT_ID = Uint32.valueOf(100L);
  90
  91     protected static final Uint64 DPN1_ID = Uint64.valueOf("1").intern();
  92     protected static final Uint64 DPN2_ID = Uint64.valueOf("2").intern();
  93     protected static final Uint64 DPN3_ID = Uint64.valueOf("3").intern();
  94
  95     protected static final String DPN1_ID_STR = "1";
  96     protected static final String DPN2_ID_STR = "2";
  97     protected static final String DPN3_ID_STR = "3";
  98
  99     protected static final String DPN1_TEPIP = "192.168.56.30";
 100     protected static final String DPN2_TEPIP = "192.168.56.40";
 101     protected static final String DPN3_TEPIP = "192.168.56.50";
 102     protected static final String TOR1_TEPIP = "192.168.56.60";
 103     protected static final String TOR2_TEPIP = "192.168.56.70";
 104     public static final String DCGW_TEPIP = "192.168.56.80";
 105
 106     protected static final String DPN1MAC1 = "10:00:00:00:00:01";
 107     protected static final String DPN1MAC2 = "10:00:00:00:00:02";
 108
 109     protected static final String DPN2MAC1 = "10:00:00:00:00:03";
 110     protected static final String DPN2MAC2 = "10:00:00:00:00:04";
 111
 112     protected static final String DPN3MAC1 = "10:00:00:00:00:05";
 113     protected static final String DPN3MAC2 = "10:00:00:00:00:06";
 114
 115     protected static final String TOR1_MAC1 = "10:00:00:00:00:07";
 116     protected static final String TOR1_IP1 = "10.0.0.1";
 117     protected static final String TOR1_MAC2 = "10:00:00:00:00:08";
 118     protected static final String TOR1_IP2 = "10.0.0.2";
 119
 120     protected static final String TOR2_MAC1 = "10:00:00:00:00:09";
 121     protected static final String TOR2_MAC2 = "10:00:00:00:00:10";
 122
 123     protected static final String DPN1_TO_DPN2TNL_MAC = "91:00:00:00:00:01";
 124     protected static final String DPN1_TO_TOR1TNL_MAC = "91:00:00:00:00:02";
 125     protected static final String DPN1_TO_DCGWTNL_MAC = "91:00:00:00:00:03";
 126     protected static final String DPN1_TO_DPN3_TNL_MAC = "91:00:00:00:00:04";
 127
 128     protected static final String DPN2_TO_DPN1_TNL_MAC = "92:00:00:00:00:01";
 129     protected static final String DPN2_TO_TOR1_TNL_MAC = "92:00:00:00:00:02";
 130     protected static final String DPN2_TO_DCGW_TNL_MAC = "92:00:00:00:00:03";
 131     protected static final String DPN2_TO_DPN3_TNL_MAC = "92:00:00:00:00:04";
 132
 133     protected static final String DPN3_TO_DPN1_TNL_MAC = "93:00:00:00:00:01";
 134     protected static final String DPN3_TO_DPN2_TNL_MAC = "93:00:00:00:00:02";
 135     protected static final String DPN3_TO_TOR1_TNL_MAC = "93:00:00:00:00:03";
 136
 137     protected static final String DPN1_TO_TOR2_TNL_MAC = "94:00:00:00:00:01";
 138     protected static final String DPN2_TO_TOR2_TNL_MAC = "94:00:00:00:00:02";
 139     protected static final String DPN3_TO_TOR2_TNL_MAC = "94:00:00:00:00:03";
 140
 141
 142     protected static final String DPN1IP1 = "10.0.0.11";
 143     protected static final String DPN1IP2 = "10.0.0.12";
 144     protected static final String DPN2IP1 = "10.0.0.13";
 145     protected static final String DPN2IP2 = "10.0.0.14";
 146     protected static final String DPN3IP1 = "10.0.0.15";
 147     protected static final String DPN3IP2 = "10.0.0.16";
 148
 149     protected static final String EVPNRECVMAC1 = "10:00:00:00:00:51";
 150     protected static final String EVPNRECVMAC2 = "10:00:00:00:00:52";
 151
 152     protected static final String EVPNRECVIP1 = "192.168.122.51";
 153     protected static final String EVPNRECVIP2 = "192.168.122.52";
 154
 155     protected static final String TOR1_NODE_ID = "hwvtep://uuid/34701c04-1118-4c65-9425-78a80d49a211";
 156     protected static final String TOR2_NODE_ID = "hwvtep://uuid/34701c04-1118-4c65-9425-78a80d49a212";
 157
 158     protected static final String L2GW1 = "l2gw1";
 159     protected static final String L2GW2 = "l2gw2";
 160     protected static final String L2GW_CONN1 = "l2gwConnection1";
 161     protected static final String L2GW_CONN2 = "l2gwConnection2";
 162     protected static final String PS1 = "ps1";
 163     protected static final String PS2 = "ps2";
 164
 165     protected static InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.tbd.params
 166             .xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>
 167             TOR1_NODE_IID = createInstanceIdentifier(TOR1_NODE_ID);
 168     protected static InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.tbd.params
 169             .xml.ns.yang.network.topology.rev131021.network.topology.topology.Node>
 170             TOR2_NODE_IID = createInstanceIdentifier(TOR2_NODE_ID);
 171
 172     protected static final String DCGWID = DCGW_TEPIP;
 173
 174     public static final String RD = "100:1";
 175     public static final String EVPN1 = "evpn1";
 176
 177     protected static Map<String, Pair<InterfaceInfo, String>> ELAN_INTERFACES = new HashMap<>();
 178     protected static Map<String, TunnelInterfaceDetails> EXTN_INTFS = new HashMap<>();
 179
 180     static {
 181         //Adding elan dpn macs
 182         /*ELAN1+":"+DPN1MAC1 ->
 183         (vlanInterfaceInfo(String interfaceName, BigInteger dpId, int portNo, int lportTag, String mac), vmPrefix)*/
 184         ELAN_INTERFACES.put(ELAN1 + ":" + DPN1MAC1 ,
 185                 ImmutablePair.of(InterfaceHelper
 186                         .buildVlanInterfaceInfo("23701c04-1118-4c65-9425-78a80d49a211",
 187                 DPN1_ID, 1, 10, DPN1MAC1), DPN1IP1));
 188
 189         ELAN_INTERFACES.put(ELAN1 + ":" + DPN1MAC2 ,
 190                 ImmutablePair.of(InterfaceHelper
 191                         .buildVlanInterfaceInfo("23701c04-1218-4c65-9425-78a80d49a211",
 192                 DPN1_ID, 2, 11, DPN1MAC2), DPN1IP2));
 193
 194         ELAN_INTERFACES.put(ELAN1 + ":" + DPN2MAC1 ,
 195                 ImmutablePair.of(InterfaceHelper
 196                         .buildVlanInterfaceInfo("23701c04-2118-4c65-9425-78a80d49a211",
 197                         DPN2_ID, 3, 12, DPN2MAC1), DPN2IP1));
 198
 199         ELAN_INTERFACES.put(ELAN1 + ":" + DPN2MAC2 ,
 200                 ImmutablePair.of(InterfaceHelper
 201                         .buildVlanInterfaceInfo("23701c04-2218-4c65-9425-78a80d49a211",
 202                         DPN2_ID, 4, 13, DPN2MAC2), DPN2IP2));
 203
 204         ELAN_INTERFACES.put(ELAN1 + ":" + DPN3MAC1 ,
 205                 ImmutablePair.of(InterfaceHelper
 206                         .buildVlanInterfaceInfo("23701c04-3118-4c65-9425-78a80d49a211",
 207                         DPN3_ID, 5, 14, DPN3MAC1), DPN3IP1));
 208
 209         ELAN_INTERFACES.put(ELAN1 + ":" + DPN3MAC2 ,
 210                 ImmutablePair.of(InterfaceHelper
 211                         .buildVlanInterfaceInfo("23701c04-3218-4c65-9425-78a80d49a211",
 212                         DPN3_ID, 6, 15, DPN3MAC2), DPN3IP2));
 213
 214         //Adding the external tunnel interfaces
 215         EXTN_INTFS.put(DPN1_ID_STR + ":" + DPN2_ID_STR, new TunnelInterfaceDetails(DPN1_TEPIP, DPN2_TEPIP, true,
 216                 InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-10", DPN1_ID, 5, 14, DPN1_TO_DPN2TNL_MAC)));
 217
 218         EXTN_INTFS.put(DPN1_ID_STR + ":" + TOR1_NODE_ID, new TunnelInterfaceDetails(DPN1_TEPIP, TOR1_TEPIP, true,
 219                 InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-12", DPN1_ID, 6, 15, DPN1_TO_TOR1TNL_MAC)));
 220         EXTN_INTFS.put(DPN1_ID_STR + ":" + TOR1_TEPIP, EXTN_INTFS.get(DPN1_ID_STR + ":" + TOR1_NODE_ID));
 221
 222         EXTN_INTFS.put(DPN2_ID_STR + ":" + DPN1_ID_STR, new TunnelInterfaceDetails(DPN2_TEPIP, DPN1_TEPIP, true,
 223                 InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-11", DPN2_ID, 7, 16, DPN2_TO_DPN1_TNL_MAC)));
 224
 225         EXTN_INTFS.put(DPN2_ID_STR + ":" + TOR1_NODE_ID, new TunnelInterfaceDetails(DPN2_TEPIP, TOR1_TEPIP, true,
 226                 InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-13", DPN2_ID, 8, 17, DPN2_TO_TOR1_TNL_MAC)));
 227         EXTN_INTFS.put(DPN2_ID_STR + ":" + TOR1_TEPIP, EXTN_INTFS.get(DPN2_ID_STR + ":" + TOR1_NODE_ID));
 228
 229         EXTN_INTFS.put(DPN1_ID_STR + ":" + DPN3_ID_STR, new TunnelInterfaceDetails(DPN1_TEPIP, DPN3_TEPIP, true,
 230                 InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-14", DPN1_ID, 9, 18, DPN1_TO_DPN3_TNL_MAC)));
 231
 232         EXTN_INTFS.put(DPN3_ID_STR + ":" + DPN1_ID_STR, new TunnelInterfaceDetails(DPN3_TEPIP, DPN1_TEPIP, true,
 233                 InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-15", DPN3_ID, 10, 19, DPN3_TO_DPN1_TNL_MAC)));
 234
 235         EXTN_INTFS.put(DPN3_ID_STR + ":" + DPN2_ID_STR, new TunnelInterfaceDetails(DPN3_TEPIP, DPN2_TEPIP, true,
 236                 InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-16", DPN3_ID, 11, 20, DPN3_TO_DPN2_TNL_MAC)));
 237
 238         EXTN_INTFS.put(DPN2_ID_STR + ":" + DPN3_ID_STR, new TunnelInterfaceDetails(DPN2_TEPIP, DPN3_TEPIP, true,
 239                 InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-17", DPN2_ID, 12, 21, DPN2_TO_DPN3_TNL_MAC)));
 240
 241         EXTN_INTFS.put(DPN3_ID_STR + ":" + TOR1_NODE_ID, new TunnelInterfaceDetails(DPN3_TEPIP, TOR1_TEPIP, true,
 242                 InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-18", DPN3_ID, 13, 22, DPN3_TO_TOR1_TNL_MAC)));
 243         EXTN_INTFS.put(DPN3_ID_STR + ":" + TOR1_TEPIP, EXTN_INTFS.get(DPN3_ID_STR + ":" + TOR1_NODE_ID));
 244
 245         EXTN_INTFS.put(DPN1_ID_STR + ":" + TOR2_NODE_ID, new TunnelInterfaceDetails(DPN1_TEPIP, TOR2_TEPIP, true,
 246                 InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-19", DPN1_ID, 14, 23, DPN1_TO_TOR2_TNL_MAC)));
 247         EXTN_INTFS.put(DPN1_ID_STR + ":" + TOR2_TEPIP, EXTN_INTFS.get(DPN1_ID_STR + ":" + TOR2_NODE_ID));
 248
 249         EXTN_INTFS.put(DPN2_ID_STR + ":" + TOR2_NODE_ID, new TunnelInterfaceDetails(DPN2_TEPIP, TOR2_TEPIP, true,
 250                 InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-20", DPN2_ID, 15, 24, DPN2_TO_TOR2_TNL_MAC)));
 251         EXTN_INTFS.put(DPN2_ID_STR + ":" + TOR2_TEPIP, EXTN_INTFS.get(DPN2_ID_STR + ":" + TOR2_NODE_ID));
 252
 253         EXTN_INTFS.put(DPN3_ID_STR + ":" + TOR2_NODE_ID, new TunnelInterfaceDetails(DPN3_TEPIP, TOR2_TEPIP, true,
 254                 InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-21", DPN3_ID, 16, 25, DPN3_TO_TOR2_TNL_MAC)));
 255         EXTN_INTFS.put(DPN3_ID_STR + ":" + TOR2_TEPIP, EXTN_INTFS.get(DPN3_ID_STR + ":" + TOR2_NODE_ID));
 256
 257         EXTN_INTFS.put(DPN1_ID_STR + ":" + DCGWID, new TunnelInterfaceDetails(DPN1_TEPIP, DCGW_TEPIP, true,
 258                 InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-22", DPN1_ID, 17, 26, DPN1_TO_DCGWTNL_MAC)));
 259
 260         EXTN_INTFS.put(DPN2_ID_STR + ":" + DCGWID, new TunnelInterfaceDetails(DPN2_TEPIP, DCGWID, true,
 261                 InterfaceHelper.buildVxlanInterfaceInfo("tun23701c04-23", DPN2_ID, 18, 27, DPN2_TO_DCGW_TNL_MAC)));
 262
 263     }
 264
 265     protected ConditionFactory getAwaiter() {
 266         return Awaitility.await("TestableListener")
 267                 .atMost(30, TimeUnit.SECONDS)//TODO constant
 268                 .pollInterval(100, TimeUnit.MILLISECONDS);
 269     }
 270
 271     void awaitForData(LogicalDatastoreType dsType, InstanceIdentifier<? extends DataObject> iid) {
 272         getAwaiter().until(() -> MDSALUtil.read(dataBroker, dsType, iid).isPresent());
 273     }
 274
 275     void awaitForDataDelete(LogicalDatastoreType dsType, InstanceIdentifier<? extends DataObject> iid) {
 276         getAwaiter().until(() -> !MDSALUtil.read(dataBroker, dsType, iid).isPresent());
 277     }
 278
 279     Flow getFlowWithoutCookie(Flow flow) {
 280         FlowBuilder flowBuilder = new FlowBuilder(flow);
 281         return flowBuilder.setCookie(null).build();
 282     }
 283
 284     Flow getSortedActions(Flow flow) {
 285         FlowBuilder flowBuilder = new FlowBuilder(flow);
 286         Instructions instructions = flowBuilder.getInstructions();
 287         InstructionsBuilder builder = new InstructionsBuilder();
 288         InstructionBuilder instructionBuilder = new InstructionBuilder(instructions.getInstruction().get(0));
 289         instructionBuilder.setInstruction(sortActions(instructionBuilder.getInstruction()));
 290         builder.setInstruction(Lists.newArrayList(instructionBuilder.build()));
 291         return flowBuilder.setInstructions(builder.build()).build();
 292     }
 293
 294     org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.Instruction
 295         sortActions(org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.Instruction input) {
 296         if (input instanceof  ApplyActionsCase) {
 297             List<Action> action = new ArrayList<>(((ApplyActionsCase)input).getApplyActions().getAction());
 298             action.sort(Comparator.comparing(Ordered::getOrder));
 299
 300             ApplyActions actions = new ApplyActionsBuilder().setAction(action).build();
 301             return new ApplyActionsCaseBuilder().setApplyActions(actions).build();
 302         }
 303         return null;
 304     }
 305
 306     protected static InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology
 307             .rev131021.network.topology.topology.Node> createInstanceIdentifier(String nodeIdString) {
 308         org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId nodeId
 309                 = new org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network
 310                 .topology.rev131021.NodeId(new Uri(nodeIdString));
 311         org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology
 312                 .topology.NodeKey nodeKey = new org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang
 313                 .network.topology.rev131021.network.topology.topology.NodeKey(nodeId);
 314         TopologyKey topoKey = new TopologyKey(new TopologyId(new Uri("hwvtep:1")));
 315         return InstanceIdentifier.builder(NetworkTopology.class)
 316                 .child(Topology.class, topoKey)
 317                 .child(org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang
 318                         .network.topology.rev131021.network.topology.topology.Node.class, nodeKey)
 319                 .build();
 320     }
 321
 322
 323     protected void setupItm() throws ExecutionException, InterruptedException {
 324         /*Add tap port and tunnel ports in DPN1 and DPN2*/
 325         interfaceMgr.addInterfaceInfo(ELAN_INTERFACES.get(ELAN1 + ":" + DPN1MAC1).getLeft());
 326         interfaceMgr.addInterfaceInfo(ELAN_INTERFACES.get(ELAN1 + ":" + DPN1MAC2).getLeft());
 327         interfaceMgr.addInterfaceInfo(ELAN_INTERFACES.get(ELAN1 + ":" + DPN2MAC1).getLeft());
 328         interfaceMgr.addInterfaceInfo(ELAN_INTERFACES.get(ELAN1 + ":" + DPN2MAC2).getLeft());
 329         interfaceMgr.addInterfaceInfo(ELAN_INTERFACES.get(ELAN1 + ":" + DPN3MAC1).getLeft());
 330         interfaceMgr.addInterfaceInfo(ELAN_INTERFACES.get(ELAN1 + ":" + DPN3MAC2).getLeft());
 331
 332         interfaceMgr.addTunnelInterface(EXTN_INTFS.get(DPN1_ID_STR + ":" + DPN2_ID_STR));
 333         interfaceMgr.addTunnelInterface(EXTN_INTFS.get(DPN2_ID_STR + ":" + DPN1_ID_STR));
 334         interfaceMgr.addTunnelInterface(EXTN_INTFS.get(DPN1_ID_STR + ":" + DPN3_ID_STR));
 335         interfaceMgr.addTunnelInterface(EXTN_INTFS.get(DPN3_ID_STR + ":" + DPN1_ID_STR));
 336         interfaceMgr.addTunnelInterface(EXTN_INTFS.get(DPN2_ID_STR + ":" + DPN3_ID_STR));
 337         interfaceMgr.addTunnelInterface(EXTN_INTFS.get(DPN3_ID_STR + ":" + DPN2_ID_STR));
 338
 339         interfaceMgr.addTunnelInterface(EXTN_INTFS.get(DPN1_ID_STR + ":" + TOR1_NODE_ID));
 340         interfaceMgr.addTunnelInterface(EXTN_INTFS.get(DPN2_ID_STR + ":" + TOR1_NODE_ID));
 341         interfaceMgr.addTunnelInterface(EXTN_INTFS.get(DPN3_ID_STR + ":" + TOR1_NODE_ID));
 342         interfaceMgr.addTunnelInterface(EXTN_INTFS.get(DPN1_ID_STR + ":" + TOR2_NODE_ID));
 343         interfaceMgr.addTunnelInterface(EXTN_INTFS.get(DPN2_ID_STR + ":" + TOR2_NODE_ID));
 344         interfaceMgr.addTunnelInterface(EXTN_INTFS.get(DPN3_ID_STR + ":" + TOR2_NODE_ID));
 345
 346         /*Add DPN1 and DPN2 TEPs*/
 347         itmRpc.addDpn(DPN1_ID, DPN1_TEPIP);
 348         itmRpc.addDpn(DPN2_ID, DPN2_TEPIP);
 349         itmRpc.addDpn(DPN3_ID, DPN3_TEPIP);
 350
 351         /*add external interface*/
 352         itmRpc.addInterface(DPN1_ID,
 353                 DPN2_TEPIP, EXTN_INTFS.get(DPN1_ID_STR + ":" + DPN2_ID_STR).getInterfaceInfo().getInterfaceName());
 354         itmRpc.addInterface(DPN2_ID,
 355                 DPN1_TEPIP, EXTN_INTFS.get(DPN2_ID_STR + ":" + DPN1_ID_STR).getInterfaceInfo().getInterfaceName());
 356         itmRpc.addInterface(DPN1_ID,
 357                 DPN3_TEPIP, EXTN_INTFS.get(DPN1_ID_STR + ":" + DPN3_ID_STR).getInterfaceInfo().getInterfaceName());
 358         itmRpc.addInterface(DPN3_ID,
 359                 DPN1_TEPIP, EXTN_INTFS.get(DPN3_ID_STR + ":" + DPN1_ID_STR).getInterfaceInfo().getInterfaceName());
 360         itmRpc.addInterface(DPN2_ID,
 361                 DPN3_TEPIP, EXTN_INTFS.get(DPN2_ID_STR + ":" + DPN3_ID_STR).getInterfaceInfo().getInterfaceName());
 362         itmRpc.addInterface(DPN3_ID,
 363                 DPN2_TEPIP, EXTN_INTFS.get(DPN3_ID_STR + ":" + DPN2_ID_STR).getInterfaceInfo().getInterfaceName());
 364
 365
 366         itmRpc.addL2GwInterface(DPN1_ID,
 367                 DCGWID, EXTN_INTFS.get(DPN1_ID_STR + ":" + DCGWID).getInterfaceInfo().getInterfaceName());
 368         itmRpc.addL2GwInterface(DPN1_ID,
 369                 TOR1_NODE_ID, EXTN_INTFS.get(DPN1_ID_STR + ":" + TOR1_NODE_ID).getInterfaceInfo().getInterfaceName());
 370         itmRpc.addL2GwInterface(DPN2_ID,
 371                 TOR1_NODE_ID, EXTN_INTFS.get(DPN2_ID_STR + ":" + TOR1_NODE_ID).getInterfaceInfo().getInterfaceName());
 372         itmRpc.addL2GwInterface(DPN3_ID,
 373                 TOR1_NODE_ID, EXTN_INTFS.get(DPN3_ID_STR + ":" + TOR1_NODE_ID).getInterfaceInfo().getInterfaceName());
 374         itmRpc.addL2GwInterface(DPN1_ID,
 375                 TOR2_NODE_ID, EXTN_INTFS.get(DPN1_ID_STR + ":" + TOR2_NODE_ID).getInterfaceInfo().getInterfaceName());
 376         itmRpc.addL2GwInterface(DPN2_ID,
 377                 TOR2_NODE_ID, EXTN_INTFS.get(DPN2_ID_STR + ":" + TOR2_NODE_ID).getInterfaceInfo().getInterfaceName());
 378         itmRpc.addL2GwInterface(DPN3_ID,
 379                 TOR2_NODE_ID, EXTN_INTFS.get(DPN3_ID_STR + ":" + TOR2_NODE_ID).getInterfaceInfo().getInterfaceName());
 380
 381
 382     }
 383
 384     protected InstanceIdentifier<Flow> getFlowIid(short tableId, FlowId flowid, Uint64 dpnId) {
 385
 386         FlowKey flowKey = new FlowKey(new FlowId(flowid));
 387         NodeId nodeId =
 388                 new NodeId("openflow:" + dpnId);
 389         Node nodeDpn =
 390                 new NodeBuilder().setId(nodeId).withKey(new NodeKey(nodeId)).build();
 391         return InstanceIdentifier.builder(Nodes.class)
 392                 .child(Node.class,
 393                         nodeDpn.key()).augmentation(FlowCapableNode.class)
 394                 .child(Table.class, new TableKey(tableId)).child(Flow.class, flowKey).build();
 395     }
 396
 397
 398     protected void createElanInstance(String elan1, Uint32 elan1SegmentId) {
 399         ElanInstance elanInstance = ExpectedObjects.createElanInstance(elan1, elan1SegmentId);
 400         MDSALUtil.syncWrite(dataBroker, LogicalDatastoreType.CONFIGURATION,
 401                 ElanHelper.getElanInstanceConfigurationDataPath(elan1), elanInstance);
 402     }
 403
 404     public void addElanInterface(String elanInstanceName, InterfaceInfo interfaceInfo, String prefix) {
 405         ElanInstance existingElanInstance = elanInstanceCache.get(elanInstanceName).orElse(null);
 406         String interfaceName = interfaceInfo.getInterfaceName();
 407
 408         if (existingElanInstance != null) {
 409             ElanInterfaceBuilder elanInterfaceBuilder = new ElanInterfaceBuilder()
 410                     .setElanInstanceName(elanInstanceName)
 411                     .setName(interfaceName)
 412                     .withKey(new ElanInterfaceKey(interfaceName));
 413
 414             StaticMacEntriesBuilder staticMacEntriesBuilder = new StaticMacEntriesBuilder();
 415             List<StaticMacEntries> staticMacEntries = new ArrayList<>();
 416             List<PhysAddress> physAddressList = Collections.singletonList(
 417                     new PhysAddress(interfaceInfo.getMacAddress()));
 418             for (PhysAddress physAddress : physAddressList) {
 419                 staticMacEntries.add(staticMacEntriesBuilder.setMacAddress(physAddress)
 420                         .setIpPrefix(new IpAddress(new Ipv4Address(prefix))).build());
 421             }
 422             elanInterfaceBuilder.setStaticMacEntries(staticMacEntries);
 423             ElanInterface elanInterface = elanInterfaceBuilder.build();
 424
 425             MDSALUtil.syncWrite(dataBroker, LogicalDatastoreType.CONFIGURATION,
 426                     ElanUtils.getElanInterfaceConfigurationDataPathId(interfaceName), elanInterface);
 427         }
 428     }
 429
 430     public void deleteElanInterface(InterfaceInfo interfaceInfo) throws TransactionCommitFailedException {
 431         String interfaceName = interfaceInfo.getInterfaceName();
 432         singleTxdataBroker.syncDelete(LogicalDatastoreType.CONFIGURATION,
 433                 ElanUtils.getElanInterfaceConfigurationDataPathId(interfaceName));
 434
 435     }
 436 }