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

Class AbstractMultiBucketOrderedPacket

java.lang.Object

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

All Implemented Interfaces:

IMultiBucketSingleFileReplicationOrderedPacket, IReplicationOrderedPacket, ISwapExternalizable, Externalizable, Serializable, Cloneable

Direct Known Subclasses:

DeletedMultiBucketOrderedPacket, DiscardedMultiBucketOrderedPacket, MultipleBucketOrderedPacket

public abstract class AbstractMultiBucketOrderedPacket
extends Object
implements IMultiBucketSingleFileReplicationOrderedPacket

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
AbstractMultiBucketOrderedPacket()
AbstractMultiBucketOrderedPacket(long globalKey, ShortObjectMap<BucketKey> bucketsKeys)

Method Summary

Modifier and Type	Method and Description
void	associateToBuckets(ShortObjectMap<List<IMultiBucketSingleFileReplicationOrderedPacket>> bucketsPackets)
short	bucketCount()
abstract AbstractMultiBucketOrderedPacket	clone()
boolean	equals(Object obj)
long	getBucketKey(short bucketIndex)
short[]	getBuckets()
ShortObjectMap<BucketKey>	getBucketsKeys()
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)
protected void	readBucketKeys(ObjectInput in)
void	readExternal(ObjectInput in)
void	readFromSwap(ObjectInput in)
void	reliableAsyncKeysUpdate(long[] bucketLastKeys, MultiBucketSingleFileConfirmationHolder confirmationHolder)
void	setReliableAsyncBeforeFilterPacket(IMultiBucketSingleFileReplicationOrderedPacket beforeFilterPacket)
String	toString()
protected void	writeBucketKeys(ObjectOutput out)
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, getConsumeState, process, replaceWithDiscarded, setConsumed

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

getData, isDataPacket, isDiscardedPacket

Constructor Detail

AbstractMultiBucketOrderedPacket

public AbstractMultiBucketOrderedPacket()

AbstractMultiBucketOrderedPacket

public AbstractMultiBucketOrderedPacket(long globalKey,
                                        ShortObjectMap<BucketKey> bucketsKeys)

Method Detail

getBucketKey

public long getBucketKey(short bucketIndex)

Specified by:

getBucketKey in interface IMultiBucketSingleFileReplicationOrderedPacket

getBucketsKeys

public ShortObjectMap<BucketKey> getBucketsKeys()

getBuckets

public short[] getBuckets()

Specified by:

getBuckets in interface IMultiBucketSingleFileReplicationOrderedPacket

bucketCount

public short bucketCount()

Specified by:

bucketCount in interface IMultiBucketSingleFileReplicationOrderedPacket

associateToBuckets

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

Specified by:

associateToBuckets in interface IMultiBucketSingleFileReplicationOrderedPacket

writeBucketKeys

protected void writeBucketKeys(ObjectOutput out)
                        throws IOException

Throws:

IOException

readBucketKeys

protected void readBucketKeys(ObjectInput in)
                       throws IOException

Throws:

IOException

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

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

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

clone

public abstract AbstractMultiBucketOrderedPacket clone()

Specified by:

clone in interface IMultiBucketSingleFileReplicationOrderedPacket

Specified by:

clone in interface IReplicationOrderedPacket

Overrides:

clone in class Object

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