com.sleepycat.je.txn

Class LatchedLockManager

java.lang.Object

com.sleepycat.je.txn.LockManager

com.sleepycat.je.txn.LatchedLockManager

All Implemented Interfaces:

EnvConfigObserver

public class LatchedLockManager
extends LockManager

LatchedLockManager uses latches to implement its critical sections.

Field Summary

Fields inherited from class com.sleepycat.je.txn.LockManager

lockTableLatches, nLockTables, TOTAL_LOCKIMPL_OVERHEAD, TOTAL_THINLOCKIMPL_OVERHEAD

Constructor Summary

Constructors

Constructor and Description
LatchedLockManager(EnvironmentImpl envImpl)

Method Summary

Methods

Modifier and Type	Method and Description
protected LockAttemptResult	attemptLock(java.lang.Long nodeId, Locker locker, LockType type, boolean nonBlockingRequest)
(package private) void	demote(long nodeId, Locker locker) Demote a lock from write to read.
protected void	dumpLockTable(LockStats stats) Dump the lock table to the lock stats.
(package private) Locker	getWriteOwnerLocker(java.lang.Long nodeId)
(package private) boolean	isLocked(java.lang.Long nodeId) Test the status of the lock on nodeId.
(package private) boolean	isOwner(java.lang.Long nodeId, Locker locker, LockType type) Return true if this locker owns this a lock of this type on given node.
(package private) boolean	isWaiter(java.lang.Long nodeId, Locker locker) Return true if this locker is waiting on this lock.
protected Lock	lookupLock(java.lang.Long nodeId)
protected DeadlockException	makeTimeoutMsg(java.lang.String lockOrTxn, Locker locker, long nodeId, LockType type, LockGrantType grantType, Lock useLock, long timeout, long start, long now, DatabaseImpl database) Create a informative lock or txn timeout message.
(package private) int	nOwners(java.lang.Long nodeId) Return the number of owners of this lock.
(package private) int	nWaiters(java.lang.Long nodeId) Return the number of waiters for this lock.
protected java.util.Set<Locker>	releaseAndFindNotifyTargets(long nodeId, Locker locker) Release the lock, and return the set of new owners to notify, if any.
(package private) void	transfer(long nodeId, Locker owningLocker, Locker destLocker, boolean demoteToRead) Transfer ownership a lock from one locker to another locker.
(package private) void	transferMultiple(long nodeId, Locker owningLocker, Locker[] destLockers) Transfer ownership a lock from one locker to a set of other txns, cloning the lock as necessary.
protected boolean	validateOwnership(java.lang.Long nodeId, Locker locker, LockType type, boolean flushFromWaiters, MemoryBudget mb)

Methods inherited from class com.sleepycat.je.txn.LockManager

attemptLockInternal, demoteInternal, dump, dumpLockTableInternal, dumpToString, envConfigUpdate, getLockTableIndex, getLockTableIndex, getWriteOwnerLockerInternal, isLockedInternal, isOwnerInternal, isWaiterInternal, lock, lockStat, lookupLockInternal, makeTimeoutMsgInternal, nOwnersInternal, nWaitersInternal, release, releaseAndFindNotifyTargetsInternal, setLockTableDump, transferInternal, transferMultipleInternal, validateOwnershipInternal

Methods inherited from class java.lang.Object

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

Constructor Detail

LatchedLockManager

public LatchedLockManager(EnvironmentImpl envImpl)
                   throws DatabaseException

Throws:

DatabaseException

Method Detail

lookupLock

protected Lock lookupLock(java.lang.Long nodeId)
                   throws DatabaseException

Specified by:

lookupLock in class LockManager

Throws:

DatabaseException

See Also:

LockManager.lookupLock(java.lang.Long)

attemptLock

protected LockAttemptResult attemptLock(java.lang.Long nodeId,
                            Locker locker,
                            LockType type,
                            boolean nonBlockingRequest)
                                 throws DatabaseException

Specified by:

attemptLock in class LockManager

Throws:

DatabaseException

See Also:

LockManager.attemptLock(java.lang.Long, com.sleepycat.je.txn.Locker, com.sleepycat.je.txn.LockType, boolean)

makeTimeoutMsg

protected DeadlockException makeTimeoutMsg(java.lang.String lockOrTxn,
                               Locker locker,
                               long nodeId,
                               LockType type,
                               LockGrantType grantType,
                               Lock useLock,
                               long timeout,
                               long start,
                               long now,
                               DatabaseImpl database)
                                    throws DatabaseException

Description copied from class: LockManager

Create a informative lock or txn timeout message.

Specified by:

makeTimeoutMsg in class LockManager

Throws:

DatabaseException

See Also:

LockManager.makeTimeoutMsg(java.lang.String, com.sleepycat.je.txn.Locker, long, com.sleepycat.je.txn.LockType, com.sleepycat.je.txn.LockGrantType, com.sleepycat.je.txn.Lock, long, long, long, com.sleepycat.je.dbi.DatabaseImpl)

releaseAndFindNotifyTargets

protected java.util.Set<Locker> releaseAndFindNotifyTargets(long nodeId,
                                                Locker locker)
                                                     throws DatabaseException

Description copied from class: LockManager

Release the lock, and return the set of new owners to notify, if any.

Specified by:

releaseAndFindNotifyTargets in class LockManager

Returns:

null if the lock does not exist or the given locker was not the owner, a non-empty set if owners should be notified after releasing, an empty set if no notification is required.

Throws:

DatabaseException

See Also:

LockManager#releaseAndNotifyTargets

transfer

void transfer(long nodeId,
            Locker owningLocker,
            Locker destLocker,
            boolean demoteToRead)
        throws DatabaseException

Description copied from class: LockManager

Transfer ownership a lock from one locker to another locker. We're not sending any notification to the waiters on the lock table, and the past and present owner should be ready for the transfer.

Specified by:

transfer in class LockManager

Throws:

DatabaseException

See Also:

LockManager.transfer(long, com.sleepycat.je.txn.Locker, com.sleepycat.je.txn.Locker, boolean)

transferMultiple

void transferMultiple(long nodeId,
                    Locker owningLocker,
                    Locker[] destLockers)
                throws DatabaseException

Description copied from class: LockManager

Transfer ownership a lock from one locker to a set of other txns, cloning the lock as necessary. This will always be demoted to read, as we can't have multiple locker owners any other way. We're not sending any notification to the waiters on the lock table, and the past and present owners should be ready for the transfer.

Specified by:

transferMultiple in class LockManager

Throws:

DatabaseException

See Also:

LockManager.transferMultiple(long, com.sleepycat.je.txn.Locker, com.sleepycat.je.txn.Locker[])

demote

void demote(long nodeId,
          Locker locker)
      throws DatabaseException

Description copied from class: LockManager

Demote a lock from write to read. Call back to the owning locker to move this to its read collection.

Specified by:

demote in class LockManager

Throws:

DatabaseException

See Also:

LockManager.demote(long, com.sleepycat.je.txn.Locker)

isLocked

boolean isLocked(java.lang.Long nodeId)
           throws DatabaseException

Description copied from class: LockManager

Test the status of the lock on nodeId. If any transaction holds any lock on it, true is returned. If no transaction holds a lock on it, false is returned. This method is only used by unit tests.

Specified by:

isLocked in class LockManager

Parameters:

nodeId - The NodeId to check.

Returns:

true if any transaction holds any lock on the nodeid. false if no lock is held by any transaction.

Throws:

DatabaseException

See Also:

LockManager.isLocked(java.lang.Long)

isOwner

boolean isOwner(java.lang.Long nodeId,
              Locker locker,
              LockType type)
          throws DatabaseException

Description copied from class: LockManager

Return true if this locker owns this a lock of this type on given node. This method is only used by unit tests.

Specified by:

isOwner in class LockManager

Throws:

DatabaseException

See Also:

LockManager.isOwner(java.lang.Long, com.sleepycat.je.txn.Locker, com.sleepycat.je.txn.LockType)

isWaiter

boolean isWaiter(java.lang.Long nodeId,
               Locker locker)
           throws DatabaseException

Description copied from class: LockManager

Return true if this locker is waiting on this lock. This method is only used by unit tests.

Specified by:

isWaiter in class LockManager

Throws:

DatabaseException

See Also:

LockManager.isWaiter(java.lang.Long, com.sleepycat.je.txn.Locker)

nWaiters

int nWaiters(java.lang.Long nodeId)
       throws DatabaseException

Description copied from class: LockManager

Return the number of waiters for this lock.

Specified by:

nWaiters in class LockManager

Throws:

DatabaseException

See Also:

LockManager.nWaiters(java.lang.Long)

nOwners

int nOwners(java.lang.Long nodeId)
      throws DatabaseException

Description copied from class: LockManager

Return the number of owners of this lock.

Specified by:

nOwners in class LockManager

Throws:

DatabaseException

See Also:

LockManager.nOwners(java.lang.Long)

getWriteOwnerLocker

Locker getWriteOwnerLocker(java.lang.Long nodeId)
                     throws DatabaseException

Specified by:

getWriteOwnerLocker in class LockManager

Returns:

the transaction that owns the write lock for this

Throws:

DatabaseException

See Also:

LockManager#getWriterOwnerLocker

validateOwnership

protected boolean validateOwnership(java.lang.Long nodeId,
                        Locker locker,
                        LockType type,
                        boolean flushFromWaiters,
                        MemoryBudget mb)
                             throws DatabaseException

Specified by:

validateOwnership in class LockManager

Throws:

DatabaseException

See Also:

LockManager.validateOwnership(java.lang.Long, com.sleepycat.je.txn.Locker, com.sleepycat.je.txn.LockType, boolean, com.sleepycat.je.dbi.MemoryBudget)

dumpLockTable

protected void dumpLockTable(LockStats stats)
                      throws DatabaseException

Description copied from class: LockManager

Dump the lock table to the lock stats.

Specified by:

dumpLockTable in class LockManager

Throws:

DatabaseException

See Also:

LockManager.dumpLockTable(com.sleepycat.je.LockStats)