src/core/interface.c

Go to the documentation of this file.

#include <sys/time.h>
#include <errno.h>
#include <pthread.h>
#include <stdio.h>
#include <stdlib.h>
#include <setjmp.h>
#include <assert.h>
#include <sched.h>
#include <misc/debug.h>
#include <misc/generic_types.h>
#include <core/stats.h>
#include <core/sentinel.h>
#include <core/koa.h>
#include <core/fm.h>
#include <core/buffer.h>
#include <core/config.h>
#include <core/tx.h>


extern txc_sentinelmgr_t *txc_g_sentinelmgr;
extern txc_buffermgr_t *txc_g_buffermgr;
extern txc_koamgr_t *txc_g_koamgr;
extern txc_txmgr_t *txc_g_txmgr;
extern txc_statsmgr_t *txc_g_statsmgr;


struct timeval txc_initialization_time;

int
_TXC_global_init()
{
        txc_config_init();
        txc_sentinelmgr_create(&txc_g_sentinelmgr);
        txc_buffermgr_create(&txc_g_buffermgr);
#ifdef _TXC_STATS_BUILD 
        txc_statsmgr_create(&txc_g_statsmgr);
#endif  
        txc_txmgr_create(&txc_g_txmgr, txc_g_buffermgr, txc_g_sentinelmgr, 
                         txc_g_statsmgr);
        txc_koamgr_create(&txc_g_koamgr, txc_g_sentinelmgr, txc_g_buffermgr);

        if (txc_runtime_settings.debug_all == TXC_BOOL_TRUE) {
                txc_runtime_settings.debug_koa      = TXC_BOOL_TRUE;
                txc_runtime_settings.debug_pool     = TXC_BOOL_TRUE;
                txc_runtime_settings.debug_sentinel = TXC_BOOL_TRUE;
                txc_runtime_settings.debug_tx       = TXC_BOOL_TRUE;
                txc_runtime_settings.debug_xcall    = TXC_BOOL_TRUE;
        }

        return (int) TXC_R_SUCCESS;
}


int
_TXC_global_shutdown()
{
        txc_stats_print(txc_g_statsmgr);

        return (int) TXC_R_SUCCESS;
}


int
_TXC_thread_init()
{
        txc_tx_create(txc_g_txmgr, &txc_l_txd);
        return (int) TXC_R_SUCCESS;
}


void                                                                          
_TXC_transaction_abort(txc_tx_abortreason_t abort_reason)
{
        txc_tx_abort_transaction(txc_l_txd, abort_reason);
}


txc_tx_xactstate_t
_TXC_get_xactstate() 
{
        txc_tx_t *txd = txc_l_txd;

        return txc_tx_get_xactstate(txd);
}


void
_TXC_transaction_pre_begin(const char *srcloc_str, const char *src_file, const char *src_fun, int src_line)
{
        txc_tx_t        *txd   = txc_l_txd;
        txc_tx_srcloc_t srcloc = {src_file, src_fun, src_line};

        txc_tx_pre_begin(txd, srcloc_str, &srcloc);
}


void
_TXC_transaction_post_begin()
{
        txc_tx_t        *txd   = txc_l_txd;

        txc_tx_post_begin(txd);
}


void
_TXC_fm_register(int flags, int *err)
{
        txc_tx_t        *txd   = txc_l_txd;

        txc_fm_register(txd, flags, err);
}

---