File transaction_sr.c¶

FileList > cubrid > src > transaction > transaction_sr.c

#include "config.h"
#include <assert.h>
#include "transaction_sr.h"
#include "locator_sr.h"
#include "log_2pc.h"
#include "log_lsa.hpp"
#include "log_manager.h"
#include "xserver_interface.h"
#include "server_support.h"
#include "dbtype.h"
#include "thread_manager.hpp"
#include "memory_wrapper.hpp"

Public Functions¶

Type	Name
TRAN_STATE	tran_server_unilaterally_abort (THREAD_ENTRY * thread_p, int tran_index)
TRAN_STATE	tran_server_unilaterally_abort_tran (THREAD_ENTRY * thread_p)
int	xtran_get_local_transaction_id (THREAD_ENTRY * thread_p, DB_VALUE * trid)
bool	xtran_is_blocked (THREAD_ENTRY * thread_p, int tran_index)
int	xtran_lock_rep_read (THREAD_ENTRY * thread_p, LOCK lock_rr_tran)
int	xtran_server_2pc_attach_global_tran (THREAD_ENTRY * thread_p, int gtrid)
TRAN_STATE	xtran_server_2pc_prepare (THREAD_ENTRY * thread_p)
TRAN_STATE	xtran_server_2pc_prepare_global_tran (THREAD_ENTRY * thread_p, int global_tranid)
int	xtran_server_2pc_recovery_prepared (THREAD_ENTRY * thread_p, int gtrids, int size)
int	xtran_server_2pc_start (THREAD_ENTRY * thread_p)
TRAN_STATE	xtran_server_abort (THREAD_ENTRY * thread_p)
TRAN_STATE	xtran_server_commit (THREAD_ENTRY * thread_p, bool retain_lock)
TRAN_STATE	xtran_server_end_topop (THREAD_ENTRY * thread_p, LOG_RESULT_TOPOP result, LOG_LSA * topop_lsa)
int	xtran_server_get_global_tran_info (THREAD_ENTRY * thread_p, int gtrid, void * buffer, int size)
bool	xtran_server_has_updated (THREAD_ENTRY * thread_p)
int	xtran_server_is_active_and_has_updated (THREAD_ENTRY * thread_p)
TRAN_STATE	xtran_server_partial_abort (THREAD_ENTRY * thread_p, const char * savept_name, LOG_LSA * savept_lsa)
int	xtran_server_savepoint (THREAD_ENTRY * thread_p, const char * savept_name, LOG_LSA * savept_lsa)
int	xtran_server_set_global_tran_info (THREAD_ENTRY * thread_p, int gtrid, void * info, int size)
int	xtran_server_start_topop (THREAD_ENTRY * thread_p, LOG_LSA * topop_lsa)
bool	xtran_should_connection_reset (THREAD_ENTRY * thread_p, bool has_updated)
int	xtran_wait_server_active_trans (THREAD_ENTRY * thread_p)

Public Functions Documentation¶

function tran_server_unilaterally_abort¶

TRAN_STATE tran_server_unilaterally_abort (
    THREAD_ENTRY * thread_p,
    int tran_index
)

function tran_server_unilaterally_abort_tran¶

TRAN_STATE tran_server_unilaterally_abort_tran (
    THREAD_ENTRY * thread_p
)

function xtran_get_local_transaction_id¶

int xtran_get_local_transaction_id (
    THREAD_ENTRY * thread_p,
    DB_VALUE * trid
)

function xtran_is_blocked¶

bool xtran_is_blocked (
    THREAD_ENTRY * thread_p,
    int tran_index
)

function xtran_lock_rep_read¶

int xtran_lock_rep_read (
    THREAD_ENTRY * thread_p,
    LOCK lock_rr_tran
)

function xtran_server_2pc_attach_global_tran¶

int xtran_server_2pc_attach_global_tran (
    THREAD_ENTRY * thread_p,
    int gtrid
)

function xtran_server_2pc_prepare¶

TRAN_STATE xtran_server_2pc_prepare (
    THREAD_ENTRY * thread_p
)

function xtran_server_2pc_prepare_global_tran¶

TRAN_STATE xtran_server_2pc_prepare_global_tran (
    THREAD_ENTRY * thread_p,
    int global_tranid
)

function xtran_server_2pc_recovery_prepared¶

int xtran_server_2pc_recovery_prepared (
    THREAD_ENTRY * thread_p,
    int gtrids,
    int size
)

function xtran_server_2pc_start¶

int xtran_server_2pc_start (
    THREAD_ENTRY * thread_p
)

function xtran_server_abort¶

TRAN_STATE xtran_server_abort (
    THREAD_ENTRY * thread_p
)

function xtran_server_commit¶

TRAN_STATE xtran_server_commit (
    THREAD_ENTRY * thread_p,
    bool retain_lock
)

function xtran_server_end_topop¶

TRAN_STATE xtran_server_end_topop (
    THREAD_ENTRY * thread_p,
    LOG_RESULT_TOPOP result,
    LOG_LSA * topop_lsa
)

function xtran_server_get_global_tran_info¶

int xtran_server_get_global_tran_info (
    THREAD_ENTRY * thread_p,
    int gtrid,
    void * buffer,
    int size
)

function xtran_server_has_updated¶

bool xtran_server_has_updated (
    THREAD_ENTRY * thread_p
)

function xtran_server_is_active_and_has_updated¶

int xtran_server_is_active_and_has_updated (
    THREAD_ENTRY * thread_p
)

function xtran_server_partial_abort¶

TRAN_STATE xtran_server_partial_abort (
    THREAD_ENTRY * thread_p,
    const  char * savept_name,
    LOG_LSA * savept_lsa
)

function xtran_server_savepoint¶

int xtran_server_savepoint (
    THREAD_ENTRY * thread_p,
    const  char * savept_name,
    LOG_LSA * savept_lsa
)

function xtran_server_set_global_tran_info¶

int xtran_server_set_global_tran_info (
    THREAD_ENTRY * thread_p,
    int gtrid,
    void * info,
    int size
)

function xtran_server_start_topop¶

int xtran_server_start_topop (
    THREAD_ENTRY * thread_p,
    LOG_LSA * topop_lsa
)

function xtran_should_connection_reset¶

bool xtran_should_connection_reset (
    THREAD_ENTRY * thread_p,
    bool has_updated
)

function xtran_wait_server_active_trans¶

int xtran_wait_server_active_trans (
    THREAD_ENTRY * thread_p
)

The documentation for this class was generated from the following file cubrid/src/transaction/transaction_sr.c