| Modifier and Type | Class and Description |
|---|---|
class |
GridCacheVersionEx
Extended cache version which also has additional DR version.
|
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheVersion |
GridCacheTxAdapter.endVer
End version (a.k.a.
|
protected GridCacheVersion |
GridCacheTxLocalAdapter.minVer
Minimal version encountered (either explicit lock or XID of this transaction).
|
protected GridCacheVersion |
GridCacheClearAllRunnable.obsoleteVer
Obsolete version.
|
protected GridCacheVersion |
GridCacheTxAdapter.startVer
Transaction counter value at the start of transaction.
|
protected GridCacheVersion |
GridCacheMapEntry.ver
Version.
|
protected GridCacheVersion |
GridCacheTxAdapter.writeVer
Entries write version.
|
protected GridCacheVersion |
GridCacheTxAdapter.xidVer
Transaction ID.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
GridCacheTxAdapter.commitVersion() |
GridCacheVersion |
GridCacheTxEx.commitVersion() |
GridCacheVersion |
GridCacheTxLocalAdapter.completedBase() |
GridCacheVersion |
GridCacheTxEntry.dhtVersion() |
GridCacheVersion |
GridCacheTxEntry.drVersion() |
GridCacheVersion |
GridCacheVersion.drVersion() |
GridCacheVersion |
GridCacheVersionEx.drVersion() |
GridCacheVersion[] |
GridCacheContext.emptyVersion() |
GridCacheVersion |
GridCacheTxAdapter.endVersion() |
GridCacheVersion |
GridCacheTxEx.endVersion() |
GridCacheVersion |
GridCacheTxEntry.explicitVersion() |
GridCacheVersion |
GridCacheVersionManager.last()
Gets last generated version without generating a new one.
|
GridCacheVersion |
GridCacheMvccManager.mappedVersion(GridCacheVersion from) |
GridCacheVersion |
GridCacheTxManager.mappedVersion(GridCacheVersion from) |
GridCacheVersion |
GridCacheTxLocalAdapter.minVersion()
Gets minimum version present in transaction.
|
GridCacheVersion |
GridCacheTxLocalEx.minVersion() |
GridCacheVersion |
GridCacheTxManager.nearVersion(GridCacheVersion dhtVer)
Reverse mapped version look up.
|
GridCacheVersion |
GridCacheTxAdapter.nearXidVersion() |
GridCacheVersion |
GridCacheTxEx.nearXidVersion() |
GridCacheVersion |
GridCacheVersionManager.next() |
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 |
GridCacheMapEntry.obsoleteVersion() |
GridCacheVersion |
GridCacheEntryEx.obsoleteVersion() |
protected GridCacheVersion |
GridCacheMapEntry.obsoleteVersionExtras() |
GridCacheVersion |
GridCacheVersionManager.onReceivedAndNext(UUID nodeId,
GridCacheVersion ver) |
GridCacheVersion |
GridCacheMvccCandidate.otherVersion() |
GridCacheVersion |
GridCacheTxAdapter.ownedVersion(K key)
Gets owned version for near remote transaction.
|
GridCacheVersion |
GridCacheTxEx.ownedVersion(K key)
Gets owned version for near remote transaction.
|
GridCacheVersion |
GridCacheMvccCandidate.ownerVersion() |
static GridCacheVersion |
GridCacheUtils.readVersion(ObjectInput in)
Reads
GridCacheVersion from input stream. |
GridCacheVersion |
GridCacheUpdateAtomicResult.removeVersion() |
GridCacheVersion |
GridCacheTxAdapter.startVersion() |
GridCacheVersion |
GridCacheTxEx.startVersion() |
GridCacheVersion |
GridCacheTxManager.txContextVersion()
Gets version of transaction in tx context or
null
if tx context is empty. |
GridCacheVersion |
GridCacheMvccManager.unmapVersion(GridCacheVersion from) |
GridCacheVersion |
GridCacheMvccCandidate.version() |
GridCacheVersion |
GridCacheMapEntry.version() |
GridCacheVersion |
GridCacheEntryInfo.version() |
GridCacheVersion |
GridCacheEntryEx.version() |
GridCacheVersion |
GridCacheVersionable.version() |
GridCacheVersion |
GridCacheSwapEntry.version() |
GridCacheVersion |
GridCacheFuture.version() |
GridCacheVersion |
GridCacheTxAdapter.writeVersion() |
GridCacheVersion |
GridCacheTxEx.writeVersion() |
GridCacheVersion |
GridCacheTxAdapter.xidVersion() |
GridCacheVersion |
GridCacheTxEx.xidVersion() |
| Modifier and Type | Method and Description |
|---|---|
Collection<GridCacheVersion> |
GridCacheTxEx.alternateVersions() |
Collection<GridCacheVersion> |
GridCacheTxLocalAdapter.alternateVersions() |
Collection<GridCacheVersion> |
GridCacheTxLocalAdapter.committedVersions() |
Collection<GridCacheVersion> |
GridCacheTxManager.committedVersions(GridCacheVersion min)
Gets committed transactions starting from the given version (inclusive).
|
Collection<GridCacheVersion> |
GridCacheMvccManager.localDhtPendingVersions(Collection<K> keys,
GridCacheVersion base) |
Collection<GridCacheVersion> |
GridCacheTxLocalAdapter.rolledbackVersions() |
Collection<GridCacheVersion> |
GridCacheTxManager.rolledbackVersions(GridCacheVersion min)
Gets rolledback transactions starting from the given version (inclusive).
|
static <K,V> GridClosure<GridCacheTxEx<K,V>,GridCacheVersion> |
GridCacheUtils.tx2xidVersion() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheTxManager.addAlternateVersion(GridCacheVersion ver,
GridCacheTxEx<K,V> tx) |
void |
GridCacheMvccManager.addAtomicFuture(GridCacheVersion futVer,
GridCacheAtomicFuture<K,?> fut) |
boolean |
GridCacheTxManager.addCommittedTx(GridCacheVersion xidVer,
GridCacheVersion nearXidVer) |
protected GridCacheTxEntry<K,V> |
GridCacheTxLocalAdapter.addEntry(GridCacheOperation op,
V val,
GridClosure<V,V> transformClos,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter,
boolean filtersSet,
long drTtl,
long drExpireTime,
GridCacheVersion drVer) |
GridCacheMvccCandidate<K> |
GridCacheMvcc.addLocal(GridCacheEntryEx<K,?> parent,
long threadId,
GridCacheVersion ver,
long timeout,
boolean reenter,
boolean tx,
boolean implicitSingle) |
GridCacheMvccCandidate<K> |
GridCacheMvcc.addLocal(GridCacheEntryEx<K,?> parent,
UUID nearNodeId,
GridCacheVersion nearVer,
long threadId,
GridCacheVersion ver,
long timeout,
boolean reenter,
boolean tx,
boolean implicitSingle,
boolean dhtLoc) |
GridCacheMvccCandidate<K> |
GridCacheMvcc.addNearLocal(GridCacheEntryEx<K,?> parent,
UUID nodeId,
UUID otherNodeId,
long threadId,
GridCacheVersion ver,
long timeout,
boolean tx,
boolean implicitSingle)
Adds new near local lock candidate.
|
GridCacheMvccCandidate<K> |
GridCacheMvcc.addRemote(GridCacheEntryEx<K,?> parent,
UUID nodeId,
UUID otherNodeId,
long threadId,
GridCacheVersion ver,
long timeout,
boolean tx,
boolean implicitSingle,
boolean nearLoc)
Adds new remote lock candidate (either near remote or dht remote).
|
boolean |
GridCacheMvccManager.addRemoved(GridCacheVersion ver) |
boolean |
GridCacheTxManager.addRolledbackTx(GridCacheVersion xidVer) |
GridFuture<?> |
GridCacheMvccManager.atomicFuture(GridCacheVersion futVer)
Gets future by given future ID.
|
void |
GridCacheEvictionManager.batchEvict(Collection<? extends K> keys,
GridCacheVersion obsoleteVer) |
GridCacheMvccCandidate<K> |
GridCacheMapEntry.candidate(GridCacheVersion ver)
Gets lock candidate for given lock ID.
|
GridCacheMvccCandidate<K> |
GridCacheMvcc.candidate(GridCacheVersion ver)
Gets candidate for lock ID.
|
GridCacheMvccCandidate<K> |
GridCacheEntryEx.candidate(GridCacheVersion ver)
Gets lock candidate for given lock ID.
|
GridCacheMvccCandidate<K> |
GridCacheExplicitLockSpan.candidate(K key,
GridCacheVersion ver)
Gets explicit lock candidate for given key.
|
boolean |
GridCacheMapEntry.clear(GridCacheVersion ver,
boolean readers,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Marks entry as obsolete and, if possible or required, removes it
from swap storage.
|
boolean |
GridCacheEntryEx.clear(GridCacheVersion ver,
boolean readers,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Marks entry as obsolete and, if possible or required, removes it
from swap storage.
|
Collection<GridCacheVersion> |
GridCacheTxManager.committedVersions(GridCacheVersion min)
Gets committed transactions starting from the given version (inclusive).
|
boolean |
GridCacheTxAdapter.commitVersion(GridCacheVersion commitVer) |
boolean |
GridCacheTxEx.commitVersion(GridCacheVersion commitVer) |
int |
GridCacheAtomicVersionComparator.compare(GridCacheVersion one,
GridCacheVersion other) |
int |
GridCacheVersion.compareTo(GridCacheVersion other) |
void |
GridCacheTxAdapter.completedVersions(GridCacheVersion base,
Collection<GridCacheVersion> committed,
Collection<GridCacheVersion> txs) |
void |
GridCacheTxEx.completedVersions(GridCacheVersion base,
Collection<GridCacheVersion> committed,
Collection<GridCacheVersion> rolledback) |
void |
GridCacheTxLocalAdapter.completedVersions(GridCacheVersion completedBase,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers) |
void |
GridCacheTxEntry.dhtVersion(GridCacheVersion dhtVer) |
GridCacheMvccCandidate<K> |
GridCacheMvcc.doneRemote(GridCacheVersion ver,
Collection<GridCacheVersion> pending,
Collection<GridCacheVersion> committed,
Collection<GridCacheVersion> rolledback)
Sets remote candidate to done.
|
void |
GridCacheTxRemoteEx.doneRemote(GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers) |
boolean |
GridCacheContext.drNeedResolve(GridCacheVersion oldVer,
GridCacheVersion newVer)
Check whether DR conflict resolution is required.
|
protected GridBiTuple<GridCacheOperation,GridDrReceiverConflictContextImpl<K,V>> |
GridCacheTxAdapter.drResolveConflict(GridCacheOperation op,
K key,
V newVal,
byte[] newValBytes,
long newTtl,
long newDrExpireTime,
GridCacheVersion newVer,
GridCacheEntryEx<K,V> old)
Resolve DR conflict.
|
void |
GridCacheTxEntry.drVersion(GridCacheVersion drVer) |
void |
GridCacheTxAdapter.endVersion(GridCacheVersion endVer) |
void |
GridCacheTxEx.endVersion(GridCacheVersion endVer) |
boolean |
GridCacheEvictionManager.evict(GridCacheEntryEx<K,V> entry,
GridCacheVersion obsoleteVer,
boolean explicit,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridCacheBatchSwapEntry<K,V> |
GridCacheMapEntry.evictInBatchInternal(GridCacheVersion obsoleteVer)
Evicts entry when batch evict is performed.
|
GridCacheBatchSwapEntry<K,V> |
GridCacheEntryEx.evictInBatchInternal(GridCacheVersion obsoleteVer)
Evicts entry when batch evict is performed.
|
boolean |
GridCacheMapEntry.evictInternal(boolean swap,
GridCacheVersion obsoleteVer,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
boolean |
GridCacheEntryEx.evictInternal(boolean swap,
GridCacheVersion obsoleteVer,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridCacheMvccCandidate<K> |
GridCacheMvccManager.explicitLock(K key,
GridCacheVersion ver)
Gets explicit lock candidate added by any thread by given key and lock version.
|
void |
GridCacheTxEntry.explicitVersion(GridCacheVersion explicitVer) |
<T> GridCacheFuture<T> |
GridCacheMvccManager.future(GridCacheVersion ver,
GridUuid futId)
Gets future for given future ID and lock ID.
|
<T> Collection<? extends GridFuture<T>> |
GridCacheMvccManager.futures(GridCacheVersion ver)
Gets all futures for given lock version, possibly empty collection.
|
boolean |
GridCacheMvcc.hasCandidate(GridCacheVersion ver) |
boolean |
GridCacheMapEntry.hasLockCandidate(GridCacheVersion ver)
Checks if the candidate is either owner or pending.
|
boolean |
GridCacheEntryEx.hasLockCandidate(GridCacheVersion ver)
Checks if the candidate is either owner or pending.
|
boolean |
GridCacheMapEntry.hasLockCandidateUnsafe(GridCacheVersion ver) |
boolean |
GridCacheEntryEx.hasLockCandidateUnsafe(GridCacheVersion ver) |
boolean |
GridCacheMapEntry.initialValue(V val,
byte[] valBytes,
GridCacheVersion ver,
long ttl,
long expireTime,
boolean preload,
long topVer,
GridDrType drType)
Sets new value if current version is 0
|
boolean |
GridCacheEntryEx.initialValue(V val,
byte[] valBytes,
GridCacheVersion ver,
long ttl,
long expireTime,
boolean preload,
long topVer,
GridDrType drType)
Sets new value if current version is 0
|
GridCacheUpdateTxResult<V> |
GridCacheMapEntry.innerRemove(GridCacheTxEx<K,V> tx,
UUID evtNodeId,
UUID affNodeId,
boolean writeThrough,
boolean retval,
boolean evt,
boolean metrics,
long topVer,
GridPredicate<GridCacheEntry<K,V>>[] filter,
GridDrType drType,
GridCacheVersion explicitVer,
UUID subjId) |
GridCacheUpdateTxResult<V> |
GridCacheEntryEx.innerRemove(GridCacheTxEx<K,V> tx,
UUID evtNodeId,
UUID affNodeId,
boolean writeThrough,
boolean retval,
boolean evt,
boolean metrics,
long topVer,
GridPredicate<GridCacheEntry<K,V>>[] filter,
GridDrType drType,
GridCacheVersion explicitVer,
UUID subjId) |
GridCacheUpdateTxResult<V> |
GridCacheMapEntry.innerSet(GridCacheTxEx<K,V> tx,
UUID evtNodeId,
UUID affNodeId,
V val,
byte[] valBytes,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
long topVer,
GridPredicate<GridCacheEntry<K,V>>[] filter,
GridDrType drType,
long drExpireTime,
GridCacheVersion explicitVer,
UUID subjId) |
GridCacheUpdateTxResult<V> |
GridCacheEntryEx.innerSet(GridCacheTxEx<K,V> tx,
UUID evtNodeId,
UUID affNodeId,
V val,
byte[] valBytes,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
long topVer,
GridPredicate<GridCacheEntry<K,V>>[] filter,
GridDrType drType,
long drExpireTime,
GridCacheVersion explicitVer,
UUID subjId) |
GridCacheUpdateAtomicResult<K,V> |
GridCacheMapEntry.innerUpdate(GridCacheVersion newVer,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
Object writeObj,
byte[] valBytes,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
boolean primary,
boolean verCheck,
GridPredicate<GridCacheEntry<K,V>>[] filter,
GridDrType drType,
long drTtl,
long drExpireTime,
GridCacheVersion drVer,
boolean drResolve,
boolean intercept,
UUID subjId) |
GridCacheUpdateAtomicResult<K,V> |
GridCacheEntryEx.innerUpdate(GridCacheVersion ver,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
Object val,
byte[] valBytes,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
boolean primary,
boolean checkVer,
GridPredicate<GridCacheEntry<K,V>>[] filter,
GridDrType drType,
long drTtl,
long drExpireTime,
GridCacheVersion drVer,
boolean drResolve,
boolean intercept,
UUID subjId) |
GridBiTuple<Boolean,V> |
GridCacheMapEntry.innerUpdateLocal(GridCacheVersion ver,
GridCacheOperation op,
Object writeObj,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
GridPredicate<GridCacheEntry<K,V>>[] filter,
boolean intercept,
UUID subjId)
Update method for local cache in atomic mode.
|
GridBiTuple<Boolean,V> |
GridCacheEntryEx.innerUpdateLocal(GridCacheVersion ver,
GridCacheOperation op,
Object writeObj,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
GridPredicate<GridCacheEntry<K,V>>[] filter,
boolean intercept,
UUID subjId)
Update method for local cache in atomic mode.
|
boolean |
GridCacheMapEntry.invalidate(GridCacheVersion curVer,
GridCacheVersion newVer)
Invalidates this entry.
|
boolean |
GridCacheEntryEx.invalidate(GridCacheVersion curVer,
GridCacheVersion newVer)
Invalidates this entry.
|
boolean |
GridCacheMvcc.isEmpty(GridCacheVersion... exclude) |
boolean |
GridCacheVersion.isGreater(GridCacheVersion ver) |
boolean |
GridCacheVersion.isGreaterEqual(GridCacheVersion ver) |
boolean |
GridCacheVersion.isLess(GridCacheVersion ver) |
boolean |
GridCacheVersion.isLessEqual(GridCacheVersion ver) |
boolean |
GridCacheMvcc.isLocallyOwned(GridCacheVersion lockVer) |
boolean |
GridCacheMvcc.isLocallyOwnedByIdOrThread(GridCacheVersion lockVer,
long threadId) |
boolean |
GridCacheMvcc.isLocallyOwnedByThread(long threadId,
boolean allowDhtLoc,
GridCacheVersion... exclude) |
boolean |
GridCacheMvcc.isOwnedBy(GridCacheVersion ver) |
boolean |
GridCacheMvccManager.isRemoved(GridCacheVersion ver) |
List<GridCacheMvccCandidate<K>> |
GridCacheMvcc.localCandidates(boolean reentries,
GridCacheVersion... excludeVers) |
Collection<GridCacheMvccCandidate<K>> |
GridCacheMapEntry.localCandidates(GridCacheVersion... exclude)
Gets all local candidates.
|
Collection<GridCacheMvccCandidate<K>> |
GridCacheMvcc.localCandidates(GridCacheVersion... excludeVers) |
Collection<GridCacheMvccCandidate<K>> |
GridCacheEntryEx.localCandidates(GridCacheVersion... exclude)
Gets all local candidates.
|
Collection<GridCacheVersion> |
GridCacheMvccManager.localDhtPendingVersions(Collection<K> keys,
GridCacheVersion base) |
GridCacheTxEx<K,V> |
GridCacheTxManager.localTxForRecovery(GridCacheVersion nearXidVer)
Gets local transaction for pessimistic tx recovery.
|
boolean |
GridCacheMapEntry.lockedBy(GridCacheVersion ver) |
boolean |
GridCacheEntryEx.lockedBy(GridCacheVersion ver) |
boolean |
GridCacheMapEntry.lockedByAny(GridCacheVersion... exclude) |
boolean |
GridCacheEntryEx.lockedByAny(GridCacheVersion... exclude) |
boolean |
GridCacheMapEntry.lockedByThread(long threadId,
GridCacheVersion exclude) |
boolean |
GridCacheEntryEx.lockedByThread(long threadId,
GridCacheVersion exclude) |
boolean |
GridCacheMapEntry.lockedByUnsafe(GridCacheVersion ver) |
boolean |
GridCacheEntryEx.lockedByUnsafe(GridCacheVersion ver) |
boolean |
GridCacheMapEntry.lockedLocally(GridCacheVersion lockVer) |
boolean |
GridCacheEntryEx.lockedLocally(GridCacheVersion lockVer) |
boolean |
GridCacheMapEntry.lockedLocallyByIdOrThread(GridCacheVersion lockVer,
long threadId) |
boolean |
GridCacheEntryEx.lockedLocallyByIdOrThread(GridCacheVersion lockVer,
long threadId) |
boolean |
GridCacheMapEntry.lockedLocallyUnsafe(GridCacheVersion lockVer) |
boolean |
GridCacheEntryEx.lockedLocallyUnsafe(GridCacheVersion lockVer) |
GridCacheVersion |
GridCacheMvccManager.mappedVersion(GridCacheVersion from) |
GridCacheVersion |
GridCacheTxManager.mappedVersion(GridCacheVersion from) |
void |
GridCacheMvccManager.mapVersion(GridCacheVersion from,
GridCacheVersion to) |
boolean |
GridCacheMapEntry.markObsolete(GridCacheVersion ver)
Sets obsolete flag if possible.
|
boolean |
GridCacheEntryEx.markObsolete(GridCacheVersion ver)
Sets obsolete flag if possible.
|
protected boolean |
GridCacheMapEntry.markObsolete0(GridCacheVersion ver,
boolean clear)
Note that
GridCacheMapEntry.onMarkedObsolete() should always be called after this method
returns true. |
boolean |
GridCacheMapEntry.markObsoleteIfEmpty(GridCacheVersion ver)
Sets obsolete flag if entry value is
null or entry is expired and no
locks are held. |
boolean |
GridCacheEntryEx.markObsoleteIfEmpty(GridCacheVersion ver)
Sets obsolete flag if entry value is
null or entry is expired and no
locks are held. |
boolean |
GridCacheMapEntry.markObsoleteVersion(GridCacheVersion ver)
Sets obsolete flag if entry version equals to
ver. |
boolean |
GridCacheEntryEx.markObsoleteVersion(GridCacheVersion ver)
Sets obsolete flag if entry version equals to
ver. |
GridCacheMvccCandidate<K> |
GridCacheMvcc.markOwned(GridCacheVersion baseVer,
GridCacheVersion owned)
Puts owned versions in front of base.
|
boolean |
GridCacheMvccCandidate.matches(GridCacheVersion ver,
UUID nodeId,
long threadId)
Checks if this candidate matches version or thread-nodeId combination.
|
GridCacheVersion |
GridCacheTxManager.nearVersion(GridCacheVersion dhtVer)
Reverse mapped version look up.
|
GridCacheVersion |
GridCacheVersionManager.next(GridCacheVersion ver)
Gets next version based on given cache version.
|
boolean |
GridCacheMapEntry.obsolete(GridCacheVersion exclude) |
boolean |
GridCacheEntryEx.obsolete(GridCacheVersion exclude) |
protected void |
GridCacheMapEntry.obsoleteVersionExtras(GridCacheVersion obsoleteVer) |
abstract void |
GridCacheAdapter.onDeferredDelete(GridCacheEntryEx<K,V> entry,
GridCacheVersion ver) |
void |
GridCacheContext.onDeferredDelete(GridCacheEntryEx<K,V> entry,
GridCacheVersion ver) |
void |
GridCacheSwapListener.onEntryUnswapped(int part,
K key,
byte[] keyBytes,
V val,
byte[] valBytes,
GridCacheVersion ver,
long ttl,
long expireTime) |
void |
GridCacheVersionManager.onReceived(UUID nodeId,
GridCacheVersion ver) |
GridCacheVersion |
GridCacheVersionManager.onReceivedAndNext(UUID nodeId,
GridCacheVersion ver) |
boolean |
GridCacheMapEntry.onTtlExpired(GridCacheVersion obsoleteVer)
Callback from ttl processor to cache entry indicating that entry is expired.
|
boolean |
GridCacheEntryEx.onTtlExpired(GridCacheVersion obsoleteVer)
Callback from ttl processor to cache entry indicating that entry is expired.
|
GridCacheMvccCandidate<K> |
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.
|
boolean |
GridCacheStoreManager.putToStore(GridCacheTx tx,
K key,
V val,
GridCacheVersion ver)
Puts key-value pair into storage.
|
GridCacheMvccCandidate<K> |
GridCacheMvcc.readyLocal(GridCacheVersion ver) |
GridCacheMvccCandidate<K> |
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.
|
protected void |
GridCacheMapEntry.refreshAhead(K key,
GridCacheVersion matchVer) |
List<GridCacheMvccCandidate<K>> |
GridCacheMvcc.remoteCandidates(GridCacheVersion... excludeVers) |
Collection<GridCacheMvccCandidate<K>> |
GridCacheMapEntry.remoteMvccSnapshot(GridCacheVersion... exclude)
Gets all remote versions.
|
Collection<GridCacheMvccCandidate<K>> |
GridCacheEntryEx.remoteMvccSnapshot(GridCacheVersion... exclude)
Gets all remote versions.
|
GridCacheMvccCandidate<K> |
GridCacheMvcc.remove(GridCacheVersion ver)
Removes lock even if it is not owner.
|
GridFuture<?> |
GridCacheMvccManager.removeAtomicFuture(GridCacheVersion futVer) |
GridCacheMvccCandidate<K> |
GridCacheExplicitLockSpan.removeCandidate(K key,
GridCacheVersion ver)
Removes lock by key and optional version.
|
GridCacheMvccCandidate<K> |
GridCacheMvccManager.removeExplicitLock(long threadId,
K key,
GridCacheVersion ver)
Removes explicit lock for given thread id, key and optional version.
|
boolean |
GridCacheEntryEx.removeLock(GridCacheVersion ver) |
Collection<GridCacheVersion> |
GridCacheTxManager.rolledbackVersions(GridCacheVersion min)
Gets rolledback transactions starting from the given version (inclusive).
|
void |
GridCacheMvcc.salvageRemote(GridCacheVersion ver)
For all remote candidates standing behind the candidate being salvaged marks their transactions
as system invalidate and marks these candidates as owned and used.
|
<T extends GridCacheTxEx<K,V>> |
GridCacheTxManager.tx(GridCacheVersion txId) |
GridCacheCommittedTxInfo<K,V> |
GridCacheTxManager.txCommitted(GridCacheVersion nearTxVer,
UUID originatingNodeId,
long originatingThreadId)
Checks whether transaction with given near version was committed on this node and returns commit info.
|
boolean |
GridCacheTxManager.txsPreparedOrCommitted(GridCacheVersion nearVer,
int txNum)
Checks if transactions with given near version ID was prepared or committed.
|
GridCacheTxEx<K,V> |
GridCacheTxManager.txx(GridCacheVersion txId) |
GridCacheVersion |
GridCacheMvccManager.unmapVersion(GridCacheVersion from) |
protected void |
GridCacheMapEntry.update(V val,
byte[] valBytes,
long expireTime,
long ttl,
GridCacheVersion ver) |
protected void |
GridCacheMapEntry.updateIndex(V val,
byte[] valBytes,
long expireTime,
GridCacheVersion ver,
V prevVal)
Updates cache index.
|
GridCacheValueBytes |
GridCacheMapEntry.valueBytes(GridCacheVersion ver)
Gets cached serialized value bytes.
|
GridCacheValueBytes |
GridCacheEntryEx.valueBytes(GridCacheVersion ver)
Gets cached serialized value bytes.
|
void |
GridCacheEntryInfo.version(GridCacheVersion ver) |
boolean |
GridCacheMapEntry.versionedValue(V val,
GridCacheVersion curVer,
GridCacheVersion newVer)
Sets new value if passed in version matches the current version
(used for read-through only).
|
boolean |
GridCacheEntryEx.versionedValue(V val,
GridCacheVersion curVer,
GridCacheVersion newVer)
Sets new value if passed in version matches the current version
(used for read-through only).
|
static byte[] |
GridCacheUtils.versionToBytes(GridCacheVersion ver)
Converts cache version to byte array.
|
void |
GridCacheTxAdapter.writeVersion(GridCacheVersion writeVer)
Sets write version.
|
void |
GridCacheTxEx.writeVersion(GridCacheVersion ver)
Sets write version.
|
static void |
GridCacheUtils.writeVersion(ObjectOutput out,
GridCacheVersion ver)
Writes
GridCacheVersion to output stream. |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheTxRemoteEx.addRemoteCandidates(Map<K,Collection<GridCacheMvccCandidate<K>>> cands,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers)
Adds remote candidates and completed versions to all involved entries.
|
void |
GridCacheTxRemoteEx.addRemoteCandidates(Map<K,Collection<GridCacheMvccCandidate<K>>> cands,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers)
Adds remote candidates and completed versions to all involved entries.
|
void |
GridCacheTxAdapter.completedVersions(GridCacheVersion base,
Collection<GridCacheVersion> committed,
Collection<GridCacheVersion> txs) |
void |
GridCacheTxAdapter.completedVersions(GridCacheVersion base,
Collection<GridCacheVersion> committed,
Collection<GridCacheVersion> txs) |
void |
GridCacheTxEx.completedVersions(GridCacheVersion base,
Collection<GridCacheVersion> committed,
Collection<GridCacheVersion> rolledback) |
void |
GridCacheTxEx.completedVersions(GridCacheVersion base,
Collection<GridCacheVersion> committed,
Collection<GridCacheVersion> rolledback) |
void |
GridCacheTxLocalAdapter.completedVersions(GridCacheVersion completedBase,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers) |
void |
GridCacheTxLocalAdapter.completedVersions(GridCacheVersion completedBase,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers) |
GridCacheMvccCandidate<K> |
GridCacheMvcc.doneRemote(GridCacheVersion ver,
Collection<GridCacheVersion> pending,
Collection<GridCacheVersion> committed,
Collection<GridCacheVersion> rolledback)
Sets remote candidate to done.
|
GridCacheMvccCandidate<K> |
GridCacheMvcc.doneRemote(GridCacheVersion ver,
Collection<GridCacheVersion> pending,
Collection<GridCacheVersion> committed,
Collection<GridCacheVersion> rolledback)
Sets remote candidate to done.
|
GridCacheMvccCandidate<K> |
GridCacheMvcc.doneRemote(GridCacheVersion ver,
Collection<GridCacheVersion> pending,
Collection<GridCacheVersion> committed,
Collection<GridCacheVersion> rolledback)
Sets remote candidate to done.
|
void |
GridCacheTxRemoteEx.doneRemote(GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers) |
void |
GridCacheTxRemoteEx.doneRemote(GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers) |
void |
GridCacheTxRemoteEx.doneRemote(GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers) |
protected GridFuture<Set<K>> |
GridCacheTxLocalAdapter.enlistWrite(Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
long ttl,
boolean implicit,
Map<? extends K,? extends V> lookup,
Map<? extends K,? extends GridClosure<V,V>> transformMap,
boolean retval,
boolean lockOnly,
GridPredicate<GridCacheEntry<K,V>>[] filter,
GridCacheReturn<V> ret,
Collection<K> enlisted,
Map<? extends K,GridCacheDrInfo<V>> drPutMap,
Map<? extends K,GridCacheVersion> drRmvMap)
Internal routine for putAll(..)
|
boolean |
GridCacheStoreManager.loadCache(GridInClosure3<K,V,GridCacheVersion> vis,
Object[] args)
Loads data from persistent store.
|
GridCacheMvccCandidate<K> |
GridCacheMvcc.orderCompleted(GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers)
Moves completed candidates right before the base one.
|
GridCacheMvccCandidate<K> |
GridCacheMvcc.orderCompleted(GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers)
Moves completed candidates right before the base one.
|
boolean |
GridCacheStoreManager.putAllToStore(GridCacheTx tx,
Map<K,GridBiTuple<V,GridCacheVersion>> map)
Puts key-value pair into storage.
|
GridCacheMvccCandidate<K> |
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.
|
GridCacheMvccCandidate<K> |
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.
|
GridCacheMvccCandidate<K> |
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 |
GridCacheProjectionEx.removeAllDr(Map<? extends K,GridCacheVersion> drMap)
Removes DR data.
|
void |
GridCacheProjectionImpl.removeAllDr(Map<? extends K,GridCacheVersion> drMap)
Removes DR data.
|
void |
GridCacheAdapter.removeAllDr(Map<? extends K,GridCacheVersion> drMap)
Removes DR data.
|
void |
GridCacheProxyImpl.removeAllDr(Map<? extends K,GridCacheVersion> drMap)
Removes DR data.
|
void |
GridCacheTxLocalAdapter.removeAllDr(Map<? extends K,GridCacheVersion> drMap) |
void |
GridCacheTxLocalEx.removeAllDr(Map<? extends K,GridCacheVersion> drMap) |
GridFuture<?> |
GridCacheProjectionEx.removeAllDrAsync(Map<? extends K,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
GridFuture<?> |
GridCacheProjectionImpl.removeAllDrAsync(Map<? extends K,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
GridFuture<?> |
GridCacheAdapter.removeAllDrAsync(Map<? extends K,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
GridFuture<?> |
GridCacheProxyImpl.removeAllDrAsync(Map<? extends K,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
GridFuture<?> |
GridCacheTxLocalAdapter.removeAllDrAsync(Map<? extends K,GridCacheVersion> drMap) |
GridFuture<?> |
GridCacheTxLocalEx.removeAllDrAsync(Map<? extends K,GridCacheVersion> drMap) |
| Constructor and Description |
|---|
GridCacheBatchSwapEntry(K key,
byte[] keyBytes,
int keyHash,
int part,
byte[] valBytes,
boolean valIsByteArr,
GridCacheVersion ver,
long ttl,
long expireTime,
GridUuid keyClsLdrId,
GridUuid valClsLdrId)
Creates batch swap entry.
|
GridCacheClearAllRunnable(GridCacheAdapter<K,V> cache,
GridCacheVersion obsoleteVer,
int id,
int totalCnt)
Constructor.
|
GridCacheLockTimeoutException(GridCacheVersion ver) |
GridCacheMvccCandidate(GridCacheEntryEx<K,?> parent,
UUID nodeId,
UUID otherNodeId,
GridCacheVersion otherVer,
long threadId,
GridCacheVersion ver,
long timeout,
boolean loc,
boolean reentry,
boolean tx,
boolean singleImplicit,
boolean nearLoc,
boolean dhtLoc) |
GridCacheSwapEntry(int keyHash,
byte[] valBytes,
boolean valIsByteArr,
GridCacheVersion ver,
long ttl,
long expireTime,
GridUuid keyClsLdrId,
GridUuid valClsLdrId) |
GridCacheTxAdapter(GridCacheContext<K,V> cctx,
GridCacheVersion xidVer,
boolean implicit,
boolean implicitSingle,
boolean loc,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
boolean invalidate,
boolean swapOrOffheapEnabled,
boolean storeEnabled,
int txSize,
Object grpLockKey,
UUID subjId) |
GridCacheTxAdapter(GridCacheContext<K,V> cctx,
UUID nodeId,
GridCacheVersion xidVer,
GridCacheVersion startVer,
long threadId,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
boolean invalidate,
boolean swapOrOffheapEnabled,
boolean storeEnabled,
int txSize,
Object grpLockKey,
UUID subjId) |
GridCacheTxEntry(GridCacheContext<K,V> ctx,
GridCacheTxEx<K,V> tx,
GridCacheOperation op,
V val,
GridClosure<V,V> transformClos,
long ttl,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>[] filters,
GridCacheVersion drVer)
This constructor is meant for local transactions.
|
GridCacheTxEntry(GridCacheContext<K,V> ctx,
GridCacheTxEx<K,V> tx,
GridCacheOperation op,
V val,
long ttl,
long drExpireTime,
GridCacheEntryEx<K,V> entry,
GridCacheVersion drVer)
This constructor is meant for remote transactions.
|
GridCacheTxLocalAdapter(GridCacheContext<K,V> cctx,
GridCacheVersion xidVer,
boolean implicit,
boolean implicitSingle,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
boolean invalidate,
boolean swapEnabled,
boolean storeEnabled,
int txSize,
Object grpLockKey,
boolean partLock,
UUID subjId) |
GridCacheUpdateAtomicResult(boolean success,
V oldVal,
V newVal,
long newTtl,
long drExpireTime,
GridCacheVersion rmvVer,
GridDrReceiverConflictContextImpl<K,V> drConflictCtx,
boolean sndToDht)
Constructor.
|
GridCacheVersionEx(int topVer,
long globalTime,
long order,
int nodeOrder,
byte dataCenterId,
GridCacheVersion drVer)
Constructor.
|
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheVersion |
GridDistributedBaseMessage.ver
Lock or transaction version.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
GridDistributedTxFinishRequest.baseVersion() |
GridCacheVersion |
GridDistributedTxPrepareRequest.commitVersion() |
GridCacheVersion |
GridDistributedTxFinishRequest.commitVersion() |
GridCacheVersion |
GridDistributedTxMapping.dhtVersion() |
GridCacheVersion |
GridDistributedLockRequest.drVersionByIndex(int idx) |
GridCacheVersion[] |
GridDistributedLockRequest.drVersions() |
GridCacheVersion |
GridCacheMappedVersion.mappedVersion()
Mapping should occur only if this interface returns a non-null value.
|
GridCacheVersion |
GridDistributedLockRequest.nearXidVersion() |
GridCacheVersion |
GridCacheOptimisticCheckPreparedTxRequest.nearXidVersion() |
GridCacheVersion |
GridCachePessimisticCheckCommittedTxRequest.nearXidVersion() |
GridCacheVersion |
GridCacheCommittedTxInfo.originatingTxId() |
GridCacheVersion |
GridDistributedBaseMessage.version() |
GridCacheVersion |
GridCachePessimisticCheckCommittedTxFuture.version() |
GridCacheVersion |
GridCacheOptimisticCheckPreparedTxFuture.version() |
GridCacheVersion |
GridDistributedTxFinishResponse.xid() |
| Modifier and Type | Method and Description |
|---|---|
Collection<GridCacheVersion> |
GridDistributedTxRemoteAdapter.alternateVersions() |
Collection<GridCacheVersion> |
GridDistributedBaseMessage.committedVersions() |
Map<K,GridCacheVersion> |
GridDistributedTxPrepareRequest.dhtVersions() |
Collection<GridCacheVersion> |
GridDistributedBaseMessage.rolledbackVersions() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDistributedTxPrepareRequest.addDhtVersion(K key,
GridCacheVersion dhtVer)
Adds version to be verified on remote node.
|
void |
GridDistributedLockRequest.addKeyBytes(K key,
byte[] keyBytes,
GridCacheTxEntry<K,V> writeEntry,
boolean retVal,
Collection<GridCacheMvccCandidate<K>> cands,
GridCacheVersion drVer,
GridCacheContext<K,V> ctx)
Adds a key.
|
GridCacheMvccCandidate<K> |
GridDistributedCacheEntry.addLocal(long threadId,
GridCacheVersion ver,
long timeout,
boolean reenter,
boolean tx,
boolean implicitSingle)
Add local candidate.
|
void |
GridDistributedTxRemoteAdapter.addRead(K key,
byte[] keyBytes,
GridCacheVersion drVer) |
void |
GridDistributedCacheEntry.addRemote(UUID nodeId,
UUID otherNodeId,
long threadId,
GridCacheVersion ver,
long timeout,
boolean tx,
boolean implicitSingle,
GridCacheVersion owned)
Adds new lock candidate.
|
void |
GridDistributedCacheEntry.addRemoteCandidates(Collection<GridCacheMvccCandidate<K>> cands,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers)
Adds remote candidates automatically filtering any local candidates.
|
boolean |
GridDistributedCacheEntry.addRemoved(GridCacheVersion ver) |
void |
GridDistributedTxRemoteAdapter.addWrite(K key,
byte[] keyBytes,
GridCacheOperation op,
V val,
byte[] valBytes,
GridCacheVersion drVer) |
protected void |
GridDistributedCacheEntry.checkRemoved(GridCacheVersion ver) |
GridCacheCommittedTxInfo<K,V> |
GridCacheTxCommitBuffer.committedTx(GridCacheVersion originatingTxVer,
UUID nodeId,
long threadId)
Gets transaction from commit buffer.
|
GridCacheCommittedTxInfo<K,V> |
GridCachePerThreadTxCommitBuffer.committedTx(GridCacheVersion originatingTxVer,
UUID nodeId,
long threadId)
Gets transaction from commit buffer.
|
void |
GridDistributedTxMapping.dhtVersion(GridCacheVersion dhtVer) |
void |
GridDistributedTxRemoteAdapter.doneRemote(GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers) |
GridCacheMvccCandidate<K> |
GridDistributedCacheEntry.doneRemote(GridCacheVersion lockVer,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
boolean sysInvalidate) |
GridCacheMvccCandidate<K> |
GridDistributedCacheEntry.doneRemote(GridCacheVersion lockVer,
GridCacheVersion baseVer,
Collection<GridCacheVersion> pendingVers,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
boolean sysInvalidate) |
void |
GridDistributedLockRequest.drVersionByIndex(int idx,
GridCacheVersion drVer) |
void |
GridDistributedCacheEntry.orderCompleted(GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers)
Reorders completed versions.
|
GridCacheMvccCandidate<K> |
GridDistributedCacheEntry.readyLock(GridCacheVersion ver) |
GridCacheMvccCandidate<K> |
GridDistributedCacheEntry.readyNearLock(GridCacheVersion ver,
GridCacheVersion mapped,
Collection<GridCacheVersion> committed,
Collection<GridCacheVersion> rolledBack,
Collection<GridCacheVersion> pending)
Notifies mvcc that near local lock is ready to be acquired.
|
Collection<GridCacheMvccCandidate<K>> |
GridDistributedCacheEntry.remoteMvccSnapshot(GridCacheVersion... exclude)
Gets all remote versions.
|
boolean |
GridDistributedCacheEntry.removeLock(GridCacheVersion ver) |
void |
GridDistributedCacheAdapter.removeVersionedEntry(K key,
GridCacheVersion ver) |
void |
GridDistributedBaseMessage.version(GridCacheVersion ver) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDistributedCacheEntry.addRemoteCandidates(Collection<GridCacheMvccCandidate<K>> cands,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers)
Adds remote candidates automatically filtering any local candidates.
|
void |
GridDistributedCacheEntry.addRemoteCandidates(Collection<GridCacheMvccCandidate<K>> cands,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers)
Adds remote candidates automatically filtering any local candidates.
|
void |
GridDistributedTxRemoteAdapter.addRemoteCandidates(Map<K,Collection<GridCacheMvccCandidate<K>>> cands,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers)
Adds remote candidates and completed versions to all involved entries.
|
void |
GridDistributedTxRemoteAdapter.addRemoteCandidates(Map<K,Collection<GridCacheMvccCandidate<K>>> cands,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers)
Adds remote candidates and completed versions to all involved entries.
|
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) |
GridCacheMvccCandidate<K> |
GridDistributedCacheEntry.doneRemote(GridCacheVersion lockVer,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
boolean sysInvalidate) |
GridCacheMvccCandidate<K> |
GridDistributedCacheEntry.doneRemote(GridCacheVersion lockVer,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
boolean sysInvalidate) |
GridCacheMvccCandidate<K> |
GridDistributedCacheEntry.doneRemote(GridCacheVersion lockVer,
GridCacheVersion baseVer,
Collection<GridCacheVersion> pendingVers,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
boolean sysInvalidate) |
GridCacheMvccCandidate<K> |
GridDistributedCacheEntry.doneRemote(GridCacheVersion lockVer,
GridCacheVersion baseVer,
Collection<GridCacheVersion> pendingVers,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
boolean sysInvalidate) |
GridCacheMvccCandidate<K> |
GridDistributedCacheEntry.doneRemote(GridCacheVersion lockVer,
GridCacheVersion baseVer,
Collection<GridCacheVersion> pendingVers,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
boolean sysInvalidate) |
void |
GridDistributedCacheEntry.orderCompleted(GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers)
Reorders completed versions.
|
void |
GridDistributedCacheEntry.orderCompleted(GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers)
Reorders completed versions.
|
GridCacheMvccCandidate<K> |
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.
|
GridCacheMvccCandidate<K> |
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.
|
GridCacheMvccCandidate<K> |
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 |
GridDistributedLockResponse.setCandidates(int idx,
Collection<GridCacheMvccCandidate<K>> cands,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers) |
void |
GridDistributedLockResponse.setCandidates(int idx,
Collection<GridCacheMvccCandidate<K>> cands,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers) |
| Constructor and Description |
|---|
GridDistributedTxFinishRequest(GridCacheVersion xidVer,
GridUuid futId,
GridCacheVersion commitVer,
long threadId,
boolean commit,
boolean invalidate,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
int txSize,
Collection<GridCacheTxEntry<K,V>> writeEntries,
Collection<GridCacheTxEntry<K,V>> recoveryWrites,
boolean reply,
Object grpLockKey) |
GridDistributedTxFinishRequest(GridCacheVersion xidVer,
GridUuid futId,
GridCacheVersion commitVer,
long threadId,
boolean commit,
boolean invalidate,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
int txSize,
Collection<GridCacheTxEntry<K,V>> writeEntries,
Collection<GridCacheTxEntry<K,V>> recoveryWrites,
boolean reply,
Object grpLockKey) |
| Modifier and Type | Method and Description |
|---|---|
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 |
GridDhtTxRemote.nearXidVersion() |
GridCacheVersion |
GridDhtTxLocal.nearXidVersion() |
GridCacheVersion |
GridDhtTxPrepareRequest.nearXidVersion() |
GridCacheVersion |
GridDhtLockRequest.owned(K key) |
GridCacheVersion |
GridDhtTxPrepareFuture.version() |
GridCacheVersion |
GridPartitionedGetFuture.version() |
GridCacheVersion |
GridDhtLockFuture.version() |
GridCacheVersion |
GridDhtGetFuture.version() |
GridCacheVersion |
GridDhtTxFinishFuture.version() |
GridCacheVersion |
GridDhtTxFinishRequest.writeVersion() |
| Modifier and Type | Method and Description |
|---|---|
Map<K,GridCacheVersion> |
GridDhtTxPrepareRequest.owned() |
Collection<GridCacheVersion> |
GridDhtTxLocalAdapter.pendingVersions() |
Collection<GridCacheVersion> |
GridDhtTxFinishRequest.pendingVersions()
Gets versions of not acquired locks with version less then one of transaction being committed.
|
GridTuple3<GridCacheVersion,V,byte[]> |
GridDhtCacheEntry.versionedValue(long topVer) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtLockRequest.addDhtKey(K key,
byte[] keyBytes,
GridCacheTxEntry<K,V> writeEntry,
GridCacheVersion drVer,
boolean invalidateEntry,
GridCacheContext<K,V> ctx)
Adds a DHT key.
|
GridCacheMvccCandidate<K> |
GridDhtCacheEntry.addDhtLocal(UUID nearNodeId,
GridCacheVersion nearVer,
long topVer,
long threadId,
GridCacheVersion ver,
long timeout,
boolean reenter,
boolean tx,
boolean implicitSingle)
Add local candidate.
|
boolean |
GridDhtCacheEntry.clearInternal(GridCacheVersion ver,
boolean swap)
Marks entry as obsolete and, if possible or required, removes it
from swap storage.
|
GridCacheMvccCandidate<K> |
GridDhtCacheEntry.localCandidateByNearVersion(GridCacheVersion nearVer,
boolean rmv) |
GridCacheMvccCandidate<K> |
GridDhtCacheEntry.mappings(GridCacheVersion ver,
Collection<UUID> mappings)
Sets mappings into entry.
|
void |
GridDhtCacheAdapter.onDeferredDelete(GridCacheEntryEx<K,V> entry,
GridCacheVersion ver) |
void |
GridDhtLocalPartition.onDeferredDelete(K key,
GridCacheVersion ver) |
void |
GridDhtLocalPartition.onEntryEvicted(K key,
GridCacheVersion ver) |
void |
GridDhtLockRequest.owned(K key,
byte[] keyBytes,
GridCacheVersion ownerMapped)
Sets owner and its mapped version.
|
void |
GridDhtTxPrepareRequest.owned(K key,
GridCacheVersion ownerMapped)
Sets owner and its mapped version.
|
boolean |
GridDhtLocalPartition.preloadingPermitted(K key,
GridCacheVersion ver)
Cache preloader should call this method within partition lock.
|
boolean |
GridDhtCacheEntry.removeLock(GridCacheVersion ver) |
void |
GridDhtTransactionalCacheAdapter.removeLocks(UUID nodeId,
GridCacheVersion ver,
Iterable<? extends K> keys,
boolean unmap) |
void |
GridDhtTxFinishRequest.writeVersion(GridCacheVersion writeVer) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtTxLocalAdapter.pendingVersions(Collection<GridCacheVersion> pendingVers) |
GridFuture<GridCacheTxEx<K,V>> |
GridDhtTxLocal.prepareAsync(Iterable<GridCacheTxEntry<K,V>> reads,
Iterable<GridCacheTxEntry<K,V>> writes,
Map<K,GridCacheVersion> verMap,
long msgId,
GridUuid nearMiniId,
Map<UUID,Collection<UUID>> txNodes,
boolean last,
Collection<UUID> lastBackups)
Prepares next batch of entries in dht transaction.
|
| Constructor and Description |
|---|
GridDhtLockFuture(GridCacheContext<K,V> cctx,
UUID nearNodeId,
GridCacheVersion nearLockVer,
long topVer,
int cnt,
boolean read,
long timeout,
GridDhtTxLocalAdapter<K,V> tx,
long threadId,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridDhtLockRequest(UUID nodeId,
GridCacheVersion nearXidVer,
long threadId,
GridUuid futId,
GridUuid miniId,
GridCacheVersion lockVer,
long topVer,
boolean isInTx,
boolean isRead,
GridCacheTxIsolation isolation,
boolean isInvalidate,
long timeout,
int dhtCnt,
int nearCnt,
int txSize,
Object grpLockKey,
boolean partLock,
UUID subjId) |
GridDhtLockResponse(GridCacheVersion lockVer,
GridUuid futId,
GridUuid miniId,
int cnt) |
GridDhtLockResponse(GridCacheVersion lockVer,
GridUuid futId,
GridUuid miniId,
Throwable err) |
GridDhtTxFinishRequest(UUID nearNodeId,
GridUuid futId,
GridUuid miniId,
long topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
long threadId,
GridCacheTxIsolation isolation,
boolean commit,
boolean invalidate,
boolean sysInvalidate,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers,
int txSize,
Collection<GridCacheTxEntry<K,V>> writes,
Collection<GridCacheTxEntry<K,V>> nearWrites,
Collection<GridCacheTxEntry<K,V>> recoverWrites,
boolean reply,
boolean onePhaseCommit,
Object grpLockKey,
UUID subjId) |
GridDhtTxFinishResponse(GridCacheVersion xid,
GridUuid futId,
GridUuid miniId) |
GridDhtTxLocalAdapter(GridCacheVersion xidVer,
boolean implicit,
boolean implicitSingle,
GridCacheContext<K,V> cctx,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
boolean invalidate,
boolean syncCommit,
boolean syncRollback,
boolean explicitLock,
boolean swapEnabled,
boolean storeEnabled,
int txSize,
Object grpLockKey,
boolean partLock,
UUID subjId) |
GridDhtTxPrepareRequest(GridUuid futId,
GridUuid miniId,
long topVer,
GridDhtTxLocalAdapter<K,V> tx,
Collection<GridCacheTxEntry<K,V>> dhtWrites,
Collection<GridCacheTxEntry<K,V>> nearWrites,
Object grpLockKey,
boolean partLock,
Map<UUID,Collection<UUID>> txNodes,
GridCacheVersion nearXidVer,
boolean last,
UUID subjId) |
GridDhtTxPrepareResponse(GridCacheVersion xid,
GridUuid futId,
GridUuid miniId) |
GridDhtTxPrepareResponse(GridCacheVersion xid,
GridUuid futId,
GridUuid miniId,
Throwable err) |
GridDhtTxRemote(UUID nearNodeId,
GridUuid rmtFutId,
UUID nodeId,
GridCacheVersion nearXidVer,
long rmtThreadId,
long topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
boolean invalidate,
long timeout,
GridCacheContext<K,V> ctx,
int txSize,
Object grpLockKey,
UUID subjId)
This constructor is meant for pessimistic transactions.
|
GridDhtTxRemote(UUID nearNodeId,
GridUuid rmtFutId,
UUID nodeId,
long rmtThreadId,
long topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
boolean invalidate,
long timeout,
GridCacheContext<K,V> ctx,
int txSize,
Object grpLockKey,
GridCacheVersion nearXidVer,
Map<UUID,Collection<UUID>> txNodes,
UUID subjId)
This constructor is meant for optimistic transactions.
|
| Constructor and Description |
|---|
GridDhtTxFinishRequest(UUID nearNodeId,
GridUuid futId,
GridUuid miniId,
long topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
long threadId,
GridCacheTxIsolation isolation,
boolean commit,
boolean invalidate,
boolean sysInvalidate,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers,
int txSize,
Collection<GridCacheTxEntry<K,V>> writes,
Collection<GridCacheTxEntry<K,V>> nearWrites,
Collection<GridCacheTxEntry<K,V>> recoverWrites,
boolean reply,
boolean onePhaseCommit,
Object grpLockKey,
UUID subjId) |
GridDhtTxFinishRequest(UUID nearNodeId,
GridUuid futId,
GridUuid miniId,
long topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
long threadId,
GridCacheTxIsolation isolation,
boolean commit,
boolean invalidate,
boolean sysInvalidate,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers,
int txSize,
Collection<GridCacheTxEntry<K,V>> writes,
Collection<GridCacheTxEntry<K,V>> nearWrites,
Collection<GridCacheTxEntry<K,V>> recoverWrites,
boolean reply,
boolean onePhaseCommit,
Object grpLockKey,
UUID subjId) |
GridDhtTxFinishRequest(UUID nearNodeId,
GridUuid futId,
GridUuid miniId,
long topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
long threadId,
GridCacheTxIsolation isolation,
boolean commit,
boolean invalidate,
boolean sysInvalidate,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers,
int txSize,
Collection<GridCacheTxEntry<K,V>> writes,
Collection<GridCacheTxEntry<K,V>> nearWrites,
Collection<GridCacheTxEntry<K,V>> recoverWrites,
boolean reply,
boolean onePhaseCommit,
Object grpLockKey,
UUID subjId) |
GridDhtTxPrepareFuture(GridCacheContext<K,V> cctx,
GridDhtTxLocalAdapter<K,V> tx,
GridUuid nearMiniId,
Map<K,GridCacheVersion> dhtVerMap,
boolean last,
Collection<UUID> lastBackups) |
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
GridDhtAtomicUpdateRequest.drVersion(int idx) |
GridCacheVersion |
GridNearAtomicUpdateRequest.drVersion(int idx) |
GridCacheVersion |
GridDhtAtomicUpdateResponse.futureVersion() |
GridCacheVersion |
GridDhtAtomicUpdateRequest.futureVersion() |
GridCacheVersion |
GridNearAtomicUpdateResponse.futureVersion() |
GridCacheVersion |
GridNearAtomicUpdateRequest.futureVersion() |
GridCacheVersion |
GridNearAtomicUpdateResponse.nearVersion() |
GridCacheVersion |
GridNearAtomicUpdateRequest.updateVersion() |
GridCacheVersion |
GridNearAtomicUpdateFuture.version() |
GridCacheVersion |
GridDhtAtomicUpdateFuture.version() |
GridCacheVersion |
GridDhtAtomicUpdateRequest.writeVersion() |
| Modifier and Type | Method and Description |
|---|---|
List<GridCacheVersion> |
GridDhtAtomicUpdateRequest.drVersions() |
List<GridCacheVersion> |
GridNearAtomicUpdateRequest.drVersions() |
Collection<GridCacheVersion> |
GridDhtAtomicDeferredUpdateResponse.futureVersions() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridNearAtomicUpdateRequest.addUpdateEntry(K key,
Object val,
long drTtl,
long drExpireTime,
GridCacheVersion drVer,
boolean primary) |
void |
GridDhtAtomicUpdateFuture.addWriteEntry(GridDhtCacheEntry<K,V> entry,
V val,
byte[] valBytes,
GridClosure<V,V> transformC,
long drTtl,
long drExpireTime,
GridCacheVersion drVer,
long ttl) |
void |
GridDhtAtomicUpdateRequest.addWriteValue(K key,
byte[] keyBytes,
V val,
byte[] valBytes,
GridClosure<V,V> transformC,
long drTtl,
long drExpireTime,
GridCacheVersion drVer) |
void |
GridNearAtomicUpdateResponse.nearVersion(GridCacheVersion nearVer) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtAtomicCache.removeAllDr(Map<? extends K,GridCacheVersion> drMap)
Removes DR data.
|
GridFuture<?> |
GridDhtAtomicCache.removeAllDrAsync(Map<? extends K,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
| Constructor and Description |
|---|
GridDhtAtomicDeferredUpdateResponse(Collection<GridCacheVersion> futVers)
Constructor.
|
GridNearAtomicUpdateFuture(GridCacheContext<K,V> cctx,
GridDhtAtomicCache<K,V> cache,
GridCacheWriteSynchronizationMode syncMode,
GridCacheOperation op,
Collection<? extends K> keys,
Collection<?> vals,
Collection<GridCacheDrInfo<V>> drPutVals,
Collection<GridCacheVersion> drRmvVals,
boolean retval,
boolean rawRetval,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter,
UUID subjId) |
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
GridDhtColocatedTxLocal.nearXidVersion() |
GridCacheVersion |
GridDhtColocatedTxPrepareFuture.version() |
GridCacheVersion |
GridDhtColocatedTxFinishFuture.version() |
GridCacheVersion |
GridDhtColocatedLockFuture.version() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridDhtDetachedCacheEntry.addRemoved(GridCacheVersion ver) |
void |
GridDhtColocatedCache.removeLocks(long threadId,
GridCacheVersion ver,
Collection<? extends K> keys)
Removes locks regardless of whether they are owned or not for given
version and keys.
|
void |
GridDhtDetachedCacheEntry.resetFromPrimary(V val,
byte[] valBytes,
GridCacheVersion ver)
Sets value to detached entry so it can be retrieved in transactional gets.
|
protected void |
GridDhtDetachedCacheEntry.updateIndex(V val,
byte[] valBytes,
long expireTime,
GridCacheVersion ver,
V old)
Updates cache index.
|
| Constructor and Description |
|---|
GridDhtPartitionsSingleMessage(GridDhtPartitionExchangeId exchId,
GridDhtPartitionMap parts,
GridCacheVersion lastVer) |
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
GridNearCacheEntry.dhtVersion() |
GridCacheVersion |
GridNearTxPrepareResponse.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 |
GridNearTxRemote.ownedVersion(K key)
Gets owned version for near remote transaction.
|
GridCacheVersion |
GridNearTxFinishFuture.version() |
GridCacheVersion |
GridNearLockFuture.version() |
GridCacheVersion |
GridNearTxPrepareFuture.version() |
GridCacheVersion |
GridNearGetResponse.version() |
GridCacheVersion |
GridNearGetRequest.version() |
GridCacheVersion |
GridNearGetFuture.version() |
| Modifier and Type | Method and Description |
|---|---|
Map<K,GridTuple3<GridCacheVersion,V,byte[]>> |
GridNearTxPrepareResponse.ownedValues() |
Collection<GridCacheVersion> |
GridNearTxPrepareResponse.pending()
Gets pending versions that are less than
GridDistributedBaseMessage.version(). |
Collection<GridCacheVersion> |
GridNearLockResponse.pending()
Gets pending versions that are less than
GridDistributedBaseMessage.version(). |
GridTuple3<GridCacheVersion,V,byte[]> |
GridNearCacheEntry.versionedValue() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridNearLockRequest.addKeyBytes(K key,
byte[] keyBytes,
boolean retVal,
GridCacheVersion dhtVer,
GridCacheTxEntry<K,V> writeEntry,
GridCacheVersion drVer,
GridCacheContext<K,V> ctx)
Adds a key.
|
GridCacheMvccCandidate<K> |
GridNearCacheEntry.addLocal(long threadId,
GridCacheVersion ver,
long timeout,
boolean reenter,
boolean tx,
boolean implicitSingle)
Add local candidate.
|
GridCacheMvccCandidate<K> |
GridNearCacheEntry.addNearLocal(UUID dhtNodeId,
long threadId,
GridCacheVersion ver,
long timeout,
boolean reenter,
boolean tx,
boolean implicitSingle)
Add near local candidate.
|
void |
GridNearTxPrepareResponse.addOwnedValue(K key,
GridCacheVersion ver,
V val,
byte[] valBytes)
Adds owned value.
|
void |
GridNearLockResponse.addValueBytes(V val,
byte[] valBytes,
boolean filterPassed,
GridCacheVersion dhtVer,
GridCacheVersion mappedVer,
GridCacheContext<K,V> ctx) |
GridCacheMvccCandidate<K> |
GridNearCacheEntry.dhtNodeId(GridCacheVersion ver,
UUID dhtNodeId) |
protected boolean |
GridNearTransactionalCache.evictNearEntry(GridCacheEntryEx<K,V> e,
GridCacheVersion obsoleteVer,
long topVer) |
boolean |
GridNearCacheEntry.loadedValue(GridCacheTxEx tx,
UUID primaryNodeId,
V val,
byte[] valBytes,
GridCacheVersion ver,
GridCacheVersion dhtVer,
GridCacheVersion expVer,
long ttl,
long expireTime,
boolean evt,
long topVer,
UUID subjId) |
void |
GridNearTransactionalCache.onDeferredDelete(GridCacheEntryEx<K,V> entry,
GridCacheVersion ver) |
void |
GridNearAtomicCache.onDeferredDelete(GridCacheEntryEx<K,V> entry,
GridCacheVersion ver) |
void |
GridNearCacheEntry.recordDhtVersion(GridCacheVersion dhtVer)
This method should be called only when committing optimistic transactions.
|
protected void |
GridNearCacheEntry.refreshAhead(K key,
GridCacheVersion matchVer) |
void |
GridNearTransactionalCache.removeLocks(GridCacheVersion ver,
Collection<? extends K> keys)
Removes locks regardless of whether they are owned or not for given
version and keys.
|
boolean |
GridNearCacheEntry.resetFromPrimary(V val,
byte[] valBytes,
GridCacheVersion ver,
GridCacheVersion dhtVer,
UUID primaryNodeId)
This method should be called only when lock is owned on this entry.
|
protected void |
GridNearCacheEntry.updateIndex(V val,
byte[] valBytes,
long expireTime,
GridCacheVersion ver,
V old)
Updates cache index.
|
void |
GridNearCacheEntry.updateOrEvict(GridCacheVersion dhtVer,
V val,
byte[] valBytes,
long expireTime,
long ttl,
UUID primaryNodeId)
This method should be called only when lock is owned on this entry.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridNearTxRemote.ownedVersions(Map<K,GridCacheVersion> vers)
Adds owned versions to map.
|
void |
GridNearTxPrepareResponse.pending(Collection<GridCacheVersion> pending)
Sets pending versions that are less than
GridDistributedBaseMessage.version(). |
void |
GridNearLockResponse.pending(Collection<GridCacheVersion> pending)
Sets pending versions that are less than
GridDistributedBaseMessage.version(). |
void |
GridNearAtomicCache.removeAllDr(Map<? extends K,GridCacheVersion> drMap)
Removes DR data.
|
GridFuture<?> |
GridNearAtomicCache.removeAllDrAsync(Map<? extends K,GridCacheVersion> drMap)
Removes DR data asynchronously.
|
| Constructor and Description |
|---|
GridNearCacheClearAllRunnable(GridCacheAdapter<K,V> cache,
GridCacheVersion obsoleteVer,
GridCacheClearAllRunnable<K,V> dhtJob)
Constructor.
|
GridNearGetRequest(GridUuid futId,
GridUuid miniId,
GridCacheVersion ver,
LinkedHashMap<K,Boolean> keys,
boolean reload,
long topVer,
GridPredicate<GridCacheEntry<K,V>>[] filter,
UUID subjId) |
GridNearGetResponse(GridUuid futId,
GridUuid miniId,
GridCacheVersion ver) |
GridNearLockRequest(long topVer,
UUID nodeId,
long threadId,
GridUuid futId,
GridCacheVersion lockVer,
boolean isInTx,
boolean implicitTx,
boolean implicitSingleTx,
boolean isRead,
GridCacheTxIsolation isolation,
boolean isInvalidate,
long timeout,
boolean syncCommit,
boolean syncRollback,
int keyCnt,
int txSize,
Object grpLockKey,
boolean partLock,
UUID subjId) |
GridNearLockResponse(GridCacheVersion lockVer,
GridUuid futId,
GridUuid miniId,
boolean filterRes,
int cnt,
Throwable err) |
GridNearTxFinishRequest(GridUuid futId,
GridCacheVersion xidVer,
long threadId,
boolean commit,
boolean invalidate,
boolean explicitLock,
long topVer,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
int txSize,
Collection<GridCacheTxEntry<K,V>> writeEntries,
Collection<GridCacheTxEntry<K,V>> recoverEntries,
boolean reply,
UUID subjId) |
GridNearTxFinishResponse(GridCacheVersion xid,
long nearThreadId,
GridUuid futId,
GridUuid miniId,
Throwable err) |
GridNearTxPrepareResponse(GridCacheVersion xid,
GridUuid futId,
GridUuid miniId,
GridCacheVersion dhtVer,
Collection<Integer> invalidParts,
Throwable err) |
GridNearTxRemote(ClassLoader ldr,
UUID nodeId,
UUID nearNodeId,
long rmtThreadId,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
boolean invalidate,
long timeout,
Collection<GridCacheTxEntry<K,V>> writeEntries,
GridCacheContext<K,V> ctx,
int txSize,
Object grpLockKey,
UUID subjId)
This constructor is meant for optimistic transactions.
|
GridNearTxRemote(UUID nodeId,
UUID nearNodeId,
GridCacheVersion nearXidVer,
long rmtThreadId,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
boolean invalidate,
long timeout,
K key,
byte[] keyBytes,
V val,
byte[] valBytes,
GridCacheVersion drVer,
GridCacheContext<K,V> ctx,
int txSize,
Object grpLockKey,
UUID subjId)
This constructor is meant for pessimistic transactions.
|
| Constructor and Description |
|---|
GridNearTxFinishRequest(GridUuid futId,
GridCacheVersion xidVer,
long threadId,
boolean commit,
boolean invalidate,
boolean explicitLock,
long topVer,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
int txSize,
Collection<GridCacheTxEntry<K,V>> writeEntries,
Collection<GridCacheTxEntry<K,V>> recoverEntries,
boolean reply,
UUID subjId) |
GridNearTxFinishRequest(GridUuid futId,
GridCacheVersion xidVer,
long threadId,
boolean commit,
boolean invalidate,
boolean explicitLock,
long topVer,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
int txSize,
Collection<GridCacheTxEntry<K,V>> writeEntries,
Collection<GridCacheTxEntry<K,V>> recoverEntries,
boolean reply,
UUID subjId) |
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
GridCacheDrInfo.version() |
| Constructor and Description |
|---|
GridCacheDrExpirationInfo(V val,
GridCacheVersion ver,
long ttl,
long expireTime)
Constructor.
|
GridCacheDrInfo(V val,
GridCacheVersion ver)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
GridCacheMvccObsoleteEntryExtras.obsoleteVersion() |
GridCacheVersion |
GridCacheEntryExtras.obsoleteVersion() |
GridCacheVersion |
GridCacheObsoleteEntryExtras.obsoleteVersion() |
GridCacheVersion |
GridCacheMvccObsoleteTtlEntryExtras.obsoleteVersion() |
GridCacheVersion |
GridCacheAttributesMvccObsoleteEntryExtras.obsoleteVersion() |
GridCacheVersion |
GridCacheEntryExtrasAdapter.obsoleteVersion() |
GridCacheVersion |
GridCacheAttributesObsoleteTtlEntryExtras.obsoleteVersion() |
GridCacheVersion |
GridCacheAttributesMvccObsoleteTtlEntryExtras.obsoleteVersion() |
GridCacheVersion |
GridCacheObsoleteTtlEntryExtras.obsoleteVersion() |
GridCacheVersion |
GridCacheAttributesObsoleteEntryExtras.obsoleteVersion() |
| Modifier and Type | Method and Description |
|---|---|
GridCacheEntryExtras<K> |
GridCacheAttributesMvccTtlEntryExtras.obsoleteVersion(GridCacheVersion obsoleteVer) |
GridCacheEntryExtras<K> |
GridCacheMvccObsoleteEntryExtras.obsoleteVersion(GridCacheVersion obsoleteVer) |
GridCacheEntryExtras<K> |
GridCacheEntryExtras.obsoleteVersion(GridCacheVersion obsoleteVer) |
GridCacheEntryExtras<K> |
GridCacheMvccEntryExtras.obsoleteVersion(GridCacheVersion obsoleteVer) |
GridCacheEntryExtras<K> |
GridCacheTtlEntryExtras.obsoleteVersion(GridCacheVersion obsoleteVer) |
GridCacheEntryExtras<K> |
GridCacheObsoleteEntryExtras.obsoleteVersion(GridCacheVersion obsoleteVer) |
GridCacheEntryExtras<K> |
GridCacheMvccObsoleteTtlEntryExtras.obsoleteVersion(GridCacheVersion obsoleteVer) |
GridCacheEntryExtras<K> |
GridCacheAttributesMvccObsoleteEntryExtras.obsoleteVersion(GridCacheVersion obsoleteVer) |
GridCacheEntryExtras<K> |
GridCacheAttributesTtlEntryExtras.obsoleteVersion(GridCacheVersion obsoleteVer) |
GridCacheEntryExtras<K> |
GridCacheAttributesObsoleteTtlEntryExtras.obsoleteVersion(GridCacheVersion obsoleteVer) |
GridCacheEntryExtras<K> |
GridCacheAttributesMvccObsoleteTtlEntryExtras.obsoleteVersion(GridCacheVersion obsoleteVer) |
GridCacheEntryExtras<K> |
GridCacheObsoleteTtlEntryExtras.obsoleteVersion(GridCacheVersion obsoleteVer) |
GridCacheEntryExtras<K> |
GridCacheAttributesObsoleteEntryExtras.obsoleteVersion(GridCacheVersion obsoleteVer) |
GridCacheEntryExtras<K> |
GridCacheMvccTtlEntryExtras.obsoleteVersion(GridCacheVersion obsoleteVer) |
GridCacheEntryExtras<K> |
GridCacheAttributesMvccEntryExtras.obsoleteVersion(GridCacheVersion obsoleteVer) |
GridCacheEntryExtras<K> |
GridCacheAttributesEntryExtras.obsoleteVersion(GridCacheVersion obsoleteVer) |
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
GridLocalLockFuture.version() |
| Modifier and Type | Method and Description |
|---|---|
GridCacheMvccCandidate<K> |
GridLocalCacheEntry.addLocal(long threadId,
GridCacheVersion ver,
long timeout,
boolean reenter,
boolean tx,
boolean implicitSingle)
Add local candidate.
|
void |
GridLocalCache.onDeferredDelete(GridCacheEntryEx<K,V> entry,
GridCacheVersion ver) |
GridCacheMvccCandidate<K> |
GridLocalCacheEntry.readyLocal(GridCacheVersion ver) |
boolean |
GridLocalCacheEntry.removeLock(GridCacheVersion ver) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridLocalAtomicCache.onDeferredDelete(GridCacheEntryEx<K,V> entry,
GridCacheVersion ver) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheQueryManager.store(K key,
byte[] keyBytes,
V val,
byte[] valBytes,
GridCacheVersion ver,
long expirationTime)
Writes key-value pair to index.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
GridDrRawEntry.version() |
| Constructor and Description |
|---|
GridDrPlainEntry(K key,
V val,
long ttl,
long expireTime,
GridCacheVersion ver)
Constructor.
|
GridDrRawEntry(K key,
byte[] keyBytes,
V val,
byte[] valBytes,
long ttl,
long expireTime,
GridCacheVersion ver)
Constructor.
|
| Modifier and Type | Field and Description |
|---|---|
static GridCacheVersion |
GridTcpCommunicationMessageAdapter.CACHE_VER_NOT_READ |
| Modifier and Type | Method and Description |
|---|---|
GridCacheVersion |
GridTcpCommunicationMessageState.getCacheVersion() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridTcpCommunicationMessageState.putCacheVersion(GridCacheVersion ver) |
Copyright © 2014. All rights reserved.