MySQL 9.0.0
Source Code Documentation
pfs_instr.cc File Reference

Performance schema instruments (implementation). More...

Functions

int init_instruments (const PFS_global_param *param)
 Initialize all the instruments instance buffers. More...
 
void cleanup_instruments ()
 Cleanup all the instruments buffers. More...
 
static const ucharfilename_hash_get_key (const uchar *entry, size_t *length)
 Get hash table key for instrumented files. More...
 
static uint filename_hash_func (const LF_HASH *, const uchar *key, size_t key_len)
 
static int filename_hash_cmp_func (const uchar *key1, size_t key_len1, const uchar *key2, size_t key_len2)
 
int init_file_hash (const PFS_global_param *param)
 Initialize the file name hash. More...
 
void cleanup_file_hash ()
 Cleanup the file name hash. More...
 
PFS_mutexcreate_mutex (PFS_mutex_class *klass, const void *identity)
 Create instrumentation for a mutex instance. More...
 
void destroy_mutex (PFS_mutex *pfs)
 Destroy instrumentation for a mutex instance. More...
 
PFS_rwlockcreate_rwlock (PFS_rwlock_class *klass, const void *identity)
 Create instrumentation for a rwlock instance. More...
 
void destroy_rwlock (PFS_rwlock *pfs)
 Destroy instrumentation for a rwlock instance. More...
 
PFS_condcreate_cond (PFS_cond_class *klass, const void *identity)
 Create instrumentation for a condition instance. More...
 
void destroy_cond (PFS_cond *pfs)
 Destroy instrumentation for a condition instance. More...
 
void carry_global_memory_stat_alloc_delta (PFS_memory_stat_alloc_delta *delta, uint index)
 
void carry_global_memory_stat_free_delta (PFS_memory_stat_free_delta *delta, uint index)
 
PFS_threadcreate_thread (PFS_thread_class *klass, PSI_thread_seqnum seqnum, const void *identity, ulonglong processlist_id)
 Create instrumentation for a thread instance. More...
 
PFS_threadfind_thread_by_internal_id (ulonglong thread_id)
 Find a PFS thread given an internal thread id. More...
 
PFS_threadfind_thread_by_processlist_id (ulonglong processlist_id)
 Find a PFS thread given a processlist id. More...
 
PFS_mutexsanitize_mutex (PFS_mutex *unsafe)
 
PFS_rwlocksanitize_rwlock (PFS_rwlock *unsafe)
 
PFS_condsanitize_cond (PFS_cond *unsafe)
 
PFS_threadsanitize_thread (PFS_thread *unsafe)
 Sanitize a PFS_thread pointer. More...
 
PFS_filesanitize_file (PFS_file *unsafe)
 
PFS_socketsanitize_socket (PFS_socket *unsafe)
 
PFS_metadata_locksanitize_metadata_lock (PFS_metadata_lock *unsafe)
 
void destroy_thread (PFS_thread *pfs)
 Destroy instrumentation for a thread instance. More...
 
static LF_PINSget_filename_hash_pins (PFS_thread *thread)
 Get the hash pins for filename_hash. More...
 
int normalize_filename (const char *filename, uint name_len, PFS_file_name &normalized)
 Normalize a filename with fully qualified path. More...
 
PFS_filefind_or_create_file (PFS_thread *thread, PFS_file_class *klass, const char *filename, uint len, bool create)
 Find or create instrumentation for a file instance by file name. More...
 
PFS_filestart_file_rename (PFS_thread *thread, const char *old_name)
 Before the rename operation: Find the file instrumentation by name, then delete the filename from the filename hash. More...
 
int end_file_rename (PFS_thread *thread, PFS_file *pfs, const char *new_name, int rename_result)
 After the rename operation: Assign the new filename to the file instrumentation instance, then add to the filename hash. More...
 
PFS_filefind_file (PFS_thread *thread, PFS_file_class *klass, const char *filename, uint len)
 Find a file instrumentation instance by name. More...
 
void release_file (PFS_file *pfs)
 Release instrumentation for a file instance. More...
 
void delete_file_name (PFS_thread *thread, PFS_file *pfs)
 Delete file name from the hash table. More...
 
void destroy_file (PFS_thread *thread, PFS_file *pfs, bool delete_name)
 Destroy instrumentation for a file instance. More...
 
PFS_tablecreate_table (PFS_table_share *share, PFS_thread *opening_thread, const void *identity)
 Create instrumentation for a table instance. More...
 
void destroy_table (PFS_table *pfs)
 Destroy instrumentation for a table instance. More...
 
PFS_socketcreate_socket (PFS_socket_class *klass, const my_socket *fd, const struct sockaddr *addr, socklen_t addr_len)
 Create instrumentation for a socket instance. More...
 
void destroy_socket (PFS_socket *pfs)
 Destroy instrumentation for a socket instance. More...
 
PFS_metadata_lockcreate_metadata_lock (void *identity, const MDL_key *mdl_key, opaque_mdl_type mdl_type, opaque_mdl_duration mdl_duration, opaque_mdl_status mdl_status, const char *src_file, uint src_line)
 
void destroy_metadata_lock (PFS_metadata_lock *pfs)
 
static void fct_reset_mutex_waits (PFS_mutex *pfs)
 
static void reset_mutex_waits_by_instance ()
 
static void fct_reset_rwlock_waits (PFS_rwlock *pfs)
 
static void reset_rwlock_waits_by_instance ()
 
static void fct_reset_cond_waits (PFS_cond *pfs)
 
static void reset_cond_waits_by_instance ()
 
static void fct_reset_file_waits (PFS_file *pfs)
 
static void reset_file_waits_by_instance ()
 
static void fct_reset_socket_waits (PFS_socket *pfs)
 
static void reset_socket_waits_by_instance ()
 
void reset_events_waits_by_instance ()
 Reset the wait statistics per object instance. More...
 
static void fct_reset_file_io (PFS_file *pfs)
 
void reset_file_instance_io ()
 Reset the I/O statistics per file instance. More...
 
static void fct_reset_socket_io (PFS_socket *pfs)
 
void reset_socket_instance_io ()
 Reset the I/O statistics per socket instance. More...
 
void reset_histogram_global ()
 
void aggregate_all_event_names (PFS_single_stat *from_array, PFS_single_stat *to_array)
 
void aggregate_all_event_names (PFS_single_stat *from_array, PFS_single_stat *to_array_1, PFS_single_stat *to_array_2)
 
void aggregate_all_stages (PFS_stage_stat *from_array, PFS_stage_stat *to_array)
 
void aggregate_all_stages (PFS_stage_stat *from_array, PFS_stage_stat *to_array_1, PFS_stage_stat *to_array_2)
 
void aggregate_all_statements (PFS_statement_stat *from_array, PFS_statement_stat *to_array)
 
void aggregate_all_statements (PFS_statement_stat *from_array, PFS_statement_stat *to_array_1, PFS_statement_stat *to_array_2)
 
void aggregate_all_transactions (PFS_transaction_stat *from_array, PFS_transaction_stat *to_array)
 
void aggregate_all_transactions (PFS_transaction_stat *from_array, PFS_transaction_stat *to_array_1, PFS_transaction_stat *to_array_2)
 
void aggregate_all_errors (PFS_error_stat *from_array, PFS_error_stat *to_array)
 
void aggregate_all_errors (PFS_error_stat *from_array, PFS_error_stat *to_array_1, PFS_error_stat *to_array_2)
 
void aggregate_all_memory_with_reassign (bool alive, PFS_memory_safe_stat *from_array, PFS_memory_shared_stat *to_array, PFS_memory_shared_stat *global_array)
 
void aggregate_all_memory (bool alive, PFS_memory_safe_stat *from_array, PFS_memory_shared_stat *to_array)
 
void aggregate_all_memory (bool alive, PFS_memory_shared_stat *from_array, PFS_memory_shared_stat *to_array)
 
void aggregate_all_memory_with_reassign (bool alive, PFS_memory_safe_stat *from_array, PFS_memory_shared_stat *to_array_1, PFS_memory_shared_stat *to_array_2, PFS_memory_shared_stat *global_array)
 
void aggregate_all_memory (bool alive, PFS_memory_shared_stat *from_array, PFS_memory_shared_stat *to_array_1, PFS_memory_shared_stat *to_array_2)
 
void aggregate_thread_status (PFS_thread *thread, PFS_account *safe_account, PFS_user *safe_user, PFS_host *safe_host)
 
static void aggregate_thread_stats (PFS_thread *thread, PFS_account *safe_account, PFS_user *safe_user, PFS_host *safe_host)
 
void aggregate_thread (PFS_thread *thread, PFS_account *safe_account, PFS_user *safe_user, PFS_host *safe_host)
 
void aggregate_thread_waits (PFS_thread *thread, PFS_account *safe_account, PFS_user *safe_user, PFS_host *safe_host)
 
void aggregate_thread_stages (PFS_thread *thread, PFS_account *safe_account, PFS_user *safe_user, PFS_host *safe_host)
 
void aggregate_thread_statements (PFS_thread *thread, PFS_account *safe_account, PFS_user *safe_user, PFS_host *safe_host)
 
void aggregate_thread_transactions (PFS_thread *thread, PFS_account *safe_account, PFS_user *safe_user, PFS_host *safe_host)
 
void aggregate_thread_errors (PFS_thread *thread, PFS_account *safe_account, PFS_user *safe_user, PFS_host *safe_host)
 
void aggregate_thread_memory (bool alive, PFS_thread *thread, PFS_account *safe_account, PFS_user *safe_user, PFS_host *safe_host)
 
void clear_thread_account (PFS_thread *thread)
 
void set_thread_account (PFS_thread *thread)
 
static void fct_update_mutex_derived_flags (PFS_mutex *pfs)
 
void update_mutex_derived_flags ()
 Update derived flags for all mutex instances. More...
 
static void fct_update_rwlock_derived_flags (PFS_rwlock *pfs)
 
void update_rwlock_derived_flags ()
 Update derived flags for all rwlock instances. More...
 
static void fct_update_cond_derived_flags (PFS_cond *pfs)
 
void update_cond_derived_flags ()
 Update derived flags for all condition instances. More...
 
static void fct_update_file_derived_flags (PFS_file *pfs)
 
void update_file_derived_flags ()
 Update derived flags for all file handles. More...
 
static void fct_update_table_derived_flags (PFS_table *pfs)
 
void update_table_derived_flags ()
 Update derived flags for all table handles. More...
 
static void fct_update_socket_derived_flags (PFS_socket *pfs)
 
void update_socket_derived_flags ()
 Update derived flags for all socket instances. More...
 
static void fct_reset_metadata_source_file_pointers (PFS_metadata_lock *pfs)
 
static void fct_update_metadata_derived_flags (PFS_metadata_lock *pfs)
 
void update_metadata_derived_flags ()
 Update derived flags for all metadata instances. More...
 
static void fct_update_thread_derived_flags (PFS_thread *pfs)
 
void update_thread_derived_flags ()
 Update derived flags for all thread instances. More...
 
void update_instruments_derived_flags ()
 Update derived flags for all instruments. More...
 
static void fct_reset_source_file_pointers (PFS_thread *pfs_thread)
 For each thread, clear the source file pointers from all waits, stages, statements and transaction events. More...
 
void reset_source_file_pointers ()
 Clear the source file pointers from all waits, stages, statements and transaction events. More...
 

Variables

ulong nested_statement_lost = 0
 
long file_handle_max = 0
 Size of the file handle array. More...
 
bool file_handle_full
 True when file_handle_array is full. More...
 
ulong file_handle_lost = 0
 Number of file handle lost. More...
 
ulong events_waits_history_per_thread = 0
 Number of EVENTS_WAITS_HISTORY records per thread. More...
 
ulong events_stages_history_per_thread = 0
 Number of EVENTS_STAGES_HISTORY records per thread. More...
 
ulong events_statements_history_per_thread = 0
 Number of EVENTS_STATEMENTS_HISTORY records per thread. More...
 
uint statement_stack_max = 0
 Max size of the statements stack. More...
 
size_t pfs_max_digest_length = 0
 Max size of the digests token array. More...
 
size_t pfs_max_sqltext = 0
 Max size of SQL TEXT. More...
 
ulong locker_lost = 0
 Number of locker lost. More...
 
ulong statement_lost = 0
 Number of statements lost. More...
 
ulong session_connect_attrs_size_per_thread
 Size of connection attribute storage per thread. More...
 
ulong session_connect_attrs_longest_seen = 0
 Longest connection attributes string seen so far, pre-truncation. More...
 
ulong session_connect_attrs_lost = 0
 Number of connection attributes lost. More...
 
ulong events_transactions_history_per_thread = 0
 Number of EVENTS_TRANSACTIONS_HISTORY records per thread. More...
 
PFS_file ** file_handle_array = nullptr
 File instrumentation handle array. More...
 
PFS_stage_statglobal_instr_class_stages_array = nullptr
 
PFS_statement_statglobal_instr_class_statements_array = nullptr
 
PFS_histogram global_statements_histogram
 
std::atomic< PFS_memory_shared_stat * > global_instr_class_memory_array {nullptr}
 
static PFS_cacheline_atomic_uint64 thread_internal_id_counter
 
LF_HASH filename_hash
 Hash table for instrumented files. More...
 
static bool filename_hash_inited = false
 True if filename_hash is initialized. More...
 

Detailed Description

Performance schema instruments (implementation).

Variable Documentation

◆ nested_statement_lost

ulong nested_statement_lost = 0