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

Class AbstractMultiBucketSingleFileGroupBacklog

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.backlog.AbstractSingleFileGroupBacklog<IMultiBucketSingleFileReplicationOrderedPacket,MultiBucketSingleFileConfirmationHolder>

com.gigaspaces.internal.cluster.node.impl.backlog.multibucketsinglefile.AbstractMultiBucketSingleFileGroupBacklog

All Implemented Interfaces:

IReplicationGroupBacklog, DynamicSourceGroupConfigHolder.IDynamicSourceGroupStateListener

Direct Known Subclasses:

MultiBucketSingleFileReliableAsyncGroupBacklog, MultiBucketSingleFileSyncGroupBacklog

public abstract class AbstractMultiBucketSingleFileGroupBacklog
extends AbstractSingleFileGroupBacklog<IMultiBucketSingleFileReplicationOrderedPacket,MultiBucketSingleFileConfirmationHolder>

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

Modifier and Type	Field	Description
protected final long[]	_bucketLastKeys
protected final ShortLongMap	_bucketsDeletionState

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

_defaultFilteredHandler, _logger, _loggerReplica, _outOfSyncDueToDeletionTargets, _replicationLogger, _rwLock

Constructor Summary

Constructors

Constructor	Description
AbstractMultiBucketSingleFileGroupBacklog(DynamicSourceGroupConfigHolder sourceConfig, String name, IReplicationPacketDataProducer<?> dataProducer)

Method Summary

Modifier and Type	Method	Description
SingleBucketOrderedPacket	addGenericOperationPacket(ISyncReplicationGroupOutContext groupContext, Object operationData, ReplicationSingleOperationType operationType)
SingleBucketOrderedPacket	addSingleOperationPacket(ISyncReplicationGroupOutContext groupContext, IEntryHolder entryHolder, ReplicationSingleOperationType operationType)
IMultiBucketSingleFileReplicationOrderedPacket	addTransactionOperationPacket(ISyncReplicationGroupOutContext groupContext, ServerTransaction transaction, ArrayList<IEntryHolder> lockedEntries, ReplicationMultipleOperationType operationType)
protected DeletedMultiBucketOrderedPacket	createBacklogOverflowPacket(long globalLastConfirmedKey, long firstKeyInBacklog, String memberName)
protected Map<String,MultiBucketSingleFileConfirmationHolder>	createConfirmationMap(SourceGroupConfig groupConfig)
protected MultiBucketSingleFileConfirmationHolder	createNewConfirmationHolder()
protected void	deleteBatchFromBacklog(long deletionBatchSize)
String	dumpState()
IProcessResult	fromWireForm(Object wiredProcessResult)
protected MultiBucketSingleFileConfirmationHolder	getConfirmationHolder(String memberName)
long	getConfirmed(String memberName)
MultiBucketSingleFileHandshakeRequest	getHandshakeRequest(String memberName, Object customBacklogMetadata)
IIdleStateData	getIdleStateData(String memberName, PlatformLogicalVersion targetMemberVersion)
protected long	getLastConfirmedKeyUnsafe(String memberLookupName)
protected long	getMemberUnconfirmedKey(MultiBucketSingleFileConfirmationHolder 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)
static String	printBucketsKeys(long[] keys)
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)
IMultiBucketSingleFileReplicationOrderedPacket	replaceWithDiscarded(IReplicationOrderedPacket packet, boolean forceDiscard)
boolean	supportDiscardMerge()
protected void	updateConfirmationHolderToCurrentLast(MultiBucketSingleFileConfirmationHolder confirmationHolder)

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

Field Details

_bucketLastKeys

protected final long[] _bucketLastKeys

_bucketsDeletionState

protected final ShortLongMap _bucketsDeletionState

Constructor Details

AbstractMultiBucketSingleFileGroupBacklog

public AbstractMultiBucketSingleFileGroupBacklog(DynamicSourceGroupConfigHolder sourceConfig,
 String name,
 IReplicationPacketDataProducer<?> dataProducer)

Method Details

createConfirmationMap

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

Specified by:

createConfirmationMap in class AbstractSingleFileGroupBacklog<IMultiBucketSingleFileReplicationOrderedPacket,MultiBucketSingleFileConfirmationHolder>

createNewConfirmationHolder

protected MultiBucketSingleFileConfirmationHolder createNewConfirmationHolder()

Specified by:

createNewConfirmationHolder in class AbstractSingleFileGroupBacklog<IMultiBucketSingleFileReplicationOrderedPacket,MultiBucketSingleFileConfirmationHolder>

getConfirmationHolder

protected MultiBucketSingleFileConfirmationHolder getConfirmationHolder(String memberName)

getHandshakeRequest

public MultiBucketSingleFileHandshakeRequest getHandshakeRequest(String memberName,
 Object customBacklogMetadata)

processHandshakeResponse

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

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

getLastConfirmedKeyUnsafe

protected long getLastConfirmedKeyUnsafe(String memberLookupName)

Specified by:

getLastConfirmedKeyUnsafe in class AbstractSingleFileGroupBacklog<IMultiBucketSingleFileReplicationOrderedPacket,MultiBucketSingleFileConfirmationHolder>

getMemberUnconfirmedKey

protected long getMemberUnconfirmedKey(MultiBucketSingleFileConfirmationHolder value)

Specified by:

getMemberUnconfirmedKey in class AbstractSingleFileGroupBacklog<IMultiBucketSingleFileReplicationOrderedPacket,MultiBucketSingleFileConfirmationHolder>

createBacklogOverflowPacket

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

Specified by:

createBacklogOverflowPacket in class AbstractSingleFileGroupBacklog<IMultiBucketSingleFileReplicationOrderedPacket,MultiBucketSingleFileConfirmationHolder>

onBeginSynchronization

protected void onBeginSynchronization(String memberName)

Specified by:

onBeginSynchronization in class AbstractSingleFileGroupBacklog<IMultiBucketSingleFileReplicationOrderedPacket,MultiBucketSingleFileConfirmationHolder>

updateConfirmationHolderToCurrentLast

protected void updateConfirmationHolderToCurrentLast(MultiBucketSingleFileConfirmationHolder confirmationHolder)

addSingleOperationPacket

public SingleBucketOrderedPacket addSingleOperationPacket(ISyncReplicationGroupOutContext groupContext,
 IEntryHolder entryHolder,
 ReplicationSingleOperationType operationType)

addGenericOperationPacket

public SingleBucketOrderedPacket addGenericOperationPacket(ISyncReplicationGroupOutContext groupContext,
 Object operationData,
 ReplicationSingleOperationType operationType)

addTransactionOperationPacket

public IMultiBucketSingleFileReplicationOrderedPacket addTransactionOperationPacket(ISyncReplicationGroupOutContext groupContext,
 ServerTransaction transaction,
 ArrayList<IEntryHolder> lockedEntries,
 ReplicationMultipleOperationType operationType)

replaceWithDiscarded

public IMultiBucketSingleFileReplicationOrderedPacket 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()

deleteBatchFromBacklog

protected void deleteBatchFromBacklog(long deletionBatchSize)

Specified by:

deleteBatchFromBacklog in class AbstractSingleFileGroupBacklog<IMultiBucketSingleFileReplicationOrderedPacket,MultiBucketSingleFileConfirmationHolder>

fromWireForm

public IProcessResult fromWireForm(Object wiredProcessResult)

dumpState

public String dumpState()

printBucketsKeys

public static String printBucketsKeys(long[] keys)

getIdleStateData

public IIdleStateData getIdleStateData(String memberName,
 PlatformLogicalVersion targetMemberVersion)

processIdleStateDataResult

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

getConfirmed

public long getConfirmed(String memberName)