|
CUBRID Engine
latest
|
|
CUBRID Engine
latest
|
#include "config.h"#include <array>#include <assert.h>#include <stdio.h>#include <string.h>#include <time.h>#include "boot_sr.h"#include "critical_section.h"#include "environment_variable.h"#include "event_log.h"#include "locator.h"#include "lock_free.h"#include "lock_manager.h"#include "log_impl.h"#include "log_manager.h"#include "memory_alloc.h"#include "memory_hash.h"#include "message_catalog.h"#include "mvcc.h"#include "object_representation_sr.h"#include "oid.h"#include "page_buffer.h"#include "perf_monitor.h"#include "porting.h"#include "query_manager.h"#include "server_support.h"#include "storage_common.h"#include "system_parameter.h"#include "thread_daemon.hpp"#include "thread_entry_task.hpp"#include "thread_lockfree_hash_map.hpp"#include "thread_manager.hpp"#include "transaction_sr.h"#include "tsc_timer.h"#include "wait_for_graph.h"#include "xserver_interface.h"#include "xasl.h"Go to the source code of this file.
Typedefs | |
| using | tran_lock_waiters_array_type = std::array< THREAD_ENTRY *, DEFAULT_LOCK_WAITING_THREAD_ARRAY_SIZE > |
Variables | |
| LOCK_COMPATIBILITY | lock_Comp [12][12] |
| static int | lk_Standalone_has_xlock = 0 |
| const size_t | DEFAULT_LOCK_WAITING_THREAD_ARRAY_SIZE = 10 |
| #define KEY_LOCK_ESCALATION_THRESHOLD 10 /* key lock escalation threshold */ |
Definition at line 168 of file lock_manager.c.
| #define LK_SET_STANDALONE_XLOCK | ( | lock | ) |
Definition at line 457 of file lock_manager.c.
Referenced by lock_hold_object_instant(), lock_object(), lock_object_wait_msecs(), lock_rep_read_tran(), and lock_subclass().
| #define MAX_NUM_LOCKS_DUMP_TO_EVENT_LOG 100 |
Definition at line 169 of file lock_manager.c.
Referenced by lock_wait_state_to_string().
| #define MSGCAT_LK_DEADLOCK_ABORT 38 |
Definition at line 226 of file lock_manager.c.
Referenced by lock_demote_class_lock().
| #define MSGCAT_LK_DEADLOCK_ABORT_HDR 37 |
Definition at line 225 of file lock_manager.c.
Referenced by lock_demote_class_lock().
| #define MSGCAT_LK_DEADLOCK_FUN 42 |
Definition at line 230 of file lock_manager.c.
| #define MSGCAT_LK_DEADLOCK_FUN_HDR 41 |
Definition at line 229 of file lock_manager.c.
| #define MSGCAT_LK_DEADLOCK_TIMEOUT 40 |
Definition at line 228 of file lock_manager.c.
Referenced by lock_demote_class_lock().
| #define MSGCAT_LK_DEADLOCK_TIMEOUT_HDR 39 |
Definition at line 227 of file lock_manager.c.
Referenced by lock_demote_class_lock().
| #define MSGCAT_LK_DUMP_LOCK_TABLE 32 |
Definition at line 220 of file lock_manager.c.
Referenced by xlock_dump().
| #define MSGCAT_LK_DUMP_TRAN_IDENTIFIERS 33 |
Definition at line 221 of file lock_manager.c.
Referenced by xlock_dump().
| #define MSGCAT_LK_DUMP_TRAN_ISOLATION 34 |
Definition at line 222 of file lock_manager.c.
Referenced by xlock_dump().
| #define MSGCAT_LK_DUMP_TRAN_STATE 35 |
Definition at line 223 of file lock_manager.c.
Referenced by xlock_dump().
| #define MSGCAT_LK_DUMP_TRAN_TIMEOUT_PERIOD 36 |
Definition at line 224 of file lock_manager.c.
Referenced by xlock_dump().
| #define MSGCAT_LK_INDEXNAME 44 |
Definition at line 232 of file lock_manager.c.
| #define MSGCAT_LK_LASTONE 47 |
Definition at line 235 of file lock_manager.c.
| #define MSGCAT_LK_MVCC_INFO 46 |
Definition at line 234 of file lock_manager.c.
Referenced by lock_demote_class_lock().
| #define MSGCAT_LK_NEWLINE 1 |
Definition at line 189 of file lock_manager.c.
Referenced by lock_demote_class_lock(), and xlock_dump().
| #define MSGCAT_LK_OID_LOCK_ACQUIRED 4 |
Definition at line 192 of file lock_manager.c.
| #define MSGCAT_LK_OID_LOCK_CONVERTED 6 |
Definition at line 194 of file lock_manager.c.
| #define MSGCAT_LK_OID_LOCK_DEMOTE 12 |
Definition at line 200 of file lock_manager.c.
| #define MSGCAT_LK_OID_LOCK_RELEASE 10 |
Definition at line 198 of file lock_manager.c.
| #define MSGCAT_LK_OID_LOCK_WAITFOR 8 |
Definition at line 196 of file lock_manager.c.
| #define MSGCAT_LK_RES_BLOCKED_HOLDER_ENTRY 27 |
Definition at line 215 of file lock_manager.c.
Referenced by lock_demote_class_lock().
| #define MSGCAT_LK_RES_BLOCKED_HOLDER_ENTRY_WITH_GRANULE 28 |
Definition at line 216 of file lock_manager.c.
Referenced by lock_demote_class_lock().
| #define MSGCAT_LK_RES_BLOCKED_HOLDER_HEAD 22 |
Definition at line 210 of file lock_manager.c.
Referenced by lock_demote_class_lock().
| #define MSGCAT_LK_RES_BLOCKED_WAITER_ENTRY 29 |
Definition at line 217 of file lock_manager.c.
Referenced by lock_demote_class_lock().
| #define MSGCAT_LK_RES_BLOCKED_WAITER_HEAD 23 |
Definition at line 211 of file lock_manager.c.
Referenced by lock_demote_class_lock().
| #define MSGCAT_LK_RES_CLASS_TYPE 16 |
Definition at line 204 of file lock_manager.c.
Referenced by lock_demote_class_lock().
| #define MSGCAT_LK_RES_INDEX_KEY_TYPE 43 |
Definition at line 231 of file lock_manager.c.
| #define MSGCAT_LK_RES_INSTANCE_TYPE 17 |
Definition at line 205 of file lock_manager.c.
Referenced by lock_demote_class_lock().
| #define MSGCAT_LK_RES_LOCK_COUNT 20 |
Definition at line 208 of file lock_manager.c.
Referenced by lock_demote_class_lock().
| #define MSGCAT_LK_RES_NON2PL_RELEASED_ENTRY 30 |
Definition at line 218 of file lock_manager.c.
Referenced by lock_demote_class_lock().
| #define MSGCAT_LK_RES_NON2PL_RELEASED_HEAD 24 |
Definition at line 212 of file lock_manager.c.
Referenced by lock_demote_class_lock().
| #define MSGCAT_LK_RES_NON_BLOCKED_HOLDER_ENTRY 25 |
Definition at line 213 of file lock_manager.c.
Referenced by lock_demote_class_lock().
| #define MSGCAT_LK_RES_NON_BLOCKED_HOLDER_ENTRY_WITH_GRANULE 26 |
Definition at line 214 of file lock_manager.c.
Referenced by lock_demote_class_lock().
| #define MSGCAT_LK_RES_NON_BLOCKED_HOLDER_HEAD 21 |
Definition at line 209 of file lock_manager.c.
Referenced by lock_demote_class_lock().
| #define MSGCAT_LK_RES_OID 14 |
Definition at line 202 of file lock_manager.c.
Referenced by lock_demote_class_lock().
| #define MSGCAT_LK_RES_ROOT_CLASS_TYPE 15 |
Definition at line 203 of file lock_manager.c.
Referenced by lock_demote_class_lock().
| #define MSGCAT_LK_RES_RR_TYPE 45 |
Definition at line 233 of file lock_manager.c.
Referenced by lock_demote_class_lock().
| #define MSGCAT_LK_RES_TOTAL_MODE 19 |
Definition at line 207 of file lock_manager.c.
Referenced by lock_demote_class_lock().
| #define MSGCAT_LK_RES_UNKNOWN_TYPE 18 |
Definition at line 206 of file lock_manager.c.
Referenced by lock_demote_class_lock().
| #define MSGCAT_LK_RES_VPID 31 |
Definition at line 219 of file lock_manager.c.
| #define MSGCAT_LK_RESUME_TRAN 3 |
Definition at line 191 of file lock_manager.c.
| #define MSGCAT_LK_SUSPEND_TRAN 2 |
Definition at line 190 of file lock_manager.c.
| #define MSGCAT_LK_VPID_LOCK_ACQUIRED 5 |
Definition at line 193 of file lock_manager.c.
| #define MSGCAT_LK_VPID_LOCK_CONVERTED 7 |
Definition at line 195 of file lock_manager.c.
| #define MSGCAT_LK_VPID_LOCK_DEMOTE 13 |
Definition at line 201 of file lock_manager.c.
| #define MSGCAT_LK_VPID_LOCK_RELEASE 11 |
Definition at line 199 of file lock_manager.c.
| #define MSGCAT_LK_VPID_LOCK_WAITFOR 9 |
Definition at line 197 of file lock_manager.c.
| #define RESOURCE_ALLOC_WAIT_TIME 10 /* 10 msec */ |
Definition at line 167 of file lock_manager.c.
| using tran_lock_waiters_array_type = std::array<THREAD_ENTRY *, DEFAULT_LOCK_WAITING_THREAD_ARRAY_SIZE> |
Definition at line 469 of file lock_manager.c.
| enum LOCK_WAIT_STATE |
| Enumerator | |
|---|---|
| LOCK_SUSPENDED | |
| LOCK_RESUMED | |
| LOCK_RESUMED_TIMEOUT | |
| LOCK_RESUMED_DEADLOCK_TIMEOUT | |
| LOCK_RESUMED_ABORTED | |
| LOCK_RESUMED_ABORTED_FIRST | |
| LOCK_RESUMED_ABORTED_OTHER | |
| LOCK_RESUMED_INTERRUPT | |
Definition at line 172 of file lock_manager.c.
| void lock_abort_composite_lock | ( | LK_COMPOSITE_LOCK * | comp_lock | ) |
Definition at line 8774 of file lock_manager.c.
References lk_lockcomp::class_list, db_private_free_and_init, lk_lockcomp_class::inst_oid_space, lk_composite_lock::lockcomp, lk_lockcomp_class::next, NULL_TRAN_INDEX, lk_lockcomp::tran_index, and lk_lockcomp::wait_msecs.
Referenced by lock_finalize_composite_lock(), qexec_clear_xasl(), and qexec_execute_mainblock_internal().
| int lock_add_composite_lock | ( | THREAD_ENTRY * | thread_p, |
| LK_COMPOSITE_LOCK * | comp_lock, | ||
| const OID * | oid, | ||
| const OID * | class_oid | ||
| ) |
Definition at line 8560 of file lock_manager.c.
References assert, lk_lockcomp::class_list, lk_lockcomp_class::class_lock_ptr, lk_lockcomp_class::class_oid, COPY_OID, db_private_alloc, db_private_free_and_init, db_private_realloc, ER_FAILED, ER_OUT_OF_VIRTUAL_MEMORY, lk_lockcomp_class::inst_oid_space, IS_WRITE_EXCLUSIVE_LOCK, IX_LOCK, LK_GRANTED, lock_get_class_lock(), lk_composite_lock::lockcomp, lk_lockcomp_class::max_inst_oids, lk_lockcomp_class::next, NO_ERROR, NULL, lk_lockcomp_class::num_inst_oids, OID_EQ, oid_Root_class_oid, p, prm_get_integer_value(), PRM_ID_LK_ESCALATION_AT, lk_lockcomp::root_class_ptr, lk_lockcomp::tran_index, lk_lockcomp::wait_msecs, and X_LOCK.
Referenced by qexec_add_composite_lock().
| int lock_classes_lock_hint | ( | THREAD_ENTRY * | thread_p, |
| LC_LOCKHINT * | lockhint | ||
| ) |
Definition at line 6347 of file lock_manager.c.
References ARG_FILE_LINE, lc_lock_hint::classes, COPY_OID, db_private_alloc, db_private_free_and_init, ER_ERROR_SEVERITY, ER_LK_BAD_ARGUMENT, er_log_debug, ER_MNT_WAITING_THREAD, ER_NOTIFICATION_SEVERITY, er_set(), error(), i, IS_LOCK, IX_LOCK, LK_GRANTED, LK_INFINITE_WAIT, LK_NOTGRANTED_DUE_ERROR, LK_NOTGRANTED_DUE_TIMEOUT, lc_lockhint_class::lock, lock_get_class_lock(), LOG_FIND_THREAD_TRAN_INDEX, logtb_find_isolation(), logtb_find_wait_msecs(), MONITOR_WAITING_THREAD, NULL, NULL_LOCK, lc_lock_hint::num_classes, lc_lockhint_class::oid, OID_IS_ROOTOID, OID_ISNULL, oid_Root_class_oid, OID_SET_NULL, prm_get_integer_value(), PRM_ID_MNT_WAITING_THREAD, lc_lock_hint::quit_on_errors, S_LOCK, SCH_M_LOCK, SIX_LOCK, tsc_elapsed_time_usec(), tsc_getticks(), and X_LOCK.
Referenced by xlocator_fetch_lockhint_classes().
| void lock_clear_deadlock_victim | ( | int | tran_index | ) |
Definition at line 8967 of file lock_manager.c.
References pthread_mutex_lock, pthread_mutex_unlock, rv, and TRAN_NORMAL.
Referenced by lock_unlock_all(), and qexec_execute_selupd_list().
| int lock_demote_class_lock | ( | THREAD_ENTRY * | thread_p, |
| const OID * | oid, | ||
| LOCK | lock, | ||
| LOCK * | ex_lock | ||
| ) |
Definition at line 4169 of file lock_manager.c.
References ARG_FILE_LINE, assert, assert_release, lk_res_key::class_oid, COPY_OID, cubregex::count(), CTIME_MAX, CUB_MAXHOSTNAMELEN, er_clear(), er_errid(), ER_ERROR_SEVERITY, ER_FAILED, ER_INTERRUPTED, ER_LK_DEADLOCK_CYCLE_DETECTED, ER_LK_NOTFOUND_IN_LOCK_HOLDER_LIST, er_log_debug, ER_NOTIFICATION_SEVERITY, ER_OUT_OF_VIRTUAL_MEMORY, er_set(), free_and_init, heap_get_class_name(), heap_get_visible_version(), heap_scancache_end(), heap_scancache_quick_start(), lk_res::holder, i, INCON_NON_TWO_PHASE_LOCK, IS_LOCK, IX_LOCK, lk_res::key, lock_Comp, LOCK_COMPAT_NO, LOCK_COMPAT_UNKNOWN, lock_Conv, lock_demote_read_class_lock_for_checksumdb(), lock_find_tran_hold_entry(), LOCK_RESOURCE_CLASS, LOCK_RESOURCE_INSTANCE, LOCK_RESOURCE_ROOT_CLASS, LOCK_TO_LOCKMODE_STRING, LOG_FIND_THREAD_TRAN_INDEX, log_state_string(), LOG_USERNAME_MAX, logtb_find_client_name_host_pid(), logtb_find_log_records_count(), logtb_find_state(), logtb_find_tranid(), logtb_find_wait_msecs(), logtb_has_deadlock_priority(), logtb_is_active(), MSGCAT_CATALOG_CUBRID, MSGCAT_LK_DEADLOCK_ABORT, MSGCAT_LK_DEADLOCK_ABORT_HDR, MSGCAT_LK_DEADLOCK_TIMEOUT, MSGCAT_LK_DEADLOCK_TIMEOUT_HDR, MSGCAT_LK_MVCC_INFO, MSGCAT_LK_NEWLINE, MSGCAT_LK_RES_BLOCKED_HOLDER_ENTRY, MSGCAT_LK_RES_BLOCKED_HOLDER_ENTRY_WITH_GRANULE, MSGCAT_LK_RES_BLOCKED_HOLDER_HEAD, MSGCAT_LK_RES_BLOCKED_WAITER_ENTRY, MSGCAT_LK_RES_BLOCKED_WAITER_HEAD, MSGCAT_LK_RES_CLASS_TYPE, MSGCAT_LK_RES_INSTANCE_TYPE, MSGCAT_LK_RES_LOCK_COUNT, MSGCAT_LK_RES_NON2PL_RELEASED_ENTRY, MSGCAT_LK_RES_NON2PL_RELEASED_HEAD, MSGCAT_LK_RES_NON_BLOCKED_HOLDER_ENTRY, MSGCAT_LK_RES_NON_BLOCKED_HOLDER_ENTRY_WITH_GRANULE, MSGCAT_LK_RES_NON_BLOCKED_HOLDER_HEAD, MSGCAT_LK_RES_OID, MSGCAT_LK_RES_ROOT_CLASS_TYPE, MSGCAT_LK_RES_RR_TYPE, MSGCAT_LK_RES_TOTAL_MODE, MSGCAT_LK_RES_UNKNOWN_TYPE, msgcat_message(), MSGCAT_SET_LOCK, MVCC_GET_DELID, MVCC_GET_INSID, MVCC_IS_FLAG_SET, MVCC_IS_HEADER_DELID_VALID, NA_LOCK, NO_ERROR, lk_res::non2pl, NULL, NULL_CHN, NULL_LOCK, NULL_TRAN_INDEX, NULL_TRANID, lk_res_key::oid, OID_AS_ARGS, oid_compare(), OID_EQ, OID_GET_REAL_CLASS_OF_DIR_OID, oid_get_rep_read_tran_oid(), OID_IS_VIRTUAL_CLASS_OF_DIR_OID, OID_ISNULL, OID_ISTEMP, OR_MVCC_FLAG_VALID_INSID, or_mvcc_get_header(), db_identifier::pageid, PEEK, pthread_mutex_lock, pthread_mutex_unlock, RECDES_INITIALIZER, lk_res::res_mutex, rv, S_LOCK, S_SUCCESS, SIX_LOCK, db_identifier::slotid, strlen, thread_get_tran_entry(), THREAD_TS_OBJ_LOCK_ENT, lk_res::total_holders_mode, lk_res::total_waiters_mode, lk_res_key::type, U_LOCK, db_identifier::volid, lk_res::waiter, X_LOCK, and xlock_dump().
Referenced by xbtree_load_online_index(), and xlocator_demote_class_lock().
|
static |
Definition at line 7682 of file lock_manager.c.
References ARG_FILE_LINE, assert, assert_release, css_are_all_request_handlers_suspended(), CTIME_MAX, ER_ERROR_SEVERITY, ER_LK_DEADLOCK_SPECIFIC_INFO, ER_LK_LOCK_WAITER_ONLY, ER_LK_TOTAL_HOLDERS_MODE, ER_NOTIFICATION_SEVERITY, er_set(), ER_WARNING_SEVERITY, error(), event_log_end(), event_log_print_client_info(), event_log_start(), free_and_init, lk_res::holder, i, lock_Comp, LOCK_COMPAT_NO, LOCK_COMPAT_UNKNOWN, lock_victimize_first_thread_mapfunc(), log_fp, logtb_find_tranid(), logtb_find_wait_msecs(), logtb_is_active(), cubthread::manager::map_entries(), NO_ERROR, NULL, NULL_LOCK, NULL_TRAN_INDEX, port_close_memstream(), port_open_memstream(), pthread_mutex_lock, pthread_mutex_unlock, rv, thread_get_manager(), lk_res::total_holders_mode, and lk_res::waiter.
Referenced by lock_initialize().
| void lock_dump_acquired | ( | FILE * | fp, |
| LK_ACQUIRED_LOCKS * | acqlocks | ||
| ) |
Definition at line 8394 of file lock_manager.c.
References i, lk_acqobj_lock::lock, LOCK_TO_LOCKMODE_STRING, lk_acquired_locks::nobj_locks, lk_acquired_locks::obj, lk_acqobj_lock::oid, db_identifier::pageid, db_identifier::slotid, and db_identifier::volid.
Referenced by log_2pc_dump_acqobj_locks().
| void lock_finalize | ( | void | ) |
Definition at line 5797 of file lock_manager.c.
References free_and_init, i, lf_freelist_destroy(), and pthread_mutex_destroy.
Referenced by lock_initialize(), and logtb_undefine_trantable().
| int lock_finalize_composite_lock | ( | THREAD_ENTRY * | thread_p, |
| LK_COMPOSITE_LOCK * | comp_lock | ||
| ) |
Definition at line 8714 of file lock_manager.c.
References lk_lockcomp::class_list, lk_lockcomp_class::class_lock_ptr, lk_lockcomp_class::class_oid, i, lk_lockcomp_class::inst_oid_space, IS_WRITE_EXCLUSIVE_LOCK, LK_GRANTED, lock_abort_composite_lock(), lk_composite_lock::lockcomp, lk_lockcomp_class::next, lk_lockcomp_class::num_inst_oids, prm_get_integer_value(), PRM_ID_LK_ESCALATION_AT, lk_lockcomp::root_class_ptr, lk_lockcomp::tran_index, lk_lockcomp::wait_msecs, and X_LOCK.
Referenced by qexec_clear_groupby_state(), qexec_end_mainblock_iterations(), and qexec_execute_mainblock_internal().
|
static |
Definition at line 6905 of file lock_manager.c.
References lk_res::holder, LOCK_RESOURCE_CLASS, LOCK_RESOURCE_INSTANCE, LOCK_RESOURCE_ROOT_CLASS, NULL, pthread_mutex_unlock, lk_res::res_mutex, and lk_res_key::type.
Referenced by lock_demote_class_lock(), lock_get_class_lock(), lock_get_object_lock(), lock_has_lock_on_object(), lock_unlock_object(), and lock_unlock_object_lock_internal().
| void lock_force_thread_timeout_lock | ( | THREAD_ENTRY * | thrd | ) |
Definition at line 7390 of file lock_manager.c.
References ARG_FILE_LINE, assert, ER_ERROR_SEVERITY, ER_LK_STRANGE_LOCK_WAIT, er_set(), LOCK_RESUMED_TIMEOUT, thread_lock_entry(), and thread_unlock_entry().
Referenced by css_stop_log_writer(), and css_stop_non_log_writer().
|
static |
Definition at line 7429 of file lock_manager.c.
References ARG_FILE_LINE, assert, ER_ERROR_SEVERITY, ER_LK_STRANGE_LOCK_WAIT, er_set(), LOCK_RESUMED_INTERRUPT, LOCK_RESUMED_TIMEOUT, logtb_is_interrupted_tran(), thread_lock_entry(), and thread_unlock_entry().
Referenced by lock_initialize().
| LK_ENTRY* lock_get_class_lock | ( | THREAD_ENTRY * | thread_p, |
| const OID * | class_oid | ||
| ) |
Definition at line 7331 of file lock_manager.c.
References ARG_FILE_LINE, assert, ER_ERROR_SEVERITY, ER_LK_BAD_ARGUMENT, er_set(), lock_find_tran_hold_entry(), logtb_get_current_tran_index(), NULL, NULL_TRAN_INDEX, OID_EQ, OID_ISNULL, oid_Root_class_oid, pthread_mutex_lock, pthread_mutex_unlock, rv, and TT_LOADDB.
Referenced by lock_add_composite_lock(), lock_classes_lock_hint(), lock_object(), lock_scan(), and lock_subclass().
| int lock_get_lock_holder_tran_index | ( | THREAD_ENTRY * | thread_p, |
| char ** | out_buf, | ||
| int | waiter_index, | ||
| LK_RES * | res | ||
| ) |
Definition at line 9068 of file lock_manager.c.
References ARG_FILE_LINE, assert_release, ER_ERROR_SEVERITY, ER_FAILED, ER_OUT_OF_VIRTUAL_MEMORY, er_set(), lk_res::holder, lk_res::key, NO_ERROR, NULL, NULL_LOCK, lk_res_key::oid, OID_ISNULL, p, pthread_mutex_lock, pthread_mutex_unlock, lk_res::res_mutex, rv, and lk_res::waiter.
Referenced by xlogtb_get_pack_tran_table().
| unsigned int lock_get_number_object_locks | ( | void | ) |
Definition at line 8836 of file lock_manager.c.
Referenced by logpb_checkpoint().
Definition at line 6959 of file lock_manager.c.
References ARG_FILE_LINE, ER_ERROR_SEVERITY, ER_LK_BAD_ARGUMENT, er_set(), lock_find_tran_hold_entry(), logtb_get_current_tran_index(), NULL_LOCK, NULL_TRAN_INDEX, OID_EQ, oid_Root_class_oid, pthread_mutex_lock, pthread_mutex_unlock, rv, S_LOCK, SCH_M_LOCK, SIX_LOCK, thread_get_thread_entry_info(), TT_LOADDB, and X_LOCK.
Referenced by catalog_end_access_with_dir_oid(), catalog_start_access_with_dir_oid(), locator_attribute_info_force(), qexec_execute_selupd_list(), sbtree_load_index(), serial_update_serial_object(), xchksum_insert_repl_log_and_demote_table_lock(), and xlocator_fetch().
|
static |
Definition at line 9829 of file lock_manager.c.
References lock_get_transaction_lock_waiting_threads_mapfunc(), cubthread::manager::map_entries(), and thread_get_manager().
Referenced by lock_is_waiting_transaction().
|
static |
Definition at line 9803 of file lock_manager.c.
Referenced by lock_get_transaction_lock_waiting_threads().
Definition at line 7073 of file lock_manager.c.
References ARG_FILE_LINE, BU_LOCK, ER_ERROR_SEVERITY, ER_LK_BAD_ARGUMENT, er_set(), lock_Conv, lock_find_tran_hold_entry(), lock_has_lock_on_object(), logtb_get_current_tran_index(), NULL_LOCK, NULL_TRAN_INDEX, OID_EQ, OID_IS_ROOTOID, oid_Root_class_oid, pthread_mutex_lock, pthread_mutex_unlock, rv, thread_get_thread_entry_info(), and TT_LOADDB.
Referenced by btree_check_locking_for_delete_unique(), btree_check_locking_for_insert_unique(), btree_fk_object_does_exist(), btree_key_find_and_lock_unique_of_non_unique(), btree_key_find_and_lock_unique_of_unique(), cubload::server_object_loader::flush_records(), heap_check_heap_file(), heap_insert_logical(), cubload::server_object_loader::init(), locator_multi_insert_force(), locator_update_force(), lock_has_lock_on_object(), lock_object(), and xbtree_find_unique().
| bool lock_has_xlock | ( | THREAD_ENTRY * | thread_p | ) |
Definition at line 7181 of file lock_manager.c.
References IX_LOCK, lk_Standalone_has_xlock, LOG_FIND_THREAD_TRAN_INDEX, pthread_mutex_lock, pthread_mutex_unlock, rv, SCH_M_LOCK, SIX_LOCK, and X_LOCK.
Referenced by xtran_server_has_updated().
| int lock_hold_object_instant | ( | THREAD_ENTRY * | thread_p, |
| const OID * | oid, | ||
| const OID * | class_oid, | ||
| LOCK | lock | ||
| ) |
Definition at line 5860 of file lock_manager.c.
References ARG_FILE_LINE, ER_ERROR_SEVERITY, ER_LK_BAD_ARGUMENT, er_set(), LK_GRANTED, LK_NOTGRANTED_DUE_ERROR, LK_SET_STANDALONE_XLOCK, LOG_FIND_THREAD_TRAN_INDEX, and NULL_LOCK.
Referenced by scan_next_heap_scan(), and scan_next_index_lookup_heap().
| int lock_initialize | ( | void | ) |
Definition at line 5604 of file lock_manager.c.
References assert, BO_IS_SERVER_RESTARTED, bool, cubthread::manager::create_daemon(), cubthread::manager::destroy_daemon(), envvar_get(), error(), cubthread::get_manager(), cubthread::daemon::get_stats(), lock_detect_local_deadlock(), lock_finalize(), lock_force_timeout_expired_wait_transactions(), lock_is_local_deadlock_detection_interval_up(), cubthread::manager::map_entries(), NO_ERROR, thread_get_manager(), cubthread::entry::TS_DEAD, and cubthread::entry::TS_FREE.
Referenced by logtb_define_trantable_log_latch().
| int lock_initialize_composite_lock | ( | THREAD_ENTRY * | thread_p, |
| LK_COMPOSITE_LOCK * | comp_lock | ||
| ) |
Definition at line 8533 of file lock_manager.c.
References lk_lockcomp::class_list, lk_composite_lock::lockcomp, LOG_FIND_THREAD_TRAN_INDEX, logtb_find_wait_msecs(), NO_ERROR, NULL, lk_lockcomp::root_class_ptr, lk_lockcomp::tran_index, and lk_lockcomp::wait_msecs.
Referenced by qexec_execute_mainblock_internal().
Definition at line 8808 of file lock_manager.c.
References IS_WRITE_EXCLUSIVE_LOCK, IX_LOCK, and S_LOCK.
Referenced by lock_object().
| bool lock_is_instant_lock_mode | ( | int | tran_index | ) |
Definition at line 8999 of file lock_manager.c.
References LOCK_RESOURCE_CLASS, and OID_IS_ROOTOID.
Referenced by qexec_execute_mainblock_internal(), and qexec_execute_selupd_list().
|
static |
Definition at line 7608 of file lock_manager.c.
References perfmon_diff_timeval(), prm_get_float_value(), and PRM_ID_LK_RUN_DEADLOCK_INTERVAL.
Referenced by lock_initialize().
| bool lock_is_waiting_transaction | ( | int | tran_index | ) |
Definition at line 7280 of file lock_manager.c.
References ARG_FILE_LINE, ER_LK_STRANGE_LOCK_WAIT, er_set(), ER_WARNING_SEVERITY, i, lock_get_transaction_lock_waiting_threads(), thread_lock_entry(), and thread_unlock_entry().
Referenced by xtran_is_blocked().
| void lock_notify_isolation_incons | ( | THREAD_ENTRY * | thread_p, |
| bool(*)(const OID *class_oid, const OID *oid, void *args) | fun, | ||
| void * | args | ||
| ) |
Definition at line 7502 of file lock_manager.c.
References assert, INCON_NON_TWO_PHASE_LOCK, LOCK_RESOURCE_INSTANCE, LOG_FIND_THREAD_TRAN_INDEX, logtb_find_isolation(), NULL, OID_ISNULL, pthread_mutex_lock, pthread_mutex_unlock, rv, TRAN_REPEATABLE_READ, and TRAN_SERIALIZABLE.
Referenced by xlocator_fetch(), xlocator_fetch_all(), xlocator_fetch_lockhint_classes(), xlocator_fetch_lockset(), xlocator_lock_and_fetch_all(), and xlocator_notify_isolation_incons().
| int lock_object | ( | THREAD_ENTRY * | thread_p, |
| const OID * | oid, | ||
| const OID * | class_oid, | ||
| LOCK | lock, | ||
| int | cond_flag | ||
| ) |
Definition at line 5904 of file lock_manager.c.
References ARG_FILE_LINE, assert, BU_LOCK, ER_ERROR_SEVERITY, ER_LK_BAD_ARGUMENT, er_log_debug, ER_MNT_WAITING_THREAD, ER_NOTIFICATION_SEVERITY, er_set(), if(), IS_LOCK, IX_LOCK, LK_COND_LOCK, LK_FORCE_ZERO_WAIT, LK_GRANTED, LK_NOTGRANTED, LK_NOTGRANTED_DUE_ERROR, LK_SET_STANDALONE_XLOCK, lock_get_class_lock(), lock_has_lock_on_object(), lock_is_class_lock_escalated(), lock_stop_instant_lock_mode(), LOG_FIND_THREAD_TRAN_INDEX, logtb_find_isolation(), logtb_find_wait_msecs(), MONITOR_WAITING_THREAD, NULL, NULL_LOCK, OID_IS_ROOTOID, oid_Root_class_oid, prm_get_integer_value(), PRM_ID_MNT_WAITING_THREAD, S_LOCK, SCH_S_LOCK, tsc_elapsed_time_usec(), tsc_getticks(), and TT_LOADDB.
Referenced by btree_check_by_class_oid(), btree_fk_object_does_exist(), btree_key_find_and_lock_unique_of_non_unique(), btree_load_check_fk(), btree_repair_prev_link_by_class_oid(), catalog_check_consistency(), catalog_get_cardinality_by_name(), catalog_start_access_with_dir_oid(), catcls_delete_instance(), file_tracker_get_and_protect(), heap_compact_pages(), heap_get_insert_location_with_lock(), heap_insert_logical(), locator_add_or_remove_index_internal(), locator_check_all_entries_of_all_btrees(), locator_check_by_class_oid(), locator_lock_and_get_object_internal(), locator_repair_btree_by_delete(), locator_repair_btree_by_insert(), locator_update_force(), locator_update_index(), lock_object_wait_msecs(), qexec_execute_insert(), qexec_for_update_set_class_locks(), qexec_set_class_locks(), scan_next_heap_scan(), scan_next_index_lookup_heap(), xboot_checkdb_table(), xbtree_find_unique(), xbtree_load_online_index(), xcache_find_xasl_id_for_execute(), xlocator_delete_class_name(), xlocator_fetch_all(), xlocator_fetch_lockhint_classes(), xlocator_find_class_oid(), xlocator_find_lockhint_class_oids(), xlocator_get_class(), xlocator_lock_and_fetch_all(), xlocator_reserve_class_name(), xserial_get_next_value(), xstats_get_statistics_from_server(), and xstats_update_statistics().
| int lock_object_wait_msecs | ( | THREAD_ENTRY * | thread_p, |
| const OID * | oid, | ||
| const OID * | class_oid, | ||
| LOCK | lock, | ||
| int | cond_flag, | ||
| int | wait_msecs | ||
| ) |
Definition at line 6238 of file lock_manager.c.
References LK_GRANTED, LK_SET_STANDALONE_XLOCK, lock_object(), and xlogtb_reset_wait_msecs().
Referenced by boot_compact_db(), and xlocator_lock_and_fetch_all().
| int lock_reacquire_crash_locks | ( | THREAD_ENTRY * | thread_p, |
| LK_ACQUIRED_LOCKS * | acqlocks, | ||
| int | tran_index | ||
| ) |
Definition at line 8234 of file lock_manager.c.
References ARG_FILE_LINE, lk_acqobj_lock::class_oid, ER_ERROR_SEVERITY, ER_LK_BAD_ARGUMENT, er_log_debug, er_set(), i, LK_GRANTED, LK_INFINITE_WAIT, LK_NOTGRANTED_DUE_ERROR, lk_acqobj_lock::lock, lk_acquired_locks::nobj_locks, lk_acquired_locks::obj, and lk_acqobj_lock::oid.
Referenced by log_2pc_read_prepare().
| void lock_remove_object_lock | ( | THREAD_ENTRY * | thread_p, |
| const OID * | oid, | ||
| const OID * | class_oid, | ||
| LOCK | lock | ||
| ) |
Definition at line 6599 of file lock_manager.c.
References lock_unlock_object_lock_internal().
| int lock_rep_read_tran | ( | THREAD_ENTRY * | thread_p, |
| LOCK | lock, | ||
| int | cond_flag | ||
| ) |
Definition at line 9597 of file lock_manager.c.
References assert, lk_res_key::class_oid, ER_FAILED, lk_res::key, lf_freelist_claim(), lf_freelist_retire(), LK_COND_LOCK, LK_FORCE_ZERO_WAIT, LK_GRANTED, LK_SET_STANDALONE_XLOCK, LOCK_RESOURCE_CLASS, LOCK_RESOURCE_INSTANCE, LOG_FIND_THREAD_TRAN_INDEX, logtb_find_wait_msecs(), mvcc_is_mvcc_disabled_class(), NO_ERROR, NULL, NULL_LOCK, lk_res_key::oid, oid_get_rep_read_tran_oid(), OID_IS_ROOTOID, OID_IS_VIRTUAL_CLASS_OF_DIR_OID, OID_ISNULL, S_LOCK, TRAN_READ_COMMITTED, and lk_res_key::type.
Referenced by xtran_lock_rep_read().
| int lock_scan | ( | THREAD_ENTRY * | thread_p, |
| const OID * | class_oid, | ||
| int | cond_flag, | ||
| LOCK | class_lock | ||
| ) |
Definition at line 6268 of file lock_manager.c.
References ARG_FILE_LINE, assert, er_errid(), ER_ERROR_SEVERITY, ER_LK_BAD_ARGUMENT, er_log_debug, ER_MNT_WAITING_THREAD, ER_NOTIFICATION_SEVERITY, er_set(), LK_COND_LOCK, LK_FORCE_ZERO_WAIT, LK_GRANTED, LK_NOTGRANTED_DUE_ERROR, LK_UNCOND_LOCK, lock_get_class_lock(), LOG_FIND_THREAD_TRAN_INDEX, logtb_find_isolation(), logtb_find_wait_msecs(), MONITOR_WAITING_THREAD, NO_ERROR, NULL, oid_Root_class_oid, prm_get_integer_value(), PRM_ID_MNT_WAITING_THREAD, tsc_elapsed_time_usec(), and tsc_getticks().
Referenced by heap_scancache_start_internal().
| void lock_start_instant_lock_mode | ( | int | tran_index | ) |
Definition at line 8853 of file lock_manager.c.
Referenced by qexec_execute_mainblock_internal(), and qexec_execute_selupd_list().
| void lock_stop_instant_lock_mode | ( | THREAD_ENTRY * | thread_p, |
| int | tran_index, | ||
| bool | need_unlock | ||
| ) |
Definition at line 8875 of file lock_manager.c.
References assert, assert_release, and cubregex::count().
Referenced by lock_object(), qexec_execute_mainblock_internal(), and qexec_execute_selupd_list().
| int lock_subclass | ( | THREAD_ENTRY * | thread_p, |
| const OID * | subclass_oid, | ||
| const OID * | superclass_oid, | ||
| LOCK | lock, | ||
| int | cond_flag | ||
| ) |
Definition at line 6116 of file lock_manager.c.
References ARG_FILE_LINE, ER_ERROR_SEVERITY, ER_LK_BAD_ARGUMENT, er_log_debug, ER_MNT_WAITING_THREAD, ER_NOTIFICATION_SEVERITY, er_set(), if(), IS_LOCK, IX_LOCK, LK_COND_LOCK, LK_FORCE_ZERO_WAIT, LK_GRANTED, LK_NOTGRANTED_DUE_ERROR, LK_SET_STANDALONE_XLOCK, lock_get_class_lock(), LOG_FIND_THREAD_TRAN_INDEX, logtb_find_isolation(), logtb_find_wait_msecs(), MONITOR_WAITING_THREAD, NULL, NULL_LOCK, prm_get_integer_value(), PRM_ID_MNT_WAITING_THREAD, S_LOCK, tsc_elapsed_time_usec(), and tsc_getticks().
Referenced by locator_insert_force(), locator_update_force(), qexec_execute_obj_fetch(), and qexec_prune_spec().
| void lock_unlock_all | ( | THREAD_ENTRY * | thread_p | ) |
Definition at line 6837 of file lock_manager.c.
References assert, INCON_NON_TWO_PHASE_LOCK, lock_clear_deadlock_victim(), LOG_FIND_THREAD_TRAN_INDEX, and pgbuf_unfix_all().
Referenced by log_abort_local(), log_commit_local(), and log_complete_for_2pc().
| void lock_unlock_all_shared_get_all_exclusive | ( | THREAD_ENTRY * | thread_p, |
| LK_ACQUIRED_LOCKS * | acqlocks | ||
| ) |
Definition at line 8286 of file lock_manager.c.
References ARG_FILE_LINE, assert, lk_acqobj_lock::class_oid, COPY_OID, ER_ERROR_SEVERITY, ER_OUT_OF_VIRTUAL_MEMORY, er_set(), lk_acqobj_lock::lock, LOG_FIND_THREAD_TRAN_INDEX, lk_acquired_locks::nobj_locks, NULL, lk_acquired_locks::obj, lk_acqobj_lock::oid, oid_Root_class_oid, OID_SET_NULL, pthread_mutex_lock, pthread_mutex_unlock, rv, and S_LOCK.
Referenced by log_2pc_commit_first_phase(), and log_2pc_prepare_global_tran().
| void lock_unlock_classes_lock_hint | ( | THREAD_ENTRY * | thread_p, |
| LC_LOCKHINT * | lockhint | ||
| ) |
Definition at line 6778 of file lock_manager.c.
References ARG_FILE_LINE, lc_lock_hint::classes, ER_ERROR_SEVERITY, ER_LK_BAD_ARGUMENT, ER_LK_UNKNOWN_ISOLATION, er_set(), i, lc_lockhint_class::lock, LOG_FIND_THREAD_TRAN_INDEX, logtb_find_isolation(), NULL_LOCK, lc_lock_hint::num_classes, lc_lockhint_class::oid, OID_ISNULL, TRAN_READ_COMMITTED, TRAN_REPEATABLE_READ, and TRAN_SERIALIZABLE.
Referenced by xlocator_fetch_lockhint_classes().
| void lock_unlock_object | ( | THREAD_ENTRY * | thread_p, |
| const OID * | oid, | ||
| const OID * | class_oid, | ||
| LOCK | lock, | ||
| bool | force | ||
| ) |
Definition at line 6616 of file lock_manager.c.
References ARG_FILE_LINE, assert, ER_ERROR_SEVERITY, ER_LK_BAD_ARGUMENT, ER_LK_UNKNOWN_ISOLATION, er_set(), is_class(), lock_find_tran_hold_entry(), LOG_FIND_THREAD_TRAN_INDEX, logtb_find_isolation(), NULL_LOCK, OID_IS_ROOTOID, S_LOCK, TRAN_READ_COMMITTED, TRAN_REPEATABLE_READ, and TRAN_SERIALIZABLE.
Referenced by boot_compact_db(), btree_check_all(), btree_check_by_class_oid(), btree_repair_prev_link(), btree_repair_prev_link_by_class_oid(), catalog_check_consistency(), file_tracker_check(), file_tracker_interruptable_iterate(), heap_check_all_heaps(), heap_compact_pages(), locator_check_all_entries_of_all_btrees(), locator_check_by_class_oid(), locator_permoid_class_name(), process_class(), xboot_checkdb_table(), xlocator_delete_class_name(), xlocator_does_exist(), xlocator_fetch(), xlocator_fetch_all(), xlocator_find_class_oid(), xlocator_find_lockhint_class_oids(), xlocator_get_class(), xlocator_lock_and_fetch_all(), xlocator_reserve_class_name(), xserial_get_next_value(), xstats_get_statistics_from_server(), and xstats_update_statistics().
| void lock_unlock_object_donot_move_to_non2pl | ( | THREAD_ENTRY * | thread_p, |
| const OID * | oid, | ||
| const OID * | class_oid, | ||
| LOCK | lock | ||
| ) |
Definition at line 6584 of file lock_manager.c.
References lock_unlock_object_lock_internal().
Referenced by btree_find_foreign_key(), btree_fk_object_does_exist(), btree_insert_internal(), btree_key_find_and_lock_unique_of_non_unique(), btree_key_find_and_lock_unique_of_unique(), catalog_end_access_with_dir_oid(), locator_check_primary_key_delete(), locator_check_primary_key_update(), locator_lock_and_get_object_internal(), locator_lock_and_get_object_with_evaluation(), scan_next_heap_scan(), scan_next_index_lookup_heap(), xbtree_find_unique(), and xlocator_fetch().
|
static |
Definition at line 6551 of file lock_manager.c.
References is_class(), lock_find_tran_hold_entry(), LOG_FIND_THREAD_TRAN_INDEX, NULL, and OID_IS_ROOTOID.
Referenced by lock_remove_object_lock(), and lock_unlock_object_donot_move_to_non2pl().
| void lock_unlock_objects_lock_set | ( | THREAD_ENTRY * | thread_p, |
| LC_LOCKSET * | lockset | ||
| ) |
Definition at line 6708 of file lock_manager.c.
References ARG_FILE_LINE, assert, lc_lockset_reqobj::class_index, lc_lock_set::classes, ER_ERROR_SEVERITY, ER_LK_BAD_ARGUMENT, ER_LK_UNKNOWN_ISOLATION, er_set(), i, LOG_FIND_THREAD_TRAN_INDEX, logtb_find_isolation(), lc_lock_set::num_reqobjs_processed, lc_lock_set::objects, lc_lockset_reqobj::oid, lc_lockset_classof::oid, OID_ISNULL, lc_lock_set::reqobj_class_lock, TRAN_READ_COMMITTED, TRAN_REPEATABLE_READ, TRAN_SERIALIZABLE, and X_LOCK.
Referenced by xlocator_fetch_lockset().
|
static |
Definition at line 7640 of file lock_manager.c.
References ARG_FILE_LINE, css_get_num_request_workers(), ER_LK_NOTENOUGH_ACTIVE_THREADS, ER_NOTIFICATION_SEVERITY, er_set(), and logtb_get_number_assigned_tran_indices().
Referenced by lock_detect_local_deadlock().
| const char* lock_wait_state_to_string | ( | int | state | ) |
Definition at line 9226 of file lock_manager.c.
References assert, lk_res_key::class_oid, COPY_OID, csect_check_own, CSECT_EVENT_LOG_FILE, er_stack_pop(), er_stack_push(), event_log_bind_values(), event_log_print_client_info(), event_log_sql_string(), free_and_init, heap_get_class_name(), lk_res::holder, i, lk_res::key, lock_Comp, LOCK_COMPAT_NO, LOCK_COMPAT_UNKNOWN, LOCK_RESOURCE_CLASS, LOCK_RESOURCE_INSTANCE, LOCK_RESOURCE_ROOT_CLASS, LOCK_RESUMED, LOCK_RESUMED_ABORTED, LOCK_RESUMED_ABORTED_FIRST, LOCK_RESUMED_ABORTED_OTHER, LOCK_RESUMED_DEADLOCK_TIMEOUT, LOCK_RESUMED_INTERRUPT, LOCK_RESUMED_TIMEOUT, LOCK_TO_LOCKMODE_STRING, LOG_FIND_TDES(), log_fp, MAX_NUM_EXEC_QUERY_HISTORY, MAX_NUM_LOCKS_DUMP_TO_EVENT_LOG, NULL, log_tdes::num_exec_queries, lk_res_key::oid, OID_EQ, OID_GET_REAL_CLASS_OF_DIR_OID, oid_get_rep_read_tran_oid(), OID_IS_VIRTUAL_CLASS_OF_DIR_OID, OID_ISTEMP, db_identifier::pageid, pthread_mutex_lock, pthread_mutex_unlock, lk_res::res_mutex, rv, db_identifier::slotid, lk_res_key::type, db_identifier::volid, lk_res::waiter, log_tdes::xasl_id, XASL_ID_COPY, XASL_ID_IS_NULL, and XASL_ID_SET_NULL.
Referenced by showstmt_array_end_scan().
| void xlock_dump | ( | THREAD_ENTRY * | thread_p, |
| FILE * | outfp | ||
| ) |
Definition at line 8429 of file lock_manager.c.
References assert_release, LK_FORCE_ZERO_WAIT, LK_INFINITE_WAIT, LK_ZERO_WAIT, log_isolation_string(), log_state_string(), logtb_find_client_name_host_pid(), logtb_find_isolation(), logtb_find_state(), logtb_find_wait_msecs(), MSGCAT_CATALOG_CUBRID, MSGCAT_LK_DUMP_LOCK_TABLE, MSGCAT_LK_DUMP_TRAN_IDENTIFIERS, MSGCAT_LK_DUMP_TRAN_ISOLATION, MSGCAT_LK_DUMP_TRAN_STATE, MSGCAT_LK_DUMP_TRAN_TIMEOUT_PERIOD, MSGCAT_LK_NEWLINE, msgcat_message(), MSGCAT_SET_LOCK, NO_ERROR, NULL, prm_get_float_value(), prm_get_integer_value(), PRM_ID_LK_ESCALATION_AT, PRM_ID_LK_RUN_DEADLOCK_INTERVAL, and xlogtb_reset_wait_msecs().
Referenced by lock_demote_class_lock(), lock_dump(), and slock_dump().
| const size_t DEFAULT_LOCK_WAITING_THREAD_ARRAY_SIZE = 10 |
Definition at line 467 of file lock_manager.c.
|
static |
Definition at line 456 of file lock_manager.c.
Referenced by lock_has_xlock().
| LOCK_COMPATIBILITY lock_Comp[12][12] |
Definition at line 67 of file lock_table.c.
Referenced by lock_demote_class_lock(), lock_detect_local_deadlock(), and lock_wait_state_to_string().
1.8.11