| 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() |
| Constructor and Description |
|---|
DataEntry(int cacheId,
KeyCacheObject key,
@Nullable 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) |
LazyMvccDataEntry(GridCacheSharedContext cctx,
int cacheId,
byte keyType,
byte[] keyBytes,
byte valType,
byte[] valBytes,
GridCacheOperation op,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
long expireTime,
int partId,
long partCnt,
MvccVersion mvccVer) |
MvccDataEntry(int cacheId,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheOperation op,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
long expireTime,
int partId,
long partCnt,
MvccVersion mvccVer) |
MvccTxRecord(TransactionState state,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
@Nullable Map<Short,Collection<Short>> participatingNodes,
MvccVersion mvccVer) |
MvccTxRecord(TransactionState state,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
@Nullable Map<Short,Collection<Short>> participatingNodes,
MvccVersion mvccVer,
long ts) |
TxRecord(TransactionState state,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
@Nullable Map<Short,Collection<Short>> participatingNodes) |
TxRecord(TransactionState state,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
@Nullable 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) |
UnwrapMvccDataEntry(int cacheId,
KeyCacheObject key,
CacheObject val,
GridCacheOperation op,
GridCacheVersion nearXidVer,
GridCacheVersion writeVer,
long expireTime,
int partId,
long partCnt,
MvccVersion mvccVer,
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 |
GridCacheAdapter.nextVersion()
Gets next grid cache version.
|
GridCacheVersion |
GridCacheAdapter.nextVersion(byte dataCenterId)
Gets next grid cache version.
|
GridCacheVersion |
GridCacheEntryEx.obsoleteVersion() |
GridCacheVersion |
GridCacheMapEntry.obsoleteVersion() |
protected @Nullable GridCacheVersion |
GridCacheMapEntry.obsoleteVersionExtras() |
GridCacheVersion |
GridCacheMvccCandidate.otherVersion() |
@Nullable GridCacheVersion |
GridCacheMvccCandidate.ownerVersion() |
@Nullable GridCacheVersion |
GridCacheUpdateAtomicResult.removeVersion() |
@Nullable GridCacheVersion |
GridCacheMvccCandidate.serializableOrder() |
GridCacheVersion |
GridCacheMvccManager.unmapVersion(GridCacheVersion from) |
GridCacheVersion |
GridCacheEntryEx.version() |
GridCacheVersion |
CacheEntryImplEx.version()
Returns a comparable object representing the version of this cache entry.
|
GridCacheVersion |
GridCacheMapEntry.version() |
GridCacheVersion |
GridCacheEntryInfo.version() |
GridCacheVersion |
GridCacheMvccCandidate.version() |
GridCacheVersion |
GridCacheVersionedFuture.version() |
GridCacheVersion |
EntryGetResult.version() |
GridCacheVersion |
CacheEvictionEntry.version() |
| Modifier and Type | Method and Description |
|---|---|
static IgniteClosure<IgniteInternalTx,GridCacheVersion> |
GridCacheUtils.tx2xidVersion() |
| Modifier and Type | Method and Description |
|---|---|
@Nullable GridCacheMvccCandidate |
GridCacheMvcc.addLocal(GridCacheEntryEx parent,
long threadId,
GridCacheVersion ver,
long timeout,
boolean reenter,
boolean tx,
boolean implicitSingle,
boolean read) |
@Nullable GridCacheMvccCandidate |
GridCacheMvcc.addLocal(GridCacheEntryEx parent,
@Nullable UUID nearNodeId,
@Nullable GridCacheVersion nearVer,
long threadId,
GridCacheVersion ver,
long timeout,
@Nullable GridCacheVersion serOrder,
boolean reenter,
boolean tx,
boolean implicitSingle,
boolean dhtLoc,
boolean read) |
@Nullable GridCacheMvccCandidate |
GridCacheMvcc.addLocal(GridCacheEntryEx parent,
@Nullable UUID nearNodeId,
@Nullable GridCacheVersion nearVer,
long threadId,
GridCacheVersion ver,
long timeout,
@Nullable GridCacheVersion serOrder,
boolean reenter,
boolean tx,
boolean implicitSingle,
boolean dhtLoc,
boolean read) |
@Nullable GridCacheMvccCandidate |
GridCacheMvcc.addLocal(GridCacheEntryEx parent,
@Nullable UUID nearNodeId,
@Nullable GridCacheVersion nearVer,
long threadId,
GridCacheVersion ver,
long timeout,
@Nullable GridCacheVersion serOrder,
boolean reenter,
boolean tx,
boolean implicitSingle,
boolean dhtLoc,
boolean read) |
GridCacheMvccCandidate |
GridCacheMvcc.addNearLocal(GridCacheEntryEx parent,
UUID nodeId,
@Nullable 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,
@Nullable 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,
@Nullable EntryGetResult getRes,
GridCacheVersion ver,
long expireTime,
long ttl,
boolean needVer,
@Nullable ClassLoader ldr) |
<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,
@Nullable ClassLoader ldr) |
void |
CacheOffheapEvictionManager.batchEvict(Collection<?> keys,
@Nullable GridCacheVersion obsoleteVer) |
void |
GridCacheEvictionManager.batchEvict(Collection<?> keys,
@Nullable GridCacheVersion obsoleteVer) |
void |
CacheEvictionManager.batchEvict(Collection<?> keys,
@Nullable GridCacheVersion obsoleteVer) |
@Nullable GridCacheMvccCandidate |
GridCacheEntryEx.candidate(GridCacheVersion ver)
Gets lock candidate for given lock ID.
|
@Nullable GridCacheMvccCandidate |
GridCacheMapEntry.candidate(GridCacheVersion ver)
Gets lock candidate for given lock ID.
|
@Nullable GridCacheMvccCandidate |
GridCacheMvcc.candidate(GridCacheVersion ver)
Gets candidate for lock ID.
|
@Nullable GridCacheMvccCandidate |
GridCacheExplicitLockSpan.candidate(IgniteTxKey key,
@Nullable 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,
@Nullable GridDhtPartitionExchangeId exchId,
@Nullable GridCacheVersion lastVer,
@Nullable IgniteDhtPartitionHistorySuppliersMap partHistSuppliers,
@Nullable IgniteDhtPartitionsToReloadMap partsToReload)
Creates partitions full message for all cache groups.
|
GridDhtPartitionsFullMessage |
GridCachePartitionExchangeManager.createPartitionsFullMessage(boolean compress,
boolean newCntrMap,
@Nullable GridDhtPartitionExchangeId exchId,
@Nullable GridCacheVersion lastVer,
@Nullable IgniteDhtPartitionHistorySuppliersMap partHistSuppliers,
@Nullable IgniteDhtPartitionsToReloadMap partsToReload,
Collection<CacheGroupContext> grps)
Creates partitions full message for selected cache groups.
|
CacheDataRow |
IgniteCacheOffheapManager.CacheDataStore.createRow(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
@Nullable CacheDataRow oldRow) |
CacheDataRow |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.createRow(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
@Nullable 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,
@Nullable Map<ClusterNode,List<GridDhtCacheEntry>> nearMap) |
@Nullable CacheLockCandidates |
GridCacheMvcc.doneRemote(GridCacheVersion ver,
Collection<GridCacheVersion> pending,
Collection<GridCacheVersion> committed,
Collection<GridCacheVersion> rolledback)
Sets remote candidate to done.
|
boolean |
CacheOffheapEvictionManager.evict(@Nullable GridCacheEntryEx entry,
@Nullable GridCacheVersion obsoleteVer,
boolean explicit,
@Nullable CacheEntryPredicate[] filter) |
boolean |
GridCacheEvictionManager.evict(@Nullable GridCacheEntryEx entry,
@Nullable GridCacheVersion obsoleteVer,
boolean explicit,
@Nullable CacheEntryPredicate[] filter) |
boolean |
CacheEvictionManager.evict(@Nullable GridCacheEntryEx entry,
@Nullable GridCacheVersion obsoleteVer,
boolean explicit,
@Nullable CacheEntryPredicate[] filter) |
boolean |
GridCacheEntryEx.evictInternal(GridCacheVersion obsoleteVer,
@Nullable CacheEntryPredicate[] filter,
boolean evictOffheap) |
boolean |
GridCacheMapEntry.evictInternal(GridCacheVersion obsoleteVer,
@Nullable CacheEntryPredicate[] filter,
boolean evictOffheap) |
@Nullable GridCacheMvccCandidate |
GridCacheMvccManager.explicitLock(IgniteTxKey key,
@Nullable GridCacheVersion ver)
Gets explicit lock candidate added by any thread by given key and lock version.
|
void |
GridCacheSharedContext.finishDhtAtomicUpdate(GridCacheVersion ver) |
@Nullable 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) |
default 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
|
default boolean |
GridCacheEntryEx.initialValue(CacheObject val,
GridCacheVersion ver,
@Nullable MvccVersion mvccVer,
@Nullable MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType,
boolean fromStore)
Sets new value if current version is 0
|
boolean |
GridCacheEntryEx.initialValue(CacheObject val,
GridCacheVersion ver,
@Nullable MvccVersion mvccVer,
@Nullable MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType,
boolean fromStore,
@Nullable CacheDataRow row)
Sets new value if current version is 0
|
boolean |
GridCacheMapEntry.initialValue(CacheObject val,
GridCacheVersion ver,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType,
boolean fromStore,
CacheDataRow row)
Sets new value if current version is 0
|
CacheObject |
GridCacheEntryEx.innerGet(@Nullable GridCacheVersion ver,
@Nullable IgniteInternalTx tx,
boolean readThrough,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary) |
CacheObject |
GridCacheMapEntry.innerGet(@Nullable GridCacheVersion ver,
@Nullable IgniteInternalTx tx,
boolean readThrough,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
@Nullable IgniteCacheExpiryPolicy expirePlc,
boolean keepBinary) |
EntryGetResult |
GridCacheEntryEx.innerGetVersioned(@Nullable GridCacheVersion ver,
IgniteInternalTx tx,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
@Nullable ReaderArguments readerArgs) |
EntryGetResult |
GridCacheMapEntry.innerGetVersioned(@Nullable GridCacheVersion ver,
IgniteInternalTx tx,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
@Nullable ReaderArguments readerArgs) |
GridCacheUpdateTxResult |
GridCacheEntryEx.innerRemove(@Nullable IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
boolean retval,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
@Nullable CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
@Nullable GridCacheVersion explicitVer,
@Nullable UUID subjId,
String taskName,
@Nullable GridCacheVersion dhtVer,
@Nullable Long updateCntr) |
GridCacheUpdateTxResult |
GridCacheEntryEx.innerRemove(@Nullable IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
boolean retval,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
@Nullable CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
@Nullable GridCacheVersion explicitVer,
@Nullable UUID subjId,
String taskName,
@Nullable GridCacheVersion dhtVer,
@Nullable Long updateCntr) |
GridCacheUpdateTxResult |
GridCacheMapEntry.innerRemove(@Nullable IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
boolean retval,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
@Nullable CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
@Nullable GridCacheVersion explicitVer,
@Nullable UUID subjId,
String taskName,
@Nullable GridCacheVersion dhtVer,
@Nullable Long updateCntr) |
GridCacheUpdateTxResult |
GridCacheMapEntry.innerRemove(@Nullable IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
boolean retval,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
@Nullable CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
@Nullable GridCacheVersion explicitVer,
@Nullable UUID subjId,
String taskName,
@Nullable GridCacheVersion dhtVer,
@Nullable Long updateCntr) |
GridCacheUpdateTxResult |
GridCacheEntryEx.innerSet(@Nullable IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
@Nullable CacheObject val,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
@Nullable CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long drExpireTime,
@Nullable GridCacheVersion explicitVer,
@Nullable UUID subjId,
String taskName,
@Nullable GridCacheVersion dhtVer,
@Nullable Long updateCntr) |
GridCacheUpdateTxResult |
GridCacheEntryEx.innerSet(@Nullable IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
@Nullable CacheObject val,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
@Nullable CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long drExpireTime,
@Nullable GridCacheVersion explicitVer,
@Nullable UUID subjId,
String taskName,
@Nullable GridCacheVersion dhtVer,
@Nullable Long updateCntr) |
GridCacheUpdateTxResult |
GridCacheMapEntry.innerSet(@Nullable IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
CacheObject val,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
@Nullable CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long drExpireTime,
@Nullable GridCacheVersion explicitVer,
@Nullable UUID subjId,
String taskName,
@Nullable GridCacheVersion dhtVer,
@Nullable Long updateCntr) |
GridCacheUpdateTxResult |
GridCacheMapEntry.innerSet(@Nullable IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
CacheObject val,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
@Nullable CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long drExpireTime,
@Nullable GridCacheVersion explicitVer,
@Nullable UUID subjId,
String taskName,
@Nullable GridCacheVersion dhtVer,
@Nullable Long updateCntr) |
GridCacheUpdateAtomicResult |
GridCacheEntryEx.innerUpdate(GridCacheVersion ver,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
@Nullable Object val,
@Nullable Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
boolean retval,
boolean keepBinary,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
boolean primary,
boolean checkVer,
AffinityTopologyVersion topVer,
@Nullable CacheEntryPredicate[] filter,
GridDrType drType,
long conflictTtl,
long conflictExpireTime,
@Nullable GridCacheVersion conflictVer,
boolean conflictResolve,
boolean intercept,
@Nullable UUID subjId,
String taskName,
@Nullable CacheObject prevVal,
@Nullable Long updateCntr,
@Nullable GridDhtAtomicAbstractUpdateFuture fut,
boolean transformOp) |
GridCacheUpdateAtomicResult |
GridCacheEntryEx.innerUpdate(GridCacheVersion ver,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
@Nullable Object val,
@Nullable Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
boolean retval,
boolean keepBinary,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
boolean primary,
boolean checkVer,
AffinityTopologyVersion topVer,
@Nullable CacheEntryPredicate[] filter,
GridDrType drType,
long conflictTtl,
long conflictExpireTime,
@Nullable GridCacheVersion conflictVer,
boolean conflictResolve,
boolean intercept,
@Nullable UUID subjId,
String taskName,
@Nullable CacheObject prevVal,
@Nullable Long updateCntr,
@Nullable GridDhtAtomicAbstractUpdateFuture fut,
boolean transformOp) |
GridCacheUpdateAtomicResult |
GridCacheMapEntry.innerUpdate(GridCacheVersion newVer,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
@Nullable Object writeObj,
@Nullable Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
boolean retval,
boolean keepBinary,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
boolean primary,
boolean verCheck,
AffinityTopologyVersion topVer,
@Nullable CacheEntryPredicate[] filter,
GridDrType drType,
long explicitTtl,
long explicitExpireTime,
@Nullable GridCacheVersion conflictVer,
boolean conflictResolve,
boolean intercept,
@Nullable UUID subjId,
String taskName,
@Nullable CacheObject prevVal,
@Nullable Long updateCntr,
@Nullable GridDhtAtomicAbstractUpdateFuture fut,
boolean transformOp) |
GridCacheUpdateAtomicResult |
GridCacheMapEntry.innerUpdate(GridCacheVersion newVer,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
@Nullable Object writeObj,
@Nullable Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
boolean retval,
boolean keepBinary,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
boolean primary,
boolean verCheck,
AffinityTopologyVersion topVer,
@Nullable CacheEntryPredicate[] filter,
GridDrType drType,
long explicitTtl,
long explicitExpireTime,
@Nullable GridCacheVersion conflictVer,
boolean conflictResolve,
boolean intercept,
@Nullable UUID subjId,
String taskName,
@Nullable CacheObject prevVal,
@Nullable Long updateCntr,
@Nullable GridDhtAtomicAbstractUpdateFuture fut,
boolean transformOp) |
GridTuple3<Boolean,Object,javax.cache.processor.EntryProcessorResult<Object>> |
GridCacheEntryEx.innerUpdateLocal(GridCacheVersion ver,
GridCacheOperation op,
@Nullable Object writeObj,
@Nullable Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
boolean retval,
boolean keepBinary,
@Nullable javax.cache.expiry.ExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
@Nullable CacheEntryPredicate[] filter,
boolean intercept,
@Nullable UUID subjId,
String taskName,
boolean transformOp)
Update method for local cache in atomic mode.
|
GridTuple3<Boolean,Object,javax.cache.processor.EntryProcessorResult<Object>> |
GridCacheMapEntry.innerUpdateLocal(GridCacheVersion ver,
GridCacheOperation op,
@Nullable Object writeObj,
@Nullable Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
boolean retval,
boolean keepBinary,
@Nullable javax.cache.expiry.ExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
@Nullable CacheEntryPredicate[] filter,
boolean intercept,
@Nullable UUID subjId,
String taskName,
boolean transformOp)
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 |
GridCacheMvccCandidate.isHeldByThreadOrVer(long threadId,
GridCacheVersion ver)
Is lock held by the thread or cache version.
|
boolean |
GridCacheMvccManager.isRemoved(GridCacheContext cacheCtx,
GridCacheVersion ver) |
@Nullable GridCacheMvccCandidate |
GridCacheMvcc.localCandidateByThreadOrVer(UUID nodeId,
long threadId,
GridCacheVersion ver)
Local candidate.
|
List<GridCacheMvccCandidate> |
GridCacheMvcc.localCandidates(boolean reentries,
GridCacheVersion... excludeVers) |
Collection<GridCacheMvccCandidate> |
GridCacheEntryEx.localCandidates(GridCacheVersion... exclude)
Gets all local candidates.
|
Collection<GridCacheMvccCandidate> |
GridCacheMapEntry.localCandidates(GridCacheVersion... exclude)
Gets all local candidates.
|
Collection<GridCacheMvccCandidate> |
GridCacheMvcc.localCandidates(GridCacheVersion... excludeVers) |
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(@Nullable GridCacheVersion ver)
Sets obsolete flag if entry value is
null or entry is expired and no
locks are held. |
boolean |
GridCacheMapEntry.markObsoleteIfEmpty(@Nullable 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.
|
void |
IgniteCacheOffheapManager.mvccApplyUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
GridDhtLocalPartition part,
MvccVersion mvccVer) |
void |
IgniteCacheOffheapManagerImpl.mvccApplyUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
GridDhtLocalPartition part,
MvccVersion mvccVer) |
void |
IgniteCacheOffheapManager.CacheDataStore.mvccApplyUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer) |
void |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccApplyUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer) |
boolean |
IgniteCacheOffheapManager.CacheDataStore.mvccInitialValue(GridCacheContext cctx,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
boolean |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccInitialValue(GridCacheContext cctx,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
boolean |
IgniteCacheOffheapManager.mvccInitialValue(GridCacheMapEntry entry,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
boolean |
IgniteCacheOffheapManagerImpl.mvccInitialValue(GridCacheMapEntry entry,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
MvccUpdateResult |
IgniteCacheOffheapManager.CacheDataStore.mvccUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot,
@Nullable CacheEntryPredicate filter,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs,
boolean primary,
boolean needHist,
boolean noCreate,
boolean needOldVal,
boolean retVal,
boolean keepBinary) |
MvccUpdateResult |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot,
@Nullable CacheEntryPredicate filter,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs,
boolean primary,
boolean needHistory,
boolean noCreate,
boolean needOldVal,
boolean retVal,
boolean keepBinary) |
MvccUpdateResult |
IgniteCacheOffheapManager.mvccUpdate(GridCacheMapEntry entry,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot,
boolean primary,
boolean needHist,
boolean noCreate,
boolean needOldVal,
@Nullable CacheEntryPredicate filter,
boolean retVal,
boolean keepBinary,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs) |
MvccUpdateResult |
IgniteCacheOffheapManagerImpl.mvccUpdate(GridCacheMapEntry entry,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccSnapshot,
boolean primary,
boolean needHistory,
boolean noCreate,
boolean needOldVal,
@Nullable CacheEntryPredicate filter,
boolean retVal,
boolean keepBinary,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs) |
boolean |
IgniteCacheOffheapManager.CacheDataStore.mvccUpdateRowWithPreloadInfo(GridCacheContext cctx,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState)
Apply update with full history.
|
boolean |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.mvccUpdateRowWithPreloadInfo(GridCacheContext cctx,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState)
Apply update with full history.
|
boolean |
IgniteCacheOffheapManager.mvccUpdateRowWithPreloadInfo(GridCacheMapEntry entry,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState)
Apply update with full history.
|
boolean |
IgniteCacheOffheapManagerImpl.mvccUpdateRowWithPreloadInfo(GridCacheMapEntry entry,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState)
Apply update with full history.
|
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.
|
@Nullable CacheLockCandidates |
GridCacheMvcc.readyLocal(GridCacheVersion ver) |
@Nullable 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,
@Nullable GridCacheVersion ver)
Removes lock by key and optional version.
|
GridCacheMvccCandidate |
GridCacheMvccManager.removeExplicitLock(long threadId,
IgniteTxKey key,
@Nullable GridCacheVersion ver)
Removes explicit lock for given thread id, key and optional version.
|
boolean |
GridCacheEntryEx.removeLock(GridCacheVersion ver) |
void |
GridCacheMvcc.salvageRemote(GridCacheVersion ver,
boolean near)
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(@Nullable CacheObject val,
long expireTime,
GridCacheVersion ver)
Stores value in offheap.
|
protected boolean |
GridCacheMapEntry.storeValue(@Nullable CacheObject val,
long expireTime,
GridCacheVersion ver,
@Nullable IgnitePredicate<CacheDataRow> predicate,
@Nullable CacheDataRow row)
Stores value in off-heap.
|
boolean |
GridCacheEntryEx.tmLock(IgniteInternalTx tx,
long timeout,
@Nullable GridCacheVersion serOrder,
@Nullable GridCacheVersion serReadVer,
boolean read)
This locks is called by transaction manager during prepare step
for optimistic transactions.
|
boolean |
GridCacheEntryEx.tmLock(IgniteInternalTx tx,
long timeout,
@Nullable GridCacheVersion serOrder,
@Nullable 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,
@Nullable Collection<UUID> rdrs) |
void |
IgniteCacheExpiryPolicy.ttlUpdated(KeyCacheObject key,
GridCacheVersion ver,
@Nullable Collection<UUID> rdrs)
Callback for ttl update on entry access.
|
GridCacheVersion |
GridCacheMvccManager.unmapVersion(GridCacheVersion from) |
protected void |
GridCacheMapEntry.update(@Nullable CacheObject val,
long expireTime,
long ttl,
GridCacheVersion ver,
boolean addTracked) |
void |
IgniteCacheOffheapManager.CacheDataStore.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
@Nullable CacheDataRow oldRow) |
void |
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
@Nullable CacheDataRow oldRow) |
void |
IgniteCacheOffheapManager.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
GridDhtLocalPartition part,
@Nullable CacheDataRow oldRow) |
void |
IgniteCacheOffheapManagerImpl.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
GridDhtLocalPartition part,
@Nullable CacheDataRow oldRow) |
void |
GridCacheEntryEx.updateTtl(@Nullable GridCacheVersion ver,
long ttl) |
void |
GridCacheMapEntry.updateTtl(@Nullable GridCacheVersion ver,
long ttl) |
@Nullable CacheObject |
GridCacheEntryEx.valueBytes(@Nullable GridCacheVersion ver)
Gets cached serialized value bytes.
|
@Nullable CacheObject |
GridCacheMapEntry.valueBytes(@Nullable GridCacheVersion ver)
Gets cached serialized value bytes.
|
void |
GridCacheEntryInfo.version(GridCacheVersion ver) |
@Nullable GridCacheVersionedFuture<?> |
GridCacheMvccManager.versionedFuture(GridCacheVersion ver,
IgniteUuid futId)
Gets future for given future ID and lock ID.
|
EntryGetResult |
GridCacheEntryEx.versionedValue(CacheObject val,
@Nullable GridCacheVersion curVer,
@Nullable GridCacheVersion newVer,
@Nullable IgniteCacheExpiryPolicy loadExpiryPlc,
@Nullable ReaderArguments readerArgs)
Sets new value if passed in version matches the current version
(used for read-through only).
|
EntryGetResult |
GridCacheEntryEx.versionedValue(CacheObject val,
@Nullable GridCacheVersion curVer,
@Nullable GridCacheVersion newVer,
@Nullable IgniteCacheExpiryPolicy loadExpiryPlc,
@Nullable 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,
@Nullable IgniteCacheExpiryPolicy loadExpiryPlc,
@Nullable ReaderArguments readerArgs)
Sets new value if passed in version matches the current version
(used for read-through only).
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable CacheLockCandidates |
GridCacheMvcc.doneRemote(GridCacheVersion ver,
Collection<GridCacheVersion> pending,
Collection<GridCacheVersion> committed,
Collection<GridCacheVersion> rolledback)
Sets remote candidate to done.
|
@Nullable CacheLockCandidates |
GridCacheMvcc.doneRemote(GridCacheVersion ver,
Collection<GridCacheVersion> pending,
Collection<GridCacheVersion> committed,
Collection<GridCacheVersion> rolledback)
Sets remote candidate to done.
|
@Nullable 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.
|
@Nullable 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.
|
@Nullable 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.
|
@Nullable 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 |
IgniteInternalCache.removeAllConflict(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data.
|
void |
GridCacheProxyImpl.removeAllConflict(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data.
|
IgniteInternalFuture<?> |
GridCacheAdapter.removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
IgniteInternalFuture<?> |
IgniteInternalCache.removeAllConflictAsync(Map<KeyCacheObject,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
IgniteInternalFuture<?> |
GridCacheProxyImpl.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,
@Nullable CacheObject valObj,
GridCacheVersion ver,
boolean keepBinary,
GridCacheEntryEx entry)
Constructor.
|
CacheInvokeEntry(KeyCacheObject keyObj,
K key,
@Nullable 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,
@Nullable UUID otherNodeId,
@Nullable GridCacheVersion otherVer,
long threadId,
GridCacheVersion ver,
boolean loc,
boolean reentry,
boolean tx,
boolean singleImplicit,
boolean nearLoc,
boolean dhtLoc,
@Nullable GridCacheVersion serOrder,
boolean read) |
GridCacheMvccCandidate(GridCacheEntryEx parent,
UUID nodeId,
@Nullable UUID otherNodeId,
@Nullable GridCacheVersion otherVer,
long threadId,
GridCacheVersion ver,
boolean loc,
boolean reentry,
boolean tx,
boolean singleImplicit,
boolean nearLoc,
boolean dhtLoc,
@Nullable GridCacheVersion serOrder,
boolean read) |
GridCacheMvccCandidate(GridCacheEntryEx parent,
UUID nodeId,
@Nullable UUID otherNodeId,
@Nullable GridCacheVersion otherVer,
long threadId,
GridCacheVersion ver,
boolean loc,
boolean reentry,
boolean tx,
boolean singleImplicit,
boolean nearLoc,
boolean dhtLoc,
@Nullable 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() |
@Nullable 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,
@Nullable GridCacheVersion dhtVer)
Adds version to be verified on remote node.
|
void |
GridCacheTtlUpdateRequest.addEntry(KeyCacheObject key,
GridCacheVersion ver) |
@Nullable 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,
@Nullable UUID otherNodeId,
long threadId,
GridCacheVersion ver,
boolean tx,
boolean implicitSingle,
@Nullable GridCacheVersion owned)
Adds new lock candidate.
|
void |
GridDistributedCacheEntry.addRemote(UUID nodeId,
@Nullable UUID otherNodeId,
long threadId,
GridCacheVersion ver,
boolean tx,
boolean implicitSingle,
@Nullable 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,
@Nullable Collection<GridCacheVersion> pendingVers,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
boolean sysInvalidate) |
@Nullable 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.
|
boolean |
GridDistributedCacheEntry.recheck(GridCacheVersion ver)
Rechecks if lock should be reassigned.
|
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,
@Nullable GridCacheVersion serOrder,
GridCacheVersion serReadVer,
boolean read)
This locks is called by transaction manager during prepare step
for optimistic transactions.
|
boolean |
GridDistributedCacheEntry.tmLock(IgniteInternalTx tx,
long timeout,
@Nullable 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,
@Nullable Collection<GridCacheVersion> pendingVers,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
boolean sysInvalidate) |
void |
GridDistributedCacheEntry.doneRemote(GridCacheVersion lockVer,
GridCacheVersion baseVer,
@Nullable 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,
@Nullable 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) |
GridDistributedLockRequest(int cacheId,
UUID nodeId,
@Nullable 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,
@NotNull AffinityTopologyVersion topVer,
@Nullable GridCacheVersion commitVer,
long threadId,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
CacheWriteSynchronizationMode syncMode,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
@Nullable UUID subjId,
int taskNameHash,
int txSize,
boolean addDepInfo) |
GridDistributedTxFinishRequest(GridCacheVersion xidVer,
IgniteUuid futId,
@NotNull AffinityTopologyVersion topVer,
@Nullable GridCacheVersion commitVer,
long threadId,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
CacheWriteSynchronizationMode syncMode,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
@Nullable 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,
@Nullable UUID subjId,
int taskNameHash,
String txLbl) |
| Constructor and Description |
|---|
GridDistributedTxFinishRequest(GridCacheVersion xidVer,
IgniteUuid futId,
@NotNull AffinityTopologyVersion topVer,
@Nullable GridCacheVersion commitVer,
long threadId,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
CacheWriteSynchronizationMode syncMode,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
@Nullable UUID subjId,
int taskNameHash,
int txSize,
boolean addDepInfo) |
GridDistributedTxFinishRequest(GridCacheVersion xidVer,
IgniteUuid futId,
@NotNull AffinityTopologyVersion topVer,
@Nullable GridCacheVersion commitVer,
long threadId,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
CacheWriteSynchronizationMode syncMode,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
@Nullable UUID subjId,
int taskNameHash,
int txSize,
boolean addDepInfo) |
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheVersion |
GridDhtTxAbstractEnlistFuture.lockVer
Lock version.
|
protected GridCacheVersion |
GridDhtTxAbstractEnlistFuture.nearLockVer
Near lock version.
|
| Modifier and Type | Field and Description |
|---|---|
protected Collection<GridCacheVersion> |
GridDhtTxOnePhaseCommitAckRequest.vers
Lock or transaction versions.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable GridCacheVersion |
GridDhtLockFuture.mappedVersion()
Mapping should occur only if this interface returns a non-null value.
|
GridCacheVersion |
GridDhtTxLocal.mappedVersion()
Mapping should occur only if this interface returns a non-null value.
|
GridCacheVersion |
GridDhtLockFuture.nearLockVersion() |
GridCacheVersion |
GridDhtTxQueryFirstEnlistRequest.nearXidVersion() |
GridCacheVersion |
GridDhtTxRemote.nearXidVersion() |
GridCacheVersion |
GridDhtTxPrepareRequest.nearXidVersion() |
GridCacheVersion |
GridDhtTxLocal.nearXidVersion() |
@Nullable GridCacheVersion |
GridDhtLockRequest.owned(KeyCacheObject key) |
GridCacheVersion |
GridDhtTxQueryEnlistRequest.version() |
GridCacheVersion |
GridDhtTxPrepareFuture.version() |
GridCacheVersion |
GridDhtGetFuture.version() |
GridCacheVersion |
GridDhtGetSingleFuture.version() |
GridCacheVersion |
GridDhtLockFuture.version() |
GridCacheVersion |
GridDhtTxFinishRequest.writeVersion() |
| Modifier and Type | Method and Description |
|---|---|
Map<IgniteTxKey,GridCacheVersion> |
GridDhtTxPrepareRequest.owned() |
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.
|
GridDhtTxLocal |
GridDhtTransactionalCacheAdapter.initTxTopologyVersion(UUID nodeId,
ClusterNode nearNode,
GridCacheVersion nearLockVer,
IgniteUuid nearFutId,
int nearMiniId,
boolean firstClientReq,
AffinityTopologyVersion topVer,
long nearThreadId,
long timeout,
UUID txSubjectId,
int txTaskNameHash,
MvccSnapshot snapshot) |
@Nullable GridCacheMvccCandidate |
GridDhtCacheEntry.mappings(GridCacheVersion ver,
Collection<ClusterNode> dhtNodeIds,
Collection<ClusterNode> nearNodeIds)
Sets mappings into entry.
|
void |
GridDhtCacheAdapter.onDeferredDelete(GridCacheEntryEx entry,
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,
@Nullable GridCacheVersion serOrder,
GridCacheVersion serReadVer,
boolean read)
This locks is called by transaction manager during prepare step
for optimistic transactions.
|
boolean |
GridDhtCacheEntry.tmLock(IgniteInternalTx tx,
long timeout,
@Nullable 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,
@NotNull 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,
@NotNull AffinityTopologyVersion topVer,
boolean isInTx,
boolean isRead,
TransactionIsolation isolation,
boolean isInvalidate,
long timeout,
int dhtCnt,
int nearCnt,
int txSize,
@Nullable UUID subjId,
int taskNameHash,
long accessTtl,
boolean skipStore,
boolean storeUsed,
boolean keepBinary,
boolean addDepInfo,
String txLbl) |
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) |
GridDhtTxAbstractEnlistFuture(UUID nearNodeId,
GridCacheVersion nearLockVer,
MvccSnapshot mvccSnapshot,
long threadId,
IgniteUuid nearFutId,
int nearMiniId,
GridDhtTxLocalAdapter tx,
long timeout,
GridCacheContext<?,?> cctx,
@Nullable CacheEntryPredicate filter,
boolean keepBinary) |
GridDhtTxEnlistFuture(UUID nearNodeId,
GridCacheVersion nearLockVer,
MvccSnapshot mvccSnapshot,
long threadId,
IgniteUuid nearFutId,
int nearMiniId,
GridDhtTxLocalAdapter tx,
long timeout,
GridCacheContext<?,?> cctx,
Collection<Object> rows,
EnlistOperation op,
@Nullable CacheEntryPredicate filter,
boolean needRes,
boolean keepBinary)
Constructor.
|
GridDhtTxFinishRequest(UUID nearNodeId,
IgniteUuid futId,
int miniId,
@NotNull 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,
@Nullable UUID subjId,
int taskNameHash,
boolean addDepInfo,
boolean retVal,
boolean waitRemoteTxs,
MvccSnapshot mvccSnapshot,
Collection<PartitionUpdateCountersMessage> updCntrs) |
GridDhtTxFinishRequest(UUID nearNodeId,
IgniteUuid futId,
int miniId,
@NotNull 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,
@Nullable UUID subjId,
int taskNameHash,
boolean addDepInfo,
Collection<Long> updateIdxs,
boolean retVal,
boolean waitRemoteTxs,
MvccSnapshot mvccSnapshot,
Collection<PartitionUpdateCountersMessage> updCntrs) |
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,
@Nullable String lb,
GridNearTxLocal parentTx) |
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,
@Nullable 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,
MvccSnapshot mvccSnapshot,
Collection<PartitionUpdateCountersMessage> updCntrs) |
GridDhtTxPrepareResponse(int part,
GridCacheVersion xid,
IgniteUuid futId,
int miniId,
boolean addDepInfo) |
GridDhtTxPrepareResponse(int part,
GridCacheVersion xid,
IgniteUuid futId,
int miniId,
Throwable err,
boolean addDepInfo) |
GridDhtTxQueryAbstractEnlistFuture(UUID nearNodeId,
GridCacheVersion nearLockVer,
MvccSnapshot mvccSnapshot,
long threadId,
IgniteUuid nearFutId,
int nearMiniId,
GridDhtTxLocalAdapter tx,
long timeout,
GridCacheContext<?,?> cctx)
Constructor.
|
GridDhtTxQueryEnlistFuture(UUID nearNodeId,
GridCacheVersion nearLockVer,
MvccSnapshot mvccSnapshot,
long threadId,
IgniteUuid nearFutId,
int nearMiniId,
GridDhtTxLocalAdapter tx,
int[] cacheIds,
int[] parts,
String schema,
String qry,
Object[] params,
int flags,
int pageSize,
long timeout,
GridCacheContext<?,?> cctx) |
GridDhtTxQueryResultsEnlistFuture(UUID nearNodeId,
GridCacheVersion nearLockVer,
MvccSnapshot mvccSnapshot,
long threadId,
IgniteUuid nearFutId,
int nearMiniId,
GridDhtTxLocalAdapter tx,
long timeout,
GridCacheContext<?,?> cctx,
Collection<Object> rows,
EnlistOperation op) |
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,
@Nullable UUID subjId,
int taskNameHash,
boolean single,
boolean storeWriteThrough,
@Nullable String txLbl)
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,
@Nullable UUID subjId,
int taskNameHash,
boolean storeWriteThrough,
@Nullable String txLbl)
This constructor is meant for pessimistic transactions.
|
| Constructor and Description |
|---|
GridDhtTxFinishRequest(UUID nearNodeId,
IgniteUuid futId,
int miniId,
@NotNull 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,
@Nullable UUID subjId,
int taskNameHash,
boolean addDepInfo,
boolean retVal,
boolean waitRemoteTxs,
MvccSnapshot mvccSnapshot,
Collection<PartitionUpdateCountersMessage> updCntrs) |
GridDhtTxFinishRequest(UUID nearNodeId,
IgniteUuid futId,
int miniId,
@NotNull 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,
@Nullable UUID subjId,
int taskNameHash,
boolean addDepInfo,
boolean retVal,
boolean waitRemoteTxs,
MvccSnapshot mvccSnapshot,
Collection<PartitionUpdateCountersMessage> updCntrs) |
GridDhtTxFinishRequest(UUID nearNodeId,
IgniteUuid futId,
int miniId,
@NotNull 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,
@Nullable UUID subjId,
int taskNameHash,
boolean addDepInfo,
boolean retVal,
boolean waitRemoteTxs,
MvccSnapshot mvccSnapshot,
Collection<PartitionUpdateCountersMessage> updCntrs) |
GridDhtTxFinishRequest(UUID nearNodeId,
IgniteUuid futId,
int miniId,
@NotNull 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,
@Nullable UUID subjId,
int taskNameHash,
boolean addDepInfo,
Collection<Long> updateIdxs,
boolean retVal,
boolean waitRemoteTxs,
MvccSnapshot mvccSnapshot,
Collection<PartitionUpdateCountersMessage> updCntrs) |
GridDhtTxFinishRequest(UUID nearNodeId,
IgniteUuid futId,
int miniId,
@NotNull 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,
@Nullable UUID subjId,
int taskNameHash,
boolean addDepInfo,
Collection<Long> updateIdxs,
boolean retVal,
boolean waitRemoteTxs,
MvccSnapshot mvccSnapshot,
Collection<PartitionUpdateCountersMessage> updCntrs) |
GridDhtTxFinishRequest(UUID nearNodeId,
IgniteUuid futId,
int miniId,
@NotNull 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,
@Nullable UUID subjId,
int taskNameHash,
boolean addDepInfo,
Collection<Long> updateIdxs,
boolean retVal,
boolean waitRemoteTxs,
MvccSnapshot mvccSnapshot,
Collection<PartitionUpdateCountersMessage> updCntrs) |
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 |
GridDhtAtomicAbstractUpdateFuture.writeVer
Write version.
|
protected GridCacheVersion |
GridDhtAtomicAbstractUpdateRequest.writeVer
Write version.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable GridCacheVersion |
GridDhtAtomicUpdateRequest.conflictVersion(int idx) |
@Nullable GridCacheVersion |
GridNearAtomicFullUpdateRequest.conflictVersion(int idx) |
@Nullable GridCacheVersion |
GridNearAtomicSingleUpdateRequest.conflictVersion(int idx) |
abstract @Nullable GridCacheVersion |
GridNearAtomicAbstractUpdateRequest.conflictVersion(int idx) |
@Nullable GridCacheVersion |
GridDhtAtomicSingleUpdateRequest.conflictVersion(int idx) |
abstract @Nullable GridCacheVersion |
GridDhtAtomicAbstractUpdateRequest.conflictVersion(int idx) |
GridCacheVersion |
GridNearAtomicUpdateResponse.nearVersion() |
GridCacheVersion |
GridDhtAtomicAbstractUpdateRequest.writeVersion() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridNearAtomicFullUpdateRequest.addUpdateEntry(KeyCacheObject key,
@Nullable Object val,
long conflictTtl,
long conflictExpireTime,
@Nullable GridCacheVersion conflictVer) |
void |
GridNearAtomicSingleUpdateRequest.addUpdateEntry(KeyCacheObject key,
@Nullable Object val,
long conflictTtl,
long conflictExpireTime,
@Nullable GridCacheVersion conflictVer) |
void |
GridNearAtomicSingleUpdateInvokeRequest.addUpdateEntry(KeyCacheObject key,
@Nullable Object val,
long conflictTtl,
long conflictExpireTime,
@Nullable GridCacheVersion conflictVer) |
void |
GridDhtAtomicUpdateRequest.addWriteValue(KeyCacheObject key,
@Nullable CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long conflictExpireTime,
@Nullable GridCacheVersion conflictVer,
boolean addPrevVal,
@Nullable CacheObject prevVal,
long updateCntr,
GridCacheOperation cacheOp) |
void |
GridDhtAtomicSingleUpdateRequest.addWriteValue(KeyCacheObject key,
@Nullable CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long conflictExpireTime,
@Nullable GridCacheVersion conflictVer,
boolean addPrevVal,
@Nullable CacheObject prevVal,
long updateCntr,
GridCacheOperation cacheOp) |
abstract void |
GridDhtAtomicAbstractUpdateRequest.addWriteValue(KeyCacheObject key,
@Nullable CacheObject val,
javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor,
long ttl,
long conflictExpireTime,
@Nullable GridCacheVersion conflictVer,
boolean addPrevVal,
@Nullable CacheObject prevVal,
long updateCntr,
GridCacheOperation cacheOp) |
protected abstract GridDhtAtomicAbstractUpdateRequest |
GridDhtAtomicAbstractUpdateFuture.createRequest(UUID nodeId,
long futId,
GridCacheVersion writeVer,
CacheWriteSynchronizationMode syncMode,
@NotNull AffinityTopologyVersion topVer,
long ttl,
long conflictExpireTime,
@Nullable GridCacheVersion conflictVer) |
protected abstract GridDhtAtomicAbstractUpdateRequest |
GridDhtAtomicAbstractUpdateFuture.createRequest(UUID nodeId,
long futId,
GridCacheVersion writeVer,
CacheWriteSynchronizationMode syncMode,
@NotNull AffinityTopologyVersion topVer,
long ttl,
long conflictExpireTime,
@Nullable 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,
@NotNull AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
boolean addDepInfo,
boolean keepBinary,
boolean skipStore)
Constructor.
|
GridDhtAtomicUpdateRequest(int cacheId,
UUID nodeId,
long futId,
GridCacheVersion writeVer,
CacheWriteSynchronizationMode syncMode,
@NotNull AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
Object[] invokeArgs,
boolean addDepInfo,
boolean keepBinary,
boolean skipStore,
boolean forceTransformBackups)
Constructor.
|
| 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)
Stores value in offheap.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable GridCacheVersion |
GridDhtPartitionsAbstractMessage.lastVersion() |
| Constructor and Description |
|---|
GridDhtPartitionsFullMessage(@Nullable GridDhtPartitionExchangeId id,
@Nullable GridCacheVersion lastVer,
@NotNull AffinityTopologyVersion topVer,
@Nullable IgniteDhtPartitionHistorySuppliersMap partHistSuppliers,
@Nullable IgniteDhtPartitionsToReloadMap partsToReload) |
GridDhtPartitionsSingleMessage(GridDhtPartitionExchangeId exchId,
boolean client,
@Nullable GridCacheVersion lastVer,
boolean compress) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtLocalPartition.onDeferredDelete(int cacheId,
KeyCacheObject key,
GridCacheVersion ver) |
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheVersion |
GridNearTxAbstractEnlistFuture.lockVer
Lock version.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
GridNearTxQueryResultsEnlistResponse.dhtVersion() |
@Nullable GridCacheVersion |
GridNearCacheEntry.dhtVersion() |
GridCacheVersion |
GridNearTxPrepareResponse.dhtVersion() |
GridCacheVersion |
GridNearTxEnlistResponse.dhtVersion() |
GridCacheVersion |
GridNearLockResponse.dhtVersion(int idx) |
GridCacheVersion |
GridNearLockRequest.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 |
GridNearTxQueryEnlistRequest.version() |
GridCacheVersion |
GridNearTxQueryEnlistResponse.version() |
GridCacheVersion |
GridNearTxQueryResultsEnlistRequest.version() |
GridCacheVersion |
GridNearLockFuture.version() |
GridCacheVersion |
GridNearGetResponse.version() |
GridCacheVersion |
GridNearTxPrepareFutureAdapter.version() |
GridCacheVersion |
GridNearGetRequest.version() |
GridCacheVersion |
GridNearTxEnlistResponse.version() |
GridCacheVersion |
CacheVersionedValue.version() |
GridCacheVersion |
GridNearTxEnlistRequest.version() |
GridCacheVersion |
GridNearTxAbstractEnlistFuture.version() |
GridCacheVersion |
GridNearTxPrepareResponse.writeVersion() |
| Modifier and Type | Method and Description |
|---|---|
Collection<GridCacheVersion> |
GridNearLockResponse.pending()
Gets pending versions that are less than
GridDistributedBaseMessage.version(). |
Collection<GridCacheVersion> |
GridNearTxPrepareResponse.pending()
Gets pending versions that are less than
GridDistributedBaseMessage.version(). |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridNearTxRemote.addEntry(GridCacheContext cacheCtx,
IgniteTxKey key,
GridCacheOperation op,
CacheObject val,
@Nullable GridCacheVersion drVer,
boolean skipStore,
boolean keepBinary) |
void |
GridNearLockRequest.addKeyBytes(KeyCacheObject key,
boolean retVal,
@Nullable 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(@Nullable CacheObject val,
boolean filterPassed,
@Nullable GridCacheVersion dhtVer,
@Nullable GridCacheVersion mappedVer) |
void |
GridNearLockResponse.addValueBytes(@Nullable CacheObject val,
boolean filterPassed,
@Nullable GridCacheVersion dhtVer,
@Nullable GridCacheVersion mappedVer) |
@Nullable GridCacheMvccCandidate |
GridNearCacheEntry.dhtNodeId(GridCacheVersion ver,
UUID dhtNodeId) |
protected boolean |
GridNearTransactionalCache.evictNearEntry(GridCacheEntryEx e,
GridCacheVersion obsoleteVer,
AffinityTopologyVersion topVer) |
boolean |
GridNearCacheEntry.loadedValue(@Nullable 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)
Stores value in offheap.
|
void |
GridNearCacheEntry.updateOrEvict(GridCacheVersion dhtVer,
@Nullable 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 |
|---|---|
void |
GridNearTxRemote.ownedVersions(Map<IgniteTxKey,GridCacheVersion> vers)
Adds owned versions to map.
|
void |
GridNearLockResponse.pending(Collection<GridCacheVersion> pending)
Sets pending versions that are less than
GridDistributedBaseMessage.version(). |
void |
GridNearTxPrepareResponse.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,
@NotNull AffinityTopologyVersion topVer,
UUID subjId,
int taskNameHash,
long createTtl,
long accessTtl,
boolean addReader,
boolean skipVals,
boolean addDepInfo,
boolean recovery,
@Nullable String txLbl,
@Nullable MvccSnapshot mvccSnapshot) |
GridNearGetResponse(int cacheId,
IgniteUuid futId,
IgniteUuid miniId,
GridCacheVersion ver,
boolean addDepInfo) |
GridNearLockRequest(int cacheId,
@NotNull 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,
@Nullable UUID subjId,
int taskNameHash,
long createTtl,
long accessTtl,
boolean skipStore,
boolean keepBinary,
boolean firstClientReq,
boolean nearCache,
boolean addDepInfo,
@Nullable String txLbl) |
GridNearLockResponse(int cacheId,
GridCacheVersion lockVer,
IgniteUuid futId,
int miniId,
boolean filterRes,
int cnt,
Throwable err,
AffinityTopologyVersion clientRemapVer,
boolean addDepInfo,
boolean compatibleRemapVer) |
GridNearTxEnlistResponse(int cacheId,
IgniteUuid futId,
int miniId,
GridCacheVersion lockVer,
GridCacheReturn res,
GridCacheVersion dhtVer,
IgniteUuid dhtFutId,
Set<UUID> newDhtNodes)
Constructor for normal result.
|
GridNearTxEnlistResponse(int cacheId,
IgniteUuid futId,
int miniId,
GridCacheVersion lockVer,
Throwable err)
Constructor for error result.
|
GridNearTxFinishRequest(IgniteUuid futId,
GridCacheVersion xidVer,
long threadId,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
CacheWriteSynchronizationMode syncMode,
boolean explicitLock,
boolean storeEnabled,
@NotNull AffinityTopologyVersion topVer,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
int txSize,
@Nullable UUID subjId,
int taskNameHash,
MvccSnapshot mvccSnapshot,
boolean addDepInfo) |
GridNearTxFinishResponse(int part,
GridCacheVersion xid,
long nearThreadId,
IgniteUuid futId,
int miniId,
@Nullable 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) |
GridNearTxQueryEnlistRequest(int cacheId,
long threadId,
IgniteUuid futId,
int miniId,
UUID subjId,
AffinityTopologyVersion topVer,
GridCacheVersion lockVer,
MvccSnapshot mvccSnapshot,
int[] cacheIds,
int[] parts,
String schema,
String qry,
Object[] params,
int flags,
int pageSize,
long timeout,
long txTimeout,
int taskNameHash,
boolean clientFirst) |
GridNearTxQueryEnlistResponse(int cacheId,
IgniteUuid futId,
int miniId,
GridCacheVersion lockVer,
long res,
boolean removeMapping,
Set<UUID> newDhtNodes) |
GridNearTxQueryEnlistResponse(int cacheId,
IgniteUuid futId,
int miniId,
GridCacheVersion lockVer,
Throwable err) |
GridNearTxQueryResultsEnlistResponse(int cacheId,
IgniteUuid futId,
int miniId,
GridCacheVersion lockVer,
long res,
GridCacheVersion dhtVer,
IgniteUuid dhtFutId,
Set<UUID> newDhtNodes) |
GridNearTxQueryResultsEnlistResponse(int cacheId,
IgniteUuid futId,
int miniId,
GridCacheVersion lockVer,
Throwable err) |
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,
@Nullable UUID subjId,
int taskNameHash,
@Nullable String txLbl)
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,
@Nullable UUID subjId,
int taskNameHash,
@Nullable String txLbl)
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,
@NotNull AffinityTopologyVersion topVer,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
int txSize,
@Nullable UUID subjId,
int taskNameHash,
MvccSnapshot mvccSnapshot,
boolean addDepInfo) |
GridNearTxFinishRequest(IgniteUuid futId,
GridCacheVersion xidVer,
long threadId,
boolean commit,
boolean invalidate,
boolean sys,
byte plc,
CacheWriteSynchronizationMode syncMode,
boolean explicitLock,
boolean storeEnabled,
@NotNull AffinityTopologyVersion topVer,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
int txSize,
@Nullable UUID subjId,
int taskNameHash,
MvccSnapshot mvccSnapshot,
boolean addDepInfo) |
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
GridCacheDrInfo.version() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridOsCacheDrManager.replicate(KeyCacheObject key,
@Nullable CacheObject val,
long ttl,
long expireTime,
GridCacheVersion ver,
GridDrType drType,
AffinityTopologyVersion topVer)
Performs replication.
|
void |
GridCacheDrManager.replicate(KeyCacheObject key,
@Nullable 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 |
GridCacheAttributesMvccObsoleteTtlEntryExtras.obsoleteVersion() |
GridCacheVersion |
GridCacheEntryExtrasAdapter.obsoleteVersion() |
GridCacheVersion |
GridCacheAttributesObsoleteEntryExtras.obsoleteVersion() |
GridCacheVersion |
GridCacheAttributesObsoleteTtlEntryExtras.obsoleteVersion() |
GridCacheVersion |
GridCacheAttributesMvccObsoleteEntryExtras.obsoleteVersion() |
@Nullable GridCacheVersion |
GridCacheEntryExtras.obsoleteVersion() |
GridCacheVersion |
GridCacheObsoleteEntryExtras.obsoleteVersion() |
GridCacheVersion |
GridCacheObsoleteTtlEntryExtras.obsoleteVersion() |
GridCacheVersion |
GridCacheMvccObsoleteTtlEntryExtras.obsoleteVersion() |
GridCacheVersion |
GridCacheMvccObsoleteEntryExtras.obsoleteVersion() |
| Constructor and Description |
|---|
GridCacheObsoleteEntryExtras(GridCacheVersion obsoleteVer)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
GridLocalCache.nextVersion()
Gets next grid cache version.
|
GridCacheVersion |
GridLocalLockFuture.version() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridLocalCache.onDeferredDelete(GridCacheEntryEx entry,
GridCacheVersion ver) |
boolean |
GridLocalCacheEntry.recheck(GridCacheVersion ver)
Rechecks if lock should be reassigned.
|
boolean |
GridLocalCacheEntry.removeLock(GridCacheVersion ver) |
boolean |
GridLocalCacheEntry.tmLock(IgniteInternalTx tx,
long timeout,
@Nullable GridCacheVersion serOrder,
GridCacheVersion serReadVer,
boolean read)
This locks is called by transaction manager during prepare step
for optimistic transactions.
|
boolean |
GridLocalCacheEntry.tmLock(IgniteInternalTx tx,
long timeout,
@Nullable 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 | Method and Description |
|---|---|
GridCacheVersion |
DeadlockProbe.initiatorVersion() |
GridCacheVersion |
ProbedTx.nearXidVersion() |
GridCacheVersion |
MvccTxEntry.version() |
GridCacheVersion |
ProbedTx.xidVersion() |
| Modifier and Type | Method and Description |
|---|---|
void |
MvccCachingManager.addEnlisted(KeyCacheObject key,
@Nullable CacheObject val,
long ttl,
long expireTime,
GridCacheVersion ver,
CacheObject oldVal,
boolean primary,
AffinityTopologyVersion topVer,
MvccVersion mvccVer,
int cacheId,
IgniteInternalTx tx,
IgniteUuid futId,
int batchNum)
Adds enlisted tx entry to cache.
|
static @Nullable GridNearTxLocal |
MvccUtils.tx(GridKernalContext ctx,
@Nullable GridCacheVersion txId) |
| Constructor and Description |
|---|
DeadlockProbe(GridCacheVersion initiatorVer,
Collection<ProbedTx> waitChain,
ProbedTx blocker,
boolean nearCheck) |
MvccTxEntry(KeyCacheObject key,
@Nullable CacheObject val,
long ttl,
long expireTime,
GridCacheVersion ver,
CacheObject oldVal,
boolean primary,
AffinityTopologyVersion topVer,
MvccVersion mvccVer,
int cacheId) |
ProbedTx(UUID nodeId,
GridCacheVersion xidVer,
GridCacheVersion nearXidVer,
long startTime,
int lockCntr) |
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheVersion |
CacheDataRowAdapter.ver |
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
CacheDataRowAdapter.version() |
GridCacheVersion |
CacheDataRow.version() |
| Modifier and Type | Method and Description |
|---|---|
CacheDataRow |
GridCacheOffheapManager.GridCacheDataStore.createRow(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
@Nullable CacheDataRow oldRow) |
void |
GridCacheOffheapManager.GridCacheDataStore.mvccApplyUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer) |
boolean |
GridCacheOffheapManager.GridCacheDataStore.mvccInitialValue(GridCacheContext cctx,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
MvccUpdateResult |
GridCacheOffheapManager.GridCacheDataStore.mvccUpdate(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccSnapshot mvccVer,
CacheEntryPredicate filter,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs,
boolean primary,
boolean needHistory,
boolean noCreate,
boolean needOldVal,
boolean retVal,
boolean keepBinary) |
boolean |
GridCacheOffheapManager.GridCacheDataStore.mvccUpdateRowWithPreloadInfo(GridCacheContext cctx,
KeyCacheObject key,
@Nullable CacheObject val,
GridCacheVersion ver,
long expireTime,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState)
Apply update with full history.
|
void |
GridCacheOffheapManager.GridCacheDataStore.update(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime,
@Nullable CacheDataRow oldRow) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridCacheOffheapManager.expire(GridCacheContext cctx,
IgniteInClosure2X<GridCacheEntryEx,GridCacheVersion> c,
int amount) |
int |
GridCacheOffheapManager.GridCacheDataStore.purgeExpired(GridCacheContext cctx,
IgniteInClosure2X<GridCacheEntryEx,GridCacheVersion> c,
long throttlingTimeout,
int amount)
Try to remove expired entries from data store.
|
| Constructor and Description |
|---|
CacheDataRowAdapter(KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
long expireTime) |
DataRowCacheAware(KeyCacheObject key,
@Nullable CacheObject val,
GridCacheVersion ver,
int part,
long expireTime,
int cacheId,
boolean storeCacheId) |
| 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 |
GridCacheStoreManagerAdapter.put(@Nullable IgniteInternalTx tx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver)
Puts key-value pair into storage.
|
boolean |
CacheStoreManager.put(@Nullable 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(@Nullable IgniteInternalTx tx,
Collection<? extends KeyCacheObject> keys,
GridInClosure3<KeyCacheObject,Object,GridCacheVersion> vis) |
boolean |
GridCacheStoreManagerAdapter.putAll(@Nullable IgniteInternalTx tx,
Map<? extends KeyCacheObject,IgniteBiTuple<? extends CacheObject,GridCacheVersion>> map)
Puts key-value pair into storage.
|
boolean |
CacheStoreManager.putAll(@Nullable IgniteInternalTx tx,
Map<? extends KeyCacheObject,IgniteBiTuple<? extends CacheObject,GridCacheVersion>> map)
Puts key-value pair into storage.
|
| Modifier and Type | Field and Description |
|---|---|
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.writeVer
Entries write version.
|
protected GridCacheVersion |
IgniteTxAdapter.xidVer
Transaction ID.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
IgniteTxAdapter.commitVersion() |
GridCacheVersion |
IgniteInternalTx.commitVersion() |
GridCacheVersion |
IgniteTxLocalAdapter.completedBase() |
@Nullable GridCacheVersion |
IgniteTxEntry.conflictVersion() |
GridCacheVersion |
IgniteTxEntry.dhtVersion() |
@Nullable 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.
|
@Nullable GridCacheVersion |
IgniteTxAdapter.nearXidVersion() |
@Nullable GridCacheVersion |
IgniteInternalTx.nearXidVersion() |
GridCacheVersion |
IgniteTxAdapter.ownedVersion(IgniteTxKey key)
Gets owned version for near remote transaction.
|
@Nullable GridCacheVersion |
IgniteInternalTx.ownedVersion(IgniteTxKey key)
Gets owned version for near remote transaction.
|
@Nullable GridCacheVersion |
IgniteTxManager.txContextVersion()
Gets version of transaction in tx context or
null
if tx context is empty. |
GridCacheVersion |
TxLock.txId() |
GridCacheVersion |
IgniteTxAdapter.writeVersion() |
GridCacheVersion |
IgniteInternalTx.writeVersion() |
GridCacheVersion |
IgniteTxAdapter.xidVersion() |
GridCacheVersion |
IgniteInternalTx.xidVersion() |
| Modifier and Type | Method and Description |
|---|---|
Collection<GridCacheVersion> |
IgniteTxLocalAdapter.alternateVersions() |
Collection<GridCacheVersion> |
IgniteInternalTx.alternateVersions() |
Collection<GridCacheVersion> |
IgniteTxLocalAdapter.committedVersions() |
List<GridCacheVersion> |
TxDeadlock.cycle() |
Collection<GridCacheVersion> |
IgniteTxLocalAdapter.rolledbackVersions() |
IgnitePair<Collection<GridCacheVersion>> |
IgniteTxManager.versions(GridCacheVersion min) |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteTxManager.addAlternateVersion(GridCacheVersion ver,
IgniteInternalTx tx) |
boolean |
IgniteTxManager.addCommittedTx(IgniteInternalTx tx,
GridCacheVersion xidVer,
@Nullable GridCacheVersion nearXidVer) |
boolean |
IgniteTxManager.addCommittedTx(IgniteInternalTx tx,
GridCacheVersion xidVer,
@Nullable GridCacheVersion nearXidVer) |
IgniteTxEntry |
IgniteTxLocalAdapter.addEntry(GridCacheOperation op,
@Nullable CacheObject val,
@Nullable javax.cache.processor.EntryProcessor entryProcessor,
Object[] invokeArgs,
GridCacheEntryEx entry,
@Nullable javax.cache.expiry.ExpiryPolicy expiryPlc,
CacheEntryPredicate[] filter,
boolean filtersSet,
long drTtl,
long drExpireTime,
@Nullable GridCacheVersion drVer,
boolean skipStore,
boolean keepBinary,
boolean addReader) |
protected void |
IgniteTxLocalAdapter.addInvokeResult(IgniteTxEntry txEntry,
CacheObject cacheVal,
GridCacheReturn ret,
GridCacheVersion ver) |
boolean |
IgniteTxManager.addRolledbackTx(IgniteInternalTx tx,
GridCacheVersion xidVer) |
void |
IgniteTxAdapter.commitVersion(GridCacheVersion commitVer) |
void |
IgniteInternalTx.commitVersion(GridCacheVersion commitVer) |
void |
IgniteTxAdapter.completedVersions(GridCacheVersion base,
Collection<GridCacheVersion> committed,
Collection<GridCacheVersion> txs) |
void |
IgniteTxLocalAdapter.completedVersions(GridCacheVersion completedBase,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers) |
void |
IgniteInternalTx.completedVersions(GridCacheVersion base,
Collection<GridCacheVersion> committed,
Collection<GridCacheVersion> rolledback) |
protected IgniteBiTuple<GridCacheOperation,GridCacheVersionConflictContext> |
IgniteTxAdapter.conflictResolve(GridCacheOperation op,
IgniteTxEntry txEntry,
CacheObject newVal,
GridCacheVersion newVer,
GridCacheEntryEx old)
Resolve DR conflict.
|
void |
IgniteTxEntry.conflictVersion(@Nullable GridCacheVersion conflictVer) |
void |
IgniteTxEntry.dhtVersion(GridCacheVersion dhtVer) |
void |
IgniteTxRemoteEx.doneRemote(GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers) |
void |
IgniteTxEntry.entryReadVersion(GridCacheVersion ver) |
void |
IgniteTxEntry.explicitVersion(GridCacheVersion explicitVer) |
GridCacheReturnCompletableWrapper |
IgniteTxManager.getCommittedTxReturn(GridCacheVersion xidVer) |
void |
IgniteTxRemoteStateImpl.invalidPartition(int cacheId,
int part,
GridCacheVersion version) |
void |
IgniteTxRemoteState.invalidPartition(int cacheId,
int part,
GridCacheVersion ver) |
void |
IgniteTxRemoteSingleStateImpl.invalidPartition(int cacheId,
int part,
GridCacheVersion ver) |
GridCacheVersion |
IgniteTxManager.mappedVersion(GridCacheVersion from) |
<T extends IgniteInternalTx> |
IgniteTxManager.nearTx(GridCacheVersion txId) |
Boolean |
IgniteTxManager.peekCompletedVersionsHistory(GridCacheVersion xid)
Peeks completed versions history map to find out whether transaction was committed or rolled back
in the recent past.
|
IgniteInternalFuture<?> |
IgniteTxManager.remoteTxFinishFuture(GridCacheVersion nearVer) |
void |
IgniteTxManager.removeTxReturn(GridCacheVersion xidVer) |
void |
IgniteTxManager.sendDeferredAckResponse(UUID nodeId,
GridCacheVersion ver) |
<T extends IgniteInternalTx> |
IgniteTxManager.tx(GridCacheVersion txId) |
IgniteInternalFuture<Boolean> |
IgniteTxManager.txCommitted(GridCacheVersion xidVer) |
@Nullable IgniteInternalFuture<Boolean> |
IgniteTxManager.txsPreparedOrCommitted(GridCacheVersion nearVer,
int txNum)
Checks if transactions with given near version ID was prepared or committed.
|
IgnitePair<Collection<GridCacheVersion>> |
IgniteTxManager.versions(GridCacheVersion min) |
void |
IgniteTxAdapter.writeVersion(GridCacheVersion writeVer)
Sets write version.
|
void |
IgniteInternalTx.writeVersion(GridCacheVersion ver)
Sets write version.
|
| 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,
@Nullable 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,
@Nullable 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,
@Nullable 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,
@Nullable 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) |
| Constructor and Description |
|---|
MvccDataRow(KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
int part,
long expireTime,
int cacheId,
MvccVersion mvccVer,
MvccVersion newMvccVer) |
MvccUpdateDataRow(GridCacheContext cctx,
KeyCacheObject key,
CacheObject val,
GridCacheVersion ver,
int part,
long expireTime,
MvccSnapshot mvccSnapshot,
MvccVersion newVer,
@Nullable CacheEntryPredicate filter,
boolean primary,
boolean lockOnly,
boolean needHist,
boolean fastUpdate,
boolean needOldVal,
boolean needPrevValue) |
| 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 |
GridCacheVersionEx.conflictVersion() |
GridCacheVersion |
GridCacheVersion.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 ver)
Gets next version based on given cache version.
|
GridCacheVersion |
GridCacheVersionManager.next(long topVer)
Gets next version based on given topology version.
|
GridCacheVersion |
GridCacheVersionManager.next(long topVer,
byte dataCenterId)
Gets next version based on given topology version.
|
GridCacheVersion |
GridCacheVersionManager.nextForLoad()
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.nextForLoad(long topVer)
Gets next version for cache store load and reload operations.
|
GridCacheVersion |
GridCacheVersionManager.onReceivedAndNext(UUID nodeId,
GridCacheVersion ver) |
GridCacheVersion |
GridCacheVersionManager.startVersion()
Gets start version.
|
GridCacheVersion |
GridCachePlainVersionedEntry.version() |
GridCacheVersion |
GridCacheVersionable.version() |
GridCacheVersion |
GridCacheRawVersionedEntry.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) |
boolean |
GridCacheVersionManager.isStartVersion(GridCacheVersion ver)
Check if given version is start version.
|
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,
@Nullable 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.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
TxVerboseId.gridCacheVersion() |
GridCacheVersion |
TxVerboseInfo.nearXidVersion() |
GridCacheVersion |
TxVerboseKey.ownerVersion() |
protected GridCacheVersion |
FetchNearXidVersionTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
| Modifier and Type | Method and Description |
|---|---|
protected VisorJob<TxVerboseId,GridCacheVersion> |
FetchNearXidVersionTask.job(TxVerboseId arg) |
| Modifier and Type | Method and Description |
|---|---|
void |
TxVerboseInfo.nearXidVersion(GridCacheVersion nearXidVer) |
| Constructor and Description |
|---|
TxVerboseId(IgniteUuid uuid,
GridCacheVersion gridCacheVer) |
TxVerboseKey(String txKey,
TxKeyLockType lockType,
GridCacheVersion ownerVer,
boolean read) |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.11.0 Release Date : September 11 2021