diff --git a/plugin/semisync/semisync_master.cc b/plugin/semisync/semisync_master.cc index 678d0f10e3c..74e299253e0 100644 --- a/plugin/semisync/semisync_master.cc +++ b/plugin/semisync/semisync_master.cc @@ -851,8 +851,8 @@ int ReplSemiSyncMaster::commitTrx(const char* trx_wait_binlog_name, * when replication has progressed far enough, we will release * these waiting threads. */ - if (abort_loop && (rpl_semi_sync_master_clients == - rpl_semi_sync_master_wait_for_slave_count - 1) && is_on()) + if (abort_loop && (rpl_semi_sync_master_clients < + rpl_semi_sync_master_wait_for_slave_count) && is_on()) { sql_print_warning("SEMISYNC: Forced shutdown. Some updates might " "not be replicated.");