Uses of Interface
com.gigaspaces.internal.cluster.node.impl.packets.IReplicationOrderedPacket

Packages that use IReplicationOrderedPacket

Package	Description
com.gigaspaces.internal.cluster.node.impl
com.gigaspaces.internal.cluster.node.impl.backlog
com.gigaspaces.internal.cluster.node.impl.backlog.globalorder
com.gigaspaces.internal.cluster.node.impl.backlog.multibucketsinglefile
com.gigaspaces.internal.cluster.node.impl.backlog.multisourcesinglefile
com.gigaspaces.internal.cluster.node.impl.backlog.reliableasync
com.gigaspaces.internal.cluster.node.impl.groups
com.gigaspaces.internal.cluster.node.impl.groups.async
com.gigaspaces.internal.cluster.node.impl.groups.reliableasync
com.gigaspaces.internal.cluster.node.impl.groups.sync
com.gigaspaces.internal.cluster.node.impl.packets
com.gigaspaces.internal.cluster.node.impl.processlog
com.gigaspaces.internal.cluster.node.impl.processlog.globalorder
com.gigaspaces.internal.cluster.node.impl.processlog.multibucketsinglefile
com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile
com.gigaspaces.internal.server.space.redolog
com.gigaspaces.internal.server.space.redolog.storage
com.gigaspaces.internal.server.space.redolog.storage.bytebuffer

Uses of IReplicationOrderedPacket in com.gigaspaces.internal.cluster.node.impl

Methods in com.gigaspaces.internal.cluster.node.impl with parameters of type IReplicationOrderedPacket

Modifier and Type	Method and Description
void	ReplicationInContext.setContextPacket(IReplicationOrderedPacket packet)

Method parameters in com.gigaspaces.internal.cluster.node.impl with type arguments of type IReplicationOrderedPacket

Modifier and Type	Method and Description
static String	ReplicationLogUtils.packetsToLogString(List<IReplicationOrderedPacket> packets)

Uses of IReplicationOrderedPacket in com.gigaspaces.internal.cluster.node.impl.backlog

Classes in com.gigaspaces.internal.cluster.node.impl.backlog with type parameters of type IReplicationOrderedPacket

Modifier and Type	Class and Description
class	AbstractSingleFileGroupBacklog<T extends IReplicationOrderedPacket,CType extends AbstractSingleFileConfirmationHolder> A base class for IReplicationGroupBacklog that contains a single IRedoLogFile and treat the order of packets in that file for the global order of the backlog

Methods in com.gigaspaces.internal.cluster.node.impl.backlog that return IReplicationOrderedPacket

Modifier and Type	Method and Description
IReplicationOrderedPacket	IReplicationGroupBacklog.getSpecificPacket(long packetKey) Gets a specific packet inside the backlog
IReplicationOrderedPacket	DefaultPacketFilteredHandler.packetFiltered(IReplicationOrderedPacket beforeFilter, IReplicationOrderedPacket afterFilter, IReplicationGroupBacklog groupBacklog, String targetMemberName)
IReplicationOrderedPacket	IReplicationGroupBacklog.replaceWithDiscarded(IReplicationOrderedPacket packet, boolean forceDiscard)

Methods in com.gigaspaces.internal.cluster.node.impl.backlog that return types with arguments of type IReplicationOrderedPacket

Modifier and Type	Method and Description
List<IReplicationOrderedPacket>	IReplicationGroupBacklog.getPackets(String memberName, int maxSize, IReplicationChannelDataFilter filter, PlatformLogicalVersion targetMemberVersion, Logger logger)
List<IReplicationOrderedPacket>	AbstractSingleFileGroupBacklog.getPackets(String memberName, int maxSize, IReplicationChannelDataFilter filter, PlatformLogicalVersion targetMemberVersion, Logger logger)
List<IReplicationOrderedPacket>	AbstractSingleFileGroupBacklog.getPacketsUnsafe(String memberName, int maxWeight, long upToKey, IReplicationChannelDataFilter dataFilter, IPacketFilteredHandler filteredHandler, PlatformLogicalVersion targetMemberVersion, Logger logger)
protected List<IReplicationOrderedPacket>	AbstractSingleFileGroupBacklog.getPacketsWithFullSerializedContent(long fromKey, long upToKey, int maxWeight)

Methods in com.gigaspaces.internal.cluster.node.impl.backlog with parameters of type IReplicationOrderedPacket

Modifier and Type	Method and Description
IMarker	IReplicationGroupBacklog.getMarker(IReplicationOrderedPacket packet, String membersGroupName)
IMarker	AbstractSingleFileGroupBacklog.getMarker(IReplicationOrderedPacket packet, String membersGroupName)
protected void	AbstractSingleFileGroupBacklog.handlePendingErrorSinglePacket(String memberName, IReplicationOrderedPacket packet, Throwable error)
boolean	IReplicationGroupBacklog.mergeWithDiscarded(IReplicationOrderedPacket previousDiscardedPacket, IReplicationOrderedPacket mergedPacket, String memberName) Merge an already existing discarded packet with a new packet that should be discarded
IReplicationOrderedPacket	DefaultPacketFilteredHandler.packetFiltered(IReplicationOrderedPacket beforeFilter, IReplicationOrderedPacket afterFilter, IReplicationGroupBacklog groupBacklog, String targetMemberName)
void	IReplicationGroupBacklog.processResult(String memberName, IProcessResult result, IReplicationOrderedPacket packet)
IReplicationOrderedPacket	IReplicationGroupBacklog.replaceWithDiscarded(IReplicationOrderedPacket packet, boolean forceDiscard)
void	IReplicationGroupBacklog.setPendingError(String memberName, Throwable error, IReplicationOrderedPacket replicatedPacket)
void	AbstractSingleFileGroupBacklog.setPendingError(String memberName, Throwable error, IReplicationOrderedPacket replicatedPacket)

Method parameters in com.gigaspaces.internal.cluster.node.impl.backlog with type arguments of type IReplicationOrderedPacket

Modifier and Type	Method and Description
protected void	AbstractSingleFileGroupBacklog.handlePendingErrorBatchPackets(String memberName, List<IReplicationOrderedPacket> packets, Throwable error, long potentialLastUnprocessedKey)
void	IReplicationGroupBacklog.processResult(String memberName, IProcessResult result, List<IReplicationOrderedPacket> packets)
void	IReplicationGroupBacklog.setPendingError(String memberName, Throwable error, List<IReplicationOrderedPacket> replicatedPackets)
void	AbstractSingleFileGroupBacklog.setPendingError(String memberName, Throwable error, List<IReplicationOrderedPacket> replicatedPackets)
protected String	AbstractSingleFileGroupBacklog.toString(List<IReplicationOrderedPacket> packets)

Uses of IReplicationOrderedPacket in com.gigaspaces.internal.cluster.node.impl.backlog.globalorder

Classes in com.gigaspaces.internal.cluster.node.impl.backlog.globalorder that implement IReplicationOrderedPacket

Modifier and Type	Class and Description
class	GlobalOrderDeletedBacklogPacket
class	GlobalOrderDiscardedReplicationPacket
class	GlobalOrderOperationPacket
class	GlobalOrderReliableAsyncKeptDiscardedOrderedPacket

Methods in com.gigaspaces.internal.cluster.node.impl.backlog.globalorder that return IReplicationOrderedPacket

Modifier and Type	Method and Description
protected IReplicationOrderedPacket	AbstractGlobalOrderGroupBacklog.addGenericOperationPacket(IReplicationGroupOutContext groupContext, Object operationData, ReplicationSingleOperationType operationType)
protected IReplicationOrderedPacket	AbstractGlobalOrderGroupBacklog.addSingleOperationPacket(IReplicationGroupOutContext groupContext, IEntryHolder entryHolder, ReplicationSingleOperationType operationType)
protected IReplicationOrderedPacket	AbstractGlobalOrderGroupBacklog.addTransactionOperationPacket(IReplicationGroupOutContext groupContext, ServerTransaction transaction, ArrayList<IEntryHolder> lockedEntries, ReplicationMultipleOperationType operationType)
IReplicationOrderedPacket	GlobalOrderDiscardedReplicationPacket.cloneWithNewData(IReplicationPacketData<?> newData)
IReplicationOrderedPacket	GlobalOrderReliableAsyncKeptDiscardedOrderedPacket.cloneWithNewData(IReplicationPacketData<?> newData)
IReplicationOrderedPacket	GlobalOrderOperationPacket.cloneWithNewData(IReplicationPacketData<?> newData)
IReplicationOrderedPacket	GlobalOrderDeletedBacklogPacket.cloneWithNewData(IReplicationPacketData<?> newData)
protected IReplicationOrderedPacket	AbstractGlobalOrderGroupBacklog.createBacklogOverflowPacket(long lastConfirmedKey, long firstKeyInBacklog, String memberName)
IReplicationOrderedPacket	GlobalOrderReliableAsyncKeptDiscardedOrderedPacket.getBeforeFilterPacket()
IReplicationOrderedPacket	GlobalOrderReliableAsyncGroupBacklog.packetFiltered(IReplicationOrderedPacket beforeFilter, IReplicationOrderedPacket afterFilter, IReplicationGroupBacklog groupBacklog, String targetMemberName)
IReplicationOrderedPacket	IPacketFilteredHandler.packetFiltered(IReplicationOrderedPacket beforeFilter, IReplicationOrderedPacket afterFilter, IReplicationGroupBacklog groupBacklog, String targetMemberName)
IReplicationOrderedPacket	AbstractGlobalOrderGroupBacklog.replaceWithDiscarded(IReplicationOrderedPacket packet, boolean forceDiscard)

Methods in com.gigaspaces.internal.cluster.node.impl.backlog.globalorder that return types with arguments of type IReplicationOrderedPacket

Modifier and Type	Method and Description
List<IReplicationOrderedPacket>	GlobalOrderReliableAsyncGroupBacklog.getReliableAsyncPackets(String memberName, int maxSize, IReplicationReliableAsyncGroupBacklog.KeeperMemberState[] keeperMembersState, IReplicationChannelDataFilter dataFilter, PlatformLogicalVersion targetMemberVersion, Logger logger)

Methods in com.gigaspaces.internal.cluster.node.impl.backlog.globalorder with parameters of type IReplicationOrderedPacket

Modifier and Type	Method and Description
boolean	GlobalOrderReliableAsyncGroupBacklog.mergeWithDiscarded(IReplicationOrderedPacket previousDiscardedPacket, IReplicationOrderedPacket mergedPacket, String memberName)
boolean	AbstractGlobalOrderGroupBacklog.mergeWithDiscarded(IReplicationOrderedPacket previousDiscardedPacket, IReplicationOrderedPacket mergedPacket, String memberName)
IReplicationOrderedPacket	GlobalOrderReliableAsyncGroupBacklog.packetFiltered(IReplicationOrderedPacket beforeFilter, IReplicationOrderedPacket afterFilter, IReplicationGroupBacklog groupBacklog, String targetMemberName)
IReplicationOrderedPacket	IPacketFilteredHandler.packetFiltered(IReplicationOrderedPacket beforeFilter, IReplicationOrderedPacket afterFilter, IReplicationGroupBacklog groupBacklog, String targetMemberName)
void	AbstractGlobalOrderGroupBacklog.processResult(String memberName, IProcessResult result, IReplicationOrderedPacket packet)
void	GlobalOrderReliableAsyncGroupBacklog.reliableAsyncSourceAdd(String sourceMemberName, IReplicationOrderedPacket packet)
void	GlobalOrderReliableAsyncGroupBacklog.reliableAsyncSourceKeep(String sourceMemberName, IReplicationOrderedPacket packet)
IReplicationOrderedPacket	AbstractGlobalOrderGroupBacklog.replaceWithDiscarded(IReplicationOrderedPacket packet, boolean forceDiscard)

Method parameters in com.gigaspaces.internal.cluster.node.impl.backlog.globalorder with type arguments of type IReplicationOrderedPacket

Modifier and Type	Method and Description
void	AbstractGlobalOrderGroupBacklog.processResult(String memberName, IProcessResult result, List<IReplicationOrderedPacket> packets)

Constructors in com.gigaspaces.internal.cluster.node.impl.backlog.globalorder with parameters of type IReplicationOrderedPacket

Constructor and Description
GlobalOrderReliableAsyncKeptDiscardedOrderedPacket(IReplicationOrderedPacket beforeFilter, IReplicationOrderedPacket afterFilter)

Uses of IReplicationOrderedPacket in com.gigaspaces.internal.cluster.node.impl.backlog.multibucketsinglefile

Subinterfaces of IReplicationOrderedPacket in com.gigaspaces.internal.cluster.node.impl.backlog.multibucketsinglefile

Modifier and Type	Interface and Description
interface	IMultiBucketSingleFileReplicationOrderedPacket
interface	ISingleBucketReplicationOrderedPacket

Classes in com.gigaspaces.internal.cluster.node.impl.backlog.multibucketsinglefile that implement IReplicationOrderedPacket

Modifier and Type	Class and Description
class	AbstractMultiBucketOrderedPacket
class	AbstractSingleBucketOrderedPacket
class	DeletedMultiBucketOrderedPacket
class	DiscardedMultiBucketOrderedPacket
class	DiscardedSingleBucketOrderedPacket
class	MultiBucketSingleFileReliableAsyncKeptDiscardedPacket
class	MultipleBucketOrderedPacket
class	SingleBucketOrderedPacket

Methods in com.gigaspaces.internal.cluster.node.impl.backlog.multibucketsinglefile that return IReplicationOrderedPacket

Modifier and Type	Method and Description
IReplicationOrderedPacket	MultiBucketSingleFileReliableAsyncGroupBacklog.packetFiltered(IReplicationOrderedPacket beforeFilter, IReplicationOrderedPacket afterFilter, IReplicationGroupBacklog groupBacklog, String targetMemberName)
IReplicationOrderedPacket	MultiBucketSingleFileReliableAsyncKeptDiscardedPacket.wrapWithReliableAsyncKeptDiscardedPacket(IMultiBucketSingleFileReplicationOrderedPacket typedAfterFilter)

Methods in com.gigaspaces.internal.cluster.node.impl.backlog.multibucketsinglefile that return types with arguments of type IReplicationOrderedPacket

Modifier and Type	Method and Description
List<IReplicationOrderedPacket>	MultiBucketSingleFileReliableAsyncGroupBacklog.getReliableAsyncPackets(String memberName, int maxSize, IReplicationReliableAsyncGroupBacklog.KeeperMemberState[] keeperMembersState, IReplicationChannelDataFilter dataFilter, PlatformLogicalVersion targetMemberVersion, Logger logger)

Methods in com.gigaspaces.internal.cluster.node.impl.backlog.multibucketsinglefile with parameters of type IReplicationOrderedPacket

Modifier and Type	Method and Description
boolean	AbstractMultiBucketSingleFileGroupBacklog.mergeWithDiscarded(IReplicationOrderedPacket previousDiscardedPacket, IReplicationOrderedPacket mergedPacket, String memberName)
IReplicationOrderedPacket	MultiBucketSingleFileReliableAsyncGroupBacklog.packetFiltered(IReplicationOrderedPacket beforeFilter, IReplicationOrderedPacket afterFilter, IReplicationGroupBacklog groupBacklog, String targetMemberName)
void	AbstractMultiBucketSingleFileGroupBacklog.processResult(String memberName, IProcessResult result, IReplicationOrderedPacket packet)
void	MultiBucketSingleFileReliableAsyncGroupBacklog.reliableAsyncSourceAdd(String sourceMemberName, IReplicationOrderedPacket packet)
void	MultiBucketSingleFileReliableAsyncGroupBacklog.reliableAsyncSourceKeep(String sourceMemberName, IReplicationOrderedPacket packet)
IMultiBucketSingleFileReplicationOrderedPacket	AbstractMultiBucketSingleFileGroupBacklog.replaceWithDiscarded(IReplicationOrderedPacket packet, boolean forceDiscard)

Method parameters in com.gigaspaces.internal.cluster.node.impl.backlog.multibucketsinglefile with type arguments of type IReplicationOrderedPacket

Modifier and Type	Method and Description
void	AbstractMultiBucketSingleFileGroupBacklog.processResult(String memberName, IProcessResult result, List<IReplicationOrderedPacket> packets)

Uses of IReplicationOrderedPacket in com.gigaspaces.internal.cluster.node.impl.backlog.multisourcesinglefile

Methods in com.gigaspaces.internal.cluster.node.impl.backlog.multisourcesinglefile that return IReplicationOrderedPacket

Modifier and Type	Method and Description
protected IReplicationOrderedPacket	AbstractMultiSourceSingleFileGroupBacklog.addGenericOperationPacket(IReplicationGroupOutContext groupContext, Object operationData, ReplicationSingleOperationType operationType)
protected IReplicationOrderedPacket	AbstractMultiSourceSingleFileGroupBacklog.addSingleOperationPacket(IReplicationGroupOutContext groupContext, IEntryHolder entryHolder, ReplicationSingleOperationType operationType)
protected IReplicationOrderedPacket	AbstractMultiSourceSingleFileGroupBacklog.addTransactionOperationPacket(IReplicationGroupOutContext groupContext, ServerTransaction transaction, ArrayList<IEntryHolder> lockedEntries, ReplicationMultipleOperationType operationType)
protected IReplicationOrderedPacket	AbstractMultiSourceSingleFileGroupBacklog.createBacklogOverflowPacket(long globalLastConfirmedKey, long firstKeyInBacklog, String memberName)
IReplicationOrderedPacket	MultiSourceSingleFileReliableAsyncGroupBacklog.packetFiltered(IReplicationOrderedPacket beforeFilter, IReplicationOrderedPacket afterFilter, IReplicationGroupBacklog groupBacklog, String targetMemberName)
IReplicationOrderedPacket	AbstractMultiSourceSingleFileGroupBacklog.replaceWithDiscarded(IReplicationOrderedPacket packet, boolean forceDiscard)

Methods in com.gigaspaces.internal.cluster.node.impl.backlog.multisourcesinglefile that return types with arguments of type IReplicationOrderedPacket

Modifier and Type	Method and Description
List<IReplicationOrderedPacket>	MultiSourceSingleFileReliableAsyncGroupBacklog.getReliableAsyncPackets(String memberName, int maxSize, IReplicationReliableAsyncGroupBacklog.KeeperMemberState[] keeperMembersState, IReplicationChannelDataFilter dataFilter, PlatformLogicalVersion targetMemberVersion, Logger logger)

Methods in com.gigaspaces.internal.cluster.node.impl.backlog.multisourcesinglefile with parameters of type IReplicationOrderedPacket

Modifier and Type	Method and Description
boolean	MultiSourceSingleFileReliableAsyncGroupBacklog.mergeWithDiscarded(IReplicationOrderedPacket previousDiscardedPacket, IReplicationOrderedPacket mergedPacket, String memberName)
boolean	AbstractMultiSourceSingleFileGroupBacklog.mergeWithDiscarded(IReplicationOrderedPacket previousDiscardedPacket, IReplicationOrderedPacket mergedPacket, String memberName)
IReplicationOrderedPacket	MultiSourceSingleFileReliableAsyncGroupBacklog.packetFiltered(IReplicationOrderedPacket beforeFilter, IReplicationOrderedPacket afterFilter, IReplicationGroupBacklog groupBacklog, String targetMemberName)
void	AbstractMultiSourceSingleFileGroupBacklog.processResult(String memberName, IProcessResult result, IReplicationOrderedPacket packet)
void	MultiSourceSingleFileReliableAsyncGroupBacklog.reliableAsyncSourceAdd(String sourceMemberName, IReplicationOrderedPacket packet)
void	MultiSourceSingleFileReliableAsyncGroupBacklog.reliableAsyncSourceKeep(String sourceMemberName, IReplicationOrderedPacket packet)
IReplicationOrderedPacket	AbstractMultiSourceSingleFileGroupBacklog.replaceWithDiscarded(IReplicationOrderedPacket packet, boolean forceDiscard)

Method parameters in com.gigaspaces.internal.cluster.node.impl.backlog.multisourcesinglefile with type arguments of type IReplicationOrderedPacket

Modifier and Type	Method and Description
void	AbstractMultiSourceSingleFileGroupBacklog.processResult(String memberName, IProcessResult result, List<IReplicationOrderedPacket> packets)

Uses of IReplicationOrderedPacket in com.gigaspaces.internal.cluster.node.impl.backlog.reliableasync

Methods in com.gigaspaces.internal.cluster.node.impl.backlog.reliableasync that return types with arguments of type IReplicationOrderedPacket

Modifier and Type	Method and Description
List<IReplicationOrderedPacket>	ReliableAsyncHandshakeIteration.getPackets()
List<IReplicationOrderedPacket>	IReplicationReliableAsyncGroupBacklog.getReliableAsyncPackets(String memberName, int maxSize, IReplicationReliableAsyncGroupBacklog.KeeperMemberState[] keeperMembersState, IReplicationChannelDataFilter dataFilter, PlatformLogicalVersion targetMemberVersion, Logger logger) Gets the next packet for the specified async member that is part of a reliable async group

Methods in com.gigaspaces.internal.cluster.node.impl.backlog.reliableasync with parameters of type IReplicationOrderedPacket

Modifier and Type	Method and Description
void	IReplicationReliableAsyncGroupBacklog.reliableAsyncSourceAdd(String sourceMemberName, IReplicationOrderedPacket packet)
void	IReplicationReliableAsyncGroupBacklog.reliableAsyncSourceKeep(String sourceMemberName, IReplicationOrderedPacket packet) Keep an already existing packet which was previously processed or will not be processed by the corresponding process log

Constructor parameters in com.gigaspaces.internal.cluster.node.impl.backlog.reliableasync with type arguments of type IReplicationOrderedPacket

Constructor and Description
ReliableAsyncHandshakeIteration(List<IReplicationOrderedPacket> packets)

Uses of IReplicationOrderedPacket in com.gigaspaces.internal.cluster.node.impl.groups

Methods in com.gigaspaces.internal.cluster.node.impl.groups with type parameters of type IReplicationOrderedPacket

Modifier and Type	Method and Description
static <T extends IReplicationOrderedPacket> T	ReplicationChannelDataFilterHelper.filterPacket(IReplicationChannelDataFilter filter, PlatformLogicalVersion targetMemberVersion, T packet, IReplicationPacketDataProducer dataProducer, IReplicationGroupBacklog groupBacklog, T previousDiscardedPacket, Logger logger, String targetMemberName)
protected static <T extends IReplicationOrderedPacket> T	ReplicationChannelDataFilterHelper.filterSingleEntryDataPacket(IReplicationChannelDataFilter filter, PlatformLogicalVersion targetMemberVersion, T packet, IReplicationPacketDataProducer dataProducer, IReplicationGroupBacklog groupBacklog, T previousDiscardedPacket, Logger logger, String targetMemberName)
protected static <T extends IReplicationOrderedPacket> boolean	ReplicationChannelDataFilterHelper.shouldFilterData(IReplicationChannelDataFilter filter, PlatformLogicalVersion targetMemberVersion, T packet, IReplicationPacketDataProducer dataProducer, Logger logger)

Methods in com.gigaspaces.internal.cluster.node.impl.groups that return types with arguments of type IReplicationOrderedPacket

Modifier and Type	Method and Description
protected List<IReplicationOrderedPacket>	AbstractReplicationSourceChannel.getPendingPackets(int batchSize) Get a list of packets that are waiting to be replicated

Methods in com.gigaspaces.internal.cluster.node.impl.groups with parameters of type IReplicationOrderedPacket

Modifier and Type	Method and Description
void	IReplicationGroupOutContext.addOrderedPacket(IReplicationOrderedPacket packet)
void	ReplicationGroupOutContext.afterAddingOrderedPacket(IReplicationOrderedPacket packet)
protected abstract void	AbstractReplicationSourceChannel.onAsyncReplicateErrorResult(Throwable t, IReplicationOrderedPacket finalPacket)
Object	AbstractReplicationTargetChannel.process(IReplicationOrderedPacket packet)
Object	IReplicationTargetGroup.process(String sourceMemberLookupName, Object sourceUniqueId, IReplicationOrderedPacket packet)
Object	AbstractReplicationTargetGroup.process(String sourceMemberLookupName, Object sourceUniqueId, IReplicationOrderedPacket packet)
protected int	AbstractReplicationSourceChannel.replicate(IReplicationOrderedPacket packet)
protected Future	AbstractReplicationSourceChannel.replicateAsync(IReplicationOrderedPacket packet)

Method parameters in com.gigaspaces.internal.cluster.node.impl.groups with type arguments of type IReplicationOrderedPacket

Modifier and Type	Method and Description
protected abstract void	AbstractReplicationSourceChannel.onAsyncReplicateErrorResult(Throwable t, List<IReplicationOrderedPacket> finalPackets)
Object	AbstractReplicationTargetChannel.processBatch(List<IReplicationOrderedPacket> packets)
Object	IReplicationTargetGroup.processBatch(String sourceMemberLookupName, Object sourceUniqueId, List<IReplicationOrderedPacket> packets)
Object	AbstractReplicationTargetGroup.processBatch(String sourceMemberLookupName, Object sourceUniqueId, List<IReplicationOrderedPacket> packets)
protected Future	AbstractReplicationSourceChannel.replicateAsync(List<IReplicationOrderedPacket> packets)
protected int	AbstractReplicationSourceChannel.replicateBatch(List<IReplicationOrderedPacket> packets) Replicate given packets
protected void	AbstractReplicationSourceChannel.replicateBatchDelayed(List<IReplicationOrderedPacket> packets) This method should be called when replicating packets that were generated at a considerable time before the actual replication (i.e async replication), this will replicate only packets that are not obsolete (i.e equals true)
protected void	AbstractReplicationSourceChannel.replicateBatchDelayedAsync(List<IReplicationOrderedPacket> packets, IAsyncReplicationListener listener)

Uses of IReplicationOrderedPacket in com.gigaspaces.internal.cluster.node.impl.groups.async

Methods in com.gigaspaces.internal.cluster.node.impl.groups.async that return types with arguments of type IReplicationOrderedPacket

Modifier and Type	Method and Description
protected List<IReplicationOrderedPacket>	AsyncReplicationSourceChannel.getPendingPackets()

Methods in com.gigaspaces.internal.cluster.node.impl.groups.async with parameters of type IReplicationOrderedPacket

Modifier and Type	Method and Description
void	AsyncReplicationGroupOutContext.addOrderedPacket(IReplicationOrderedPacket packet)
protected void	AsyncReplicationSourceChannel.onAsyncReplicateErrorResult(Throwable t, IReplicationOrderedPacket finalPacket)

Method parameters in com.gigaspaces.internal.cluster.node.impl.groups.async with type arguments of type IReplicationOrderedPacket

Modifier and Type	Method and Description
protected void	AsyncReplicationSourceChannel.onAsyncReplicateErrorResult(Throwable t, List<IReplicationOrderedPacket> finalPackets)

Uses of IReplicationOrderedPacket in com.gigaspaces.internal.cluster.node.impl.groups.reliableasync

Methods in com.gigaspaces.internal.cluster.node.impl.groups.reliableasync that return types with arguments of type IReplicationOrderedPacket

Modifier and Type	Method and Description
protected List<IReplicationOrderedPacket>	ReliableAsyncReplicationSourceChannel.getPendingPackets()

Methods in com.gigaspaces.internal.cluster.node.impl.groups.reliableasync with parameters of type IReplicationOrderedPacket

Modifier and Type	Method and Description
IMarker	IReplicationReliableAsyncMediator.getMarker(IReplicationOrderedPacket packet, String membersGroupName)
IMarker	SourceDelegationReplicationReliableAsyncMediator.getMarker(IReplicationOrderedPacket packet, String membersGroupName)
void	IReplicationReliableAsyncMediator.reliableAsyncSourceAdd(String sourceLookupName, IReplicationOrderedPacket packet)
void	SourceDelegationReplicationReliableAsyncMediator.reliableAsyncSourceAdd(String sourceLookupName, IReplicationOrderedPacket packet)
void	IReplicationReliableAsyncMediator.reliableAsyncSourceKeep(String sourceMemberName, IReplicationOrderedPacket packet)
void	SourceDelegationReplicationReliableAsyncMediator.reliableAsyncSourceKeep(String sourceMemberName, IReplicationOrderedPacket packet)

Uses of IReplicationOrderedPacket in com.gigaspaces.internal.cluster.node.impl.groups.sync

Methods in com.gigaspaces.internal.cluster.node.impl.groups.sync that return IReplicationOrderedPacket

Modifier and Type	Method and Description
IReplicationOrderedPacket	ISyncReplicationGroupOutContext.getSinglePacket()
IReplicationOrderedPacket	SyncReplicationGroupOutContext.getSinglePacket()

Methods in com.gigaspaces.internal.cluster.node.impl.groups.sync that return types with arguments of type IReplicationOrderedPacket

Modifier and Type	Method and Description
List<IReplicationOrderedPacket>	ISyncReplicationGroupOutContext.getOrderedPackets()
List<IReplicationOrderedPacket>	SyncReplicationGroupOutContext.getOrderedPackets()

Methods in com.gigaspaces.internal.cluster.node.impl.groups.sync with parameters of type IReplicationOrderedPacket

Modifier and Type	Method and Description
void	SyncReplicationGroupOutContext.addOrderedPacket(IReplicationOrderedPacket packet)
protected void	SyncReplicationSourceChannel.onAsyncReplicateErrorResult(Throwable t, IReplicationOrderedPacket packet)

Method parameters in com.gigaspaces.internal.cluster.node.impl.groups.sync with type arguments of type IReplicationOrderedPacket

Modifier and Type	Method and Description
protected void	SyncReplicationSourceChannel.onAsyncReplicateErrorResult(Throwable t, List<IReplicationOrderedPacket> packets)

Uses of IReplicationOrderedPacket in com.gigaspaces.internal.cluster.node.impl.packets

Methods in com.gigaspaces.internal.cluster.node.impl.packets that return IReplicationOrderedPacket

Modifier and Type	Method and Description
IReplicationOrderedPacket	IReplicationOrderedPacket.clone()
IReplicationOrderedPacket	IReplicationOrderedPacket.cloneWithNewData(IReplicationPacketData<?> newData) Clones the packet replacing its data with the new data
IReplicationOrderedPacket	ReplicatedDataPacket.getPacket()

Methods in com.gigaspaces.internal.cluster.node.impl.packets that return types with arguments of type IReplicationOrderedPacket

Modifier and Type	Method and Description
List<IReplicationOrderedPacket>	BatchReplicatedDataPacket.getBatch()

Methods in com.gigaspaces.internal.cluster.node.impl.packets with parameters of type IReplicationOrderedPacket

Modifier and Type	Method and Description
void	ReplicatedDataPacket.setPacket(IReplicationOrderedPacket packet)

Method parameters in com.gigaspaces.internal.cluster.node.impl.packets with type arguments of type IReplicationOrderedPacket

Modifier and Type	Method and Description
void	BatchReplicatedDataPacket.setBatch(List<IReplicationOrderedPacket> batch)

Uses of IReplicationOrderedPacket in com.gigaspaces.internal.cluster.node.impl.processlog

Methods in com.gigaspaces.internal.cluster.node.impl.processlog with parameters of type IReplicationOrderedPacket

Modifier and Type	Method and Description
IDataConsumeFix	IReplicationProcessLogExceptionHandler.handleException(IDataConsumeResult errorResult, IReplicationOrderedPacket packet)
IDataConsumeFix	DefaultProcessLogExceptionHandler.handleException(IDataConsumeResult errorResult, IReplicationOrderedPacket packet)
IProcessResult	IReplicationTargetProcessLog.process(String sourceLookupName, IReplicationOrderedPacket packet, IReplicationInFilterCallback inFilterCallback)

Method parameters in com.gigaspaces.internal.cluster.node.impl.processlog with type arguments of type IReplicationOrderedPacket

Modifier and Type	Method and Description
IProcessResult	IReplicationTargetProcessLog.processBatch(String sourceLookupName, List<IReplicationOrderedPacket> packet, IReplicationInFilterCallback inFilterCallback)

Uses of IReplicationOrderedPacket in com.gigaspaces.internal.cluster.node.impl.processlog.globalorder

Methods in com.gigaspaces.internal.cluster.node.impl.processlog.globalorder with parameters of type IReplicationOrderedPacket

Modifier and Type	Method and Description
protected void	GlobalOrderReliableAsyncTargetKeeperProcessLog.afterSuccessfulConsumption(String sourceLookupName, IReplicationOrderedPacket packet)
protected void	GlobalOrderTargetProcessLog.afterSuccessfulConsumption(String sourceLookupName, IReplicationOrderedPacket packet)
int	GlobalOrderTargetProcessLog.SharedOrderedPacketComparator.compare(IReplicationOrderedPacket o1, IReplicationOrderedPacket o2)
protected boolean	AbstractGlobalOrderTargetProcessLog.filterDuplicate(IReplicationOrderedPacket packet)
GlobalOrderProcessResult	GlobalOrderTargetProcessLog.process(String sourceLookupName, IReplicationOrderedPacket packet, IReplicationInFilterCallback inFilterCallback)
IProcessResult	GlobalOrderBatchConsumeTargetProcessLog.process(String sourceLookupName, IReplicationOrderedPacket packet, IReplicationInFilterCallback inFilterCallback)

Method parameters in com.gigaspaces.internal.cluster.node.impl.processlog.globalorder with type arguments of type IReplicationOrderedPacket

Modifier and Type	Method and Description
protected void	AbstractGlobalOrderTargetProcessLog.filterDuplicate(List<IReplicationOrderedPacket> packets)
GlobalOrderProcessResult	GlobalOrderTargetProcessLog.processBatch(String sourceLookupName, List<IReplicationOrderedPacket> packets, IReplicationInFilterCallback filterInCallback)
GlobalOrderProcessResult	GlobalOrderBatchConsumeTargetProcessLog.processBatch(String sourceLookupName, List<IReplicationOrderedPacket> packets, IReplicationInFilterCallback inFilterCallback)

Uses of IReplicationOrderedPacket in com.gigaspaces.internal.cluster.node.impl.processlog.multibucketsinglefile

Methods in com.gigaspaces.internal.cluster.node.impl.processlog.multibucketsinglefile that return types with arguments of type IReplicationOrderedPacket

Modifier and Type	Method and Description
List<IReplicationOrderedPacket>	ParallelBatchProcessingContext.getSegment(int segmentIndex)

Methods in com.gigaspaces.internal.cluster.node.impl.processlog.multibucketsinglefile with parameters of type IReplicationOrderedPacket

Modifier and Type	Method and Description
protected void	AbstractMultiBucketSingleFileTargetProcessLog.afterSuccessfulConsumption(String sourceLookupName, IReplicationOrderedPacket packet)
protected void	MultiBucketSingleFileReliableAsyncTargetKeeperProcessLog.afterSuccessfulConsumption(String sourceLookupName, IReplicationOrderedPacket packet)
protected boolean	MultiBucketSingleFileBatchConsumeTargetProcessLog.filterDuplicate(IReplicationOrderedPacket packet)
MultiBucketSingleFileProcessResult	MultiBucketSingleFileBatchConsumeTargetProcessLog.process(String sourceLookupName, IReplicationOrderedPacket packet, IReplicationInFilterCallback inFilterCallback)
MultiBucketSingleFileProcessResult	AbstractMultiBucketSingleFileTargetProcessLog.process(String sourceLookupName, IReplicationOrderedPacket packet, IReplicationInFilterCallback inFilterCallback)
MultiBucketSingleFileProcessResult	AbstractMultiBucketSingleFileTargetProcessLog.process(String sourceLookupName, IReplicationOrderedPacket packet, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext batchContext, int segmentIndex)

Method parameters in com.gigaspaces.internal.cluster.node.impl.processlog.multibucketsinglefile with type arguments of type IReplicationOrderedPacket

Modifier and Type	Method and Description
void	AbstractMultiBucketSingleFileTargetProcessLog.createBatchParallelProcessingContinuationTask(String sourceLookupName, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext context, List<IReplicationOrderedPacket> batch, int segmentIndex)
protected void	MultiBucketSingleFileBatchConsumeTargetProcessLog.filterDuplicate(List<IReplicationOrderedPacket> packets)
MultiBucketSingleFileProcessResult	MultiBucketSingleFileBatchConsumeTargetProcessLog.processBatch(String sourceLookupName, List<IReplicationOrderedPacket> packets, IReplicationInFilterCallback inFilterCallback)
MultiBucketSingleFileProcessResult	AbstractMultiBucketSingleFileTargetProcessLog.processBatch(String sourceLookupName, List<IReplicationOrderedPacket> packets, IReplicationInFilterCallback inFilterCallback)

Uses of IReplicationOrderedPacket in com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile

Fields in com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile declared as IReplicationOrderedPacket

Modifier and Type	Field and Description
protected IReplicationOrderedPacket	MultiSourceProcessLogPacket._packet

Methods in com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile that return IReplicationOrderedPacket

Modifier and Type	Method and Description
IReplicationOrderedPacket	MultiSourceProcessLogPacket.getReplicationPacket()

Methods in com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile with parameters of type IReplicationOrderedPacket

Modifier and Type	Method and Description
protected boolean	MultiSourceSingleFileReliableAsyncTargetProcessLog.filterDuplicate(IReplicationOrderedPacket packet)
IProcessResult	MultiSourceSingleFileReliableAsyncTargetProcessLog.process(String sourceLookupName, IReplicationOrderedPacket packet, IReplicationInFilterCallback inFilterCallback)

Method parameters in com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile with type arguments of type IReplicationOrderedPacket

Modifier and Type	Method and Description
protected void	MultiSourceSingleFileReliableAsyncTargetProcessLog.filterDuplicate(List<IReplicationOrderedPacket> packets)
IProcessResult	MultiSourceSingleFileReliableAsyncTargetProcessLog.processBatch(String sourceLookupName, List<IReplicationOrderedPacket> packets, IReplicationInFilterCallback inFilterCallback)

Constructors in com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile with parameters of type IReplicationOrderedPacket

Constructor and Description
MultiSourceProcessLogMultiParticipantPacket(IReplicationOrderedPacket packet, IReplicationParticipantsMediator participantsMediator, IReplicationParticipantsMetadata participantsMetadata)
MultiSourceProcessLogPacket(IReplicationOrderedPacket packet)

Uses of IReplicationOrderedPacket in com.gigaspaces.internal.server.space.redolog

Classes in com.gigaspaces.internal.server.space.redolog with type parameters of type IReplicationOrderedPacket

Modifier and Type	Class and Description
class	FixedSizeSwapRedoLogFile<T extends IReplicationOrderedPacket> A swap based implementation of the IRedoLogFile interface, A fixed number of packets can be held in the memory and once this number is exeeded the other packets are stored in a provided INonBatchRedoLogFileStorage
class	FixedSizeSwapRedoLogFileConfig<T extends IReplicationOrderedPacket> Configures a FixedSizeSwapRedoLogFileConfig
interface	IRedoLogFile<T extends IReplicationOrderedPacket> Acts as the redo log packets storage MemoryRedoLogFile Implementor should support concurrent readers or a single writer, in other words, the implementor can assume access to this structure are guarded with a reader writer lock according to the operation type An exception is IRedoLogFile.getApproximateSize() method which should not assume a reader lock is held.
class	MemoryRedoLogFile<T extends IReplicationOrderedPacket> A memory only based implementation of the IRedoLogFile interface.

Uses of IReplicationOrderedPacket in com.gigaspaces.internal.server.space.redolog.storage

Classes in com.gigaspaces.internal.server.space.redolog.storage with type parameters of type IReplicationOrderedPacket

Modifier and Type	Class and Description
class	BufferedRedoLogFileStorageDecorator<T extends IReplicationOrderedPacket> Wraps a IRedoLogFileStorage with a buffer, allowing adding single packets in the storage which will be flushed once a specific buffer size is reached
class	CacheLastRedoLogFileStorageDecorator<T extends IReplicationOrderedPacket> Wraps a INonBatchRedoLogFileStorage with a cache that keeps a constant size number of packets in memory which were the last appended packet.
interface	INonBatchRedoLogFileStorage<T extends IReplicationOrderedPacket> Extends the IRedoLogFileStorage interface by adding a non batch behavior of adding packets to the end of the list.
interface	IRedoLogFileStorage<T extends IReplicationOrderedPacket> Provide an external storage for a redo log file, Packets are stored as a single list, adding packets are always appended at the end of the list, and removal of packets are always from the start of the list Implementor should support concurrent readers or a single writer, in other words, the implementor can assume access to this structure are guarded with a reader writer lock according to the operation type An exception is IRedoLogFileStorage.size() method which should not assume a reader lock is held.

Uses of IReplicationOrderedPacket in com.gigaspaces.internal.server.space.redolog.storage.bytebuffer

Classes in com.gigaspaces.internal.server.space.redolog.storage.bytebuffer with type parameters of type IReplicationOrderedPacket

Modifier and Type	Class and Description
class	ByteBufferRedoLogFileStorage<T extends IReplicationOrderedPacket> An implementation of redo log file storage which is based on an underlying byte buffer storages provider which simulated an endless byte buffer