org.gridgain.grid.kernal.processors.cache.distributed

Class GridDistributedCacheAdapter<K,V>

java.lang.Object

org.gridgain.grid.util.lang.GridMetadataAwareAdapter

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

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

All Implemented Interfaces:

Externalizable, Serializable, Iterable<GridCacheEntry<K,V>>, GridCache<K,V>, GridCacheProjection<K,V>, GridMetadataAware, GridCacheProjectionEx<K,V>

Direct Known Subclasses:

GridDhtCacheAdapter, GridNearCacheAdapter

public abstract class GridDistributedCacheAdapter<K,V>
extends GridCacheAdapter<K,V>

Distributed cache implementation.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.gridgain.grid.kernal.processors.cache.GridCacheAdapter

GridCacheAdapter.AsyncOp<T>, GridCacheAdapter.FutureHolder

Field Summary

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

afterPessimisticUnlock, beforePessimisticLock, cacheCfg, CLEAR_ALL_SPLIT_THRESHOLD, ctx, gridCfg, lastFut, locNodeId, log, map, metrics

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	GridDistributedCacheAdapter() Empty constructor required by Externalizable.
protected	GridDistributedCacheAdapter(GridCacheContext<K,V> ctx, GridCacheConcurrentMap<K,V> map)
protected	GridDistributedCacheAdapter(GridCacheContext<K,V> ctx, int startSize)

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract GridFuture<Boolean>	lockAllAsync(Collection<? extends K> keys, long timeout, GridCacheTxLocalEx<K,V> tx, boolean isInvalidate, boolean isRead, boolean retval, GridCacheTxIsolation isolation, GridPredicate<GridCacheEntry<K,V>>[] filter)
GridFuture<Boolean>	lockAllAsync(Collection<? extends K> keys, long timeout, GridPredicate<GridCacheEntry<K,V>>... filter) All or nothing synchronous lock for passed in keys.
void	removeVersionedEntry(K key, GridCacheVersion ver)
String	toString()
GridFuture<Boolean>	txLockAsync(Collection<? extends K> keys, long timeout, GridCacheTxLocalEx<K,V> tx, boolean isRead, boolean retval, GridCacheTxIsolation isolation, boolean isInvalidate, GridPredicate<GridCacheEntry<K,V>>[] filter)

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

affinity, afterPessimisticUnlock, afterPessimisticUnlock, allEntries, asyncOp, asyncOpAcquire, asyncOpRelease, beforePessimisticLock, beforePessimisticLock, cache, checkJta, clear, clear0, clearAll, clearAll, clearAll0, compact, compact, compactAll, compactAll, configuration, containsAllKeys, containsAllValues, containsAnyKeys, containsAnyValues, containsKey, containsKey, containsValue, containsValue, context, dataStructures, dgc, dgc, drBackupQueueSize, drListStateTransfers, drPause, drPauseState, drResume, drStateTransfer, entries, entry, entryEx, entryEx, entryEx, entryExSafe, entrySet, entrySet, entrySet, entrySet, entrySetx, evict, evict, evictAll, evictAll, evictAll, flags, flagsOff, flagsOn, forAll, forceRepartition, forEach, forSubjectId, get, get, get, getAll, getAll, getAllAsync, getAllAsync, getAllAsync, getAllAsync, getAllOutTx, getAllOutTxAsync, getAsync, getAsync, getForcePrimary, getForcePrimaryAsync, ggfsDataSpaceMax, ggfsDataSpaceUsed, globalClearAll, gridProjection, init, isColocated, isDht, isDhtAtomic, isDrSystemCache, isEmpty, isGgfsDataCache, isLocal, isLocked, isLockedByThread, isMongoDataCache, isMongoMetaCache, isNear, iterator, keySet, keySet, loadCache, loadCacheAsync, lock, lockAll, lockAsync, log, map, metrics, metrics0, name, nearSize, newTx, offHeapAllocatedSize, offHeapEntriesCount, offHeapIterator, onDeferredDelete, onGgfsDataSizeChanged, onKernalStart, onKernalStop, onUndeploy, overflowSize, peek, peek, peek, peek0, peek0, peek0, peekAll, peekAll0, peekAll0, peekEx, predicate, preloader, primaryEntrySet, primaryEntrySet, primaryKeySet, primaryKeySet, primarySize, primaryValues, primaryValues, printMemoryStats, processCheckCommittedTxRequest, processCheckCommittedTxResponse, processCheckPreparedTxRequest, processCheckPreparedTxResponse, projection, projection, projection, promote, promoteAll, put, put, putAll, putAllAsync, putAllDr, putAllDrAsync, putAsync, putAsync, putIfAbsent, putIfAbsentAsync, putx, putx, putxAsync, putxAsync, putxIfAbsent, putxIfAbsentAsync, queries, randomEntry, readExternal, readResolve, readThroughAllAsync, reload, reload, reloadAll, reloadAll, reloadAll, reloadAll, reloadAll, reloadAllAsync, reloadAllAsync, reloadAllAsync, reloadAllAsync, reloadAllAsync, reloadAsync, reloadAsync, remove, remove, remove, removeAll, removeAll, removeAllAsync, removeAllAsync, removeAllDr, removeAllDrAsync, removeAsync, removeAsync, removeAsync, removeEntry, removeIfObsolete, removex, removex, removex, removexAsync, removexAsync, removexAsync, replace, replace, replaceAsync, replaceAsync, replacex, replacex, replacexAsync, replacexAsync, resetMetrics, saveFuture, size, splitClearAll, start, startInfo, stop, stopInfo, swapIterator, swapKeys, swapSize, toMap, transform, transformAll, transformAll, transformAllAsync, transformAllAsync, transformAndCompute, transformAsync, transformAsync, tx, txStart, txStart, txStart, txStartAffinity, txStartPartition, txSynchronizations, txSynchronize, txUnsynchronize, unlock, values, values, wrappers, writeExternal

Methods inherited from class org.gridgain.grid.util.lang.GridMetadataAwareAdapter

addMeta, addMetaIfAbsent, addMetaIfAbsent, allMeta, clone, copyMeta, copyMeta, hasMeta, hasMeta, meta, putMetaIfAbsent, putMetaIfAbsent, readExternalMeta, removeMeta, removeMeta, replaceMeta, writeExternalMeta

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.gridgain.grid.cache.GridCacheProjection

unlockAll

Methods inherited from interface org.gridgain.grid.GridMetadataAware

addMeta, addMetaIfAbsent, addMetaIfAbsent, allMeta, copyMeta, copyMeta, hasMeta, hasMeta, meta, putMetaIfAbsent, putMetaIfAbsent, removeMeta, removeMeta, replaceMeta

Constructor Detail

GridDistributedCacheAdapter

protected GridDistributedCacheAdapter()

Empty constructor required by Externalizable.

GridDistributedCacheAdapter

protected GridDistributedCacheAdapter(GridCacheContext<K,V> ctx,
                           int startSize)

Parameters:

ctx - Cache registry.

startSize - Start size.

GridDistributedCacheAdapter

protected GridDistributedCacheAdapter(GridCacheContext<K,V> ctx,
                           GridCacheConcurrentMap<K,V> map)

Parameters:

ctx - Cache context.

map - Cache map.

Method Detail

txLockAsync

public GridFuture<Boolean> txLockAsync(Collection<? extends K> keys,
                              long timeout,
                              GridCacheTxLocalEx<K,V> tx,
                              boolean isRead,
                              boolean retval,
                              GridCacheTxIsolation isolation,
                              boolean isInvalidate,
                              GridPredicate<GridCacheEntry<K,V>>[] filter)

Specified by:

txLockAsync in class GridCacheAdapter<K,V>

Parameters:

keys - Keys to lock.

timeout - Lock timeout.

tx - Transaction.

isRead - True for read operations.

retval - Flag to return value.

isolation - Transaction isolation.

isInvalidate - Invalidate flag.

filter - Optional filter.

Returns:

Locks future.

lockAllAsync

public GridFuture<Boolean> lockAllAsync(Collection<? extends K> keys,
                               long timeout,
                               GridPredicate<GridCacheEntry<K,V>>... filter)

All or nothing synchronous lock for passed in keys. This method together with filter check will be executed as one atomic operation. If at least one filter validation failed, no locks will be acquired.

Transactions

Locks are not transactional and should not be used from within transactions. If you do need explicit locking within transaction, then you should use GridCacheTxConcurrency.PESSIMISTIC concurrency control for transaction which will acquire explicit locks for relevant cache operations.

Cache Flags

This method is not available if any of the following flags are set on projection: GridCacheFlag.LOCAL, GridCacheFlag.READ.

Parameters:

keys - Keys to lock.

timeout - Timeout in milliseconds to wait for lock to be acquired ('0' for no expiration).

filter - Optional filter that needs to atomically pass in order for the locks to be acquired.

Returns:

Future for the collection of locks. The future will return true if all filters passed and locks were acquired before timeout has expired, false otherwise.

lockAllAsync

protected abstract GridFuture<Boolean> lockAllAsync(Collection<? extends K> keys,
                               long timeout,
                               @Nullable
                               GridCacheTxLocalEx<K,V> tx,
                               boolean isInvalidate,
                               boolean isRead,
                               boolean retval,
                               @Nullable
                               GridCacheTxIsolation isolation,
                               GridPredicate<GridCacheEntry<K,V>>[] filter)

Parameters:

keys - Keys to lock.

timeout - Timeout.

tx - Transaction

isInvalidate - Invalidation flag.

isRead - Indicates whether value is read or written.

retval - Flag to return value.

isolation - Transaction isolation.

filter - Optional filter.

Returns:

Future for locks.

removeVersionedEntry

public void removeVersionedEntry(K key,
                        GridCacheVersion ver)

Parameters:

key - Key to remove.

ver - Version to remove.

toString

public String toString()

Overrides:

toString in class GridCacheAdapter<K,V>