File transaction_cl.c¶

FileList > cubrid > src > transaction > transaction_cl.c

#include "config.h"
#include <unistd.h>
#include <stdio.h>
#include <sys/param.h>
#include "dbi.h"
#include "misc_string.h"
#include "transaction_cl.h"
#include "memory_alloc.h"
#include "locator_cl.h"
#include "work_space.h"
#include "server_interface.h"
#include "log_comm.h"
#include "log_lsa.hpp"
#include "db_query.h"
#include "boot_cl.h"
#include "virtual_object.h"
#include "schema_manager.h"
#include "trigger_manager.h"
#include "system_parameter.h"
#include "db.h"
#include "porting.h"
#include "network_interface_cl.h"
#include "tcp.h"

Public Types¶

Type	Name
enum	LATEST_QUERY_STATUS

Public Attributes¶

Type	Name
int	tm_Tran_ID = `-1`
bool	tm_Tran_async_ws = `[false](broker__monitor_8c.md#function-timeout)`
bool	tm_Tran_check_interrupt = `[true](broker__monitor_8c.md#function-timeout)`
int	tm_Tran_index = `[NULL\_TRAN\_INDEX](storage__common_8h.md#define-null_tran_index)`
int	tm_Tran_invalidate_snapshot = `1`
TRAN_ISOLATION	tm_Tran_isolation = `TRAN\_UNKNOWN\_ISOLATION`
int	tm_Tran_latest_query_status
LC_FETCH_VERSION_TYPE	tm_Tran_read_fetch_instance_version = `LC\_FETCH\_MVCC\_VERSION`
LOCK	tm_Tran_rep_read_lock = `NULL\_LOCK`
int	tm_Tran_wait_msecs = `(-1)`
bool	tm_Use_OID_preflush = `[true](broker__monitor_8c.md#function-timeout)`

Public Static Attributes¶

Type	Name
UINT64	tm_Query_begin = `0`
int	tm_Query_timeout = `0`
int	tm_libcas_depth = `0`
DB_NAMELIST *	user_savepoint_list = `[NULL](freelistheap_8h.md#define-null)`

Public Functions¶

Type	Name
int	tran_2pc_attach_global_tran (int gtrid)
int	tran_2pc_prepare (void)
int	tran_2pc_prepare_global_tran (int gtrid)
int	tran_2pc_recovery_prepared (int gtrids, int size)
int	tran_2pc_start (void)
int	tran_abort (void)
int	tran_abort_only_client (bool is_server_down)
int	tran_abort_upto_system_savepoint (const char * savepoint_name)
int	tran_abort_upto_user_savepoint (const char * savepoint_name)
void	tran_begin_libcas_function (void)
void	tran_cache_tran_settings (int tran_index, int lock_timeout, TRAN_ISOLATION tran_isolation)
int	tran_commit (bool retain_lock)
void	tran_end_libcas_function (void)
int	tran_flush_to_commit (void)
void	tran_free_savepoint_list (void)
bool	tran_get_check_interrupt (void)
int	tran_get_global_tran_info (int gtrid, void * buffer, int size)
int	tran_get_libcas_depth (void)
int	tran_get_query_timeout (void)
void	tran_get_tran_settings (int * lock_wait_in_msecs, TRAN_ISOLATION * tran_isolation, bool * async_ws)
bool	tran_has_updated (void)
int	tran_internal_abort_upto_savepoint (const char * savepoint_name, SAVEPOINT_TYPE savepoint_type, bool client_decache_all_but_norealclasses)
bool	tran_is_active_and_has_updated (void)
bool	tran_is_in_libcas (void)
bool	tran_is_reset_required (void)
int	tran_reset_isolation (TRAN_ISOLATION isolation, bool async_ws)
void	tran_reset_latest_query_status (void)
void	tran_reset_libcas_function (void)
int	tran_reset_wait_times (int wait_in_msecs)
int	tran_savepoint_internal (const char * savept_name, SAVEPOINT_TYPE savepoint_type)
bool	tran_set_check_interrupt (bool flag)
int	tran_set_global_tran_info (int gtrid, void * info, int size)
void	tran_set_latest_query_status (int end_query_result, int tran_state, int should_conn_reset)
void	tran_set_query_timeout (int query_timeout)
int	tran_system_savepoint (const char * savept_name)
int	tran_unilaterally_abort (void)
bool	tran_was_latest_query_aborted (void)
bool	tran_was_latest_query_committed (void)
bool	tran_was_latest_query_ended (void)

Public Static Functions¶

Type	Name
int	tran_add_savepoint (const char * savept_name)
UINT64	tran_current_timemillis (void)
void	tran_free_list_upto_savepoint (const char * savept_name)

Public Types Documentation¶

enum LATEST_QUERY_STATUS¶

enum LATEST_QUERY_STATUS {
    NONE = 0,
    ABORTED = 0x1000,
    QUERY_ENDED = 0x100,
    COMMITTED = 0x10,
    RESET_REQUIRED = 0x1
};

Public Attributes Documentation¶

variable tm_Tran_ID¶

int tm_Tran_ID;

variable tm_Tran_async_ws¶

bool tm_Tran_async_ws;

variable tm_Tran_check_interrupt¶

bool tm_Tran_check_interrupt;

variable tm_Tran_index¶

int tm_Tran_index;

variable tm_Tran_invalidate_snapshot¶

int tm_Tran_invalidate_snapshot;

variable tm_Tran_isolation¶

TRAN_ISOLATION tm_Tran_isolation;

variable tm_Tran_latest_query_status¶

int tm_Tran_latest_query_status;

variable tm_Tran_read_fetch_instance_version¶

LC_FETCH_VERSION_TYPE tm_Tran_read_fetch_instance_version;

variable tm_Tran_rep_read_lock¶

LOCK tm_Tran_rep_read_lock;

variable tm_Tran_wait_msecs¶

int tm_Tran_wait_msecs;

variable tm_Use_OID_preflush¶

bool tm_Use_OID_preflush;

Public Static Attributes Documentation¶

variable tm_Query_begin¶

UINT64 tm_Query_begin;

variable tm_Query_timeout¶

int tm_Query_timeout;

variable tm_libcas_depth¶

int tm_libcas_depth;

variable user_savepoint_list¶

DB_NAMELIST* user_savepoint_list;

Public Functions Documentation¶

function tran_2pc_attach_global_tran¶

int tran_2pc_attach_global_tran (
    int gtrid
)

function tran_2pc_prepare¶

int tran_2pc_prepare (
    void
)

function tran_2pc_prepare_global_tran¶

int tran_2pc_prepare_global_tran (
    int gtrid
)

function tran_2pc_recovery_prepared¶

int tran_2pc_recovery_prepared (
    int gtrids,
    int size
)

function tran_2pc_start¶

int tran_2pc_start (
    void
)

function tran_abort¶

int tran_abort (
    void
)

function tran_abort_only_client¶

int tran_abort_only_client (
    bool is_server_down
)

function tran_abort_upto_system_savepoint¶

int tran_abort_upto_system_savepoint (
    const  char * savepoint_name
)

function tran_abort_upto_user_savepoint¶

int tran_abort_upto_user_savepoint (
    const  char * savepoint_name
)

function tran_begin_libcas_function¶

void tran_begin_libcas_function (
    void
)

function tran_cache_tran_settings¶

void tran_cache_tran_settings (
    int tran_index,
    int lock_timeout,
    TRAN_ISOLATION tran_isolation
)

function tran_commit¶

int tran_commit (
    bool retain_lock
)

function tran_end_libcas_function¶

void tran_end_libcas_function (
    void
)

function tran_flush_to_commit¶

int tran_flush_to_commit (
    void
)

function tran_free_savepoint_list¶

void tran_free_savepoint_list (
    void
)

function tran_get_check_interrupt¶

bool tran_get_check_interrupt (
    void
)

function tran_get_global_tran_info¶

int tran_get_global_tran_info (
    int gtrid,
    void * buffer,
    int size
)

function tran_get_libcas_depth¶

int tran_get_libcas_depth (
    void
)

function tran_get_query_timeout¶

int tran_get_query_timeout (
    void
)

function tran_get_tran_settings¶

void tran_get_tran_settings (
    int * lock_wait_in_msecs,
    TRAN_ISOLATION * tran_isolation,
    bool * async_ws
)

function tran_has_updated¶

bool tran_has_updated (
    void
)

function tran_internal_abort_upto_savepoint¶

int tran_internal_abort_upto_savepoint (
    const  char * savepoint_name,
    SAVEPOINT_TYPE savepoint_type,
    bool client_decache_all_but_norealclasses
)

function tran_is_active_and_has_updated¶

bool tran_is_active_and_has_updated (
    void
)

function tran_is_in_libcas¶

bool tran_is_in_libcas (
    void
)

function tran_is_reset_required¶

bool tran_is_reset_required (
    void
)

function tran_reset_isolation¶

int tran_reset_isolation (
    TRAN_ISOLATION isolation,
    bool async_ws
)

function tran_reset_latest_query_status¶

void tran_reset_latest_query_status (
    void
)

function tran_reset_libcas_function¶

void tran_reset_libcas_function (
    void
)

function tran_reset_wait_times¶

int tran_reset_wait_times (
    int wait_in_msecs
)

function tran_savepoint_internal¶

int tran_savepoint_internal (
    const  char * savept_name,
    SAVEPOINT_TYPE savepoint_type
)

function tran_set_check_interrupt¶

bool tran_set_check_interrupt (
    bool flag
)

function tran_set_global_tran_info¶

int tran_set_global_tran_info (
    int gtrid,
    void * info,
    int size
)

function tran_set_latest_query_status¶

void tran_set_latest_query_status (
    int end_query_result,
    int tran_state,
    int should_conn_reset
)

function tran_set_query_timeout¶

void tran_set_query_timeout (
    int query_timeout
)

function tran_system_savepoint¶

int tran_system_savepoint (
    const  char * savept_name
)

function tran_unilaterally_abort¶

int tran_unilaterally_abort (
    void
)

function tran_was_latest_query_aborted¶

bool tran_was_latest_query_aborted (
    void
)

function tran_was_latest_query_committed¶

bool tran_was_latest_query_committed (
    void
)

function tran_was_latest_query_ended¶

bool tran_was_latest_query_ended (
    void
)

Public Static Functions Documentation¶

function tran_add_savepoint¶

static int tran_add_savepoint (
    const  char * savept_name
)

function tran_current_timemillis¶

static UINT64 tran_current_timemillis (
    void
)

function tran_free_list_upto_savepoint¶

static void tran_free_list_upto_savepoint (
    const  char * savept_name
)

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