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

Class AbstractMultiBucketSingleFileTargetProcessLog

java.lang.Object

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

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

All Implemented Interfaces:

IReplicationTargetProcessLog, IMultiBucketSingleFileProcessLog

Direct Known Subclasses:

MultiBucketSingleFileBatchConsumeTargetProcessLog, MultiBucketSingleFileSyncTargetProcessLog

public abstract class AbstractMultiBucketSingleFileTargetProcessLog
extends AbstractSingleFileTargetProcessLog
implements IMultiBucketSingleFileProcessLog

Field Summary

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

_specificLogger

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected void	afterSuccessfulConsumption(String sourceLookupName, IReplicationOrderedPacket packet)
protected boolean	canResetState()
boolean	close(long time, TimeUnit unit)
void	createBatchParallelProcessingContinuationTask(String sourceLookupName, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext context, List<IReplicationOrderedPacket> batch, int segmentIndex)
String	dumpState()
protected String	dumpStateExtra()
long	getConsumeTimeout()
ExecutorService	getExecutorService()
long[]	getLastGlobalProcessedKeys()
long[]	getLastProcessedKeys()
Logger	getSpecificLogger()
boolean	isFirstHandshakeForTarget()
MultiBucketSingleFileHandshakeResponse	performHandshake(String memberName, IBacklogHandshakeRequest handshakeRequest)
MultiBucketSingleFileProcessResult	process(String sourceLookupName, DeletedMultiBucketOrderedPacket packet, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext batchContext, int segmentIndex)
MultiBucketSingleFileProcessResult	process(String sourceLookupName, DiscardedMultiBucketOrderedPacket packet, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext batchContext, int segmentIndex)
MultiBucketSingleFileProcessResult	process(String sourceLookupName, IReplicationOrderedPacket packet, IReplicationInFilterCallback inFilterCallback)
MultiBucketSingleFileProcessResult	process(String sourceLookupName, IReplicationOrderedPacket packet, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext batchContext, int segmentIndex)
MultiBucketSingleFileProcessResult	process(String sourceLookupName, ISingleBucketReplicationOrderedPacket packet, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext batchContext, int segmentIndex)
MultiBucketSingleFileProcessResult	process(String sourceLookupName, MultipleBucketOrderedPacket packet, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext batchContext, int segmentIndex)
MultiBucketSingleFileProcessResult	processBatch(String sourceLookupName, List<IReplicationOrderedPacket> packets, IReplicationInFilterCallback inFilterCallback)
void	processHandshakeIteration(String sourceMemberName, IHandshakeIteration handshakeIteration)
IProcessResult	processIdleStateData(String string, IIdleStateData idleStateData, IReplicationInFilterCallback inFilterCallback)
IProcessLogHandshakeResponse	resync(IBacklogHandshakeRequest handshakeRequest)
protected boolean	shouldCloneOnFilter()
protected void	throwClosedException()
Object	toWireForm(IProcessResult processResult)
void	validateNotClosed()
void	validateOpen()

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

contentRequiredWhileProcessing, 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

getDataConsumer, toLogMessage

Constructor Detail

AbstractMultiBucketSingleFileTargetProcessLog

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

AbstractMultiBucketSingleFileTargetProcessLog

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

Method Detail

getExecutorService

public ExecutorService getExecutorService()

getLastProcessedKeys

public long[] getLastProcessedKeys()

getLastGlobalProcessedKeys

public long[] getLastGlobalProcessedKeys()

isFirstHandshakeForTarget

public boolean isFirstHandshakeForTarget()

performHandshake

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

Specified by:

performHandshake in interface IReplicationTargetProcessLog

Throws:

IncomingReplicationOutOfSyncException

canResetState

protected boolean canResetState()

validateOpen

public void validateOpen()

validateNotClosed

public void validateNotClosed()

throwClosedException

protected void throwClosedException()

processBatch

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

Specified by:

processBatch in interface IReplicationTargetProcessLog

createBatchParallelProcessingContinuationTask

public void createBatchParallelProcessingContinuationTask(String sourceLookupName,
                                                          IReplicationInFilterCallback inFilterCallback,
                                                          ParallelBatchProcessingContext context,
                                                          List<IReplicationOrderedPacket> batch,
                                                          int segmentIndex)

process

public MultiBucketSingleFileProcessResult process(String sourceLookupName,
                                                  IReplicationOrderedPacket packet,
                                                  IReplicationInFilterCallback inFilterCallback,
                                                  ParallelBatchProcessingContext batchContext,
                                                  int segmentIndex)

process

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

Specified by:

process in interface IReplicationTargetProcessLog

process

public MultiBucketSingleFileProcessResult process(String sourceLookupName,
                                                  ISingleBucketReplicationOrderedPacket packet,
                                                  IReplicationInFilterCallback inFilterCallback,
                                                  ParallelBatchProcessingContext batchContext,
                                                  int segmentIndex)

Specified by:

process in interface IMultiBucketSingleFileProcessLog

process

public MultiBucketSingleFileProcessResult process(String sourceLookupName,
                                                  MultipleBucketOrderedPacket packet,
                                                  IReplicationInFilterCallback inFilterCallback,
                                                  ParallelBatchProcessingContext batchContext,
                                                  int segmentIndex)

Specified by:

process in interface IMultiBucketSingleFileProcessLog

process

public MultiBucketSingleFileProcessResult process(String sourceLookupName,
                                                  DiscardedMultiBucketOrderedPacket packet,
                                                  IReplicationInFilterCallback inFilterCallback,
                                                  ParallelBatchProcessingContext batchContext,
                                                  int segmentIndex)

Specified by:

process in interface IMultiBucketSingleFileProcessLog

process

public MultiBucketSingleFileProcessResult process(String sourceLookupName,
                                                  DeletedMultiBucketOrderedPacket packet,
                                                  IReplicationInFilterCallback inFilterCallback,
                                                  ParallelBatchProcessingContext batchContext,
                                                  int segmentIndex)

Specified by:

process in interface IMultiBucketSingleFileProcessLog

close

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

Specified by:

close in interface IReplicationTargetProcessLog

Throws:

InterruptedException

getConsumeTimeout

public long getConsumeTimeout()

processHandshakeIteration

public void processHandshakeIteration(String sourceMemberName,
                                      IHandshakeIteration handshakeIteration)

Specified by:

processHandshakeIteration in interface IReplicationTargetProcessLog

shouldCloneOnFilter

protected boolean shouldCloneOnFilter()

afterSuccessfulConsumption

protected void afterSuccessfulConsumption(String sourceLookupName,
                                          IReplicationOrderedPacket packet)

resync

public IProcessLogHandshakeResponse resync(IBacklogHandshakeRequest handshakeRequest)

Specified by:

resync in interface IReplicationTargetProcessLog

toWireForm

public Object toWireForm(IProcessResult processResult)

Specified by:

toWireForm in interface IReplicationTargetProcessLog

dumpState

public String dumpState()

Specified by:

dumpState in interface IReplicationTargetProcessLog

Specified by:

dumpState in class AbstractSingleFileTargetProcessLog

dumpStateExtra

protected String dumpStateExtra()

getSpecificLogger

public Logger getSpecificLogger()

processIdleStateData

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

Specified by:

processIdleStateData in interface IReplicationTargetProcessLog