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, Externalizable, Serializable, Cloneable

Direct Known Subclasses:

DiscardedSingleBucketOrderedPacket, SingleBucketOrderedPacket

public abstract class AbstractSingleBucketOrderedPacket
extends Object
implements ISingleBucketReplicationOrderedPacket

See Also:

Serialized Form

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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

Constructor Detail

AbstractSingleBucketOrderedPacket

public AbstractSingleBucketOrderedPacket()

AbstractSingleBucketOrderedPacket

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

Method Detail

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 ISingleBucketReplicationOrderedPacket

Specified by:

clone in interface IReplicationOrderedPacket

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