interfacemanager/interfacemanager-impl/src/test/java/org/opendaylight/genius/interfacemanager/test/InterfaceManagerTestUtil.java

   1 /*
   2  * Copyright (c) 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 package org.opendaylight.genius.interfacemanager.test;
   9
  10 import static org.opendaylight.mdsal.common.api.LogicalDatastoreType.CONFIGURATION;
  11 import static org.opendaylight.mdsal.common.api.LogicalDatastoreType.OPERATIONAL;
  12
  13 import java.math.BigInteger;
  14 import java.util.ArrayList;
  15 import java.util.Arrays;
  16 import java.util.List;
  17 import java.util.concurrent.ExecutionException;
  18 import org.awaitility.core.ConditionTimeoutException;
  19 import org.opendaylight.genius.datastoreutils.testutils.AsyncEventsWaiter;
  20 import org.opendaylight.genius.datastoreutils.testutils.JobCoordinatorCountedEventsWaiter;
  21 import org.opendaylight.genius.interfacemanager.IfmConstants;
  22 import org.opendaylight.genius.interfacemanager.IfmUtil;
  23 import org.opendaylight.genius.interfacemanager.renderer.ovs.utilities.SouthboundUtils;
  24 import org.opendaylight.genius.mdsalutil.MDSALUtil;
  25 import org.opendaylight.genius.mdsalutil.MetaDataUtil;
  26 import org.opendaylight.genius.mdsalutil.NwConstants;
  27 import org.opendaylight.mdsal.binding.api.DataBroker;
  28 import org.opendaylight.mdsal.binding.api.WriteTransaction;
  29 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.iana._if.type.rev170119.L2vlan;
  30 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.iana._if.type.rev170119.Tunnel;
  31 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
  32 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Address;
  33 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Uri;
  34 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.InterfaceType;
  35 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface;
  36 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.InterfaceBuilder;
  37 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.InterfaceKey;
  38 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.MacAddress;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.list.Action;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNodeConnector;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNodeConnectorBuilder;
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortConfig;
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.flow.capable.port.State;
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.flow.capable.port.StateBuilder;
  45 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.list.Instruction;
  46 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.IfL2vlan;
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.IfL2vlanBuilder;
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.IfTunnel;
  49 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.IfTunnelBuilder;
  50 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.ParentRefs;
  51 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.ParentRefsBuilder;
  52 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.TunnelMonitoringTypeBfd;
  53 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.TunnelTypeBase;
  54 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.TunnelTypeVxlan;
  55 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.servicebinding.rev160406.ServiceBindings;
  56 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.servicebinding.rev160406.ServiceModeIngress;
  57 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.servicebinding.rev160406.ServiceTypeFlowBased;
  58 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.servicebinding.rev160406.StypeOpenflowBuilder;
  59 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.servicebinding.rev160406.service.bindings.ServicesInfo;
  60 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.servicebinding.rev160406.service.bindings.ServicesInfoKey;
  61 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.servicebinding.rev160406.service.bindings.services.info.BoundServices;
  62 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.servicebinding.rev160406.service.bindings.services.info.BoundServicesBuilder;
  63 import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.servicebinding.rev160406.service.bindings.services.info.BoundServicesKey;
  64 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorId;
  65 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeId;
  66 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.Nodes;
  67 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.node.NodeConnector;
  68 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.node.NodeConnectorBuilder;
  69 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.node.NodeConnectorKey;
  70 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
  71 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeBuilder;
  72 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeKey;
  73 import org.opendaylight.yang.gen.v1.urn.opendaylight.l2.types.rev130827.VlanId;
  74 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.TopologyId;
  75 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.node.TerminationPoint;
  76 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  77 import org.opendaylight.yangtools.yang.common.Uint64;
  78 import org.slf4j.Logger;
  79 import org.slf4j.LoggerFactory;
  80
  81 public final class InterfaceManagerTestUtil {
  82     private static final Logger LOG = LoggerFactory.getLogger(InterfaceManagerConfigurationTest.class);
  83     public static final String PARENT_INTERFACE = "tap23701c04-7e";
  84     public static final String DEVICE_PORT = "eth0";
  85     public static final String PARENT_INTERFACE_1 = "tap23701c04-7f";
  86     public static final String PARENT_INTERFACE_2 = "tap23702c04-7f";
  87     public static final String INTERFACE_NAME = "23701c04-7e58-4c65-9425-78a80d49a218";
  88     public static final String INTERFACE_NAME_1 = "23701c04-7e58-4c65-9425-78a80d49a220";
  89     public static final String INTERFACE_NAME_2 = "23701c04-7e58-4c65-9425-78a80d49a221";
  90     public static final String TUNNEL_INTERFACE_NAME = "tun414a856a7a4";
  91     public static final String TRUNK_INTERFACE_NAME = "23701c04-7e58-4c65-9425-78a80d49a219";
  92
  93     public static final Uint64 DPN_ID_1 = Uint64.ONE;
  94     public static final Uint64 DPN_ID_2 = Uint64.valueOf(2);
  95     public static final long PORT_NO_1 = 2;
  96
  97     public static final TopologyId OVSDB_TOPOLOGY_ID = new TopologyId(new Uri("ovsdb:1"));
  98     public static final NodeKey NODE_KEY = new NodeKey(new NodeId("openflow:1"));
  99
 100     private InterfaceManagerTestUtil() {
 101
 102     }
 103
 104     static org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface
 105         buildStateInterface(String ifName, String dpnId, String portNo, String phyAddress,
 106                             Class<? extends InterfaceType> ifType) {
 107         org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang
 108                 .ietf.interfaces.rev140508.interfaces.state.InterfaceBuilder ifaceBuilder =
 109                 new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang
 110                         .ietf.interfaces.rev140508.interfaces.state.InterfaceBuilder();
 111         if (ifType != null) {
 112             ifaceBuilder.setType(ifType);
 113         }
 114         ifaceBuilder.withKey(IfmUtil.getStateInterfaceKeyFromName(ifName));
 115         ifaceBuilder.setOperStatus(
 116                 org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang
 117                         .ietf.interfaces.rev140508.interfaces.state.Interface.OperStatus.Up);
 118         ifaceBuilder.setLowerLayerIf(Arrays.asList("openflow:" + dpnId + ":" + portNo));
 119         if (phyAddress != null) {
 120             ifaceBuilder.setPhysAddress(
 121                     org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.PhysAddress
 122                             .getDefaultInstance(phyAddress));
 123         }
 124         ifaceBuilder.setIfIndex(1);
 125         return ifaceBuilder.build();
 126     }
 127
 128     static Node buildInventoryDpnNode(Uint64 dpnId) {
 129         NodeId nodeId = new NodeId("openflow:" + dpnId);
 130         Node nodeDpn = new NodeBuilder().setId(nodeId).withKey(new NodeKey(nodeId)).build();
 131
 132         return nodeDpn;
 133     }
 134
 135
 136     static org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.node.NodeConnector
 137         buildFlowCapableNodeConnector(NodeConnectorId ncId, String portName, boolean isLive) {
 138         NodeConnectorBuilder ncBuilder = new NodeConnectorBuilder()
 139                 .setId(ncId)
 140                 .withKey(new NodeConnectorKey(ncId));
 141         ncBuilder.addAugmentation(buildFlowCapableNodeConnector(false, isLive,"AA:AA:AA:AA:AA:AA", portName));
 142         return ncBuilder.build();
 143     }
 144
 145     static FlowCapableNodeConnector buildFlowCapableNodeConnector(boolean isPortDown, boolean isLive,
 146                                                                   String macAddress, String portName) {
 147         PortConfig portConfig = new PortConfig(false, false, false, isPortDown);
 148         State state = new StateBuilder().setBlocked(true).setLinkDown(false).setLive(isLive).build();
 149         FlowCapableNodeConnectorBuilder fcNodeConnector = new FlowCapableNodeConnectorBuilder().setName(portName)
 150                 .setHardwareAddress(MacAddress.getDefaultInstance(macAddress)).setConfiguration(portConfig)
 151                 .setState(state);
 152         return fcNodeConnector.build();
 153     }
 154
 155     static NodeConnectorId buildNodeConnectorId(Uint64 dpn, long portNo) {
 156         return new NodeConnectorId(buildNodeConnectorString(dpn, portNo));
 157     }
 158
 159     static String buildNodeConnectorString(Uint64 dpn, long portNo) {
 160         return IfmConstants.OF_URI_PREFIX + dpn + IfmConstants.OF_URI_SEPARATOR + portNo;
 161     }
 162
 163     static InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.node.NodeConnector>
 164         buildNodeConnectorInstanceIdentifier(Uint64 dpn, long portNo) {
 165         NodeConnectorId nodeConnectorId = buildNodeConnectorId(dpn, portNo);
 166         NodeId nodeId = IfmUtil.getNodeIdFromNodeConnectorId(nodeConnectorId);
 167         InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.node.NodeConnector>
 168                 ncIdentifier = InstanceIdentifier.builder(Nodes.class).child(Node.class, new NodeKey(nodeId))
 169                 .child(org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.node.NodeConnector.class,
 170                         new NodeConnectorKey(nodeConnectorId)).build();
 171         return ncIdentifier;
 172     }
 173
 174     static Interface buildInterface(String ifName, String desc, boolean enabled, Object ifType,
 175                                            String parentInterface, IfL2vlan.L2vlanMode l2vlanMode) {
 176         InterfaceBuilder builder = new InterfaceBuilder().withKey(new InterfaceKey(ifName)).setName(ifName)
 177                 .setDescription(desc).setEnabled(enabled).setType((Class<? extends InterfaceType>) ifType);
 178         builder.addAugmentation(new ParentRefsBuilder().setParentInterface(parentInterface).build());
 179         if (ifType.equals(L2vlan.class)) {
 180             IfL2vlanBuilder ifL2vlanBuilder = new IfL2vlanBuilder().setL2vlanMode(l2vlanMode);
 181             if (IfL2vlan.L2vlanMode.TrunkMember.equals(l2vlanMode)) {
 182                 ifL2vlanBuilder.setVlanId(new VlanId(100));
 183             } else {
 184                 ifL2vlanBuilder.setVlanId(VlanId.getDefaultInstance("0"));
 185             }
 186             builder.addAugmentation(ifL2vlanBuilder.build());
 187         } else if (ifType.equals(IfTunnel.class)) {
 188             builder.addAugmentation(new IfTunnelBuilder().setTunnelDestination(null).setTunnelGateway(null)
 189                     .setTunnelSource(null).setTunnelInterfaceType(null).build());
 190         }
 191         return builder.build();
 192     }
 193
 194     static Interface buildTunnelInterface(BigInteger dpn, String ifName, String desc, boolean enabled,
 195                                           Class<? extends TunnelTypeBase> tunType, String remoteIpStr,
 196                                           String localIpStr) {
 197         IpAddress remoteIp = new IpAddress(Ipv4Address.getDefaultInstance(remoteIpStr));
 198         IpAddress localIp = new IpAddress(Ipv4Address.getDefaultInstance(localIpStr));
 199         return new InterfaceBuilder()
 200                 .withKey(new InterfaceKey(ifName))
 201                 .setDescription(desc)
 202                 .setEnabled(enabled)
 203                 .setType(Tunnel.class)
 204                 .addAugmentation(new ParentRefsBuilder().setDatapathNodeIdentifier(dpn).build())
 205                 .addAugmentation(new IfTunnelBuilder()
 206                         .setTunnelDestination(remoteIp)
 207                         .setTunnelGateway(localIp)
 208                         .setTunnelSource(localIp)
 209                         .setTunnelInterfaceType(tunType)
 210                         .setInternal(true)
 211                         .setMonitorEnabled(false)
 212                         .build())
 213                 .build();
 214     }
 215
 216     static InstanceIdentifier<TerminationPoint> getTerminationPointId(InstanceIdentifier<?> bridgeIid,
 217                                                                       String portName) {
 218         InstanceIdentifier<TerminationPoint> tpIid = SouthboundUtils.createTerminationPointInstanceIdentifier(
 219                 InstanceIdentifier.keyOf(bridgeIid.firstIdentifierOf(
 220                         org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns
 221                         .yang.network.topology.rev131021.network.topology.topology.Node.class)), portName);
 222         return tpIid;
 223     }
 224
 225     static void deleteInterfaceConfig(DataBroker dataBroker, String ifaceName)
 226             throws ExecutionException, InterruptedException {
 227         InstanceIdentifier<Interface> vlanInterfaceEnabledInterfaceInstanceIdentifier = IfmUtil.buildId(
 228                 ifaceName);
 229         WriteTransaction tx = dataBroker.newWriteOnlyTransaction();
 230         tx.delete(CONFIGURATION, vlanInterfaceEnabledInterfaceInstanceIdentifier);
 231         tx.commit().get();
 232     }
 233
 234     static void updateInterfaceAdminState(DataBroker dataBroker, String ifaceName, boolean isEnabled)
 235             throws ExecutionException, InterruptedException {
 236         InstanceIdentifier<Interface> vlanInterfaceEnabledInterfaceInstanceIdentifier = IfmUtil.buildId(ifaceName);
 237         InterfaceBuilder builder = new InterfaceBuilder().withKey(new InterfaceKey(ifaceName)).setName(ifaceName)
 238             .setEnabled(isEnabled);
 239         WriteTransaction tx = dataBroker.newWriteOnlyTransaction();
 240         tx.merge(CONFIGURATION, vlanInterfaceEnabledInterfaceInstanceIdentifier, builder.build());
 241         tx.commit().get();
 242     }
 243
 244     static void updateTunnelMonitoringAttributes(DataBroker dataBroker, String ifaceName)
 245             throws ExecutionException, InterruptedException {
 246         InstanceIdentifier<Interface> tunnelInstanceIdentifier = IfmUtil.buildId(ifaceName);
 247         WriteTransaction tx = dataBroker.newWriteOnlyTransaction();
 248         tx.merge(CONFIGURATION, tunnelInstanceIdentifier, new InterfaceBuilder()
 249                 .withKey(new InterfaceKey(ifaceName))
 250                 .setName(ifaceName)
 251                 .addAugmentation(new IfTunnelBuilder()
 252                         .setMonitorProtocol(TunnelMonitoringTypeBfd.class)
 253                         .setMonitorEnabled(true)
 254                         .build())
 255                 .build());
 256         tx.commit().get();
 257     }
 258
 259     static void putInterfaceConfig(DataBroker dataBroker, String ifaceName, ParentRefs parentRefs,
 260                                           Class<? extends InterfaceType> ifType)
 261             throws ExecutionException, InterruptedException {
 262         Interface interfaceInfo;
 263         if (!Tunnel.class.equals(ifType)) {
 264             interfaceInfo = InterfaceManagerTestUtil.buildInterface(ifaceName, ifaceName, true, ifType,
 265                     parentRefs.getParentInterface(), IfL2vlan.L2vlanMode.Trunk);
 266         } else {
 267             interfaceInfo = buildTunnelInterface(parentRefs.getDatapathNodeIdentifier().toJava(),ifaceName, ifaceName,
 268                     true, TunnelTypeVxlan.class, "1.1.1.1", "2.2.2.2");
 269         }
 270         InstanceIdentifier<Interface> interfaceInstanceIdentifier = IfmUtil.buildId(ifaceName);
 271         WriteTransaction tx = dataBroker.newWriteOnlyTransaction();
 272         tx.mergeParentStructurePut(CONFIGURATION, interfaceInstanceIdentifier, interfaceInfo);
 273         tx.commit().get();
 274     }
 275
 276     static void putVlanInterfaceConfig(DataBroker dataBroker, String ifaceName, String parentRefs,
 277                                               IfL2vlan.L2vlanMode l2vlanMode)
 278             throws ExecutionException, InterruptedException {
 279         Interface interfaceInfo = InterfaceManagerTestUtil.buildInterface(ifaceName, ifaceName,
 280                 true, L2vlan.class, parentRefs, l2vlanMode);
 281         InstanceIdentifier<Interface> interfaceInstanceIdentifier = IfmUtil.buildId(ifaceName);
 282         WriteTransaction tx = dataBroker.newWriteOnlyTransaction();
 283         tx.mergeParentStructurePut(CONFIGURATION, interfaceInstanceIdentifier, interfaceInfo);
 284         tx.commit().get();
 285     }
 286
 287     static void createFlowCapableNodeConnector(DataBroker dataBroker, String interfaceName,
 288                                                Class<? extends InterfaceType> ifType)
 289             throws ExecutionException, InterruptedException {
 290         WriteTransaction tx = dataBroker.newWriteOnlyTransaction();
 291         Uint64 dpnId = Tunnel.class.equals(ifType) ? DPN_ID_2 : DPN_ID_1;
 292         long portNo = Tunnel.class.equals(ifType) ? PORT_NO_1 : PORT_NO_1;
 293         NodeConnector nodeConnector = InterfaceManagerTestUtil
 294                 .buildFlowCapableNodeConnector(buildNodeConnectorId(dpnId, portNo), interfaceName, true);
 295         tx.mergeParentStructurePut(OPERATIONAL,buildNodeConnectorInstanceIdentifier(dpnId, portNo), nodeConnector);
 296         tx.commit().get();
 297     }
 298
 299     static void updateFlowCapableNodeConnectorState(DataBroker dataBroker, String interfaceName,
 300             Class<? extends InterfaceType> ifType, boolean isLive) throws ExecutionException, InterruptedException {
 301         WriteTransaction tx = dataBroker.newWriteOnlyTransaction();
 302         Uint64 dpnId = Tunnel.class.equals(ifType) ? DPN_ID_2 : DPN_ID_1;
 303         long portNo = Tunnel.class.equals(ifType) ? PORT_NO_1 : PORT_NO_1;
 304         NodeConnector nodeConnector = InterfaceManagerTestUtil
 305             .buildFlowCapableNodeConnector(buildNodeConnectorId(dpnId, portNo), interfaceName, isLive);
 306         tx.mergeParentStructureMerge(OPERATIONAL,buildNodeConnectorInstanceIdentifier(dpnId, portNo), nodeConnector);
 307         tx.commit().get();
 308     }
 309
 310     static void removeFlowCapableNodeConnectorState(DataBroker dataBroker, Class<? extends InterfaceType> ifType)
 311             throws ExecutionException, InterruptedException {
 312         WriteTransaction tx = dataBroker.newWriteOnlyTransaction();
 313         Uint64 dpnId = Tunnel.class.equals(ifType) ? DPN_ID_2 : DPN_ID_1;
 314         long portNo = Tunnel.class.equals(ifType) ? PORT_NO_1 : PORT_NO_1;
 315         tx.delete(OPERATIONAL,buildNodeConnectorInstanceIdentifier(dpnId, portNo));
 316         tx.commit().get();
 317     }
 318
 319
 320     static void removeNode(DataBroker dataBroker) throws ExecutionException, InterruptedException {
 321         WriteTransaction tx = dataBroker.newWriteOnlyTransaction();
 322         InstanceIdentifier<Node> nodeInstanceIdentifier = InstanceIdentifier.builder(Nodes.class)
 323             .child(Node.class, new NodeKey(IfmUtil.buildDpnNodeId(DPN_ID_2))).build();
 324         tx.delete(OPERATIONAL,nodeInstanceIdentifier);
 325         tx.commit().get();
 326     }
 327
 328     static void waitTillOperationCompletes(JobCoordinatorCountedEventsWaiter coordinatorEventsWaiter,
 329                                            AsyncEventsWaiter asyncEventsWaiter) {
 330         coordinatorEventsWaiter.awaitJobsConsumption(0);
 331         asyncEventsWaiter.awaitEventsConsumption();
 332     }
 333
 334     static void waitTillOperationCompletes(String testDescription,
 335                                            JobCoordinatorCountedEventsWaiter coordinatorEventsWaiter,
 336                                            int expectedJobCount,
 337                                            AsyncEventsWaiter asyncEventsWaiter) {
 338         try {
 339             coordinatorEventsWaiter.awaitJobsConsumption(expectedJobCount);
 340             asyncEventsWaiter.awaitEventsConsumption();
 341         } catch (ConditionTimeoutException e) {
 342             LOG.error("{} failed on awaiting events consumption", testDescription);
 343             throw e;
 344         }
 345     }
 346
 347     static BoundServices buildServicesInfo(String serviceName, short serviceIndex) {
 348         int instructionKey = 0;
 349         List<Instruction> instructions = new ArrayList<>();
 350         instructions.add(MDSALUtil.buildAndGetWriteMetadaInstruction(MetaDataUtil.getElanTagMetadata(1),
 351             MetaDataUtil.METADATA_MASK_SERVICE, ++instructionKey));
 352
 353         List<Action> actions = new ArrayList<>();
 354         instructions.add(MDSALUtil.buildApplyActionsInstruction(actions, ++instructionKey));
 355         instructions.add(MDSALUtil.buildAndGetGotoTableInstruction(NwConstants.ELAN_BASE_TABLE,
 356             ++instructionKey));
 357
 358         BoundServices serviceInfo = InterfaceManagerTestUtil.getBoundServices(serviceName, serviceIndex,
 359             serviceIndex, NwConstants.COOKIE_ELAN_INGRESS_TABLE, instructions);
 360         return serviceInfo;
 361     }
 362
 363     static BoundServices getBoundServices(String serviceName, short servicePriority, int flowPriority,
 364                                           Uint64 cookie, List<Instruction> instructions) {
 365         StypeOpenflowBuilder augBuilder = new StypeOpenflowBuilder().setFlowCookie(cookie).setFlowPriority(flowPriority)
 366             .setInstruction(instructions);
 367         return new BoundServicesBuilder().withKey(new BoundServicesKey(servicePriority)).setServiceName(serviceName)
 368             .setServicePriority(servicePriority).setServiceType(ServiceTypeFlowBased.class)
 369             .addAugmentation(augBuilder.build()).build();
 370     }
 371
 372     static InstanceIdentifier<BoundServices> buildServiceId(String vpnInterfaceName, short serviceIndex) {
 373         return InstanceIdentifier.builder(ServiceBindings.class)
 374             .child(ServicesInfo.class, new ServicesInfoKey(vpnInterfaceName, ServiceModeIngress.class))
 375             .child(BoundServices.class, new BoundServicesKey(serviceIndex)).build();
 376     }
 377 }