org.gridgain.grid.kernal.processors.cache

Interface GridCacheTxRemoteEx<K,V>

All Superinterfaces:

AutoCloseable, GridCacheTx, GridCacheTxEx<K,V>, GridMetadataAware, GridTimeoutObject, Serializable

All Known Implementing Classes:

GridDhtTxRemote, GridDistributedTxRemoteAdapter, GridNearTxRemote

public interface GridCacheTxRemoteEx<K,V>
extends GridCacheTxEx<K,V>

Local transaction API.

Nested Class Summary

Nested classes/interfaces inherited from interface org.gridgain.grid.kernal.processors.cache.GridCacheTxEx

GridCacheTxEx.FinalizationStatus

Method Summary

Methods

Modifier and Type	Method and Description
void	addRemoteCandidates(Map<K,Collection<GridCacheMvccCandidate<K>>> cands, Collection<GridCacheVersion> committedVers, Collection<GridCacheVersion> rolledbackVers) Adds remote candidates and completed versions to all involved entries.
void	doneRemote(GridCacheVersion baseVer, Collection<GridCacheVersion> committedVers, Collection<GridCacheVersion> rolledbackVers, Collection<GridCacheVersion> pendingVers)
long	remoteThreadId()
boolean	setWriteValue(GridCacheTxEntry<K,V> e)

Methods inherited from interface org.gridgain.grid.kernal.processors.cache.GridCacheTxEx

addInvalidPartition, addLocalCandidates, allEntries, alternateVersions, colocated, commitVersion, commitVersion, completedVersions, dht, done, empty, endVersion, endVersion, enforceSerializable, entry, eventNodeId, finishFuture, groupLock, groupLockKey, hasReadKey, hasWriteKey, implicitSingle, internal, invalidate, invalidPartitions, isSystemInvalidate, local, localCandidates, markFinalizing, markPreparing, masterNodeIds, near, nearXidVersion, needsCompletedVersions, onePhaseCommit, onOwnerChanged, optimistic, optimisticLockEntries, originatingNodeId, otherNodeId, ownedVersion, ownsLock, ownsLockUnsafe, peek, pessimistic, prepare, prepareAsync, readCommitted, readEntries, readMap, readSet, recoveryWrites, remainingTime, removed, repeatableRead, replicated, rollbackAsync, seal, serializable, size, startVersion, state, subjectId, syncCommit, syncRollback, systemInvalidate, timedOut, topologyVersion, topologyVersion, transactionNodes, user, writeEntries, writeMap, writeSet, writeVersion, writeVersion, xidVersion

Methods inherited from interface org.gridgain.grid.cache.GridCacheTx

close, commit, commitAsync, concurrency, implicit, isInvalidate, isolation, isRollbackOnly, nodeId, rollback, setRollbackOnly, startTime, state, threadId, timeout, timeout, xid

Methods inherited from interface org.gridgain.grid.GridMetadataAware

addMeta, addMetaIfAbsent, addMetaIfAbsent, allMeta, copyMeta, copyMeta, hasMeta, hasMeta, meta, putMetaIfAbsent, putMetaIfAbsent, removeMeta, removeMeta, replaceMeta

Methods inherited from interface org.gridgain.grid.kernal.processors.timeout.GridTimeoutObject

endTime, onTimeout, timeoutId

Method Detail

remoteThreadId

long remoteThreadId()

Returns:

Remote thread ID.

doneRemote

void doneRemote(GridCacheVersion baseVer,
              Collection<GridCacheVersion> committedVers,
              Collection<GridCacheVersion> rolledbackVers,
              Collection<GridCacheVersion> pendingVers)

Parameters:

baseVer - Base version.

committedVers - Committed version.

rolledbackVers - Rolled back version.

pendingVers - Pending versions.

setWriteValue

boolean setWriteValue(GridCacheTxEntry<K,V> e)

Parameters:

e - Sets write value for pessimistic transactions.

Returns:

True if entry was found.

addRemoteCandidates

void addRemoteCandidates(Map<K,Collection<GridCacheMvccCandidate<K>>> cands,
                       Collection<GridCacheVersion> committedVers,
                       Collection<GridCacheVersion> rolledbackVers)

Adds remote candidates and completed versions to all involved entries.

Parameters:

cands - Candidates.

committedVers - Committed versions.

rolledbackVers - Rolled back versions.