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

Class GlobalOrderReliableAsyncTargetKeeperProcessLog

java.lang.Object

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

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

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

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

All Implemented Interfaces:

IReplicationAsyncTargetProcessLog, IReplicationTargetProcessLog, IReplicationReliableAsyncKeeperTargetProcessLog, IReplicationSyncTargetProcessLog

Direct Known Subclasses:

MultiSourceSingleFileReliableAsyncTargetKeeperProcessLog

public class GlobalOrderReliableAsyncTargetKeeperProcessLog
extends GlobalOrderTargetProcessLog
implements IReplicationReliableAsyncKeeperTargetProcessLog

Nested Class Summary

Nested classes/interfaces inherited from class com.gigaspaces.internal.cluster.node.impl.processlog.globalorder.GlobalOrderTargetProcessLog

GlobalOrderTargetProcessLog.SharedOrderedPacketComparator

Field Summary

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

_lastProcessedKey, _lifeCycleLock, _lock

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

_dataConsumer, _specificLogger

Constructor Summary

Constructors

Constructor and Description
GlobalOrderReliableAsyncTargetKeeperProcessLog(GlobalOrderProcessLogConfig processLogConfig, IReplicationPacketDataConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, boolean oneWayMode, IReplicationGroupHistory groupHistory, IReplicationReliableAsyncMediator mediator)
GlobalOrderReliableAsyncTargetKeeperProcessLog(GlobalOrderProcessLogConfig processLogConfig, IReplicationPacketDataConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, long lastProcessedKey, boolean isFirstHandshake, boolean oneWayMode, IReplicationGroupHistory groupHistory, IReplicationReliableAsyncMediator mediator)

Method Summary

Modifier and Type	Method and Description
protected void	afterSuccessfulConsumption(String sourceLookupName, IReplicationOrderedPacket packet)
protected boolean	canResetState()
protected boolean	contentRequiredWhileProcessing()
ReplicationInContext	createReplicationInContext()
IReplicationReliableAsyncMediator	getMediator()
protected IReliableAsyncState	getReliableAsyncStateFromHandshakeRequest(IBacklogHandshakeRequest handshakeRequest)
ReplicationInContext	getReplicationInContext()
GlobalOrderProcessLogHandshakeResponse	performHandshake(String memberName, IBacklogHandshakeRequest handshakeRequest)
void	processHandshakeIteration(String sourceMemberName, IHandshakeIteration handshakeIteration)
protected boolean	shouldCloneOnFilter()

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

dumpStateExtra, onClose, process, processBatch, processPackets

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

close, dumpState, filterDuplicate, filterDuplicate, getLastProcessedKey, isClosed, isFirstHandshakeForTarget, isOpen, logDeletion, processIdleStateData, resync, throwClosedException, toWireForm

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

getDataConsumer, getExceptionHandler, getGroupHistory, getGroupName, 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

close, dumpState, getDataConsumer, processIdleStateData, resync, toLogMessage, toWireForm

Constructor Detail

GlobalOrderReliableAsyncTargetKeeperProcessLog

public GlobalOrderReliableAsyncTargetKeeperProcessLog(GlobalOrderProcessLogConfig processLogConfig,
                                                      IReplicationPacketDataConsumer<?> dataConsumer,
                                                      IReplicationProcessLogExceptionHandler exceptionHandler,
                                                      IReplicationInFacade replicationInFacade,
                                                      String name,
                                                      String groupName,
                                                      String sourceLookupName,
                                                      boolean oneWayMode,
                                                      IReplicationGroupHistory groupHistory,
                                                      IReplicationReliableAsyncMediator mediator)

GlobalOrderReliableAsyncTargetKeeperProcessLog

public GlobalOrderReliableAsyncTargetKeeperProcessLog(GlobalOrderProcessLogConfig processLogConfig,
                                                      IReplicationPacketDataConsumer<?> dataConsumer,
                                                      IReplicationProcessLogExceptionHandler exceptionHandler,
                                                      IReplicationInFacade replicationInFacade,
                                                      String name,
                                                      String groupName,
                                                      String sourceLookupName,
                                                      long lastProcessedKey,
                                                      boolean isFirstHandshake,
                                                      boolean oneWayMode,
                                                      IReplicationGroupHistory groupHistory,
                                                      IReplicationReliableAsyncMediator mediator)

Method Detail

createReplicationInContext

public ReplicationInContext createReplicationInContext()

Overrides:

createReplicationInContext in class AbstractSingleFileTargetProcessLog

getReplicationInContext

public ReplicationInContext getReplicationInContext()

Overrides:

getReplicationInContext in class AbstractSingleFileTargetProcessLog

contentRequiredWhileProcessing

protected boolean contentRequiredWhileProcessing()

Overrides:

contentRequiredWhileProcessing in class GlobalOrderTargetProcessLog

getMediator

public IReplicationReliableAsyncMediator getMediator()

Specified by:

getMediator in interface IReplicationReliableAsyncKeeperTargetProcessLog

shouldCloneOnFilter

protected boolean shouldCloneOnFilter()

Overrides:

shouldCloneOnFilter in class GlobalOrderTargetProcessLog

afterSuccessfulConsumption

protected void afterSuccessfulConsumption(String sourceLookupName,
                                          IReplicationOrderedPacket packet)

Overrides:

afterSuccessfulConsumption in class GlobalOrderTargetProcessLog

processHandshakeIteration

public void processHandshakeIteration(String sourceMemberName,
                                      IHandshakeIteration handshakeIteration)

Specified by:

processHandshakeIteration in interface IReplicationTargetProcessLog

Overrides:

processHandshakeIteration in class AbstractGlobalOrderTargetProcessLog

performHandshake

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

Specified by:

performHandshake in interface IReplicationTargetProcessLog

Overrides:

performHandshake in class AbstractGlobalOrderTargetProcessLog

Throws:

IncomingReplicationOutOfSyncException

getReliableAsyncStateFromHandshakeRequest

protected IReliableAsyncState getReliableAsyncStateFromHandshakeRequest(IBacklogHandshakeRequest handshakeRequest)

canResetState

protected boolean canResetState()

Overrides:

canResetState in class AbstractGlobalOrderTargetProcessLog