|
|
@ -1762,13 +1762,11 @@ pthread_handler_t start_wsrep_THD(void *arg) |
|
|
THD *thd; |
|
|
THD *thd; |
|
|
wsrep_thd_processor_fun processor= (wsrep_thd_processor_fun)arg; |
|
|
wsrep_thd_processor_fun processor= (wsrep_thd_processor_fun)arg; |
|
|
|
|
|
|
|
|
if (my_thread_init() || (!(thd= new THD(true)))) |
|
|
|
|
|
|
|
|
if (my_thread_init() || (!(thd= new THD(next_thread_id(), true)))) |
|
|
{ |
|
|
{ |
|
|
goto error; |
|
|
goto error; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
thd->thread_id= next_thread_id(); |
|
|
|
|
|
|
|
|
|
|
|
mysql_mutex_lock(&LOCK_thread_count); |
|
|
mysql_mutex_lock(&LOCK_thread_count); |
|
|
|
|
|
|
|
|
if (wsrep_gtid_mode) |
|
|
if (wsrep_gtid_mode) |
|
|
|