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

Class McastUpdateJob

java.lang.Object

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

org.opendaylight.netvirt.elan.l2gw.jobs.McastUpdateJob

All Implemented Interfaces:

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

public class McastUpdateJob
extends DataStoreJob

Field Summary

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

jobKey, leftTrials

Constructor Summary

Constructors

Constructor	Description
McastUpdateJob(java.lang.String elanName, java.lang.String nodeId, boolean add, ElanL2GatewayMulticastUtils mcastUtils, ElanClusterUtils elanClusterUtils, Scheduler scheduler, org.opendaylight.infrautils.jobcoordinator.JobCoordinator jobCoordinator)

Method Summary

Modifier and Type	Method	Description
java.util.List<com.google.common.util.concurrent.ListenableFuture<?>>	call()
static void	removeMcastForNode(java.lang.String elanName, java.lang.String nodeId, ElanL2GatewayMulticastUtils mcastUtils, ElanClusterUtils elanClusterUtils, Scheduler scheduler, org.opendaylight.infrautils.jobcoordinator.JobCoordinator jobCoordinator)
void	submit()
static void	updateAllMcasts(java.lang.String elanName, ElanL2GatewayMulticastUtils mcastUtils, ElanClusterUtils elanClusterUtils, Scheduler scheduler, org.opendaylight.infrautils.jobcoordinator.JobCoordinator jobCoordinator)
static void	updateAllMcastsForConnectionAdd(java.lang.String elanName, ElanL2GatewayMulticastUtils mcastUtils, ElanClusterUtils elanClusterUtils, Scheduler scheduler, org.opendaylight.infrautils.jobcoordinator.JobCoordinator jobCoordinator)
static void	updateAllMcastsForConnectionDelete(java.lang.String elanName, ElanL2GatewayMulticastUtils mcastUtils, ElanClusterUtils elanClusterUtils, Scheduler scheduler, org.opendaylight.infrautils.jobcoordinator.JobCoordinator jobCoordinator, L2GatewayDevice deletedDevice)
static void	updateAllMcastsForDpnAdd(java.lang.String elanName, ElanL2GatewayMulticastUtils mcastUtils, ElanClusterUtils elanClusterUtils, Scheduler scheduler, org.opendaylight.infrautils.jobcoordinator.JobCoordinator jobCoordinator)
static void	updateAllMcastsForDpnDelete(java.lang.String elanName, ElanL2GatewayMulticastUtils mcastUtils, ElanClusterUtils elanClusterUtils, java.math.BigInteger srcDpnId, ElanItmUtils elanItmUtils, Scheduler scheduler, org.opendaylight.infrautils.jobcoordinator.JobCoordinator jobCoordinator)
static void	updateMcastForNode(java.lang.String elanName, java.lang.String nodeId, ElanL2GatewayMulticastUtils mcastUtils, ElanClusterUtils elanClusterUtils, Scheduler scheduler, org.opendaylight.infrautils.jobcoordinator.JobCoordinator jobCoordinator)

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

McastUpdateJob

public McastUpdateJob(java.lang.String elanName,
                      java.lang.String nodeId,
                      boolean add,
                      ElanL2GatewayMulticastUtils mcastUtils,
                      ElanClusterUtils elanClusterUtils,
                      Scheduler scheduler,
                      org.opendaylight.infrautils.jobcoordinator.JobCoordinator jobCoordinator)

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

updateAllMcasts

public static void updateAllMcasts(java.lang.String elanName,
                                   ElanL2GatewayMulticastUtils mcastUtils,
                                   ElanClusterUtils elanClusterUtils,
                                   Scheduler scheduler,
                                   org.opendaylight.infrautils.jobcoordinator.JobCoordinator jobCoordinator)

removeMcastForNode

public static void removeMcastForNode(java.lang.String elanName,
                                      java.lang.String nodeId,
                                      ElanL2GatewayMulticastUtils mcastUtils,
                                      ElanClusterUtils elanClusterUtils,
                                      Scheduler scheduler,
                                      org.opendaylight.infrautils.jobcoordinator.JobCoordinator jobCoordinator)

updateMcastForNode

public static void updateMcastForNode(java.lang.String elanName,
                                      java.lang.String nodeId,
                                      ElanL2GatewayMulticastUtils mcastUtils,
                                      ElanClusterUtils elanClusterUtils,
                                      Scheduler scheduler,
                                      org.opendaylight.infrautils.jobcoordinator.JobCoordinator jobCoordinator)

updateAllMcastsForConnectionAdd

public static void updateAllMcastsForConnectionAdd(java.lang.String elanName,
                                                   ElanL2GatewayMulticastUtils mcastUtils,
                                                   ElanClusterUtils elanClusterUtils,
                                                   Scheduler scheduler,
                                                   org.opendaylight.infrautils.jobcoordinator.JobCoordinator jobCoordinator)

updateAllMcastsForConnectionDelete

public static void updateAllMcastsForConnectionDelete(java.lang.String elanName,
                                                      ElanL2GatewayMulticastUtils mcastUtils,
                                                      ElanClusterUtils elanClusterUtils,
                                                      Scheduler scheduler,
                                                      org.opendaylight.infrautils.jobcoordinator.JobCoordinator jobCoordinator,
                                                      L2GatewayDevice deletedDevice)

updateAllMcastsForDpnAdd

public static void updateAllMcastsForDpnAdd(java.lang.String elanName,
                                            ElanL2GatewayMulticastUtils mcastUtils,
                                            ElanClusterUtils elanClusterUtils,
                                            Scheduler scheduler,
                                            org.opendaylight.infrautils.jobcoordinator.JobCoordinator jobCoordinator)

updateAllMcastsForDpnDelete

public static void updateAllMcastsForDpnDelete(java.lang.String elanName,
                                               ElanL2GatewayMulticastUtils mcastUtils,
                                               ElanClusterUtils elanClusterUtils,
                                               java.math.BigInteger srcDpnId,
                                               ElanItmUtils elanItmUtils,
                                               Scheduler scheduler,
                                               org.opendaylight.infrautils.jobcoordinator.JobCoordinator jobCoordinator)