com.hazelcast.transaction.impl

Class TransactionImpl

java.lang.Object

com.hazelcast.transaction.impl.TransactionImpl

All Implemented Interfaces:

Transaction

Direct Known Subclasses:

AllowedDuringPassiveStateTransactionImpl

public class TransactionImpl
extends Object
implements Transaction

Nested Class Summary

Nested classes/interfaces inherited from interface com.hazelcast.transaction.impl.Transaction

Transaction.State

Constructor Summary

Constructors

Constructor and Description
TransactionImpl(TransactionManagerServiceImpl transactionManagerService, NodeEngine nodeEngine, TransactionOptions options, String txOwnerUuid)
TransactionImpl(TransactionManagerServiceImpl transactionManagerService, NodeEngine nodeEngine, TransactionOptions options, String txOwnerUuid, boolean originatedFromClient)

Method Summary

Methods

Modifier and Type	Method and Description
void	add(TransactionLogRecord record)
void	begin()
void	commit()
protected CreateTxBackupLogOperation	createCreateTxBackupLogOperation()
protected PurgeTxBackupLogOperation	createPurgeTxBackupLogOperation()
protected ReplicateTxBackupLogOperation	createReplicateTxBackupLogOperation()
protected RollbackTxBackupLogOperation	createRollbackTxBackupLogOperation()
void	ensureBackupLogsExist() Some data-structures like the Transaction List rely on (empty) backup logs to be created before any change on the data-structure is made.
TransactionLogRecord	get(Object key)
String	getOwnerUuid()
long	getStartTime()
Transaction.State	getState()
long	getTimeoutMillis()
protected TransactionLog	getTransactionLog()
String	getTxnId()
boolean	isOriginatedFromClient()
void	prepare()
void	remove(Object key)
boolean	requiresPrepare() Checks if this Transaction needs to be prepared.
void	rollback()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

TransactionImpl

public TransactionImpl(TransactionManagerServiceImpl transactionManagerService,
               NodeEngine nodeEngine,
               TransactionOptions options,
               String txOwnerUuid)

TransactionImpl

public TransactionImpl(TransactionManagerServiceImpl transactionManagerService,
               NodeEngine nodeEngine,
               TransactionOptions options,
               String txOwnerUuid,
               boolean originatedFromClient)

Method Detail

getTxnId

public String getTxnId()

Specified by:

getTxnId in interface Transaction

getStartTime

public long getStartTime()

getOwnerUuid

public String getOwnerUuid()

Specified by:

getOwnerUuid in interface Transaction

isOriginatedFromClient

public boolean isOriginatedFromClient()

Specified by:

isOriginatedFromClient in interface Transaction

getState

public Transaction.State getState()

Specified by:

getState in interface Transaction

getTimeoutMillis

public long getTimeoutMillis()

Specified by:

getTimeoutMillis in interface Transaction

getTransactionLog

protected TransactionLog getTransactionLog()

add

public void add(TransactionLogRecord record)

Specified by:

add in interface Transaction

get

public TransactionLogRecord get(Object key)

Specified by:

get in interface Transaction

remove

public void remove(Object key)

Specified by:

remove in interface Transaction

begin

public void begin()
           throws IllegalStateException

Specified by:

begin in interface Transaction

Throws:

IllegalStateException

prepare

public void prepare()
             throws TransactionException

Specified by:

prepare in interface Transaction

Throws:

TransactionException

requiresPrepare

public boolean requiresPrepare()

Checks if this Transaction needs to be prepared.

Preparing a transaction costs time since the backup log potentially needs to be copied and each logrecord needs to prepare its content (e.g. by acquiring locks). This takes time.

If a transaction is local or if there is 1 or 0 items in the transaction log, instead of preparing, we are just going to try to commit. If the lock is still acquired, the write succeeds, and if the lock isn't acquired, the write fails; the same effect as a prepare would have.

Returns:

true if prepare() is required.

commit

public void commit()
            throws TransactionException,
                   IllegalStateException

Specified by:

commit in interface Transaction

Throws:

TransactionException

IllegalStateException

rollback

public void rollback()
              throws IllegalStateException

Specified by:

rollback in interface Transaction

Throws:

IllegalStateException

ensureBackupLogsExist

public void ensureBackupLogsExist()

Some data-structures like the Transaction List rely on (empty) backup logs to be created before any change on the data-structure is made. That is why when such a data-structure is loaded, it should the creation.

Not every data-structure, e.g. the Transactional Map, relies on it and in some cases can even skip it.

createCreateTxBackupLogOperation

protected CreateTxBackupLogOperation createCreateTxBackupLogOperation()

createReplicateTxBackupLogOperation

protected ReplicateTxBackupLogOperation createReplicateTxBackupLogOperation()

createRollbackTxBackupLogOperation

protected RollbackTxBackupLogOperation createRollbackTxBackupLogOperation()

createPurgeTxBackupLogOperation

protected PurgeTxBackupLogOperation createPurgeTxBackupLogOperation()

toString

public String toString()

Overrides:

toString in class Object