diff options
Diffstat (limited to 'sql/wsrep_var.cc')
| -rw-r--r-- | sql/wsrep_var.cc | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/sql/wsrep_var.cc b/sql/wsrep_var.cc index ad1f4ec0eac..6ed4eafb059 100644 --- a/sql/wsrep_var.cc +++ b/sql/wsrep_var.cc @@ -35,8 +35,6 @@ const char* wsrep_node_address = 0; const char* wsrep_node_incoming_address = 0; const char* wsrep_start_position = 0; -static long wsrep_prev_slave_threads = wsrep_slave_threads; - int wsrep_init_vars() { wsrep_provider = my_strdup(WSREP_NONE, MYF(MY_WME)); @@ -539,8 +537,8 @@ void wsrep_node_address_init (const char* value) static void wsrep_slave_count_change_update () { - wsrep_slave_count_change += (wsrep_slave_threads - wsrep_prev_slave_threads); - wsrep_prev_slave_threads = wsrep_slave_threads; + //wsrep running threads = applier thread + 1 rollback thread + wsrep_slave_count_change = (wsrep_slave_threads - wsrep_running_threads + 1); } bool wsrep_slave_threads_update (sys_var *self, THD* thd, enum_var_type type) |