Class TransactionKeyLockManager

java.lang.Object

com.loomcache.server.transaction.TransactionKeyLockManager

public final class TransactionKeyLockManager
extends Object

Owns pessimistic transactional map-key lock state.

The state is an owner-token table, not a JVM lock held across the transaction lifetime. That keeps Raft apply threads non-blocking: applying TX_LOCK_KEY either records ownership for the transaction or fails fast when another transaction owns the same map/key.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	TransactionKeyLockManager.LockedKey

Constructor Summary

Constructors

Constructor	Description
TransactionKeyLockManager()

Method Summary

Modifier and Type	Method	Description
void	assertMapWriteAllowed(@Nullable UUID transactionId, String mapName)
void	assertWriteAllowed(@Nullable UUID transactionId, String mapName, String key)
boolean	isLockedByOther(@Nullable UUID transactionId, String mapName, String key)
void	lock(UUID transactionId, String mapName, String key)
void	lockAll(UUID transactionId, Collection<TransactionKeyLockManager.LockedKey> lockedKeys)
void	releaseAll(UUID transactionId)
List<TransactionKeyLockManager.LockedKey>	snapshotLocks(UUID transactionId)
static @Nullable UUID	transactionIdFromSenderId(@Nullable String senderId)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TransactionKeyLockManager

public TransactionKeyLockManager()

Method Details

lock

public void lock(UUID transactionId,
 String mapName,
 String key)

lockAll

public void lockAll(UUID transactionId,
 Collection<TransactionKeyLockManager.LockedKey> lockedKeys)

assertWriteAllowed

public void assertWriteAllowed(@Nullable UUID transactionId,
 String mapName,
 String key)

assertMapWriteAllowed

public void assertMapWriteAllowed(@Nullable UUID transactionId,
 String mapName)

releaseAll

public void releaseAll(UUID transactionId)

snapshotLocks

public List<TransactionKeyLockManager.LockedKey> snapshotLocks(UUID transactionId)

isLockedByOther

public boolean isLockedByOther(@Nullable UUID transactionId,
 String mapName,
 String key)

transactionIdFromSenderId

public static @Nullable UUID transactionIdFromSenderId(@Nullable String senderId)