public class AsyncReplicationSourceChannel extends AbstractReplicationSourceChannel
| Modifier and Type | Class and Description |
|---|---|
class |
AsyncReplicationSourceChannel.AsyncDispatcher
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
|
AbstractReplicationSourceChannel.ChannelState_packetsPool, _specificLogger, _specificVerboseLogger, _statisticsCounter| Modifier and Type | Method and Description |
|---|---|
protected void |
closeImpl() |
void |
execute(IReplicationGroupOutContext groupContext) |
void |
flushPendingReplication() |
int |
getBatchSize() |
ReplicationStatistics.ReplicationOperatingMode |
getChannelOpertingMode() |
protected List<IReplicationOrderedPacket> |
getPendingPackets() |
protected void |
onActiveImpl() |
protected void |
onAsyncReplicateErrorResult(Throwable t,
IReplicationOrderedPacket finalPacket) |
protected void |
onAsyncReplicateErrorResult(Throwable t,
List<IReplicationOrderedPacket> finalPackets) |
protected void |
onDisconnectedImpl() |
protected void |
start() |
beginSynchronizing, beginSynchronizing, close, dispatchBacklogDropped, dumpState, getChannelState, getConnection, getDataFilter, getGroupBacklog, getGroupName, getInconsistencyReason, getLastSampledTP, getMemberName, getMyLookupName, getPendingPackets, getSampleTPBefore, getStatistics, getTargetLogicalVersion, getTargetReplicationEndpointDetails, isActive, isClosed, isDataFiltered, isInconsistent, isSynchronizing, logEventInHistory, onConnected, onDisconnected, onDumpState, pingTarget, registerWith, replicate, replicate, replicateAsync, replicateAsync, replicateBatch, replicateBatchDelayed, replicateBatchDelayedAsync, sampleStatistics, signalSynchronizingDone, stopSynchronization, synchronizationCopyStageDone, synchronizationDataGenerated, wrapConnectionpublic AsyncReplicationSourceChannel(DynamicSourceGroupConfigHolder groupConfig, String groupName, String memberName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationGroupBacklog groupBacklog, IReplicationOutFilter outFilter, int batchSize, long intervalMilis, int intervalOperations, IAsyncHandlerProvider asyncHandlerProvider, IReplicationChannelDataFilter dataFilter, IReplicationSourceGroupStateListener stateListener, IReplicationGroupHistory groupHistory, ReplicationStatistics.ReplicationMode channelType, Object customBacklogMetadata, String tag)
public AsyncReplicationSourceChannel(DynamicSourceGroupConfigHolder groupConfig, String groupName, String memberName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationGroupBacklog groupBacklog, IReplicationOutFilter outFilter, int batchSize, long intervalMilis, int intervalOperations, IAsyncHandlerProvider asyncHandlerProvider, IReplicationChannelDataFilter dataFilter, IReplicationSourceGroupStateListener stateListener, IReplicationGroupHistory groupHistory, ReplicationStatistics.ReplicationMode channelType, Object customBacklogMetadata, String tag, boolean resetTarget)
public AsyncReplicationSourceChannel(DynamicSourceGroupConfigHolder groupConfig, String groupName, String memberName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationGroupBacklog groupBacklog, IReplicationOutFilter outFilter, int batchSize, long intervalMilis, int intervalOperations, IAsyncHandlerProvider asyncHandlerProvider, boolean autoStart, IReplicationChannelDataFilter dataFilter, IReplicationSourceGroupStateListener stateListener, IReplicationGroupHistory groupHistory, ReplicationStatistics.ReplicationMode channelType, Object customBacklogMetadata, String tag, boolean resetTarget)
protected void start()
start in class AbstractReplicationSourceChannelpublic int getBatchSize()
protected void onActiveImpl()
onActiveImpl in class AbstractReplicationSourceChannelprotected void onDisconnectedImpl()
onDisconnectedImpl in class AbstractReplicationSourceChannelprotected void closeImpl()
closeImpl in class AbstractReplicationSourceChannelpublic void execute(IReplicationGroupOutContext groupContext)
protected List<IReplicationOrderedPacket> getPendingPackets()
public void flushPendingReplication()
flushPendingReplication in class AbstractReplicationSourceChannelpublic ReplicationStatistics.ReplicationOperatingMode getChannelOpertingMode()
getChannelOpertingMode in class AbstractReplicationSourceChannelprotected void onAsyncReplicateErrorResult(Throwable t, IReplicationOrderedPacket finalPacket)
onAsyncReplicateErrorResult in class AbstractReplicationSourceChannelprotected void onAsyncReplicateErrorResult(Throwable t, List<IReplicationOrderedPacket> finalPackets)
onAsyncReplicateErrorResult in class AbstractReplicationSourceChannelCopyright © GigaSpaces.