Class McastUpdateJob
- java.lang.Object
-
- org.opendaylight.netvirt.elan.l2gw.jobs.McastUpdateJob
-
- All Implemented Interfaces:
java.util.concurrent.Callable<java.util.List<com.google.common.util.concurrent.ListenableFuture<java.lang.Void>>>
public class McastUpdateJob extends java.lang.Object implements java.util.concurrent.Callable<java.util.List<com.google.common.util.concurrent.ListenableFuture<java.lang.Void>>>
-
-
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
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.List<com.google.common.util.concurrent.ListenableFuture<java.lang.Void>>
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)
-
-
-
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<java.lang.Void>> call() throws java.lang.Exception
- Specified by:
call
in interfacejava.util.concurrent.Callable<java.util.List<com.google.common.util.concurrent.ListenableFuture<java.lang.Void>>>
- 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)
-
-