org.opendaylight.genius.utils.clustering

Class EntityOwnershipUtils

java.lang.Object

org.opendaylight.genius.utils.clustering.EntityOwnershipUtils

public class EntityOwnershipUtils
extends Object

EntityOwnershipService utilities.

Author:

Thomas Pantelis

Constructor Summary

Constructors

Constructor and Description
EntityOwnershipUtils(org.opendaylight.mdsal.eos.binding.api.EntityOwnershipService entityOwnershipService)

Method Summary

Modifier and Type	Method and Description
org.opendaylight.mdsal.eos.binding.api.EntityOwnershipService	getEntityOwnershipService()
boolean	isEntityOwner(org.opendaylight.mdsal.eos.binding.api.Entity entity) Checks if the local node is the owner of an entity.
boolean	isEntityOwner(org.opendaylight.mdsal.eos.binding.api.Entity entity, long sleepBetweenRetries, int tries) Checks if the local node is the owner of an entity.
boolean	isEntityOwner(String entityType, String entityName) Checks if the local node is the owner of an entity.
void	runOnlyInOwnerNode(String entityType, String entityName, org.opendaylight.infrautils.jobcoordinator.JobCoordinator coordinator, String jobDesc, Runnable job) Runs a job task if the local node is the owner of an entity.
void	runOnlyInOwnerNode(String entityType, String entityName, org.opendaylight.infrautils.jobcoordinator.JobCoordinator coordinator, String jobKey, String jobDesc, Callable<List<com.google.common.util.concurrent.ListenableFuture<Void>>> job) Runs a job task if the local node is the owner of an entity.

Methods inherited from class java.lang.Object

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

Constructor Detail

EntityOwnershipUtils

@Inject
public EntityOwnershipUtils(org.opendaylight.mdsal.eos.binding.api.EntityOwnershipService entityOwnershipService)

Method Detail

getEntityOwnershipService

public org.opendaylight.mdsal.eos.binding.api.EntityOwnershipService getEntityOwnershipService()

isEntityOwner

public boolean isEntityOwner(String entityType,
                             String entityName)

Checks if the local node is the owner of an entity.

Parameters:

entityType - the entity type

entityName - the entity name

Returns:

true is the owner, false otherwise

isEntityOwner

public boolean isEntityOwner(org.opendaylight.mdsal.eos.binding.api.Entity entity)

Checks if the local node is the owner of an entity.

Parameters:

entity - the entity

Returns:

true is the owner, false otherwise

isEntityOwner

public boolean isEntityOwner(org.opendaylight.mdsal.eos.binding.api.Entity entity,
                             long sleepBetweenRetries,
                             int tries)

Checks if the local node is the owner of an entity.

Parameters:

entity - the entity

sleepBetweenRetries - the busy wait interval in millis if the entity is not yet present

tries - the total number of busy wait tries

Returns:

true is the owner, false otherwise

runOnlyInOwnerNode

public void runOnlyInOwnerNode(String entityType,
                               String entityName,
                               org.opendaylight.infrautils.jobcoordinator.JobCoordinator coordinator,
                               String jobDesc,
                               Runnable job)

Runs a job task if the local node is the owner of an entity.

Parameters:

entityType - the entity type

entityName - the entity name

coordinator - the JobCoordinator on which to run the job task

jobDesc - description of the job for logging

job - the job task

runOnlyInOwnerNode

public void runOnlyInOwnerNode(String entityType,
                               String entityName,
                               org.opendaylight.infrautils.jobcoordinator.JobCoordinator coordinator,
                               String jobKey,
                               String jobDesc,
                               Callable<List<com.google.common.util.concurrent.ListenableFuture<Void>>> job)

Runs a job task if the local node is the owner of an entity.

Parameters:

entityType - the entity type

entityName - the entity name

coordinator - the JobCoordinator on which to run the job

jobKey - the job key

jobDesc - description of the job for logging

job - the job task