com.sleepycat.je.txn

Class Txn

java.lang.Object

com.sleepycat.je.txn.Locker

com.sleepycat.je.txn.Txn

All Implemented Interfaces:

Loggable

Direct Known Subclasses:

AutoTxn

public class Txn
extends Locker
implements Loggable

A Txn is one that's created by a call to Environment.txnBegin. This class must support multithreaded use.

Field Summary

Fields

Modifier and Type	Field and Description
static int	ACCUMULATED_LIMIT
static byte	TXN_NOSYNC
static byte	TXN_SYNC
static byte	TXN_WRITE_NOSYNC

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
Txn() Constructor for reading from log.
Txn(EnvironmentImpl envImpl, TransactionConfig config) Create a transaction from Environment.txnBegin.
Txn(EnvironmentImpl envImpl, TransactionConfig config, long id)

Method Summary

Methods

Modifier and Type	Method and Description
long	abort(boolean forceFlush) Abort this transaction.
void	abort(javax.transaction.xa.Xid xid)
void	addLogInfo(long lastLsn) Called by the recovery manager when logging a transaction aware object.
protected void	checkState(boolean calledByAbort) Throw an exception if the transaction is not open.
LockStats	collectStats(LockStats stats) stats
long	commit() Call commit() with the default sync configuration property.
long	commit(byte flushSyncBehavior) Commit this transaction 1.
void	commit(javax.transaction.xa.Xid xid)
boolean	createdNode(long nodeId)
void	dumpLog(java.lang.StringBuffer sb, boolean verbose) Write the object into the string buffer for log dumping.
protected long	generateId(TxnManager txnManager) UserTxns get a new unique id for each instance.
long	getAbortLsn(long nodeId)
int	getLogSize()
boolean	getOnlyAbortable() Get the state of a transaction's ONLY_ABORTABLE.
boolean	getPrepared()
long	getTransactionId()
Txn	getTxnLocker() This is a transactional locker.
WriteLockInfo	getWriteLockInfo(long nodeId)
boolean	isHandleLockTransferrable()
boolean	isReadCommittedIsolation() Is read-committed isolation if so configured.
boolean	isSerializableIsolation() Is serializable isolation if so configured.
boolean	isSuspended()
boolean	isTransactional() Is always transactional.
void	markDeleteAtTxnEnd(DatabaseImpl dbImpl, boolean deleteAtCommit) Database operations like remove and truncate leave behind residual DatabaseImpls that must be purged at transaction commit or abort.
Locker	newNonTxnLocker() Returns 'this', since this locker holds no non-transactional locks.
void	operationEnd() Created transactions do nothing at the end of the operation.
void	operationEnd(boolean operationOK) Created transactions do nothing at the end of the operation.
int	prepare(javax.transaction.xa.Xid xid)
void	readFromLog(java.nio.ByteBuffer logBuffer, byte entryTypeVersion) Initialize this object from the data in itemBuf.
void	registerCursor(CursorImpl cursor) Cursors operating under this transaction are added to the collection.
void	releaseNonTxnLocks() This locker holds no non-transactional locks.
void	setHandleLockOwner(boolean ignore, Database dbHandle, boolean dbIsClosing) Created transactions don't transfer locks until commit.
void	setOnlyAbortable() Set the state of a transaction to ONLY_ABORTABLE.
void	setPrepared(boolean prepared)
void	setSuspended(boolean suspended)
void	unRegisterCursor(CursorImpl cursor) Remove a cursor from the collection.
void	writeToLog(java.nio.ByteBuffer logBuffer) Serialize this object into the buffer.

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

addDeleteInfo, addToHandleMaps, demoteLock, dumpLockTable, getDefaultNoWait, getId, getLockTimeout, getTxnTimeOut, 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

Field Detail

TXN_NOSYNC

public static final byte TXN_NOSYNC

See Also:

Constant Field Values

TXN_WRITE_NOSYNC

public static final byte TXN_WRITE_NOSYNC

See Also:

Constant Field Values

TXN_SYNC

public static final byte TXN_SYNC

See Also:

Constant Field Values

ACCUMULATED_LIMIT

public static int ACCUMULATED_LIMIT

Constructor Detail

Txn

public Txn(EnvironmentImpl envImpl,
   TransactionConfig config)
    throws DatabaseException

Create a transaction from Environment.txnBegin.

Throws:

DatabaseException

Txn

public Txn(EnvironmentImpl envImpl,
   TransactionConfig config,
   long id)
    throws DatabaseException

Throws:

DatabaseException

Txn

public Txn()

Constructor for reading from log.

Method Detail

generateId

protected long generateId(TxnManager txnManager)

UserTxns get a new unique id for each instance.

Specified by:

generateId in class Locker

getPrepared

public boolean getPrepared()

setPrepared

public void setPrepared(boolean prepared)

setSuspended

public void setSuspended(boolean suspended)

isSuspended

public boolean isSuspended()

prepare

public int prepare(javax.transaction.xa.Xid xid)
            throws DatabaseException

Throws:

DatabaseException

commit

public void commit(javax.transaction.xa.Xid xid)
            throws DatabaseException

Throws:

DatabaseException

abort

public void abort(javax.transaction.xa.Xid xid)
           throws DatabaseException

Throws:

DatabaseException

commit

public long commit()
            throws DatabaseException

Call commit() with the default sync configuration property.

Throws:

DatabaseException

commit

public long commit(byte flushSyncBehavior)
            throws DatabaseException

Commit this transaction 1. Releases read locks 2. Writes a txn commit record into the log 3. Flushes the log to disk. 4. Add deleted LN info to IN compressor queue 5. Release all write locks If any step of this fails, we must convert this transaction to an abort.

Throws:

DatabaseException

abort

public long abort(boolean forceFlush)
           throws DatabaseException

Abort this transaction. Steps are: 1. Release LN read locks. 2. Write a txn abort entry to the log. This is only for log file cleaning optimization and there's no need to guarantee a flush to disk. 3. Find the last LN log entry written for this txn, and use that to traverse the log looking for nodes to undo. For each node, use the same undo logic as recovery to rollback the transaction. Note that we walk the log in order to undo in reverse order of the actual operations. For example, suppose the txn did this: delete K1/D1 (in LN 10) create K1/D1 (in LN 20) If we process LN10 before LN 20, we'd inadvertently create a duplicate tree of "K1", which would be fatal for the mapping tree. 4. Release the write lock for this LN.

Throws:

DatabaseException

addLogInfo

public void addLogInfo(long lastLsn)
                throws DatabaseException

Called by the recovery manager when logging a transaction aware object. This method is synchronized by the caller, by being called within the log latch. Record the last LSN for this transaction, to create the transaction chain, and also record the LSN in the write info for abort logic.

Throws:

DatabaseException

markDeleteAtTxnEnd

public void markDeleteAtTxnEnd(DatabaseImpl dbImpl,
                      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

Parameters:

dbImpl - databaseImpl to remove

deleteAtCommit - true if this databaseImpl should be cleaned on commit, false if it should be cleaned on abort.

mb - environment memory budget.

Throws:

DatabaseException

createdNode

public boolean createdNode(long nodeId)
                    throws DatabaseException

Specified by:

createdNode in class Locker

Returns:

true if this transaction created this node. We know that this is true if the node is write locked and has a null abort LSN.

Throws:

DatabaseException

getAbortLsn

public long getAbortLsn(long nodeId)
                 throws DatabaseException

Specified by:

getAbortLsn in class Locker

Returns:

the abortLsn for this node.

Throws:

DatabaseException

getWriteLockInfo

public WriteLockInfo getWriteLockInfo(long nodeId)
                               throws DatabaseException

Specified by:

getWriteLockInfo in class Locker

Returns:

the WriteLockInfo for this node.

Throws:

DatabaseException

isTransactional

public boolean isTransactional()

Is always transactional.

Specified by:

isTransactional in class Locker

isSerializableIsolation

public boolean isSerializableIsolation()

Is serializable isolation if so configured.

Specified by:

isSerializableIsolation in class Locker

isReadCommittedIsolation

public boolean isReadCommittedIsolation()

Is read-committed isolation if so configured.

Specified by:

isReadCommittedIsolation in class Locker

getTxnLocker

public Txn getTxnLocker()

This is a transactional locker.

Specified by:

getTxnLocker in class Locker

newNonTxnLocker

public Locker newNonTxnLocker()
                       throws DatabaseException

Returns 'this', since this locker holds no non-transactional locks.

Specified by:

newNonTxnLocker in class Locker

Throws:

DatabaseException

releaseNonTxnLocks

public void releaseNonTxnLocks()
                        throws DatabaseException

This locker holds no non-transactional locks.

Specified by:

releaseNonTxnLocks in class Locker

Throws:

DatabaseException

operationEnd

public void operationEnd()
                  throws DatabaseException

Created transactions do nothing at the end of the operation.

Specified by:

operationEnd in class Locker

Throws:

DatabaseException

operationEnd

public void operationEnd(boolean operationOK)
                  throws DatabaseException

Created transactions do nothing at the end of the operation.

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 ignore,
                      Database dbHandle,
                      boolean dbIsClosing)
                        throws DatabaseException

Created transactions don't transfer locks until commit.

Specified by:

setHandleLockOwner in class Locker

Throws:

DatabaseException

registerCursor

public void registerCursor(CursorImpl cursor)
                    throws DatabaseException

Cursors operating under this transaction are added to the collection.

Specified by:

registerCursor in class Locker

Throws:

DatabaseException

unRegisterCursor

public void unRegisterCursor(CursorImpl cursor)
                      throws DatabaseException

Remove a cursor from the collection.

Specified by:

unRegisterCursor in class Locker

Throws:

DatabaseException

isHandleLockTransferrable

public boolean isHandleLockTransferrable()

Overrides:

isHandleLockTransferrable in class Locker

Returns:

true if this txn is willing to give up the handle lock to another txn before this txn ends.

collectStats

public LockStats collectStats(LockStats stats)
                       throws DatabaseException

stats

Specified by:

collectStats in class Locker

Throws:

DatabaseException

setOnlyAbortable

public void setOnlyAbortable()

Set the state of a transaction to ONLY_ABORTABLE.

getOnlyAbortable

public boolean getOnlyAbortable()

Get the state of a transaction's ONLY_ABORTABLE.

checkState

protected void checkState(boolean calledByAbort)
                   throws DatabaseException

Throw an exception if the transaction is not open. If calledByAbort is true, it means we're being called from abort(). Caller must invoke with "this" synchronized.

Specified by:

checkState in class Locker

Throws:

DatabaseException

getLogSize

public int getLogSize()

Specified by:

getLogSize in interface Loggable

Returns:

number of bytes used to store this object.

See Also:

Loggable.getLogSize()

writeToLog

public void writeToLog(java.nio.ByteBuffer logBuffer)

Description copied from interface: Loggable

Serialize this object into the buffer.

Specified by:

writeToLog in interface Loggable

Parameters:

logBuffer - is the destination buffer

See Also:

Loggable.writeToLog(java.nio.ByteBuffer)

readFromLog

public void readFromLog(java.nio.ByteBuffer logBuffer,
               byte entryTypeVersion)

Description copied from interface: Loggable

Initialize this object from the data in itemBuf.

Specified by:

readFromLog in interface Loggable

See Also:

It's ok for FindBugs to whine about id not being synchronized.

dumpLog

public void dumpLog(java.lang.StringBuffer sb,
           boolean verbose)

Description copied from interface: Loggable

Write the object into the string buffer for log dumping. Each object should be dumped without indentation or new lines and should be valid XML.

Specified by:

dumpLog in interface Loggable

Parameters:

sb - destination string buffer

verbose - if true, dump the full, verbose version

See Also:

Loggable.dumpLog(java.lang.StringBuffer, boolean)

getTransactionId

public long getTransactionId()

Specified by:

getTransactionId in interface Loggable

Returns:

the transaction id embedded within this loggable object. Objects that have no transaction id should return 0.

See Also:

Loggable.getTransactionId()