org.infinispan.statetransfer

Class StateTransferLockImpl

java.lang.Object

org.infinispan.statetransfer.StateTransferLockImpl

All Implemented Interfaces:

StateTransferLock

public class StateTransferLockImpl
extends Object
implements StateTransferLock

StateTransferLock implementation.

Since:

5.2

Author:

anistor@redhat.com, Dan Berindei

Constructor Summary

Constructors

Constructor and Description
StateTransferLockImpl()

Method Summary

Modifier and Type	Method and Description
void	acquireExclusiveTopologyLock()
void	acquireSharedTopologyLock()
void	notifyTopologyInstalled(int topologyId)
void	notifyTransactionDataReceived(int topologyId)
void	releaseExclusiveTopologyLock()
void	releaseSharedTopologyLock()
void	stop()
boolean	topologyReceived(int expectedTopologyId)
boolean	transactionDataReceived(int expectedTopologyId)
void	waitForTopology(int expectedTopologyId, long timeout, TimeUnit unit)
void	waitForTransactionData(int expectedTopologyId, long timeout, TimeUnit unit)

Methods inherited from class java.lang.Object

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

Constructor Detail

StateTransferLockImpl

public StateTransferLockImpl()

Method Detail

stop

public void stop()

acquireExclusiveTopologyLock

public void acquireExclusiveTopologyLock()

Specified by:

acquireExclusiveTopologyLock in interface StateTransferLock

releaseExclusiveTopologyLock

public void releaseExclusiveTopologyLock()

Specified by:

releaseExclusiveTopologyLock in interface StateTransferLock

acquireSharedTopologyLock

public void acquireSharedTopologyLock()

Specified by:

acquireSharedTopologyLock in interface StateTransferLock

releaseSharedTopologyLock

public void releaseSharedTopologyLock()

Specified by:

releaseSharedTopologyLock in interface StateTransferLock

notifyTransactionDataReceived

public void notifyTransactionDataReceived(int topologyId)

Specified by:

notifyTransactionDataReceived in interface StateTransferLock

waitForTransactionData

public void waitForTransactionData(int expectedTopologyId,
                                   long timeout,
                                   TimeUnit unit)
                            throws InterruptedException

Specified by:

waitForTransactionData in interface StateTransferLock

Throws:

InterruptedException

transactionDataReceived

public boolean transactionDataReceived(int expectedTopologyId)

Specified by:

transactionDataReceived in interface StateTransferLock

notifyTopologyInstalled

public void notifyTopologyInstalled(int topologyId)

Specified by:

notifyTopologyInstalled in interface StateTransferLock

waitForTopology

public void waitForTopology(int expectedTopologyId,
                            long timeout,
                            TimeUnit unit)
                     throws InterruptedException

Specified by:

waitForTopology in interface StateTransferLock

Throws:

InterruptedException

topologyReceived

public boolean topologyReceived(int expectedTopologyId)

Specified by:

topologyReceived in interface StateTransferLock