Package org.opendaylight.netvirt.elan.l2gw.jobs

Class BcGroupUpdateJob

java.lang.Object

org.opendaylight.netvirt.elan.l2gw.jobs.DataStoreJob

org.opendaylight.netvirt.elan.l2gw.jobs.BcGroupUpdateJob

All Implemented Interfaces:

java.util.concurrent.Callable<java.util.List<? extends com.google.common.util.concurrent.ListenableFuture<?>>>

public class BcGroupUpdateJob
extends DataStoreJob

Field Summary

Fields inherited from class org.opendaylight.netvirt.elan.l2gw.jobs.DataStoreJob

jobKey, leftTrials

Constructor Summary

Constructors

Constructor	Description
BcGroupUpdateJob(java.lang.String elanName, boolean add, org.opendaylight.yangtools.yang.common.Uint64 addedDpn, L2GatewayDevice addedL2gw, ElanRefUtil elanRefUtil, ElanL2GatewayMulticastUtils elanL2GatewayMulticastUtils, org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager mdsalApiManager, ElanInstanceDpnsCache elanInstanceDpnsCache, ElanItmUtils elanItmUtils)

Method Summary

Modifier and Type	Method	Description
java.util.List<com.google.common.util.concurrent.ListenableFuture<?>>	call()
static java.lang.String	getTunnelInterfaceFlowRef(org.opendaylight.yangtools.yang.common.Uint64 dpnId, short tableId, java.lang.String ifName)
void	installDpnDefaultFlows(java.lang.String elan, L2GatewayDevice device)
void	installDpnDefaultFlows(java.lang.String elan, org.opendaylight.yangtools.yang.common.Uint64 dpnId)
void	installDpnDefaultFlows(java.lang.String elan, org.opendaylight.yangtools.yang.common.Uint64 dpnId, L2GatewayDevice device)
void	makeTunnelIngressFlow(org.opendaylight.yangtools.yang.common.Uint64 dpnId, long portNo, java.lang.String interfaceName, int ifIndex)
void	submit()
static void	updateAllBcGroups(java.lang.String elanName, boolean add, org.opendaylight.yangtools.yang.common.Uint64 addedDpn, L2GatewayDevice addedL2gw, ElanRefUtil elanRefUtil, ElanL2GatewayMulticastUtils elanL2GatewayMulticastUtils, org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager mdsalApiManager, ElanInstanceDpnsCache elanInstanceDpnsCache, ElanItmUtils elanItmUtils)

Methods inherited from class org.opendaylight.netvirt.elan.l2gw.jobs.DataStoreJob

processResult

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BcGroupUpdateJob

public BcGroupUpdateJob(java.lang.String elanName,
                        boolean add,
                        org.opendaylight.yangtools.yang.common.Uint64 addedDpn,
                        L2GatewayDevice addedL2gw,
                        ElanRefUtil elanRefUtil,
                        ElanL2GatewayMulticastUtils elanL2GatewayMulticastUtils,
                        org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager mdsalApiManager,
                        ElanInstanceDpnsCache elanInstanceDpnsCache,
                        ElanItmUtils elanItmUtils)

Method Detail

submit

public void submit()

call

public java.util.List<com.google.common.util.concurrent.ListenableFuture<?>> call()
                                                                           throws java.lang.Exception

Throws:

java.lang.Exception

installDpnDefaultFlows

public void installDpnDefaultFlows(java.lang.String elan,
                                   L2GatewayDevice device)

installDpnDefaultFlows

public void installDpnDefaultFlows(java.lang.String elan,
                                   org.opendaylight.yangtools.yang.common.Uint64 dpnId)

installDpnDefaultFlows

public void installDpnDefaultFlows(java.lang.String elan,
                                   org.opendaylight.yangtools.yang.common.Uint64 dpnId,
                                   L2GatewayDevice device)

getTunnelInterfaceFlowRef

public static java.lang.String getTunnelInterfaceFlowRef(org.opendaylight.yangtools.yang.common.Uint64 dpnId,
                                                         short tableId,
                                                         java.lang.String ifName)

makeTunnelIngressFlow

public void makeTunnelIngressFlow(org.opendaylight.yangtools.yang.common.Uint64 dpnId,
                                  long portNo,
                                  java.lang.String interfaceName,
                                  int ifIndex)

updateAllBcGroups

public static void updateAllBcGroups(java.lang.String elanName,
                                     boolean add,
                                     org.opendaylight.yangtools.yang.common.Uint64 addedDpn,
                                     L2GatewayDevice addedL2gw,
                                     ElanRefUtil elanRefUtil,
                                     ElanL2GatewayMulticastUtils elanL2GatewayMulticastUtils,
                                     org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager mdsalApiManager,
                                     ElanInstanceDpnsCache elanInstanceDpnsCache,
                                     ElanItmUtils elanItmUtils)