Commit 744e605d authored by Sergei Golubchik's avatar Sergei Golubchik

cleanup: wsrep helper to create a thread

parent 0fab28ce
...@@ -369,6 +369,14 @@ static void wsrep_replication_process(THD *thd) ...@@ -369,6 +369,14 @@ static void wsrep_replication_process(THD *thd)
DBUG_VOID_RETURN; DBUG_VOID_RETURN;
} }
static bool create_wsrep_THD(wsrep_thd_processor_fun processor)
{
pthread_t unused;
bool res= pthread_create(&unused, &connection_attrib, start_wsrep_THD,
(void*)processor);
return res;
}
void wsrep_create_appliers(long threads) void wsrep_create_appliers(long threads)
{ {
if (!wsrep_connected) if (!wsrep_connected)
...@@ -385,11 +393,8 @@ void wsrep_create_appliers(long threads) ...@@ -385,11 +393,8 @@ void wsrep_create_appliers(long threads)
} }
long wsrep_threads=0; long wsrep_threads=0;
pthread_t hThread;
while (wsrep_threads++ < threads) { while (wsrep_threads++ < threads) {
if (pthread_create( if (create_wsrep_THD(wsrep_replication_process))
&hThread, &connection_attrib,
start_wsrep_THD, (void*)wsrep_replication_process))
WSREP_WARN("Can't create thread to manage wsrep replication"); WSREP_WARN("Can't create thread to manage wsrep replication");
} }
} }
...@@ -476,10 +481,8 @@ void wsrep_create_rollbacker() ...@@ -476,10 +481,8 @@ void wsrep_create_rollbacker()
{ {
if (wsrep_provider && strcasecmp(wsrep_provider, "none")) if (wsrep_provider && strcasecmp(wsrep_provider, "none"))
{ {
pthread_t hThread;
/* create rollbacker */ /* create rollbacker */
if (pthread_create( &hThread, &connection_attrib, if (create_wsrep_THD(wsrep_rollback_process))
start_wsrep_THD, (void*)wsrep_rollback_process))
WSREP_WARN("Can't create thread to manage wsrep rollback"); WSREP_WARN("Can't create thread to manage wsrep rollback");
} }
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment