diff options
| author | Sujatha <sujatha.sivakumar@mariadb.com> | 2020-11-12 14:10:05 +0530 |
|---|---|---|
| committer | Sujatha <sujatha.sivakumar@mariadb.com> | 2020-11-12 14:10:05 +0530 |
| commit | bafb011a82c0a6437515c37e37aef433d043f592 (patch) | |
| tree | f92b3549ab24142a55f0c48a07326b6da290502b /sql/rpl_rli.cc | |
| parent | 150f447af1d9ffff168372505e5c9b4297bdd9d4 (diff) | |
| parent | 984a06db2ce2b2e3c7c5028245905417f2141cd7 (diff) | |
| download | mariadb-git-bafb011a82c0a6437515c37e37aef433d043f592.tar.gz | |
Merge branch '10.2' into 10.3
Diffstat (limited to 'sql/rpl_rli.cc')
| -rw-r--r-- | sql/rpl_rli.cc | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/sql/rpl_rli.cc b/sql/rpl_rli.cc index fe699d4c920..7bc38d28961 100644 --- a/sql/rpl_rli.cc +++ b/sql/rpl_rli.cc @@ -458,7 +458,8 @@ static inline int add_relay_log(Relay_log_info* rli,LOG_INFO* linfo) linfo->log_file_name); DBUG_RETURN(1); } - rli->log_space_total += s.st_size; + my_atomic_add64_explicit((volatile int64*)(&rli->log_space_total), + s.st_size, MY_MEMORY_ORDER_RELAXED); DBUG_PRINT("info",("log_space_total: %llu", rli->log_space_total)); DBUG_RETURN(0); } @@ -468,7 +469,8 @@ static int count_relay_log_space(Relay_log_info* rli) { LOG_INFO linfo; DBUG_ENTER("count_relay_log_space"); - rli->log_space_total= 0; + my_atomic_store64_explicit((volatile int64*)(&rli->log_space_total), 0, + MY_MEMORY_ORDER_RELAXED); if (rli->relay_log.find_log_pos(&linfo, NullS, 1)) { sql_print_error("Could not find first log while counting relay log space"); @@ -1227,8 +1229,8 @@ int purge_relay_logs(Relay_log_info* rli, THD *thd, bool just_reset, strmake_buf(rli->group_relay_log_name, rli->relay_log.get_log_fname()); strmake_buf(rli->event_relay_log_name, rli->relay_log.get_log_fname()); rli->group_relay_log_pos= rli->event_relay_log_pos= BIN_LOG_HEADER_SIZE; - rli->log_space_total= 0; - + my_atomic_store64_explicit((volatile int64*)(&rli->log_space_total), 0, + MY_MEMORY_ORDER_RELAXED); if (count_relay_log_space(rli)) { *errmsg= "Error counting relay log space"; |