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

Class MultiBucketSingleFileReliableAsyncGroupBacklog

java.lang.Object

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

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

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

All Implemented Interfaces:

IPacketFilteredHandler, IReplicationGroupBacklog, IReplicationReliableAsyncGroupBacklog, DynamicSourceGroupConfigHolder.IDynamicSourceGroupStateListener

public class MultiBucketSingleFileReliableAsyncGroupBacklog
extends AbstractMultiBucketSingleFileGroupBacklog
implements IReplicationReliableAsyncGroupBacklog, IPacketFilteredHandler

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MultiBucketSingleFileReliableAsyncGroupBacklog.PacketComperator

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

AbstractSingleFileGroupBacklog.CaluclateMinUnconfirmedKeyProcedure, AbstractSingleFileGroupBacklog.CompactionEnabledCaluclateMinUnconfirmedKeyProcedure, AbstractSingleFileGroupBacklog.ICaluclateMinUnconfirmedKey

Nested classes/interfaces inherited from interface com.gigaspaces.internal.cluster.node.impl.backlog.reliableasync.IReplicationReliableAsyncGroupBacklog

IReplicationReliableAsyncGroupBacklog.KeeperMemberState

Field Summary

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

_bucketLastKeys, _bucketsDeletionState

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

_defaultFilteredHandler, _logger, _loggerReplica, _outOfSyncDueToDeletionTargets, _replicationLogger, _rwLock

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	add(ReliableAsyncReplicationGroupOutContext groupContext, IEntryHolder entryHolder, ReplicationSingleOperationType operationType)
void	addGeneric(ReliableAsyncReplicationGroupOutContext groupContext, Object operationData, ReplicationSingleOperationType operationType)
void	addTransaction(ReliableAsyncReplicationGroupOutContext groupContext, ServerTransaction transaction, ArrayList<IEntryHolder> lockedEntries, ReplicationMultipleOperationType operationType)
void	afterHandshake(IProcessLogHandshakeResponse handshakeResponse)	Called after handshake is done with the keeper target group
String	dumpState()
MultiBucketSingleFileReliableAsyncState	getEntireReliableAsyncState()
protected IPacketFilteredHandler	getFilteredHandler()
MultiBucketSingleFileHandshakeRequest	getHandshakeRequest(String memberName, Object customBacklogMetadata)
protected long	getInitialMaxAllowedDeleteUpTo()
protected long	getMinimumUnconfirmedKeyUnsafe()
IHandshakeIteration	getNextHandshakeIteration(String memberName, IHandshakeContext handshakeContext)
List<IReplicationOrderedPacket>	getReliableAsyncPackets(String memberName, int maxSize, IReplicationReliableAsyncGroupBacklog.KeeperMemberState[] keeperMembersState, IReplicationChannelDataFilter dataFilter, PlatformLogicalVersion targetMemberVersion, org.slf4j.Logger logger)	Gets the next packet for the specified async member that is part of a reliable async group
MultiBucketSingleFileReliableAsyncState	getReliableAsyncState(String targetMemberName)
IReplicationOrderedPacket	packetFiltered(IReplicationOrderedPacket beforeFilter, IReplicationOrderedPacket afterFilter, IReplicationGroupBacklog groupBacklog, String targetMemberName)
IHandshakeContext	processHandshakeResponse(String memberName, IBacklogHandshakeRequest request, IProcessLogHandshakeResponse response, PlatformLogicalVersion targetLogicalVersion, Object customBacklogMetadata)
void	reliableAsyncSourceAdd(String sourceMemberName, IReplicationOrderedPacket packet)
void	reliableAsyncSourceKeep(String sourceMemberName, IReplicationOrderedPacket packet)	Keep an already existing packet which was previously processed or will not be processed by the corresponding process log
void	updateReliableAsyncState(IReliableAsyncState reliableAsyncState, String sourceMemberName)

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

addGenericOperationPacket, addSingleOperationPacket, addTransactionOperationPacket, createBacklogOverflowPacket, createConfirmationMap, createNewConfirmationHolder, deleteBatchFromBacklog, fromWireForm, getConfirmationHolder, getConfirmed, getIdleStateData, getLastConfirmedKeyUnsafe, getMemberUnconfirmedKey, getState, mergeWithDiscarded, onBeginSynchronization, printBucketsKeys, processIdleStateDataResult, processResult, processResult, replaceWithDiscarded, supportDiscardMerge, updateConfirmationHolderToCurrentLast

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, getFirstKeyInBacklogInternal, getFirstRequiredKeyUnsafe, getGroupConfigSnapshot, getGroupName, getLastInsertedKeyToBacklogUnsafe, getLogPrefix, getMarker, getMembersToValidateAgainst, getName, 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

Methods inherited from interface com.gigaspaces.internal.cluster.node.impl.config.DynamicSourceGroupConfigHolder.IDynamicSourceGroupStateListener

memberAdded, memberRemoved

Methods inherited from interface com.gigaspaces.internal.cluster.node.impl.backlog.IReplicationGroupBacklog

beginSynchronizing, beginSynchronizing, clearReplicated, close, decreaseWeight, flushRedoLogToStorage, freeWriteLock, fromWireForm, getConfirmed, getCurrentMarker, getDataProducer, getIdleStateData, getMarker, getPackets, getSpecificPacket, getState, getStatistics, getSwapStorageType, getUnconfirmedMarker, getWeight, getWeight, increaseWeight, makeMemberConfirmedOnAll, mergeWithDiscarded, monitor, performCompaction, processIdleStateDataResult, processResult, processResult, registerWith, replaceWithDiscarded, setGroupHistory, setPendingError, setPendingError, setPendingError, setStateListener, size, size, stopSynchronization, supportDiscardMerge, synchronizationCopyStageDone, synchronizationDataGenerated, synchronizationDone, toLogMessage, writeLock

Constructor Details

MultiBucketSingleFileReliableAsyncGroupBacklog

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

Method Details

add

public void add(ReliableAsyncReplicationGroupOutContext groupContext,
 IEntryHolder entryHolder,
 ReplicationSingleOperationType operationType)

Specified by:

add in interface IReplicationReliableAsyncGroupBacklog

addGeneric

public void addGeneric(ReliableAsyncReplicationGroupOutContext groupContext,
 Object operationData,
 ReplicationSingleOperationType operationType)

Specified by:

addGeneric in interface IReplicationReliableAsyncGroupBacklog

addTransaction

public void addTransaction(ReliableAsyncReplicationGroupOutContext groupContext,
 ServerTransaction transaction,
 ArrayList<IEntryHolder> lockedEntries,
 ReplicationMultipleOperationType operationType)

Specified by:

addTransaction in interface IReplicationReliableAsyncGroupBacklog

getHandshakeRequest

public MultiBucketSingleFileHandshakeRequest getHandshakeRequest(String memberName,
 Object customBacklogMetadata)

Specified by:

getHandshakeRequest in interface IReplicationGroupBacklog

Overrides:

getHandshakeRequest in class AbstractMultiBucketSingleFileGroupBacklog

getReliableAsyncPackets

public List<IReplicationOrderedPacket> getReliableAsyncPackets(String memberName,
 int maxSize,
 IReplicationReliableAsyncGroupBacklog.KeeperMemberState[] keeperMembersState,
 IReplicationChannelDataFilter dataFilter,
 PlatformLogicalVersion targetMemberVersion,
 org.slf4j.Logger logger)

Description copied from interface: IReplicationReliableAsyncGroupBacklog

Gets the next packet for the specified async member that is part of a reliable async group

Specified by:

getReliableAsyncPackets in interface IReplicationReliableAsyncGroupBacklog

keeperMembersState - the state of the keeper sync member

processHandshakeResponse

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

Specified by:

processHandshakeResponse in interface IReplicationGroupBacklog

Overrides:

processHandshakeResponse in class AbstractMultiBucketSingleFileGroupBacklog

reliableAsyncSourceKeep

public void reliableAsyncSourceKeep(String sourceMemberName,
 IReplicationOrderedPacket packet)

Description copied from interface: IReplicationReliableAsyncGroupBacklog

Keep an already existing packet which was previously processed or will not be processed by the corresponding process log

Specified by:

reliableAsyncSourceKeep in interface IReplicationReliableAsyncGroupBacklog

reliableAsyncSourceAdd

public void reliableAsyncSourceAdd(String sourceMemberName,
 IReplicationOrderedPacket packet)

Specified by:

reliableAsyncSourceAdd in interface IReplicationReliableAsyncGroupBacklog

getEntireReliableAsyncState

public MultiBucketSingleFileReliableAsyncState getEntireReliableAsyncState()

Specified by:

getEntireReliableAsyncState in interface IReplicationReliableAsyncGroupBacklog

getReliableAsyncState

public MultiBucketSingleFileReliableAsyncState getReliableAsyncState(String targetMemberName)

Specified by:

getReliableAsyncState in interface IReplicationReliableAsyncGroupBacklog

updateReliableAsyncState

public void updateReliableAsyncState(IReliableAsyncState reliableAsyncState,
 String sourceMemberName)
                              throws NoSuchReplicationMemberException,
MissingReliableAsyncTargetStateException

Specified by:

updateReliableAsyncState in interface IReplicationReliableAsyncGroupBacklog

Throws:

NoSuchReplicationMemberException

MissingReliableAsyncTargetStateException

afterHandshake

public void afterHandshake(IProcessLogHandshakeResponse handshakeResponse)

Description copied from interface: IReplicationReliableAsyncGroupBacklog

Called after handshake is done with the keeper target group

Specified by:

afterHandshake in interface IReplicationReliableAsyncGroupBacklog

getMinimumUnconfirmedKeyUnsafe

protected long getMinimumUnconfirmedKeyUnsafe()

Overrides:

getMinimumUnconfirmedKeyUnsafe in class AbstractSingleFileGroupBacklog<IMultiBucketSingleFileReplicationOrderedPacket,MultiBucketSingleFileConfirmationHolder>

getInitialMaxAllowedDeleteUpTo

protected long getInitialMaxAllowedDeleteUpTo()

Overrides:

getInitialMaxAllowedDeleteUpTo in class AbstractSingleFileGroupBacklog<IMultiBucketSingleFileReplicationOrderedPacket,MultiBucketSingleFileConfirmationHolder>

getNextHandshakeIteration

public IHandshakeIteration getNextHandshakeIteration(String memberName,
 IHandshakeContext handshakeContext)

Specified by:

getNextHandshakeIteration in interface IReplicationGroupBacklog

Overrides:

getNextHandshakeIteration in class AbstractSingleFileGroupBacklog<IMultiBucketSingleFileReplicationOrderedPacket,MultiBucketSingleFileConfirmationHolder>

getFilteredHandler

protected IPacketFilteredHandler getFilteredHandler()

Overrides:

getFilteredHandler in class AbstractSingleFileGroupBacklog<IMultiBucketSingleFileReplicationOrderedPacket,MultiBucketSingleFileConfirmationHolder>

packetFiltered

public IReplicationOrderedPacket packetFiltered(IReplicationOrderedPacket beforeFilter,
 IReplicationOrderedPacket afterFilter,
 IReplicationGroupBacklog groupBacklog,
 String targetMemberName)

Specified by:

packetFiltered in interface IPacketFilteredHandler

dumpState

public String dumpState()

Specified by:

dumpState in interface IReplicationGroupBacklog

Overrides:

dumpState in class AbstractMultiBucketSingleFileGroupBacklog