Package com.gigaspaces.internal.cluster.node.impl.groups.async

Class AsyncReplicationSourceChannel.AsyncDispatcher

java.lang.Object
com.gigaspaces.internal.utils.concurrent.AsyncCallable
com.gigaspaces.internal.cluster.node.impl.groups.async.AsyncReplicationSourceChannel.AsyncDispatcher
All Implemented Interfaces:
IAsyncReplicationListener, Callable<IAsyncHandlerProvider.CycleResult>
Enclosing class:
AsyncReplicationSourceChannel
public class AsyncReplicationSourceChannel.AsyncDispatcher extends AsyncCallable implements IAsyncReplicationListener
The async channel is in two states: 1) Idle (the async dispatcher has returned an IDLE_CONTINUE result) 2) Sending: 2.1) The async dispatcher is running (the call method is being executed), it is preparing the the packets for sending, and then dispatch them to the target in asynchronous manner 2.2) The async dispatcher is suspended, waiting to be resumed or waken once the async result is recieved and processed 2.3) onResult is called when the async result is arrived and the result is being processed which in its turn decide whether to go into idle mode or to continue to another sending cycle if there are enough packets pending