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

Class MultiBucketSingleFileSyncGroupBacklog

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

All Implemented Interfaces:

IReplicationGroupBacklog, IReplicationSyncGroupBacklog, DynamicSourceGroupConfigHolder.IDynamicSourceGroupStateListener

public class MultiBucketSingleFileSyncGroupBacklog
extends AbstractMultiBucketSingleFileGroupBacklog
implements IReplicationSyncGroupBacklog

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.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
MultiBucketSingleFileSyncGroupBacklog(DynamicSourceGroupConfigHolder sourceConfig, String name, IReplicationPacketDataProducer<?> dataProducer)

Method Summary

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

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

addGenericOperationPacket, addSingleOperationPacket, addTransactionOperationPacket, createBacklogOverflowPacket, createConfirmationMap, createNewConfirmationHolder, deleteBatchFromBacklog, dumpState, fromWireForm, getConfirmationHolder, getConfirmed, getHandshakeRequest, getIdleStateData, getLastConfirmedKeyUnsafe, getMemberUnconfirmedKey, getState, mergeWithDiscarded, onBeginSynchronization, printBucketsKeys, processHandshakeResponse, 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, getFilteredHandler, getFirstKeyInBacklogInternal, getFirstRequiredKeyUnsafe, 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, 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

MultiBucketSingleFileSyncGroupBacklog

public MultiBucketSingleFileSyncGroupBacklog(DynamicSourceGroupConfigHolder sourceConfig,
 String name,
 IReplicationPacketDataProducer<?> dataProducer)

Method Details

add

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

Specified by:

add in interface IReplicationSyncGroupBacklog

addTransaction

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

Specified by:

addTransaction in interface IReplicationSyncGroupBacklog

addGeneric

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

Specified by:

addGeneric in interface IReplicationSyncGroupBacklog