@@ -1231,7 +1231,7 @@ static inline int fill_mts_gaps_and_recover(Master_info* mi)
1231
1231
sql_print_information (" MTS recovery: starting coordinator thread to fill MTS "
1232
1232
" gaps." );
1233
1233
recovery_error= start_slave_thread (
1234
- #ifdef HAVE_PSI_INTERFACE
1234
+ #ifdef HAVE_PSI_THREAD_INTERFACE
1235
1235
key_thread_slave_sql,
1236
1236
#endif
1237
1237
handle_slave_sql, &rli->run_lock ,
@@ -1934,7 +1934,7 @@ terminate_slave_thread(THD *thd,
1934
1934
1935
1935
1936
1936
bool start_slave_thread (
1937
- #ifdef HAVE_PSI_INTERFACE
1937
+ #ifdef HAVE_PSI_THREAD_INTERFACE
1938
1938
PSI_thread_key thread_key,
1939
1939
#endif
1940
1940
my_start_routine h_func, mysql_mutex_t *start_lock,
@@ -2071,7 +2071,7 @@ bool start_slave_threads(bool need_lock_slave, bool wait_for_start,
2071
2071
2072
2072
if (thread_mask & SLAVE_IO)
2073
2073
is_error= start_slave_thread (
2074
- #ifdef HAVE_PSI_INTERFACE
2074
+ #ifdef HAVE_PSI_THREAD_INTERFACE
2075
2075
key_thread_slave_io,
2076
2076
#endif
2077
2077
handle_slave_io, lock_io, lock_cond_io,
@@ -2094,7 +2094,7 @@ bool start_slave_threads(bool need_lock_slave, bool wait_for_start,
2094
2094
}
2095
2095
if (!is_error)
2096
2096
is_error= start_slave_thread (
2097
- #ifdef HAVE_PSI_INTERFACE
2097
+ #ifdef HAVE_PSI_THREAD_INTERFACE
2098
2098
key_thread_slave_sql,
2099
2099
#endif
2100
2100
handle_slave_sql, lock_sql, lock_cond_sql,
@@ -4360,13 +4360,13 @@ static int init_slave_thread(THD* thd, SLAVE_THD_TYPE thd_type)
4360
4360
*/
4361
4361
thd->set_new_thread_id ();
4362
4362
4363
- #ifdef HAVE_PSI_INTERFACE
4363
+ #ifdef HAVE_PSI_THREAD_INTERFACE
4364
4364
/*
4365
4365
Populate the PROCESSLIST_ID in the instrumentation.
4366
4366
*/
4367
4367
struct PSI_thread *psi= PSI_THREAD_CALL (get_thread)();
4368
4368
PSI_THREAD_CALL (set_thread_id)(psi, thd->thread_id ());
4369
- #endif /* HAVE_PSI_INTERFACE */
4369
+ #endif /* HAVE_PSI_THREAD_INTERFACE */
4370
4370
4371
4371
DBUG_EXECUTE_IF (" simulate_io_slave_error_on_init" ,
4372
4372
simulate_error|= (1 << SLAVE_THD_IO););
@@ -5669,7 +5669,7 @@ extern "C" void *handle_slave_io(void *arg)
5669
5669
THD_CHECK_SENTRY (thd);
5670
5670
mi->info_thd = thd;
5671
5671
5672
- #ifdef HAVE_PSI_INTERFACE
5672
+ #ifdef HAVE_PSI_THREAD_INTERFACE
5673
5673
// save the instrumentation for IO thread in mi->info_thd
5674
5674
struct PSI_thread *psi= PSI_THREAD_CALL (get_thread)();
5675
5675
thd_set_psi (mi->info_thd , psi);
@@ -6263,7 +6263,7 @@ static void *handle_slave_worker(void *arg)
6263
6263
ulonglong purge_size= 0 ;
6264
6264
struct slave_job_item _item, *job_item= &_item;
6265
6265
Global_THD_manager *thd_manager= Global_THD_manager::get_instance ();
6266
- #ifdef HAVE_PSI_INTERFACE
6266
+ #ifdef HAVE_PSI_THREAD_INTERFACE
6267
6267
struct PSI_thread *psi;
6268
6268
#endif
6269
6269
Rpl_filter* rpl_filter;
@@ -6283,7 +6283,7 @@ static void *handle_slave_worker(void *arg)
6283
6283
mysql_mutex_unlock (&w->info_thd_lock );
6284
6284
thd->thread_stack = (char *)&thd;
6285
6285
6286
- #ifdef HAVE_PSI_INTERFACE
6286
+ #ifdef HAVE_PSI_THREAD_INTERFACE
6287
6287
// save the instrumentation for worker thread in w->info_thd
6288
6288
psi= PSI_THREAD_CALL (get_thread)();
6289
6289
thd_set_psi (w->info_thd , psi);
@@ -7313,7 +7313,7 @@ extern "C" void *handle_slave_sql(void *arg)
7313
7313
mysql_mutex_lock (&rli->info_thd_lock );
7314
7314
rli->info_thd = thd;
7315
7315
7316
- #ifdef HAVE_PSI_INTERFACE
7316
+ #ifdef HAVE_PSI_THREAD_INTERFACE
7317
7317
// save the instrumentation for SQL thread in rli->info_thd
7318
7318
struct PSI_thread *psi= PSI_THREAD_CALL (get_thread)();
7319
7319
thd_set_psi (rli->info_thd , psi);
0 commit comments