Commit b2029c03 authored by Sujatha's avatar Sujatha

Merge branch '10.3' into 10.4

parents 972dc6ee bafb011a
...@@ -720,7 +720,7 @@ class MYSQL_BIN_LOG: public TC_LOG, private MYSQL_LOG ...@@ -720,7 +720,7 @@ class MYSQL_BIN_LOG: public TC_LOG, private MYSQL_LOG
{ {
bytes_written = 0; bytes_written = 0;
} }
void harvest_bytes_written(ulonglong* counter) void harvest_bytes_written(Atomic_counter<uint64> *counter)
{ {
#ifndef DBUG_OFF #ifndef DBUG_OFF
char buf1[22],buf2[22]; char buf1[22],buf2[22];
......
...@@ -459,7 +459,7 @@ static inline int add_relay_log(Relay_log_info* rli,LOG_INFO* linfo) ...@@ -459,7 +459,7 @@ static inline int add_relay_log(Relay_log_info* rli,LOG_INFO* linfo)
DBUG_RETURN(1); DBUG_RETURN(1);
} }
rli->log_space_total += s.st_size; rli->log_space_total += s.st_size;
DBUG_PRINT("info",("log_space_total: %llu", rli->log_space_total)); DBUG_PRINT("info",("log_space_total: %llu", uint64(rli->log_space_total)));
DBUG_RETURN(0); DBUG_RETURN(0);
} }
...@@ -1252,7 +1252,7 @@ int purge_relay_logs(Relay_log_info* rli, THD *thd, bool just_reset, ...@@ -1252,7 +1252,7 @@ int purge_relay_logs(Relay_log_info* rli, THD *thd, bool just_reset,
mysql_mutex_unlock(rli->relay_log.get_log_lock()); mysql_mutex_unlock(rli->relay_log.get_log_lock());
} }
err: err:
DBUG_PRINT("info",("log_space_total: %llu",rli->log_space_total)); DBUG_PRINT("info",("log_space_total: %llu", uint64(rli->log_space_total)));
mysql_mutex_unlock(&rli->data_lock); mysql_mutex_unlock(&rli->data_lock);
DBUG_RETURN(error); DBUG_RETURN(error);
} }
......
...@@ -240,7 +240,8 @@ class Relay_log_info : public Slave_reporting_capability ...@@ -240,7 +240,8 @@ class Relay_log_info : public Slave_reporting_capability
threads, the SQL thread sets it to unblock the I/O thread and make it threads, the SQL thread sets it to unblock the I/O thread and make it
temporarily forget about the constraint. temporarily forget about the constraint.
*/ */
ulonglong log_space_limit,log_space_total; ulonglong log_space_limit;
Atomic_counter<uint64> log_space_total;
bool ignore_log_space_limit; bool ignore_log_space_limit;
/* /*
......
...@@ -2781,7 +2781,7 @@ static bool wait_for_relay_log_space(Relay_log_info* rli) ...@@ -2781,7 +2781,7 @@ static bool wait_for_relay_log_space(Relay_log_info* rli)
DBUG_PRINT("info", ("log_space_limit=%llu log_space_total=%llu " DBUG_PRINT("info", ("log_space_limit=%llu log_space_total=%llu "
"ignore_log_space_limit=%d " "ignore_log_space_limit=%d "
"sql_force_rotate_relay=%d", "sql_force_rotate_relay=%d",
rli->log_space_limit, rli->log_space_total, rli->log_space_limit, uint64(rli->log_space_total),
(int) rli->ignore_log_space_limit, (int) rli->ignore_log_space_limit,
(int) rli->sql_force_rotate_relay)); (int) rli->sql_force_rotate_relay));
} }
...@@ -5039,7 +5039,7 @@ Stopping slave I/O thread due to out-of-memory error from master"); ...@@ -5039,7 +5039,7 @@ Stopping slave I/O thread due to out-of-memory error from master");
{ {
DBUG_PRINT("info", ("log_space_limit=%llu log_space_total=%llu " DBUG_PRINT("info", ("log_space_limit=%llu log_space_total=%llu "
"ignore_log_space_limit=%d", "ignore_log_space_limit=%d",
rli->log_space_limit, rli->log_space_total, rli->log_space_limit, uint64(rli->log_space_total),
(int) rli->ignore_log_space_limit)); (int) rli->ignore_log_space_limit));
} }
#endif #endif
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment