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

Class MultiSourceSingleFileReliableAsyncGroupBacklog

java.lang.Object

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

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

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

All Implemented Interfaces:

IPacketFilteredHandler, IReplicationGroupBacklog, IReplicationReliableAsyncGroupBacklog, DynamicSourceGroupConfigHolder.IDynamicSourceGroupStateListener

public class MultiSourceSingleFileReliableAsyncGroupBacklog
extends AbstractMultiSourceSingleFileGroupBacklog
implements IReplicationReliableAsyncGroupBacklog, IPacketFilteredHandler

Nested Class Summary

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

Modifier and Type	Field	Description
protected final Map<String,Long>	_ongoingReliableAsyncHandshakeCompletion

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

_defaultFilteredHandler, _logger, _loggerReplica, _outOfSyncDueToDeletionTargets, _replicationLogger, _rwLock

Constructor Summary

Constructors

Constructor	Description
MultiSourceSingleFileReliableAsyncGroupBacklog(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
protected MultiSourceSingleFileReliableAsyncState	buildReliableAsyncState(Set<Map.Entry<String,MultiSourceSingleFileConfirmationHolder>> asyncTargetsConfirmations)
String	dumpState()
MultiSourceSingleFileReliableAsyncState	getEntireReliableAsyncState()
protected IPacketFilteredHandler	getFilteredHandler()
protected IHandshakeContext	getHandshakeContext(String memberName, IBacklogHandshakeRequest request, PlatformLogicalVersion targetLogicalVersion, GlobalOrderProcessLogHandshakeResponse typedResponse, long lastProcessedKey)
protected MultiSourceSingleFileBacklogHandshakeRequest	getHandshakeRequestImpl(String memberName, MultiSourceSingleFileBacklogHandshakeRequest handshakeRequest)
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
MultiSourceSingleFileReliableAsyncState	getReliableAsyncState(String targetMemberLookupName)
boolean	mergeWithDiscarded(IReplicationOrderedPacket previousDiscardedPacket, IReplicationOrderedPacket mergedPacket, String memberName)	Merge an already existing discarded packet with a new packet that should be discarded
IReplicationOrderedPacket	packetFiltered(IReplicationOrderedPacket beforeFilter, IReplicationOrderedPacket afterFilter, IReplicationGroupBacklog groupBacklog, String targetMemberName)
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.multisourcesinglefile.AbstractMultiSourceSingleFileGroupBacklog

addGenericOperationPacket, addSingleOperationPacket, addTransactionOperationPacket, createBacklogOverflowPacket, createConfirmationMap, createNewConfirmationHolder, deleteBatchFromBacklog, fromWireForm, getConfirmed, getFirstRequiredKeyUnsafe, getHandshakeRequest, getIdleStateData, getLastConfirmedKeyUnsafe, getMemberUnconfirmedKey, getState, onBeginSynchronization, processHandshakeResponse, processIdleStateDataResult, processResult, processResult, replaceWithDiscarded, setPendingError, 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, getFirstKeyInBacklogInternal, 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, 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, getHandshakeRequest, getIdleStateData, getMarker, getPackets, getSpecificPacket, getState, getStatistics, getSwapStorageType, getUnconfirmedMarker, getWeight, getWeight, increaseWeight, makeMemberConfirmedOnAll, monitor, performCompaction, processHandshakeResponse, processIdleStateDataResult, processResult, processResult, registerWith, replaceWithDiscarded, setGroupHistory, setPendingError, setPendingError, setPendingError, setStateListener, size, size, stopSynchronization, supportDiscardMerge, synchronizationCopyStageDone, synchronizationDataGenerated, synchronizationDone, toLogMessage, writeLock

Field Details

_ongoingReliableAsyncHandshakeCompletion

protected final Map<String,Long> _ongoingReliableAsyncHandshakeCompletion

Constructor Details

MultiSourceSingleFileReliableAsyncGroupBacklog

public MultiSourceSingleFileReliableAsyncGroupBacklog(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

reliableAsyncSourceAdd

public void reliableAsyncSourceAdd(String sourceMemberName,
 IReplicationOrderedPacket packet)

Specified by:

reliableAsyncSourceAdd in interface IReplicationReliableAsyncGroupBacklog

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

getEntireReliableAsyncState

public MultiSourceSingleFileReliableAsyncState getEntireReliableAsyncState()

Specified by:

getEntireReliableAsyncState in interface IReplicationReliableAsyncGroupBacklog

updateReliableAsyncState

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

Specified by:

updateReliableAsyncState in interface IReplicationReliableAsyncGroupBacklog

Throws:

NoSuchReplicationMemberException

MissingReliableAsyncTargetStateException

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

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

dumpState

public String dumpState()

Specified by:

dumpState in interface IReplicationGroupBacklog

Overrides:

dumpState in class AbstractMultiSourceSingleFileGroupBacklog

getHandshakeRequestImpl

protected MultiSourceSingleFileBacklogHandshakeRequest getHandshakeRequestImpl(String memberName,
 MultiSourceSingleFileBacklogHandshakeRequest handshakeRequest)

Overrides:

getHandshakeRequestImpl in class AbstractMultiSourceSingleFileGroupBacklog

getHandshakeContext

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

Overrides:

getHandshakeContext in class AbstractMultiSourceSingleFileGroupBacklog

getReliableAsyncState

public MultiSourceSingleFileReliableAsyncState getReliableAsyncState(String targetMemberLookupName)

Specified by:

getReliableAsyncState in interface IReplicationReliableAsyncGroupBacklog

buildReliableAsyncState

protected MultiSourceSingleFileReliableAsyncState buildReliableAsyncState(Set<Map.Entry<String,MultiSourceSingleFileConfirmationHolder>> asyncTargetsConfirmations)

packetFiltered

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

Specified by:

packetFiltered in interface IPacketFilteredHandler

getFilteredHandler

protected IPacketFilteredHandler getFilteredHandler()

Overrides:

getFilteredHandler in class AbstractSingleFileGroupBacklog<IReplicationOrderedPacket,MultiSourceSingleFileConfirmationHolder>

getNextHandshakeIteration

public IHandshakeIteration getNextHandshakeIteration(String memberName,
 IHandshakeContext handshakeContext)

Specified by:

getNextHandshakeIteration in interface IReplicationGroupBacklog

Overrides:

getNextHandshakeIteration in class AbstractSingleFileGroupBacklog<IReplicationOrderedPacket,MultiSourceSingleFileConfirmationHolder>

getMinimumUnconfirmedKeyUnsafe

protected long getMinimumUnconfirmedKeyUnsafe()

Overrides:

getMinimumUnconfirmedKeyUnsafe in class AbstractSingleFileGroupBacklog<IReplicationOrderedPacket,MultiSourceSingleFileConfirmationHolder>

getInitialMaxAllowedDeleteUpTo

protected long getInitialMaxAllowedDeleteUpTo()

Overrides:

getInitialMaxAllowedDeleteUpTo in class AbstractSingleFileGroupBacklog<IReplicationOrderedPacket,MultiSourceSingleFileConfirmationHolder>

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

Specified by:

mergeWithDiscarded in interface IReplicationGroupBacklog

Overrides:

mergeWithDiscarded in class AbstractMultiSourceSingleFileGroupBacklog

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