/dports/databases/mariadb104-server/mariadb-10.4.24/sql/ |
H A D | service_wsrep.cc | 190 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 D | wsrep_thd.cc | 314 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 D | wsrep_mysqld.h | 271 #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 D | wsrep_thd.h | 90 bool wsrep_bf_abort(THD* bf_thd, THD* victim_thd);
|
/dports/databases/mariadb105-client/mariadb-10.5.15/sql/ |
H A D | service_wsrep.cc | 189 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 D | wsrep_thd.cc | 314 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 D | wsrep_mysqld.h | 276 #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 D | service_wsrep.cc | 190 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 D | wsrep_thd.cc | 314 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 D | wsrep_mysqld.h | 271 #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 D | service_wsrep.cc | 189 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 D | wsrep_thd.cc | 314 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 D | wsrep_mysqld.h | 276 #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 D | wsrep_thd.cc | 805 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 D | wsrep_mysqld.h | 213 #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 D | wsrep_thd.cc | 805 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 D | wsrep_mysqld.h | 213 #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 D | service_wsrep.h | 77 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 D | service_wsrep.h | 77 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 D | service_wsrep.h | 77 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 D | service_wsrep.h | 77 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 D | wsrep_thd.cc | 671 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 D | wsrep_mysqld.h | 259 #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 D | wsrep_thd.cc | 705 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 D | wsrep_mysqld.h | 269 #define WSREP_LOG_CONFLICT(bf_thd, victim_thd, bf_abort) \ argument 276 if (victim_thd) WSREP_LOG_CONFLICT_THD(victim_thd, "Victim thread"); \
|