summaryrefslogtreecommitdiff
path: root/sql/slave.cc
diff options
context:
space:
mode:
authorSergey Vojtovich <svoj@mariadb.org>2020-04-15 18:35:48 +0400
committerSergey Vojtovich <svoj@mariadb.org>2020-04-15 18:36:07 +0400
commit5876ed9e5b573596d449edfafc1f99caf5fd03d0 (patch)
treee5f4c19b5ee2de3b6f9dd57bcdcc8914fcba4faf /sql/slave.cc
parentc1bdf62452139e9310d3234266802748ba4c74b8 (diff)
downloadmariadb-git-5876ed9e5b573596d449edfafc1f99caf5fd03d0.tar.gz
Relay_log_info::executed_entries to Atomic_counter
Diffstat (limited to 'sql/slave.cc')
-rw-r--r--sql/slave.cc4
1 files changed, 2 insertions, 2 deletions
diff --git a/sql/slave.cc b/sql/slave.cc
index 7fb68d2dfb5..be200ce52d8 100644
--- a/sql/slave.cc
+++ b/sql/slave.cc
@@ -3438,7 +3438,7 @@ static bool send_show_master_info_data(THD *thd, Master_info *mi, bool full,
{
protocol->store((uint32) mi->rli.retried_trans);
protocol->store((ulonglong) mi->rli.max_relay_log_size);
- protocol->store((uint32) mi->rli.executed_entries);
+ protocol->store(mi->rli.executed_entries);
protocol->store((uint32) mi->received_heartbeats);
protocol->store((double) mi->heartbeat_period, 3, &tmp);
protocol->store(gtid_pos->ptr(), gtid_pos->length(), &my_charset_bin);
@@ -4537,7 +4537,7 @@ static int exec_relay_log_event(THD* thd, Relay_log_info* rli,
}
}
- thread_safe_increment64(&rli->executed_entries);
+ rli->executed_entries++;
#ifdef WITH_WSREP
wsrep_after_statement(thd);
#endif /* WITH_WSREP */