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

Class AbstractSingleBucketOrderedPacket

java.lang.Object

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

All Implemented Interfaces:

IMultiBucketSingleFileReplicationOrderedPacket, ISingleBucketReplicationOrderedPacket, IReplicationOrderedPacket, ISwapExternalizable, SmartExternalizable, Externalizable, Serializable, Cloneable

Direct Known Subclasses:

DiscardedSingleBucketOrderedPacket, SingleBucketOrderedPacket

public abstract class AbstractSingleBucketOrderedPacket
extends Object
implements ISingleBucketReplicationOrderedPacket

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
AbstractSingleBucketOrderedPacket()
AbstractSingleBucketOrderedPacket(long globalKey, long bucketKey, short bucketIndex)

Method Summary

Modifier and Type	Method	Description
void	associateToBuckets(ShortObjectMap<List<IMultiBucketSingleFileReplicationOrderedPacket>> bucketsPackets)
short	bucketCount()
abstract AbstractSingleBucketOrderedPacket	clone()
boolean	equals(Object obj)
short	getBucketIndex()
long	getBucketKey()
long	getBucketKey(short bucketIndex)
short[]	getBuckets()
PacketConsumeState	getConsumeState(short bucketIndex)
long	getEndKey()	return the last key for given packets - relevant to range packets - merged discarded/deleted packets
long	getKey()
IMultiBucketSingleFileReplicationOrderedPacket	getReliableAsyncBeforeFilterPacket()
int	getWeight()
int	hashCode()
long	processResult(String memberName, MultiBucketSingleFileProcessResult processResult, MultiBucketSingleFileConfirmationHolder confirmationHolder)
void	readExternal(ObjectInput in)
void	readFromSwap(ObjectInput in)
void	reliableAsyncKeysUpdate(long[] bucketLastKeys, MultiBucketSingleFileConfirmationHolder confirmationHolder)
boolean	setConsumed()
void	setReliableAsyncBeforeFilterPacket(IMultiBucketSingleFileReplicationOrderedPacket beforeFilterPacket)
String	toString()
void	writeExternal(ObjectOutput out)
void	writeToSwap(ObjectOutput out)

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.gigaspaces.internal.cluster.node.impl.backlog.multibucketsinglefile.IMultiBucketSingleFileReplicationOrderedPacket

cloneWithNewData, process, replaceWithDiscarded

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

getData, isDataPacket, isDiscardedPacket

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Constructor Details

AbstractSingleBucketOrderedPacket

public AbstractSingleBucketOrderedPacket()

AbstractSingleBucketOrderedPacket

public AbstractSingleBucketOrderedPacket(long globalKey,
 long bucketKey,
 short bucketIndex)

Method Details

getKey

public long getKey()

Specified by:

getKey in interface IReplicationOrderedPacket

getEndKey

public long getEndKey()

Description copied from interface: IReplicationOrderedPacket

return the last key for given packets - relevant to range packets - merged discarded/deleted packets

Specified by:

getEndKey in interface IReplicationOrderedPacket

getBucketKey

public long getBucketKey(short bucketIndex)

Specified by:

getBucketKey in interface IMultiBucketSingleFileReplicationOrderedPacket

getBuckets

public short[] getBuckets()

Specified by:

getBuckets in interface IMultiBucketSingleFileReplicationOrderedPacket

getConsumeState

public PacketConsumeState getConsumeState(short bucketIndex)

Specified by:

getConsumeState in interface IMultiBucketSingleFileReplicationOrderedPacket

setConsumed

public boolean setConsumed()

Specified by:

setConsumed in interface IMultiBucketSingleFileReplicationOrderedPacket

getBucketIndex

public short getBucketIndex()

Specified by:

getBucketIndex in interface ISingleBucketReplicationOrderedPacket

getBucketKey

public long getBucketKey()

Specified by:

getBucketKey in interface ISingleBucketReplicationOrderedPacket

bucketCount

public short bucketCount()

Specified by:

bucketCount in interface IMultiBucketSingleFileReplicationOrderedPacket

associateToBuckets

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

Specified by:

associateToBuckets in interface IMultiBucketSingleFileReplicationOrderedPacket

processResult

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

Specified by:

processResult in interface IMultiBucketSingleFileReplicationOrderedPacket

reliableAsyncKeysUpdate

public void reliableAsyncKeysUpdate(long[] bucketLastKeys,
 MultiBucketSingleFileConfirmationHolder confirmationHolder)

Specified by:

reliableAsyncKeysUpdate in interface IMultiBucketSingleFileReplicationOrderedPacket

getReliableAsyncBeforeFilterPacket

public IMultiBucketSingleFileReplicationOrderedPacket getReliableAsyncBeforeFilterPacket()

Specified by:

getReliableAsyncBeforeFilterPacket in interface IMultiBucketSingleFileReplicationOrderedPacket

setReliableAsyncBeforeFilterPacket

public void setReliableAsyncBeforeFilterPacket(IMultiBucketSingleFileReplicationOrderedPacket beforeFilterPacket)

Specified by:

setReliableAsyncBeforeFilterPacket in interface IMultiBucketSingleFileReplicationOrderedPacket

clone

public abstract AbstractSingleBucketOrderedPacket clone()

Specified by:

clone in interface IMultiBucketSingleFileReplicationOrderedPacket

Specified by:

clone in interface IReplicationOrderedPacket

Specified by:

clone in interface ISingleBucketReplicationOrderedPacket

Overrides:

clone in class Object

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

writeToSwap

public void writeToSwap(ObjectOutput out)
                 throws IOException

Specified by:

writeToSwap in interface ISwapExternalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

readFromSwap

public void readFromSwap(ObjectInput in)
                  throws IOException,
ClassNotFoundException

Specified by:

readFromSwap in interface ISwapExternalizable

Throws:

IOException

ClassNotFoundException

toString

public String toString()

Overrides:

toString in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

getWeight

public int getWeight()

Specified by:

getWeight in interface IReplicationOrderedPacket