summaryrefslogtreecommitdiff
path: root/sql
diff options
context:
space:
mode:
authorVladislav Vaintroub <wlad@mariadb.com>2022-09-07 16:39:30 +0200
committerVladislav Vaintroub <wlad@mariadb.com>2022-09-07 16:39:30 +0200
commit7d63f21693ab06f59be47385293064fe8fa1c02e (patch)
tree32d4fa6891544bdd3c6dede27dc46ec0c363f97d /sql
parentbacaf2d4f4c6d77a0b6c1ae4daddd19f81ef6fa3 (diff)
parent80cf7a4c43209a91ac6514ac3ea0dd0b592e17f0 (diff)
downloadmariadb-git-7d63f21693ab06f59be47385293064fe8fa1c02e.tar.gz
Merge branch '10.5' into 10.6
# Conflicts: # sql/sql_connect.cc # sql/threadpool_common.cc
Diffstat (limited to 'sql')
-rw-r--r--sql/sql_connect.cc14
-rw-r--r--sql/threadpool_common.cc8
2 files changed, 6 insertions, 16 deletions
diff --git a/sql/sql_connect.cc b/sql/sql_connect.cc
index 18db76e99cb..842e5cdb101 100644
--- a/sql/sql_connect.cc
+++ b/sql/sql_connect.cc
@@ -1108,6 +1108,12 @@ static int check_connection(THD *thd)
void setup_connection_thread_globals(THD *thd)
{
+ DBUG_EXECUTE_IF("CONNECT_wait", {
+ extern Dynamic_array<MYSQL_SOCKET> listen_sockets;
+ DBUG_ASSERT(listen_sockets.size());
+ while (listen_sockets.size())
+ my_sleep(1000);
+ });
thd->store_globals();
}
@@ -1359,14 +1365,6 @@ void do_handle_one_connection(CONNECT *connect, bool put_in_cache)
return;
}
- DBUG_EXECUTE_IF("CONNECT_wait",
- {
- extern Dynamic_array<MYSQL_SOCKET> listen_sockets;
- DBUG_ASSERT(listen_sockets.size());
- while (listen_sockets.size())
- my_sleep(1000);
- });
-
/*
If a thread was created to handle this connection:
increment slow_launch_threads counter if it took more than
diff --git a/sql/threadpool_common.cc b/sql/threadpool_common.cc
index 97c6c317cc4..965432357be 100644
--- a/sql/threadpool_common.cc
+++ b/sql/threadpool_common.cc
@@ -250,14 +250,6 @@ static THD *threadpool_add_connection(CONNECT *connect, TP_connection *c)
{
THD *thd= NULL;
- DBUG_EXECUTE_IF("CONNECT_wait",
- {
- extern Dynamic_array<MYSQL_SOCKET> listen_sockets;
- DBUG_ASSERT(listen_sockets.size());
- while (listen_sockets.size())
- my_sleep(1000);
- });
-
/*
Create a new connection context: mysys_thread_var and PSI thread
Store them in THD.