com.gigaspaces.internal.cluster.node.impl.backlog.globalorder

Class GlobalOrderReliableAsyncGroupBacklog

java.lang.Object

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

com.gigaspaces.internal.cluster.node.impl.backlog.globalorder.AbstractGlobalOrderGroupBacklog

com.gigaspaces.internal.cluster.node.impl.backlog.globalorder.GlobalOrderReliableAsyncGroupBacklog

All Implemented Interfaces:

IPacketFilteredHandler, IReplicationGroupBacklog, IReplicationReliableAsyncGroupBacklog, DynamicSourceGroupConfigHolder.IDynamicSourceGroupStateListener

public class GlobalOrderReliableAsyncGroupBacklog
extends AbstractGlobalOrderGroupBacklog
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 inherited from class com.gigaspaces.internal.cluster.node.impl.backlog.AbstractSingleFileGroupBacklog

_defaultFilteredHandler, _logger, _loggerReplica, _outOfSyncDueToDeletionTargets, _replicationLogger, _rwLock

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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()
GlobalOrderReliableAsyncState	getEntireReliableAsyncState()
protected IPacketFilteredHandler	getFilteredHandler()
GlobalOrderBacklogHandshakeRequest	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
GlobalOrderReliableAsyncState	getReliableAsyncState(String targetMemberName)
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)
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.globalorder.AbstractGlobalOrderGroupBacklog

addGenericOperationPacket, addSingleOperationPacket, addTransactionOperationPacket, createBacklogOverflowPacket, createConfirmationMap, createNewConfirmationHolder, deleteBatchFromBacklog, fromWireForm, getConfirmed, getIdleStateData, getLastConfirmationInternal, getLastConfirmedKeyUnsafe, getMemberUnconfirmedKey, getState, onBeginSynchronization, processIdleStateDataResult, processResult, processResult, replaceWithDiscarded, 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, 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, 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.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, monitor, performCompaction, processIdleStateDataResult, processResult, processResult, registerWith, replaceWithDiscarded, setGroupHistory, setPendingError, setPendingError, setPendingError, setStateListener, size, size, stopSynchronization, supportDiscardMerge, synchronizationCopyStageDone, synchronizationDataGenerated, synchronizationDone, toLogMessage, writeLock

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

memberAdded, memberRemoved

Constructor Detail

GlobalOrderReliableAsyncGroupBacklog

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

Method Detail

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

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

getEntireReliableAsyncState

public GlobalOrderReliableAsyncState getEntireReliableAsyncState()

Specified by:

getEntireReliableAsyncState in interface IReplicationReliableAsyncGroupBacklog

getReliableAsyncState

public GlobalOrderReliableAsyncState 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

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 AbstractGlobalOrderGroupBacklog

getMinimumUnconfirmedKeyUnsafe

protected long getMinimumUnconfirmedKeyUnsafe()

Overrides:

getMinimumUnconfirmedKeyUnsafe in class AbstractSingleFileGroupBacklog<IReplicationOrderedPacket,GlobalOrderConfirmationHolder>

getInitialMaxAllowedDeleteUpTo

protected long getInitialMaxAllowedDeleteUpTo()

Overrides:

getInitialMaxAllowedDeleteUpTo in class AbstractSingleFileGroupBacklog<IReplicationOrderedPacket,GlobalOrderConfirmationHolder>

getHandshakeRequest

public GlobalOrderBacklogHandshakeRequest getHandshakeRequest(String memberName,
                                                              Object customBacklogMetadata)

Specified by:

getHandshakeRequest in interface IReplicationGroupBacklog

Overrides:

getHandshakeRequest in class AbstractGlobalOrderGroupBacklog

getNextHandshakeIteration

public IHandshakeIteration getNextHandshakeIteration(String memberName,
                                                     IHandshakeContext handshakeContext)

Specified by:

getNextHandshakeIteration in interface IReplicationGroupBacklog

Overrides:

getNextHandshakeIteration in class AbstractSingleFileGroupBacklog<IReplicationOrderedPacket,GlobalOrderConfirmationHolder>

getFilteredHandler

protected IPacketFilteredHandler getFilteredHandler()

Overrides:

getFilteredHandler in class AbstractSingleFileGroupBacklog<IReplicationOrderedPacket,GlobalOrderConfirmationHolder>

packetFiltered

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

Specified by:

packetFiltered in interface IPacketFilteredHandler

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 AbstractGlobalOrderGroupBacklog

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

dumpState

public String dumpState()

Specified by:

dumpState in interface IReplicationGroupBacklog

Overrides:

dumpState in class AbstractGlobalOrderGroupBacklog