diff options
Diffstat (limited to 'sql/rpl_parallel.cc')
| -rw-r--r-- | sql/rpl_parallel.cc | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/sql/rpl_parallel.cc b/sql/rpl_parallel.cc index 144b12a9fdf..dc5e3ff1fbf 100644 --- a/sql/rpl_parallel.cc +++ b/sql/rpl_parallel.cc @@ -1023,7 +1023,7 @@ handle_rpl_parallel_thread(void *arg) my_thread_init(); thd = new THD(next_thread_id()); thd->thread_stack = (char*)&thd; - add_to_active_threads(thd); + server_threads.insert(thd); set_current_thd(thd); pthread_detach_this_thread(); thd->init_for_queries(); @@ -1432,7 +1432,7 @@ handle_rpl_parallel_thread(void *arg) thd->temporary_tables= 0; THD_CHECK_SENTRY(thd); - unlink_not_visible_thd(thd); + server_threads.erase(thd); delete thd; mysql_mutex_lock(&rpt->LOCK_rpl_thread); |