Package org.infinispan.transaction.impl
Class RemoteTransaction
- java.lang.Object
-
- org.infinispan.transaction.impl.AbstractCacheTransaction
-
- org.infinispan.transaction.impl.RemoteTransaction
-
- All Implemented Interfaces:
Cloneable
,CacheTransaction
- Direct Known Subclasses:
RecoveryAwareRemoteTransaction
public class RemoteTransaction extends AbstractCacheTransaction implements Cloneable
Defines the state of a remotely originated transaction.- Since:
- 4.0
- Author:
- Mircea.Markus@jboss.com
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.infinispan.transaction.xa.CacheTransaction
CacheTransaction.TransactionCompletedListener
-
-
Field Summary
-
Fields inherited from class org.infinispan.transaction.impl.AbstractCacheTransaction
affectedKeys, lookedUpEntries, modifications, topologyId, tx
-
-
Constructor Summary
Constructors Constructor Description RemoteTransaction(org.infinispan.commands.write.WriteCommand[] modifications, GlobalTransaction tx, int topologyId, long txCreationTime)
RemoteTransaction(GlobalTransaction tx, int topologyId, long txCreationTime)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Object
clone()
CompletableFuture<Void>
enterSynchronizationAsync(CompletableFuture<Void> releaseFuture)
boolean
equals(Object o)
TotalOrderRemoteTransactionState
getTransactionState()
int
hashCode()
int
lookedUpEntriesTopology()
void
putLookedUpEntries(Map<Object,CacheEntry> entries)
void
putLookedUpEntry(Object key, CacheEntry e)
void
setLookedUpEntriesTopology(int lookedUpEntriesTopology)
void
setStateTransferFlag(Flag stateTransferFlag)
String
toString()
-
Methods inherited from class org.infinispan.transaction.impl.AbstractCacheTransaction
addAffectedKey, addAllAffectedKeys, addBackupLockForKey, addListener, addVersionRead, areLocksReleased, cleanupBackupLocks, clearLockedKeys, clearLookedUpEntries, containsLockOrBackupLock, findAnyLockedOrBackupLocked, forEachBackupLock, freezeModifications, getAffectedKeys, getAllModifications, getBackupLockedKeys, getCreationTime, getGlobalTransaction, getLockedKeys, getLookedUpEntries, getModifications, getReleaseFutureForKey, getReleaseFutureForKeys, getStateTransferFlag, getTopologyId, getUpdatedEntryVersions, getVersionsRead, hasModification, isFromStateTransfer, isMarkedForRollback, lookupEntry, markForRollback, notifyOnTransactionFinished, ownsLock, registerLockedKey, removeBackupLock, removeBackupLocks, removeLookedUpEntry, setModifications, setUpdatedEntryVersions, waitForLockRelease
-
Methods inherited from class java.lang.Object
finalize, getClass, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.infinispan.transaction.xa.CacheTransaction
addReadKey, getLookedUpRemoteVersion, keyRead, putLookedUpRemoteVersion, replaceVersionRead
-
-
-
-
Constructor Detail
-
RemoteTransaction
public RemoteTransaction(org.infinispan.commands.write.WriteCommand[] modifications, GlobalTransaction tx, int topologyId, long txCreationTime)
-
RemoteTransaction
public RemoteTransaction(GlobalTransaction tx, int topologyId, long txCreationTime)
-
-
Method Detail
-
setStateTransferFlag
public void setStateTransferFlag(Flag stateTransferFlag)
- Specified by:
setStateTransferFlag
in classAbstractCacheTransaction
-
putLookedUpEntry
public void putLookedUpEntry(Object key, CacheEntry e)
- Specified by:
putLookedUpEntry
in interfaceCacheTransaction
-
putLookedUpEntries
public void putLookedUpEntries(Map<Object,CacheEntry> entries)
- Specified by:
putLookedUpEntries
in interfaceCacheTransaction
-
setLookedUpEntriesTopology
public void setLookedUpEntriesTopology(int lookedUpEntriesTopology)
-
lookedUpEntriesTopology
public int lookedUpEntriesTopology()
-
getTransactionState
public final TotalOrderRemoteTransactionState getTransactionState()
- Returns:
- get (or create if needed) the
TotalOrderRemoteTransactionState
associated to this remote transaction
-
enterSynchronizationAsync
public final CompletableFuture<Void> enterSynchronizationAsync(CompletableFuture<Void> releaseFuture)
-
-