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

Class AbstractGlobalOrderGroupBacklog

java.lang.Object

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

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

All Implemented Interfaces:

IReplicationGroupBacklog, DynamicSourceGroupConfigHolder.IDynamicSourceGroupStateListener

Direct Known Subclasses:

GlobalOrderAsyncGroupBacklog, GlobalOrderReliableAsyncGroupBacklog, GlobalOrderSyncGroupBacklog

public abstract class AbstractGlobalOrderGroupBacklog
extends AbstractSingleFileGroupBacklog<IReplicationOrderedPacket,GlobalOrderConfirmationHolder>

Nested Class Summary

Nested classes/interfaces inherited from class com.gigaspaces.internal.cluster.node.impl.backlog.AbstractSingleFileGroupBacklog

AbstractSingleFileGroupBacklog.CaluclateMinUnconfirmedKeyProcedure

Field Summary

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

_defaultFilteredHandler, _logger, _loggerReplica, _outOfSyncDueToDeletionTargets, _rwLock

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected IReplicationOrderedPacket	addGenericOperationPacket(IReplicationGroupOutContext groupContext, Object operationData, ReplicationSingleOperationType operationType)
protected IReplicationOrderedPacket	addSingleOperationPacket(IReplicationGroupOutContext groupContext, IEntryHolder entryHolder, ReplicationSingleOperationType operationType)
protected IReplicationOrderedPacket	addTransactionOperationPacket(IReplicationGroupOutContext groupContext, ServerTransaction transaction, ArrayList<IEntryHolder> lockedEntries, ReplicationMultipleOperationType operationType)
protected IReplicationOrderedPacket	createBacklogOverflowPacket(long lastConfirmedKey, long firstKeyInBacklog, String memberName)
protected Map<String,GlobalOrderConfirmationHolder>	createConfirmationMap(SourceGroupConfig groupConfig)
protected GlobalOrderConfirmationHolder	createNewConfirmationHolder()
protected void	deleteBatchFromBacklog(long deletionBatchSize)
String	dumpState()
IProcessResult	fromWireForm(Object wiredProcessResult)
long	getConfirmed(String memberName)
GlobalOrderBacklogHandshakeRequest	getHandshakeRequest(String memberName, Object customBacklogMetadata)
IIdleStateData	getIdleStateData(String memberName, PlatformLogicalVersion targetMemberVersion)
GlobalOrderConfirmationHolder	getLastConfirmationInternal(String memberName)
protected long	getLastConfirmedKeyUnsafe(String memberLookupName)
protected long	getMemberUnconfirmedKey(GlobalOrderConfirmationHolder value)
IBacklogMemberState	getState(String memberName)
boolean	mergeWithDiscarded(IReplicationOrderedPacket previousDiscardedPacket, IReplicationOrderedPacket mergedPacket, String memberName) Merge an already existing discarded packet with a new packet that should be discarded
protected void	onBeginSynchronization(String memberName)
IHandshakeContext	processHandshakeResponse(String memberName, IBacklogHandshakeRequest request, IProcessLogHandshakeResponse response, PlatformLogicalVersion targetLogicalVersion, Object customBacklogMetadata)
void	processIdleStateDataResult(String memberName, IProcessResult result, IIdleStateData idleStateData)
void	processResult(String memberName, IProcessResult result, IReplicationOrderedPacket packet)
void	processResult(String memberName, IProcessResult result, List<IReplicationOrderedPacket> packets)
IReplicationOrderedPacket	replaceWithDiscarded(IReplicationOrderedPacket packet, boolean forceDiscard)
boolean	supportDiscardMerge()

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

appendConfirmationStateString, beginSynchronizing, beginSynchronizing, checkSynchronizingDone, cleanPendingErrorStateIfNeeded, clearConfirmedPackets, clearReplicated, close, decreaseWeight, decreaseWeightToAllMembersFromOldestPacket, ensureLimit, filterPacketForSynchronizing, 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, getUnconfirmedMarker, getWeight, getWeight, getWeightUnsafe, handlePendingErrorBatchPackets, handlePendingErrorSinglePacket, hasExistingMember, increaseAllMembersWeight, increaseWeight, insertReplicationOrderedPacketToBacklog, isBacklogDroppedEntirely, isMarkerReached, isSynchronizing, logPendingErrorResolved, makeMemberConfirmedOnAll, memberAdded, memberRemoved, monitor, printRedoLog, registerWith, removeSynchronizingState, setGroupHistory, setNextKeyUnsafe, setPacketWeight, setPendingError, setPendingError, setPendingError, setStateListener, shouldInsertPacket, size, size, stopSynchronization, synchronizationCopyStageDone, synchronizationDataGenerated, synchronizationDone, takeNextKeyUnsafe, toLogMessage, toString, updateBacklogLimitations, validateIntegrity, validateReliableAsyncUpdateTargetsMatch, writeLock

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AbstractGlobalOrderGroupBacklog

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

Method Detail

createConfirmationMap

protected Map<String,GlobalOrderConfirmationHolder> createConfirmationMap(SourceGroupConfig groupConfig)

Specified by:

createConfirmationMap in class AbstractSingleFileGroupBacklog<IReplicationOrderedPacket,GlobalOrderConfirmationHolder>

createNewConfirmationHolder

protected GlobalOrderConfirmationHolder createNewConfirmationHolder()

Specified by:

createNewConfirmationHolder in class AbstractSingleFileGroupBacklog<IReplicationOrderedPacket,GlobalOrderConfirmationHolder>

getHandshakeRequest

public GlobalOrderBacklogHandshakeRequest getHandshakeRequest(String memberName,
                                                              Object customBacklogMetadata)

createBacklogOverflowPacket

protected IReplicationOrderedPacket createBacklogOverflowPacket(long lastConfirmedKey,
                                                                long firstKeyInBacklog,
                                                                String memberName)

Specified by:

createBacklogOverflowPacket in class AbstractSingleFileGroupBacklog<IReplicationOrderedPacket,GlobalOrderConfirmationHolder>

processHandshakeResponse

public IHandshakeContext processHandshakeResponse(String memberName,
                                                  IBacklogHandshakeRequest request,
                                                  IProcessLogHandshakeResponse response,
                                                  PlatformLogicalVersion targetLogicalVersion,
                                                  Object customBacklogMetadata)

getMemberUnconfirmedKey

protected long getMemberUnconfirmedKey(GlobalOrderConfirmationHolder value)

Specified by:

getMemberUnconfirmedKey in class AbstractSingleFileGroupBacklog<IReplicationOrderedPacket,GlobalOrderConfirmationHolder>

processResult

public void processResult(String memberName,
                          IProcessResult result,
                          List<IReplicationOrderedPacket> packets)
                   throws ReplicationException

Throws:

ReplicationException

processResult

public void processResult(String memberName,
                          IProcessResult result,
                          IReplicationOrderedPacket packet)
                   throws ReplicationException

Throws:

ReplicationException

getState

public IBacklogMemberState getState(String memberName)

onBeginSynchronization

protected void onBeginSynchronization(String memberName)

Specified by:

onBeginSynchronization in class AbstractSingleFileGroupBacklog<IReplicationOrderedPacket,GlobalOrderConfirmationHolder>

replaceWithDiscarded

public IReplicationOrderedPacket replaceWithDiscarded(IReplicationOrderedPacket packet,
                                                      boolean forceDiscard)

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

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

supportDiscardMerge

public boolean supportDiscardMerge()

getLastConfirmationInternal

public GlobalOrderConfirmationHolder getLastConfirmationInternal(String memberName)

dumpState

public String dumpState()

addSingleOperationPacket

protected IReplicationOrderedPacket addSingleOperationPacket(IReplicationGroupOutContext groupContext,
                                                             IEntryHolder entryHolder,
                                                             ReplicationSingleOperationType operationType)

addTransactionOperationPacket

protected IReplicationOrderedPacket addTransactionOperationPacket(IReplicationGroupOutContext groupContext,
                                                                  ServerTransaction transaction,
                                                                  ArrayList<IEntryHolder> lockedEntries,
                                                                  ReplicationMultipleOperationType operationType)

addGenericOperationPacket

protected IReplicationOrderedPacket addGenericOperationPacket(IReplicationGroupOutContext groupContext,
                                                              Object operationData,
                                                              ReplicationSingleOperationType operationType)

getLastConfirmedKeyUnsafe

protected long getLastConfirmedKeyUnsafe(String memberLookupName)

Specified by:

getLastConfirmedKeyUnsafe in class AbstractSingleFileGroupBacklog<IReplicationOrderedPacket,GlobalOrderConfirmationHolder>

deleteBatchFromBacklog

protected void deleteBatchFromBacklog(long deletionBatchSize)

Specified by:

deleteBatchFromBacklog in class AbstractSingleFileGroupBacklog<IReplicationOrderedPacket,GlobalOrderConfirmationHolder>

fromWireForm

public IProcessResult fromWireForm(Object wiredProcessResult)

getIdleStateData

public IIdleStateData getIdleStateData(String memberName,
                                       PlatformLogicalVersion targetMemberVersion)

processIdleStateDataResult

public void processIdleStateDataResult(String memberName,
                                       IProcessResult result,
                                       IIdleStateData idleStateData)

getConfirmed

public long getConfirmed(String memberName)