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

Constructors

Constructor and Description
OutboundTransferTask(Address destination, Set<Integer> segments, int stateTransferChunkSize, int topologyId, ConsistentHash readCh, StateProviderImpl stateProvider, DataContainer dataContainer, PersistenceManager persistenceManager, RpcManager rpcManager, CommandsFactory commandsFactory, InternalEntryFactory ef, long timeout, String cacheName)

Method Summary

Methods

Modifier and Type	Method and Description
void	cancel() Cancel the whole task.
void	cancelSegments(Set<Integer> cancelledSegments) Cancel some of the segments.
void	execute(ExecutorService executorService)
Address	getDestination()
Set<Integer>	getSegments()
boolean	isCancelled()
void	run()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

OutboundTransferTask

public OutboundTransferTask(Address destination,
                    Set<Integer> segments,
                    int stateTransferChunkSize,
                    int topologyId,
                    ConsistentHash readCh,
                    StateProviderImpl stateProvider,
                    DataContainer dataContainer,
                    PersistenceManager persistenceManager,
                    RpcManager rpcManager,
                    CommandsFactory commandsFactory,
                    InternalEntryFactory ef,
                    long timeout,
                    String cacheName)

Method Detail

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