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

Class McastUpdateJob

java.lang.Object

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 java.lang.Object
implements java.util.concurrent.Callable<java.util.List<? extends com.google.common.util.concurrent.ListenableFuture<?>>>

Field Summary

Fields

Modifier and Type	Field	Description
protected java.lang.String	jobKey

Constructor Summary

Constructors

Constructor	Description
McastUpdateJob(java.lang.String elanName, java.lang.String nodeId, boolean add, ElanL2GatewayMulticastUtils mcastUtils, ElanClusterUtils elanClusterUtils)

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)
void	submit()
static void	updateAllMcasts(java.lang.String elanName, ElanL2GatewayMulticastUtils mcastUtils, ElanClusterUtils elanClusterUtils)
static void	updateAllMcastsForConnectionAdd(java.lang.String elanName, ElanL2GatewayMulticastUtils mcastUtils, ElanClusterUtils elanClusterUtils)
static void	updateAllMcastsForConnectionDelete(java.lang.String elanName, ElanL2GatewayMulticastUtils mcastUtils, ElanClusterUtils elanClusterUtils, L2GatewayDevice deletedDevice)
static void	updateAllMcastsForDpnAdd(java.lang.String elanName, ElanL2GatewayMulticastUtils mcastUtils, ElanClusterUtils elanClusterUtils)
static void	updateAllMcastsForDpnDelete(java.lang.String elanName, ElanL2GatewayMulticastUtils mcastUtils, ElanClusterUtils elanClusterUtils, org.opendaylight.yangtools.yang.common.Uint64 srcDpnId, ElanItmUtils elanItmUtils)
static void	updateMcastForNode(java.lang.String elanName, java.lang.String nodeId, ElanL2GatewayMulticastUtils mcastUtils, ElanClusterUtils elanClusterUtils)

Methods inherited from class java.lang.Object

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

Field Detail

jobKey

protected java.lang.String jobKey

Constructor Detail

McastUpdateJob

public McastUpdateJob(java.lang.String elanName,
                      java.lang.String nodeId,
                      boolean add,
                      ElanL2GatewayMulticastUtils mcastUtils,
                      ElanClusterUtils elanClusterUtils)

Method Detail

submit

public void submit()

call

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

Specified by:

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

Throws:

java.lang.Exception

updateAllMcasts

public static void updateAllMcasts(java.lang.String elanName,
                                   ElanL2GatewayMulticastUtils mcastUtils,
                                   ElanClusterUtils elanClusterUtils)

removeMcastForNode

public static void removeMcastForNode(java.lang.String elanName,
                                      java.lang.String nodeId,
                                      ElanL2GatewayMulticastUtils mcastUtils,
                                      ElanClusterUtils elanClusterUtils)

updateMcastForNode

public static void updateMcastForNode(java.lang.String elanName,
                                      java.lang.String nodeId,
                                      ElanL2GatewayMulticastUtils mcastUtils,
                                      ElanClusterUtils elanClusterUtils)

updateAllMcastsForConnectionAdd

public static void updateAllMcastsForConnectionAdd(java.lang.String elanName,
                                                   ElanL2GatewayMulticastUtils mcastUtils,
                                                   ElanClusterUtils elanClusterUtils)

updateAllMcastsForConnectionDelete

public static void updateAllMcastsForConnectionDelete(java.lang.String elanName,
                                                      ElanL2GatewayMulticastUtils mcastUtils,
                                                      ElanClusterUtils elanClusterUtils,
                                                      L2GatewayDevice deletedDevice)

updateAllMcastsForDpnAdd

public static void updateAllMcastsForDpnAdd(java.lang.String elanName,
                                            ElanL2GatewayMulticastUtils mcastUtils,
                                            ElanClusterUtils elanClusterUtils)

updateAllMcastsForDpnDelete

public static void updateAllMcastsForDpnDelete(java.lang.String elanName,
                                               ElanL2GatewayMulticastUtils mcastUtils,
                                               ElanClusterUtils elanClusterUtils,
                                               org.opendaylight.yangtools.yang.common.Uint64 srcDpnId,
                                               ElanItmUtils elanItmUtils)