From 3f449c6318bdafebe1834231f21ab286149df617 Mon Sep 17 00:00:00 2001 From: Daniele Sciascia Date: Tue, 27 Oct 2020 09:40:42 +0100 Subject: [PATCH] Remove calls to client_service::will_replay() Method client_service::will_replay() is now called whenever the transaction state changes to s_must_replay, in transaction::state(). --- src/transaction.cpp | 7 ------- 1 file changed, 7 deletions(-) diff --git a/src/transaction.cpp b/src/transaction.cpp index 7f9b2ca..d02f5f2 100644 --- a/src/transaction.cpp +++ b/src/transaction.cpp @@ -422,7 +422,6 @@ int wsrep::transaction::after_prepare( if (state() == s_must_abort) { assert(client_state_.mode() == wsrep::client_state::m_local); - client_service_.will_replay(); state(lock, s_must_replay); ret = 1; } @@ -470,7 +469,6 @@ int wsrep::transaction::before_commit() if (certified() || (is_xa() && is_streaming())) { - client_service_.will_replay(); state(lock, s_must_replay); } else @@ -509,7 +507,6 @@ int wsrep::transaction::before_commit() case wsrep::provider::success: break; case wsrep::provider::error_bf_abort: - client_service_.will_replay(); if (state() != s_must_abort) { state(lock, s_must_abort); @@ -695,7 +692,6 @@ int wsrep::transaction::before_rollback() case s_must_abort: if (certified()) { - client_service_.will_replay(); state(lock, s_must_replay); } else @@ -1023,7 +1019,6 @@ bool wsrep::transaction::bf_abort( // rollbacker gets control. if (is_xa() && state_at_enter == s_prepared) { - client_service_.will_replay(); state(lock, s_must_replay); client_state_.set_rollbacker_active(true); } @@ -1642,7 +1637,6 @@ int wsrep::transaction::certify_commit( { if (is_xa() && state() == s_must_abort) { - client_service_.will_replay(); state(lock, s_must_replay); } return 1; @@ -1768,7 +1762,6 @@ int wsrep::transaction::certify_commit( { if (is_xa()) { - client_service_.will_replay(); state(lock, s_must_replay); } client_state_.override_error(wsrep::e_deadlock_error);