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

Class SyncReplicationSourceGroup

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.groups.AbstractReplicationSourceGroup<SourceGroupConfig>

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

All Implemented Interfaces:

DynamicSourceGroupConfigHolder.IDynamicSourceGroupStateListener, IReplicationGroupHistory, IReplicationSourceGroup

public class SyncReplicationSourceGroup
extends AbstractReplicationSourceGroup<SourceGroupConfig>
implements IReplicationSourceGroup

Field Summary

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

_channelCreationLock, _specificLogger

Constructor Summary

Constructors

Constructor and Description

SyncReplicationSourceGroup(DynamicSourceGroupConfigHolder groupConfig, IReplicationRouter replicationRouter, IReplicationOutFilter outFilter, IReplicationThrottleControllerBuilder throttleControllerBuilder, IAsyncHandlerProvider asyncStateHandlerProvider, int asyncStateBatchSize, long idleDelayMilis, IReplicationSyncGroupBacklog groupBacklog, String myLookupName, IReplicationSourceGroupStateListener stateListener, ReplicationStatistics.ReplicationMode channelType)

Method Summary

Modifier and Type	Method and Description
void	beforeExecute(ReplicationOutContext replicationContext, IEntryHolder entryHolder, ReplicationSingleOperationType operationType) Creates a single entry holder operation replication data from the given properties and add it to the provided context
void	beforeExecuteGeneric(ReplicationOutContext replicationContext, Object operationData, ReplicationSingleOperationType operationType) Create a single type descriptor operation replication data and add it to provided context
void	beforeTransactionExecute(ReplicationOutContext replicationContext, ServerTransaction transaction, ArrayList<IEntryHolder> lockedEntries, ReplicationMultipleOperationType operationType) Creates transaction replication data and adds it to the provided context
protected AbstractReplicationSourceChannel	createChannel(String memberLookupName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationChannelDataFilter dataFilter, IReplicationGroupHistory groupHistory, boolean dynamicMember, SourceGroupConfig groupConfig, Object customBacklogMetadata, boolean resetTarget)
int	executeImpl(IReplicationGroupOutContext groupContext)
protected AbstractReplicationSourceChannel	getChannel(String memberLookupName)
boolean	isSingleTarget()
protected void	onCloseTemporaryChannel(String sourceMemberName, AbstractReplicationSourceChannel channel)

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

beginSynchronizing, beginSynchronizing, checkChannelConnected, close, closeReplicationChannels, closeTemporaryChannel, createChannel, createReplicationChannels, createTemporaryChannel, dumpState, execute, execute, flushPendingReplication, getAsyncHandlerProvider, getChannelEndpointDetails, getChannelHistory, getChannels, getChannelSafe, getChannelsStatus, getConfigHolder, getGroupBacklog, getGroupName, getLogPrefix, getMyLookupName, getOutFilter, getPotentialRemovedMembers, getStateListener, getStatistics, logEvent, logGroupEvent, memberAdded, memberRemoved, monitorConsistencyLevel, onClose, onMemberAdded, onMemberRemoved, outputDescendingEvents, registerWith, sampleStatistics, scanAndRemoveDroppedMembers, setActive, setPassive, stopSynchronization, synchronizationCopyStageDone, synchronizationDataGenerated, validateGroupConsistencyLevelPolicy

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.gigaspaces.internal.cluster.node.impl.groups.IReplicationSourceGroup

beginSynchronizing, beginSynchronizing, checkChannelConnected, close, closeTemporaryChannel, createTemporaryChannel, dumpState, execute, execute, flushPendingReplication, getChannelEndpointDetails, getChannelsStatus, getConfigHolder, getGroupBacklog, getGroupName, getStatistics, monitorConsistencyLevel, registerWith, sampleStatistics, setActive, setPassive, stopSynchronization, synchronizationCopyStageDone, synchronizationDataGenerated

Constructor Detail

SyncReplicationSourceGroup

public SyncReplicationSourceGroup(DynamicSourceGroupConfigHolder groupConfig,
                                  IReplicationRouter replicationRouter,
                                  IReplicationOutFilter outFilter,
                                  IReplicationThrottleControllerBuilder throttleControllerBuilder,
                                  IAsyncHandlerProvider asyncStateHandlerProvider,
                                  int asyncStateBatchSize,
                                  long idleDelayMilis,
                                  IReplicationSyncGroupBacklog groupBacklog,
                                  String myLookupName,
                                  IReplicationSourceGroupStateListener stateListener,
                                  ReplicationStatistics.ReplicationMode channelType)

Method Detail

beforeExecute

public void beforeExecute(ReplicationOutContext replicationContext,
                          IEntryHolder entryHolder,
                          ReplicationSingleOperationType operationType)

Description copied from interface: IReplicationSourceGroup

Creates a single entry holder operation replication data from the given properties and add it to the provided context

Specified by:

beforeExecute in interface IReplicationSourceGroup

Parameters:

replicationContext - context to attach the replication data to

entryHolder - the entry holder data

operationType - the operation type

beforeTransactionExecute

public void beforeTransactionExecute(ReplicationOutContext replicationContext,
                                     ServerTransaction transaction,
                                     ArrayList<IEntryHolder> lockedEntries,
                                     ReplicationMultipleOperationType operationType)

Description copied from interface: IReplicationSourceGroup

Creates transaction replication data and adds it to the provided context

Specified by:

beforeTransactionExecute in interface IReplicationSourceGroup

beforeExecuteGeneric

public void beforeExecuteGeneric(ReplicationOutContext replicationContext,
                                 Object operationData,
                                 ReplicationSingleOperationType operationType)

Description copied from interface: IReplicationSourceGroup

Create a single type descriptor operation replication data and add it to provided context

Specified by:

beforeExecuteGeneric in interface IReplicationSourceGroup

executeImpl

public int executeImpl(IReplicationGroupOutContext groupContext)

Specified by:

executeImpl in class AbstractReplicationSourceGroup<SourceGroupConfig>

createChannel

protected AbstractReplicationSourceChannel createChannel(String memberLookupName,
                                                         IReplicationRouter replicationRouter,
                                                         IReplicationMonitoredConnection connection,
                                                         IReplicationChannelDataFilter dataFilter,
                                                         IReplicationGroupHistory groupHistory,
                                                         boolean dynamicMember,
                                                         SourceGroupConfig groupConfig,
                                                         Object customBacklogMetadata,
                                                         boolean resetTarget)

Specified by:

createChannel in class AbstractReplicationSourceGroup<SourceGroupConfig>

onCloseTemporaryChannel

protected void onCloseTemporaryChannel(String sourceMemberName,
                                       AbstractReplicationSourceChannel channel)

Specified by:

onCloseTemporaryChannel in class AbstractReplicationSourceGroup<SourceGroupConfig>

getChannel

protected AbstractReplicationSourceChannel getChannel(String memberLookupName)

Overrides:

getChannel in class AbstractReplicationSourceGroup<SourceGroupConfig>

isSingleTarget

public boolean isSingleTarget()