mariadb/storage/perfschema/unittest/pfs_instr-t.cc
Monty 0ccdf54b64 Check and remove high stack usage
I checked all stack overflow potential problems found with
gcc -Wstack-usage=16384
and
clang -Wframe-larger-than=16384 -no-inline

Fixes:
Added '#pragma clang diagnostic ignored "-Wframe-larger-than="'
  to a lot of function to where stack usage large but resonable.
- Added stack check warnings to BUILD scrips when using clang and debug.

Function changed to use malloc instead allocating things on stack:
- read_bootstrap_query() now allocates line_buffer (20000 bytes) with
  malloc() instead of using stack. This has a small performance impact
  but this is not releant for bootstrap.
- mroonga grn_select() used 65856 bytes on stack. Changed it to use
  malloc().
- Wsrep_schema::replay_transaction() and
  Wsrep_schema::recover_sr_transactions().
- Connect zipOpen3()

Not fixed:
- mroonga/vendor/groonga/lib/expr.c grn_proc_call() uses
  43712 byte on stack.  However this is not easy to fix as the stack
  used is caused by a lot of code generated by defines.
- Most changes in mroonga/groonga where only adding of pragmas to disable
  stack warnings.
- rocksdb/options/options_helper.cc uses 20288 of stack space.
  (no reason to fix except to get rid of the compiler warning)
- Causes using alloca() where the allocation size is resonable.
- An issue in libmariadb (reported to connectors).
2024-04-23 14:12:31 +03:00

491 lines
17 KiB
C++

/* Copyright (c) 2008, 2023, Oracle and/or its affiliates.
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License, version 2.0,
as published by the Free Software Foundation.
This program is also distributed with certain software (including
but not limited to OpenSSL) that is licensed under separate terms,
as designated in a particular file or component or in included license
documentation. The authors of MySQL hereby grant you an additional
permission to link the program and your derivative works with the
separately licensed software that they have included with MySQL.
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License, version 2.0, for more details.
You should have received a copy of the GNU General Public License
along with this program; if not, write to the Free Software Foundation,
51 Franklin Street, Fifth Floor, Boston, MA 02110-1335 USA */
#include <my_global.h>
#include <my_thread.h>
#include <pfs_instr.h>
#include <pfs_stat.h>
#include <pfs_global.h>
#include <pfs_instr_class.h>
#include <pfs_buffer_container.h>
#include <tap.h>
#include "stub_global_status_var.h"
#include <memory.h>
PFS_global_param param;
void test_no_instruments()
{
int rc;
memset(& param, 0xFF, sizeof(param));
param.m_enabled= true;
param.m_mutex_class_sizing= 0;
param.m_rwlock_class_sizing= 0;
param.m_cond_class_sizing= 0;
param.m_thread_class_sizing= 0;
param.m_table_share_sizing= 0;
param.m_file_class_sizing= 0;
param.m_socket_class_sizing= 0;
param.m_mutex_sizing= 0;
param.m_rwlock_sizing= 0;
param.m_cond_sizing= 0;
param.m_thread_sizing= 0;
param.m_table_sizing= 0;
param.m_file_sizing= 0;
param.m_file_handle_sizing= 0;
param.m_socket_sizing= 0;
param.m_events_waits_history_sizing= 0;
param.m_events_waits_history_long_sizing= 0;
param.m_setup_actor_sizing= 0;
param.m_setup_object_sizing= 0;
param.m_host_sizing= 0;
param.m_user_sizing= 0;
param.m_account_sizing= 0;
param.m_stage_class_sizing= 0;
param.m_events_stages_history_sizing= 0;
param.m_events_stages_history_long_sizing= 0;
param.m_statement_class_sizing= 0;
param.m_events_statements_history_sizing= 0;
param.m_events_statements_history_long_sizing= 0;
param.m_events_transactions_history_sizing= 0;
param.m_events_transactions_history_long_sizing= 0;
param.m_digest_sizing= 0;
param.m_session_connect_attrs_sizing= 0;
param.m_program_sizing= 0;
param.m_prepared_stmt_sizing= 0;
param.m_statement_stack_sizing= 0;
param.m_memory_class_sizing= 0;
param.m_metadata_lock_sizing= 0;
init_event_name_sizing(& param);
rc= init_instruments(& param);
ok(rc == 0, "zero init");
cleanup_instruments();
}
PRAGMA_DISABLE_CHECK_STACK_FRAME
void test_no_instances()
{
int rc;
PFS_mutex_class dummy_mutex_class;
PFS_rwlock_class dummy_rwlock_class;
PFS_cond_class dummy_cond_class;
PFS_thread_class dummy_thread_class;
PFS_file_class dummy_file_class;
PFS_table_share dummy_table_share;
PFS_socket_class dummy_socket_class;
PFS_mutex *mutex;
PFS_rwlock *rwlock;
PFS_cond *cond;
PFS_thread *thread;
PFS_file *file;
PFS_socket *socket;
PFS_table *table;
dummy_mutex_class.m_event_name_index = 0;
dummy_mutex_class.m_flags = 0;
dummy_mutex_class.m_enabled = true;
dummy_mutex_class.m_volatility = PSI_VOLATILITY_UNKNOWN;
dummy_rwlock_class.m_event_name_index = 1;
dummy_rwlock_class.m_flags = 0;
dummy_rwlock_class.m_enabled = true;
dummy_rwlock_class.m_volatility = PSI_VOLATILITY_UNKNOWN;
dummy_cond_class.m_event_name_index = 2;
dummy_cond_class.m_flags = 0;
dummy_cond_class.m_enabled = true;
dummy_cond_class.m_volatility = PSI_VOLATILITY_UNKNOWN;
dummy_file_class.m_event_name_index = 3;
dummy_file_class.m_flags = 0;
dummy_file_class.m_enabled = true;
dummy_file_class.m_volatility = PSI_VOLATILITY_UNKNOWN;
dummy_socket_class.m_event_name_index = 4;
dummy_socket_class.m_flags = 0;
dummy_socket_class.m_enabled = true;
dummy_socket_class.m_volatility = PSI_VOLATILITY_UNKNOWN;
memset(& param, 0xFF, sizeof(param));
param.m_enabled= true;
param.m_mutex_class_sizing= 1;
param.m_rwlock_class_sizing= 1;
param.m_cond_class_sizing= 1;
param.m_thread_class_sizing= 1;
param.m_table_share_sizing= 1;
param.m_file_class_sizing= 1;
param.m_socket_class_sizing= 0;
param.m_mutex_sizing= 0;
param.m_rwlock_sizing= 0;
param.m_cond_sizing= 0;
param.m_thread_sizing= 0;
param.m_table_sizing= 0;
param.m_file_sizing= 0;
param.m_file_handle_sizing= 0;
param.m_socket_sizing= 0;
param.m_events_waits_history_sizing= 0;
param.m_events_waits_history_long_sizing= 0;
param.m_setup_actor_sizing= 0;
param.m_setup_object_sizing= 0;
param.m_host_sizing= 0;
param.m_user_sizing= 0;
param.m_account_sizing= 0;
param.m_stage_class_sizing= 0;
param.m_events_stages_history_sizing= 0;
param.m_events_stages_history_long_sizing= 0;
param.m_statement_class_sizing= 0;
param.m_events_statements_history_sizing= 0;
param.m_events_statements_history_long_sizing= 0;
param.m_events_transactions_history_sizing= 0;
param.m_events_transactions_history_long_sizing= 0;
param.m_digest_sizing= 0;
param.m_session_connect_attrs_sizing= 0;
param.m_program_sizing= 0;
param.m_prepared_stmt_sizing= 0;
param.m_statement_stack_sizing= 0;
param.m_memory_class_sizing= 1;
param.m_metadata_lock_sizing= 0;
init_event_name_sizing(& param);
rc= init_instruments(& param);
ok(rc == 0, "no instances init");
mutex= create_mutex(& dummy_mutex_class, NULL);
ok(mutex == NULL, "no mutex");
ok(global_mutex_container.get_lost_counter() == 1, "lost 1");
mutex= create_mutex(& dummy_mutex_class, NULL);
ok(mutex == NULL, "no mutex");
ok(global_mutex_container.get_lost_counter() == 2, "lost 2");
rwlock= create_rwlock(& dummy_rwlock_class, NULL);
ok(rwlock == NULL, "no rwlock");
ok(global_rwlock_container.m_lost == 1, "lost 1");
rwlock= create_rwlock(& dummy_rwlock_class, NULL);
ok(rwlock == NULL, "no rwlock");
ok(global_rwlock_container.m_lost == 2, "lost 2");
cond= create_cond(& dummy_cond_class, NULL);
ok(cond == NULL, "no cond");
ok(global_cond_container.m_lost == 1, "lost 1");
cond= create_cond(& dummy_cond_class, NULL);
ok(cond == NULL, "no cond");
ok(global_cond_container.m_lost == 2, "lost 2");
thread= create_thread(& dummy_thread_class, NULL, 0);
ok(thread == NULL, "no thread");
ok(global_thread_container.m_lost == 1, "lost 1");
thread= create_thread(& dummy_thread_class, NULL, 0);
ok(thread == NULL, "no thread");
ok(global_thread_container.m_lost == 2, "lost 2");
PFS_thread fake_thread;
fake_thread.m_filename_hash_pins= NULL;
file= find_or_create_file(& fake_thread, & dummy_file_class, "dummy", 5, true);
ok(file == NULL, "no file");
ok(global_file_container.m_lost == 1, "lost 1");
file= find_or_create_file(& fake_thread, & dummy_file_class, "dummy", 5, true);
ok(file == NULL, "no file");
ok(global_file_container.m_lost == 2, "lost 2");
init_file_hash(& param);
file= find_or_create_file(& fake_thread, & dummy_file_class, "dummy", 5, true);
ok(file == NULL, "no file");
ok(global_file_container.m_lost == 3, "lost 3");
file= find_or_create_file(& fake_thread, & dummy_file_class, "dummy", 5, true);
ok(file == NULL, "no file");
ok(global_file_container.m_lost == 4, "lost 4");
char long_file_name[10000];
int size= sizeof(long_file_name);
memset(long_file_name, 'X', size);
file= find_or_create_file(& fake_thread, & dummy_file_class, long_file_name, size, true);
ok(file == NULL, "no file");
ok(global_file_container.m_lost == 5, "lost 5");
table= create_table(& dummy_table_share, & fake_thread, NULL);
ok(table == NULL, "no table");
ok(global_table_container.m_lost == 1, "lost 1");
table= create_table(& dummy_table_share, & fake_thread, NULL);
ok(table == NULL, "no table");
ok(global_table_container.m_lost == 2, "lost 2");
socket= create_socket(& dummy_socket_class, NULL, NULL, 0);
ok(socket == NULL, "no socket");
ok(global_socket_container.m_lost == 1, "lost 1");
socket= create_socket(& dummy_socket_class, NULL, NULL, 0);
ok(socket == NULL, "no socket");
ok(global_socket_container.m_lost == 2, "lost 2");
/* No result to test, just make sure it does not crash */
reset_events_waits_by_instance();
reset_events_waits_by_thread();
cleanup_file_hash();
cleanup_instruments();
}
PRAGMA_REENABLE_CHECK_STACK_FRAME
void test_with_instances()
{
int rc;
PFS_mutex_class dummy_mutex_class;
PFS_rwlock_class dummy_rwlock_class;
PFS_cond_class dummy_cond_class;
PFS_thread_class dummy_thread_class;
PFS_file_class dummy_file_class;
PFS_socket_class dummy_socket_class;
PFS_table_share dummy_table_share;
PFS_mutex *mutex_1;
PFS_mutex *mutex_2;
PFS_rwlock *rwlock_1;
PFS_rwlock *rwlock_2;
PFS_cond *cond_1;
PFS_cond *cond_2;
PFS_thread *thread_1;
PFS_thread *thread_2;
PFS_file *file_1;
PFS_file *file_2;
PFS_socket *socket_1;
PFS_socket *socket_2;
PFS_table *table_1;
PFS_table *table_2;
memset(& param, 0xFF, sizeof(param));
param.m_enabled= true;
param.m_mutex_class_sizing= 1;
param.m_rwlock_class_sizing= 1;
param.m_cond_class_sizing= 1;
param.m_thread_class_sizing= 1;
param.m_table_share_sizing= 1;
param.m_file_class_sizing= 1;
param.m_socket_class_sizing= 1;
param.m_mutex_sizing= 2;
param.m_rwlock_sizing= 2;
param.m_cond_sizing= 2;
param.m_thread_sizing= 2;
param.m_table_sizing= 2;
param.m_file_sizing= 2;
param.m_file_handle_sizing= 100;
param.m_socket_sizing= 2;
param.m_events_waits_history_sizing= 10;
param.m_events_waits_history_long_sizing= 10000;
param.m_setup_actor_sizing= 0;
param.m_setup_object_sizing= 0;
param.m_host_sizing= 0;
param.m_user_sizing= 0;
param.m_account_sizing= 0;
param.m_stage_class_sizing= 0;
param.m_events_stages_history_sizing= 0;
param.m_events_stages_history_long_sizing= 0;
param.m_statement_class_sizing= 0;
param.m_events_statements_history_sizing= 0;
param.m_events_statements_history_long_sizing= 0;
param.m_events_transactions_history_sizing= 0;
param.m_events_transactions_history_long_sizing= 0;
param.m_digest_sizing= 0;
param.m_session_connect_attrs_sizing= 0;
param.m_program_sizing= 0;
param.m_prepared_stmt_sizing= 0;
param.m_statement_stack_sizing= 0;
param.m_memory_class_sizing= 1;
param.m_metadata_lock_sizing= 0;
init_event_name_sizing(& param);
rc= init_instruments(& param);
ok(rc == 0, "instances init");
dummy_mutex_class.m_event_name_index= 0;
dummy_mutex_class.m_flags= 0;
dummy_mutex_class.m_enabled= true;
dummy_mutex_class.m_volatility = PSI_VOLATILITY_UNKNOWN;
dummy_rwlock_class.m_event_name_index= 1;
dummy_rwlock_class.m_flags= 0;
dummy_rwlock_class.m_enabled= true;
dummy_rwlock_class.m_volatility = PSI_VOLATILITY_UNKNOWN;
dummy_cond_class.m_event_name_index= 2;
dummy_cond_class.m_flags= 0;
dummy_cond_class.m_enabled= true;
dummy_cond_class.m_volatility = PSI_VOLATILITY_UNKNOWN;
dummy_file_class.m_event_name_index= 3;
dummy_file_class.m_flags= 0;
dummy_file_class.m_enabled= true;
dummy_file_class.m_volatility = PSI_VOLATILITY_UNKNOWN;
dummy_socket_class.m_event_name_index= 4;
dummy_socket_class.m_flags= 0;
dummy_socket_class.m_enabled= true;
dummy_socket_class.m_volatility = PSI_VOLATILITY_UNKNOWN;
dummy_table_share.m_enabled= true;
dummy_table_share.m_timed= true;
mutex_1= create_mutex(& dummy_mutex_class, NULL);
ok(mutex_1 != NULL, "mutex");
ok(global_mutex_container.get_lost_counter() == 0, "not lost");
mutex_2= create_mutex(& dummy_mutex_class, NULL);
ok(mutex_2 != NULL, "mutex");
ok(global_mutex_container.get_lost_counter() == 0, "not lost");
mutex_2= create_mutex(& dummy_mutex_class, NULL);
ok(mutex_2 == NULL, "no mutex");
ok(global_mutex_container.get_lost_counter() == 1, "lost 1");
destroy_mutex(mutex_1);
mutex_2= create_mutex(& dummy_mutex_class, NULL);
ok(mutex_2 != NULL, "mutex");
ok(global_mutex_container.get_lost_counter() == 1, "no new loss");
rwlock_1= create_rwlock(& dummy_rwlock_class, NULL);
ok(rwlock_1 != NULL, "rwlock");
ok(global_rwlock_container.m_lost == 0, "not lost");
rwlock_2= create_rwlock(& dummy_rwlock_class, NULL);
ok(rwlock_2 != NULL, "rwlock");
ok(global_rwlock_container.m_lost == 0, "not lost");
rwlock_2= create_rwlock(& dummy_rwlock_class, NULL);
ok(rwlock_2 == NULL, "no rwlock");
ok(global_rwlock_container.m_lost == 1, "lost 1");
destroy_rwlock(rwlock_1);
rwlock_2= create_rwlock(& dummy_rwlock_class, NULL);
ok(rwlock_2 != NULL, "rwlock");
ok(global_rwlock_container.m_lost == 1, "no new loss");
cond_1= create_cond(& dummy_cond_class, NULL);
ok(cond_1 != NULL, "cond");
ok(global_cond_container.m_lost == 0, "not lost");
cond_2= create_cond(& dummy_cond_class, NULL);
ok(cond_2 != NULL, "cond");
ok(global_cond_container.m_lost == 0, "not lost");
cond_2= create_cond(& dummy_cond_class, NULL);
ok(cond_2 == NULL, "no cond");
ok(global_cond_container.m_lost == 1, "lost 1");
destroy_cond(cond_1);
cond_2= create_cond(& dummy_cond_class, NULL);
ok(cond_2 != NULL, "cond");
ok(global_cond_container.m_lost == 1, "no new loss");
thread_1= create_thread(& dummy_thread_class, NULL, 0);
ok(thread_1 != NULL, "thread");
ok(global_thread_container.m_lost == 0, "not lost");
thread_2= create_thread(& dummy_thread_class, NULL, 0);
ok(thread_2 != NULL, "thread");
ok(global_thread_container.m_lost == 0, "not lost");
thread_2= create_thread(& dummy_thread_class, NULL, 0);
ok(thread_2 == NULL, "no thread");
ok(global_thread_container.m_lost == 1, "lost 1");
destroy_thread(thread_1);
thread_2= create_thread(& dummy_thread_class, NULL, 0);
ok(thread_2 != NULL, "thread");
ok(global_thread_container.m_lost == 1, "no new loss");
PFS_thread fake_thread;
fake_thread.m_filename_hash_pins= NULL;
file_1= find_or_create_file(& fake_thread, & dummy_file_class, "dummy", 5, true);
ok(file_1 == NULL, "no file");
ok(global_file_container.m_lost == 1, "lost 1");
file_1= find_or_create_file(& fake_thread, & dummy_file_class, "dummy", 5, true);
ok(file_1 == NULL, "no file");
ok(global_file_container.m_lost == 2, "lost 2");
init_file_hash(& param);
global_file_container.m_lost= 0;
file_1= find_or_create_file(& fake_thread, & dummy_file_class, "dummy_A", 7, true);
ok(file_1 != NULL, "file");
ok(file_1->m_file_stat.m_open_count == 1, "open count 1");
ok(global_file_container.m_lost == 0, "not lost");
file_2= find_or_create_file(& fake_thread, & dummy_file_class, "dummy_A", 7, true);
ok(file_1 == file_2, "same file");
ok(file_1->m_file_stat.m_open_count == 2, "open count 2");
ok(global_file_container.m_lost == 0, "not lost");
release_file(file_2);
ok(file_1->m_file_stat.m_open_count == 1, "open count 1");
file_2= find_or_create_file(& fake_thread, & dummy_file_class, "dummy_B", 7, true);
ok(file_2 != NULL, "file");
ok(global_file_container.m_lost == 0, "not lost");
file_2= find_or_create_file(& fake_thread, & dummy_file_class, "dummy_C", 7, true);
ok(file_2 == NULL, "no file");
ok(global_file_container.m_lost == 1, "lost");
release_file(file_1);
/* the file still exists, not destroyed */
ok(file_1->m_file_stat.m_open_count == 0, "open count 0");
file_2= find_or_create_file(& fake_thread, & dummy_file_class, "dummy_D", 7, true);
ok(file_2 == NULL, "no file");
ok(global_file_container.m_lost == 2, "lost");
socket_1= create_socket(& dummy_socket_class, NULL, NULL, 0);
ok(socket_1 != NULL, "socket");
ok(global_socket_container.m_lost == 0, "not lost");
socket_2= create_socket(& dummy_socket_class, NULL, NULL, 0);
ok(socket_2 != NULL, "socket");
ok(global_socket_container.m_lost == 0, "not lost");
socket_2= create_socket(& dummy_socket_class, NULL, NULL, 0);
ok(socket_2 == NULL, "no socket");
ok(global_socket_container.m_lost == 1, "lost 1");
destroy_socket(socket_1);
socket_2= create_socket(& dummy_socket_class, NULL, NULL, 0);
ok(socket_2 != NULL, "socket");
ok(global_socket_container.m_lost == 1, "no new loss");
table_1= create_table(& dummy_table_share, & fake_thread, NULL);
ok(table_1 != NULL, "table");
ok(global_table_container.m_lost == 0, "not lost");
table_2= create_table(& dummy_table_share, & fake_thread, NULL);
ok(table_2 != NULL, "table");
ok(global_table_container.m_lost == 0, "not lost");
table_2= create_table(& dummy_table_share, & fake_thread, NULL);
ok(table_2 == NULL, "no table");
ok(global_table_container.m_lost == 1, "lost 1");
destroy_table(table_1);
table_2= create_table(& dummy_table_share, & fake_thread, NULL);
ok(table_2 != NULL, "table");
ok(global_table_container.m_lost == 1, "no new loss");
//TODO: test that cleanup works
reset_events_waits_by_instance();
reset_events_waits_by_thread();
cleanup_file_hash();
cleanup_instruments();
}
void do_all_tests()
{
flag_global_instrumentation= true;
flag_thread_instrumentation= true;
test_no_instruments();
test_no_instances();
test_with_instances();
}
int main(int argc, char **argv)
{
plan(103);
MY_INIT(argv[0]);
do_all_tests();
my_end(0);
return (exit_status());
}