|
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.InboundTransferTask
public class InboundTransferTask
Inbound state transfer task. Fetches multiple data segments from a remote source node and applies them to local cache. Instances of InboundTransferTask are created and managed by StateTransferManagerImpl. StateTransferManagerImpl must have zero or one such task for each segment.
Constructor Summary | |
---|---|
InboundTransferTask(Set<Integer> segments,
Address source,
int topologyId,
StateConsumerImpl stateConsumer,
RpcManager rpcManager,
CommandsFactory commandsFactory,
long timeout,
String cacheName)
|
Method Summary | |
---|---|
boolean |
awaitCompletion()
Wait until all segments are received, cancelled, or the task is terminated abruptly by terminate() . |
void |
cancel()
|
void |
cancelSegments(Set<Integer> cancelledSegments)
Cancels a subset of the segments. |
Set<Integer> |
getSegments()
|
Address |
getSource()
|
Set<Integer> |
getUnfinishedSegments()
|
void |
onStateReceived(int segmentId,
boolean isLastChunk)
|
boolean |
requestSegments()
Send START_STATE_TRANSFER request to source node. |
void |
terminate()
Terminate abruptly regardless if the segments were received or not. |
String |
toString()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public InboundTransferTask(Set<Integer> segments, Address source, int topologyId, StateConsumerImpl stateConsumer, RpcManager rpcManager, CommandsFactory commandsFactory, long timeout, String cacheName)
Method Detail |
---|
public Set<Integer> getSegments()
public Set<Integer> getUnfinishedSegments()
public Address getSource()
public boolean requestSegments()
public void cancelSegments(Set<Integer> cancelledSegments)
cancelledSegments
- the segments to be cancelledpublic void cancel()
public void onStateReceived(int segmentId, boolean isLastChunk)
public boolean awaitCompletion() throws InterruptedException
terminate()
.
InterruptedException
- if the thread is interrupted while waitingpublic void terminate()
public String toString()
toString
in class Object
|
Infinispan Distribution 5.2.6.Final-redhat-2 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |