/dports/databases/mariadb104-server/mariadb-10.4.24/sql/ |
H A D | service_wsrep.cc | 187 extern "C" void wsrep_handle_SR_rollback(THD *bf_thd, in wsrep_handle_SR_rollback() argument 192 if (!victim_thd || !wsrep_on(bf_thd)) return; in wsrep_handle_SR_rollback() 204 if (!(bf_thd && bf_thd != victim_thd)) in wsrep_handle_SR_rollback() 208 if (bf_thd) in wsrep_handle_SR_rollback() 210 wsrep_bf_abort(bf_thd, victim_thd); in wsrep_handle_SR_rollback() 219 if (bf_thd) in wsrep_handle_SR_rollback() 221 wsrep_store_threadvars(bf_thd); in wsrep_handle_SR_rollback() 237 DBUG_ASSERT(!debug_sync_set_action(bf_thd, in wsrep_thd_bf_abort() 241 my_bool ret= wsrep_bf_abort(bf_thd, victim_thd); in wsrep_thd_bf_abort() 260 victim_thd->wsrep_aborter= bf_thd->thread_id; in wsrep_thd_bf_abort() [all …]
|
H A D | wsrep_thd.cc | 315 THD *bf_thd= (THD *) bf_thd_ptr; in wsrep_abort_thd() local 323 if ((WSREP(bf_thd) || in wsrep_abort_thd() 324 ((WSREP_ON || bf_thd->variables.wsrep_OSU_method == WSREP_OSU_RSU) && in wsrep_abort_thd() 325 wsrep_thd_is_toi(bf_thd))) && in wsrep_abort_thd() 329 WSREP_DEBUG("wsrep_abort_thd, by: %llu, victim: %llu", (bf_thd) ? in wsrep_abort_thd() 331 ha_abort_transaction(bf_thd, victim_thd, signal); in wsrep_abort_thd() 342 bool wsrep_bf_abort(THD* bf_thd, THD* victim_thd) in wsrep_bf_abort() argument 344 WSREP_LOG_THD(bf_thd, "BF aborter before"); in wsrep_bf_abort() 356 DBUG_ASSERT(!debug_sync_set_action(bf_thd, in wsrep_bf_abort() 382 wsrep::seqno bf_seqno(bf_thd->wsrep_trx().ws_meta().seqno()); in wsrep_bf_abort() [all …]
|
H A D | wsrep_mysqld.h | 271 #define WSREP_LOG_CONFLICT(bf_thd, victim_thd, bf_abort) \ argument 277 if (bf_thd) WSREP_LOG_CONFLICT_THD(bf_thd, "Winning thread"); \
|
/dports/databases/mariadb105-client/mariadb-10.5.15/sql/ |
H A D | service_wsrep.cc | 186 extern "C" void wsrep_handle_SR_rollback(THD *bf_thd, in wsrep_handle_SR_rollback() argument 191 if (!victim_thd || !wsrep_on(bf_thd)) return; in wsrep_handle_SR_rollback() 203 if (!(bf_thd && bf_thd != victim_thd)) in wsrep_handle_SR_rollback() 207 if (bf_thd) in wsrep_handle_SR_rollback() 209 wsrep_bf_abort(bf_thd, victim_thd); in wsrep_handle_SR_rollback() 218 if (bf_thd) in wsrep_handle_SR_rollback() 220 wsrep_store_threadvars(bf_thd); in wsrep_handle_SR_rollback() 236 DBUG_ASSERT(!debug_sync_set_action(bf_thd, in wsrep_thd_bf_abort() 240 my_bool ret= wsrep_bf_abort(bf_thd, victim_thd); in wsrep_thd_bf_abort() 259 victim_thd->wsrep_aborter= bf_thd->thread_id; in wsrep_thd_bf_abort() [all …]
|
H A D | wsrep_thd.cc | 315 THD *bf_thd= (THD *) bf_thd_ptr; in wsrep_abort_thd() local 323 if ((WSREP(bf_thd) || in wsrep_abort_thd() 324 ((WSREP_ON || bf_thd->variables.wsrep_OSU_method == WSREP_OSU_RSU) && in wsrep_abort_thd() 325 wsrep_thd_is_toi(bf_thd))) && in wsrep_abort_thd() 329 WSREP_DEBUG("wsrep_abort_thd, by: %llu, victim: %llu", (bf_thd) ? in wsrep_abort_thd() 331 ha_abort_transaction(bf_thd, victim_thd, signal); in wsrep_abort_thd() 342 bool wsrep_bf_abort(THD* bf_thd, THD* victim_thd) in wsrep_bf_abort() argument 344 WSREP_LOG_THD(bf_thd, "BF aborter before"); in wsrep_bf_abort() 356 DBUG_ASSERT(!debug_sync_set_action(bf_thd, in wsrep_bf_abort() 382 wsrep::seqno bf_seqno(bf_thd->wsrep_trx().ws_meta().seqno()); in wsrep_bf_abort() [all …]
|
H A D | wsrep_mysqld.h | 276 #define WSREP_LOG_CONFLICT(bf_thd, victim_thd, bf_abort) \ argument 282 if (bf_thd) WSREP_LOG_CONFLICT_THD(bf_thd, "Winning thread"); \
|
/dports/databases/mariadb104-client/mariadb-10.4.24/sql/ |
H A D | service_wsrep.cc | 187 extern "C" void wsrep_handle_SR_rollback(THD *bf_thd, 192 if (!victim_thd || !wsrep_on(bf_thd)) return; 204 if (!(bf_thd && bf_thd != victim_thd)) in slave_reply() 208 if (bf_thd) 210 wsrep_bf_abort(bf_thd, victim_thd); 219 if (bf_thd) 221 wsrep_store_threadvars(bf_thd); 237 DBUG_ASSERT(!debug_sync_set_action(bf_thd, 241 my_bool ret= wsrep_bf_abort(bf_thd, victim_thd); 260 victim_thd->wsrep_aborter= bf_thd->thread_id; [all …]
|
H A D | wsrep_thd.cc | 315 THD *bf_thd= (THD *) bf_thd_ptr; in wsrep_abort_thd() local 323 if ((WSREP(bf_thd) || in wsrep_abort_thd() 324 ((WSREP_ON || bf_thd->variables.wsrep_OSU_method == WSREP_OSU_RSU) && in wsrep_abort_thd() 325 wsrep_thd_is_toi(bf_thd))) && in wsrep_abort_thd() 329 WSREP_DEBUG("wsrep_abort_thd, by: %llu, victim: %llu", (bf_thd) ? in wsrep_abort_thd() 331 ha_abort_transaction(bf_thd, victim_thd, signal); in wsrep_abort_thd() 342 bool wsrep_bf_abort(THD* bf_thd, THD* victim_thd) in wsrep_bf_abort() argument 344 WSREP_LOG_THD(bf_thd, "BF aborter before"); in wsrep_bf_abort() 356 DBUG_ASSERT(!debug_sync_set_action(bf_thd, in wsrep_bf_abort() 382 wsrep::seqno bf_seqno(bf_thd->wsrep_trx().ws_meta().seqno()); in wsrep_bf_abort() [all …]
|
H A D | wsrep_mysqld.h | 271 #define WSREP_LOG_CONFLICT(bf_thd, victim_thd, bf_abort) \ argument 277 if (bf_thd) WSREP_LOG_CONFLICT_THD(bf_thd, "Winning thread"); \
|
/dports/databases/mariadb105-server/mariadb-10.5.15/sql/ |
H A D | service_wsrep.cc | 186 extern "C" void wsrep_handle_SR_rollback(THD *bf_thd, in wsrep_handle_SR_rollback() argument 191 if (!victim_thd || !wsrep_on(bf_thd)) return; in wsrep_handle_SR_rollback() 203 if (!(bf_thd && bf_thd != victim_thd)) in wsrep_handle_SR_rollback() 207 if (bf_thd) in wsrep_handle_SR_rollback() 209 wsrep_bf_abort(bf_thd, victim_thd); in wsrep_handle_SR_rollback() 218 if (bf_thd) in wsrep_handle_SR_rollback() 220 wsrep_store_threadvars(bf_thd); in wsrep_handle_SR_rollback() 236 DBUG_ASSERT(!debug_sync_set_action(bf_thd, in wsrep_thd_bf_abort() 240 my_bool ret= wsrep_bf_abort(bf_thd, victim_thd); in wsrep_thd_bf_abort() 259 victim_thd->wsrep_aborter= bf_thd->thread_id; in wsrep_thd_bf_abort() [all …]
|
H A D | wsrep_thd.cc | 315 THD *bf_thd= (THD *) bf_thd_ptr; in wsrep_abort_thd() local 323 if ((WSREP(bf_thd) || in wsrep_abort_thd() 324 ((WSREP_ON || bf_thd->variables.wsrep_OSU_method == WSREP_OSU_RSU) && in wsrep_abort_thd() 325 wsrep_thd_is_toi(bf_thd))) && in wsrep_abort_thd() 329 WSREP_DEBUG("wsrep_abort_thd, by: %llu, victim: %llu", (bf_thd) ? in wsrep_abort_thd() 331 ha_abort_transaction(bf_thd, victim_thd, signal); in wsrep_abort_thd() 342 bool wsrep_bf_abort(THD* bf_thd, THD* victim_thd) in wsrep_bf_abort() argument 344 WSREP_LOG_THD(bf_thd, "BF aborter before"); in wsrep_bf_abort() 356 DBUG_ASSERT(!debug_sync_set_action(bf_thd, in wsrep_bf_abort() 382 wsrep::seqno bf_seqno(bf_thd->wsrep_trx().ws_meta().seqno()); in wsrep_bf_abort() [all …]
|
H A D | wsrep_mysqld.h | 276 #define WSREP_LOG_CONFLICT(bf_thd, victim_thd, bf_abort) \ argument 282 if (bf_thd) WSREP_LOG_CONFLICT_THD(bf_thd, "Winning thread"); \
|
/dports/databases/mariadb103-server/mariadb-10.3.34/sql/ |
H A D | wsrep_thd.cc | 806 THD *bf_thd= (THD *) bf_thd_ptr; in wsrep_abort_thd() local 812 if ( (WSREP(bf_thd) || in wsrep_abort_thd() 813 ( (WSREP_ON || bf_thd->variables.wsrep_OSU_method == WSREP_OSU_RSU) && in wsrep_abort_thd() 814 bf_thd->wsrep_exec_mode == TOTAL_ORDER) ) && in wsrep_abort_thd() 823 (bf_thd) ? (long long)bf_thd->real_id : 0, in wsrep_abort_thd() 829 WSREP_DEBUG("wsrep_abort_thd, by: %llu, victim: %llu", (bf_thd) ? in wsrep_abort_thd() 830 (long long)bf_thd->real_id : 0, (long long)victim_thd->real_id); in wsrep_abort_thd() 831 ha_abort_transaction(bf_thd, victim_thd, signal); in wsrep_abort_thd() 835 WSREP_DEBUG("wsrep_abort_thd not effective: %p %p", bf_thd, victim_thd); in wsrep_abort_thd()
|
H A D | wsrep_mysqld.h | 213 #define WSREP_LOG_CONFLICT(bf_thd, victim_thd, bf_abort) \ argument 219 if (bf_thd != NULL) WSREP_LOG_CONFLICT_THD(bf_thd, "Winning thread"); \
|
/dports/databases/mariadb103-client/mariadb-10.3.34/sql/ |
H A D | wsrep_thd.cc | 806 THD *bf_thd= (THD *) bf_thd_ptr; in wsrep_abort_thd() local 812 if ( (WSREP(bf_thd) || in wsrep_abort_thd() 813 ( (WSREP_ON || bf_thd->variables.wsrep_OSU_method == WSREP_OSU_RSU) && in wsrep_abort_thd() 814 bf_thd->wsrep_exec_mode == TOTAL_ORDER) ) && in wsrep_abort_thd() 823 (bf_thd) ? (long long)bf_thd->real_id : 0, in wsrep_abort_thd() 829 WSREP_DEBUG("wsrep_abort_thd, by: %llu, victim: %llu", (bf_thd) ? in wsrep_abort_thd() 830 (long long)bf_thd->real_id : 0, (long long)victim_thd->real_id); in wsrep_abort_thd() 831 ha_abort_transaction(bf_thd, victim_thd, signal); in wsrep_abort_thd() 835 WSREP_DEBUG("wsrep_abort_thd not effective: %p %p", bf_thd, victim_thd); in wsrep_abort_thd()
|
H A D | wsrep_mysqld.h | 213 #define WSREP_LOG_CONFLICT(bf_thd, victim_thd, bf_abort) \ argument 219 if (bf_thd != NULL) WSREP_LOG_CONFLICT_THD(bf_thd, "Winning thread"); \
|
/dports/databases/mariadb105-client/mariadb-10.5.15/include/mysql/ |
H A D | service_wsrep.h | 76 my_bool (*wsrep_thd_bf_abort_func)(MYSQL_THD bf_thd, 89 bool (*wsrep_thd_set_wsrep_aborter_func)(MYSQL_THD bf_thd, MYSQL_THD thd); 196 extern "C" bool wsrep_thd_set_wsrep_aborter(MYSQL_THD bf_thd, MYSQL_THD victim_thd); 211 extern "C" my_bool wsrep_thd_bf_abort(MYSQL_THD bf_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 | 76 my_bool (*wsrep_thd_bf_abort_func)(MYSQL_THD bf_thd, 86 bool (*wsrep_thd_set_wsrep_aborter_func)(MYSQL_THD bf_thd, MYSQL_THD thd); 190 extern "C" bool wsrep_thd_set_wsrep_aborter(MYSQL_THD bf_thd, MYSQL_THD victim_thd); 205 extern "C" my_bool wsrep_thd_bf_abort(MYSQL_THD bf_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 | 76 my_bool (*wsrep_thd_bf_abort_func)(MYSQL_THD bf_thd, 89 bool (*wsrep_thd_set_wsrep_aborter_func)(MYSQL_THD bf_thd, MYSQL_THD thd); 196 extern "C" bool wsrep_thd_set_wsrep_aborter(MYSQL_THD bf_thd, MYSQL_THD victim_thd); 211 extern "C" my_bool wsrep_thd_bf_abort(MYSQL_THD bf_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 | 76 my_bool (*wsrep_thd_bf_abort_func)(MYSQL_THD bf_thd, 86 bool (*wsrep_thd_set_wsrep_aborter_func)(MYSQL_THD bf_thd, MYSQL_THD thd); 190 extern "C" bool wsrep_thd_set_wsrep_aborter(MYSQL_THD bf_thd, MYSQL_THD victim_thd); 205 extern "C" my_bool wsrep_thd_bf_abort(MYSQL_THD bf_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 | 672 THD *bf_thd = (THD *) bf_thd_ptr; in wsrep_abort_thd() local 675 if ( (WSREP(bf_thd) || in wsrep_abort_thd() 676 ( (WSREP_ON || bf_thd->variables.wsrep_OSU_method == WSREP_OSU_RSU) && in wsrep_abort_thd() 677 bf_thd->wsrep_exec_mode == TOTAL_ORDER) ) && in wsrep_abort_thd() 680 WSREP_DEBUG("wsrep_abort_thd, by: %llu, victim: %llu", (bf_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 265 if (bf_thd) WSREP_LOG_CONFLICT_THD(bf_thd, "Winning thread"); \
|
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/sql/ |
H A D | wsrep_thd.cc | 706 THD *bf_thd = (THD *) bf_thd_ptr; in wsrep_abort_thd() local 709 if ( (WSREP(bf_thd) || in wsrep_abort_thd() 710 ( (WSREP_ON || bf_thd->variables.wsrep_OSU_method == WSREP_OSU_RSU) && in wsrep_abort_thd() 711 bf_thd->wsrep_exec_mode == TOTAL_ORDER) ) && in wsrep_abort_thd() 714 WSREP_DEBUG("wsrep_abort_thd, by: %llu, victim: %llu", (bf_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 275 if (bf_thd) WSREP_LOG_CONFLICT_THD(bf_thd, "Winning thread"); \
|
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/innobase/include/ |
H A D | ha_prototypes.h | 213 THD* bf_thd,
|