Package 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

Description

OutboundTransferTask(Address destination, IntSet segments, int segmentCount, int chunkSize, int topologyId, KeyPartitioner keyPartitioner, Consumer<OutboundTransferTask> onCompletion, Consumer<List<StateChunk>> onChunkReplicated, BiFunction<InternalCacheEntry,org.infinispan.container.impl.InternalEntryFactory,InternalCacheEntry> mapEntryFromDataContainer, BiFunction<MarshalledEntry,org.infinispan.container.impl.InternalEntryFactory,InternalCacheEntry> mapEntryFromStore, org.infinispan.container.impl.InternalDataContainer dataContainer, PersistenceManager persistenceManager, RpcManager rpcManager, org.infinispan.commands.CommandsFactory commandsFactory, org.infinispan.container.impl.InternalEntryFactory ef, long timeout, String cacheName, boolean applyState, boolean pushTransfer)

Method Summary

Modifier and Type	Method	Description
void	cancel()	Cancel the whole task.
void	cancelSegments(IntSet cancelledSegments)	Cancel some of the segments.
static InternalCacheEntry	defaultMapEntryFromDataContainer(InternalCacheEntry ice, org.infinispan.container.impl.InternalEntryFactory entryFactory)
static InternalCacheEntry	defaultMapEntryFromStore(MarshalledEntry me, org.infinispan.container.impl.InternalEntryFactory entryFactory)
void	execute(ExecutorService executorService)
Address	getDestination()
IntSet	getSegments()
int	getTopologyId()
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,
                            IntSet segments,
                            int segmentCount,
                            int chunkSize,
                            int topologyId,
                            KeyPartitioner keyPartitioner,
                            Consumer<OutboundTransferTask> onCompletion,
                            Consumer<List<StateChunk>> onChunkReplicated,
                            BiFunction<InternalCacheEntry,org.infinispan.container.impl.InternalEntryFactory,InternalCacheEntry> mapEntryFromDataContainer,
                            BiFunction<MarshalledEntry,org.infinispan.container.impl.InternalEntryFactory,InternalCacheEntry> mapEntryFromStore,
                            org.infinispan.container.impl.InternalDataContainer dataContainer,
                            PersistenceManager persistenceManager,
                            RpcManager rpcManager,
                            org.infinispan.commands.CommandsFactory commandsFactory,
                            org.infinispan.container.impl.InternalEntryFactory ef,
                            long timeout,
                            String cacheName,
                            boolean applyState,
                            boolean pushTransfer)

Method Detail

execute

public void execute(ExecutorService executorService)

getDestination

public Address getDestination()

getSegments

public IntSet getSegments()

getTopologyId

public int getTopologyId()

run

public void run()

Specified by:

run in interface Runnable

cancelSegments

public void cancelSegments(IntSet 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

defaultMapEntryFromDataContainer

public static InternalCacheEntry defaultMapEntryFromDataContainer(InternalCacheEntry ice,
                                                                  org.infinispan.container.impl.InternalEntryFactory entryFactory)

defaultMapEntryFromStore

public static InternalCacheEntry defaultMapEntryFromStore(MarshalledEntry me,
                                                          org.infinispan.container.impl.InternalEntryFactory entryFactory)