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

Class AsyncReplicationSourceChannel

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.groups.AbstractReplicationSourceChannel

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

All Implemented Interfaces:

IReplicationSourceChannel, IConnectionStateListener

Direct Known Subclasses:

ReliableAsyncReplicationSourceChannel

public class AsyncReplicationSourceChannel
extends AbstractReplicationSourceChannel

Nested Class Summary

Nested Classes

Modifier and Type	Class	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

Nested classes/interfaces inherited from class com.gigaspaces.internal.cluster.node.impl.groups.AbstractReplicationSourceChannel

AbstractReplicationSourceChannel.ChannelState

Field Summary

Fields inherited from class com.gigaspaces.internal.cluster.node.impl.groups.AbstractReplicationSourceChannel

_packetsPool, _specificLogger, _specificVerboseLogger, _statisticsCounter

Constructor Summary

Constructors

Constructor	Description
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)
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)
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)

Method Summary

Modifier and Type	Method	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()

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.groups.AbstractReplicationSourceChannel

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, wrapConnection

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AsyncReplicationSourceChannel

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)

AsyncReplicationSourceChannel

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)

AsyncReplicationSourceChannel

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)

Method Details

start

protected void start()

Overrides:

start in class AbstractReplicationSourceChannel

getBatchSize

public int getBatchSize()

onActiveImpl

protected void onActiveImpl()

Specified by:

onActiveImpl in class AbstractReplicationSourceChannel

onDisconnectedImpl

protected void onDisconnectedImpl()

Specified by:

onDisconnectedImpl in class AbstractReplicationSourceChannel

closeImpl

protected void closeImpl()

Specified by:

closeImpl in class AbstractReplicationSourceChannel

execute

public void execute(IReplicationGroupOutContext groupContext)

getPendingPackets

protected List<IReplicationOrderedPacket> getPendingPackets()

flushPendingReplication

public void flushPendingReplication()

Specified by:

flushPendingReplication in class AbstractReplicationSourceChannel

getChannelOpertingMode

public ReplicationStatistics.ReplicationOperatingMode getChannelOpertingMode()

Specified by:

getChannelOpertingMode in class AbstractReplicationSourceChannel

onAsyncReplicateErrorResult

protected void onAsyncReplicateErrorResult(Throwable t,
 IReplicationOrderedPacket finalPacket)

Specified by:

onAsyncReplicateErrorResult in class AbstractReplicationSourceChannel

onAsyncReplicateErrorResult

protected void onAsyncReplicateErrorResult(Throwable t,
 List<IReplicationOrderedPacket> finalPackets)

Specified by:

onAsyncReplicateErrorResult in class AbstractReplicationSourceChannel