Commit aeb8eae5 authored by Marko Mäkelä's avatar Marko Mäkelä

Merge 10.4 into 10.5

parents 0d88365b 02878f12
...@@ -35,6 +35,7 @@ SET TRANSACTION ISOLATION LEVEL READ UNCOMMITTED; ...@@ -35,6 +35,7 @@ SET TRANSACTION ISOLATION LEVEL READ UNCOMMITTED;
SELECT * FROM t; SELECT * FROM t;
a a
3 3
SET GLOBAL innodb_max_purge_lag_wait=0;
# restart # restart
SELECT * FROM t; SELECT * FROM t;
a a
......
...@@ -37,6 +37,7 @@ UPDATE t SET a=3 WHERE a=1; ...@@ -37,6 +37,7 @@ UPDATE t SET a=3 WHERE a=1;
SELECT * FROM t; SELECT * FROM t;
SET TRANSACTION ISOLATION LEVEL READ UNCOMMITTED; SET TRANSACTION ISOLATION LEVEL READ UNCOMMITTED;
SELECT * FROM t; SELECT * FROM t;
SET GLOBAL innodb_max_purge_lag_wait=0;
--let $restart_parameters= --let $restart_parameters=
--source include/restart_mysqld.inc --source include/restart_mysqld.inc
SELECT * FROM t; SELECT * FROM t;
......
...@@ -223,6 +223,8 @@ static uint innodb_max_purge_lag_wait; ...@@ -223,6 +223,8 @@ static uint innodb_max_purge_lag_wait;
static void innodb_max_purge_lag_wait_update(THD *thd, st_mysql_sys_var *, static void innodb_max_purge_lag_wait_update(THD *thd, st_mysql_sys_var *,
void *, const void *limit) void *, const void *limit)
{ {
if (high_level_read_only)
return;
const uint l= *static_cast<const uint*>(limit); const uint l= *static_cast<const uint*>(limit);
if (trx_sys.rseg_history_len <= l) if (trx_sys.rseg_history_len <= l)
return; return;
......
...@@ -1348,8 +1348,6 @@ static tpool::timer *purge_coordinator_timer; ...@@ -1348,8 +1348,6 @@ static tpool::timer *purge_coordinator_timer;
/** Wake up the purge threads if there is work to do. */ /** Wake up the purge threads if there is work to do. */
void srv_wake_purge_thread_if_not_active() void srv_wake_purge_thread_if_not_active()
{ {
ut_ad(!srv_read_only_mode);
if (purge_sys.enabled() && !purge_sys.paused() && if (purge_sys.enabled() && !purge_sys.paused() &&
(srv_undo_log_truncate || trx_sys.rseg_history_len) && (srv_undo_log_truncate || trx_sys.rseg_history_len) &&
++purge_state.m_running == 1) ++purge_state.m_running == 1)
......
...@@ -1422,7 +1422,6 @@ inline void trx_t::commit_in_memory(const mtr_t *mtr) ...@@ -1422,7 +1422,6 @@ inline void trx_t::commit_in_memory(const mtr_t *mtr)
trx_mutex_exit(this); trx_mutex_exit(this);
ut_a(error_state == DB_SUCCESS); ut_a(error_state == DB_SUCCESS);
if (!srv_read_only_mode)
srv_wake_purge_thread_if_not_active(); srv_wake_purge_thread_if_not_active();
} }
......
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