Package org.graylog2.indexer.datanode

Class DatanodeMigrationLockServiceImpl

java.lang.Object

org.graylog2.indexer.datanode.DatanodeMigrationLockServiceImpl

All Implemented Interfaces:

DatanodeMigrationLockService

public class DatanodeMigrationLockServiceImpl
extends Object
implements DatanodeMigrationLockService

Field Summary

Fields

Modifier and Type	Field	Description
static final int	LOCK_EXTEND_PERIOD_SECONDS

Constructor Summary

Constructors

Constructor	Description
DatanodeMigrationLockServiceImpl(LockService lockService)

Method Summary

Modifier and Type	Method	Description
Lock	acquireLock(IndexSet indexSet, Class<?> caller, String context, DatanodeMigrationLockWaitConfig config)	This is a blocking method.
void	release(Lock lock)	Each lock needs to be explicitly released, otherwise the implementation may extend it as long as the node is running.
void	tryRun(IndexSet indexSet, Class<?> caller, Runnable runnable)	Will run the runnable only if it can get a lock on the first try.

Methods inherited from class java.lang.Object

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

Field Details

LOCK_EXTEND_PERIOD_SECONDS

public static final int LOCK_EXTEND_PERIOD_SECONDS

See Also:

• Constant Field Values

Constructor Details

DatanodeMigrationLockServiceImpl

@Inject
public DatanodeMigrationLockServiceImpl(LockService lockService)

Method Details

acquireLock

public Lock acquireLock(IndexSet indexSet,
 Class<?> caller,
 String context,
 DatanodeMigrationLockWaitConfig config)

Description copied from interface: DatanodeMigrationLockService

This is a blocking method. It will try to acquire a lock and repeat the process until the general timeout defined in the DatanodeMigrationLockWaitConfig.lockAcquireTimeout() is reached.

Specified by:

acquireLock in interface DatanodeMigrationLockService

tryRun

public void tryRun(IndexSet indexSet,
 Class<?> caller,
 Runnable runnable)

Description copied from interface: DatanodeMigrationLockService

Will run the runnable only if it can get a lock on the first try. If the lock is taken, it will skip the execution.

Specified by:

tryRun in interface DatanodeMigrationLockService

release

public void release(Lock lock)

Description copied from interface: DatanodeMigrationLockService

Each lock needs to be explicitly released, otherwise the implementation may extend it as long as the node is running.

Specified by:

release in interface DatanodeMigrationLockService