org.gridgain.grid.kernal.processors.cache

Class GridCacheTxLocalAdapter<K,V>

java.lang.Object

org.gridgain.grid.util.lang.GridMetadataAwareAdapter

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

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

All Implemented Interfaces:

Externalizable, Serializable, AutoCloseable, GridCacheTx, GridMetadataAware, GridCacheTxEx<K,V>, GridCacheTxLocalEx<K,V>, GridTimeoutObject

Direct Known Subclasses:

GridDhtTxLocalAdapter

public abstract class GridCacheTxLocalAdapter<K,V>
extends GridCacheTxAdapter<K,V>
implements GridCacheTxLocalEx<K,V>

Transaction adapter for cache transactions.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	GridCacheTxLocalAdapter.FinishClosure<T> Post-lock closure.
protected class	GridCacheTxLocalAdapter.PLC1<T> Post-lock closure alias.
protected class	GridCacheTxLocalAdapter.PLC2<T> Post-lock closure alias.
protected class	GridCacheTxLocalAdapter.PMC<T> Post-lock closure alias.
protected class	GridCacheTxLocalAdapter.PostLockClosure1<T> Post-lock closure.
protected class	GridCacheTxLocalAdapter.PostLockClosure2<T> Post-lock closure.
protected class	GridCacheTxLocalAdapter.PostMissClosure<T> Post-lock closure.

Nested classes/interfaces inherited from interface org.gridgain.grid.kernal.processors.cache.GridCacheTxEx

GridCacheTxEx.FinalizationStatus

Field Summary

Fields

Modifier and Type	Field and Description
protected AtomicReference<Throwable>	commitErr Commit error.
protected AtomicBoolean	doneFlag Flag indicating with TM commit happened.
protected GridCacheVersion	minVer Minimal version encountered (either explicit lock or XID of this transaction).
protected GridCacheTxMap<K,V>	readView Read view on transaction map.
protected Map<K,GridCacheTxEntry<K,V>>	txMap Per-transaction read map.
protected GridCacheTxMap<K,V>	writeView Write view on transaction map.

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

cctx, concurrency, endVer, grpLockKey, implicit, implicitSingle, internal, invalidate, isDone, isolation, loc, log, nodeId, onePhaseCommit, startTime, startVer, storeEnabled, subjId, swapOrOffheapEnabled, threadId, timeout, txSize, writeVer, xidVer

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	GridCacheTxLocalAdapter() Empty constructor required for Externalizable.
protected	GridCacheTxLocalAdapter(GridCacheContext<K,V> cctx, GridCacheVersion xidVer, boolean implicit, boolean implicitSingle, GridCacheTxConcurrency concurrency, GridCacheTxIsolation isolation, long timeout, boolean invalidate, boolean swapEnabled, boolean storeEnabled, int txSize, Object grpLockKey, boolean partLock, UUID subjId)

Method Summary

Methods

Modifier and Type	Method and Description
protected GridCacheTxEntry<K,V>	addEntry(GridCacheOperation op, V val, GridClosure<V,V> transformClos, GridCacheEntryEx<K,V> entry, long ttl, GridPredicate<GridCacheEntry<K,V>>[] filter, boolean filtersSet, long drTtl, long drExpireTime, GridCacheVersion drVer)
protected void	addGroupTxMapping(Collection<K> keys) Adds key mapping to transaction.
Collection<GridCacheTxEntry<K,V>>	allEntries()
Collection<GridCacheVersion>	alternateVersions()
protected void	batchStoreCommit(Iterable<GridCacheTxEntry<K,V>> writeEntries) Performs batch database operations.
protected void	checkValid(GridPredicate<GridCacheEntry<K,V>>[] filter) Checks transaction expiration.
void	commit() Commits this transaction by initiating two-phase-commit process.
protected boolean	commitAfterLock()
Throwable	commitError()
void	commitError(Throwable e)
Collection<GridCacheVersion>	committedVersions()
GridCacheVersion	completedBase()
void	completedVersions(GridCacheVersion completedBase, Collection<GridCacheVersion> committedVers, Collection<GridCacheVersion> rolledbackVers)
boolean	empty()
protected GridFuture<Set<K>>	enlistWrite(Collection<? extends K> keys, GridCacheEntryEx<K,V> cached, long ttl, boolean implicit, Map<? extends K,? extends V> lookup, Map<? extends K,? extends GridClosure<V,V>> transformMap, boolean retval, boolean lockOnly, GridPredicate<GridCacheEntry<K,V>>[] filter, GridCacheReturn<V> ret, Collection<K> enlisted, Map<? extends K,GridCacheDrInfo<V>> drPutMap, Map<? extends K,GridCacheVersion> drRmvMap) Internal routine for putAll(..)
GridCacheTxEntry<K,V>	entry(K key)
protected GridCacheEntryEx<K,V>	entryEx(K key) Gets cache entry for given key.
protected GridCacheEntryEx<K,V>	entryEx(K key, long topVer) Gets cache entry for given key and topology version.
UUID	eventNodeId()
GridFuture<Map<K,V>>	getAllAsync(Collection<? extends K> keys, GridCacheEntryEx<K,V> cached, GridPredicate<GridCacheEntry<K,V>>[] filter)
GridFuture<?>	groupLockAsync(Collection<K> keys) Performs keys locking for affinity-based group lock transactions.
boolean	hasReadKey(K key)
boolean	hasWriteKey(K key)
boolean	init() Initializes read map.
protected boolean	isBatchUpdate()
protected boolean	isSingleUpdate()
boolean	isStarted()
GridFuture<Boolean>	loadMissing(boolean async, Collection<? extends K> keys, GridBiInClosure<K,V> c)
Collection<UUID>	masterNodeIds()
GridCacheVersion	minVersion() Gets minimum version present in transaction.
boolean	onOwnerChanged(GridCacheEntryEx<K,V> entry, GridCacheMvccCandidate<K> owner) Callback invoked whenever there is a lock that has been acquired by this transaction for any of the participating entries.
UUID	originatingNodeId() Gets node ID which directly started this transaction.
boolean	partitionLock()
GridTuple<V>	peek(boolean failFast, K key, GridPredicate<GridCacheEntry<K,V>>[] filter)
protected Set<K>	postLockWrite(Iterable<? extends K> keys, Set<K> failed, Map<K,V> transformed, Map<? extends K,? extends GridClosure<V,V>> transformMap, GridCacheReturn<V> ret, boolean rmv, boolean retval, GridPredicate<GridCacheEntry<K,V>>[] filter) Post lock processing for put or remove.
void	prepare() Prepare state.
V	put(K key, V val, GridCacheEntryEx<K,V> cached, long ttl, GridPredicate<GridCacheEntry<K,V>>[] filter)
GridCacheReturn<V>	putAll(Map<? extends K,? extends V> map, GridPredicate<GridCacheEntry<K,V>>[] filter)
GridFuture<GridCacheReturn<V>>	putAllAsync(Map<? extends K,? extends V> map, boolean retval, GridCacheEntryEx<K,V> cached, long ttl, GridPredicate<GridCacheEntry<K,V>>[] filter)
void	putAllDr(Map<? extends K,GridCacheDrInfo<V>> drMap)
GridFuture<?>	putAllDrAsync(Map<? extends K,GridCacheDrInfo<V>> drMap)
GridFuture<V>	putAsync(K key, V val, GridCacheEntryEx<K,V> cached, long ttl, GridPredicate<GridCacheEntry<K,V>>[] filter)
GridFuture<V>	putAsync(K key, V val, GridPredicate<GridCacheEntry<K,V>>[] filter)
boolean	putx(K key, V val, GridCacheEntryEx<K,V> cached, long ttl, GridPredicate<GridCacheEntry<K,V>>[] filter)
boolean	putx(K key, V val, GridPredicate<GridCacheEntry<K,V>>[] filter)
GridFuture<Boolean>	putxAsync(K key, V val, GridCacheEntryEx<K,V> cached, long ttl, GridPredicate<GridCacheEntry<K,V>>[] filter)
GridFuture<Boolean>	putxAsync(K key, V val, GridPredicate<GridCacheEntry<K,V>>[] filter)
GridFuture<GridCacheReturn<V>>	putxAsync0(K key, V val, GridCacheEntryEx<K,V> cached, long ttl, GridPredicate<GridCacheEntry<K,V>>[] filter)
Collection<GridCacheTxEntry<K,V>>	readEntries()
Map<K,GridCacheTxEntry<K,V>>	readMap()
Set<K>	readSet()
V	remove(K key, GridCacheEntryEx<K,V> cached, GridPredicate<GridCacheEntry<K,V>>[] filter)
GridCacheReturn<V>	removeAll(Collection<? extends K> keys, GridPredicate<GridCacheEntry<K,V>>[] filter)
GridFuture<GridCacheReturn<V>>	removeAllAsync(Collection<? extends K> keys, GridCacheEntryEx<K,V> cached, boolean implicit, boolean retval, GridPredicate<GridCacheEntry<K,V>>[] filter)
void	removeAllDr(Map<? extends K,GridCacheVersion> drMap)
GridFuture<?>	removeAllDrAsync(Map<? extends K,GridCacheVersion> drMap)
GridFuture<V>	removeAsync(K key, GridCacheEntryEx<K,V> cached, GridPredicate<GridCacheEntry<K,V>>[] filter) Asynchronous remove.
boolean	removed(K key) Checks whether given key has been removed within transaction.
boolean	removex(K key, GridCacheEntryEx<K,V> cached, GridPredicate<GridCacheEntry<K,V>>[] filter)
GridFuture<Boolean>	removexAsync(K key, GridCacheEntryEx<K,V> cached, GridPredicate<GridCacheEntry<K,V>>[] filter) Asynchronous remove.
GridFuture<GridCacheReturn<V>>	removexAsync0(K key, GridCacheEntryEx<K,V> cached, GridPredicate<GridCacheEntry<K,V>>[] filter) Asynchronous remove.
Collection<GridCacheVersion>	rolledbackVersions()
void	seal() Seals transaction for updates.
void	sendTransformedValues(boolean snd)
void	tmCommit() Commits transaction to transaction manager.
String	toString()
boolean	transform(K key, GridClosure<V,V> transformer)
void	transformAll(Map<? extends K,? extends GridClosure<V,V>> map)
GridFuture<?>	transformAllAsync(Map<? extends K,? extends GridClosure<V,V>> map)
GridFuture<Boolean>	transformAsync(K key, GridClosure<V,V> transformer, GridCacheEntryEx<K,V> cached, long ttl)
<R> R	transformCompute(K key, GridClosure<V,GridBiTuple<V,R>> transformer)
protected void	updateExplicitVersion(GridCacheTxEntry<K,V> txEntry, GridCacheEntryEx<K,V> entry) Updates explicit version for tx entry based on current entry lock owner.
void	userCommit()
protected void	userPrepare()
void	userRollback()
Collection<GridCacheTxEntry<K,V>>	writeEntries()
Map<K,GridCacheTxEntry<K,V>>	writeMap()
Set<K>	writeSet()

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

addInvalidPartition, applyTransformClosures, awaitCompletion, awaitSignal, awaitSignal, checkInternal, close, colocated, commitVersion, commitVersion, concurrency, dht, done, drResolveConflict, endTime, endVersion, endVersion, enforceSerializable, equals, evictNearEntry, finalizationStatus, finishFuture, groupLock, groupLockEntry, groupLockKey, hashCode, implicit, implicitSingle, initCommitVersion, internal, invalidate, invalidPartitions, isInvalidate, isNearLocallyMapped, isolation, isRollbackOnly, isSystemInvalidate, local, lock, lockTimeout, log, markFinalizing, markPreparing, near, nearXidVersion, needsCompletedVersions, nodeId, onePhaseCommit, onePhaseCommit, onTimeout, optimistic, optimisticLockEntries, otherNodeId, ownedVersion, ownsLock, ownsLockUnsafe, pessimistic, readCommitted, readExternal, readResolve, recoveryWrites, recoveryWrites, remainingTime, repeatableRead, replicated, serializable, setRollbackOnly, signalAll, size, startTime, startVersion, state, state, subjectId, syncCommit, syncRollback, systemInvalidate, threadId, timedOut, timeout, timeout, timeoutId, topologyVersion, topologyVersion, transactionNodes, unlock, updateNearCache, user, writeExternal, writeVersion, writeVersion, xid, xidVersion

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

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.gridgain.grid.kernal.processors.cache.GridCacheTxLocalEx

finish, future, groupLockEntry

Methods inherited from interface org.gridgain.grid.kernal.processors.cache.GridCacheTxEx

addInvalidPartition, addLocalCandidates, colocated, commitVersion, commitVersion, dht, done, endVersion, endVersion, enforceSerializable, finishFuture, groupLock, groupLockKey, implicitSingle, internal, invalidate, invalidPartitions, isSystemInvalidate, local, localCandidates, markFinalizing, markPreparing, near, nearXidVersion, needsCompletedVersions, onePhaseCommit, optimistic, optimisticLockEntries, otherNodeId, ownedVersion, ownsLock, ownsLockUnsafe, pessimistic, prepareAsync, readCommitted, recoveryWrites, remainingTime, repeatableRead, replicated, rollbackAsync, serializable, size, startVersion, state, subjectId, syncCommit, syncRollback, systemInvalidate, timedOut, topologyVersion, topologyVersion, transactionNodes, user, writeVersion, writeVersion, xidVersion

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

close, commitAsync, concurrency, implicit, isInvalidate, isolation, isRollbackOnly, nodeId, rollback, setRollbackOnly, startTime, state, threadId, timeout, timeout, xid

Methods inherited from interface org.gridgain.grid.GridMetadataAware

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

Methods inherited from interface org.gridgain.grid.kernal.processors.timeout.GridTimeoutObject

endTime, onTimeout, timeoutId

Field Detail

txMap

@GridToStringExclude
protected Map<K,GridCacheTxEntry<K,V>> txMap

Per-transaction read map.

readView

@GridToStringExclude
protected GridCacheTxMap<K,V> readView

Read view on transaction map.

writeView

@GridToStringExclude
protected GridCacheTxMap<K,V> writeView

Write view on transaction map.

minVer

protected GridCacheVersion minVer

Minimal version encountered (either explicit lock or XID of this transaction).

doneFlag

protected AtomicBoolean doneFlag

Flag indicating with TM commit happened.

commitErr

protected AtomicReference<Throwable> commitErr

Commit error.

Constructor Detail

GridCacheTxLocalAdapter

protected GridCacheTxLocalAdapter()

Empty constructor required for Externalizable.

GridCacheTxLocalAdapter

protected GridCacheTxLocalAdapter(GridCacheContext<K,V> cctx,
                       GridCacheVersion xidVer,
                       boolean implicit,
                       boolean implicitSingle,
                       GridCacheTxConcurrency concurrency,
                       GridCacheTxIsolation isolation,
                       long timeout,
                       boolean invalidate,
                       boolean swapEnabled,
                       boolean storeEnabled,
                       int txSize,
                       @Nullable
                       Object grpLockKey,
                       boolean partLock,
                       @Nullable
                       UUID subjId)

Parameters:

cctx - Cache registry.

xidVer - Transaction ID.

implicit - True if transaction was implicitly started by the system, false if it was started explicitly by user.

implicitSingle - True if transaction is implicit with only one key.

concurrency - Concurrency.

isolation - Isolation.

timeout - Timeout.

invalidate - Invalidation policy.

swapEnabled - Whether to use swap storage.

storeEnabled - Whether to use read/write through.

txSize - Expected transaction size.

grpLockKey - Group lock key if this is a group-lock transaction.

partLock - True if this is a group-lock transaction and lock is acquired for whole partition.

Method Detail

eventNodeId

public UUID eventNodeId()

Specified by:

eventNodeId in interface GridCacheTxEx<K,V>

Returns:

Event node ID.

originatingNodeId

public UUID originatingNodeId()

Gets node ID which directly started this transaction. In case of DHT local transaction it will be near node ID, in case of DHT remote transaction it will be primary node ID, in case of replicated remote transaction it will be starter node ID.

Specified by:

originatingNodeId in interface GridCacheTxEx<K,V>

Returns:

Originating node ID.

empty

public boolean empty()

Specified by:

empty in interface GridCacheTxEx<K,V>

Returns:

True if transaction is empty.

masterNodeIds

public Collection<UUID> masterNodeIds()

Specified by:

masterNodeIds in interface GridCacheTxEx<K,V>

Returns:

Master node IDs.

partitionLock

public boolean partitionLock()

Specified by:

partitionLock in interface GridCacheTxLocalEx<K,V>

Returns:

True if keys from the same partition are allowed to be enlisted in group-lock transaction.

commitError

public Throwable commitError()

Specified by:

commitError in interface GridCacheTxLocalEx<K,V>

Returns:

Commit error.

commitError

public void commitError(Throwable e)

Specified by:

commitError in interface GridCacheTxLocalEx<K,V>

Parameters:

e - Commit error.

onOwnerChanged

public boolean onOwnerChanged(GridCacheEntryEx<K,V> entry,
                     GridCacheMvccCandidate<K> owner)

Callback invoked whenever there is a lock that has been acquired by this transaction for any of the participating entries.

Specified by:

onOwnerChanged in interface GridCacheTxEx<K,V>

Parameters:

entry - Cache entry.

owner - Lock candidate that won ownership of the lock.

Returns:

True if transaction cared about notification.

isStarted

public boolean isStarted()

Specified by:

isStarted in class GridCacheTxAdapter<K,V>

Returns:

True if transaction has at least one key enlisted.

hasReadKey

public boolean hasReadKey(K key)

Specified by:

hasReadKey in interface GridCacheTxEx<K,V>

Parameters:

key - Key to check.

Returns:

True if key is present.

hasWriteKey

public boolean hasWriteKey(K key)

Specified by:

hasWriteKey in interface GridCacheTxEx<K,V>

Parameters:

key - Key to check.

Returns:

True if key is present.

readSet

public Set<K> readSet()

Specified by:

readSet in interface GridCacheTxEx<K,V>

Returns:

Transaction read set.

writeSet

public Set<K> writeSet()

Specified by:

writeSet in interface GridCacheTxEx<K,V>

Returns:

Transaction write set.

removed

public boolean removed(K key)

Checks whether given key has been removed within transaction.

Specified by:

removed in interface GridCacheTxEx<K,V>

Parameters:

key - Key to check.

Returns:

True if key has been removed.

readMap

public Map<K,GridCacheTxEntry<K,V>> readMap()

Specified by:

readMap in interface GridCacheTxEx<K,V>

Returns:

Transaction read map.

writeMap

public Map<K,GridCacheTxEntry<K,V>> writeMap()

Specified by:

writeMap in interface GridCacheTxEx<K,V>

Returns:

Transaction write map.

allEntries

public Collection<GridCacheTxEntry<K,V>> allEntries()

Specified by:

allEntries in interface GridCacheTxEx<K,V>

Returns:

All transaction entries.

readEntries

public Collection<GridCacheTxEntry<K,V>> readEntries()

Specified by:

readEntries in interface GridCacheTxEx<K,V>

Returns:

Read entries.

writeEntries

public Collection<GridCacheTxEntry<K,V>> writeEntries()

Specified by:

writeEntries in interface GridCacheTxEx<K,V>

Returns:

Write entries.

entry

@Nullable
public GridCacheTxEntry<K,V> entry(K key)

Specified by:

entry in interface GridCacheTxEx<K,V>

Parameters:

key - Key for the entry.

Returns:

Entry for the key (either from write set or read set).

seal

public void seal()

Seals transaction for updates.

Specified by:

seal in interface GridCacheTxEx<K,V>

sendTransformedValues

public void sendTransformedValues(boolean snd)

Parameters:

snd - True if values in tx entries should be replaced with transformed values and sent to remote nodes.

commitAfterLock

protected boolean commitAfterLock()

Returns:

True if should be committed after lock is acquired.

peek

@Nullable
public GridTuple<V> peek(boolean failFast,
                         K key,
                         GridPredicate<GridCacheEntry<K,V>>[] filter)
                  throws GridCacheFilterFailedException

Specified by:

peek in interface GridCacheTxEx<K,V>

Parameters:

failFast - Fail-fast flag.

key - Key to look up.

filter - Filter to check.

Returns:

Current value for the key within transaction.

Throws:

GridCacheFilterFailedException - If filter failed and failFast is true.

loadMissing

public GridFuture<Boolean> loadMissing(boolean async,
                              Collection<? extends K> keys,
                              GridBiInClosure<K,V> c)

Specified by:

loadMissing in interface GridCacheTxLocalEx<K,V>

Parameters:

async - if True, then loading will happen in a separate thread.

keys - Keys.

c - Closure.

Returns:

Future with True value if loading took place.

minVersion

public GridCacheVersion minVersion()

Gets minimum version present in transaction.

Specified by:

minVersion in interface GridCacheTxLocalEx<K,V>

Returns:

Minimum versions.

userPrepare

protected void userPrepare()
                    throws GridException

Throws:

GridException - If prepare step failed.

commit

public void commit()
            throws GridException

Commits this transaction by initiating two-phase-commit process.

Specified by:

commit in interface GridCacheTx

Throws:

GridException - If commit failed.

prepare

public void prepare()
             throws GridException

Prepare state.

Specified by:

prepare in interface GridCacheTxEx<K,V>

Throws:

GridException - If failed.

entryEx

protected GridCacheEntryEx<K,V> entryEx(K key)

Gets cache entry for given key.

Parameters:

key - Key.

Returns:

Cache entry.

entryEx

protected GridCacheEntryEx<K,V> entryEx(K key,
                            long topVer)

Gets cache entry for given key and topology version.

Parameters:

key - Key.

topVer - Topology version.

Returns:

Cache entry.

batchStoreCommit

protected void batchStoreCommit(Iterable<GridCacheTxEntry<K,V>> writeEntries)
                         throws GridException

Performs batch database operations. This commit must be called before userCommit(). This way if there is a DB failure, cache transaction can still be rolled back.

Parameters:

writeEntries - Transaction write set.

Throws:

GridException - If batch update failed.

userCommit

public void userCommit()
                throws GridException

Specified by:

userCommit in interface GridCacheTxLocalEx<K,V>

Throws:

GridException - If commit failed.

tmCommit

public void tmCommit()

Commits transaction to transaction manager. Used for one-phase commit transactions only.

completedVersions

public void completedVersions(GridCacheVersion completedBase,
                     Collection<GridCacheVersion> committedVers,
                     Collection<GridCacheVersion> rolledbackVers)

Specified by:

completedVersions in interface GridCacheTxEx<K,V>

Overrides:

completedVersions in class GridCacheTxAdapter<K,V>

Parameters:

completedBase - Base for committed versions.

committedVers - Committed transactions relative to base.

rolledbackVers - Rolled back transactions relative to base.

completedBase

public GridCacheVersion completedBase()

Returns:

Completed base for ordering.

committedVersions

public Collection<GridCacheVersion> committedVersions()

Returns:

Committed versions.

rolledbackVersions

public Collection<GridCacheVersion> rolledbackVersions()

Returns:

Rolledback versions.

userRollback

public void userRollback()
                  throws GridException

Specified by:

userRollback in interface GridCacheTxLocalEx<K,V>

Throws:

GridException - If rollback failed.

getAllAsync

public GridFuture<Map<K,V>> getAllAsync(Collection<? extends K> keys,
                               @Nullable
                               GridCacheEntryEx<K,V> cached,
                               GridPredicate<GridCacheEntry<K,V>>[] filter)

Specified by:

getAllAsync in interface GridCacheTxLocalEx<K,V>

Parameters:

keys - Keys to get.

cached - Cached entry if this method is called from entry wrapper. Cached entry is passed if and only if there is only one key in collection of keys.

filter - Entry filter.

Returns:

Future for this get.

put

public V put(K key,
    V val,
    @Nullable
    GridCacheEntryEx<K,V> cached,
    long ttl,
    GridPredicate<GridCacheEntry<K,V>>[] filter)
      throws GridException

Specified by:

put in interface GridCacheTxLocalEx<K,V>

Parameters:

key - Key.

val - Value.

cached - Cached cache entry, if called from entry wrapper.

ttl - Entry time-to-live value. If negative, leave unchanged.

filter - Filter.

Returns:

Old value.

Throws:

GridException - If put failed.

putx

public boolean putx(K key,
           V val,
           GridPredicate<GridCacheEntry<K,V>>[] filter)
             throws GridException

Specified by:

putx in interface GridCacheTxLocalEx<K,V>

Parameters:

key - Key.

val - Value.

filter - Filter.

Returns:

True if put succeeded.

Throws:

GridException - If put failed.

putx

public boolean putx(K key,
           V val,
           @Nullable
           GridCacheEntryEx<K,V> cached,
           long ttl,
           GridPredicate<GridCacheEntry<K,V>>[] filter)
             throws GridException

Specified by:

putx in interface GridCacheTxLocalEx<K,V>

Parameters:

key - Key.

val - Value.

cached - Cached cache entry, if called from entry wrapper.

ttl - Time to live for entry. If negative, leave unchanged.

filter - Filter.

Returns:

True if put succeeded.

Throws:

GridException - If put failed.

putAll

public GridCacheReturn<V> putAll(Map<? extends K,? extends V> map,
                        GridPredicate<GridCacheEntry<K,V>>[] filter)
                          throws GridException

Specified by:

putAll in interface GridCacheTxLocalEx<K,V>

Parameters:

map - Map to put.

filter - Filter.

Returns:

Old value for the first key in the map.

Throws:

GridException - If put failed.

putAsync

public GridFuture<V> putAsync(K key,
                     V val,
                     GridPredicate<GridCacheEntry<K,V>>[] filter)

Specified by:

putAsync in interface GridCacheTxLocalEx<K,V>

Parameters:

key - Key.

val - Value.

filter - Filter.

Returns:

Value future.

putAsync

public GridFuture<V> putAsync(K key,
                     V val,
                     @Nullable
                     GridCacheEntryEx<K,V> cached,
                     long ttl,
                     GridPredicate<GridCacheEntry<K,V>>[] filter)

Specified by:

putAsync in interface GridCacheTxLocalEx<K,V>

Parameters:

key - Key.

val - Value.

cached - Optional cached cache entry.

ttl - Time to live for entry. If negative, leave unchanged.

filter - Filter.

Returns:

Value future.

putAllAsync

public GridFuture<GridCacheReturn<V>> putAllAsync(Map<? extends K,? extends V> map,
                                         boolean retval,
                                         @Nullable
                                         GridCacheEntryEx<K,V> cached,
                                         long ttl,
                                         GridPredicate<GridCacheEntry<K,V>>[] filter)

Specified by:

putAllAsync in interface GridCacheTxLocalEx<K,V>

Parameters:

map - Map to put.

retval - Flag indicating whether a value should be returned.

cached - Cached entry, if any. Will be provided only if map has size 1.

ttl - Time to live for entry. If negative, leave unchanged.

filter - Filter.

Returns:

Future all the put operation which will return value as if GridCacheTxLocalEx.put(Object, Object, GridCacheEntryEx, long, GridPredicate[]) was called.

putxAsync

public GridFuture<Boolean> putxAsync(K key,
                            V val,
                            GridPredicate<GridCacheEntry<K,V>>[] filter)

Specified by:

putxAsync in interface GridCacheTxLocalEx<K,V>

Parameters:

key - Key.

val - Value.

filter - Filter.

Returns:

Value future.

putxAsync

public GridFuture<Boolean> putxAsync(K key,
                            V val,
                            @Nullable
                            GridCacheEntryEx<K,V> cached,
                            long ttl,
                            GridPredicate<GridCacheEntry<K,V>>[] filter)

Specified by:

putxAsync in interface GridCacheTxLocalEx<K,V>

Parameters:

key - Key.

val - Value.

cached - Optional cached cache entry.

ttl - Time to live for entry. If negative, leave unchanged.

filter - Filter.

Returns:

Value future.

putxAsync0

public GridFuture<GridCacheReturn<V>> putxAsync0(K key,
                                        V val,
                                        @Nullable
                                        GridCacheEntryEx<K,V> cached,
                                        long ttl,
                                        GridPredicate<GridCacheEntry<K,V>>[] filter)

Specified by:

putxAsync0 in interface GridCacheTxLocalEx<K,V>

Parameters:

key - Key.

val - Value.

cached - Optional cached cache entry.

ttl - Time to live for entry. If negative, leave unchanged.

filter - Filter.

Returns:

Value future.

putAllDr

public void putAllDr(Map<? extends K,GridCacheDrInfo<V>> drMap)
              throws GridException

Specified by:

putAllDr in interface GridCacheTxLocalEx<K,V>

Parameters:

drMap - DR map to put.

Throws:

GridException - If put failed.

putAllDrAsync

public GridFuture<?> putAllDrAsync(Map<? extends K,GridCacheDrInfo<V>> drMap)

Specified by:

putAllDrAsync in interface GridCacheTxLocalEx<K,V>

Parameters:

drMap - DR map to put.

Returns:

Future all the put operation which will return value as if GridCacheTxLocalEx.put(Object, Object, GridCacheEntryEx, long, GridPredicate[]) was called.

transform

public boolean transform(K key,
                GridClosure<V,V> transformer)
                  throws GridException

Specified by:

transform in interface GridCacheTxLocalEx<K,V>

Parameters:

key - Key.

transformer - Value transform closure.

Returns:

True if put succeeded.

Throws:

GridException - If put failed.

transformCompute

public <R> R transformCompute(K key,
                     GridClosure<V,GridBiTuple<V,R>> transformer)
                   throws GridException

Specified by:

transformCompute in interface GridCacheTxLocalEx<K,V>

Parameters:

key - Key.

transformer - Closure.

Returns:

Value computed by the given closure.

Throws:

GridException - If failed.

transformAll

public void transformAll(@Nullable
                Map<? extends K,? extends GridClosure<V,V>> map)
                  throws GridException

Specified by:

transformAll in interface GridCacheTxLocalEx<K,V>

Parameters:

map - Map to put.

Throws:

GridException - If put failed.

transformAsync

public GridFuture<Boolean> transformAsync(K key,
                                 GridClosure<V,V> transformer,
                                 @Nullable
                                 GridCacheEntryEx<K,V> cached,
                                 long ttl)

Specified by:

transformAsync in interface GridCacheTxLocalEx<K,V>

Parameters:

key - Key.

transformer - Value transform closure.

cached - Cached entry, if called from entry wrapper.

ttl - Entry time-to-live value. If negative, leave unchanged.

Returns:

Transform operation future.

transformAllAsync

public GridFuture<?> transformAllAsync(@Nullable
                              Map<? extends K,? extends GridClosure<V,V>> map)

Specified by:

transformAllAsync in interface GridCacheTxLocalEx<K,V>

Parameters:

map - Map to put.

Returns:

Transform operation future.

remove

public V remove(K key,
       @Nullable
       GridCacheEntryEx<K,V> cached,
       GridPredicate<GridCacheEntry<K,V>>[] filter)
         throws GridException

Specified by:

remove in interface GridCacheTxLocalEx<K,V>

Parameters:

key - Key.

cached - Cached entry, if any.

filter - Filter.

Returns:

Value.

Throws:

GridException - If remove failed.

removex

public boolean removex(K key,
              @Nullable
              GridCacheEntryEx<K,V> cached,
              GridPredicate<GridCacheEntry<K,V>>[] filter)
                throws GridException

Specified by:

removex in interface GridCacheTxLocalEx<K,V>

Parameters:

key - Key.

cached - Cached entry, if any.

filter - Filter.

Returns:

Value.

Throws:

GridException - If remove failed.

removeAll

public GridCacheReturn<V> removeAll(Collection<? extends K> keys,
                           GridPredicate<GridCacheEntry<K,V>>[] filter)
                             throws GridException

Specified by:

removeAll in interface GridCacheTxLocalEx<K,V>

Parameters:

keys - Keys to remove.

filter - Filter.

Returns:

Value of first removed key.

Throws:

GridException - If remove failed.

removeAsync

public GridFuture<V> removeAsync(K key,
                        @Nullable
                        GridCacheEntryEx<K,V> cached,
                        GridPredicate<GridCacheEntry<K,V>>[] filter)

Asynchronous remove.

Specified by:

removeAsync in interface GridCacheTxLocalEx<K,V>

Parameters:

key - Key to remove.

cached - Cached entry, if any.

filter - Filter.

Returns:

Removed value.

removexAsync

public GridFuture<Boolean> removexAsync(K key,
                               @Nullable
                               GridCacheEntryEx<K,V> cached,
                               GridPredicate<GridCacheEntry<K,V>>[] filter)

Asynchronous remove.

Specified by:

removexAsync in interface GridCacheTxLocalEx<K,V>

Parameters:

key - Key to remove.

cached - Cached entry, if any.

filter - Filter.

Returns:

Removed value.

removexAsync0

public GridFuture<GridCacheReturn<V>> removexAsync0(K key,
                                           @Nullable
                                           GridCacheEntryEx<K,V> cached,
                                           GridPredicate<GridCacheEntry<K,V>>[] filter)

Asynchronous remove.

Specified by:

removexAsync0 in interface GridCacheTxLocalEx<K,V>

Parameters:

key - Key to remove.

cached - Optional cached entry.

filter - Filter.

Returns:

Removed value.

removeAllDr

public void removeAllDr(Map<? extends K,GridCacheVersion> drMap)
                 throws GridException

Specified by:

removeAllDr in interface GridCacheTxLocalEx<K,V>

Parameters:

drMap - DR map.

Throws:

GridException - If remove failed.

removeAllDrAsync

public GridFuture<?> removeAllDrAsync(Map<? extends K,GridCacheVersion> drMap)

Specified by:

removeAllDrAsync in interface GridCacheTxLocalEx<K,V>

Parameters:

drMap - DR map.

Returns:

Future for asynchronous remove.

enlistWrite

protected GridFuture<Set<K>> enlistWrite(Collection<? extends K> keys,
                             @Nullable
                             GridCacheEntryEx<K,V> cached,
                             long ttl,
                             boolean implicit,
                             @Nullable
                             Map<? extends K,? extends V> lookup,
                             @Nullable
                             Map<? extends K,? extends GridClosure<V,V>> transformMap,
                             boolean retval,
                             boolean lockOnly,
                             GridPredicate<GridCacheEntry<K,V>>[] filter,
                             GridCacheReturn<V> ret,
                             Collection<K> enlisted,
                             @Nullable
                             Map<? extends K,GridCacheDrInfo<V>> drPutMap,
                             @Nullable
                             Map<? extends K,GridCacheVersion> drRmvMap)

Internal routine for putAll(..)

Parameters:

keys - Keys to enlist.

cached - Cached entry.

ttl - Time to live for entry. If negative, leave unchanged.

implicit - Implicit flag.

lookup - Value lookup map (null for remove).

transformMap - Map with transform closures if this is a transform operation.

retval - Flag indicating whether a value should be returned.

lockOnly - If true, then entry will be enlisted as noop.

filter - User filters.

ret - Return value.

enlisted - Collection of keys enlisted into this transaction.

drPutMap - DR put map (optional).

drRmvMap - DR remove map (optional).

Returns:

Future with skipped keys (the ones that didn't pass filter for pessimistic transactions).

postLockWrite

protected Set<K> postLockWrite(Iterable<? extends K> keys,
                   Set<K> failed,
                   @Nullable
                   Map<K,V> transformed,
                   @Nullable
                   Map<? extends K,? extends GridClosure<V,V>> transformMap,
                   GridCacheReturn<V> ret,
                   boolean rmv,
                   boolean retval,
                   GridPredicate<GridCacheEntry<K,V>>[] filter)
                        throws GridException

Post lock processing for put or remove.

Parameters:

keys - Keys.

failed - Collection of potentially failed keys (need to populate in this method).

transformed - Output map where transformed values will be placed.

transformMap - Transform map.

ret - Return value.

rmv - True if remove.

retval - Flag to return value or not.

filter - Filter to check entries.

Returns:

Failed keys.

Throws:

GridException - If error.

removeAllAsync

public GridFuture<GridCacheReturn<V>> removeAllAsync(Collection<? extends K> keys,
                                            @Nullable
                                            GridCacheEntryEx<K,V> cached,
                                            boolean implicit,
                                            boolean retval,
                                            GridPredicate<GridCacheEntry<K,V>>[] filter)

Specified by:

removeAllAsync in interface GridCacheTxLocalEx<K,V>

Parameters:

keys - Keys to remove.

cached - Cached entry, if any. Will be provided only if size of keys collection is 1.

implicit - Allows to externally control how transaction handles implicit flags.

retval - Flag indicating whether a value should be returned.

filter - Filter.

Returns:

Future for asynchronous remove.

addGroupTxMapping

protected void addGroupTxMapping(Collection<K> keys)

Adds key mapping to transaction.

Parameters:

keys - Keys to add.

groupLockAsync

public GridFuture<?> groupLockAsync(Collection<K> keys)

Performs keys locking for affinity-based group lock transactions.

Specified by:

groupLockAsync in interface GridCacheTxLocalEx<K,V>

Parameters:

keys - Keys to lock.

Returns:

Lock future.

init

public boolean init()

Initializes read map.

Returns:

True if transaction was successfully started.

checkValid

protected void checkValid(GridPredicate<GridCacheEntry<K,V>>[] filter)
                   throws GridException

Checks transaction expiration.

Parameters:

filter - Optional array of filters to check for optimistic transactions.

Throws:

GridException - If transaction failed.

alternateVersions

public Collection<GridCacheVersion> alternateVersions()

Specified by:

alternateVersions in interface GridCacheTxEx<K,V>

Returns:

Alternate transaction versions.

addEntry

protected final GridCacheTxEntry<K,V> addEntry(GridCacheOperation op,
                             @Nullable
                             V val,
                             @Nullable
                             GridClosure<V,V> transformClos,
                             GridCacheEntryEx<K,V> entry,
                             long ttl,
                             GridPredicate<GridCacheEntry<K,V>>[] filter,
                             boolean filtersSet,
                             long drTtl,
                             long drExpireTime,
                             @Nullable
                             GridCacheVersion drVer)

Parameters:

op - Cache operation.

val - Value.

ttl - Time to leave to set to tx entry. If null, leave unchanged.

transformClos - Transform closure.

entry - Cache entry.

filter - Filter.

filtersSet - True if filter should be marked as set.

drTtl - DR TTL (if any).

drExpireTime - DR expire time (if any).

drVer - DR version.

Returns:

Transaction entry.

updateExplicitVersion

protected void updateExplicitVersion(GridCacheTxEntry<K,V> txEntry,
                         GridCacheEntryEx<K,V> entry)
                              throws GridCacheEntryRemovedException

Updates explicit version for tx entry based on current entry lock owner.

Parameters:

txEntry - Tx entry to update.

entry - Entry.

Throws:

GridCacheEntryRemovedException - If entry was concurrently removed.

isBatchUpdate

protected boolean isBatchUpdate()

Returns:

True if updates should be batched up.

isSingleUpdate

protected boolean isSingleUpdate()

Returns:

True if updates should be done individually.

toString

public String toString()

Overrides:

toString in class GridCacheTxAdapter<K,V>