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

Class GlobalOrderTargetProcessLog

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

All Implemented Interfaces:

IReplicationAsyncTargetProcessLog, IReplicationTargetProcessLog, IReplicationSyncTargetProcessLog

Direct Known Subclasses:

GlobalOrderReliableAsyncTargetKeeperProcessLog

public class GlobalOrderTargetProcessLog
extends AbstractGlobalOrderTargetProcessLog
implements IReplicationSyncTargetProcessLog, IReplicationAsyncTargetProcessLog

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	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
GlobalOrderTargetProcessLog(GlobalOrderProcessLogConfig processLogConfig, IReplicationPacketDataConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, boolean oneWayProcessing, IReplicationGroupHistory groupHistory)
GlobalOrderTargetProcessLog(GlobalOrderProcessLogConfig processLogConfig, IReplicationPacketDataConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, long lastProcessedKey, boolean isFirstHandshake, boolean oneWayProcessing, IReplicationGroupHistory groupHistory)

Method Summary

Modifier and Type	Method and Description
protected void	afterSuccessfulConsumption(String sourceLookupName, IReplicationOrderedPacket packet)
protected boolean	contentRequiredWhileProcessing()
protected String	dumpStateExtra()
protected void	onClose()
GlobalOrderProcessResult	process(String sourceLookupName, IReplicationOrderedPacket packet, IReplicationInFilterCallback inFilterCallback)
GlobalOrderProcessResult	processBatch(String sourceLookupName, List<IReplicationOrderedPacket> packets, IReplicationInFilterCallback filterInCallback)
protected boolean	processPackets(String sourceLookupName, long myLastKey, IReplicationInFilterCallback filterInCallback)
protected boolean	shouldCloneOnFilter()

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

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

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

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

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

Constructor Detail

GlobalOrderTargetProcessLog

public GlobalOrderTargetProcessLog(GlobalOrderProcessLogConfig processLogConfig,
                                   IReplicationPacketDataConsumer<?> dataConsumer,
                                   IReplicationProcessLogExceptionHandler exceptionHandler,
                                   IReplicationInFacade replicationInFacade,
                                   String name,
                                   String groupName,
                                   String sourceLookupName,
                                   boolean oneWayProcessing,
                                   IReplicationGroupHistory groupHistory)

GlobalOrderTargetProcessLog

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

Method Detail

contentRequiredWhileProcessing

protected boolean contentRequiredWhileProcessing()

Specified by:

contentRequiredWhileProcessing in class AbstractSingleFileTargetProcessLog

processBatch

public GlobalOrderProcessResult processBatch(String sourceLookupName,
                                             List<IReplicationOrderedPacket> packets,
                                             IReplicationInFilterCallback filterInCallback)

Specified by:

processBatch in interface IReplicationTargetProcessLog

process

public GlobalOrderProcessResult process(String sourceLookupName,
                                        IReplicationOrderedPacket packet,
                                        IReplicationInFilterCallback inFilterCallback)

Specified by:

process in interface IReplicationTargetProcessLog

processPackets

protected boolean processPackets(String sourceLookupName,
                                 long myLastKey,
                                 IReplicationInFilterCallback filterInCallback)
                          throws Exception

Throws:

Exception

afterSuccessfulConsumption

protected void afterSuccessfulConsumption(String sourceLookupName,
                                          IReplicationOrderedPacket packet)

shouldCloneOnFilter

protected boolean shouldCloneOnFilter()

dumpStateExtra

protected String dumpStateExtra()

Overrides:

dumpStateExtra in class AbstractGlobalOrderTargetProcessLog

onClose

protected void onClose()

Specified by:

onClose in class AbstractGlobalOrderTargetProcessLog