src/core/fm.c

Go to the documentation of this file.

#include <misc/result.h>
#include <misc/malloc.h>
#include <misc/debug.h>
#include <misc/mutex.h>
#include <misc/generic_types.h>
#include <core/config.h>
#include <core/fm.h>
#include <core/tx.h>
#include <core/txdesc.h>

void
txc_fm_init(txc_tx_t *txd)
{
        txd->fm_abort = TXC_BOOL_FALSE;
        txd->fm_error_result = 0;
        txd->fm_flags = 0;
}

void
txc_fm_register(txc_tx_t *txd, int flags, int *error_result)
{
        txd->fm_flags = flags;
        txd->fm_error_result = error_result;
}


void 
txc_fm_transaction_postbegin(txc_tx_t *txd)
{
        if (txd->fm_abort == TXC_BOOL_TRUE) {
                txc_tx_abort_transaction(txd, TXC_ABORTREASON_USERABORT);
        }
}


void
txc_fm_handle_commit_failure(txc_tx_t *txd, int error_result)
{
        if (txd->fm_error_result) {
                *txd->fm_error_result = error_result;
        }       
}


void
txc_fm_handle_undo_failure(txc_tx_t *txd, int error_result)
{
        if (error_result) {
                if (txd->fm_error_result) {
                        *txd->fm_error_result = error_result;
                }       
                if (txd->fm_flags && TXC_FM_NO_RETRY) {
                        /* 
                         * The transaction is already at the rollback state and will
                         * restart after finished with the undo actions. Set the
                         * fm_abort flag so that we abort the transaction right
                         * after restart.
                         */
                        txd->fm_abort = TXC_BOOL_TRUE;
                }       
        }
        /* 
         * Reset the failure flags for the next dynamic instance of the 
         * current transaction.
         */
        txd->fm_flags = 0;
}

---