Class McastUpdateJob

  • All Implemented Interfaces:
    java.util.concurrent.Callable<java.util.List<? extends com.google.common.util.concurrent.ListenableFuture<?>>>

    public class McastUpdateJob
    extends DataStoreJob
    • 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
      • 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)
      • 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)