Infinispan Distribution 5.2.6.Final-redhat-2

org.infinispan.statetransfer
Class OutboundTransferTask

java.lang.Object
  extended by 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)
           
 
Method Summary
 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,
                            CacheLoaderManager cacheLoaderManager,
                            RpcManager rpcManager,
                            CommandsFactory commandsFactory,
                            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

Infinispan Distribution 5.2.6.Final-redhat-2

Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.