summaryrefslogtreecommitdiff
path: root/sql/service_wsrep.cc
diff options
context:
space:
mode:
authorMarko Mäkelä <marko.makela@mariadb.com>2021-10-04 19:32:13 +0300
committerMarko Mäkelä <marko.makela@mariadb.com>2021-10-04 19:32:13 +0300
commitead38354e60e0fb241de8abe0ed6a57c14dfb820 (patch)
tree308df72d136757f18f747deea29f5cbb5c161541 /sql/service_wsrep.cc
parentf3bd2780632288bec8e8462404df0fea356afd7d (diff)
parent097b7b8c9e7f5900842a329286882f55aa42f27e (diff)
downloadmariadb-git-ead38354e60e0fb241de8abe0ed6a57c14dfb820.tar.gz
Merge 10.4 into 10.5
Diffstat (limited to 'sql/service_wsrep.cc')
-rw-r--r--sql/service_wsrep.cc11
1 files changed, 5 insertions, 6 deletions
diff --git a/sql/service_wsrep.cc b/sql/service_wsrep.cc
index 91b1a48cad7..67735972400 100644
--- a/sql/service_wsrep.cc
+++ b/sql/service_wsrep.cc
@@ -268,12 +268,11 @@ extern "C" my_bool wsrep_thd_order_before(const THD *left, const THD *right)
extern "C" my_bool wsrep_thd_is_aborting(const MYSQL_THD thd)
{
mysql_mutex_assert_owner(&thd->LOCK_thd_data);
- if (thd != 0)
+
+ const wsrep::client_state& cs(thd->wsrep_cs());
+ const enum wsrep::transaction::state tx_state(cs.transaction().state());
+ switch (tx_state)
{
- const wsrep::client_state& cs(thd->wsrep_cs());
- const enum wsrep::transaction::state tx_state(cs.transaction().state());
- switch (tx_state)
- {
case wsrep::transaction::s_must_abort:
return (cs.state() == wsrep::client_state::s_exec ||
cs.state() == wsrep::client_state::s_result);
@@ -282,8 +281,8 @@ extern "C" my_bool wsrep_thd_is_aborting(const MYSQL_THD thd)
return true;
default:
return false;
- }
}
+
return false;
}