Package com.gigaspaces.internal.cluster.node.impl.processlog.globalorder

Class AbstractGlobalOrderTargetProcessLog

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.processlog.AbstractSingleFileTargetProcessLog

com.gigaspaces.internal.cluster.node.impl.processlog.globalorder.AbstractGlobalOrderTargetProcessLog

All Implemented Interfaces:

IReplicationTargetProcessLog

Direct Known Subclasses:

GlobalOrderBatchConsumeTargetProcessLog, GlobalOrderTargetProcessLog

public abstract class AbstractGlobalOrderTargetProcessLog
extends AbstractSingleFileTargetProcessLog
implements IReplicationTargetProcessLog

Field Summary

Fields

Modifier and Type	Field	Description
protected long	_lastProcessedKey
protected final Object	_lifeCycleLock
protected final Lock	_lock

Fields inherited from class com.gigaspaces.internal.cluster.node.impl.processlog.AbstractSingleFileTargetProcessLog

_dataConsumer, _specificLogger

Constructor Summary

Constructors

Constructor	Description
AbstractGlobalOrderTargetProcessLog(IReplicationPacketDataConsumer dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, long lastProcessedKey, boolean firstHandshakeForTarget, IReplicationGroupHistory groupHistory)

Method Summary

Modifier and Type	Method	Description
protected boolean	canResetState()
boolean	close(long time, TimeUnit unit)
String	dumpState()
protected String	dumpStateExtra()
protected boolean	filterDuplicate(IReplicationOrderedPacket packet)
protected void	filterDuplicate(List<IReplicationOrderedPacket> packets)
long	getLastProcessedKey()
protected boolean	isClosed()
boolean	isFirstHandshakeForTarget()
protected boolean	isOpen()
protected void	logDeletion(GlobalOrderDeletedBacklogPacket deletedBacklogPacket)
protected abstract void	onClose()
GlobalOrderProcessLogHandshakeResponse	performHandshake(String memberName, IBacklogHandshakeRequest handshakeRequest)
void	processHandshakeIteration(String sourceMemberName, IHandshakeIteration handshakeIteration)
IProcessResult	processIdleStateData(String string, IIdleStateData idleStateData, IReplicationInFilterCallback inFilterCallback)
IProcessLogHandshakeResponse	resync(IBacklogHandshakeRequest handshakeRequest)
protected void	throwClosedException()
Object	toWireForm(IProcessResult processResult)

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.processlog.AbstractSingleFileTargetProcessLog

contentRequiredWhileProcessing, createReplicationInContext, getDataConsumer, getExceptionHandler, getGroupHistory, getGroupName, getReplicationInContext, getReplicationInFacade, getSourceLookupName, throwIfRepetitiveError, toLogMessage

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.processlog.IReplicationTargetProcessLog

getDataConsumer, process, processBatch, toLogMessage

Field Details

_lifeCycleLock

protected final Object _lifeCycleLock

_lock

protected final Lock _lock

_lastProcessedKey

protected long _lastProcessedKey

Constructor Details

AbstractGlobalOrderTargetProcessLog

public AbstractGlobalOrderTargetProcessLog(IReplicationPacketDataConsumer dataConsumer,
 IReplicationProcessLogExceptionHandler exceptionHandler,
 IReplicationInFacade replicationInFacade,
 String name,
 String groupName,
 String sourceLookupName,
 long lastProcessedKey,
 boolean firstHandshakeForTarget,
 IReplicationGroupHistory groupHistory)

Method Details

getLastProcessedKey

public long getLastProcessedKey()

isFirstHandshakeForTarget

public boolean isFirstHandshakeForTarget()

performHandshake

public GlobalOrderProcessLogHandshakeResponse performHandshake(String memberName,
 IBacklogHandshakeRequest handshakeRequest)
                                                        throws IncomingReplicationOutOfSyncException

Specified by:

performHandshake in interface IReplicationTargetProcessLog

Throws:

IncomingReplicationOutOfSyncException

canResetState

protected boolean canResetState()

throwClosedException

protected void throwClosedException()

filterDuplicate

protected void filterDuplicate(List<IReplicationOrderedPacket> packets)

filterDuplicate

protected boolean filterDuplicate(IReplicationOrderedPacket packet)

close

public boolean close(long time,
 TimeUnit unit)
              throws InterruptedException

Specified by:

close in interface IReplicationTargetProcessLog

Throws:

InterruptedException

isOpen

protected boolean isOpen()

isClosed

protected boolean isClosed()

onClose

protected abstract void onClose()

resync

public IProcessLogHandshakeResponse resync(IBacklogHandshakeRequest handshakeRequest)

Specified by:

resync in interface IReplicationTargetProcessLog

processHandshakeIteration

public void processHandshakeIteration(String sourceMemberName,
 IHandshakeIteration handshakeIteration)

Specified by:

processHandshakeIteration in interface IReplicationTargetProcessLog

toWireForm

public Object toWireForm(IProcessResult processResult)

Specified by:

toWireForm in interface IReplicationTargetProcessLog

logDeletion

protected void logDeletion(GlobalOrderDeletedBacklogPacket deletedBacklogPacket)

dumpState

public String dumpState()

Specified by:

dumpState in interface IReplicationTargetProcessLog

Specified by:

dumpState in class AbstractSingleFileTargetProcessLog

dumpStateExtra

protected String dumpStateExtra()

processIdleStateData

public IProcessResult processIdleStateData(String string,
 IIdleStateData idleStateData,
 IReplicationInFilterCallback inFilterCallback)

Specified by:

processIdleStateData in interface IReplicationTargetProcessLog