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

Class AsyncReplicationSourceGroup

java.lang.Object

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

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

All Implemented Interfaces:

DynamicSourceGroupConfigHolder.IDynamicSourceGroupStateListener, IReplicationGroupHistory, IReplicationSourceGroup

public class AsyncReplicationSourceGroup
extends AbstractReplicationSourceGroup<SourceGroupConfig>
implements IReplicationSourceGroup

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	AsyncReplicationSourceGroup.DroppedTargetScanner

Field Summary

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

_channelCreationLock, _specificLogger

Constructor Summary

Constructors

Constructor and Description
AsyncReplicationSourceGroup(DynamicSourceGroupConfigHolder groupConfig, IReplicationRouter replicationRouter, IReplicationAsyncGroupBacklog groupBacklog, String myLookupName, IReplicationOutFilter outFilter, int batchSize, long intervalMilis, int intervalOperations, IAsyncHandlerProvider asyncProvider, IReplicationSourceGroupStateListener stateListener)

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)
protected String[]	getPotentialRemovedMembers(SourceGroupConfig config)
protected void	onClose()
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, getStateListener, getStatistics, logEvent, logGroupEvent, memberAdded, memberRemoved, monitorConsistencyLevel, 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

AsyncReplicationSourceGroup

public AsyncReplicationSourceGroup(DynamicSourceGroupConfigHolder groupConfig,
                                   IReplicationRouter replicationRouter,
                                   IReplicationAsyncGroupBacklog groupBacklog,
                                   String myLookupName,
                                   IReplicationOutFilter outFilter,
                                   int batchSize,
                                   long intervalMilis,
                                   int intervalOperations,
                                   IAsyncHandlerProvider asyncProvider,
                                   IReplicationSourceGroupStateListener stateListener)

Method Detail

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>

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>

getChannel

protected AbstractReplicationSourceChannel getChannel(String memberLookupName)

Overrides:

getChannel in class AbstractReplicationSourceGroup<SourceGroupConfig>

getPotentialRemovedMembers

protected String[] getPotentialRemovedMembers(SourceGroupConfig config)

Overrides:

getPotentialRemovedMembers in class AbstractReplicationSourceGroup<SourceGroupConfig>

onClose

protected void onClose()

Overrides:

onClose in class AbstractReplicationSourceGroup<SourceGroupConfig>