|
Infinispan Distribution 5.2.6.Final-redhat-2 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.infinispan.statetransfer.StateProviderImpl
public class StateProviderImpl
StateProvider
implementation.
Constructor Summary | |
---|---|
StateProviderImpl()
|
Method Summary | |
---|---|
void |
cancelOutboundTransfer(Address destination,
int topologyId,
Set<Integer> segments)
Cancel sending of cache entries that belong to the given set of segments. |
List<TransactionInfo> |
getTransactionsForSegments(Address destination,
int requestTopologyId,
Set<Integer> segments)
Gets the list of transactions that affect keys from the given segments. |
void |
init(Cache cache,
ExecutorService executorService,
Configuration configuration,
RpcManager rpcManager,
CommandsFactory commandsFactory,
CacheNotifier cacheNotifier,
CacheLoaderManager cacheLoaderManager,
DataContainer dataContainer,
TransactionTable transactionTable,
StateTransferLock stateTransferLock,
StateConsumer stateConsumer)
|
boolean |
isStateTransferInProgress()
|
void |
onTopologyChange(TopologyChangedEvent<?,?> tce)
|
void |
onTopologyUpdate(CacheTopology cacheTopology,
boolean isRebalance)
Receive notification of topology changes. |
void |
start()
|
void |
startOutboundTransfer(Address destination,
int requestTopologyId,
Set<Integer> segments)
Start to send cache entries that belong to the given set of segments. |
void |
stop()
Cancels all outbound state transfers. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public StateProviderImpl()
Method Detail |
---|
public void init(Cache cache, ExecutorService executorService, Configuration configuration, RpcManager rpcManager, CommandsFactory commandsFactory, CacheNotifier cacheNotifier, CacheLoaderManager cacheLoaderManager, DataContainer dataContainer, TransactionTable transactionTable, StateTransferLock stateTransferLock, StateConsumer stateConsumer)
public boolean isStateTransferInProgress()
isStateTransferInProgress
in interface StateProvider
public void onTopologyChange(TopologyChangedEvent<?,?> tce)
public void onTopologyUpdate(CacheTopology cacheTopology, boolean isRebalance)
StateProvider
onTopologyUpdate
in interface StateProvider
public void start()
start
in interface StateProvider
public void stop()
StateProvider
stop
in interface StateProvider
public List<TransactionInfo> getTransactionsForSegments(Address destination, int requestTopologyId, Set<Integer> segments) throws InterruptedException
StateProvider
getTransactionsForSegments
in interface StateProvider
destination
- the address of the requester
InterruptedException
public void startOutboundTransfer(Address destination, int requestTopologyId, Set<Integer> segments) throws InterruptedException
StateProvider
startOutboundTransfer
in interface StateProvider
destination
- the address of the requester
InterruptedException
public void cancelOutboundTransfer(Address destination, int topologyId, Set<Integer> segments)
StateProvider
cancelOutboundTransfer
in interface StateProvider
destination
- the address of the requestersegments
- the segments that we have to cancel transfer for
|
Infinispan Distribution 5.2.6.Final-redhat-2 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |