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

Class GridCacheDataStructuresManager<K,V>

java.lang.Object

org.gridgain.grid.kernal.processors.cache.GridCacheManagerAdapter<K,V>

org.gridgain.grid.kernal.processors.cache.datastructures.GridCacheDataStructuresManager<K,V>

All Implemented Interfaces:

GridCacheManager<K,V>

public final class GridCacheDataStructuresManager<K,V>
extends GridCacheManagerAdapter<K,V>

Manager of data structures.

Field Summary

Fields inherited from class org.gridgain.grid.kernal.processors.cache.GridCacheManagerAdapter

cctx, log

Constructor Summary

Constructors

Constructor and Description
GridCacheDataStructuresManager() Default constructor.

Method Summary

Methods

Modifier and Type	Method and Description
GridCacheAtomicLong	atomicLong(String name, long initVal, boolean create) Gets an atomic long from cache or creates one if it's not cached.
<T> GridCacheAtomicReference<T>	atomicReference(String name, T initVal, boolean create) Gets an atomic reference from cache or creates one if it's not cached.
<T,S> GridCacheAtomicStamped<T,S>	atomicStamped(String name, T initVal, S initStamp, boolean create) Gets an atomic stamped from cache or creates one if it's not cached.
GridCacheCountDownLatch	countDownLatch(String name, int cnt, boolean autoDel, boolean create) Gets or creates count down latch.
void	onEntryUpdated(K key, boolean rmv) Entry update callback.
protected void	onKernalStart0()
protected void	onKernalStop0(boolean cancel)
void	onPartitionEvicted(int part) Partition evicted callback.
void	onTxCommitted(GridCacheTxEx<K,V> tx) Transaction committed callback for transaction manager.
void	printMemoryStats() Prints memory statistics (sizes of internal data structures, etc.).
<T> GridCacheQueue<T>	queue(String name, int cap, boolean colloc, boolean create) Gets a queue from cache or creates one if it's not cached.
boolean	removeAtomicLong(String name) Removes atomic long from cache.
boolean	removeAtomicReference(String name) Removes atomic reference from cache.
boolean	removeAtomicStamped(String name) Removes atomic stamped from cache.
boolean	removeCountDownLatch(String name) Removes count down latch from cache.
boolean	removeQueue(String name, int batchSize) Removes queue from cache.
boolean	removeSequence(String name) Removes sequence from cache.
boolean	removeSet(String name) Removes set.
GridCacheAtomicSequence	sequence(String name, long initVal, boolean create) Gets a sequence from cache or creates one if it's not cached.
<T> GridCacheSet<T>	set(String name, boolean collocated, boolean create) Gets a set from cache or creates one if it's not cached.
GridConcurrentHashSet<GridCacheSetItemKey>	setData(GridUuid id)

Methods inherited from class org.gridgain.grid.kernal.processors.cache.GridCacheManagerAdapter

context, kernalStartInfo, kernalStopInfo, log, onKernalStart, onKernalStop, start, start0, startInfo, stop, stop0, stopInfo, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

GridCacheDataStructuresManager

public GridCacheDataStructuresManager()

Default constructor.

Method Detail

onKernalStart0

protected void onKernalStart0()

Overrides:

onKernalStart0 in class GridCacheManagerAdapter<K,V>

onKernalStop0

protected void onKernalStop0(boolean cancel)

Overrides:

onKernalStop0 in class GridCacheManagerAdapter<K,V>

Parameters:

cancel - Cancel flag.

sequence

public final GridCacheAtomicSequence sequence(String name,
                               long initVal,
                               boolean create)
                                       throws GridException

Gets a sequence from cache or creates one if it's not cached.

Parameters:

name - Sequence name.

initVal - Initial value for sequence. If sequence already cached, initVal will be ignored.

create - If true sequence will be created in case it is not in cache.

Returns:

Sequence.

Throws:

GridException - If loading failed.

removeSequence

public final boolean removeSequence(String name)
                             throws GridException

Removes sequence from cache.

Parameters:

name - Sequence name.

Returns:

Method returns true if sequence has been removed and false if it's not cached.

Throws:

GridException - If removing failed.

atomicLong

public final GridCacheAtomicLong atomicLong(String name,
                             long initVal,
                             boolean create)
                                     throws GridException

Gets an atomic long from cache or creates one if it's not cached.

Parameters:

name - Name of atomic long.

initVal - Initial value for atomic long. If atomic long already cached, initVal will be ignored.

create - If true atomic long will be created in case it is not in cache.

Returns:

Atomic long.

Throws:

GridException - If loading failed.

removeAtomicLong

public final boolean removeAtomicLong(String name)
                               throws GridException

Removes atomic long from cache.

Parameters:

name - Atomic long name.

Returns:

Method returns true if atomic long has been removed and false if it's not cached.

Throws:

GridException - If removing failed.

atomicReference

public final <T> GridCacheAtomicReference<T> atomicReference(String name,
                                              T initVal,
                                              boolean create)
                                                  throws GridException

Gets an atomic reference from cache or creates one if it's not cached.

Parameters:

name - Name of atomic reference.

initVal - Initial value for atomic reference. If atomic reference already cached, initVal will be ignored.

create - If true atomic reference will be created in case it is not in cache.

Returns:

Atomic reference.

Throws:

GridException - If loading failed.

removeAtomicReference

public final boolean removeAtomicReference(String name)
                                    throws GridException

Removes atomic reference from cache.

Parameters:

name - Atomic reference name.

Returns:

Method returns true if atomic reference has been removed and false if it's not cached.

Throws:

GridException - If removing failed.

atomicStamped

public final <T,S> GridCacheAtomicStamped<T,S> atomicStamped(String name,
                                              T initVal,
                                              S initStamp,
                                              boolean create)
                                                throws GridException

Gets an atomic stamped from cache or creates one if it's not cached.

Parameters:

name - Name of atomic stamped.

initVal - Initial value for atomic stamped. If atomic stamped already cached, initVal will be ignored.

initStamp - Initial stamp for atomic stamped. If atomic stamped already cached, initStamp will be ignored.

create - If true atomic stamped will be created in case it is not in cache.

Returns:

Atomic stamped.

Throws:

GridException - If loading failed.

removeAtomicStamped

public final boolean removeAtomicStamped(String name)
                                  throws GridException

Removes atomic stamped from cache.

Parameters:

name - Atomic stamped name.

Returns:

Method returns true if atomic stamped has been removed and false if it's not cached.

Throws:

GridException - If removing failed.

queue

public final <T> GridCacheQueue<T> queue(String name,
                          int cap,
                          boolean colloc,
                          boolean create)
                              throws GridException

Gets a queue from cache or creates one if it's not cached.

Parameters:

name - Name of queue.

cap - Max size of queue.

colloc - Collocation flag.

create - If true queue will be created in case it is not in cache.

Returns:

Instance of queue.

Throws:

GridException - If failed.

removeQueue

public final boolean removeQueue(String name,
                  int batchSize)
                          throws GridException

Removes queue from cache.

Parameters:

name - Queue name.

batchSize - Batch size.

Returns:

Method returns true if queue has been removed and false if it's not cached.

Throws:

GridException - If removing failed.

countDownLatch

public GridCacheCountDownLatch countDownLatch(String name,
                                     int cnt,
                                     boolean autoDel,
                                     boolean create)
                                       throws GridException

Gets or creates count down latch. If count down latch is not found in cache, it is created using provided name and count parameter.

Parameters:

name - Name of the latch.

cnt - Initial count.

autoDel - True to automatically delete latch from cache when its count reaches zero.

create - If true latch will be created in case it is not in cache, if it is false all parameters except name are ignored.

Returns:

Count down latch for the given name or null if it is not found and create is false.

Throws:

GridException - If operation failed.

removeCountDownLatch

public boolean removeCountDownLatch(String name)
                             throws GridException

Removes count down latch from cache.

Parameters:

name - Name of the latch.

Returns:

Count down latch for the given name.

Throws:

GridException - If operation failed.

onTxCommitted

public void onTxCommitted(GridCacheTxEx<K,V> tx)

Transaction committed callback for transaction manager.

Parameters:

tx - Committed transaction.

set

@Nullable
public <T> GridCacheSet<T> set(String name,
                               boolean collocated,
                               boolean create)
                    throws GridException

Gets a set from cache or creates one if it's not cached.

Parameters:

name - Set name.

collocated - Collocation flag.

create - If true set will be created in case it is not in cache.

Returns:

Set instance.

Throws:

GridException - If failed.

removeSet

public boolean removeSet(String name)
                  throws GridException

Removes set.

Parameters:

name - Set name.

Returns:

True if set was removed.

Throws:

GridException - If failed.

onEntryUpdated

public void onEntryUpdated(K key,
                  boolean rmv)

Entry update callback.

Parameters:

key - Key.

rmv - True if entry was removed.

onPartitionEvicted

public void onPartitionEvicted(int part)

Partition evicted callback.

Parameters:

part - Partition number.

setData

@Nullable
public GridConcurrentHashSet<GridCacheSetItemKey> setData(GridUuid id)

Parameters:

id - Set ID.

Returns:

Data for given set.

printMemoryStats

public void printMemoryStats()

Prints memory statistics (sizes of internal data structures, etc.). NOTE: this method is for testing and profiling purposes only.

Specified by:

printMemoryStats in interface GridCacheManager<K,V>

Overrides:

printMemoryStats in class GridCacheManagerAdapter<K,V>