org.opendaylight.dsbenchmark.txchain

Class TxchainDomWrite

java.lang.Object

org.opendaylight.dsbenchmark.DatastoreAbstractWriter

org.opendaylight.dsbenchmark.txchain.TxchainDomWrite

All Implemented Interfaces:

EventListener, TransactionChainListener

public class TxchainDomWrite
extends DatastoreAbstractWriter
implements TransactionChainListener

Field Summary

Fields inherited from class org.opendaylight.dsbenchmark.DatastoreAbstractWriter

dataStore, innerListElem, oper, outerListElem, rn, txError, txOk, writesPerTx

Constructor Summary

Constructors

Constructor and Description
TxchainDomWrite(DOMDataBroker domDataBroker, StartTestInput.Operation oper, int outerListElem, int innerListElem, long writesPerTx, StartTestInput.DataStore dataStore)

Method Summary

Modifier and Type	Method and Description
void	createList()
void	executeList()
void	onTransactionChainFailed(TransactionChain<?,?> chain, AsyncTransaction<?,?> transaction, Throwable cause) Invoked if when a transaction in the chain fails.
void	onTransactionChainSuccessful(TransactionChain<?,?> chain) Invoked when a transaction chain is completed.

Methods inherited from class org.opendaylight.dsbenchmark.DatastoreAbstractWriter

getDataStoreType, getTxError, getTxOk

Methods inherited from class java.lang.Object

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

Constructor Detail

TxchainDomWrite

public TxchainDomWrite(DOMDataBroker domDataBroker,
                       StartTestInput.Operation oper,
                       int outerListElem,
                       int innerListElem,
                       long writesPerTx,
                       StartTestInput.DataStore dataStore)

Method Detail

createList

public void createList()

Specified by:

createList in class DatastoreAbstractWriter

executeList

public void executeList()

Specified by:

executeList in class DatastoreAbstractWriter

onTransactionChainFailed

public void onTransactionChainFailed(TransactionChain<?,?> chain,
                                     AsyncTransaction<?,?> transaction,
                                     Throwable cause)

Description copied from interface: TransactionChainListener

Invoked if when a transaction in the chain fails. All other transactions are automatically cancelled by the time this notification is invoked. Implementations should invoke chain.close() to close the chain.

Specified by:

onTransactionChainFailed in interface TransactionChainListener

Parameters:

chain - Transaction chain which failed

transaction - Transaction which caused the chain to fail

cause - The cause of transaction failure

onTransactionChainSuccessful

public void onTransactionChainSuccessful(TransactionChain<?,?> chain)

Description copied from interface: TransactionChainListener

Invoked when a transaction chain is completed. A transaction chain is considered completed when it has been closed and all its instructions have completed successfully.

Specified by:

onTransactionChainSuccessful in interface TransactionChainListener

Parameters:

chain - Transaction chain which completed