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

Class ReliableAsyncReplicationSourceGroup

java.lang.Object

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

com.gigaspaces.internal.cluster.node.impl.groups.reliableasync.ReliableAsyncReplicationSourceGroup

All Implemented Interfaces:

IReplicationBacklogStateListener, DynamicSourceGroupConfigHolder.IDynamicSourceGroupStateListener, IReplicationGroupHistory, IReplicationSourceGroup

public class ReliableAsyncReplicationSourceGroup
extends AbstractReplicationSourceGroup<ReliableAsyncSourceGroupConfig>
implements IReplicationBacklogStateListener

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	ReliableAsyncReplicationSourceGroup.AsyncCompletionNotifier

Field Summary

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

_channelCreationLock, _specificLogger

Constructor Summary

Constructors

Constructor

Description

ReliableAsyncReplicationSourceGroup(DynamicSourceGroupConfigHolder groupConfig, IReplicationRouter replicationRouter, IReplicationReliableAsyncGroupBacklog groupBacklog, String myLookupName, IReplicationOutFilter outFilter, IReplicationThrottleControllerBuilder throttleController, IAsyncHandlerProvider asyncHandlerProvider, int syncChannelAsyncStateBatchSize, long syncChannelIdleDelayMilis, int asyncChannelBatchSize, long asyncChannelInterval, int asyncChannelIntervalOperations, IReplicationSourceGroupStateListener stateListener)

Method Summary

Modifier and Type	Method	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)
void	execute(IReplicationUnreliableOperation operation)
int	executeImpl(IReplicationGroupOutContext groupContext)
protected AbstractReplicationSourceChannel	getChannel(String memberLookupName)
protected String[]	getPotentialRemovedMembers(SourceGroupConfig config)
boolean	isSingleTarget()
void	monitorConsistencyLevel()	Monitors sla state of the replication group
protected void	notifyKeepersOfGroupMembersChange(SourceGroupConfig newConfig)
protected void	onClose()
protected void	onCloseTemporaryChannel(String sourceMemberName, AbstractReplicationSourceChannel channel)
protected void	onMemberAdded(MemberAddedEvent memberAddedEvent, SourceGroupConfig newConfig)
protected void	onMemberRemoved(String memberName, SourceGroupConfig newConfig)
void	onPacketsClearedAfterConfirmation(long packetsCount)
void	setActive(MetricRegistrator metricRegistrator)
void	setPassive(boolean closeProxy)
protected void	validateGroupConsistencyLevelPolicy(GroupConsistencyLevelPolicy groupSlaPolicy, ReliableAsyncSourceGroupConfig sourceGroupConfig)

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

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

Methods inherited from class java.lang.Object

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

Constructor Details

ReliableAsyncReplicationSourceGroup

public ReliableAsyncReplicationSourceGroup(DynamicSourceGroupConfigHolder groupConfig,
 IReplicationRouter replicationRouter,
 IReplicationReliableAsyncGroupBacklog groupBacklog,
 String myLookupName,
 IReplicationOutFilter outFilter,
 IReplicationThrottleControllerBuilder throttleController,
 IAsyncHandlerProvider asyncHandlerProvider,
 int syncChannelAsyncStateBatchSize,
 long syncChannelIdleDelayMilis,
 int asyncChannelBatchSize,
 long asyncChannelInterval,
 int asyncChannelIntervalOperations,
 IReplicationSourceGroupStateListener stateListener)

Method Details

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<ReliableAsyncSourceGroupConfig>

onCloseTemporaryChannel

protected void onCloseTemporaryChannel(String sourceMemberName,
 AbstractReplicationSourceChannel channel)

Specified by:

onCloseTemporaryChannel in class AbstractReplicationSourceGroup<ReliableAsyncSourceGroupConfig>

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

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

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

executeImpl

public int executeImpl(IReplicationGroupOutContext groupContext)

Specified by:

executeImpl in class AbstractReplicationSourceGroup<ReliableAsyncSourceGroupConfig>

execute

public void execute(IReplicationUnreliableOperation operation)

Specified by:

execute in interface IReplicationSourceGroup

Overrides:

execute in class AbstractReplicationSourceGroup<ReliableAsyncSourceGroupConfig>

validateGroupConsistencyLevelPolicy

protected void validateGroupConsistencyLevelPolicy(GroupConsistencyLevelPolicy groupSlaPolicy,
 ReliableAsyncSourceGroupConfig sourceGroupConfig)

Overrides:

validateGroupConsistencyLevelPolicy in class AbstractReplicationSourceGroup<ReliableAsyncSourceGroupConfig>

monitorConsistencyLevel

public void monitorConsistencyLevel()
                             throws ConsistencyLevelViolationException

Description copied from interface: IReplicationSourceGroup

Monitors sla state of the replication group

Specified by:

monitorConsistencyLevel in interface IReplicationSourceGroup

Overrides:

monitorConsistencyLevel in class AbstractReplicationSourceGroup<ReliableAsyncSourceGroupConfig>

Throws:

ConsistencyLevelViolationException - if the sla is breached

getChannel

protected AbstractReplicationSourceChannel getChannel(String memberLookupName)

Overrides:

getChannel in class AbstractReplicationSourceGroup<ReliableAsyncSourceGroupConfig>

onMemberAdded

protected void onMemberAdded(MemberAddedEvent memberAddedEvent,
 SourceGroupConfig newConfig)

Overrides:

onMemberAdded in class AbstractReplicationSourceGroup<ReliableAsyncSourceGroupConfig>

notifyKeepersOfGroupMembersChange

protected void notifyKeepersOfGroupMembersChange(SourceGroupConfig newConfig)

onMemberRemoved

protected void onMemberRemoved(String memberName,
 SourceGroupConfig newConfig)

Overrides:

onMemberRemoved in class AbstractReplicationSourceGroup<ReliableAsyncSourceGroupConfig>

setActive

public void setActive(MetricRegistrator metricRegistrator)

Specified by:

setActive in interface IReplicationSourceGroup

Overrides:

setActive in class AbstractReplicationSourceGroup<ReliableAsyncSourceGroupConfig>

setPassive

public void setPassive(boolean closeProxy)

Specified by:

setPassive in interface IReplicationSourceGroup

Overrides:

setPassive in class AbstractReplicationSourceGroup<ReliableAsyncSourceGroupConfig>

Parameters:

closeProxy - - whether to close the stub proxy when it has no more references.

onClose

protected void onClose()

Overrides:

onClose in class AbstractReplicationSourceGroup<ReliableAsyncSourceGroupConfig>

isSingleTarget

public boolean isSingleTarget()

getPotentialRemovedMembers

protected String[] getPotentialRemovedMembers(SourceGroupConfig config)

Overrides:

getPotentialRemovedMembers in class AbstractReplicationSourceGroup<ReliableAsyncSourceGroupConfig>

onPacketsClearedAfterConfirmation

public void onPacketsClearedAfterConfirmation(long packetsCount)

Specified by:

onPacketsClearedAfterConfirmation in interface IReplicationBacklogStateListener