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

Interface IMultiBucketSingleFileReplicationOrderedPacket

All Superinterfaces:

Cloneable, Externalizable, IReplicationOrderedPacket, ISwapExternalizable, Serializable, SmartExternalizable

All Known Subinterfaces:

ISingleBucketReplicationOrderedPacket

All Known Implementing Classes:

AbstractMultiBucketOrderedPacket, AbstractSingleBucketOrderedPacket, DeletedMultiBucketOrderedPacket, DiscardedMultiBucketOrderedPacket, DiscardedSingleBucketOrderedPacket, MultiBucketSingleFileReliableAsyncKeptDiscardedPacket, MultipleBucketOrderedPacket, SingleBucketOrderedPacket

public interface IMultiBucketSingleFileReplicationOrderedPacket
extends IReplicationOrderedPacket

Method Summary

Modifier and Type	Method and Description
void	associateToBuckets(ShortObjectMap<List<IMultiBucketSingleFileReplicationOrderedPacket>> bucketsPackets)
short	bucketCount()
IMultiBucketSingleFileReplicationOrderedPacket	clone()
IMultiBucketSingleFileReplicationOrderedPacket	cloneWithNewData(IReplicationPacketData<?> newData) Clones the packet replacing its data with the new data
long	getBucketKey(short bucketIndex)
short[]	getBuckets()
PacketConsumeState	getConsumeState(short bucketIndex)
IMultiBucketSingleFileReplicationOrderedPacket	getReliableAsyncBeforeFilterPacket()
MultiBucketSingleFileProcessResult	process(String sourceLookupName, IMultiBucketSingleFileProcessLog processLog, IReplicationInFilterCallback inFilterCallback, ParallelBatchProcessingContext context, int segmentIndex)
long	processResult(String memberName, MultiBucketSingleFileProcessResult processResult, MultiBucketSingleFileConfirmationHolder confirmationHolder)
void	reliableAsyncKeysUpdate(long[] bucketLastKeys, MultiBucketSingleFileConfirmationHolder confirmationHolder)
IMultiBucketSingleFileReplicationOrderedPacket	replaceWithDiscarded()
boolean	setConsumed()
void	setReliableAsyncBeforeFilterPacket(IMultiBucketSingleFileReplicationOrderedPacket beforeFilterPacket)

Methods inherited from interface com.gigaspaces.internal.cluster.node.impl.packets.IReplicationOrderedPacket

getData, getEndKey, getKey, getWeight, isDataPacket, isDiscardedPacket

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Methods inherited from interface java.io.Externalizable

readExternal, writeExternal

Methods inherited from interface com.gigaspaces.internal.server.space.redolog.storage.bytebuffer.ISwapExternalizable

readFromSwap, writeToSwap

Method Detail

process

MultiBucketSingleFileProcessResult process(String sourceLookupName,
                                           IMultiBucketSingleFileProcessLog processLog,
                                           IReplicationInFilterCallback inFilterCallback,
                                           ParallelBatchProcessingContext context,
                                           int segmentIndex)

processResult

long processResult(String memberName,
                   MultiBucketSingleFileProcessResult processResult,
                   MultiBucketSingleFileConfirmationHolder confirmationHolder)

getBucketKey

long getBucketKey(short bucketIndex)

getConsumeState

PacketConsumeState getConsumeState(short bucketIndex)

setConsumed

boolean setConsumed()

bucketCount

short bucketCount()

getBuckets

short[] getBuckets()

associateToBuckets

void associateToBuckets(ShortObjectMap<List<IMultiBucketSingleFileReplicationOrderedPacket>> bucketsPackets)

replaceWithDiscarded

IMultiBucketSingleFileReplicationOrderedPacket replaceWithDiscarded()

clone

IMultiBucketSingleFileReplicationOrderedPacket clone()

Specified by:

clone in interface IReplicationOrderedPacket

cloneWithNewData

IMultiBucketSingleFileReplicationOrderedPacket cloneWithNewData(IReplicationPacketData<?> newData)

Description copied from interface: IReplicationOrderedPacket

Clones the packet replacing its data with the new data

Specified by:

cloneWithNewData in interface IReplicationOrderedPacket

reliableAsyncKeysUpdate

void reliableAsyncKeysUpdate(long[] bucketLastKeys,
                             MultiBucketSingleFileConfirmationHolder confirmationHolder)

getReliableAsyncBeforeFilterPacket

IMultiBucketSingleFileReplicationOrderedPacket getReliableAsyncBeforeFilterPacket()

setReliableAsyncBeforeFilterPacket

void setReliableAsyncBeforeFilterPacket(IMultiBucketSingleFileReplicationOrderedPacket beforeFilterPacket)