Package com.gigaspaces.internal.cluster.node.impl.backlog.multisourcesinglefile

Class AbstractMultiSourceSingleFileGroupBacklog

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.backlog.AbstractSingleFileGroupBacklog<IReplicationOrderedPacket,MultiSourceSingleFileConfirmationHolder>

com.gigaspaces.internal.cluster.node.impl.backlog.multisourcesinglefile.AbstractMultiSourceSingleFileGroupBacklog

All Implemented Interfaces:

IReplicationGroupBacklog, DynamicSourceGroupConfigHolder.IDynamicSourceGroupStateListener

Direct Known Subclasses:

MultiSourceSingleFileAsyncGroupBacklog, MultiSourceSingleFileReliableAsyncGroupBacklog

public abstract class AbstractMultiSourceSingleFileGroupBacklog
extends AbstractSingleFileGroupBacklog<IReplicationOrderedPacket,MultiSourceSingleFileConfirmationHolder>

Nested Class Summary

Nested classes/interfaces inherited from class com.gigaspaces.internal.cluster.node.impl.backlog.AbstractSingleFileGroupBacklog

AbstractSingleFileGroupBacklog.CaluclateMinUnconfirmedKeyProcedure, AbstractSingleFileGroupBacklog.CompactionEnabledCaluclateMinUnconfirmedKeyProcedure, AbstractSingleFileGroupBacklog.ICaluclateMinUnconfirmedKey

Field Summary

Fields inherited from class com.gigaspaces.internal.cluster.node.impl.backlog.AbstractSingleFileGroupBacklog

_defaultFilteredHandler, _logger, _loggerReplica, _outOfSyncDueToDeletionTargets, _replicationLogger, _rwLock

Constructor Summary

Constructors

Constructor	Description
AbstractMultiSourceSingleFileGroupBacklog(DynamicSourceGroupConfigHolder groupConfig, String name, IReplicationPacketDataProducer<?> dataProducer)

Method Summary

Modifier and Type	Method	Description
protected IReplicationOrderedPacket	addGenericOperationPacket(IReplicationGroupOutContext groupContext, Object operationData, ReplicationSingleOperationType operationType)
protected IReplicationOrderedPacket	addSingleOperationPacket(IReplicationGroupOutContext groupContext, IEntryHolder entryHolder, ReplicationSingleOperationType operationType)
protected IReplicationOrderedPacket	addTransactionOperationPacket(IReplicationGroupOutContext groupContext, ServerTransaction transaction, ArrayList<IEntryHolder> lockedEntries, ReplicationMultipleOperationType operationType)
protected IReplicationOrderedPacket	createBacklogOverflowPacket(long globalLastConfirmedKey, long firstKeyInBacklog, String memberName)
protected Map<String,MultiSourceSingleFileConfirmationHolder>	createConfirmationMap(SourceGroupConfig groupConfig)
protected MultiSourceSingleFileConfirmationHolder	createNewConfirmationHolder()
protected void	deleteBatchFromBacklog(long deletionBatchSize)
String	dumpState()
IProcessResult	fromWireForm(Object wiredProcessResult)
long	getConfirmed(String memberName)
protected long	getFirstRequiredKeyUnsafe(String memberName)
protected IHandshakeContext	getHandshakeContext(String memberName, IBacklogHandshakeRequest request, PlatformLogicalVersion targetLogicalVersion, GlobalOrderProcessLogHandshakeResponse typedResponse, long lastProcessedKey)
MultiSourceSingleFileBacklogHandshakeRequest	getHandshakeRequest(String memberName, Object customBacklogMetadata)
protected MultiSourceSingleFileBacklogHandshakeRequest	getHandshakeRequestImpl(String memberName, MultiSourceSingleFileBacklogHandshakeRequest handshakeRequest)
IIdleStateData	getIdleStateData(String memberName, PlatformLogicalVersion targetMemberVersion)
protected long	getLastConfirmedKeyUnsafe(String memberLookupName)
protected long	getMemberUnconfirmedKey(MultiSourceSingleFileConfirmationHolder value)
IBacklogMemberState	getState(String memberName)
boolean	mergeWithDiscarded(IReplicationOrderedPacket previousDiscardedPacket, IReplicationOrderedPacket mergedPacket, String memberName)	Merge an already existing discarded packet with a new packet that should be discarded
protected void	onBeginSynchronization(String memberName)
IHandshakeContext	processHandshakeResponse(String memberName, IBacklogHandshakeRequest request, IProcessLogHandshakeResponse response, PlatformLogicalVersion targetLogicalVersion, Object customBacklogMetadata)
void	processIdleStateDataResult(String memberName, IProcessResult result, IIdleStateData idleStateData)
void	processResult(String memberName, IProcessResult result, IReplicationOrderedPacket packet)
void	processResult(String memberName, IProcessResult result, List<IReplicationOrderedPacket> packets)
IReplicationOrderedPacket	replaceWithDiscarded(IReplicationOrderedPacket packet, boolean forceDiscard)
void	setPendingError(String memberName, Throwable error, IIdleStateData idleStateData)
boolean	supportDiscardMerge()

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.backlog.AbstractSingleFileGroupBacklog

appendConfirmationStateString, beginSynchronizing, beginSynchronizing, checkSynchronizingDone, cleanPendingErrorStateIfNeeded, clearConfirmedPackets, clearReplicated, close, decreaseMirrorDiscardedCount, decreaseWeight, decreaseWeightToAllMembersFromOldestPacket, ensureLimit, filterPacketForSynchronizing, flushRedoLogToStorage, freeWriteLock, getAllConfirmationHoldersUnsafe, getAllConfirmations, getAllConfirmations, getBacklogFile, getConfirmationHolderUnsafe, getCurrentMarker, getDataProducer, getFilteredHandler, getFirstKeyInBacklogInternal, getGroupConfigSnapshot, getGroupName, getInitialMaxAllowedDeleteUpTo, getLastInsertedKeyToBacklogUnsafe, getLogPrefix, getMarker, getMembersToValidateAgainst, getMinimumUnconfirmedKeyUnsafe, getName, getNextHandshakeIteration, getNextKeyUnsafe, getPackets, getPacketsUnsafe, getPacketsWithFullSerializedContent, getSpecificPacket, getSpecificPackets, getStatistics, getSwapStorageType, getUnconfirmedMarker, getWeight, getWeight, getWeightUnsafe, handlePendingErrorBatchPackets, handlePendingErrorSinglePacket, hasExistingMember, hasMirror, increaseAllMembersWeight, increaseMirrorDiscardedCount, increaseWeight, insertReplicationOrderedPacketToBacklog, isBacklogDroppedEntirely, isMarkerReached, isSynchronizing, logPendingErrorResolved, makeMemberConfirmedOnAll, memberAdded, memberRemoved, monitor, notifyDroppedIfListening, peekOldestPacket, performCompaction, performCompactionUnsafe, printRedoLog, registerWith, removeSynchronizingState, setGroupHistory, setNextKeyUnsafe, setPacketWeight, setPendingError, setPendingError, setStateListener, shouldInsertPacket, size, size, stopSynchronization, synchronizationCopyStageDone, synchronizationDataGenerated, synchronizationDone, takeNextKeyUnsafe, toLogMessage, toString, updateBacklogLimitations, updateMirrorWeightAfterCompaction, validateIntegrity, validateReliableAsyncUpdateTargetsMatch, writeLock

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AbstractMultiSourceSingleFileGroupBacklog

public AbstractMultiSourceSingleFileGroupBacklog(DynamicSourceGroupConfigHolder groupConfig,
 String name,
 IReplicationPacketDataProducer<?> dataProducer)

Method Details

getHandshakeRequest

public MultiSourceSingleFileBacklogHandshakeRequest getHandshakeRequest(String memberName,
 Object customBacklogMetadata)

getHandshakeRequestImpl

protected MultiSourceSingleFileBacklogHandshakeRequest getHandshakeRequestImpl(String memberName,
 MultiSourceSingleFileBacklogHandshakeRequest handshakeRequest)

getFirstRequiredKeyUnsafe

protected long getFirstRequiredKeyUnsafe(String memberName)

Overrides:

getFirstRequiredKeyUnsafe in class AbstractSingleFileGroupBacklog<IReplicationOrderedPacket,MultiSourceSingleFileConfirmationHolder>

processHandshakeResponse

public IHandshakeContext processHandshakeResponse(String memberName,
 IBacklogHandshakeRequest request,
 IProcessLogHandshakeResponse response,
 PlatformLogicalVersion targetLogicalVersion,
 Object customBacklogMetadata)

getHandshakeContext

protected IHandshakeContext getHandshakeContext(String memberName,
 IBacklogHandshakeRequest request,
 PlatformLogicalVersion targetLogicalVersion,
 GlobalOrderProcessLogHandshakeResponse typedResponse,
 long lastProcessedKey)

getState

public IBacklogMemberState getState(String memberName)

processResult

public void processResult(String memberName,
 IProcessResult result,
 List<IReplicationOrderedPacket> packets)
                   throws ReplicationException

Throws:

ReplicationException

processResult

public void processResult(String memberName,
 IProcessResult result,
 IReplicationOrderedPacket packet)
                   throws ReplicationException

Throws:

ReplicationException

replaceWithDiscarded

public IReplicationOrderedPacket replaceWithDiscarded(IReplicationOrderedPacket packet,
 boolean forceDiscard)

mergeWithDiscarded

public boolean mergeWithDiscarded(IReplicationOrderedPacket previousDiscardedPacket,
 IReplicationOrderedPacket mergedPacket,
 String memberName)

Description copied from interface: IReplicationGroupBacklog

Merge an already existing discarded packet with a new packet that should be discarded

Parameters:

previousDiscardedPacket - the already existing discarded packet which is a result IReplicationGroupBacklog.replaceWithDiscarded(IReplicationOrderedPacket, boolean)

mergedPacket - the new packet that needs to be discarded and merged into the existing discarded packet

memberName - TODO

Returns:

return true if merge is successful, false otherwise

supportDiscardMerge

public boolean supportDiscardMerge()

dumpState

public String dumpState()

fromWireForm

public IProcessResult fromWireForm(Object wiredProcessResult)

createConfirmationMap

protected Map<String,MultiSourceSingleFileConfirmationHolder> createConfirmationMap(SourceGroupConfig groupConfig)

Specified by:

createConfirmationMap in class AbstractSingleFileGroupBacklog<IReplicationOrderedPacket,MultiSourceSingleFileConfirmationHolder>

createNewConfirmationHolder

protected MultiSourceSingleFileConfirmationHolder createNewConfirmationHolder()

Specified by:

createNewConfirmationHolder in class AbstractSingleFileGroupBacklog<IReplicationOrderedPacket,MultiSourceSingleFileConfirmationHolder>

deleteBatchFromBacklog

protected void deleteBatchFromBacklog(long deletionBatchSize)

Specified by:

deleteBatchFromBacklog in class AbstractSingleFileGroupBacklog<IReplicationOrderedPacket,MultiSourceSingleFileConfirmationHolder>

getLastConfirmedKeyUnsafe

protected long getLastConfirmedKeyUnsafe(String memberLookupName)

Specified by:

getLastConfirmedKeyUnsafe in class AbstractSingleFileGroupBacklog<IReplicationOrderedPacket,MultiSourceSingleFileConfirmationHolder>

onBeginSynchronization

protected void onBeginSynchronization(String memberName)

Specified by:

onBeginSynchronization in class AbstractSingleFileGroupBacklog<IReplicationOrderedPacket,MultiSourceSingleFileConfirmationHolder>

createBacklogOverflowPacket

protected IReplicationOrderedPacket createBacklogOverflowPacket(long globalLastConfirmedKey,
 long firstKeyInBacklog,
 String memberName)

Specified by:

createBacklogOverflowPacket in class AbstractSingleFileGroupBacklog<IReplicationOrderedPacket,MultiSourceSingleFileConfirmationHolder>

getMemberUnconfirmedKey

protected long getMemberUnconfirmedKey(MultiSourceSingleFileConfirmationHolder value)

Specified by:

getMemberUnconfirmedKey in class AbstractSingleFileGroupBacklog<IReplicationOrderedPacket,MultiSourceSingleFileConfirmationHolder>

addSingleOperationPacket

protected IReplicationOrderedPacket addSingleOperationPacket(IReplicationGroupOutContext groupContext,
 IEntryHolder entryHolder,
 ReplicationSingleOperationType operationType)

addGenericOperationPacket

protected IReplicationOrderedPacket addGenericOperationPacket(IReplicationGroupOutContext groupContext,
 Object operationData,
 ReplicationSingleOperationType operationType)

addTransactionOperationPacket

protected IReplicationOrderedPacket addTransactionOperationPacket(IReplicationGroupOutContext groupContext,
 ServerTransaction transaction,
 ArrayList<IEntryHolder> lockedEntries,
 ReplicationMultipleOperationType operationType)

getIdleStateData

public IIdleStateData getIdleStateData(String memberName,
 PlatformLogicalVersion targetMemberVersion)

processIdleStateDataResult

public void processIdleStateDataResult(String memberName,
 IProcessResult result,
 IIdleStateData idleStateData)
                                throws ReplicationException

Throws:

ReplicationException

setPendingError

public void setPendingError(String memberName,
 Throwable error,
 IIdleStateData idleStateData)

Specified by:

setPendingError in interface IReplicationGroupBacklog

Overrides:

setPendingError in class AbstractSingleFileGroupBacklog<IReplicationOrderedPacket,MultiSourceSingleFileConfirmationHolder>

getConfirmed

public long getConfirmed(String memberName)