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
All Methods Static Methods Instance Methods Concrete Methods 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
-
-
-
-
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)
-
-