Home
last modified time | relevance | path

Searched refs:victim_thd (Results 1 – 25 of 54) sorted by relevance

123

/dports/databases/mariadb104-server/mariadb-10.4.24/sql/
H A Dservice_wsrep.cc190 DBUG_ASSERT(victim_thd); in wsrep_handle_SR_rollback()
194 wsrep_thd_LOCK(victim_thd); in wsrep_handle_SR_rollback()
197 victim_thd->thread_id, in wsrep_handle_SR_rollback()
204 if (!(bf_thd && bf_thd != victim_thd)) in wsrep_handle_SR_rollback()
210 wsrep_bf_abort(bf_thd, victim_thd); in wsrep_handle_SR_rollback()
214 wsrep_thd_self_abort(victim_thd); in wsrep_handle_SR_rollback()
217 wsrep_thd_UNLOCK(victim_thd); in wsrep_handle_SR_rollback()
252 if (victim_thd->wsrep_aborter && victim_thd->wsrep_aborter != bf_thd->thread_id) in wsrep_thd_bf_abort()
256 wsrep_thd_UNLOCK(victim_thd); in wsrep_thd_bf_abort()
266 wsrep_thd_UNLOCK(victim_thd); in wsrep_thd_bf_abort()
[all …]
H A Dwsrep_thd.cc314 THD *victim_thd= (THD *) victim_thd_ptr; in wsrep_abort_thd() local
326 victim_thd && in wsrep_abort_thd()
327 !wsrep_thd_is_aborting(victim_thd)) in wsrep_abort_thd()
336 wsrep_thd_UNLOCK(victim_thd); in wsrep_abort_thd()
342 bool wsrep_bf_abort(THD* bf_thd, THD* victim_thd) in wsrep_bf_abort() argument
345 WSREP_LOG_THD(victim_thd, "victim before"); in wsrep_bf_abort()
360 if (WSREP(victim_thd) && !victim_thd->wsrep_trx().active()) in wsrep_bf_abort()
363 switch (victim_thd->wsrep_trx().state()) in wsrep_bf_abort()
377 wsrep_start_transaction(victim_thd, victim_thd->wsrep_next_trx_id()); in wsrep_bf_abort()
398 wsrep_thd_UNLOCK(victim_thd); in wsrep_bf_abort()
[all …]
H A Dwsrep_mysqld.h271 #define WSREP_LOG_CONFLICT(bf_thd, victim_thd, bf_abort) \ argument
278 if (victim_thd) WSREP_LOG_CONFLICT_THD(victim_thd, "Victim thread"); \
H A Dwsrep_thd.h90 bool wsrep_bf_abort(THD* bf_thd, THD* victim_thd);
/dports/databases/mariadb105-client/mariadb-10.5.15/sql/
H A Dservice_wsrep.cc189 DBUG_ASSERT(victim_thd); in wsrep_handle_SR_rollback()
193 wsrep_thd_LOCK(victim_thd); in wsrep_handle_SR_rollback()
196 victim_thd->thread_id, in wsrep_handle_SR_rollback()
203 if (!(bf_thd && bf_thd != victim_thd)) in wsrep_handle_SR_rollback()
209 wsrep_bf_abort(bf_thd, victim_thd); in wsrep_handle_SR_rollback()
213 wsrep_thd_self_abort(victim_thd); in wsrep_handle_SR_rollback()
216 wsrep_thd_UNLOCK(victim_thd); in wsrep_handle_SR_rollback()
251 if (victim_thd->wsrep_aborter && victim_thd->wsrep_aborter != bf_thd->thread_id) in wsrep_thd_bf_abort()
255 wsrep_thd_UNLOCK(victim_thd); in wsrep_thd_bf_abort()
265 wsrep_thd_UNLOCK(victim_thd); in wsrep_thd_bf_abort()
[all …]
H A Dwsrep_thd.cc314 THD *victim_thd= (THD *) victim_thd_ptr; in wsrep_abort_thd() local
326 victim_thd && in wsrep_abort_thd()
327 !wsrep_thd_is_aborting(victim_thd)) in wsrep_abort_thd()
336 wsrep_thd_UNLOCK(victim_thd); in wsrep_abort_thd()
342 bool wsrep_bf_abort(THD* bf_thd, THD* victim_thd) in wsrep_bf_abort() argument
345 WSREP_LOG_THD(victim_thd, "victim before"); in wsrep_bf_abort()
360 if (WSREP(victim_thd) && !victim_thd->wsrep_trx().active()) in wsrep_bf_abort()
363 switch (victim_thd->wsrep_trx().state()) in wsrep_bf_abort()
377 wsrep_start_transaction(victim_thd, victim_thd->wsrep_next_trx_id()); in wsrep_bf_abort()
398 wsrep_thd_UNLOCK(victim_thd); in wsrep_bf_abort()
[all …]
H A Dwsrep_mysqld.h276 #define WSREP_LOG_CONFLICT(bf_thd, victim_thd, bf_abort) \ argument
283 if (victim_thd) WSREP_LOG_CONFLICT_THD(victim_thd, "Victim thread"); \
/dports/databases/mariadb104-client/mariadb-10.4.24/sql/
H A Dservice_wsrep.cc190 DBUG_ASSERT(victim_thd);
194 wsrep_thd_LOCK(victim_thd);
197 victim_thd->thread_id,
204 if (!(bf_thd && bf_thd != victim_thd)) in slave_reply()
210 wsrep_bf_abort(bf_thd, victim_thd);
214 wsrep_thd_self_abort(victim_thd);
217 wsrep_thd_UNLOCK(victim_thd);
252 if (victim_thd->wsrep_aborter && victim_thd->wsrep_aborter != bf_thd->thread_id)
256 wsrep_thd_UNLOCK(victim_thd);
266 wsrep_thd_UNLOCK(victim_thd);
[all …]
H A Dwsrep_thd.cc314 THD *victim_thd= (THD *) victim_thd_ptr; in wsrep_abort_thd() local
326 victim_thd && in wsrep_abort_thd()
327 !wsrep_thd_is_aborting(victim_thd)) in wsrep_abort_thd()
336 wsrep_thd_UNLOCK(victim_thd); in wsrep_abort_thd()
342 bool wsrep_bf_abort(THD* bf_thd, THD* victim_thd) in wsrep_bf_abort() argument
345 WSREP_LOG_THD(victim_thd, "victim before"); in wsrep_bf_abort()
360 if (WSREP(victim_thd) && !victim_thd->wsrep_trx().active()) in wsrep_bf_abort()
363 switch (victim_thd->wsrep_trx().state()) in wsrep_bf_abort()
377 wsrep_start_transaction(victim_thd, victim_thd->wsrep_next_trx_id()); in wsrep_bf_abort()
398 wsrep_thd_UNLOCK(victim_thd); in wsrep_bf_abort()
[all …]
H A Dwsrep_mysqld.h271 #define WSREP_LOG_CONFLICT(bf_thd, victim_thd, bf_abort) \ argument
278 if (victim_thd) WSREP_LOG_CONFLICT_THD(victim_thd, "Victim thread"); \
/dports/databases/mariadb105-server/mariadb-10.5.15/sql/
H A Dservice_wsrep.cc189 DBUG_ASSERT(victim_thd); in wsrep_handle_SR_rollback()
193 wsrep_thd_LOCK(victim_thd); in wsrep_handle_SR_rollback()
196 victim_thd->thread_id, in wsrep_handle_SR_rollback()
203 if (!(bf_thd && bf_thd != victim_thd)) in wsrep_handle_SR_rollback()
209 wsrep_bf_abort(bf_thd, victim_thd); in wsrep_handle_SR_rollback()
213 wsrep_thd_self_abort(victim_thd); in wsrep_handle_SR_rollback()
216 wsrep_thd_UNLOCK(victim_thd); in wsrep_handle_SR_rollback()
251 if (victim_thd->wsrep_aborter && victim_thd->wsrep_aborter != bf_thd->thread_id) in wsrep_thd_bf_abort()
255 wsrep_thd_UNLOCK(victim_thd); in wsrep_thd_bf_abort()
265 wsrep_thd_UNLOCK(victim_thd); in wsrep_thd_bf_abort()
[all …]
H A Dwsrep_thd.cc314 THD *victim_thd= (THD *) victim_thd_ptr; in wsrep_abort_thd() local
326 victim_thd && in wsrep_abort_thd()
327 !wsrep_thd_is_aborting(victim_thd)) in wsrep_abort_thd()
336 wsrep_thd_UNLOCK(victim_thd); in wsrep_abort_thd()
342 bool wsrep_bf_abort(THD* bf_thd, THD* victim_thd) in wsrep_bf_abort() argument
345 WSREP_LOG_THD(victim_thd, "victim before"); in wsrep_bf_abort()
360 if (WSREP(victim_thd) && !victim_thd->wsrep_trx().active()) in wsrep_bf_abort()
363 switch (victim_thd->wsrep_trx().state()) in wsrep_bf_abort()
377 wsrep_start_transaction(victim_thd, victim_thd->wsrep_next_trx_id()); in wsrep_bf_abort()
398 wsrep_thd_UNLOCK(victim_thd); in wsrep_bf_abort()
[all …]
H A Dwsrep_mysqld.h276 #define WSREP_LOG_CONFLICT(bf_thd, victim_thd, bf_abort) \ argument
283 if (victim_thd) WSREP_LOG_CONFLICT_THD(victim_thd, "Victim thread"); \
/dports/databases/mariadb103-server/mariadb-10.3.34/sql/
H A Dwsrep_thd.cc805 THD *victim_thd= (THD *) victim_thd_ptr; in wsrep_abort_thd() local
809 mysql_mutex_assert_owner(&victim_thd->LOCK_thd_data); in wsrep_abort_thd()
810 mysql_mutex_assert_owner(&victim_thd->LOCK_thd_kill); in wsrep_abort_thd()
815 victim_thd) in wsrep_abort_thd()
817 if ((victim_thd->wsrep_conflict_state == MUST_ABORT) || in wsrep_abort_thd()
818 (victim_thd->wsrep_conflict_state == ABORTED) || in wsrep_abort_thd()
819 (victim_thd->wsrep_conflict_state == ABORTING)) in wsrep_abort_thd()
824 (long long)victim_thd->real_id); in wsrep_abort_thd()
825 wsrep_thd_UNLOCK(victim_thd); in wsrep_abort_thd()
831 ha_abort_transaction(bf_thd, victim_thd, signal); in wsrep_abort_thd()
[all …]
H A Dwsrep_mysqld.h213 #define WSREP_LOG_CONFLICT(bf_thd, victim_thd, bf_abort) \ argument
220 if (victim_thd) WSREP_LOG_CONFLICT_THD(victim_thd, "Victim thread"); \
/dports/databases/mariadb103-client/mariadb-10.3.34/sql/
H A Dwsrep_thd.cc805 THD *victim_thd= (THD *) victim_thd_ptr; in wsrep_abort_thd() local
809 mysql_mutex_assert_owner(&victim_thd->LOCK_thd_data); in wsrep_abort_thd()
810 mysql_mutex_assert_owner(&victim_thd->LOCK_thd_kill); in wsrep_abort_thd()
815 victim_thd) in wsrep_abort_thd()
817 if ((victim_thd->wsrep_conflict_state == MUST_ABORT) || in wsrep_abort_thd()
818 (victim_thd->wsrep_conflict_state == ABORTED) || in wsrep_abort_thd()
819 (victim_thd->wsrep_conflict_state == ABORTING)) in wsrep_abort_thd()
824 (long long)victim_thd->real_id); in wsrep_abort_thd()
825 wsrep_thd_UNLOCK(victim_thd); in wsrep_abort_thd()
831 ha_abort_transaction(bf_thd, victim_thd, signal); in wsrep_abort_thd()
[all …]
H A Dwsrep_mysqld.h213 #define WSREP_LOG_CONFLICT(bf_thd, victim_thd, bf_abort) \ argument
220 if (victim_thd) WSREP_LOG_CONFLICT_THD(victim_thd, "Victim thread"); \
/dports/databases/mariadb105-client/mariadb-10.5.15/include/mysql/
H A Dservice_wsrep.h77 MYSQL_THD victim_thd,
80 …id (*wsrep_handle_SR_rollback_func)(MYSQL_THD BF_thd, MYSQL_THD victim_thd);
196 extern "C" bool wsrep_thd_set_wsrep_aborter(MYSQL_THD bf_thd, MYSQL_THD victim_thd);
207 extern "C" void wsrep_handle_SR_rollback(MYSQL_THD BF_thd, MYSQL_THD victim_thd);
212 MYSQL_THD victim_thd,
240 extern "C" bool wsrep_thd_set_wsrep_aborter(MYSQL_THD bf_thd, MYSQL_THD victim_thd);
/dports/databases/mariadb104-server/mariadb-10.4.24/include/mysql/
H A Dservice_wsrep.h77 MYSQL_THD victim_thd,
80 …id (*wsrep_handle_SR_rollback_func)(MYSQL_THD BF_thd, MYSQL_THD victim_thd);
190 extern "C" bool wsrep_thd_set_wsrep_aborter(MYSQL_THD bf_thd, MYSQL_THD victim_thd);
201 extern "C" void wsrep_handle_SR_rollback(MYSQL_THD BF_thd, MYSQL_THD victim_thd);
206 MYSQL_THD victim_thd,
231 extern "C" bool wsrep_thd_set_wsrep_aborter(MYSQL_THD bf_thd, MYSQL_THD victim_thd);
/dports/databases/mariadb105-server/mariadb-10.5.15/include/mysql/
H A Dservice_wsrep.h77 MYSQL_THD victim_thd,
80 …id (*wsrep_handle_SR_rollback_func)(MYSQL_THD BF_thd, MYSQL_THD victim_thd);
196 extern "C" bool wsrep_thd_set_wsrep_aborter(MYSQL_THD bf_thd, MYSQL_THD victim_thd);
207 extern "C" void wsrep_handle_SR_rollback(MYSQL_THD BF_thd, MYSQL_THD victim_thd);
212 MYSQL_THD victim_thd,
240 extern "C" bool wsrep_thd_set_wsrep_aborter(MYSQL_THD bf_thd, MYSQL_THD victim_thd);
/dports/databases/mariadb104-client/mariadb-10.4.24/include/mysql/
H A Dservice_wsrep.h77 MYSQL_THD victim_thd,
80 …id (*wsrep_handle_SR_rollback_func)(MYSQL_THD BF_thd, MYSQL_THD victim_thd);
190 extern "C" bool wsrep_thd_set_wsrep_aborter(MYSQL_THD bf_thd, MYSQL_THD victim_thd);
201 extern "C" void wsrep_handle_SR_rollback(MYSQL_THD BF_thd, MYSQL_THD victim_thd);
206 MYSQL_THD victim_thd,
231 extern "C" bool wsrep_thd_set_wsrep_aborter(MYSQL_THD bf_thd, MYSQL_THD victim_thd);
/dports/databases/mysqlwsrep56-server/mysql-wsrep-wsrep_5.6.51-25.33/sql/
H A Dwsrep_thd.cc671 THD *victim_thd = (THD *) victim_thd_ptr; in wsrep_abort_thd() local
678 victim_thd) in wsrep_abort_thd()
681 (long long)bf_thd->real_id : 0, (long long)victim_thd->real_id); in wsrep_abort_thd()
682 ha_wsrep_abort_transaction(bf_thd, victim_thd, signal); in wsrep_abort_thd()
686 WSREP_DEBUG("wsrep_abort_thd not effective: %p %p", bf_thd, victim_thd); in wsrep_abort_thd()
H A Dwsrep_mysqld.h259 #define WSREP_LOG_CONFLICT(bf_thd, victim_thd, bf_abort) \ argument
266 if (victim_thd) WSREP_LOG_CONFLICT_THD(victim_thd, "Victim thread"); \
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/sql/
H A Dwsrep_thd.cc705 THD *victim_thd = (THD *) victim_thd_ptr; in wsrep_abort_thd() local
712 victim_thd) in wsrep_abort_thd()
715 (long long)bf_thd->real_id : 0, (long long)victim_thd->real_id); in wsrep_abort_thd()
716 ha_wsrep_abort_transaction(bf_thd, victim_thd, signal); in wsrep_abort_thd()
720 WSREP_DEBUG("wsrep_abort_thd not effective: %p %p", bf_thd, victim_thd); in wsrep_abort_thd()
H A Dwsrep_mysqld.h269 #define WSREP_LOG_CONFLICT(bf_thd, victim_thd, bf_abort) \ argument
276 if (victim_thd) WSREP_LOG_CONFLICT_THD(victim_thd, "Victim thread"); \

123