public class GlobalOrderReliableAsyncGroupBacklog extends AbstractGlobalOrderGroupBacklog implements IReplicationReliableAsyncGroupBacklog, IPacketFilteredHandler
AbstractSingleFileGroupBacklog.CaluclateMinUnconfirmedKeyProcedure, AbstractSingleFileGroupBacklog.CompactionEnabledCaluclateMinUnconfirmedKeyProcedure, AbstractSingleFileGroupBacklog.ICaluclateMinUnconfirmedKeyIReplicationReliableAsyncGroupBacklog.KeeperMemberState_defaultFilteredHandler, _logger, _loggerReplica, _outOfSyncDueToDeletionTargets, _replicationLogger, _rwLock| Constructor and Description |
|---|
GlobalOrderReliableAsyncGroupBacklog(DynamicSourceGroupConfigHolder groupConfig,
String name,
IReplicationPacketDataProducer<?> dataProducer) |
addGenericOperationPacket, addSingleOperationPacket, addTransactionOperationPacket, createBacklogOverflowPacket, createConfirmationMap, createNewConfirmationHolder, deleteBatchFromBacklog, fromWireForm, getConfirmed, getIdleStateData, getLastConfirmationInternal, getLastConfirmedKeyUnsafe, getMemberUnconfirmedKey, getState, onBeginSynchronization, processIdleStateDataResult, processResult, processResult, replaceWithDiscarded, supportDiscardMergeappendConfirmationStateString, beginSynchronizing, beginSynchronizing, checkSynchronizingDone, cleanPendingErrorStateIfNeeded, clearConfirmedPackets, clearReplicated, close, decreaseMirrorDiscardedCount, decreaseWeight, decreaseWeightToAllMembersFromOldestPacket, ensureLimit, filterPacketForSynchronizing, freeWriteLock, getAllConfirmationHoldersUnsafe, getAllConfirmations, getAllConfirmations, getBacklogFile, getConfirmationHolderUnsafe, getCurrentMarker, getDataProducer, getFirstKeyInBacklogInternal, getFirstRequiredKeyUnsafe, getGroupConfigSnapshot, getGroupName, getLastInsertedKeyToBacklogUnsafe, getLogPrefix, getMarker, getMembersToValidateAgainst, getName, getNextKeyUnsafe, getPackets, getPacketsUnsafe, getPacketsWithFullSerializedContent, getSpecificPacket, getSpecificPackets, getStatistics, 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, writeLockclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitbeginSynchronizing, beginSynchronizing, clearReplicated, close, decreaseWeight, freeWriteLock, fromWireForm, getConfirmed, getCurrentMarker, getDataProducer, getIdleStateData, getMarker, getPackets, getSpecificPacket, getState, getStatistics, 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, writeLockmemberAdded, memberRemovedpublic GlobalOrderReliableAsyncGroupBacklog(DynamicSourceGroupConfigHolder groupConfig, String name, IReplicationPacketDataProducer<?> dataProducer)
public void reliableAsyncSourceKeep(String sourceMemberName, IReplicationOrderedPacket packet)
IReplicationReliableAsyncGroupBacklogreliableAsyncSourceKeep in interface IReplicationReliableAsyncGroupBacklogpublic void reliableAsyncSourceAdd(String sourceMemberName, IReplicationOrderedPacket packet)
reliableAsyncSourceAdd in interface IReplicationReliableAsyncGroupBacklogpublic void add(ReliableAsyncReplicationGroupOutContext groupContext, IEntryHolder entryHolder, ReplicationSingleOperationType operationType)
add in interface IReplicationReliableAsyncGroupBacklogpublic void addGeneric(ReliableAsyncReplicationGroupOutContext groupContext, Object operationData, ReplicationSingleOperationType operationType)
addGeneric in interface IReplicationReliableAsyncGroupBacklogpublic void addTransaction(ReliableAsyncReplicationGroupOutContext groupContext, ServerTransaction transaction, ArrayList<IEntryHolder> lockedEntries, ReplicationMultipleOperationType operationType)
addTransaction in interface IReplicationReliableAsyncGroupBacklogpublic GlobalOrderReliableAsyncState getEntireReliableAsyncState()
getEntireReliableAsyncState in interface IReplicationReliableAsyncGroupBacklogpublic GlobalOrderReliableAsyncState getReliableAsyncState(String targetMemberName)
getReliableAsyncState in interface IReplicationReliableAsyncGroupBacklogpublic void updateReliableAsyncState(IReliableAsyncState reliableAsyncState, String sourceMemberName) throws NoSuchReplicationMemberException, MissingReliableAsyncTargetStateException
updateReliableAsyncState in interface IReplicationReliableAsyncGroupBacklogNoSuchReplicationMemberExceptionMissingReliableAsyncTargetStateExceptionpublic void afterHandshake(IProcessLogHandshakeResponse handshakeResponse)
IReplicationReliableAsyncGroupBacklogafterHandshake in interface IReplicationReliableAsyncGroupBacklogpublic List<IReplicationOrderedPacket> getReliableAsyncPackets(String memberName, int maxSize, IReplicationReliableAsyncGroupBacklog.KeeperMemberState[] keeperMembersState, IReplicationChannelDataFilter dataFilter, PlatformLogicalVersion targetMemberVersion, Logger logger)
IReplicationReliableAsyncGroupBackloggetReliableAsyncPackets in interface IReplicationReliableAsyncGroupBacklogkeeperMembersState - the state of the keeper sync memberpublic IHandshakeContext processHandshakeResponse(String memberName, IBacklogHandshakeRequest request, IProcessLogHandshakeResponse response, PlatformLogicalVersion targetLogicalVersion, Object customBacklogMetadata)
processHandshakeResponse in interface IReplicationGroupBacklogprocessHandshakeResponse in class AbstractGlobalOrderGroupBacklogprotected long getMinimumUnconfirmedKeyUnsafe()
protected long getInitialMaxAllowedDeleteUpTo()
public GlobalOrderBacklogHandshakeRequest getHandshakeRequest(String memberName, Object customBacklogMetadata)
getHandshakeRequest in interface IReplicationGroupBackloggetHandshakeRequest in class AbstractGlobalOrderGroupBacklogpublic IHandshakeIteration getNextHandshakeIteration(String memberName, IHandshakeContext handshakeContext)
getNextHandshakeIteration in interface IReplicationGroupBackloggetNextHandshakeIteration in class AbstractSingleFileGroupBacklog<IReplicationOrderedPacket,GlobalOrderConfirmationHolder>protected IPacketFilteredHandler getFilteredHandler()
public IReplicationOrderedPacket packetFiltered(IReplicationOrderedPacket beforeFilter, IReplicationOrderedPacket afterFilter, IReplicationGroupBacklog groupBacklog, String targetMemberName)
packetFiltered in interface IPacketFilteredHandlerpublic boolean mergeWithDiscarded(IReplicationOrderedPacket previousDiscardedPacket, IReplicationOrderedPacket mergedPacket, String memberName)
IReplicationGroupBacklogmergeWithDiscarded in interface IReplicationGroupBacklogmergeWithDiscarded in class AbstractGlobalOrderGroupBacklogpreviousDiscardedPacket - 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 packetmemberName - TODOpublic String dumpState()
dumpState in interface IReplicationGroupBacklogdumpState in class AbstractGlobalOrderGroupBacklogCopyright © GigaSpaces.