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