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

Class SyncReplicationSourceChannel

java.lang.Object

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

com.gigaspaces.internal.cluster.node.impl.groups.sync.SyncReplicationSourceChannel

All Implemented Interfaces:

IReplicationSourceChannel, IConnectionStateListener

public class SyncReplicationSourceChannel
extends AbstractReplicationSourceChannel

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	SyncReplicationSourceChannel.AsyncDispatcher

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

SyncReplicationSourceChannel(DynamicSourceGroupConfigHolder groupConfig, String groupName, String memberName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationGroupBacklog groupBacklog, IReplicationOutFilter outFilter, IReplicationThrottleController throttleController, IAsyncHandlerProvider asyncHandlerProvider, int asyncStateBatchSize, long idleDelayMilis, IReplicationChannelDataFilter dataFilter, IReplicationSourceGroupStateListener stateListener, IReplicationGroupHistory groupHistory, ReplicationStatistics.ReplicationMode channelType, Object customBacklogMetadata)

Method Summary

Modifier and Type	Method	Description
protected void	closeImpl()
int	execute(ISyncReplicationGroupOutContext context)
Future<?>	executeAsync(ISyncReplicationGroupOutContext context)
void	flushPendingReplication()
ReplicationStatistics.ReplicationOperatingMode	getChannelOpertingMode()
boolean	isSync()
protected void	onActiveImpl()
protected void	onAsyncReplicateErrorResult(Throwable t, IReplicationOrderedPacket packet)
protected void	onAsyncReplicateErrorResult(Throwable t, List<IReplicationOrderedPacket> packets)
protected void	onDisconnectedImpl()
String	onDumpState()

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, pingTarget, registerWith, replicate, replicate, replicateAsync, replicateAsync, replicateBatch, replicateBatchDelayed, replicateBatchDelayedAsync, sampleStatistics, signalSynchronizingDone, start, stopSynchronization, synchronizationCopyStageDone, synchronizationDataGenerated, wrapConnection

Methods inherited from class java.lang.Object

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

Constructor Details

SyncReplicationSourceChannel

public SyncReplicationSourceChannel(DynamicSourceGroupConfigHolder groupConfig,
 String groupName,
 String memberName,
 IReplicationRouter replicationRouter,
 IReplicationMonitoredConnection connection,
 IReplicationGroupBacklog groupBacklog,
 IReplicationOutFilter outFilter,
 IReplicationThrottleController throttleController,
 IAsyncHandlerProvider asyncHandlerProvider,
 int asyncStateBatchSize,
 long idleDelayMilis,
 IReplicationChannelDataFilter dataFilter,
 IReplicationSourceGroupStateListener stateListener,
 IReplicationGroupHistory groupHistory,
 ReplicationStatistics.ReplicationMode channelType,
 Object customBacklogMetadata)

Method Details

executeAsync

public Future<?> executeAsync(ISyncReplicationGroupOutContext context)

onAsyncReplicateErrorResult

protected void onAsyncReplicateErrorResult(Throwable t,
 IReplicationOrderedPacket packet)

Specified by:

onAsyncReplicateErrorResult in class AbstractReplicationSourceChannel

onAsyncReplicateErrorResult

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

Specified by:

onAsyncReplicateErrorResult in class AbstractReplicationSourceChannel

execute

public int execute(ISyncReplicationGroupOutContext context)

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

isSync

public boolean isSync()

flushPendingReplication

public void flushPendingReplication()

Specified by:

flushPendingReplication in class AbstractReplicationSourceChannel

getChannelOpertingMode

public ReplicationStatistics.ReplicationOperatingMode getChannelOpertingMode()

Specified by:

getChannelOpertingMode in class AbstractReplicationSourceChannel

onDumpState

public String onDumpState()

Overrides:

onDumpState in class AbstractReplicationSourceChannel