org.infinispan.statetransfer
Class OutboundTransferTask
java.lang.Object
org.infinispan.statetransfer.OutboundTransferTask
- All Implemented Interfaces:
- Runnable
public class OutboundTransferTask
- extends Object
- implements Runnable
Outbound state transfer task. Pushes data segments to another cluster member on request. Instances of
OutboundTransferTask are created and managed by StateTransferManagerImpl. There should be at most
one such task per destination at any time.
- Since:
- 5.2
- Author:
- anistor@redhat.com
Constructor Summary |
OutboundTransferTask(Address destination,
Set<Integer> segments,
int stateTransferChunkSize,
int topologyId,
ConsistentHash readCh,
StateProviderImpl stateProvider,
DataContainer dataContainer,
CacheLoaderManager cacheLoaderManager,
RpcManager rpcManager,
CommandsFactory commandsFactory,
long timeout,
String cacheName)
|
OutboundTransferTask
public OutboundTransferTask(Address destination,
Set<Integer> segments,
int stateTransferChunkSize,
int topologyId,
ConsistentHash readCh,
StateProviderImpl stateProvider,
DataContainer dataContainer,
CacheLoaderManager cacheLoaderManager,
RpcManager rpcManager,
CommandsFactory commandsFactory,
long timeout,
String cacheName)
execute
public void execute(ExecutorService executorService)
getDestination
public Address getDestination()
getSegments
public Set<Integer> getSegments()
run
public void run()
- Specified by:
run
in interface Runnable
cancelSegments
public void cancelSegments(Set<Integer> cancelledSegments)
- Cancel some of the segments. If all segments get cancelled then the whole task will be cancelled.
- Parameters:
cancelledSegments
- segments to cancel.
cancel
public void cancel()
- Cancel the whole task.
isCancelled
public boolean isCancelled()
toString
public String toString()
- Overrides:
toString
in class Object
Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.