Issue with wsrep_slave_threads

[Raghavendra D Prabhu]

set global wsrep_slave_threads=12;
set global wsrep_slave_threads=1;
set global wsrep_slave_threads=12;

causes total number of threads to 24. This is because there is no condition checking for this.

=== modified file 'sql/wsrep_applier.cc'
--- sql/wsrep_applier.cc 2013-11-10 11:09:20 +0000
+++ sql/wsrep_applier.cc 2014-03-10 23:19:08 +0000
@@ -325,6 +325,7 @@
     if (wsrep_slave_count_change < 0)
     {
       wsrep_slave_count_change++;
+ WSREP_DEBUG("Closing applier thread, to close %d", abs(wsrep_slave_count_change));
       *exit = true;
     }
     mysql_mutex_unlock(&LOCK_wsrep_slave_threads);

=== modified file 'sql/wsrep_var.cc'
--- sql/wsrep_var.cc 2014-02-27 11:31:26 +0000
+++ sql/wsrep_var.cc 2014-03-10 23:22:30 +0000
@@ -475,17 +475,22 @@

 bool wsrep_slave_threads_check (sys_var *self, THD* thd, set_var* var)
 {
+ if (wsrep_slave_count_change != 0) {
+ WSREP_DEBUG("Still closing existing threads - %d", abs(wsrep_slave_count_change));
+ return true;
+ }
   mysql_mutex_lock(&LOCK_wsrep_slave_threads);
   wsrep_slave_count_change = var->value->val_int() - wsrep_slave_threads;
   mysql_mutex_unlock(&LOCK_wsrep_slave_threads);

- return 0;
+ return false;
 }

 bool wsrep_slave_threads_update (sys_var *self, THD* thd, enum_var_type type)
 {
   if (wsrep_slave_count_change > 0)
   {
+ WSREP_DEBUG("Creating %d applier threads, total %ld", wsrep_slave_count_change, wsrep_slave_threads);
     wsrep_create_appliers(wsrep_slave_count_change);
     wsrep_slave_count_change = 0;
   }

[Shahriyar Rzayev (rzayev-sehriyar)]

Percona now uses JIRA for bug reports so this bug report is migrated to: https://jira.percona.com/browse/PXC-1646