com.sleepycat.je.txn

Class BasicLocker

java.lang.Object

com.sleepycat.je.txn.Locker

com.sleepycat.je.txn.BasicLocker

Direct Known Subclasses:

BuddyLocker, ThreadLocker

public class BasicLocker
extends Locker

A concrete Locker that simply tracks locks and releases them when operationEnd is called.

Field Summary

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

defaultNoWait, deleteInfo, envImpl, handleLockToHandleMap, handleToHandleLockMap, id, lockManager, lockTimeOutMillis, readUncommittedDefault, thread

Constructor Summary

Constructors

Constructor and Description
BasicLocker(EnvironmentImpl env) Creates a BasicLocker.

Method Summary

Methods

Modifier and Type	Method and Description
protected void	checkState(boolean ignoreCalledByAbort)
LockStats	collectStats(LockStats stats) stats
boolean	createdNode(long nodeId) Always false for this txn.
protected long	generateId(TxnManager txnManager) BasicLockers always have a fixed id, because they are never used for recovery.
long	getAbortLsn(long nodeId)
long	getOwnerAbortLsn(long nodeId) Get the abort LSN for this node in the txn that owns the lock on this node.
Txn	getTxnLocker() No transactional locker is available.
WriteLockInfo	getWriteLockInfo(long nodeId)
Locker	getWriteOwnerLocker(long nodeId) Get the txn that owns the lock on this node.
boolean	isReadCommittedIsolation() Is never read-committed isolation.
boolean	isSerializableIsolation() Is never serializable isolation.
boolean	isTransactional() Is never transactional.
void	markDeleteAtTxnEnd(DatabaseImpl db, boolean deleteAtCommit) Database operations like remove and truncate leave behind residual DatabaseImpls that must be purged at transaction commit or abort.
Locker	newNonTxnLocker() Creates a new instance of this txn for the same environment.
void	operationEnd() Release locks at the end of the transaction.
void	operationEnd(boolean operationOK) Release locks at the end of the transaction.
void	registerCursor(CursorImpl cursor) This txn doesn't store cursors.
void	releaseNonTxnLocks() Releases all locks, since all locks held by this locker are non-transactional.
void	setHandleLockOwner(boolean operationOK, Database dbHandle, boolean dbIsClosing) Transfer any MapLN locks to the db handle.
void	unRegisterCursor(CursorImpl cursor) This txn doesn't store cursors.

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

addDeleteInfo, addToHandleMaps, demoteLock, dumpLockTable, getDefaultNoWait, getId, getLockTimeout, getTxnTimeOut, isHandleLockTransferrable, isReadUncommittedDefault, isTimedOut, lock, nonBlockingLock, operationEnd, releaseLock, setLockTimeout, setTxnTimeout, sharesLocksWith, toString, transferHandleLock

Methods inherited from class java.lang.Object

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

Constructor Detail

BasicLocker

public BasicLocker(EnvironmentImpl env)
            throws DatabaseException

Creates a BasicLocker.

Throws:

DatabaseException

Method Detail

generateId

protected long generateId(TxnManager txnManager)

BasicLockers always have a fixed id, because they are never used for recovery.

Specified by:

generateId in class Locker

checkState

protected void checkState(boolean ignoreCalledByAbort)
                   throws DatabaseException

Specified by:

checkState in class Locker

Throws:

DatabaseException

getWriteOwnerLocker

public Locker getWriteOwnerLocker(long nodeId)
                           throws DatabaseException

Get the txn that owns the lock on this node. Return null if there's no owning txn found.

Throws:

DatabaseException

getOwnerAbortLsn

public long getOwnerAbortLsn(long nodeId)
                      throws DatabaseException

Get the abort LSN for this node in the txn that owns the lock on this node. Return null if there's no owning txn found.

Throws:

DatabaseException

isTransactional

public boolean isTransactional()

Is never transactional.

Specified by:

isTransactional in class Locker

isSerializableIsolation

public boolean isSerializableIsolation()

Is never serializable isolation.

Specified by:

isSerializableIsolation in class Locker

isReadCommittedIsolation

public boolean isReadCommittedIsolation()

Is never read-committed isolation.

Specified by:

isReadCommittedIsolation in class Locker

getTxnLocker

public Txn getTxnLocker()

No transactional locker is available.

Specified by:

getTxnLocker in class Locker

newNonTxnLocker

public Locker newNonTxnLocker()
                       throws DatabaseException

Creates a new instance of this txn for the same environment. No transactional locks are held by this object, so no locks are retained.

Specified by:

newNonTxnLocker in class Locker

Throws:

DatabaseException

releaseNonTxnLocks

public void releaseNonTxnLocks()
                        throws DatabaseException

Releases all locks, since all locks held by this locker are non-transactional.

Specified by:

releaseNonTxnLocks in class Locker

Throws:

DatabaseException

operationEnd

public void operationEnd()
                  throws DatabaseException

Release locks at the end of the transaction.

Specified by:

operationEnd in class Locker

Throws:

DatabaseException

operationEnd

public void operationEnd(boolean operationOK)
                  throws DatabaseException

Release locks at the end of the transaction.

Specified by:

operationEnd in class Locker

Parameters:

operationOK - is whether the operation succeeded, since that may impact ending behavior. (i.e for AutoTxn)

Throws:

DatabaseException

setHandleLockOwner

public void setHandleLockOwner(boolean operationOK,
                      Database dbHandle,
                      boolean dbIsClosing)
                        throws DatabaseException

Transfer any MapLN locks to the db handle.

Specified by:

setHandleLockOwner in class Locker

Throws:

DatabaseException

registerCursor

public void registerCursor(CursorImpl cursor)
                    throws DatabaseException

This txn doesn't store cursors.

Specified by:

registerCursor in class Locker

Throws:

DatabaseException

unRegisterCursor

public void unRegisterCursor(CursorImpl cursor)
                      throws DatabaseException

This txn doesn't store cursors.

Specified by:

unRegisterCursor in class Locker

Throws:

DatabaseException

getAbortLsn

public long getAbortLsn(long nodeId)
                 throws DatabaseException

Specified by:

getAbortLsn in class Locker

Returns:

the abort LSN for this node.

Throws:

DatabaseException

getWriteLockInfo

public WriteLockInfo getWriteLockInfo(long nodeId)
                               throws DatabaseException

Specified by:

getWriteLockInfo in class Locker

Returns:

a dummy WriteLockInfo for this node.

Throws:

DatabaseException

markDeleteAtTxnEnd

public void markDeleteAtTxnEnd(DatabaseImpl db,
                      boolean deleteAtCommit)
                        throws DatabaseException

Description copied from class: Locker

Database operations like remove and truncate leave behind residual DatabaseImpls that must be purged at transaction commit or abort.

Specified by:

markDeleteAtTxnEnd in class Locker

Throws:

DatabaseException

createdNode

public boolean createdNode(long nodeId)
                    throws DatabaseException

Always false for this txn.

Specified by:

createdNode in class Locker

Returns:

true if this transaction created this node, for a operation with transactional semantics.

Throws:

DatabaseException

collectStats

public LockStats collectStats(LockStats stats)
                       throws DatabaseException

stats

Specified by:

collectStats in class Locker

Throws:

DatabaseException