| Modifier and Type | Method and Description |
|---|---|
void |
IgniteDiagnosticPrepareContext.remoteTxInfo(UUID nodeId,
GridCacheVersion dhtVer,
GridCacheVersion nearVer,
String msg) |
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheVersion |
DataEntry.nearXidVer
Near transaction version.
|
protected GridCacheVersion |
DataEntry.writeVer
Write version.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
DataEntry.nearXidVersion() |
GridCacheVersion |
TxRecord.nearXidVersion() |
GridCacheVersion |
DataEntry.writeVersion() |
GridCacheVersion |
TxRecord.writeVersion() |
| Modifier and Type | Method and Description |
|---|---|
void |
TxRecord.dhtVersion(GridCacheVersion writeVer) |
void |
TxRecord.nearXidVersion(GridCacheVersion nearXidVer) |
| Constructor and Description |
|---|
DataEntry(int cacheId,
KeyCacheObject key,
CacheObject val,
GridCacheOperation op,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
long expireTime,
int partId,
long partCnt) |
LazyDataEntry(GridCacheSharedContext cctx,
int cacheId,
byte keyType,
byte[] keyBytes,
byte valType,
byte[] valBytes,
GridCacheOperation op,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
long expireTime,
int partId,
long partCnt) |
TxRecord(TransactionState state,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
Map<Short,Collection<Short>> participatingNodes) |
TxRecord(TransactionState state,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
Map<Short,Collection<Short>> participatingNodes,
long ts) |
UnwrapDataEntry(int cacheId,
KeyCacheObject key,
CacheObject val,
GridCacheOperation op,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
long expireTime,
int partId,
long partCnt,
CacheObjectValueContext cacheObjValCtx,
boolean keepBinary) |
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheVersion |
GridCacheClearAllRunnable.obsoleteVer
Obsolete version.
|
protected GridCacheVersion |
GridCacheMapEntry.ver
Version.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion[] |
GridCacheContext.emptyVersion() |
GridCacheVersion |
GridCacheMvccManager.mappedVersion(GridCacheVersion from) |
GridCacheVersion |
GridCacheEntryEx.obsoleteVersion() |
GridCacheVersion |
GridCacheMapEntry.obsoleteVersion() |
protected GridCacheVersion |
GridCacheMapEntry.obsoleteVersionExtras() |
GridCacheVersion |
GridCacheMvccCandidate.otherVersion() |
GridCacheVersion |
GridCacheMvccCandidate.ownerVersion() |
GridCacheVersion |
GridCacheUpdateAtomicResult.removeVersion() |
GridCacheVersion |
GridCacheMvccCandidate.serializableOrder() |
GridCacheVersion |
GridCacheMvccManager.unmapVersion(GridCacheVersion from) |
GridCacheVersion |
GridCacheMvccCandidate.version() |
GridCacheVersion |
CacheEvictionEntry.version() |
GridCacheVersion |
CacheEntryImplEx.version()
Returns a comparable object representing the version of this cache entry.
|
GridCacheVersion |
GridCacheVersionedFuture.version() |
GridCacheVersion |
GridCacheEntryInfo.version() |
GridCacheVersion |
EntryGetResult.version() |
GridCacheVersion |
GridCacheEntryEx.version() |
GridCacheVersion |
GridCacheMapEntry.version() |
| Modifier and Type | Method and Description |
|---|---|
Map<KeyCacheObject,GridCacheVersion> |
GridCacheAdapter.CacheExpiryPolicy.entries() |
Map<KeyCacheObject,GridCacheVersion> |
IgniteCacheExpiryPolicy.entries() |
Map<UUID,Collection<IgniteBiTuple<KeyCacheObject,GridCacheVersion>>> |
GridCacheAdapter.CacheExpiryPolicy.readers() |
Map<UUID,Collection<IgniteBiTuple<KeyCacheObject,GridCacheVersion>>> |
IgniteCacheExpiryPolicy.readers() |
static IgniteClosure<IgniteInternalTx,GridCacheVersion> |
GridCacheUtils.tx2xidVersion() |
| Modifier and Type | Method and Description |
|---|---|
GridCacheMvccCandidate |
GridCacheMvcc.addLocal(GridCacheEntryEx parent,
long threadId,
GridCacheVersion ver,
long timeout,
boolean reenter,
boolean tx,
boolean implicitSingle,
boolean read) |
GridCacheMvccCandidate |
GridCacheMvcc.addLocal(GridCacheEntryEx parent,
UUID nearNodeId,
GridCacheVersion nearVer,
long threadId,
GridCacheVersion ver,
long timeout,
GridCacheVersion serOrder,
boolean reenter,
boolean tx,
boolean implicitSingle,
boolean dhtLoc,
boolean read) |
GridCacheMvccCandidate |
GridCacheMvcc.addNearLocal(GridCacheEntryEx parent,
UUID nodeId,
UUID otherNodeId,
long threadId,
GridCacheVersion ver,
boolean tx,
boolean implicitSingle,
boolean read)
Adds new near local lock candidate.
|
GridCacheMvccCandidate |
GridCacheMvcc.addRemote(GridCacheEntryEx parent,
UUID nodeId,
UUID otherNodeId,
long threadId,
GridCacheVersion ver,
boolean tx,
boolean implicitSingle,
boolean nearLoc)
Adds new remote lock candidate (either near remote or dht remote).
|
boolean |
GridCacheMvccManager.addRemoved(GridCacheContext cacheCtx,
GridCacheVersion ver) |
<K1,V1> void |
GridCacheContext.addResult(Map<K1,V1> map,
KeyCacheObject key,
CacheObject val,
boolean skipVals,
boolean keepCacheObjects,
boolean deserializeBinary,
boolean cpy,
EntryGetResult getRes,
GridCacheVersion ver,
long expireTime,
long ttl,
boolean needVer) |
<K1,V1> void |
GridCacheContext.addResult(Map<K1,V1> map,
KeyCacheObject key,
CacheObject val,
boolean skipVals,
boolean keepCacheObjects,
boolean deserializeBinary,
boolean cpy,
GridCacheVersion ver,
long expireTime,
long ttl) |
void |
CacheOffheapEvictionManager.batchEvict(Collection<?> keys,
GridCacheVersion obsoleteVer) |
void |
GridCacheEvictionManager.batchEvict(Collection<?> keys,
GridCacheVersion obsoleteVer) |
void |
CacheEvictionManager.batchEvict(Collection<?> keys,
GridCacheVersion obsoleteVer) |
GridCacheMvccCandidate |
GridCacheMvcc.candidate(GridCacheVersion ver)
Gets candidate for lock ID.
|
GridCacheMvccCandidate |
GridCacheEntryEx.candidate(GridCacheVersion ver)
Gets lock candidate for given lock ID.
|
GridCacheMvccCandidate |
GridCacheMapEntry.candidate(GridCacheVersion ver)
Gets lock candidate for given lock ID.
|
GridCacheMvccCandidate |
GridCacheExplicitLockSpan.candidate(IgniteTxKey key,
GridCacheVersion ver)
Gets explicit lock candidate for given key.
|
boolean |
GridCacheEntryEx.checkSerializableReadVersion(GridCacheVersion serReadVer)
Checks if there was read/write conflict in serializable transaction.
|
boolean |
GridCacheMapEntry.checkSerializableReadVersion(GridCacheVersion serReadVer)
Checks if there was read/write conflict in serializable transaction.
|
boolean |
GridCacheEntryEx.clear(GridCacheVersion ver,
boolean readers)
Marks entry as obsolete and, if possible or required, removes it
from swap storage.
|
boolean |
GridCacheMapEntry.clear(GridCacheVersion ver,
boolean readers)
Marks entry as obsolete and, if possible or required, removes it
from swap storage.
|
void |
GridCacheEntryEx.clearReserveForLoad(GridCacheVersion ver) |
void |
GridCacheMapEntry.clearReserveForLoad(GridCacheVersion ver) |
int |
GridCacheAtomicVersionComparator.compare(GridCacheVersion one,
GridCacheVersion other)
Compares two cache versions.
|
GridDhtPartitionsFullMessage |
GridCachePartitionExchangeManager.createPartitionsFullMessage(boolean compress,
boolean newCntrMap,
GridDhtPartitionExchangeId exchId,
GridCacheVersion lastVer,
IgniteDhtPartitionHistorySuppliersMap partHistSuppliers,
IgniteDhtPartitionsToReloadMap partsToReload) |
CacheDataRow |
IgniteCacheOffheapManager.CacheDataStore.createRow(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
CacheDataRow oldRow) |
CacheDataRow |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.createRow(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
CacheDataRow oldRow) |
void |
GridCacheContext.dhtMap(GridDhtCacheEntry entry,
GridCacheVersion explicitLockVer,
IgniteLogger log,
Map<ClusterNode,List<GridDhtCacheEntry>> dhtMap,
Map<ClusterNode,List<GridDhtCacheEntry>> nearMap) |
void |
GridCacheContext.dhtMap(UUID nearNodeId,
AffinityTopologyVersion topVer,
GridDhtCacheEntry entry,
GridCacheVersion explicitLockVer,
IgniteLogger log,
Map<ClusterNode,List<GridDhtCacheEntry>> dhtMap,
Map<ClusterNode,List<GridDhtCacheEntry>> nearMap) |
CacheLockCandidates |
GridCacheMvcc.doneRemote(GridCacheVersion ver,
Collection<GridCacheVersion> pending,
Collection<GridCacheVersion> committed,
Collection<GridCacheVersion> rolledback)
Sets remote candidate to done.
|
boolean |
CacheOffheapEvictionManager.evict(GridCacheEntryEx entry,
GridCacheVersion obsoleteVer,
boolean explicit,
CacheEntryPredicate[] filter) |
boolean |
GridCacheEvictionManager.evict(GridCacheEntryEx entry,
GridCacheVersion obsoleteVer,
boolean explicit,
CacheEntryPredicate[] filter) |
boolean |
CacheEvictionManager.evict(GridCacheEntryEx entry,
GridCacheVersion obsoleteVer,
boolean explicit,
CacheEntryPredicate[] filter) |
boolean |
GridCacheEntryEx.evictInternal(GridCacheVersion obsoleteVer,
CacheEntryPredicate[] filter,
boolean evictOffheap) |
boolean |
GridCacheMapEntry.evictInternal(GridCacheVersion obsoleteVer,
CacheEntryPredicate[] filter,
boolean evictOffheap) |
GridCacheMvccCandidate |
GridCacheMvccManager.explicitLock(IgniteTxKey key,
GridCacheVersion ver)
Gets explicit lock candidate added by any thread by given key and lock version.
|
void |
GridCacheSharedContext.finishDhtAtomicUpdate(GridCacheVersion ver) |
Collection<GridCacheVersionedFuture<?>> |
GridCacheMvccManager.futuresForVersion(GridCacheVersion ver)
Gets futures for given lock ID.
|
boolean |
GridCacheMvccCandidate.hasCandidate(GridCacheVersion ver) |
boolean |
CacheLockCandidates.hasCandidate(GridCacheVersion ver) |
boolean |
GridCacheEntryEx.hasLockCandidate(GridCacheVersion ver)
Checks if the candidate is either owner or pending.
|
boolean |
GridCacheMapEntry.hasLockCandidate(GridCacheVersion ver)
Checks if the candidate is either owner or pending.
|
boolean |
GridCacheEntryEx.hasLockCandidateUnsafe(GridCacheVersion ver) |
boolean |
GridCacheMapEntry.hasLockCandidateUnsafe(GridCacheVersion ver) |
boolean |
GridCacheEntryEx.initialValue(CacheObject val,
GridCacheVersion ver,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType,
boolean fromStore)
Sets new value if current version is 0
|
boolean |
GridCacheMapEntry.initialValue(CacheObject val,
GridCacheVersion ver,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType,
boolean fromStore)
Sets new value if current version is 0
|
CacheObject |
GridCacheEntryEx.innerGet(GridCacheVersion ver,
IgniteInternalTx tx,
boolean readThrough,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary) |
CacheObject |
GridCacheMapEntry.innerGet(GridCacheVersion ver,
IgniteInternalTx tx,
boolean readThrough,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expirePlc,
boolean keepBinary) |
EntryGetResult |
GridCacheEntryEx.innerGetVersioned(GridCacheVersion ver,
IgniteInternalTx tx,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
ReaderArguments readerArgs) |
EntryGetResult |
GridCacheMapEntry.innerGetVersioned(GridCacheVersion ver,
IgniteInternalTx tx,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
ReaderArguments readerArgs) |
GridCacheUpdateTxResult |
GridCacheEntryEx.innerRemove(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
boolean retval,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
GridCacheVersion explicitVer,
UUID subjId,
String taskName,
GridCacheVersion dhtVer,
Long updateCntr) |
GridCacheUpdateTxResult |
GridCacheMapEntry.innerRemove(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
boolean retval,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
GridCacheVersion explicitVer,
UUID subjId,
String taskName,
GridCacheVersion dhtVer,
Long updateCntr) |
GridCacheUpdateTxResult |
GridCacheEntryEx.innerSet(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
CacheObject val,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long drExpireTime,
GridCacheVersion explicitVer,
UUID subjId,
String taskName,
GridCacheVersion dhtVer,
Long updateCntr) |
GridCacheUpdateTxResult |
GridCacheMapEntry.innerSet(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
CacheObject val,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long drExpireTime,
GridCacheVersion explicitVer,
UUID subjId,
String taskName,
GridCacheVersion dhtVer,
Long updateCntr) |
GridCacheUpdateAtomicResult |
GridCacheEntryEx.innerUpdate(GridCacheVersion ver,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
Object val,
Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
boolean retval,
boolean keepBinary,
IgniteCacheExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
boolean primary,
boolean checkVer,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long conflictTtl,
long conflictExpireTime,
GridCacheVersion conflictVer,
boolean conflictResolve,
boolean intercept,
UUID subjId,
String taskName,
CacheObject prevVal,
Long updateCntr,
GridDhtAtomicAbstractUpdateFuture fut) |
GridCacheUpdateAtomicResult |
GridCacheMapEntry.innerUpdate(GridCacheVersion newVer,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
Object writeObj,
Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
boolean retval,
boolean keepBinary,
IgniteCacheExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
boolean primary,
boolean verCheck,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long explicitTtl,
long explicitExpireTime,
GridCacheVersion conflictVer,
boolean conflictResolve,
boolean intercept,
UUID subjId,
String taskName,
CacheObject prevVal,
Long updateCntr,
GridDhtAtomicAbstractUpdateFuture fut) |
GridTuple3<Boolean,Object,javax.cache.processor.EntryProcessorResult<Object>> |
GridCacheEntryEx.innerUpdateLocal(GridCacheVersion ver,
GridCacheOperation op,
Object writeObj,
Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
boolean retval,
boolean keepBinary,
javax.cache.expiry.ExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
CacheEntryPredicate[] filter,
boolean intercept,
UUID subjId,
String taskName)
Update method for local cache in atomic mode.
|
GridTuple3<Boolean,Object,javax.cache.processor.EntryProcessorResult<Object>> |
GridCacheMapEntry.innerUpdateLocal(GridCacheVersion ver,
GridCacheOperation op,
Object writeObj,
Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
boolean retval,
boolean keepBinary,
javax.cache.expiry.ExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
CacheEntryPredicate[] filter,
boolean intercept,
UUID subjId,
String taskName)
Update method for local cache in atomic mode.
|
boolean |
GridCacheEntryEx.invalidate(GridCacheVersion newVer)
Invalidates this entry.
|
boolean |
GridCacheMapEntry.invalidate(GridCacheVersion newVer)
Invalidates this entry.
|
boolean |
GridCacheMvcc.isEmpty(GridCacheVersion... exclude) |
boolean |
GridCacheMvccManager.isRemoved(GridCacheContext cacheCtx,
GridCacheVersion ver) |
List<GridCacheMvccCandidate> |
GridCacheMvcc.localCandidates(boolean reentries,
GridCacheVersion... excludeVers) |
Collection<GridCacheMvccCandidate> |
GridCacheMvcc.localCandidates(GridCacheVersion... excludeVers) |
Collection<GridCacheMvccCandidate> |
GridCacheEntryEx.localCandidates(GridCacheVersion... exclude)
Gets all local candidates.
|
Collection<GridCacheMvccCandidate> |
GridCacheMapEntry.localCandidates(GridCacheVersion... exclude)
Gets all local candidates.
|
boolean |
GridCacheEntryEx.lockedBy(GridCacheVersion ver) |
boolean |
GridCacheMapEntry.lockedBy(GridCacheVersion ver) |
boolean |
GridCacheEntryEx.lockedByAny(GridCacheVersion... exclude) |
boolean |
GridCacheMapEntry.lockedByAny(GridCacheVersion... exclude) |
boolean |
GridCacheEntryEx.lockedByThread(long threadId,
GridCacheVersion exclude) |
boolean |
GridCacheMapEntry.lockedByThread(long threadId,
GridCacheVersion exclude) |
boolean |
GridCacheEntryEx.lockedByUnsafe(GridCacheVersion ver) |
boolean |
GridCacheMapEntry.lockedByUnsafe(GridCacheVersion ver) |
boolean |
GridCacheEntryEx.lockedLocally(GridCacheVersion lockVer) |
boolean |
GridCacheMapEntry.lockedLocally(GridCacheVersion lockVer) |
boolean |
GridCacheEntryEx.lockedLocallyByIdOrThread(GridCacheVersion lockVer,
long threadId) |
boolean |
GridCacheMapEntry.lockedLocallyByIdOrThread(GridCacheVersion lockVer,
long threadId) |
boolean |
GridCacheEntryEx.lockedLocallyUnsafe(GridCacheVersion lockVer) |
boolean |
GridCacheMapEntry.lockedLocallyUnsafe(GridCacheVersion lockVer) |
protected void |
GridCacheMapEntry.logUpdate(GridCacheOperation op,
CacheObject val,
GridCacheVersion writeVer,
long expireTime,
long updCntr) |
GridCacheVersion |
GridCacheMvccManager.mappedVersion(GridCacheVersion from) |
void |
GridCacheMvccManager.mapVersion(GridCacheVersion from,
GridCacheVersion to) |
boolean |
GridCacheEntryEx.markObsolete(GridCacheVersion ver)
Sets obsolete flag if possible.
|
boolean |
GridCacheMapEntry.markObsolete(GridCacheVersion ver)
Sets obsolete flag if possible.
|
protected boolean |
GridCacheMapEntry.markObsolete0(GridCacheVersion ver,
boolean clear,
GridCacheObsoleteEntryExtras extras)
Note that
GridCacheMapEntry.onMarkedObsolete() should always be called after this method
returns true. |
boolean |
GridCacheEntryEx.markObsoleteIfEmpty(GridCacheVersion ver)
Sets obsolete flag if entry value is
null or entry is expired and no
locks are held. |
boolean |
GridCacheMapEntry.markObsoleteIfEmpty(GridCacheVersion obsoleteVer)
Sets obsolete flag if entry value is
null or entry is expired and no
locks are held. |
boolean |
GridCacheEntryEx.markObsoleteVersion(GridCacheVersion ver)
Sets obsolete flag if entry version equals to
ver. |
boolean |
GridCacheMapEntry.markObsoleteVersion(GridCacheVersion ver)
Sets obsolete flag if entry version equals to
ver. |
void |
GridCacheMvcc.markOwned(GridCacheVersion baseVer,
GridCacheVersion owned)
Puts owned versions in front of base.
|
boolean |
GridCacheEntryEx.obsolete(GridCacheVersion exclude) |
boolean |
GridCacheMapEntry.obsolete(GridCacheVersion exclude) |
void |
GridCacheContext.onDeferredDelete(GridCacheEntryEx entry,
GridCacheVersion ver) |
abstract void |
GridCacheAdapter.onDeferredDelete(GridCacheEntryEx entry,
GridCacheVersion ver) |
boolean |
GridCacheEntryEx.onTtlExpired(GridCacheVersion obsoleteVer)
Callback from ttl processor to cache entry indicating that entry is expired.
|
boolean |
GridCacheMapEntry.onTtlExpired(GridCacheVersion obsoleteVer)
Callback from ttl processor to cache entry indicating that entry is expired.
|
void |
GridCacheMvcc.orderCompleted(GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers)
Moves completed candidates right before the base one.
|
boolean |
GridCacheMvccCandidate.otherVersion(GridCacheVersion otherVer)
Sets mapped version for candidate.
|
boolean |
GridCacheMvccCandidate.ownerVersion(GridCacheVersion ownerVer)
Sets owned version for proper lock ordering when remote candidate is added.
|
CacheLockCandidates |
GridCacheMvcc.readyLocal(GridCacheVersion ver) |
CacheLockCandidates |
GridCacheMvcc.readyNearLocal(GridCacheVersion ver,
GridCacheVersion mappedVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledBackVers,
Collection<GridCacheVersion> pending)
Marks near-local candidate as ready and makes locks reassignment.
|
List<GridCacheMvccCandidate> |
GridCacheMvcc.remoteCandidates(GridCacheVersion... excludeVers) |
Collection<GridCacheMvccCandidate> |
GridCacheEntryEx.remoteMvccSnapshot(GridCacheVersion... exclude)
Gets all remote versions.
|
Collection<GridCacheMvccCandidate> |
GridCacheMapEntry.remoteMvccSnapshot(GridCacheVersion... exclude)
Gets all remote versions.
|
void |
GridCacheMvcc.remove(GridCacheVersion ver)
Removes lock even if it is not owner.
|
GridCacheMvccCandidate |
GridCacheExplicitLockSpan.removeCandidate(IgniteTxKey key,
GridCacheVersion ver)
Removes lock by key and optional version.
|
GridCacheMvccCandidate |
GridCacheMvccManager.removeExplicitLock(long threadId,
IgniteTxKey key,
GridCacheVersion ver)
Removes explicit lock for given thread id, key and optional version.
|
boolean |
GridCacheEntryEx.removeLock(GridCacheVersion ver) |
void |
GridCacheMvcc.salvageRemote(GridCacheVersion ver)
For all remote candidates standing behind the candidate being salvaged marks their transactions
as system invalidate and marks these candidates as owned and used.
|
int |
GridCacheSharedContext.startDhtAtomicUpdate(GridCacheVersion ver) |
protected boolean |
GridCacheMapEntry.storeValue(CacheObject val,
long expireTime,
GridCacheVersion ver,
CacheDataRow oldRow)
Stores value in offheap.
|
protected boolean |
GridCacheMapEntry.storeValue(CacheObject val,
long expireTime,
GridCacheVersion ver,
CacheDataRow oldRow,
IgnitePredicate<CacheDataRow> predicate)
Stores value in offheap.
|
boolean |
GridCacheEntryEx.tmLock(IgniteInternalTx tx,
long timeout,
GridCacheVersion serOrder,
GridCacheVersion serReadVer,
boolean read)
This locks is called by transaction manager during prepare step
for optimistic transactions.
|
void |
GridCacheAdapter.CacheExpiryPolicy.ttlUpdated(KeyCacheObject key,
GridCacheVersion ver,
Collection<UUID> rdrs) |
void |
IgniteCacheExpiryPolicy.ttlUpdated(KeyCacheObject key,
GridCacheVersion ver,
Collection<UUID> rdrs)
Callback for ttl update on entry access.
|
GridCacheVersion |
GridCacheMvccManager.unmapVersion(GridCacheVersion from) |
protected void |
GridCacheMapEntry.update(CacheObject val,
long expireTime,
long ttl,
GridCacheVersion ver,
boolean addTracked) |
void |
IgniteCacheOffheapManager.CacheDataStore.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
CacheDataRow oldRow) |
void |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
CacheDataRow oldRow) |
void |
IgniteCacheOffheapManager.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
GridDhtLocalPartition part,
CacheDataRow oldRow) |
void |
IgniteCacheOffheapManagerImpl.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
GridDhtLocalPartition part,
CacheDataRow oldRow) |
void |
GridCacheEntryEx.updateTtl(GridCacheVersion ver,
long ttl) |
void |
GridCacheMapEntry.updateTtl(GridCacheVersion ver,
long ttl) |
CacheObject |
GridCacheEntryEx.valueBytes(GridCacheVersion ver)
Gets cached serialized value bytes.
|
CacheObject |
GridCacheMapEntry.valueBytes(GridCacheVersion ver)
Gets cached serialized value bytes.
|
void |
GridCacheEntryInfo.version(GridCacheVersion ver) |
GridCacheVersionedFuture<?> |
GridCacheMvccManager.versionedFuture(GridCacheVersion ver,
IgniteUuid futId)
Gets future for given future ID and lock ID.
|
EntryGetResult |
GridCacheEntryEx.versionedValue(CacheObject val,
GridCacheVersion curVer,
GridCacheVersion newVer,
IgniteCacheExpiryPolicy loadExpiryPlc,
ReaderArguments readerArgs)
Sets new value if passed in version matches the current version
(used for read-through only).
|
EntryGetResult |
GridCacheMapEntry.versionedValue(CacheObject val,
GridCacheVersion curVer,
GridCacheVersion newVer,
IgniteCacheExpiryPolicy loadExpiryPlc,
ReaderArguments readerArgs)
Sets new value if passed in version matches the current version
(used for read-through only).
|
| Modifier and Type | Method and Description |
|---|---|
CacheLockCandidates |
GridCacheMvcc.doneRemote(GridCacheVersion ver,
Collection<GridCacheVersion> pending,
Collection<GridCacheVersion> committed,
Collection<GridCacheVersion> rolledback)
Sets remote candidate to done.
|
CacheLockCandidates |
GridCacheMvcc.doneRemote(GridCacheVersion ver,
Collection<GridCacheVersion> pending,
Collection<GridCacheVersion> committed,
Collection<GridCacheVersion> rolledback)
Sets remote candidate to done.
|
CacheLockCandidates |
GridCacheMvcc.doneRemote(GridCacheVersion ver,
Collection<GridCacheVersion> pending,
Collection<GridCacheVersion> committed,
Collection<GridCacheVersion> rolledback)
Sets remote candidate to done.
|
boolean |
IgniteCacheOffheapManager.expire(GridCacheContext cctx,
IgniteInClosure2X<GridCacheEntryEx,GridCacheVersion> c,
int amount) |
boolean |
IgniteCacheOffheapManagerImpl.expire(GridCacheContext cctx,
IgniteInClosure2X<GridCacheEntryEx,GridCacheVersion> c,
int amount) |
void |
GridCacheMvcc.orderCompleted(GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers)
Moves completed candidates right before the base one.
|
void |
GridCacheMvcc.orderCompleted(GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers)
Moves completed candidates right before the base one.
|
CacheLockCandidates |
GridCacheMvcc.readyNearLocal(GridCacheVersion ver,
GridCacheVersion mappedVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledBackVers,
Collection<GridCacheVersion> pending)
Marks near-local candidate as ready and makes locks reassignment.
|
CacheLockCandidates |
GridCacheMvcc.readyNearLocal(GridCacheVersion ver,
GridCacheVersion mappedVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledBackVers,
Collection<GridCacheVersion> pending)
Marks near-local candidate as ready and makes locks reassignment.
|
CacheLockCandidates |
GridCacheMvcc.readyNearLocal(GridCacheVersion ver,
GridCacheVersion mappedVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledBackVers,
Collection<GridCacheVersion> pending)
Marks near-local candidate as ready and makes locks reassignment.
|
void |
GridCacheAdapter.removeAllConflict(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data.
|
void |
GridCacheProxyImpl.removeAllConflict(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data.
|
void |
IgniteInternalCache.removeAllConflict(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data.
|
IgniteInternalFuture<?> |
GridCacheAdapter.removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
IgniteInternalFuture<?> |
GridCacheProxyImpl.removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
IgniteInternalFuture<?> |
IgniteInternalCache.removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
| Constructor and Description |
|---|
CacheEntryImpl(K key,
V val,
GridCacheVersion ver) |
CacheEntryImplEx(K key,
V val,
GridCacheVersion ver) |
CacheEvictionEntry(KeyCacheObject key,
GridCacheVersion ver,
boolean near) |
CacheInvokeEntry(KeyCacheObject keyObj,
CacheObject valObj,
GridCacheVersion ver,
boolean keepBinary,
GridCacheEntryEx entry)
Constructor.
|
CacheInvokeEntry(KeyCacheObject keyObj,
K key,
CacheObject valObj,
V val,
GridCacheVersion ver,
boolean keepBinary,
GridCacheEntryEx entry) |
EntryGetResult(Object val,
GridCacheVersion ver) |
EntryGetResult(Object val,
GridCacheVersion ver,
boolean reserved) |
EntryGetWithTtlResult(Object val,
GridCacheVersion ver,
boolean reserved,
long expireTime,
long ttl) |
GridCacheClearAllRunnable(GridCacheAdapter<K,V> cache,
GridCacheVersion obsoleteVer,
int id,
int totalCnt,
boolean readers)
Constructor.
|
GridCacheLockTimeoutException(GridCacheVersion ver) |
GridCacheMvccCandidate(GridCacheEntryEx parent,
UUID nodeId,
UUID otherNodeId,
GridCacheVersion otherVer,
long threadId,
GridCacheVersion ver,
boolean loc,
boolean reentry,
boolean tx,
boolean singleImplicit,
boolean nearLoc,
boolean dhtLoc,
GridCacheVersion serOrder,
boolean read) |
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheVersion |
GridDistributedBaseMessage.ver
Lock or transaction version.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
GridDistributedTxFinishRequest.baseVersion() |
GridCacheVersion |
GridDistributedTxFinishRequest.commitVersion() |
GridCacheVersion |
GridDistributedTxMapping.dhtVersion() |
GridCacheVersion |
GridCacheMappedVersion.mappedVersion()
Mapping should occur only if this interface returns a non-null value.
|
GridCacheVersion |
GridCacheTxRecoveryRequest.nearXidVersion() |
GridCacheVersion |
GridDistributedLockRequest.nearXidVersion() |
GridCacheVersion |
GridDistributedBaseMessage.version() |
GridCacheVersion |
GridCacheTtlUpdateRequest.version(int idx) |
GridCacheVersion |
GridDistributedTxPrepareRequest.writeVersion() |
GridCacheVersion |
GridDistributedTxFinishResponse.xid() |
| Modifier and Type | Method and Description |
|---|---|
Collection<GridCacheVersion> |
GridDistributedTxRemoteAdapter.alternateVersions() |
Collection<GridCacheVersion> |
GridDistributedBaseMessage.committedVersions() |
Map<IgniteTxKey,GridCacheVersion> |
GridDistributedTxPrepareRequest.dhtVersions() |
List<GridCacheVersion> |
GridCacheTtlUpdateRequest.nearVersions() |
Collection<GridCacheVersion> |
GridDistributedBaseMessage.rolledbackVersions() |
List<GridCacheVersion> |
GridCacheTtlUpdateRequest.versions() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDistributedTxPrepareRequest.addDhtVersion(IgniteTxKey key,
GridCacheVersion dhtVer)
Adds version to be verified on remote node.
|
void |
GridCacheTtlUpdateRequest.addEntry(KeyCacheObject key,
GridCacheVersion ver) |
GridCacheMvccCandidate |
GridDistributedCacheEntry.addLocal(long threadId,
GridCacheVersion ver,
AffinityTopologyVersion topVer,
long timeout,
boolean reenter,
boolean tx,
boolean implicitSingle,
boolean read)
Add local candidate.
|
void |
GridCacheTtlUpdateRequest.addNearEntry(KeyCacheObject key,
GridCacheVersion ver) |
void |
GridDistributedCacheEntry.addRemote(UUID nodeId,
UUID otherNodeId,
long threadId,
GridCacheVersion ver,
boolean tx,
boolean implicitSingle,
GridCacheVersion owned)
Adds new lock candidate.
|
boolean |
GridDistributedCacheEntry.addRemoved(GridCacheVersion ver) |
protected void |
GridDistributedCacheEntry.checkRemoved(GridCacheVersion ver) |
void |
GridDistributedTxMapping.dhtVersion(GridCacheVersion dhtVer,
GridCacheVersion writeVer) |
void |
GridDistributedTxRemoteAdapter.doneRemote(GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers) |
void |
GridDistributedCacheEntry.doneRemote(GridCacheVersion lockVer,
GridCacheVersion baseVer,
Collection<GridCacheVersion> pendingVers,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
boolean sysInvalidate) |
CacheLockCandidates |
GridDistributedCacheEntry.readyLock(GridCacheVersion ver) |
void |
GridDistributedCacheEntry.readyNearLock(GridCacheVersion ver,
GridCacheVersion mapped,
Collection<GridCacheVersion> committed,
Collection<GridCacheVersion> rolledBack,
Collection<GridCacheVersion> pending)
Notifies mvcc that near local lock is ready to be acquired.
|
Collection<GridCacheMvccCandidate> |
GridDistributedCacheEntry.remoteMvccSnapshot(GridCacheVersion... exclude)
Gets all remote versions.
|
boolean |
GridDistributedCacheEntry.removeLock(GridCacheVersion ver) |
void |
GridDistributedCacheAdapter.removeVersionedEntry(KeyCacheObject key,
GridCacheVersion ver) |
boolean |
GridDistributedCacheEntry.tmLock(IgniteInternalTx tx,
long timeout,
GridCacheVersion serOrder,
GridCacheVersion serReadVer,
boolean read)
This locks is called by transaction manager during prepare step
for optimistic transactions.
|
void |
GridDistributedBaseMessage.version(GridCacheVersion ver) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDistributedBaseMessage.completedVersions(Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers) |
void |
GridDistributedBaseMessage.completedVersions(Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers) |
void |
GridDistributedTxRemoteAdapter.doneRemote(GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers) |
void |
GridDistributedTxRemoteAdapter.doneRemote(GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers) |
void |
GridDistributedTxRemoteAdapter.doneRemote(GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers) |
void |
GridDistributedCacheEntry.doneRemote(GridCacheVersion lockVer,
GridCacheVersion baseVer,
Collection<GridCacheVersion> pendingVers,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
boolean sysInvalidate) |
void |
GridDistributedCacheEntry.doneRemote(GridCacheVersion lockVer,
GridCacheVersion baseVer,
Collection<GridCacheVersion> pendingVers,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
boolean sysInvalidate) |
void |
GridDistributedCacheEntry.doneRemote(GridCacheVersion lockVer,
GridCacheVersion baseVer,
Collection<GridCacheVersion> pendingVers,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
boolean sysInvalidate) |
void |
GridDistributedCacheEntry.readyNearLock(GridCacheVersion ver,
GridCacheVersion mapped,
Collection<GridCacheVersion> committed,
Collection<GridCacheVersion> rolledBack,
Collection<GridCacheVersion> pending)
Notifies mvcc that near local lock is ready to be acquired.
|
void |
GridDistributedCacheEntry.readyNearLock(GridCacheVersion ver,
GridCacheVersion mapped,
Collection<GridCacheVersion> committed,
Collection<GridCacheVersion> rolledBack,
Collection<GridCacheVersion> pending)
Notifies mvcc that near local lock is ready to be acquired.
|
void |
GridDistributedCacheEntry.readyNearLock(GridCacheVersion ver,
GridCacheVersion mapped,
Collection<GridCacheVersion> committed,
Collection<GridCacheVersion> rolledBack,
Collection<GridCacheVersion> pending)
Notifies mvcc that near local lock is ready to be acquired.
|
| Constructor and Description |
|---|
GridCacheTxRecoveryResponse(GridCacheVersion txId,
IgniteUuid futId,
IgniteUuid miniId,
boolean success,
boolean addDepInfo) |
GridDistributedBaseMessage(GridCacheVersion ver,
int cnt,
boolean addDepInfo) |
GridDistributedLockRequest(int cacheId,
UUID nodeId,
GridCacheVersion nearXidVer,
long threadId,
IgniteUuid futId,
GridCacheVersion lockVer,
boolean isInTx,
boolean isRead,
TransactionIsolation isolation,
boolean isInvalidate,
long timeout,
int keyCnt,
int txSize,
boolean skipStore,
boolean keepBinary,
boolean addDepInfo) |
GridDistributedLockResponse(int cacheId,
GridCacheVersion lockVer,
IgniteUuid futId,
int cnt,
boolean addDepInfo) |
GridDistributedLockResponse(int cacheId,
GridCacheVersion lockVer,
IgniteUuid futId,
int cnt,
Throwable err,
boolean addDepInfo) |
GridDistributedLockResponse(int cacheId,
GridCacheVersion lockVer,
IgniteUuid futId,
Throwable err,
boolean addDepInfo) |
GridDistributedTxFinishRequest(GridCacheVersion xidVer,
IgniteUuid futId,
AffinityTopologyVersion topVer,
GridCacheVersion commitVer,
long threadId,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
CacheWriteSynchronizationMode syncMode,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
UUID subjId,
int taskNameHash,
int txSize,
boolean addDepInfo) |
GridDistributedTxFinishResponse(int part,
GridCacheVersion txId,
IgniteUuid futId) |
GridDistributedTxPrepareResponse(int part,
GridCacheVersion xid,
boolean addDepInfo) |
GridDistributedTxPrepareResponse(int part,
GridCacheVersion xid,
Throwable err,
boolean addDepInfo) |
GridDistributedTxRemoteAdapter(GridCacheSharedContext<?,?> ctx,
UUID nodeId,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
byte plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
boolean invalidate,
long timeout,
int txSize,
UUID subjId,
int taskNameHash) |
| Constructor and Description |
|---|
GridDistributedTxFinishRequest(GridCacheVersion xidVer,
IgniteUuid futId,
AffinityTopologyVersion topVer,
GridCacheVersion commitVer,
long threadId,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
CacheWriteSynchronizationMode syncMode,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
UUID subjId,
int taskNameHash,
int txSize,
boolean addDepInfo) |
GridDistributedTxFinishRequest(GridCacheVersion xidVer,
IgniteUuid futId,
AffinityTopologyVersion topVer,
GridCacheVersion commitVer,
long threadId,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
CacheWriteSynchronizationMode syncMode,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
UUID subjId,
int taskNameHash,
int txSize,
boolean addDepInfo) |
| Modifier and Type | Field and Description |
|---|---|
protected Collection<GridCacheVersion> |
GridDhtTxOnePhaseCommitAckRequest.vers
Lock or transaction versions.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
GridDhtTxLocal.mappedVersion()
Mapping should occur only if this interface returns a non-null value.
|
GridCacheVersion |
GridDhtLockFuture.mappedVersion()
Mapping should occur only if this interface returns a non-null value.
|
GridCacheVersion |
GridDhtLockFuture.nearLockVersion() |
GridCacheVersion |
GridDhtTxPrepareRequest.nearXidVersion() |
GridCacheVersion |
GridDhtTxRemote.nearXidVersion() |
GridCacheVersion |
GridDhtTxLocal.nearXidVersion() |
GridCacheVersion |
GridDhtLockRequest.owned(KeyCacheObject key) |
GridCacheVersion |
GridDhtGetFuture.version() |
GridCacheVersion |
GridDhtGetSingleFuture.version() |
GridCacheVersion |
GridDhtLockFuture.version() |
GridCacheVersion |
GridDhtTxPrepareFuture.version() |
GridCacheVersion |
GridDhtTxFinishRequest.writeVersion() |
| Modifier and Type | Method and Description |
|---|---|
Map<IgniteTxKey,GridCacheVersion> |
GridDhtTxPrepareRequest.owned() |
IgniteBiTuple<GridCacheVersion,CacheObject> |
GridDhtCacheEntry.versionedValue(AffinityTopologyVersion topVer) |
Collection<GridCacheVersion> |
GridDhtTxOnePhaseCommitAckRequest.versions() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridDhtCacheEntry.clearInternal(GridCacheVersion ver,
GridCacheObsoleteEntryExtras extras)
Marks entry as obsolete and, if possible or required, removes it
from swap storage.
|
GridCacheMvccCandidate |
GridDhtCacheEntry.mappings(GridCacheVersion ver,
Collection<ClusterNode> dhtNodeIds,
Collection<ClusterNode> nearNodeIds)
Sets mappings into entry.
|
void |
GridDhtCacheAdapter.onDeferredDelete(GridCacheEntryEx entry,
GridCacheVersion ver) |
void |
GridDhtLocalPartition.onDeferredDelete(int cacheId,
KeyCacheObject key,
GridCacheVersion ver) |
void |
GridDhtTxPrepareRequest.owned(IgniteTxKey key,
GridCacheVersion ownerMapped)
Sets owner and its mapped version.
|
void |
GridDhtLockRequest.owned(KeyCacheObject key,
GridCacheVersion ownerMapped)
Sets owner and its mapped version.
|
boolean |
GridDhtCacheEntry.removeLock(GridCacheVersion ver) |
void |
GridDhtTransactionalCacheAdapter.removeLocks(UUID nodeId,
GridCacheVersion ver,
Iterable<KeyCacheObject> keys,
boolean unmap) |
void |
GridDhtCacheEntry.removeMapping(GridCacheVersion ver,
ClusterNode mappedNode) |
boolean |
GridDhtCacheEntry.tmLock(IgniteInternalTx tx,
long timeout,
GridCacheVersion serOrder,
GridCacheVersion serReadVer,
boolean read)
This locks is called by transaction manager during prepare step
for optimistic transactions.
|
void |
GridDhtTxFinishRequest.writeVersion(GridCacheVersion writeVer) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtTxLocalAdapter.pendingVersions(Collection<GridCacheVersion> pendingVers) |
| Constructor and Description |
|---|
GridDhtLockFuture(GridCacheContext<?,?> cctx,
UUID nearNodeId,
GridCacheVersion nearLockVer,
AffinityTopologyVersion topVer,
int cnt,
boolean read,
boolean needReturnVal,
long timeout,
GridDhtTxLocalAdapter tx,
long threadId,
long createTtl,
long accessTtl,
CacheEntryPredicate[] filter,
boolean skipStore,
boolean keepBinary) |
GridDhtLockRequest(int cacheId,
UUID nodeId,
GridCacheVersion nearXidVer,
long threadId,
IgniteUuid futId,
IgniteUuid miniId,
GridCacheVersion lockVer,
AffinityTopologyVersion topVer,
boolean isInTx,
boolean isRead,
TransactionIsolation isolation,
boolean isInvalidate,
long timeout,
int dhtCnt,
int nearCnt,
int txSize,
UUID subjId,
int taskNameHash,
long accessTtl,
boolean skipStore,
boolean storeUsed,
boolean keepBinary,
boolean addDepInfo) |
GridDhtLockResponse(int cacheId,
GridCacheVersion lockVer,
IgniteUuid futId,
IgniteUuid miniId,
int cnt,
boolean addDepInfo) |
GridDhtLockResponse(int cacheId,
GridCacheVersion lockVer,
IgniteUuid futId,
IgniteUuid miniId,
Throwable err,
boolean addDepInfo) |
GridDhtTxFinishRequest(UUID nearNodeId,
IgniteUuid futId,
int miniId,
AffinityTopologyVersion topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
long threadId,
TransactionIsolation isolation,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
boolean sysInvalidate,
CacheWriteSynchronizationMode syncMode,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers,
int txSize,
UUID subjId,
int taskNameHash,
boolean addDepInfo,
boolean retVal,
boolean waitRemoteTxs) |
GridDhtTxFinishRequest(UUID nearNodeId,
IgniteUuid futId,
int miniId,
AffinityTopologyVersion topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
long threadId,
TransactionIsolation isolation,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
boolean sysInvalidate,
CacheWriteSynchronizationMode syncMode,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers,
int txSize,
UUID subjId,
int taskNameHash,
boolean addDepInfo,
Collection<Long> updateIdxs,
boolean retVal,
boolean waitRemoteTxs) |
GridDhtTxFinishResponse(int part,
GridCacheVersion xid,
IgniteUuid futId,
int miniId) |
GridDhtTxLocal(GridCacheSharedContext cctx,
AffinityTopologyVersion topVer,
UUID nearNodeId,
GridCacheVersion nearXidVer,
IgniteUuid nearFutId,
int nearMiniId,
long nearThreadId,
boolean implicit,
boolean implicitSingle,
boolean sys,
boolean explicitLock,
byte plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean invalidate,
boolean storeEnabled,
boolean onePhaseCommit,
int txSize,
Map<UUID,Collection<UUID>> txNodes,
UUID subjId,
int taskNameHash) |
GridDhtTxLocalAdapter(GridCacheSharedContext cctx,
GridCacheVersion xidVer,
boolean implicit,
boolean implicitSingle,
boolean sys,
boolean explicitLock,
byte plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean invalidate,
boolean storeEnabled,
boolean onePhaseCommit,
int txSize,
UUID subjId,
int taskNameHash) |
GridDhtTxPrepareRequest(IgniteUuid futId,
int miniId,
AffinityTopologyVersion topVer,
GridDhtTxLocalAdapter tx,
long timeout,
Collection<IgniteTxEntry> dhtWrites,
Collection<IgniteTxEntry> nearWrites,
Map<UUID,Collection<UUID>> txNodes,
GridCacheVersion nearXidVer,
boolean last,
boolean onePhaseCommit,
UUID subjId,
int taskNameHash,
boolean addDepInfo,
boolean storeWriteThrough,
boolean retVal) |
GridDhtTxPrepareResponse(int part,
GridCacheVersion xid,
IgniteUuid futId,
int miniId,
boolean addDepInfo) |
GridDhtTxPrepareResponse(int part,
GridCacheVersion xid,
IgniteUuid futId,
int miniId,
Throwable err,
boolean addDepInfo) |
GridDhtTxRemote(GridCacheSharedContext ctx,
UUID nearNodeId,
IgniteUuid rmtFutId,
UUID nodeId,
AffinityTopologyVersion topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
byte plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
boolean invalidate,
long timeout,
int txSize,
GridCacheVersion nearXidVer,
Map<UUID,Collection<UUID>> txNodes,
UUID subjId,
int taskNameHash,
boolean single,
boolean storeWriteThrough)
This constructor is meant for optimistic transactions.
|
GridDhtTxRemote(GridCacheSharedContext ctx,
UUID nearNodeId,
IgniteUuid rmtFutId,
UUID nodeId,
GridCacheVersion nearXidVer,
AffinityTopologyVersion topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
byte plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
boolean invalidate,
long timeout,
int txSize,
UUID subjId,
int taskNameHash,
boolean storeWriteThrough)
This constructor is meant for pessimistic transactions.
|
| Constructor and Description |
|---|
GridDhtTxFinishRequest(UUID nearNodeId,
IgniteUuid futId,
int miniId,
AffinityTopologyVersion topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
long threadId,
TransactionIsolation isolation,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
boolean sysInvalidate,
CacheWriteSynchronizationMode syncMode,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers,
int txSize,
UUID subjId,
int taskNameHash,
boolean addDepInfo,
boolean retVal,
boolean waitRemoteTxs) |
GridDhtTxFinishRequest(UUID nearNodeId,
IgniteUuid futId,
int miniId,
AffinityTopologyVersion topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
long threadId,
TransactionIsolation isolation,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
boolean sysInvalidate,
CacheWriteSynchronizationMode syncMode,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers,
int txSize,
UUID subjId,
int taskNameHash,
boolean addDepInfo,
boolean retVal,
boolean waitRemoteTxs) |
GridDhtTxFinishRequest(UUID nearNodeId,
IgniteUuid futId,
int miniId,
AffinityTopologyVersion topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
long threadId,
TransactionIsolation isolation,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
boolean sysInvalidate,
CacheWriteSynchronizationMode syncMode,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers,
int txSize,
UUID subjId,
int taskNameHash,
boolean addDepInfo,
boolean retVal,
boolean waitRemoteTxs) |
GridDhtTxFinishRequest(UUID nearNodeId,
IgniteUuid futId,
int miniId,
AffinityTopologyVersion topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
long threadId,
TransactionIsolation isolation,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
boolean sysInvalidate,
CacheWriteSynchronizationMode syncMode,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers,
int txSize,
UUID subjId,
int taskNameHash,
boolean addDepInfo,
Collection<Long> updateIdxs,
boolean retVal,
boolean waitRemoteTxs) |
GridDhtTxFinishRequest(UUID nearNodeId,
IgniteUuid futId,
int miniId,
AffinityTopologyVersion topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
long threadId,
TransactionIsolation isolation,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
boolean sysInvalidate,
CacheWriteSynchronizationMode syncMode,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers,
int txSize,
UUID subjId,
int taskNameHash,
boolean addDepInfo,
Collection<Long> updateIdxs,
boolean retVal,
boolean waitRemoteTxs) |
GridDhtTxFinishRequest(UUID nearNodeId,
IgniteUuid futId,
int miniId,
AffinityTopologyVersion topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
long threadId,
TransactionIsolation isolation,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
boolean sysInvalidate,
CacheWriteSynchronizationMode syncMode,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers,
int txSize,
UUID subjId,
int taskNameHash,
boolean addDepInfo,
Collection<Long> updateIdxs,
boolean retVal,
boolean waitRemoteTxs) |
GridDhtTxOnePhaseCommitAckRequest(Collection<GridCacheVersion> vers) |
GridDhtTxPrepareFuture(GridCacheSharedContext cctx,
GridDhtTxLocalAdapter tx,
long timeout,
int nearMiniId,
Map<IgniteTxKey,GridCacheVersion> dhtVerMap,
boolean last,
boolean retVal) |
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheVersion |
GridDhtAtomicAbstractUpdateRequest.writeVer
Write version.
|
protected GridCacheVersion |
GridDhtAtomicAbstractUpdateFuture.writeVer
Write version.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
GridDhtAtomicUpdateRequest.conflictVersion(int idx) |
abstract GridCacheVersion |
GridDhtAtomicAbstractUpdateRequest.conflictVersion(int idx) |
GridCacheVersion |
GridNearAtomicFullUpdateRequest.conflictVersion(int idx) |
GridCacheVersion |
GridDhtAtomicSingleUpdateRequest.conflictVersion(int idx) |
abstract GridCacheVersion |
GridNearAtomicAbstractUpdateRequest.conflictVersion(int idx) |
GridCacheVersion |
GridNearAtomicSingleUpdateRequest.conflictVersion(int idx) |
GridCacheVersion |
GridNearAtomicUpdateResponse.nearVersion() |
GridCacheVersion |
GridDhtAtomicAbstractUpdateRequest.writeVersion() |
| Modifier and Type | Method and Description |
|---|---|
List<GridCacheVersion> |
GridNearAtomicFullUpdateRequest.conflictVersions() |
abstract List<GridCacheVersion> |
GridNearAtomicAbstractUpdateRequest.conflictVersions() |
List<GridCacheVersion> |
GridNearAtomicSingleUpdateRequest.conflictVersions() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridNearAtomicFullUpdateRequest.addUpdateEntry(KeyCacheObject key,
Object val,
long conflictTtl,
long conflictExpireTime,
GridCacheVersion conflictVer) |
void |
GridNearAtomicSingleUpdateInvokeRequest.addUpdateEntry(KeyCacheObject key,
Object val,
long conflictTtl,
long conflictExpireTime,
GridCacheVersion conflictVer) |
void |
GridNearAtomicSingleUpdateRequest.addUpdateEntry(KeyCacheObject key,
Object val,
long conflictTtl,
long conflictExpireTime,
GridCacheVersion conflictVer) |
void |
GridDhtAtomicUpdateRequest.addWriteValue(KeyCacheObject key,
CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long conflictExpireTime,
GridCacheVersion conflictVer,
boolean addPrevVal,
CacheObject prevVal,
long updateCntr) |
abstract void |
GridDhtAtomicAbstractUpdateRequest.addWriteValue(KeyCacheObject key,
CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long conflictExpireTime,
GridCacheVersion conflictVer,
boolean addPrevVal,
CacheObject prevVal,
long updateCntr) |
void |
GridDhtAtomicSingleUpdateRequest.addWriteValue(KeyCacheObject key,
CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long conflictExpireTime,
GridCacheVersion conflictVer,
boolean addPrevVal,
CacheObject prevVal,
long updateCntr) |
protected abstract GridDhtAtomicAbstractUpdateRequest |
GridDhtAtomicAbstractUpdateFuture.createRequest(UUID nodeId,
long futId,
GridCacheVersion writeVer,
CacheWriteSynchronizationMode syncMode,
AffinityTopologyVersion topVer,
long ttl,
long conflictExpireTime,
GridCacheVersion conflictVer) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtAtomicCache.removeAllConflict(Map<KeyCacheObject,GridCacheVersion> conflictMap)
Removes DR data.
|
IgniteInternalFuture<?> |
GridDhtAtomicCache.removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> conflictMap)
Removes DR data asynchronously.
|
| Constructor and Description |
|---|
GridDhtAtomicAbstractUpdateFuture(GridCacheContext cctx,
GridCacheVersion writeVer,
GridNearAtomicAbstractUpdateRequest updateReq) |
GridDhtAtomicAbstractUpdateRequest(int cacheId,
UUID nodeId,
long futId,
GridCacheVersion writeVer,
CacheWriteSynchronizationMode syncMode,
AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
boolean addDepInfo,
boolean keepBinary,
boolean skipStore)
Constructor.
|
GridDhtAtomicUpdateRequest(int cacheId,
UUID nodeId,
long futId,
GridCacheVersion writeVer,
CacheWriteSynchronizationMode syncMode,
AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
Object[] invokeArgs,
boolean addDepInfo,
boolean keepBinary,
boolean skipStore,
boolean forceTransformBackups)
Constructor.
|
| Constructor and Description |
|---|
GridNearAtomicUpdateFuture(GridCacheContext cctx,
GridDhtAtomicCache cache,
CacheWriteSynchronizationMode syncMode,
GridCacheOperation op,
Collection<?> keys,
Collection<?> vals,
Object[] invokeArgs,
Collection<GridCacheDrInfo> conflictPutVals,
Collection<GridCacheVersion> conflictRmvVals,
boolean retval,
boolean rawRetval,
javax.cache.expiry.ExpiryPolicy expiryPlc,
CacheEntryPredicate[] filter,
UUID subjId,
int taskNameHash,
boolean skipStore,
boolean keepBinary,
boolean recovery,
int remapCnt) |
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
GridDhtColocatedLockFuture.version() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridDhtDetachedCacheEntry.addRemoved(GridCacheVersion ver) |
protected void |
GridDhtDetachedCacheEntry.logUpdate(GridCacheOperation op,
CacheObject val,
GridCacheVersion writeVer,
long expireTime,
long updCntr) |
void |
GridDhtColocatedCache.removeLocks(long threadId,
GridCacheVersion ver,
Collection<KeyCacheObject> keys)
Removes locks regardless of whether they are owned or not for given
version and keys.
|
void |
GridDhtDetachedCacheEntry.resetFromPrimary(CacheObject val,
GridCacheVersion ver)
Sets value to detached entry so it can be retrieved in transactional gets.
|
protected boolean |
GridDhtDetachedCacheEntry.storeValue(CacheObject val,
long expireTime,
GridCacheVersion ver,
CacheDataRow oldRow)
Stores value in offheap.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
GridDhtPartitionsAbstractMessage.lastVersion() |
| Constructor and Description |
|---|
GridDhtPartitionsFullMessage(GridDhtPartitionExchangeId id,
GridCacheVersion lastVer,
AffinityTopologyVersion topVer,
IgniteDhtPartitionHistorySuppliersMap partHistSuppliers,
IgniteDhtPartitionsToReloadMap partsToReload) |
GridDhtPartitionsSingleMessage(GridDhtPartitionExchangeId exchId,
boolean client,
GridCacheVersion lastVer,
boolean compress) |
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
GridNearTxPrepareResponse.dhtVersion() |
GridCacheVersion |
GridNearCacheEntry.dhtVersion() |
GridCacheVersion |
GridNearLockRequest.dhtVersion(int idx) |
GridCacheVersion |
GridNearLockResponse.dhtVersion(int idx) |
GridCacheVersion |
GridNearLockResponse.mappedVersion(int idx)
Returns DHT candidate version for acquired near lock on DHT node.
|
GridCacheVersion |
GridNearTxRemote.nearXidVersion() |
GridCacheVersion |
GridNearTxLocal.nearXidVersion() |
GridCacheVersion |
GridNearTxRemote.ownedVersion(IgniteTxKey key)
Gets owned version for near remote transaction.
|
GridCacheVersion |
CacheVersionedValue.version() |
GridCacheVersion |
GridNearGetRequest.version() |
GridCacheVersion |
GridNearTxPrepareFutureAdapter.version() |
GridCacheVersion |
GridNearGetResponse.version() |
GridCacheVersion |
GridNearLockFuture.version() |
GridCacheVersion |
GridNearTxPrepareResponse.writeVersion() |
| Modifier and Type | Method and Description |
|---|---|
Collection<GridCacheVersion> |
GridNearTxPrepareResponse.pending()
Gets pending versions that are less than
GridDistributedBaseMessage.version(). |
Collection<GridCacheVersion> |
GridNearLockResponse.pending()
Gets pending versions that are less than
GridDistributedBaseMessage.version(). |
IgniteBiTuple<GridCacheVersion,CacheObject> |
GridNearCacheEntry.versionedValue() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridNearTxRemote.addEntry(GridCacheContext cacheCtx,
IgniteTxKey key,
GridCacheOperation op,
CacheObject val,
GridCacheVersion drVer,
boolean skipStore,
boolean keepBinary) |
void |
GridNearLockRequest.addKeyBytes(KeyCacheObject key,
boolean retVal,
GridCacheVersion dhtVer,
GridCacheContext ctx)
Adds a key.
|
GridCacheMvccCandidate |
GridNearCacheEntry.addLocal(long threadId,
GridCacheVersion ver,
AffinityTopologyVersion topVer,
long timeout,
boolean reenter,
boolean tx,
boolean implicitSingle,
boolean read)
Add local candidate.
|
void |
GridNearTxPrepareResponse.addOwnedValue(IgniteTxKey key,
GridCacheVersion ver,
CacheObject val)
Adds owned value.
|
void |
GridNearLockResponse.addValueBytes(CacheObject val,
boolean filterPassed,
GridCacheVersion dhtVer,
GridCacheVersion mappedVer) |
GridCacheMvccCandidate |
GridNearCacheEntry.dhtNodeId(GridCacheVersion ver,
UUID dhtNodeId) |
protected boolean |
GridNearTransactionalCache.evictNearEntry(GridCacheEntryEx e,
GridCacheVersion obsoleteVer,
AffinityTopologyVersion topVer) |
boolean |
GridNearCacheEntry.loadedValue(IgniteInternalTx tx,
UUID primaryNodeId,
CacheObject val,
GridCacheVersion ver,
GridCacheVersion dhtVer,
long ttl,
long expireTime,
boolean evt,
boolean keepBinary,
AffinityTopologyVersion topVer,
UUID subjId) |
protected void |
GridNearCacheEntry.logUpdate(GridCacheOperation op,
CacheObject val,
GridCacheVersion ver,
long expireTime,
long updCntr) |
void |
GridNearAtomicCache.onDeferredDelete(GridCacheEntryEx entry,
GridCacheVersion ver) |
void |
GridNearTransactionalCache.onDeferredDelete(GridCacheEntryEx entry,
GridCacheVersion ver) |
boolean |
GridNearCacheEntry.recordDhtVersion(GridCacheVersion dhtVer) |
void |
GridNearTransactionalCache.removeLocks(GridCacheVersion ver,
Collection<KeyCacheObject> keys)
Removes locks regardless of whether they are owned or not for given
version and keys.
|
boolean |
GridNearCacheEntry.resetFromPrimary(CacheObject val,
GridCacheVersion ver,
GridCacheVersion dhtVer,
UUID primaryNodeId,
AffinityTopologyVersion topVer)
This method should be called only when lock is owned on this entry.
|
protected boolean |
GridNearCacheEntry.storeValue(CacheObject val,
long expireTime,
GridCacheVersion ver,
CacheDataRow oldRow)
Stores value in offheap.
|
void |
GridNearCacheEntry.updateOrEvict(GridCacheVersion dhtVer,
CacheObject val,
long expireTime,
long ttl,
UUID primaryNodeId,
AffinityTopologyVersion topVer)
This method should be called only when lock is owned on this entry.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Void> |
GridNearTxLocal.loadMissing(GridCacheContext cacheCtx,
AffinityTopologyVersion topVer,
boolean readThrough,
boolean async,
Collection<KeyCacheObject> keys,
boolean skipVals,
boolean needVer,
boolean keepBinary,
boolean recovery,
javax.cache.expiry.ExpiryPolicy expiryPlc,
GridInClosure3<KeyCacheObject,Object,GridCacheVersion> c) |
void |
GridNearTxRemote.ownedVersions(Map<IgniteTxKey,GridCacheVersion> vers)
Adds owned versions to map.
|
void |
GridNearTxPrepareResponse.pending(Collection<GridCacheVersion> pending)
Sets pending versions that are less than
GridDistributedBaseMessage.version(). |
void |
GridNearLockResponse.pending(Collection<GridCacheVersion> pending)
Sets pending versions that are less than
GridDistributedBaseMessage.version(). |
void |
GridNearAtomicCache.removeAllConflict(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data.
|
IgniteInternalFuture<?> |
GridNearAtomicCache.removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
IgniteInternalFuture<?> |
GridNearTxLocal.removeAllDrAsync(GridCacheContext cacheCtx,
Map<KeyCacheObject,GridCacheVersion> drMap) |
| Constructor and Description |
|---|
CacheVersionedValue(CacheObject val,
GridCacheVersion ver) |
GridNearCacheClearAllRunnable(GridCacheAdapter<K,V> cache,
GridCacheVersion obsoleteVer,
GridCacheClearAllRunnable<K,V> dhtJob)
Constructor.
|
GridNearGetRequest(int cacheId,
IgniteUuid futId,
IgniteUuid miniId,
GridCacheVersion ver,
Map<KeyCacheObject,Boolean> keys,
boolean readThrough,
AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
long createTtl,
long accessTtl,
boolean addReader,
boolean skipVals,
boolean addDepInfo,
boolean recovery) |
GridNearGetResponse(int cacheId,
IgniteUuid futId,
IgniteUuid miniId,
GridCacheVersion ver,
boolean addDepInfo) |
GridNearLockRequest(int cacheId,
AffinityTopologyVersion topVer,
UUID nodeId,
long threadId,
IgniteUuid futId,
GridCacheVersion lockVer,
boolean isInTx,
boolean isRead,
boolean retVal,
TransactionIsolation isolation,
boolean isInvalidate,
long timeout,
int keyCnt,
int txSize,
boolean syncCommit,
UUID subjId,
int taskNameHash,
long createTtl,
long accessTtl,
boolean skipStore,
boolean keepBinary,
boolean firstClientReq,
boolean nearCache,
boolean addDepInfo) |
GridNearLockResponse(int cacheId,
GridCacheVersion lockVer,
IgniteUuid futId,
int miniId,
boolean filterRes,
int cnt,
Throwable err,
AffinityTopologyVersion clientRemapVer,
boolean addDepInfo) |
GridNearTxFinishRequest(IgniteUuid futId,
GridCacheVersion xidVer,
long threadId,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
CacheWriteSynchronizationMode syncMode,
boolean explicitLock,
boolean storeEnabled,
AffinityTopologyVersion topVer,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
int txSize,
UUID subjId,
int taskNameHash,
boolean addDepInfo) |
GridNearTxFinishResponse(int part,
GridCacheVersion xid,
long nearThreadId,
IgniteUuid futId,
int miniId,
Throwable err) |
GridNearTxPrepareResponse(int part,
GridCacheVersion xid,
IgniteUuid futId,
int miniId,
GridCacheVersion dhtVer,
GridCacheVersion writeVer,
GridCacheReturn retVal,
Throwable err,
AffinityTopologyVersion clientRemapVer,
boolean onePhaseCommit,
boolean addDepInfo) |
GridNearTxRemote(GridCacheSharedContext ctx,
AffinityTopologyVersion topVer,
ClassLoader ldr,
UUID nodeId,
UUID nearNodeId,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
byte plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
boolean invalidate,
long timeout,
Collection<IgniteTxEntry> writeEntries,
int txSize,
UUID subjId,
int taskNameHash)
This constructor is meant for optimistic transactions.
|
GridNearTxRemote(GridCacheSharedContext ctx,
AffinityTopologyVersion topVer,
UUID nodeId,
UUID nearNodeId,
GridCacheVersion nearXidVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
boolean sys,
byte plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
boolean invalidate,
long timeout,
int txSize,
UUID subjId,
int taskNameHash)
This constructor is meant for pessimistic transactions.
|
| Constructor and Description |
|---|
GridNearTxFinishRequest(IgniteUuid futId,
GridCacheVersion xidVer,
long threadId,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
CacheWriteSynchronizationMode syncMode,
boolean explicitLock,
boolean storeEnabled,
AffinityTopologyVersion topVer,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
int txSize,
UUID subjId,
int taskNameHash,
boolean addDepInfo) |
GridNearTxFinishRequest(IgniteUuid futId,
GridCacheVersion xidVer,
long threadId,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
CacheWriteSynchronizationMode syncMode,
boolean explicitLock,
boolean storeEnabled,
AffinityTopologyVersion topVer,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
int txSize,
UUID subjId,
int taskNameHash,
boolean addDepInfo) |
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
GridCacheDrInfo.version() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheDrManager.replicate(KeyCacheObject key,
CacheObject val,
long ttl,
long expireTime,
GridCacheVersion ver,
GridDrType drType,
AffinityTopologyVersion topVer)
Performs replication.
|
void |
GridOsCacheDrManager.replicate(KeyCacheObject key,
CacheObject val,
long ttl,
long expireTime,
GridCacheVersion ver,
GridDrType drType,
AffinityTopologyVersion topVer)
Performs replication.
|
| Constructor and Description |
|---|
GridCacheDrExpirationInfo(CacheObject val,
GridCacheVersion ver,
long ttl,
long expireTime)
Constructor.
|
GridCacheDrInfo(CacheObject val,
GridCacheVersion ver)
Constructor.
|
GridCacheDrInfo(javax.cache.processor.EntryProcessor proc,
GridCacheVersion ver)
Constructor.
|
GridCacheDrInfo(GridCacheVersion ver)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
GridCacheObsoleteEntryExtras.obsoleteVersion() |
GridCacheVersion |
GridCacheObsoleteTtlEntryExtras.obsoleteVersion() |
GridCacheVersion |
GridCacheMvccObsoleteTtlEntryExtras.obsoleteVersion() |
GridCacheVersion |
GridCacheEntryExtras.obsoleteVersion() |
GridCacheVersion |
GridCacheMvccObsoleteEntryExtras.obsoleteVersion() |
GridCacheVersion |
GridCacheAttributesMvccObsoleteTtlEntryExtras.obsoleteVersion() |
GridCacheVersion |
GridCacheAttributesObsoleteTtlEntryExtras.obsoleteVersion() |
GridCacheVersion |
GridCacheEntryExtrasAdapter.obsoleteVersion() |
GridCacheVersion |
GridCacheAttributesMvccObsoleteEntryExtras.obsoleteVersion() |
GridCacheVersion |
GridCacheAttributesObsoleteEntryExtras.obsoleteVersion() |
| Constructor and Description |
|---|
GridCacheObsoleteEntryExtras(GridCacheVersion obsoleteVer)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
GridLocalLockFuture.version() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridLocalCache.onDeferredDelete(GridCacheEntryEx entry,
GridCacheVersion ver) |
boolean |
GridLocalCacheEntry.removeLock(GridCacheVersion ver) |
boolean |
GridLocalCacheEntry.tmLock(IgniteInternalTx tx,
long timeout,
GridCacheVersion serOrder,
GridCacheVersion serReadVer,
boolean read)
This locks is called by transaction manager during prepare step
for optimistic transactions.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridLocalAtomicCache.onDeferredDelete(GridCacheEntryEx entry,
GridCacheVersion ver) |
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheVersion |
CacheDataRowAdapter.ver |
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
CacheDataRow.version() |
GridCacheVersion |
CacheDataRowAdapter.version() |
| Constructor and Description |
|---|
CacheDataRowAdapter(KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime) |
| Modifier and Type | Method and Description |
|---|---|
static GridCacheVersion |
CacheVersionIO.read(ByteBuffer buf,
boolean allowNull)
Reads GridCacheVersion instance from the given buffer.
|
static GridCacheVersion |
CacheVersionIO.read(long pageAddr,
boolean allowNull)
Reads GridCacheVersion instance from the given address.
|
| Modifier and Type | Method and Description |
|---|---|
static int |
CacheVersionIO.size(GridCacheVersion ver,
boolean allowNull) |
static void |
CacheVersionIO.write(ByteBuffer buf,
GridCacheVersion ver,
boolean allowNull) |
static void |
CacheVersionIO.write(long addr,
GridCacheVersion ver,
boolean allowNull) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
CacheStoreManager.put(IgniteInternalTx tx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver)
Puts key-value pair into storage.
|
boolean |
GridCacheStoreManagerAdapter.put(IgniteInternalTx tx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver)
Puts key-value pair into storage.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
CacheStoreManager.loadCache(GridInClosure3<KeyCacheObject,Object,GridCacheVersion> vis,
Object[] args)
Loads data from persistent store.
|
void |
CacheStoreManager.localStoreLoadAll(IgniteInternalTx tx,
Collection<? extends KeyCacheObject> keys,
GridInClosure3<KeyCacheObject,Object,GridCacheVersion> vis) |
boolean |
CacheStoreManager.putAll(IgniteInternalTx tx,
Map<? extends KeyCacheObject,IgniteBiTuple<? extends CacheObject,GridCacheVersion>> map)
Puts key-value pair into storage.
|
boolean |
GridCacheStoreManagerAdapter.putAll(IgniteInternalTx tx,
Map<? extends KeyCacheObject,IgniteBiTuple<? extends CacheObject,GridCacheVersion>> map)
Puts key-value pair into storage.
|
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheVersion |
IgniteTxAdapter.endVer
End version (a.k.a.
|
static GridCacheVersion |
IgniteTxEntry.GET_ENTRY_INVALID_VER_AFTER_GET |
static GridCacheVersion |
IgniteTxEntry.GET_ENTRY_INVALID_VER_UPDATED |
protected GridCacheVersion |
IgniteTxLocalAdapter.minVer
Minimal version encountered (either explicit lock or XID of this transaction).
|
static GridCacheVersion |
IgniteTxEntry.SER_READ_EMPTY_ENTRY_VER
Dummy version for non-existing entry read in SERIALIZABLE transaction.
|
static GridCacheVersion |
IgniteTxEntry.SER_READ_NOT_EMPTY_VER
Dummy version for any existing entry read in SERIALIZABLE transaction.
|
protected GridCacheVersion |
IgniteTxAdapter.startVer
Transaction counter value at the start of transaction.
|
protected GridCacheVersion |
IgniteTxAdapter.writeVer
Entries write version.
|
protected GridCacheVersion |
IgniteTxAdapter.xidVer
Transaction ID.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
IgniteInternalTx.commitVersion() |
GridCacheVersion |
IgniteTxAdapter.commitVersion() |
GridCacheVersion |
IgniteTxLocalAdapter.completedBase() |
GridCacheVersion |
IgniteTxEntry.conflictVersion() |
GridCacheVersion |
IgniteTxEntry.dhtVersion() |
GridCacheVersion |
IgniteTxEntry.entryReadVersion()
Gets stored entry version.
|
GridCacheVersion |
IgniteTxEntry.explicitVersion() |
GridCacheVersion |
IgniteTxManager.mappedVersion(GridCacheVersion from) |
GridCacheVersion |
IgniteTxLocalEx.minVersion() |
GridCacheVersion |
IgniteTxLocalAdapter.minVersion()
Gets minimum version present in transaction.
|
GridCacheVersion |
IgniteInternalTx.nearXidVersion() |
GridCacheVersion |
IgniteTxAdapter.nearXidVersion() |
GridCacheVersion |
IgniteInternalTx.ownedVersion(IgniteTxKey key)
Gets owned version for near remote transaction.
|
GridCacheVersion |
IgniteTxAdapter.ownedVersion(IgniteTxKey key)
Gets owned version for near remote transaction.
|
GridCacheVersion |
IgniteTxManager.txContextVersion()
Gets version of transaction in tx context or
null
if tx context is empty. |
GridCacheVersion |
TxLock.txId() |
GridCacheVersion |
IgniteInternalTx.writeVersion() |
GridCacheVersion |
IgniteTxAdapter.writeVersion() |
GridCacheVersion |
IgniteInternalTx.xidVersion() |
GridCacheVersion |
IgniteTxAdapter.xidVersion() |
| Modifier and Type | Method and Description |
|---|---|
Collection<GridCacheVersion> |
IgniteInternalTx.alternateVersions() |
Collection<GridCacheVersion> |
IgniteTxLocalAdapter.alternateVersions() |
Collection<GridCacheVersion> |
IgniteTxLocalAdapter.committedVersions() |
List<GridCacheVersion> |
TxDeadlock.cycle() |
Collection<GridCacheVersion> |
IgniteTxLocalAdapter.rolledbackVersions() |
IgnitePair<Collection<GridCacheVersion>> |
IgniteTxManager.versions(GridCacheVersion min) |
| Constructor and Description |
|---|
IgniteTxAdapter(GridCacheSharedContext<?,?> cctx,
GridCacheVersion xidVer,
boolean implicit,
boolean loc,
boolean sys,
byte plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean invalidate,
boolean storeEnabled,
boolean onePhaseCommit,
int txSize,
UUID subjId,
int taskNameHash) |
IgniteTxAdapter(GridCacheSharedContext<?,?> cctx,
UUID nodeId,
GridCacheVersion xidVer,
GridCacheVersion startVer,
long threadId,
boolean sys,
byte plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
int txSize,
UUID subjId,
int taskNameHash) |
IgniteTxEntry(GridCacheContext<?,?> ctx,
IgniteInternalTx tx,
GridCacheOperation op,
CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
Object[] invokeArgs,
long ttl,
GridCacheEntryEx entry,
CacheEntryPredicate[] filters,
GridCacheVersion conflictVer,
boolean skipStore,
boolean keepBinary,
boolean addReader)
This constructor is meant for local transactions.
|
IgniteTxEntry(GridCacheContext<?,?> ctx,
IgniteInternalTx tx,
GridCacheOperation op,
CacheObject val,
long ttl,
long conflictExpireTime,
GridCacheEntryEx entry,
GridCacheVersion conflictVer,
boolean skipStore,
boolean keepBinary)
This constructor is meant for remote transactions.
|
IgniteTxLocalAdapter(GridCacheSharedContext cctx,
GridCacheVersion xidVer,
boolean implicit,
boolean implicitSingle,
boolean sys,
byte plc,
TransactionConcurrency concurrency,
TransactionIsolation isolation,
long timeout,
boolean invalidate,
boolean storeEnabled,
boolean onePhaseCommit,
int txSize,
UUID subjId,
int taskNameHash) |
TxLock(GridCacheVersion txId,
UUID nearNodeId,
long threadId,
byte ownership) |
| Constructor and Description |
|---|
TxDeadlock(List<GridCacheVersion> cycle,
Map<GridCacheVersion,T2<UUID,Long>> txs,
Map<GridCacheVersion,Set<IgniteTxKey>> txLockedKeys,
Map<IgniteTxKey,Set<GridCacheVersion>> txRequestedKeys) |
TxDeadlock(List<GridCacheVersion> cycle,
Map<GridCacheVersion,T2<UUID,Long>> txs,
Map<GridCacheVersion,Set<IgniteTxKey>> txLockedKeys,
Map<IgniteTxKey,Set<GridCacheVersion>> txRequestedKeys) |
TxDeadlock(List<GridCacheVersion> cycle,
Map<GridCacheVersion,T2<UUID,Long>> txs,
Map<GridCacheVersion,Set<IgniteTxKey>> txLockedKeys,
Map<IgniteTxKey,Set<GridCacheVersion>> txRequestedKeys) |
TxDeadlock(List<GridCacheVersion> cycle,
Map<GridCacheVersion,T2<UUID,Long>> txs,
Map<GridCacheVersion,Set<IgniteTxKey>> txLockedKeys,
Map<IgniteTxKey,Set<GridCacheVersion>> txRequestedKeys) |
| Constructor and Description |
|---|
DataRow(KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
int part,
long expireTime,
int cacheId) |
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
PartitionEntryHashRecord.version() |
| Constructor and Description |
|---|
PartitionEntryHashRecord(int cacheId,
String cacheName,
KeyCacheObject key,
String keyStr,
byte[] keyBytes,
GridCacheVersion ver,
int valHash) |
PartitionEntryHashRecord(int cacheId,
String cacheName,
KeyCacheObject key,
String keyStr,
byte[] keyBytes,
GridCacheVersion ver,
int valHash,
CacheObject val,
String valStr,
byte[] valBytes) |
| Modifier and Type | Class and Description |
|---|---|
class |
GridCacheVersionEx
Extended cache version which also has additional DR version.
|
| Modifier and Type | Field and Description |
|---|---|
static GridCacheVersion |
GridCacheVersionManager.EVICT_VER |
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
GridCacheVersion.conflictVersion() |
GridCacheVersion |
GridCacheVersionEx.conflictVersion() |
GridCacheVersion |
GridCacheVersionManager.isolatedStreamerVersion()
Version for entries loaded with isolated streamer, should be less than any version generated
for entries update.
|
GridCacheVersion |
GridCacheVersionManager.last()
Gets last generated version without generating a new one.
|
GridCacheVersion |
GridCacheVersionManager.next() |
GridCacheVersion |
GridCacheVersionManager.next(AffinityTopologyVersion topVer)
Gets next version based on given topology version.
|
GridCacheVersion |
GridCacheVersionManager.next(byte dataCenterId) |
GridCacheVersion |
GridCacheVersionManager.next(GridCacheVersion ver)
Gets next version based on given cache version.
|
GridCacheVersion |
GridCacheVersionManager.nextForLoad()
Gets next version for cache store load and reload operations.
|
GridCacheVersion |
GridCacheVersionManager.nextForLoad(AffinityTopologyVersion topVer)
Gets next version for cache store load and reload operations.
|
GridCacheVersion |
GridCacheVersionManager.nextForLoad(GridCacheVersion ver)
Gets next version for cache store load and reload operations.
|
GridCacheVersion |
GridCacheVersionManager.onReceivedAndNext(UUID nodeId,
GridCacheVersion ver) |
GridCacheVersion |
GridCacheRawVersionedEntry.version() |
GridCacheVersion |
GridCachePlainVersionedEntry.version() |
GridCacheVersion |
GridCacheVersionable.version() |
GridCacheVersion |
GridCacheVersionAware.version()
Gets version.
|
| Modifier and Type | Method and Description |
|---|---|
int |
GridCacheVersion.compareTo(GridCacheVersion other) |
boolean |
GridCacheVersion.isGreater(GridCacheVersion ver) |
boolean |
GridCacheVersion.isGreaterEqual(GridCacheVersion ver) |
boolean |
GridCacheVersion.isLess(GridCacheVersion ver) |
boolean |
GridCacheVersion.isLessEqual(GridCacheVersion ver) |
GridCacheVersion |
GridCacheVersionManager.next(GridCacheVersion ver)
Gets next version based on given cache version.
|
GridCacheVersion |
GridCacheVersionManager.nextForLoad(GridCacheVersion ver)
Gets next version for cache store load and reload operations.
|
void |
GridCacheVersionManager.onReceived(UUID nodeId,
GridCacheVersion ver) |
GridCacheVersion |
GridCacheVersionManager.onReceivedAndNext(UUID nodeId,
GridCacheVersion ver) |
| Constructor and Description |
|---|
GridCacheLazyPlainVersionedEntry(GridCacheContext cctx,
KeyCacheObject keyObj,
CacheObject valObj,
long ttl,
long expireTime,
GridCacheVersion ver,
boolean keepBinary) |
GridCacheLazyPlainVersionedEntry(GridCacheContext cctx,
KeyCacheObject keyObj,
CacheObject valObj,
long ttl,
long expireTime,
GridCacheVersion ver,
boolean isStartVer,
boolean keepBinary) |
GridCachePlainVersionedEntry(K key,
V val,
long ttl,
long expireTime,
GridCacheVersion ver) |
GridCachePlainVersionedEntry(K key,
V val,
long ttl,
long expireTime,
GridCacheVersion ver,
boolean isStartVer) |
GridCacheRawVersionedEntry(byte[] keyBytes,
byte[] valBytes,
long ttl,
long expireTime,
GridCacheVersion ver)
Constructor used in receiver hub where marshalled key and value are available and we do not want to
unmarshal value.
|
GridCacheRawVersionedEntry(KeyCacheObject key,
CacheObject val,
long ttl,
long expireTime,
GridCacheVersion ver)
Constructor used for local store load when key and value are available.
|
GridCacheVersionEx(int topVer,
int nodeOrderDrId,
long order,
GridCacheVersion drVer)
Constructor.
|
GridCacheVersionEx(int topVer,
long order,
int nodeOrder,
byte dataCenterId,
GridCacheVersion drVer)
Constructor.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 2.5.0 Release Date : May 23 2018