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

Class AbstractReplicationTargetGroup

java.lang.Object

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

All Implemented Interfaces:

IReplicationGroupHistory, IReplicationTargetGroup

Direct Known Subclasses:

AbstractAsyncReplicationTargetGroup, AbstractSyncReplicationTargetGroup, ReliableAsyncSingleOriginReplicationTargetGroup

public abstract class AbstractReplicationTargetGroup
extends Object
implements IReplicationTargetGroup, IReplicationGroupHistory

Field Summary

Fields

Modifier and Type	Field and Description
protected int	_channelCloseTimeout
protected static org.slf4j.Logger	_loggerReplica
protected org.slf4j.Logger	_specificLogger

Constructor Summary

Constructors

Constructor and Description
AbstractReplicationTargetGroup(TargetGroupConfig groupConfig, IReplicationRouter replicationRouter, IReplicationInFacade replicationInFacade, IReplicationInFilter inFilter, IReplicationTargetGroupStateListener stateListener)

Method Summary

Modifier and Type	Method and Description
void	addSynchronizeState(String sourceMemberLookupName, SpaceReplicaState spaceReplicaState)
void	close() Close this replication group, once closed it can no longer be used
protected void	closeChannel(AbstractReplicationTargetChannel channel)
ConnectChannelHandshakeResponse	connectChannel(RouterStubHolder sourceRouterStubHolder, ConnectChannelHandshakeRequest handshakeRequest) Connect a IReplicationSourceChannel to this group.
protected abstract AbstractReplicationTargetChannel	createNewChannelImpl(ReplicationEndpointDetails sourceEndpointDetails, IReplicationMonitoredConnection sourceConnection, IBacklogHandshakeRequest handshakeRequest, IReplicationGroupHistory groupHistory)
String	dumpState()
IReplicationTargetChannel	getChannel(String sourceMemberLookupName)
TargetGroupConfig	getGroupConfig()
String	getGroupName()
IReplicationInFilter	getInFilter()
long	getLastProcessTimeStamp(String replicaSourceLookupName)
IReplicationInFacade	getReplicationInFacade()
protected IReplicationRouter	getReplicationRouter()
IReplicationTargetGroupStateListener	getStateListener()
boolean	isFiltered()
void	logEvent(String memberName, String event)
void	logGroupEvent(String event)
void	onChannelBacklogDropped(String sourceMemberLookupName, Object sourceUniqueId, IBacklogMemberState memberState)
String	outputDescendingEvents(String memberName)
Object	process(String sourceMemberLookupName, Object sourceUniqueId, IReplicationOrderedPacket packet)
Object	processBatch(String sourceMemberLookupName, Object sourceUniqueId, List<IReplicationOrderedPacket> packets)
void	processHandshakeIteration(String sourceMemberLookupName, Object sourceUniqueId, IHandshakeIteration handshakeIteration)
Object	processIdleStateData(String sourceMemberLookupName, Object sourceUniqueId, IIdleStateData idleStateData)
void	processUnreliableOperation(String sourceMemberLookupName, Object sourceUniqueId, IReplicationUnreliableOperation operation)
void	setActive()
void	setPassive()
void	synchronizationDone(String sourceMemberLookupName, Object sourceUniqueId)
protected abstract void	validateConnectChannelImpl(String sourceMemberLookupName) Validate if can accept the channel request, no exception means this channel request can be accepted

Methods inherited from class java.lang.Object

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

Field Detail

_loggerReplica

protected static final org.slf4j.Logger _loggerReplica

_specificLogger

protected final org.slf4j.Logger _specificLogger

_channelCloseTimeout

protected final int _channelCloseTimeout

Constructor Detail

AbstractReplicationTargetGroup

public AbstractReplicationTargetGroup(TargetGroupConfig groupConfig,
                                      IReplicationRouter replicationRouter,
                                      IReplicationInFacade replicationInFacade,
                                      IReplicationInFilter inFilter,
                                      IReplicationTargetGroupStateListener stateListener)

Method Detail

logEvent

public void logEvent(String memberName,
                     String event)

Specified by:

logEvent in interface IReplicationGroupHistory

logGroupEvent

public void logGroupEvent(String event)

Specified by:

logGroupEvent in interface IReplicationGroupHistory

outputDescendingEvents

public String outputDescendingEvents(String memberName)

Specified by:

outputDescendingEvents in interface IReplicationGroupHistory

getReplicationRouter

protected IReplicationRouter getReplicationRouter()

getChannel

public IReplicationTargetChannel getChannel(String sourceMemberLookupName)

Specified by:

getChannel in interface IReplicationTargetGroup

connectChannel

public ConnectChannelHandshakeResponse connectChannel(RouterStubHolder sourceRouterStubHolder,
                                                      ConnectChannelHandshakeRequest handshakeRequest)

Description copied from interface: IReplicationTargetGroup

Connect a IReplicationSourceChannel to this group. The success or failure of this operation is indicated by the result IProcessLogHandshakeResponse

Specified by:

connectChannel in interface IReplicationTargetGroup

handshakeRequest - the handshake related details

Returns:

The success or failure of this operation is indicated by the result IProcessLogHandshakeResponse

onChannelBacklogDropped

public void onChannelBacklogDropped(String sourceMemberLookupName,
                                    Object sourceUniqueId,
                                    IBacklogMemberState memberState)

Specified by:

onChannelBacklogDropped in interface IReplicationTargetGroup

processHandshakeIteration

public void processHandshakeIteration(String sourceMemberLookupName,
                                      Object sourceUniqueId,
                                      IHandshakeIteration handshakeIteration)

Specified by:

processHandshakeIteration in interface IReplicationTargetGroup

createNewChannelImpl

protected abstract AbstractReplicationTargetChannel createNewChannelImpl(ReplicationEndpointDetails sourceEndpointDetails,
                                                                         IReplicationMonitoredConnection sourceConnection,
                                                                         IBacklogHandshakeRequest handshakeRequest,
                                                                         IReplicationGroupHistory groupHistory)

processBatch

public Object processBatch(String sourceMemberLookupName,
                           Object sourceUniqueId,
                           List<IReplicationOrderedPacket> packets)

Specified by:

processBatch in interface IReplicationTargetGroup

processIdleStateData

public Object processIdleStateData(String sourceMemberLookupName,
                                   Object sourceUniqueId,
                                   IIdleStateData idleStateData)

Specified by:

processIdleStateData in interface IReplicationTargetGroup

process

public Object process(String sourceMemberLookupName,
                      Object sourceUniqueId,
                      IReplicationOrderedPacket packet)

Specified by:

process in interface IReplicationTargetGroup

processUnreliableOperation

public void processUnreliableOperation(String sourceMemberLookupName,
                                       Object sourceUniqueId,
                                       IReplicationUnreliableOperation operation)

Specified by:

processUnreliableOperation in interface IReplicationTargetGroup

getGroupName

public String getGroupName()

Specified by:

getGroupName in interface IReplicationTargetGroup

getInFilter

public IReplicationInFilter getInFilter()

getGroupConfig

public TargetGroupConfig getGroupConfig()

closeChannel

protected void closeChannel(AbstractReplicationTargetChannel channel)

close

public void close()

Description copied from interface: IReplicationTargetGroup

Close this replication group, once closed it can no longer be used

Specified by:

close in interface IReplicationTargetGroup

getLastProcessTimeStamp

public long getLastProcessTimeStamp(String replicaSourceLookupName)

Specified by:

getLastProcessTimeStamp in interface IReplicationTargetGroup

addSynchronizeState

public void addSynchronizeState(String sourceMemberLookupName,
                                SpaceReplicaState spaceReplicaState)

Specified by:

addSynchronizeState in interface IReplicationTargetGroup

synchronizationDone

public void synchronizationDone(String sourceMemberLookupName,
                                Object sourceUniqueId)

Specified by:

synchronizationDone in interface IReplicationTargetGroup

isFiltered

public boolean isFiltered()

getStateListener

public IReplicationTargetGroupStateListener getStateListener()

setActive

public void setActive()

Specified by:

setActive in interface IReplicationTargetGroup

setPassive

public void setPassive()

Specified by:

setPassive in interface IReplicationTargetGroup

validateConnectChannelImpl

protected abstract void validateConnectChannelImpl(String sourceMemberLookupName)

Validate if can accept the channel request, no exception means this channel request can be accepted

getReplicationInFacade

public IReplicationInFacade getReplicationInFacade()

dumpState

public String dumpState()

Specified by:

dumpState in interface IReplicationTargetGroup