org.opendaylight.netvirt.elan.utils

Class ElanClusterUtils

java.lang.Object

org.opendaylight.netvirt.elan.utils.ElanClusterUtils

public class ElanClusterUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
ElanClusterUtils()

Method Summary

Modifier and Type	Method and Description
static <T extends org.opendaylight.yangtools.yang.binding.DataObject> void	asyncReadAndExecute(org.opendaylight.controller.md.sal.binding.api.DataBroker broker, org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType datastoreType, org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> iid, String jobKey, Function<com.google.common.base.Optional<T>,Void> function)
static void	runOnlyInLeaderNode(org.opendaylight.controller.md.sal.common.api.clustering.EntityOwnershipService entityOwnershipService, Runnable job)
static void	runOnlyInLeaderNode(org.opendaylight.controller.md.sal.common.api.clustering.EntityOwnershipService entityOwnershipService, Runnable job, String jobDescription)
static void	runOnlyInLeaderNode(org.opendaylight.controller.md.sal.common.api.clustering.EntityOwnershipService entityOwnershipService, String jobKey, Callable<List<com.google.common.util.concurrent.ListenableFuture<Void>>> dataStoreJob)
static void	runOnlyInLeaderNode(org.opendaylight.controller.md.sal.common.api.clustering.EntityOwnershipService entityOwnershipService, String jobKey, String jobDescription, Callable<List<com.google.common.util.concurrent.ListenableFuture<Void>>> dataStoreJob)

Methods inherited from class java.lang.Object

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

Constructor Detail

ElanClusterUtils

public ElanClusterUtils()

Method Detail

runOnlyInLeaderNode

public static void runOnlyInLeaderNode(org.opendaylight.controller.md.sal.common.api.clustering.EntityOwnershipService entityOwnershipService,
                                       Runnable job)

runOnlyInLeaderNode

public static void runOnlyInLeaderNode(org.opendaylight.controller.md.sal.common.api.clustering.EntityOwnershipService entityOwnershipService,
                                       Runnable job,
                                       String jobDescription)

runOnlyInLeaderNode

public static void runOnlyInLeaderNode(org.opendaylight.controller.md.sal.common.api.clustering.EntityOwnershipService entityOwnershipService,
                                       String jobKey,
                                       Callable<List<com.google.common.util.concurrent.ListenableFuture<Void>>> dataStoreJob)

runOnlyInLeaderNode

public static void runOnlyInLeaderNode(org.opendaylight.controller.md.sal.common.api.clustering.EntityOwnershipService entityOwnershipService,
                                       String jobKey,
                                       String jobDescription,
                                       Callable<List<com.google.common.util.concurrent.ListenableFuture<Void>>> dataStoreJob)

asyncReadAndExecute

public static <T extends org.opendaylight.yangtools.yang.binding.DataObject> void asyncReadAndExecute(org.opendaylight.controller.md.sal.binding.api.DataBroker broker,
                                                                                                      org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType datastoreType,
                                                                                                      org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> iid,
                                                                                                      String jobKey,
                                                                                                      Function<com.google.common.base.Optional<T>,Void> function)