summaryrefslogtreecommitdiff
path: root/sql/mdl.cc
diff options
context:
space:
mode:
authorJan Lindström <jan.lindstrom@mariadb.com>2020-08-17 08:57:13 +0300
committerJan Lindström <jan.lindstrom@mariadb.com>2020-08-24 15:00:50 +0300
commitf5a3b118df034a2412fa744ae132f1af09ba8111 (patch)
treebd09b40201ee887f0860846cc2cde3e222c968ff /sql/mdl.cc
parentf3160ee44f8f3ae4e5eeea768e289ec40253f35e (diff)
downloadmariadb-git-bb-10.2-MDEV-23483.tar.gz
MDEV-23483: Set Galera SST thd as system threadbb-10.2-MDEV-23483
Revert change to MDL and set SST donor thread as a system thread. Joiner thread was already a system thread.
Diffstat (limited to 'sql/mdl.cc')
-rw-r--r--sql/mdl.cc25
1 files changed, 8 insertions, 17 deletions
diff --git a/sql/mdl.cc b/sql/mdl.cc
index 14a1f17fe86..9eeb82eeffd 100644
--- a/sql/mdl.cc
+++ b/sql/mdl.cc
@@ -25,7 +25,6 @@
#include <mysql/psi/mysql_stage.h>
#include "wsrep_mysqld.h"
#include "wsrep_thd.h"
-#include "wsrep_sst.h"
#ifdef HAVE_PSI_INTERFACE
static PSI_mutex_key key_MDL_wait_LOCK_wait_status;
@@ -2138,26 +2137,18 @@ MDL_context::acquire_lock(MDL_request *mdl_request, double lock_wait_timeout)
wait_status= m_wait.timed_wait(m_owner, &abs_shortwait, FALSE,
mdl_request->key.get_wait_state_name());
- THD* thd= m_owner->get_thd();
-
if (wait_status != MDL_wait::EMPTY)
break;
/* Check if the client is gone while we were waiting. */
- if (! thd_is_connected(thd))
+ if (! thd_is_connected(m_owner->get_thd()))
{
-#if defined(WITH_WSREP) && !defined(EMBEDDED_LIBRARY)
- // During SST client might not be connected
- if (!wsrep_is_sst_progress())
-#endif
- {
- /*
- * The client is disconnected. Don't wait forever:
- * assume it's the same as a wait timeout, this
- * ensures all error handling is correct.
- */
- wait_status= MDL_wait::TIMEOUT;
- break;
- }
+ /*
+ * The client is disconnected. Don't wait forever:
+ * assume it's the same as a wait timeout, this
+ * ensures all error handling is correct.
+ */
+ wait_status= MDL_wait::TIMEOUT;
+ break;
}
mysql_prlock_wrlock(&lock->m_rwlock);