Uses of Class
org.apache.ignite.internal.processors.cache.transactions.IgniteTxEntry

Packages that use IgniteTxEntry

Package	Description
org.apache.ignite.internal.processors.cache
org.apache.ignite.internal.processors.cache.distributed
org.apache.ignite.internal.processors.cache.distributed.dht
org.apache.ignite.internal.processors.cache.distributed.near
org.apache.ignite.internal.processors.cache.transactions

Uses of IgniteTxEntry in org.apache.ignite.internal.processors.cache

Methods in org.apache.ignite.internal.processors.cache that return types with arguments of type IgniteTxEntry

Modifier and Type	Method and Description
static <K,V> IgnitePredicate<IgniteTxEntry<K,V>>	GridCacheUtils.reads()
static <K,V> IgniteClosure<IgniteTxEntry<K,V>,GridCacheEntryEx<K,V>>	GridCacheUtils.tx2entry()
static <K,V> IgniteClosure<IgniteTxEntry<K,V>,K>	GridCacheUtils.tx2key()
static <K,V> IgniteClosure<IgniteTxEntry<K,V>,byte[]>	GridCacheUtils.tx2keyBytes()
static <K,V> IgniteClosure<Collection<IgniteTxEntry<K,V>>,Collection<K>>	GridCacheUtils.txCol2Key()
static <K,V> IgnitePredicate<IgniteTxEntry<K,V>>	GridCacheUtils.writes()

Methods in org.apache.ignite.internal.processors.cache with parameters of type IgniteTxEntry

Modifier and Type	Method and Description
void	GridCacheEvictionManager.touch(IgniteTxEntry<K,V> txEntry, boolean loc)

Method parameters in org.apache.ignite.internal.processors.cache with type arguments of type IgniteTxEntry

Modifier and Type	Method and Description
protected void	GridCacheMessage.marshalTx(Iterable<IgniteTxEntry<K,V>> txEntries, GridCacheSharedContext<K,V> ctx)
protected void	GridCacheMessage.unmarshalTx(Iterable<IgniteTxEntry<K,V>> txEntries, boolean near, GridCacheSharedContext<K,V> ctx, ClassLoader ldr)

Uses of IgniteTxEntry in org.apache.ignite.internal.processors.cache.distributed

Fields in org.apache.ignite.internal.processors.cache.distributed with type parameters of type IgniteTxEntry

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

Methods in org.apache.ignite.internal.processors.cache.distributed that return IgniteTxEntry

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

Methods in org.apache.ignite.internal.processors.cache.distributed that return types with arguments of type IgniteTxEntry

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

Methods in org.apache.ignite.internal.processors.cache.distributed with parameters of type IgniteTxEntry

Modifier and Type	Method and Description
void	GridDistributedTxMapping.add(IgniteTxEntry<K,V> entry)
protected void	GridDistributedTxRemoteAdapter.addExplicit(IgniteTxEntry<K,V> e) Adds explicit version if there is one.
boolean	GridDistributedTxMapping.removeEntry(IgniteTxEntry<K,V> entry)
boolean	GridDistributedTxRemoteAdapter.setWriteValue(IgniteTxEntry<K,V> e)

Method parameters in org.apache.ignite.internal.processors.cache.distributed with type arguments of type IgniteTxEntry

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

Constructor parameters in org.apache.ignite.internal.processors.cache.distributed with type arguments of type IgniteTxEntry

Constructor and Description
GridDistributedTxPrepareRequest(IgniteInternalTx<K,V> tx, Collection<IgniteTxEntry<K,V>> reads, Collection<IgniteTxEntry<K,V>> writes, IgniteTxKey grpLockKey, boolean partLock, Map<UUID,Collection<UUID>> txNodes, boolean onePhaseCommit)
GridDistributedTxPrepareRequest(IgniteInternalTx<K,V> tx, Collection<IgniteTxEntry<K,V>> reads, Collection<IgniteTxEntry<K,V>> writes, IgniteTxKey grpLockKey, boolean partLock, Map<UUID,Collection<UUID>> txNodes, boolean onePhaseCommit)

Uses of IgniteTxEntry in org.apache.ignite.internal.processors.cache.distributed.dht

Methods in org.apache.ignite.internal.processors.cache.distributed.dht that return types with arguments of type IgniteTxEntry

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

Methods in org.apache.ignite.internal.processors.cache.distributed.dht with parameters of type IgniteTxEntry

Modifier and Type	Method and Description
IgniteInternalFuture<Boolean>	GridDhtTxLocalAdapter.addEntry(long msgId, IgniteTxEntry<K,V> e)
protected IgniteInternalFuture<Boolean>	GridDhtTxLocal.addReader(long msgId, GridDhtCacheEntry<K,V> cached, IgniteTxEntry<K,V> entry, long topVer) Adds reader to cached entry.
protected abstract IgniteInternalFuture<Boolean>	GridDhtTxLocalAdapter.addReader(long msgId, GridDhtCacheEntry<K,V> cached, IgniteTxEntry<K,V> entry, long topVer) Adds reader to cached entry.
void	GridDhtTxRemote.addWrite(IgniteTxEntry<K,V> entry, ClassLoader ldr)
protected void	GridDhtTxLocal.updateExplicitVersion(IgniteTxEntry<K,V> txEntry, GridCacheEntryEx<K,V> entry) Updates explicit version for tx entry based on current entry lock owner.

Method parameters in org.apache.ignite.internal.processors.cache.distributed.dht with type arguments of type IgniteTxEntry

Modifier and Type	Method and Description
void	GridDhtTxPrepareFuture.prepare(Iterable<IgniteTxEntry<K,V>> reads, Iterable<IgniteTxEntry<K,V>> writes, Map<UUID,Collection<UUID>> txNodes) Initializes future.
void	GridDhtTxPrepareFuture.prepare(Iterable<IgniteTxEntry<K,V>> reads, Iterable<IgniteTxEntry<K,V>> writes, Map<UUID,Collection<UUID>> txNodes) Initializes future.
IgniteInternalFuture<IgniteInternalTx<K,V>>	GridDhtTxLocal.prepareAsync(Iterable<IgniteTxEntry<K,V>> reads, Iterable<IgniteTxEntry<K,V>> writes, Map<IgniteTxKey<K>,GridCacheVersion> verMap, long msgId, IgniteUuid nearMiniId, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups, IgniteInClosure<GridNearTxPrepareResponse<K,V>> completeCb) Prepares next batch of entries in dht transaction.
IgniteInternalFuture<IgniteInternalTx<K,V>>	GridDhtTxLocal.prepareAsync(Iterable<IgniteTxEntry<K,V>> reads, Iterable<IgniteTxEntry<K,V>> writes, Map<IgniteTxKey<K>,GridCacheVersion> verMap, long msgId, IgniteUuid nearMiniId, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups, IgniteInClosure<GridNearTxPrepareResponse<K,V>> completeCb) Prepares next batch of entries in dht transaction.

Constructor parameters in org.apache.ignite.internal.processors.cache.distributed.dht with type arguments of type IgniteTxEntry

Constructor and Description
GridDhtTxPrepareRequest(IgniteUuid futId, IgniteUuid miniId, long topVer, GridDhtTxLocalAdapter<K,V> tx, Collection<IgniteTxEntry<K,V>> dhtWrites, Collection<IgniteTxEntry<K,V>> nearWrites, IgniteTxKey grpLockKey, boolean partLock, Map<UUID,Collection<UUID>> txNodes, GridCacheVersion nearXidVer, boolean last, boolean onePhaseCommit, UUID subjId, int taskNameHash)
GridDhtTxPrepareRequest(IgniteUuid futId, IgniteUuid miniId, long topVer, GridDhtTxLocalAdapter<K,V> tx, Collection<IgniteTxEntry<K,V>> dhtWrites, Collection<IgniteTxEntry<K,V>> nearWrites, IgniteTxKey grpLockKey, boolean partLock, Map<UUID,Collection<UUID>> txNodes, GridCacheVersion nearXidVer, boolean last, boolean onePhaseCommit, UUID subjId, int taskNameHash)

Uses of IgniteTxEntry in org.apache.ignite.internal.processors.cache.distributed.near

Methods in org.apache.ignite.internal.processors.cache.distributed.near that return types with arguments of type IgniteTxEntry

Modifier and Type	Method and Description
Collection<IgniteTxEntry<K,V>>	GridNearTxLocal.optimisticLockEntries() Gets a list of entries that needs to be locked on the next step of prepare stage of optimistic transaction.

Methods in org.apache.ignite.internal.processors.cache.distributed.near with parameters of type IgniteTxEntry

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

Method parameters in org.apache.ignite.internal.processors.cache.distributed.near with type arguments of type IgniteTxEntry

Modifier and Type	Method and Description
void	GridNearTxRemote.addEntries(ClassLoader ldr, Iterable<IgniteTxEntry<K,V>> entries) Adds entries to started near remote tx.
void	GridNearTxLocal.optimisticLockEntries(Collection<IgniteTxEntry<K,V>> optimisticLockEntries)
IgniteInternalFuture<IgniteInternalTx<K,V>>	GridNearTxLocal.prepareAsyncLocal(Collection<IgniteTxEntry<K,V>> reads, Collection<IgniteTxEntry<K,V>> writes, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups, IgniteInClosure<GridNearTxPrepareResponse<K,V>> completeCb) Prepares next batch of entries in dht transaction.
IgniteInternalFuture<IgniteInternalTx<K,V>>	GridNearTxLocal.prepareAsyncLocal(Collection<IgniteTxEntry<K,V>> reads, Collection<IgniteTxEntry<K,V>> writes, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups, IgniteInClosure<GridNearTxPrepareResponse<K,V>> completeCb) Prepares next batch of entries in dht transaction.

Constructor parameters in org.apache.ignite.internal.processors.cache.distributed.near with type arguments of type IgniteTxEntry

Constructor and Description
GridNearTxPrepareRequest(IgniteUuid futId, long topVer, IgniteInternalTx<K,V> tx, Collection<IgniteTxEntry<K,V>> reads, Collection<IgniteTxEntry<K,V>> writes, IgniteTxKey grpLockKey, boolean partLock, boolean near, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups, boolean onePhaseCommit, boolean retVal, boolean implicitSingle, UUID subjId, int taskNameHash)
GridNearTxPrepareRequest(IgniteUuid futId, long topVer, IgniteInternalTx<K,V> tx, Collection<IgniteTxEntry<K,V>> reads, Collection<IgniteTxEntry<K,V>> writes, IgniteTxKey grpLockKey, boolean partLock, boolean near, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups, boolean onePhaseCommit, boolean retVal, boolean implicitSingle, UUID subjId, int taskNameHash)
GridNearTxRemote(GridCacheSharedContext<K,V> ctx, ClassLoader ldr, UUID nodeId, UUID nearNodeId, long rmtThreadId, GridCacheVersion xidVer, GridCacheVersion commitVer, boolean sys, TransactionConcurrency concurrency, TransactionIsolation isolation, boolean invalidate, long timeout, Collection<IgniteTxEntry<K,V>> writeEntries, int txSize, IgniteTxKey grpLockKey, UUID subjId, int taskNameHash) This constructor is meant for optimistic transactions.

Uses of IgniteTxEntry in org.apache.ignite.internal.processors.cache.transactions

Fields in org.apache.ignite.internal.processors.cache.transactions with type parameters of type IgniteTxEntry

Modifier and Type	Field and Description
protected Map<IgniteTxKey<K>,IgniteTxEntry<K,V>>	IgniteTxLocalAdapter.txMap Per-transaction read map.

Methods in org.apache.ignite.internal.processors.cache.transactions that return IgniteTxEntry

Modifier and Type	Method and Description
protected IgniteTxEntry<K,V>	IgniteTxLocalAdapter.addEntry(GridCacheOperation op, V val, javax.cache.processor.EntryProcessor entryProcessor, Object[] invokeArgs, GridCacheEntryEx<K,V> entry, javax.cache.expiry.ExpiryPolicy expiryPlc, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter, boolean filtersSet, long drTtl, long drExpireTime, GridCacheVersion drVer)
IgniteTxEntry<K,V>	IgniteTxEntry.cleanCopy(GridCacheContext<K,V> ctx)
IgniteTxEntry<K,V>	IgniteInternalTx.entry(IgniteTxKey<K> key)
IgniteTxEntry<K,V>	IgniteTxLocalAdapter.entry(IgniteTxKey<K> key)
IgniteTxEntry<K,V>	IgniteTxMap.get(Object key)
IgniteTxEntry<K,V>	IgniteTxAdapter.groupLockEntry() This method uses unchecked assignment to cast group lock key entry to transaction generic signature.
IgniteTxEntry<K,V>	IgniteTxLocalEx.groupLockEntry()
IgniteTxEntry<K,V>	IgniteTxMap.remove(Object key)

Methods in org.apache.ignite.internal.processors.cache.transactions that return types with arguments of type IgniteTxEntry

Modifier and Type	Method and Description
Collection<IgniteTxEntry<K,V>>	IgniteInternalTx.allEntries()
Collection<IgniteTxEntry<K,V>>	IgniteTxLocalAdapter.allEntries()
Set<Map.Entry<IgniteTxKey<K>,IgniteTxEntry<K,V>>>	IgniteTxMap.entrySet()
Collection<IgniteTxEntry<K,V>>	IgniteTxAdapter.optimisticLockEntries() Gets a list of entries that needs to be locked on the next step of prepare stage of optimistic transaction.
Collection<IgniteTxEntry<K,V>>	IgniteInternalTx.optimisticLockEntries() Gets a list of entries that needs to be locked on the next step of prepare stage of optimistic transaction.
Collection<IgniteTxEntry<K,V>>	IgniteInternalTx.readEntries()
Collection<IgniteTxEntry<K,V>>	IgniteTxLocalAdapter.readEntries()
Map<IgniteTxKey<K>,IgniteTxEntry<K,V>>	IgniteInternalTx.readMap()
Map<IgniteTxKey<K>,IgniteTxEntry<K,V>>	IgniteTxLocalAdapter.readMap()
Collection<IgniteTxEntry<K,V>>	IgniteInternalTx.writeEntries()
Collection<IgniteTxEntry<K,V>>	IgniteTxLocalAdapter.writeEntries()
Map<IgniteTxKey<K>,IgniteTxEntry<K,V>>	IgniteInternalTx.writeMap()
Map<IgniteTxKey<K>,IgniteTxEntry<K,V>>	IgniteTxLocalAdapter.writeMap()

Methods in org.apache.ignite.internal.processors.cache.transactions with parameters of type IgniteTxEntry

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

Method parameters in org.apache.ignite.internal.processors.cache.transactions with type arguments of type IgniteTxEntry

Modifier and Type	Method and Description
protected void	IgniteTxLocalAdapter.batchStoreCommit(Iterable<IgniteTxEntry<K,V>> writeEntries) Performs batch database operations.

Constructor parameters in org.apache.ignite.internal.processors.cache.transactions with type arguments of type IgniteTxEntry

Constructor and Description
IgniteTxMap(Map<IgniteTxKey<K>,IgniteTxEntry<K,V>> txMap, IgnitePredicate<IgniteTxEntry<K,V>> filter)
IgniteTxMap(Map<IgniteTxKey<K>,IgniteTxEntry<K,V>> txMap, IgnitePredicate<IgniteTxEntry<K,V>> filter)