#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"

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

Functions
static int	tran_add_savepoint (const char *savept_name)

static void	tran_free_list_upto_savepoint (const char *savept_name)

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

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

int	tran_reset_wait_times (int wait_in_msecs)

int	tran_reset_isolation (TRAN_ISOLATION isolation, bool async_ws)

int	tran_flush_to_commit (void)

int	tran_commit (bool retain_lock)

int	tran_abort (void)

int	tran_unilaterally_abort (void)

int	tran_abort_only_client (bool is_server_down)

bool	tran_has_updated (void)

bool	tran_is_active_and_has_updated (void)

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

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

int	tran_2pc_start (void)

int	tran_2pc_prepare (void)

int	tran_2pc_recovery_prepared (int gtrids[], int size)

int	tran_2pc_attach_global_tran (int gtrid)

int	tran_2pc_prepare_global_tran (int gtrid)

void	tran_free_savepoint_list (void)

int	tran_system_savepoint (const char *savept_name)

int	tran_savepoint_internal (const char *savept_name, SAVEPOINT_TYPE savepoint_type)

int	tran_abort_upto_system_savepoint (const char *savepoint_name)

int	tran_abort_upto_user_savepoint (const char *savepoint_name)

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

static UINT64	tran_current_timemillis (void)

void	tran_set_query_timeout (int query_timeout)

int	tran_get_query_timeout (void)

void	tran_begin_libcas_function (void)

void	tran_end_libcas_function (void)

bool	tran_is_in_libcas (void)

bool	tran_set_check_interrupt (bool flag)

bool	tran_get_check_interrupt (void)

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

void	tran_reset_latest_query_status (void)

bool	tran_was_latest_query_ended (void)

bool	tran_was_latest_query_committed (void)

bool	tran_was_latest_query_aborted (void)

bool	tran_is_reset_required (void)

Variables
int	tm_Tran_index = NULL_TRAN_INDEX

TRAN_ISOLATION	tm_Tran_isolation = TRAN_UNKNOWN_ISOLATION

bool	tm_Tran_async_ws = false

int	tm_Tran_wait_msecs = TRAN_LOCK_INFINITE_WAIT

bool	tm_Tran_check_interrupt = false

int	tm_Tran_ID = -1

int	tm_Tran_invalidate_snapshot = 1

LOCK	tm_Tran_rep_read_lock = NULL_LOCK

LC_FETCH_VERSION_TYPE	tm_Tran_read_fetch_instance_version = LC_FETCH_MVCC_VERSION

int	tm_Tran_latest_query_status

static UINT64	tm_Query_begin = 0

static int	tm_Query_timeout = 0

static bool	tm_Is_libcas = false

static DB_NAMELIST *	user_savepoint_list = NULL

bool	tm_Use_OID_preflush = true

Enumeration Type Documentation

enum LATEST_QUERY_STATUS

Enumerator
NONE
ABORTED
QUERY_ENDED
COMMITTED
RESET_REQUIRED

Definition at line 1366 of file transaction_cl.c.

Function Documentation

int tran_2pc_attach_global_tran ( int gtrid )

Definition at line 840 of file transaction_cl.c.

References assert, er_errid(), NO_ERROR, NULL_TRAN_INDEX, tm_Tran_index, and tran_server_2pc_attach_global_tran().

Referenced by db_2pc_attach_transaction().

Here is the caller graph for this function:

int tran_2pc_prepare ( void )

Definition at line 717 of file transaction_cl.c.

References ARG_FILE_LINE, assert, BOOT_IS_CLIENT_RESTARTED, db_clear_client_query_result(), er_errid(), er_log_debug, er_stack_clearall(), locator_all_flush(), log_state_string(), NO_ERROR, TRAN_ACTIVE, TRAN_RECOVERY, tran_server_2pc_prepare(), TRAN_UNACTIVE_2PC_ABORT_DECISION, TRAN_UNACTIVE_2PC_COLLECTING_PARTICIPANT_VOTES, TRAN_UNACTIVE_2PC_COMMIT_DECISION, TRAN_UNACTIVE_2PC_PREPARE, TRAN_UNACTIVE_ABORTED, TRAN_UNACTIVE_ABORTED_INFORMING_PARTICIPANTS, TRAN_UNACTIVE_COMMITTED, TRAN_UNACTIVE_COMMITTED_INFORMING_PARTICIPANTS, TRAN_UNACTIVE_COMMITTED_WITH_POSTPONE, TRAN_UNACTIVE_TOPOPE_COMMITTED_WITH_POSTPONE, TRAN_UNACTIVE_UNILATERALLY_ABORTED, TRAN_UNACTIVE_UNKNOWN, and ws_clear_all_hints().

Referenced by db_2pc_prepare_transaction().

Here is the caller graph for this function:

int tran_2pc_prepare_global_tran ( int gtrid )

Definition at line 871 of file transaction_cl.c.

References ARG_FILE_LINE, assert, BOOT_IS_CLIENT_RESTARTED, db_clear_client_query_result(), er_errid(), er_log_debug, er_stack_clearall(), locator_all_flush(), log_state_string(), NO_ERROR, TRAN_ACTIVE, TRAN_RECOVERY, tran_server_2pc_prepare_global_tran(), TRAN_UNACTIVE_2PC_ABORT_DECISION, TRAN_UNACTIVE_2PC_COLLECTING_PARTICIPANT_VOTES, TRAN_UNACTIVE_2PC_COMMIT_DECISION, TRAN_UNACTIVE_2PC_PREPARE, TRAN_UNACTIVE_ABORTED, TRAN_UNACTIVE_ABORTED_INFORMING_PARTICIPANTS, TRAN_UNACTIVE_COMMITTED, TRAN_UNACTIVE_COMMITTED_INFORMING_PARTICIPANTS, TRAN_UNACTIVE_COMMITTED_WITH_POSTPONE, TRAN_UNACTIVE_TOPOPE_COMMITTED_WITH_POSTPONE, TRAN_UNACTIVE_UNILATERALLY_ABORTED, TRAN_UNACTIVE_UNKNOWN, and ws_clear_all_hints().

Referenced by db_2pc_prepare_to_commit_transaction().

Here is the caller graph for this function:

int tran_2pc_recovery_prepared	(	int	gtrids[],
		int	size
	)

Definition at line 819 of file transaction_cl.c.

References tran_server_2pc_recovery_prepared().

Referenced by db_2pc_prepared_transactions().

Here is the caller graph for this function:

int tran_2pc_start ( void )

Definition at line 697 of file transaction_cl.c.

References tran_server_2pc_start().

Referenced by db_2pc_start_transaction().

Here is the caller graph for this function:

int tran_abort ( void )

Definition at line 409 of file transaction_cl.c.

References ARG_FILE_LINE, assert, ASSERT_ERROR_AND_SET, BOOT_IS_CLIENT_RESTARTED, db_clear_client_query_result(), er_log_debug, er_stack_clearall(), log_state_string(), NO_ERROR, NULL_LOCK, sm_transaction_boundary(), tm_Tran_rep_read_lock, tr_check_rollback_triggers(), TR_TIME_AFTER, TR_TIME_BEFORE, TRAN_ACTIVE, tran_free_savepoint_list(), TRAN_RECOVERY, tran_reset_latest_query_status(), tran_server_abort(), TRAN_UNACTIVE_2PC_ABORT_DECISION, TRAN_UNACTIVE_2PC_COLLECTING_PARTICIPANT_VOTES, TRAN_UNACTIVE_2PC_COMMIT_DECISION, TRAN_UNACTIVE_2PC_PREPARE, TRAN_UNACTIVE_ABORTED, TRAN_UNACTIVE_ABORTED_INFORMING_PARTICIPANTS, TRAN_UNACTIVE_COMMITTED, TRAN_UNACTIVE_COMMITTED_INFORMING_PARTICIPANTS, TRAN_UNACTIVE_COMMITTED_WITH_POSTPONE, TRAN_UNACTIVE_TOPOPE_COMMITTED_WITH_POSTPONE, TRAN_UNACTIVE_UNILATERALLY_ABORTED, TRAN_UNACTIVE_UNKNOWN, tran_was_latest_query_aborted(), tran_was_latest_query_committed(), tran_was_latest_query_ended(), ws_abort_mops(), ws_clear(), ws_filter_dirty(), and ws_increment_mvcc_snapshot_version().

Referenced by boot_shutdown_client(), conn_end_tran(), db_abort_transaction(), do_rollback(), sqmgr_execute_query(), and tran_unilaterally_abort().

Here is the caller graph for this function:

int tran_abort_only_client ( bool is_server_down )

Definition at line 561 of file transaction_cl.c.

References ARG_FILE_LINE, BOOT_IS_CLIENT_RESTARTED, db_clear_client_query_result(), ER_ERROR_SEVERITY, er_set(), ER_TM_SERVER_DOWN_UNILATERALLY_ABORTED, NO_ERROR, NULL_LOCK, tm_Tran_rep_read_lock, tr_check_abort_triggers(), ws_abort_mops(), and ws_filter_dirty().

Referenced by boot_server_die_or_changed(), compactdb_start(), do_execute_statement(), do_reclaim_class_addresses(), do_statement(), locator_assign_permanent_oid(), locator_find_class_by_oid(), locator_fun_get_all_mops(), locator_lock(), locator_lock_and_doesexist(), locator_lock_class_of_instance(), and locator_lockhint_classes().

Here is the caller graph for this function:

int tran_abort_upto_system_savepoint ( const char * savepoint_name )

Definition at line 1148 of file transaction_cl.c.

References SYSTEM_SAVEPOINT, and tran_internal_abort_upto_savepoint().

Referenced by au_change_owner_method(), au_grant(), au_revoke(), check_merge_trigger(), check_trigger(), dbt_rename(), delete_list_by_oids(), do_alter(), do_alter_change_col_comment(), do_alter_change_default_cs_coll(), do_alter_change_tbl_comment(), do_alter_clause_change_attribute(), do_alter_index_comment(), do_alter_index_rebuild(), do_alter_index_status(), do_alter_one_clause_with_template(), do_alter_trigger(), do_alter_user(), do_check_internal_statements(), do_create_entity(), do_create_user(), do_drop(), do_drop_user(), do_grant(), do_rename(), do_revoke(), do_truncate(), jsp_add_stored_procedure(), jsp_create_stored_procedure(), obt_update_internal(), sm_add_constraint(), sm_add_secondary_index_on_partition(), sm_delete_class_mop(), sm_drop_index(), sm_exist_index(), sm_rename_class(), sm_truncate_class(), tr_create_trigger(), tr_drop_trigger_internal(), tr_rename_trigger(), update_class(), and update_objs_for_list_file().

int tran_abort_upto_user_savepoint ( const char * savepoint_name )

Definition at line 1161 of file transaction_cl.c.

References tran_free_list_upto_savepoint(), tran_internal_abort_upto_savepoint(), and USER_SAVEPOINT.

Referenced by db_abort_to_savepoint_internal().

Here is the caller graph for this function:

static int tran_add_savepoint ( const char * savept_name )

static

Definition at line 973 of file transaction_cl.c.

References assert, db_ws_alloc(), db_ws_free(), er_errid(), db_namelist::name, db_namelist::next, NO_ERROR, NULL, user_savepoint_list, and ws_copy_string().

Referenced by tran_savepoint_internal().

Here is the caller graph for this function:

void tran_begin_libcas_function ( void )

Definition at line 1315 of file transaction_cl.c.

References tm_Is_libcas.

Referenced by jsp_receive_response(), and jsp_send_destroy_request().

Here is the caller graph for this function:

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

Definition at line 121 of file transaction_cl.c.

References db_Connect_status, DB_CONNECTION_STATUS_NOT_CONNECTED, NULL_TRAN_INDEX, tm_Tran_index, tm_Tran_isolation, and tm_Tran_wait_msecs.

Referenced by boot_client(), and logpb_fatal_error_internal().

Here is the caller graph for this function:

int tran_commit ( bool retain_lock )

Definition at line 272 of file transaction_cl.c.

References ARG_FILE_LINE, assert, ASSERT_ERROR_AND_SET, BOOT_IS_CLIENT_RESTARTED, db_clear_client_query_result(), db_Connect_status, DB_CONNECTION_STATUS_RESET, er_log_debug, er_stack_clearall(), log_does_allow_replication(), log_state_string(), NO_ERROR, NULL_LOCK, sm_transaction_boundary(), tm_Tran_rep_read_lock, tr_check_commit_triggers(), TR_TIME_AFTER, TR_TIME_BEFORE, TRAN_ACTIVE, tran_flush_to_commit(), tran_free_savepoint_list(), tran_is_reset_required(), TRAN_RECOVERY, tran_reset_latest_query_status(), tran_server_commit(), TRAN_UNACTIVE_2PC_ABORT_DECISION, TRAN_UNACTIVE_2PC_COLLECTING_PARTICIPANT_VOTES, TRAN_UNACTIVE_2PC_COMMIT_DECISION, TRAN_UNACTIVE_2PC_PREPARE, TRAN_UNACTIVE_ABORTED, TRAN_UNACTIVE_ABORTED_INFORMING_PARTICIPANTS, TRAN_UNACTIVE_COMMITTED, TRAN_UNACTIVE_COMMITTED_INFORMING_PARTICIPANTS, TRAN_UNACTIVE_COMMITTED_WITH_POSTPONE, TRAN_UNACTIVE_TOPOPE_COMMITTED_WITH_POSTPONE, TRAN_UNACTIVE_UNILATERALLY_ABORTED, TRAN_UNACTIVE_UNKNOWN, tran_was_latest_query_aborted(), tran_was_latest_query_committed(), tran_was_latest_query_ended(), ws_clear_all_hints(), and ws_increment_mvcc_snapshot_version().

Referenced by boot_initialize_client(), boot_restart_client(), boot_shutdown_client(), conn_end_tran(), db_commit_transaction(), do_commit(), and proxy_io_make_end_tran_request().

Here is the caller graph for this function:

static UINT64 tran_current_timemillis ( void )

static

Definition at line 1261 of file transaction_cl.c.

References NULL.

Referenced by tran_get_query_timeout(), and tran_set_query_timeout().

Here is the caller graph for this function:

void tran_end_libcas_function ( void )

Definition at line 1325 of file transaction_cl.c.

References tm_Is_libcas.

Referenced by jsp_receive_response(), and jsp_send_destroy_request().

Here is the caller graph for this function:

int tran_flush_to_commit ( void )

Definition at line 229 of file transaction_cl.c.

References err, locator_all_flush(), locator_assign_all_permanent_oids(), NO_ERROR, tm_Use_OID_preflush, and ws_need_flush().

Referenced by do_execute_delete(), do_execute_insert(), do_execute_merge(), do_execute_update(), and tran_commit().

Here is the caller graph for this function:

static void tran_free_list_upto_savepoint ( const char * savept_name )

static

Definition at line 1024 of file transaction_cl.c.

References db_ws_free(), intl_mbs_casecmp(), db_namelist::name, and db_namelist::next.

Referenced by tran_abort_upto_user_savepoint().

Here is the caller graph for this function:

void tran_free_savepoint_list ( void )

Definition at line 1007 of file transaction_cl.c.

References nlist_free(), and NULL.

Referenced by boot_client_all_finalize(), boot_initialize_client(), boot_restart_client(), tran_abort(), and tran_commit().

Here is the caller graph for this function:

bool tran_get_check_interrupt ( void )

Definition at line 1361 of file transaction_cl.c.

References tm_Tran_check_interrupt.

Referenced by logtb_get_check_interrupt().

Here is the caller graph for this function:

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

Definition at line 669 of file transaction_cl.c.

References assert, er_errid(), NO_ERROR, and tran_server_get_global_tran_info().

Referenced by db_get_global_transaction_info().

Here is the caller graph for this function:

int tran_get_query_timeout ( void )

Definition at line 1290 of file transaction_cl.c.

References tm_Query_begin, tm_Query_timeout, and tran_current_timemillis().

Referenced by execute_query(), and prepare_and_execute_query().

Here is the caller graph for this function:

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

Definition at line 148 of file transaction_cl.c.

References TM_TRAN_ASYNC_WS, TM_TRAN_ISOLATION, and TM_TRAN_WAIT_MSECS.

Referenced by ci_conn_get_option_impl(), db_get_tran_settings(), do_get_xaction(), set_iso_level(), and ux_get_tran_setting().

Here is the caller graph for this function:

bool tran_has_updated ( void )

Definition at line 603 of file transaction_cl.c.

References tran_server_has_updated(), and ws_has_updated().

Referenced by db_commit_is_needed(), and tran_internal_abort_upto_savepoint().

Here is the caller graph for this function:

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

Definition at line 1202 of file transaction_cl.c.

References ARG_FILE_LINE, assert, er_errid(), er_log_debug, ER_NET_SERVER_CRASHED, ER_TM_SERVER_DOWN_UNILATERALLY_ABORTED, log_state_string(), NO_ERROR, sm_transaction_boundary(), SYSTEM_SAVEPOINT, tran_has_updated(), tran_server_partial_abort(), TRAN_UNACTIVE_ABORTED, TRAN_UNACTIVE_UNKNOWN, tran_unilaterally_abort(), ws_abort_mops(), ws_clear(), ws_decache_allxlockmops_but_norealclasses(), and ws_filter_dirty().

Referenced by insert_local(), tran_abort_upto_system_savepoint(), and tran_abort_upto_user_savepoint().

Here is the caller graph for this function:

bool tran_is_active_and_has_updated ( void )

Definition at line 618 of file transaction_cl.c.

References tran_server_is_active_and_has_updated(), and ws_has_updated().

Referenced by boot_shutdown_client().

Here is the caller graph for this function:

bool tran_is_in_libcas ( void )

Definition at line 1335 of file transaction_cl.c.

References tm_Is_libcas.

Referenced by set_query_timeout().

Here is the caller graph for this function:

bool tran_is_reset_required ( void )

Definition at line 1467 of file transaction_cl.c.

References RESET_REQUIRED, and tm_Tran_latest_query_status.

Referenced by tran_commit().

Here is the caller graph for this function:

int tran_reset_isolation	(	TRAN_ISOLATION	isolation,
		bool	async_ws
	)

Definition at line 198 of file transaction_cl.c.

References ARG_FILE_LINE, ER_MVCC_LOG_INVALID_ISOLATION_LEVEL, er_set(), ER_SYNTAX_ERROR_SEVERITY, IS_VALID_ISOLATION_LEVEL, log_reset_isolation(), NO_ERROR, tm_Tran_async_ws, and tm_Tran_isolation.

Referenced by boot_restart_client(), ci_conn_set_option_impl(), db_set_isolation(), and do_set_xaction().

Here is the caller graph for this function:

void tran_reset_latest_query_status ( void )

Definition at line 1427 of file transaction_cl.c.

References NONE, and tm_Tran_latest_query_status.

Referenced by db_reset_latest_query_status(), tran_abort(), tran_commit(), and tran_set_latest_query_status().

Here is the caller graph for this function:

int tran_reset_wait_times ( int wait_in_msecs )

Definition at line 171 of file transaction_cl.c.

References log_reset_wait_msecs(), and tm_Tran_wait_msecs.

Referenced by boot_restart_client(), ci_conn_set_option_impl(), compactdb_start(), db_set_lock_timeout(), delete_real_class(), do_execute_delete(), do_execute_merge(), do_execute_update(), do_insert_template(), do_merge(), do_reclaim_addresses(), do_set_xaction(), update_real_class(), and ux_set_lock_timeout().

Here is the caller graph for this function:

int tran_savepoint_internal	(	const char *	savept_name,
		SAVEPOINT_TYPE	savepoint_type
	)

Definition at line 1100 of file transaction_cl.c.

References ARG_FILE_LINE, assert, er_errid(), er_log_debug, er_msg(), locator_all_flush(), NO_ERROR, tran_add_savepoint(), tran_server_savepoint(), USER_SAVEPOINT, and ws_need_flush().

Referenced by db_savepoint_transaction_internal(), and tran_system_savepoint().

Here is the caller graph for this function:

bool tran_set_check_interrupt ( bool flag )

Definition at line 1346 of file transaction_cl.c.

References tm_Tran_check_interrupt.

Referenced by logtb_set_check_interrupt().

Here is the caller graph for this function:

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

Definition at line 639 of file transaction_cl.c.

References assert, er_errid(), NO_ERROR, and tran_server_set_global_tran_info().

Referenced by db_set_global_transaction_info().

Here is the caller graph for this function:

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

Definition at line 1391 of file transaction_cl.c.

References ABORTED, assert, COMMITTED, NO_ERROR, QUERY_ENDED, RESET_REQUIRED, tm_Tran_latest_query_status, tran_reset_latest_query_status(), TRAN_UNACTIVE_ABORTED, TRAN_UNACTIVE_ABORTED_INFORMING_PARTICIPANTS, TRAN_UNACTIVE_COMMITTED, TRAN_UNACTIVE_COMMITTED_INFORMING_PARTICIPANTS, and tran_was_latest_query_committed().

Referenced by qmgr_execute_query().

Here is the caller graph for this function:

void tran_set_query_timeout ( int query_timeout )

Definition at line 1279 of file transaction_cl.c.

References query_timeout, tm_Query_begin, tm_Query_timeout, and tran_current_timemillis().

Referenced by chksum_start(), and set_query_timeout().

Here is the caller graph for this function:

int tran_system_savepoint ( const char * savept_name )

Definition at line 1070 of file transaction_cl.c.

References SYSTEM_SAVEPOINT, and tran_savepoint_internal().

Referenced by au_change_owner_method(), au_grant(), au_revoke(), check_merge_trigger(), check_trigger(), dbt_rename(), delete_list_by_oids(), do_alter(), do_alter_change_col_comment(), do_alter_change_default_cs_coll(), do_alter_change_tbl_comment(), do_alter_clause_change_attribute(), do_alter_index_comment(), do_alter_index_rebuild(), do_alter_index_status(), do_alter_one_clause_with_template(), do_alter_trigger(), do_alter_user(), do_check_internal_statements(), do_create_entity(), do_create_user(), do_delete(), do_drop(), do_drop_user(), do_execute_delete(), do_execute_merge(), do_execute_update(), do_grant(), do_merge(), do_rename(), do_revoke(), do_truncate(), do_update(), insert_local(), insert_subquery_results(), jsp_add_stored_procedure(), jsp_create_stored_procedure(), obt_update_internal(), sm_add_constraint(), sm_add_secondary_index_on_partition(), sm_delete_class_mop(), sm_drop_index(), sm_exist_index(), sm_rename_class(), sm_truncate_class(), tr_create_trigger(), tr_drop_trigger_internal(), tr_rename_trigger(), update_class(), and update_objs_for_list_file().

int tran_unilaterally_abort ( void )

Definition at line 515 of file transaction_cl.c.

References ARG_FILE_LINE, CUB_MAXHOSTNAMELEN, ER_ERROR_SEVERITY, ER_LK_UNILATERALLY_ABORTED, er_set(), GETHOSTNAME, getuserid(), host, L_cuserid, NO_ERROR, NULL, pid, tm_Tran_index, tr_check_abort_triggers(), and tran_abort().

Referenced by sm_drop_index(), sm_exist_index(), tran_internal_abort_upto_savepoint(), and ws_abort_transaction().

Here is the caller graph for this function:

bool tran_was_latest_query_aborted ( void )

Definition at line 1457 of file transaction_cl.c.

References ABORTED, and tm_Tran_latest_query_status.

Referenced by do_commit_after_execute(), do_execute_statement(), do_statement(), tran_abort(), tran_commit(), and ux_auto_commit().

Here is the caller graph for this function:

bool tran_was_latest_query_committed ( void )

Definition at line 1447 of file transaction_cl.c.

References COMMITTED, and tm_Tran_latest_query_status.

Referenced by build_xasl_for_server_delete(), css_send_req_to_server(), do_commit_after_execute(), do_execute_delete(), do_execute_merge(), do_execute_update(), do_insert_at_server(), fetch_result(), tran_abort(), tran_commit(), tran_set_latest_query_status(), update_at_server(), and ux_auto_commit().

Here is the caller graph for this function:

bool tran_was_latest_query_ended ( void )

Definition at line 1437 of file transaction_cl.c.

References QUERY_ENDED, and tm_Tran_latest_query_status.

Referenced by db_query_end(), do_execute_merge(), do_merge(), pt_end_query(), tran_abort(), and tran_commit().

Here is the caller graph for this function:

Variable Documentation

bool tm_Is_libcas = false

static

Definition at line 93 of file transaction_cl.c.

Referenced by tran_begin_libcas_function(), tran_end_libcas_function(), and tran_is_in_libcas().

UINT64 tm_Query_begin = 0

static

Definition at line 91 of file transaction_cl.c.

Referenced by tran_get_query_timeout(), and tran_set_query_timeout().

int tm_Query_timeout = 0

static

Definition at line 92 of file transaction_cl.c.

Referenced by tran_get_query_timeout(), and tran_set_query_timeout().

bool tm_Tran_async_ws = false

Definition at line 68 of file transaction_cl.c.

Referenced by tran_reset_isolation().

bool tm_Tran_check_interrupt = false

Definition at line 70 of file transaction_cl.c.

Referenced by tran_get_check_interrupt(), and tran_set_check_interrupt().

int tm_Tran_ID = -1

Definition at line 71 of file transaction_cl.c.

int tm_Tran_invalidate_snapshot = 1

Definition at line 72 of file transaction_cl.c.

Referenced by css_client_init(), css_send_data_to_server(), css_send_error_to_server(), css_send_req_to_server(), css_send_req_to_server_2_data(), css_send_req_to_server_no_reply(), css_send_request_to_server_with_buffer(), and db_invalidate_mvcc_snapshot_before_statement().

TRAN_ISOLATION tm_Tran_isolation = TRAN_UNKNOWN_ISOLATION

Definition at line 67 of file transaction_cl.c.

Referenced by tran_cache_tran_settings(), and tran_reset_isolation().

int tm_Tran_latest_query_status

Definition at line 79 of file transaction_cl.c.

Referenced by tran_is_reset_required(), tran_reset_latest_query_status(), tran_set_latest_query_status(), tran_was_latest_query_aborted(), tran_was_latest_query_committed(), and tran_was_latest_query_ended().

LC_FETCH_VERSION_TYPE tm_Tran_read_fetch_instance_version = LC_FETCH_MVCC_VERSION

Definition at line 78 of file transaction_cl.c.

Referenced by db_set_read_fetch_instance_version().

LOCK tm_Tran_rep_read_lock = NULL_LOCK

Definition at line 73 of file transaction_cl.c.

Referenced by locator_find_lockhint_class_oids(), tran_abort(), tran_abort_only_client(), tran_commit(), and tran_lock_rep_read().

int tm_Tran_wait_msecs = TRAN_LOCK_INFINITE_WAIT

Definition at line 69 of file transaction_cl.c.

Referenced by tran_cache_tran_settings(), and tran_reset_wait_times().

bool tm_Use_OID_preflush = true

Definition at line 226 of file transaction_cl.c.

Referenced by do_execute_select(), ldr_init_loader(), and tran_flush_to_commit().

DB_NAMELIST* user_savepoint_list = NULL

static

Definition at line 102 of file transaction_cl.c.

Referenced by tran_add_savepoint().

Enumerations

Functions

Variables

Enumeration Type Documentation

Function Documentation

Variable Documentation