Package 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	Description
StateTransferLockImpl()

Method Summary

Modifier and Type	Method	Description
void	acquireExclusiveTopologyLock()
void	acquireSharedTopologyLock()
void	notifyTopologyInstalled(int topologyId)
void	notifyTransactionDataReceived(int topologyId)
void	releaseExclusiveTopologyLock()
void	releaseSharedTopologyLock()
void	stop()
CompletableFuture<Void>	topologyFuture(int expectedTopologyId)
boolean	topologyReceived(int expectedTopologyId)
CompletableFuture<Void>	transactionDataFuture(int expectedTopologyId)
boolean	transactionDataReceived(int expectedTopologyId)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.statetransfer.StateTransferLock

waitForTopology, waitForTransactionData

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

transactionDataFuture

public CompletableFuture<Void> transactionDataFuture(int expectedTopologyId)

Specified by:

transactionDataFuture in interface StateTransferLock

transactionDataReceived

public boolean transactionDataReceived(int expectedTopologyId)

Specified by:

transactionDataReceived in interface StateTransferLock

notifyTopologyInstalled

public void notifyTopologyInstalled(int topologyId)

Specified by:

notifyTopologyInstalled in interface StateTransferLock

topologyFuture

public CompletableFuture<Void> topologyFuture(int expectedTopologyId)

Specified by:

topologyFuture in interface StateTransferLock

topologyReceived

public boolean topologyReceived(int expectedTopologyId)

Specified by:

topologyReceived in interface StateTransferLock