public class RemoteTransaction extends AbstractCacheTransaction implements Cloneable
CacheTransaction.TransactionCompletedListener
affectedKeys, lookedUpEntries, modifications, topologyId, tx
Constructor and Description |
---|
RemoteTransaction(GlobalTransaction tx,
int topologyId,
long txCreationTime) |
RemoteTransaction(WriteCommand[] modifications,
GlobalTransaction tx,
int topologyId,
long txCreationTime) |
Modifier and Type | Method and Description |
---|---|
Object |
clone() |
CompletableFuture<Void> |
enterSynchronizationAsync(CompletableFuture<Void> releaseFuture) |
boolean |
equals(Object o) |
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() |
addAffectedKey, addAllAffectedKeys, addBackupLockForKey, addListener, addVersionRead, cleanupBackupLocks, clearLockedKeys, clearLookedUpEntries, forEachBackupLock, forEachLock, 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
public RemoteTransaction(WriteCommand[] modifications, GlobalTransaction tx, int topologyId, long txCreationTime)
public RemoteTransaction(GlobalTransaction tx, int topologyId, long txCreationTime)
public void setStateTransferFlag(Flag stateTransferFlag)
setStateTransferFlag
in class AbstractCacheTransaction
public void putLookedUpEntry(Object key, CacheEntry e)
putLookedUpEntry
in interface CacheTransaction
public void putLookedUpEntries(Map<Object,CacheEntry> entries)
putLookedUpEntries
in interface CacheTransaction
public void setLookedUpEntriesTopology(int lookedUpEntriesTopology)
public int lookedUpEntriesTopology()
public final CompletableFuture<Void> enterSynchronizationAsync(CompletableFuture<Void> releaseFuture)
Copyright © 2021 JBoss by Red Hat. All rights reserved.