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

Class MultiBucketSingleFileBatchConsumeTargetProcessLog

java.lang.Object

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

com.gigaspaces.internal.cluster.node.impl.processlog.multibucketsinglefile.AbstractMultiBucketSingleFileTargetProcessLog

com.gigaspaces.internal.cluster.node.impl.processlog.multibucketsinglefile.MultiBucketSingleFileBatchConsumeTargetProcessLog

All Implemented Interfaces:

IReplicationAsyncTargetProcessLog, IReplicationBatchConsumeAsyncTargetProcessLog, IReplicationTargetProcessLog, IBatchExecutedCallback, IMultiBucketSingleFileProcessLog

Direct Known Subclasses:

MultiBucketSingleFileReliableAsyncTargetProcessLog

public class MultiBucketSingleFileBatchConsumeTargetProcessLog
extends AbstractMultiBucketSingleFileTargetProcessLog
implements IBatchExecutedCallback, IReplicationBatchConsumeAsyncTargetProcessLog

Field Summary

Fields

Modifier and Type	Field and Description
protected Lock	_lock

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

_dataConsumer, _specificLogger

Constructor Summary

Constructors

Modifier	Constructor and Description
	MultiBucketSingleFileBatchConsumeTargetProcessLog(ProcessLogConfig config, IReplicationPacketDataBatchConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory)
protected	MultiBucketSingleFileBatchConsumeTargetProcessLog(ProcessLogConfig config, IReplicationPacketDataBatchConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, long lastGlobalProcessedKey, long[] lastProcessedKeys, long[] lastGlobalProcessedKeys, boolean firstHandshakeForTarget, IReplicationGroupHistory groupHistory)

Method Summary

Modifier and Type	Method and Description
void	batchConsumed(ShortLongMap bucketProcessedKeys, ShortLongMap bucketGlobalProcessedKeys, long lastGlobalprocessedKey)
protected boolean	contentRequiredWhileProcessing()
protected String	dumpStateExtra()
protected boolean	filterDuplicate(IReplicationOrderedPacket packet)
protected void	filterDuplicate(List<IReplicationOrderedPacket> packets)
long	getLastGlobalProcessedKey()
MultiBucketSingleFileHandshakeResponse	performHandshake(String memberName, IBacklogHandshakeRequest handshakeRequest)
MultiBucketSingleFileProcessResult	process(String sourceLookupName, IReplicationOrderedPacket packet, IReplicationInFilterCallback inFilterCallback)
MultiBucketSingleFileProcessResult	processBatch(String sourceLookupName, List<IReplicationOrderedPacket> packets, IReplicationInFilterCallback inFilterCallback)

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

afterSuccessfulConsumption, canResetState, close, createBatchParallelProcessingContinuationTask, dumpState, getConsumeTimeout, getExecutorService, getLastGlobalProcessedKeys, getLastProcessedKeys, getSpecificLogger, isFirstHandshakeForTarget, process, process, process, process, process, processHandshakeIteration, processIdleStateData, resync, shouldCloneOnFilter, throwClosedException, toWireForm, validateNotClosed, validateOpen

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

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

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

Field Detail

_lock

protected final Lock _lock

Constructor Detail

MultiBucketSingleFileBatchConsumeTargetProcessLog

public MultiBucketSingleFileBatchConsumeTargetProcessLog(ProcessLogConfig config,
                                                         IReplicationPacketDataBatchConsumer<?> dataConsumer,
                                                         IReplicationProcessLogExceptionHandler exceptionHandler,
                                                         IReplicationInFacade replicationInFacade,
                                                         String name,
                                                         String groupName,
                                                         String sourceLookupName,
                                                         IReplicationGroupHistory groupHistory)

MultiBucketSingleFileBatchConsumeTargetProcessLog

protected MultiBucketSingleFileBatchConsumeTargetProcessLog(ProcessLogConfig config,
                                                            IReplicationPacketDataBatchConsumer<?> dataConsumer,
                                                            IReplicationProcessLogExceptionHandler exceptionHandler,
                                                            IReplicationInFacade replicationInFacade,
                                                            String name,
                                                            String groupName,
                                                            String sourceLookupName,
                                                            long lastGlobalProcessedKey,
                                                            long[] lastProcessedKeys,
                                                            long[] lastGlobalProcessedKeys,
                                                            boolean firstHandshakeForTarget,
                                                            IReplicationGroupHistory groupHistory)

Method Detail

contentRequiredWhileProcessing

protected boolean contentRequiredWhileProcessing()

Specified by:

contentRequiredWhileProcessing in class AbstractSingleFileTargetProcessLog

performHandshake

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

Specified by:

performHandshake in interface IReplicationTargetProcessLog

Overrides:

performHandshake in class AbstractMultiBucketSingleFileTargetProcessLog

Throws:

IncomingReplicationOutOfSyncException

processBatch

public MultiBucketSingleFileProcessResult processBatch(String sourceLookupName,
                                                       List<IReplicationOrderedPacket> packets,
                                                       IReplicationInFilterCallback inFilterCallback)

Specified by:

processBatch in interface IReplicationTargetProcessLog

Overrides:

processBatch in class AbstractMultiBucketSingleFileTargetProcessLog

process

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

Specified by:

process in interface IReplicationTargetProcessLog

Overrides:

process in class AbstractMultiBucketSingleFileTargetProcessLog

batchConsumed

public void batchConsumed(ShortLongMap bucketProcessedKeys,
                          ShortLongMap bucketGlobalProcessedKeys,
                          long lastGlobalprocessedKey)

Specified by:

batchConsumed in interface IBatchExecutedCallback

filterDuplicate

protected void filterDuplicate(List<IReplicationOrderedPacket> packets)

filterDuplicate

protected boolean filterDuplicate(IReplicationOrderedPacket packet)

getLastGlobalProcessedKey

public long getLastGlobalProcessedKey()

dumpStateExtra

protected String dumpStateExtra()

Overrides:

dumpStateExtra in class AbstractMultiBucketSingleFileTargetProcessLog