diff options
Diffstat (limited to 'sql/sql_parse.cc')
| -rw-r--r-- | sql/sql_parse.cc | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/sql/sql_parse.cc b/sql/sql_parse.cc index 81233c038a1..3f6fa8d24ad 100644 --- a/sql/sql_parse.cc +++ b/sql/sql_parse.cc @@ -929,7 +929,8 @@ bool do_command(THD *thd) pos = uint4korr(packet + 1); flags = uint2korr(packet + 5); pthread_mutex_lock(&LOCK_server_id); - kill_zombie_dump_threads(slave_server_id = uint4korr(packet+7)); + if ((slave_server_id = uint4korr(packet+7))) + kill_zombie_dump_threads(slave_server_id); thd->server_id = slave_server_id; pthread_mutex_unlock(&LOCK_server_id); mysql_binlog_send(thd, thd->strdup(packet + 11), pos, flags); |