diff options
Diffstat (limited to 'sql/wsrep_trans_observer.h')
| -rw-r--r-- | sql/wsrep_trans_observer.h | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/sql/wsrep_trans_observer.h b/sql/wsrep_trans_observer.h index 467b33ea206..e6901f15ca7 100644 --- a/sql/wsrep_trans_observer.h +++ b/sql/wsrep_trans_observer.h @@ -56,6 +56,13 @@ static inline bool wsrep_must_abort(THD* thd) } /* + Return true if the transaction must be replayed. + */ +static inline bool wsrep_must_replay(THD* thd) +{ + return (thd->wsrep_trx().state() == wsrep::transaction::s_must_replay); +} +/* Return true if transaction has not been committed. Note that we don't require thd->LOCK_thd_data here. Calling this method |