Uses of Class
org.gridgain.grid.kernal.processors.cache.GridCacheTxEntry

Packages that use GridCacheTxEntry

Package	Description
org.gridgain.grid.kernal.processors.cache
org.gridgain.grid.kernal.processors.cache.distributed
org.gridgain.grid.kernal.processors.cache.distributed.dht
org.gridgain.grid.kernal.processors.cache.distributed.dht.colocated
org.gridgain.grid.kernal.processors.cache.distributed.near

Uses of GridCacheTxEntry in org.gridgain.grid.kernal.processors.cache

Fields in org.gridgain.grid.kernal.processors.cache with type parameters of type GridCacheTxEntry

Modifier and Type	Field and Description
protected Map<K,GridCacheTxEntry<K,V>>	GridCacheTxLocalAdapter.txMap Per-transaction read map.

Methods in org.gridgain.grid.kernal.processors.cache that return GridCacheTxEntry

Modifier and Type	Method and Description
protected GridCacheTxEntry<K,V>	GridCacheTxLocalAdapter.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)
GridCacheTxEntry<K,V>	GridCacheTxEntry.cleanCopy(GridCacheContext<K,V> ctx)
GridCacheTxEntry<K,V>	GridCacheTxEx.entry(K key)
GridCacheTxEntry<K,V>	GridCacheTxLocalAdapter.entry(K key)
GridCacheTxEntry<K,V>	GridCacheTxMap.get(Object key)
GridCacheTxEntry<K,V>	GridCacheTxAdapter.groupLockEntry() This method uses unchecked assignment to cast group lock key entry to transaction generic signature.
GridCacheTxEntry<K,V>	GridCacheTxLocalEx.groupLockEntry()
GridCacheTxEntry<K,V>	GridCacheTxMap.remove(Object key)

Methods in org.gridgain.grid.kernal.processors.cache that return types with arguments of type GridCacheTxEntry

Modifier and Type	Method and Description
Collection<GridCacheTxEntry<K,V>>	GridCacheTxEx.allEntries()
Collection<GridCacheTxEntry<K,V>>	GridCacheTxLocalAdapter.allEntries()
Set<Map.Entry<K,GridCacheTxEntry<K,V>>>	GridCacheTxMap.entrySet()
Collection<GridCacheTxEntry<K,V>>	GridCacheTxAdapter.optimisticLockEntries() Gets a list of entries that needs to be locked on the next step of prepare stage of optimistic transaction.
Collection<GridCacheTxEntry<K,V>>	GridCacheTxEx.optimisticLockEntries() Gets a list of entries that needs to be locked on the next step of prepare stage of optimistic transaction.
Collection<GridCacheTxEntry<K,V>>	GridCacheTxEx.readEntries()
Collection<GridCacheTxEntry<K,V>>	GridCacheTxLocalAdapter.readEntries()
Map<K,GridCacheTxEntry<K,V>>	GridCacheTxEx.readMap()
Map<K,GridCacheTxEntry<K,V>>	GridCacheTxLocalAdapter.readMap()
static <K,V> GridPredicate<GridCacheTxEntry<K,V>>	GridCacheUtils.reads()
Collection<GridCacheTxEntry<K,V>>	GridCacheTxAdapter.recoveryWrites()
Collection<GridCacheTxEntry<K,V>>	GridCacheTxEx.recoveryWrites() Gets pessimistic recovery writes, i.e.
static <K,V> GridPredicate<GridCacheTxEntry<K,V>>	GridCacheUtils.transferRequired()
static <K,V> GridClosure<GridCacheTxEntry<K,V>,GridCacheEntryEx<K,V>>	GridCacheUtils.tx2entry()
static <K,V> GridClosure<GridCacheTxEntry<K,V>,K>	GridCacheUtils.tx2key()
static <K,V> GridClosure<GridCacheTxEntry<K,V>,byte[]>	GridCacheUtils.tx2keyBytes()
static <K,V> GridClosure<Collection<GridCacheTxEntry<K,V>>,Collection<K>>	GridCacheUtils.txCol2Key()
Collection<GridCacheTxEntry<K,V>>	GridCacheTxEx.writeEntries()
Collection<GridCacheTxEntry<K,V>>	GridCacheTxLocalAdapter.writeEntries()
Map<K,GridCacheTxEntry<K,V>>	GridCacheTxEx.writeMap()
Map<K,GridCacheTxEntry<K,V>>	GridCacheTxLocalAdapter.writeMap()
static <K,V> GridPredicate<GridCacheTxEntry<K,V>>	GridCacheUtils.writes()

Methods in org.gridgain.grid.kernal.processors.cache with parameters of type GridCacheTxEntry

Modifier and Type	Method and Description
protected GridTuple3<GridCacheOperation,V,byte[]>	GridCacheTxAdapter.applyTransformClosures(GridCacheTxEntry<K,V> txEntry, boolean metrics)
protected boolean	GridCacheTxAdapter.evictNearEntry(GridCacheTxEntry<K,V> e, boolean primaryOnly)
protected boolean	GridCacheTxAdapter.isNearLocallyMapped(GridCacheTxEntry<K,V> e, boolean primaryOnly)
boolean	GridCacheTxRemoteEx.setWriteValue(GridCacheTxEntry<K,V> e)
protected void	GridCacheTxLocalAdapter.updateExplicitVersion(GridCacheTxEntry<K,V> txEntry, GridCacheEntryEx<K,V> entry) Updates explicit version for tx entry based on current entry lock owner.

Method parameters in org.gridgain.grid.kernal.processors.cache with type arguments of type GridCacheTxEntry

Modifier and Type	Method and Description
protected void	GridCacheTxLocalAdapter.batchStoreCommit(Iterable<GridCacheTxEntry<K,V>> writeEntries) Performs batch database operations.
protected void	GridCacheMessage.marshalTx(Iterable<GridCacheTxEntry<K,V>> txEntries, GridCacheContext<K,V> ctx)
void	GridCacheTxAdapter.recoveryWrites(Collection<GridCacheTxEntry<K,V>> recoveryWrites)
protected void	GridCacheMessage.unmarshalTx(Iterable<GridCacheTxEntry<K,V>> txEntries, GridCacheContext<K,V> ctx, ClassLoader ldr)

Constructor parameters in org.gridgain.grid.kernal.processors.cache with type arguments of type GridCacheTxEntry

Constructor and Description
GridCacheTxMap(Map<K,GridCacheTxEntry<K,V>> txMap, GridPredicate<GridCacheTxEntry<K,V>> filter)
GridCacheTxMap(Map<K,GridCacheTxEntry<K,V>> txMap, GridPredicate<GridCacheTxEntry<K,V>> filter)

Uses of GridCacheTxEntry in org.gridgain.grid.kernal.processors.cache.distributed

Fields in org.gridgain.grid.kernal.processors.cache.distributed with type parameters of type GridCacheTxEntry

Modifier and Type	Field and Description
protected Map<K,GridCacheTxEntry<K,V>>	GridDistributedTxRemoteAdapter.readMap Read set.
protected Map<K,GridCacheTxEntry<K,V>>	GridDistributedTxRemoteAdapter.writeMap Write map.

Methods in org.gridgain.grid.kernal.processors.cache.distributed that return GridCacheTxEntry

Modifier and Type	Method and Description
GridCacheTxEntry<K,V>	GridDistributedTxRemoteAdapter.entry(K key)

Methods in org.gridgain.grid.kernal.processors.cache.distributed that return types with arguments of type GridCacheTxEntry

Modifier and Type	Method and Description
Collection<GridCacheTxEntry<K,V>>	GridDistributedTxRemoteAdapter.allEntries()
Collection<GridCacheTxEntry<K,V>>	GridDistributedTxMapping.entries()
Collection<GridCacheTxEntry<K,V>>	GridDistributedTxRemoteAdapter.readEntries()
Map<K,GridCacheTxEntry<K,V>>	GridDistributedTxRemoteAdapter.readMap()
Collection<GridCacheTxEntry<K,V>>	GridDistributedTxPrepareRequest.reads()
Collection<GridCacheTxEntry<K,V>>	GridDistributedTxMapping.reads()
Collection<GridCacheTxEntry<K,V>>	GridDistributedTxFinishRequest.recoveryWrites()
Collection<GridCacheTxEntry<K,V>>	GridCacheCommittedTxInfo.recoveryWrites()
List<GridCacheTxEntry<K,V>>	GridDistributedLockRequest.writeEntries()
Collection<GridCacheTxEntry<K,V>>	GridDistributedTxRemoteAdapter.writeEntries()
Map<K,GridCacheTxEntry<K,V>>	GridDistributedTxRemoteAdapter.writeMap()
Collection<GridCacheTxEntry<K,V>>	GridDistributedTxPrepareRequest.writes()
Collection<GridCacheTxEntry<K,V>>	GridDistributedTxFinishRequest.writes()
Collection<GridCacheTxEntry<K,V>>	GridDistributedTxMapping.writes()

Methods in org.gridgain.grid.kernal.processors.cache.distributed with parameters of type GridCacheTxEntry

Modifier and Type	Method and Description
void	GridDistributedTxMapping.add(GridCacheTxEntry<K,V> entry)
protected void	GridDistributedTxRemoteAdapter.addExplicit(GridCacheTxEntry<K,V> e) Adds explicit version if there is one.
void	GridDistributedLockRequest.addKeyBytes(K key, byte[] keyBytes, GridCacheTxEntry<K,V> writeEntry, boolean retVal, Collection<GridCacheMvccCandidate<K>> cands, GridCacheVersion drVer, GridCacheContext<K,V> ctx) Adds a key.
boolean	GridDistributedTxMapping.removeEntry(GridCacheTxEntry<K,V> entry)
boolean	GridDistributedTxRemoteAdapter.setWriteValue(GridCacheTxEntry<K,V> e)

Method parameters in org.gridgain.grid.kernal.processors.cache.distributed with type arguments of type GridCacheTxEntry

Modifier and Type	Method and Description
void	GridDistributedTxMapping.entries(Collection<GridCacheTxEntry<K,V>> entries, boolean readOnly)
protected void	GridDistributedTxPrepareRequest.reads(Collection<GridCacheTxEntry<K,V>> reads)
protected void	GridDistributedTxPrepareRequest.writes(Collection<GridCacheTxEntry<K,V>> writes)

Constructor parameters in org.gridgain.grid.kernal.processors.cache.distributed with type arguments of type GridCacheTxEntry

Constructor and Description
GridDistributedTxFinishRequest(GridCacheVersion xidVer, GridUuid futId, GridCacheVersion commitVer, long threadId, boolean commit, boolean invalidate, GridCacheVersion baseVer, Collection<GridCacheVersion> committedVers, Collection<GridCacheVersion> rolledbackVers, int txSize, Collection<GridCacheTxEntry<K,V>> writeEntries, Collection<GridCacheTxEntry<K,V>> recoveryWrites, boolean reply, Object grpLockKey)
GridDistributedTxFinishRequest(GridCacheVersion xidVer, GridUuid futId, GridCacheVersion commitVer, long threadId, boolean commit, boolean invalidate, GridCacheVersion baseVer, Collection<GridCacheVersion> committedVers, Collection<GridCacheVersion> rolledbackVers, int txSize, Collection<GridCacheTxEntry<K,V>> writeEntries, Collection<GridCacheTxEntry<K,V>> recoveryWrites, boolean reply, Object grpLockKey)
GridDistributedTxPrepareRequest(GridCacheTxEx<K,V> tx, Collection<GridCacheTxEntry<K,V>> reads, Collection<GridCacheTxEntry<K,V>> writes, Object grpLockKey, boolean partLock, Map<UUID,Collection<UUID>> txNodes)
GridDistributedTxPrepareRequest(GridCacheTxEx<K,V> tx, Collection<GridCacheTxEntry<K,V>> reads, Collection<GridCacheTxEntry<K,V>> writes, Object grpLockKey, boolean partLock, Map<UUID,Collection<UUID>> txNodes)

Uses of GridCacheTxEntry in org.gridgain.grid.kernal.processors.cache.distributed.dht

Methods in org.gridgain.grid.kernal.processors.cache.distributed.dht that return types with arguments of type GridCacheTxEntry

Modifier and Type	Method and Description
Collection<GridCacheTxEntry<K,V>>	GridDhtTxPrepareRequest.nearWrites()
Collection<GridCacheTxEntry<K,V>>	GridDhtTxFinishRequest.nearWrites()

Methods in org.gridgain.grid.kernal.processors.cache.distributed.dht with parameters of type GridCacheTxEntry

Modifier and Type	Method and Description
void	GridDhtLockRequest.addDhtKey(K key, byte[] keyBytes, GridCacheTxEntry<K,V> writeEntry, GridCacheVersion drVer, boolean invalidateEntry, GridCacheContext<K,V> ctx) Adds a DHT key.
GridFuture<Boolean>	GridDhtTxLocalAdapter.addEntry(long msgId, GridCacheTxEntry<K,V> e)
protected abstract GridFuture<Boolean>	GridDhtTxLocalAdapter.addReader(long msgId, GridDhtCacheEntry<K,V> cached, GridCacheTxEntry<K,V> entry, long topVer) Adds reader to cached entry.
protected GridFuture<Boolean>	GridDhtTxLocal.addReader(long msgId, GridDhtCacheEntry<K,V> cached, GridCacheTxEntry<K,V> entry, long topVer) Adds reader to cached entry.
protected void	GridDhtTxLocal.updateExplicitVersion(GridCacheTxEntry<K,V> txEntry, GridCacheEntryEx<K,V> entry) Updates explicit version for tx entry based on current entry lock owner.

Method parameters in org.gridgain.grid.kernal.processors.cache.distributed.dht with type arguments of type GridCacheTxEntry

Modifier and Type	Method and Description
protected void	GridDhtTransactionalCacheAdapter.finish(GridCacheContext<K,V> ctx, UUID nodeId, GridCacheTxRemoteEx<K,V> tx, GridDhtTxFinishRequest<K,V> req, Collection<GridCacheTxEntry<K,V>> writes)
void	GridDhtTxPrepareFuture.prepare(Iterable<GridCacheTxEntry<K,V>> reads, Iterable<GridCacheTxEntry<K,V>> writes, Map<UUID,Collection<UUID>> txNodes) Initializes future.
void	GridDhtTxPrepareFuture.prepare(Iterable<GridCacheTxEntry<K,V>> reads, Iterable<GridCacheTxEntry<K,V>> writes, Map<UUID,Collection<UUID>> txNodes) Initializes future.
GridFuture<GridCacheTxEx<K,V>>	GridDhtTxLocal.prepareAsync(Iterable<GridCacheTxEntry<K,V>> reads, Iterable<GridCacheTxEntry<K,V>> writes, Map<K,GridCacheVersion> verMap, long msgId, GridUuid nearMiniId, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups) Prepares next batch of entries in dht transaction.
GridFuture<GridCacheTxEx<K,V>>	GridDhtTxLocal.prepareAsync(Iterable<GridCacheTxEntry<K,V>> reads, Iterable<GridCacheTxEntry<K,V>> writes, Map<K,GridCacheVersion> verMap, long msgId, GridUuid nearMiniId, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups) Prepares next batch of entries in dht transaction.

Constructor parameters in org.gridgain.grid.kernal.processors.cache.distributed.dht with type arguments of type GridCacheTxEntry

Constructor and Description
GridDhtTxFinishRequest(UUID nearNodeId, GridUuid futId, GridUuid miniId, long topVer, GridCacheVersion xidVer, GridCacheVersion commitVer, long threadId, GridCacheTxIsolation isolation, boolean commit, boolean invalidate, boolean sysInvalidate, GridCacheVersion baseVer, Collection<GridCacheVersion> committedVers, Collection<GridCacheVersion> rolledbackVers, Collection<GridCacheVersion> pendingVers, int txSize, Collection<GridCacheTxEntry<K,V>> writes, Collection<GridCacheTxEntry<K,V>> nearWrites, Collection<GridCacheTxEntry<K,V>> recoverWrites, boolean reply, boolean onePhaseCommit, Object grpLockKey, UUID subjId)
GridDhtTxFinishRequest(UUID nearNodeId, GridUuid futId, GridUuid miniId, long topVer, GridCacheVersion xidVer, GridCacheVersion commitVer, long threadId, GridCacheTxIsolation isolation, boolean commit, boolean invalidate, boolean sysInvalidate, GridCacheVersion baseVer, Collection<GridCacheVersion> committedVers, Collection<GridCacheVersion> rolledbackVers, Collection<GridCacheVersion> pendingVers, int txSize, Collection<GridCacheTxEntry<K,V>> writes, Collection<GridCacheTxEntry<K,V>> nearWrites, Collection<GridCacheTxEntry<K,V>> recoverWrites, boolean reply, boolean onePhaseCommit, Object grpLockKey, UUID subjId)
GridDhtTxFinishRequest(UUID nearNodeId, GridUuid futId, GridUuid miniId, long topVer, GridCacheVersion xidVer, GridCacheVersion commitVer, long threadId, GridCacheTxIsolation isolation, boolean commit, boolean invalidate, boolean sysInvalidate, GridCacheVersion baseVer, Collection<GridCacheVersion> committedVers, Collection<GridCacheVersion> rolledbackVers, Collection<GridCacheVersion> pendingVers, int txSize, Collection<GridCacheTxEntry<K,V>> writes, Collection<GridCacheTxEntry<K,V>> nearWrites, Collection<GridCacheTxEntry<K,V>> recoverWrites, boolean reply, boolean onePhaseCommit, Object grpLockKey, UUID subjId)
GridDhtTxPrepareRequest(GridUuid futId, GridUuid miniId, long topVer, GridDhtTxLocalAdapter<K,V> tx, Collection<GridCacheTxEntry<K,V>> dhtWrites, Collection<GridCacheTxEntry<K,V>> nearWrites, Object grpLockKey, boolean partLock, Map<UUID,Collection<UUID>> txNodes, GridCacheVersion nearXidVer, boolean last, UUID subjId)
GridDhtTxPrepareRequest(GridUuid futId, GridUuid miniId, long topVer, GridDhtTxLocalAdapter<K,V> tx, Collection<GridCacheTxEntry<K,V>> dhtWrites, Collection<GridCacheTxEntry<K,V>> nearWrites, Object grpLockKey, boolean partLock, Map<UUID,Collection<UUID>> txNodes, GridCacheVersion nearXidVer, boolean last, UUID subjId)

Uses of GridCacheTxEntry in org.gridgain.grid.kernal.processors.cache.distributed.dht.colocated

Methods in org.gridgain.grid.kernal.processors.cache.distributed.dht.colocated that return types with arguments of type GridCacheTxEntry

Modifier and Type	Method and Description
Collection<GridCacheTxEntry<K,V>>	GridDhtColocatedTxLocal.optimisticLockEntries() Gets a list of entries that needs to be locked on the next step of prepare stage of optimistic transaction.
Collection<GridCacheTxEntry<K,V>>	GridDhtColocatedTxLocal.recoveryWrites() Gets pessimistic recovery writes, i.e.

Methods in org.gridgain.grid.kernal.processors.cache.distributed.dht.colocated with parameters of type GridCacheTxEntry

Modifier and Type	Method and Description
protected GridFuture<Boolean>	GridDhtColocatedTxLocal.addReader(long msgId, GridDhtCacheEntry<K,V> cached, GridCacheTxEntry<K,V> entry, long topVer) Adds reader to cached entry.
protected void	GridDhtColocatedTxLocal.updateExplicitVersion(GridCacheTxEntry<K,V> txEntry, GridCacheEntryEx<K,V> entry) Updates explicit version for tx entry based on current entry lock owner.

Method parameters in org.gridgain.grid.kernal.processors.cache.distributed.dht.colocated with type arguments of type GridCacheTxEntry

Modifier and Type	Method and Description
GridFuture<GridCacheTxEx<K,V>>	GridDhtColocatedTxLocal.prepareAsyncLocal(Collection<GridCacheTxEntry<K,V>> reads, Collection<GridCacheTxEntry<K,V>> writes, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups) Prepares next batch of entries in dht transaction.
GridFuture<GridCacheTxEx<K,V>>	GridDhtColocatedTxLocal.prepareAsyncLocal(Collection<GridCacheTxEntry<K,V>> reads, Collection<GridCacheTxEntry<K,V>> writes, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups) Prepares next batch of entries in dht transaction.
GridFuture<GridCacheTxEx<K,V>>	GridDhtColocatedCache.prepareTxLocally(GridDhtColocatedTxLocal<K,V> tx, Collection<GridCacheTxEntry<K,V>> reads, Collection<GridCacheTxEntry<K,V>> writes, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups)
GridFuture<GridCacheTxEx<K,V>>	GridDhtColocatedCache.prepareTxLocally(GridDhtColocatedTxLocal<K,V> tx, Collection<GridCacheTxEntry<K,V>> reads, Collection<GridCacheTxEntry<K,V>> writes, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups)

Uses of GridCacheTxEntry in org.gridgain.grid.kernal.processors.cache.distributed.near

Methods in org.gridgain.grid.kernal.processors.cache.distributed.near with parameters of type GridCacheTxEntry

Modifier and Type	Method and Description
void	GridNearLockRequest.addKeyBytes(K key, byte[] keyBytes, boolean retVal, GridCacheVersion dhtVer, GridCacheTxEntry<K,V> writeEntry, GridCacheVersion drVer, GridCacheContext<K,V> ctx) Adds a key.

Method parameters in org.gridgain.grid.kernal.processors.cache.distributed.near with type arguments of type GridCacheTxEntry

Modifier and Type	Method and Description
void	GridNearTxRemote.addEntries(ClassLoader ldr, Iterable<GridCacheTxEntry<K,V>> entries) Adds entries to started near remote tx.

Constructor parameters in org.gridgain.grid.kernal.processors.cache.distributed.near with type arguments of type GridCacheTxEntry

Constructor and Description
GridNearTxFinishRequest(GridUuid futId, GridCacheVersion xidVer, long threadId, boolean commit, boolean invalidate, boolean explicitLock, long topVer, GridCacheVersion baseVer, Collection<GridCacheVersion> committedVers, Collection<GridCacheVersion> rolledbackVers, int txSize, Collection<GridCacheTxEntry<K,V>> writeEntries, Collection<GridCacheTxEntry<K,V>> recoverEntries, boolean reply, UUID subjId)
GridNearTxFinishRequest(GridUuid futId, GridCacheVersion xidVer, long threadId, boolean commit, boolean invalidate, boolean explicitLock, long topVer, GridCacheVersion baseVer, Collection<GridCacheVersion> committedVers, Collection<GridCacheVersion> rolledbackVers, int txSize, Collection<GridCacheTxEntry<K,V>> writeEntries, Collection<GridCacheTxEntry<K,V>> recoverEntries, boolean reply, UUID subjId)
GridNearTxPrepareRequest(GridUuid futId, long topVer, GridCacheTxEx<K,V> tx, Collection<GridCacheTxEntry<K,V>> reads, Collection<GridCacheTxEntry<K,V>> writes, Object grpLockKey, boolean partLock, boolean syncCommit, boolean syncRollback, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups, UUID subjId)
GridNearTxPrepareRequest(GridUuid futId, long topVer, GridCacheTxEx<K,V> tx, Collection<GridCacheTxEntry<K,V>> reads, Collection<GridCacheTxEntry<K,V>> writes, Object grpLockKey, boolean partLock, boolean syncCommit, boolean syncRollback, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups, UUID subjId)
GridNearTxRemote(ClassLoader ldr, UUID nodeId, UUID nearNodeId, long rmtThreadId, GridCacheVersion xidVer, GridCacheVersion commitVer, GridCacheTxConcurrency concurrency, GridCacheTxIsolation isolation, boolean invalidate, long timeout, Collection<GridCacheTxEntry<K,V>> writeEntries, GridCacheContext<K,V> ctx, int txSize, Object grpLockKey, UUID subjId) This constructor is meant for optimistic transactions.