org.gridgain.grid.kernal.processors.cache.datastructures

Class GridCacheAtomicSequenceImpl

java.lang.Object

org.gridgain.grid.kernal.processors.cache.datastructures.GridCacheAtomicSequenceImpl

All Implemented Interfaces:

Externalizable, Serializable, GridCacheAtomicSequence, GridCacheAtomicSequenceEx, GridCacheRemovable

public final class GridCacheAtomicSequenceImpl
extends Object
implements GridCacheAtomicSequenceEx, Externalizable

Cache sequence implementation.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GridCacheAtomicSequenceImpl() Empty constructor required by Externalizable.
GridCacheAtomicSequenceImpl(String name, GridCacheInternalKey key, GridCacheProjection<GridCacheInternalKey,GridCacheAtomicSequenceValue> seqView, GridCacheContext ctx, long locVal, long upBound) Default constructor.

Method Summary

Methods

Modifier and Type	Method and Description
long	addAndGet(long l) Adds l elements to atomic sequence and gets value of atomic sequence.
int	batchSize() Get local batch size for this sequences.
void	batchSize(int size) Set local batch size for this sequences.
long	get() Gets current value of atomic sequence.
long	getAndAdd(long l) Gets current value of atomic sequence and adds l elements.
long	getAndIncrement() Gets and increments current value of atomic sequence.
long	incrementAndGet() Increments and returns the value of atomic sequence.
GridCacheInternalKey	key() Get current sequence key.
String	name() Name of atomic sequence.
void	onInvalid(Exception err)
boolean	onRemoved() Set status of data structure as removed.
void	readExternal(ObjectInput in)
boolean	removed() Gets status of atomic sequence.
String	toString()
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

GridCacheAtomicSequenceImpl

public GridCacheAtomicSequenceImpl()

Empty constructor required by Externalizable.

GridCacheAtomicSequenceImpl

public GridCacheAtomicSequenceImpl(String name,
                           GridCacheInternalKey key,
                           GridCacheProjection<GridCacheInternalKey,GridCacheAtomicSequenceValue> seqView,
                           GridCacheContext ctx,
                           long locVal,
                           long upBound)

Default constructor.

Parameters:

name - Sequence name.

key - Sequence key.

seqView - Sequence projection.

ctx - CacheContext.

locVal - Local counter.

upBound - Upper bound.

Method Detail

name

public String name()

Name of atomic sequence.

Specified by:

name in interface GridCacheAtomicSequence

Returns:

Name of atomic sequence.

get

public long get()
         throws GridException

Gets current value of atomic sequence.

Specified by:

get in interface GridCacheAtomicSequence

Returns:

Value of atomic sequence.

Throws:

GridException - If operation failed.

incrementAndGet

public long incrementAndGet()
                     throws GridException

Increments and returns the value of atomic sequence.

Specified by:

incrementAndGet in interface GridCacheAtomicSequence

Returns:

Value of atomic sequence after increment.

Throws:

GridException - If operation failed.

getAndIncrement

public long getAndIncrement()
                     throws GridException

Gets and increments current value of atomic sequence.

Specified by:

getAndIncrement in interface GridCacheAtomicSequence

Returns:

Value of atomic sequence before increment.

Throws:

GridException - If operation failed.

addAndGet

public long addAndGet(long l)
               throws GridException

Adds l elements to atomic sequence and gets value of atomic sequence.

Specified by:

addAndGet in interface GridCacheAtomicSequence

Parameters:

l - Number of added elements.

Returns:

Value of atomic sequence.

Throws:

GridException - If operation failed.

getAndAdd

public long getAndAdd(long l)
               throws GridException

Gets current value of atomic sequence and adds l elements.

Specified by:

getAndAdd in interface GridCacheAtomicSequence

Parameters:

l - Number of added elements.

Returns:

Value of atomic sequence.

Throws:

GridException - If operation failed.

batchSize

public int batchSize()

Get local batch size for this sequences.

Specified by:

batchSize in interface GridCacheAtomicSequence

Returns:

Sequence batch size.

batchSize

public void batchSize(int size)

Set local batch size for this sequences.

Specified by:

batchSize in interface GridCacheAtomicSequence

Parameters:

size - Sequence batch size. Must be more then 0.

onRemoved

public boolean onRemoved()

Set status of data structure as removed.

Specified by:

onRemoved in interface GridCacheRemovable

Returns:

Current status.

onInvalid

public void onInvalid(@Nullable
             Exception err)

Specified by:

onInvalid in interface GridCacheRemovable

Parameters:

err - Error which cause data structure to become invalid.

key

public GridCacheInternalKey key()

Get current sequence key.

Specified by:

key in interface GridCacheAtomicSequenceEx

Returns:

Sequence key.

removed

public boolean removed()

Gets status of atomic sequence.

Specified by:

removed in interface GridCacheAtomicSequence

Returns:

true if atomic sequence was removed from cache, false otherwise.

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

toString

public String toString()

Overrides:

toString in class Object