src/tm/itm.h

Go to the documentation of this file.

#if (_TM_SYSTEM_ITM)

#ifndef _TXC_ITM_H
#define _TXC_ITM_H

#include <itm.h>

static inline
void
tmsystem_tx_init(txc_tx_t *txd)
{
        txd->itm_td = _ITM_getTransaction();
        txd->tid = (unsigned int) _ITM_getThreadnum();
}


_ITM_CALL_CONVENTION void
tmsystem_generic_undo_action(void *arg) 
{
        tx_generic_undo_action((txc_tx_t *) arg);
}


_ITM_CALL_CONVENTION void
tmsystem_generic_commit_action(void *arg) 
{
        tx_generic_commit_action((txc_tx_t *) arg);
}


static inline 
void
tmsystem_register_generic_undo_action(txc_tx_t *txd)
{
        if (txd->generic_undo_action_registered == 0) {
                _ITM_addUserUndoAction(txd->itm_td, 
                                       tmsystem_generic_undo_action, (void *) txd);
                txd->generic_undo_action_registered = 1;                                           
        }
}


static inline 
void
tmsystem_register_generic_commit_action(txc_tx_t *txd)
{
        if (txd->generic_commit_action_registered == 0) {
                /* 
                 * Using ticket number 2 to register commit action to the outer 
                 * transaction 
                 */
                _ITM_addUserCommitAction(txd->itm_td, 
                                         tmsystem_generic_commit_action, 2, (void *) txd);
                txd->generic_commit_action_registered = 1;                                         
        }
}


static inline
void
tmsystem_abort_transaction(txc_tx_t *txd, txc_tx_abortreason_t abort_reason)
{
        tmsystem_register_generic_undo_action(txd);
    txd->abort_reason = abort_reason;
        txd->forced_retries++;
        switch (abort_reason) {
                case TXC_ABORTREASON_USERABORT:
                        _ITM_abortTransaction(txd->itm_td, userAbort, NULL);
                        break;
                case TXC_ABORTREASON_TMCONFLICT:
                        _ITM_abortTransaction(txd->itm_td, TMConflict, NULL);
                        break;
                case TXC_ABORTREASON_USERRETRY:
                case TXC_ABORTREASON_BUSYSENTINEL:
                case TXC_ABORTREASON_INCONSISTENCY:
                case TXC_ABORTREASON_BUSYTXLOCK:
                        _ITM_abortTransaction(txd->itm_td, userRetry, NULL);
                        break;
                default:
                        TXC_INTERNALERROR("Unknown abort reason\n");
                        /* never returns here */
        }
}


static inline 
txc_tx_xactstate_t
tmsystem_get_xactstate(txc_tx_t *txd) 
{
    _ITM_transaction *td;
    _ITM_howExecuting mode;

    td = txd->itm_td;
    mode = _ITM_inTransaction(td);
        switch (mode) {
                case outsideTransaction:
                        return TXC_XACTSTATE_NONTRANSACTIONAL;
                case inRetryableTransaction:
                        return TXC_XACTSTATE_TRANSACTIONAL_RETRYABLE;
                case inIrrevocableTransaction:
                        return TXC_XACTSTATE_TRANSACTIONAL_IRREVOCABLE;
                default:
                        TXC_INTERNALERROR("Unknown transaction state"); 
        }   
}


#endif /* _TXC_ITM_H */

#endif /* _TM_SYSTEM_ITM */

---