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

Class MultiSourceSingleFileAsyncGroupBacklog

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.MultiSourceSingleFileAsyncGroupBacklog

All Implemented Interfaces:

IReplicationAsyncGroupBacklog, IReplicationGroupBacklog, DynamicSourceGroupConfigHolder.IDynamicSourceGroupStateListener

public class MultiSourceSingleFileAsyncGroupBacklog
extends AbstractMultiSourceSingleFileGroupBacklog
implements IReplicationAsyncGroupBacklog

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

_defaultFilteredHandler, _logger, _loggerReplica, _outOfSyncDueToDeletionTargets, _replicationLogger, _rwLock

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	add(IAsyncReplicationGroupOutContext groupContext, IEntryHolder entryHolder, ReplicationSingleOperationType operationType)
void	addGeneric(IAsyncReplicationGroupOutContext groupContext, Object operationData, ReplicationSingleOperationType operationType)
void	addTransaction(IAsyncReplicationGroupOutContext groupContext, ServerTransaction transaction, ArrayList<IEntryHolder> lockedEntries, ReplicationMultipleOperationType operationType)

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.backlog.multisourcesinglefile.AbstractMultiSourceSingleFileGroupBacklog

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

Constructor Details

MultiSourceSingleFileAsyncGroupBacklog

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

Method Details

add

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

Specified by:

add in interface IReplicationAsyncGroupBacklog

addGeneric

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

Specified by:

addGeneric in interface IReplicationAsyncGroupBacklog

addTransaction

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

Specified by:

addTransaction in interface IReplicationAsyncGroupBacklog