Home
last modified time | relevance | path

Searched refs:bf_thd (Results 1 – 25 of 56) sorted by relevance

123

/dports/databases/mariadb104-server/mariadb-10.4.24/sql/
H A Dservice_wsrep.cc187 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 Dwsrep_thd.cc315 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 Dwsrep_mysqld.h271 #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 Dservice_wsrep.cc186 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 Dwsrep_thd.cc315 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 Dwsrep_mysqld.h276 #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 Dservice_wsrep.cc187 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 Dwsrep_thd.cc315 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 Dwsrep_mysqld.h271 #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 Dservice_wsrep.cc186 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 Dwsrep_thd.cc315 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 Dwsrep_mysqld.h276 #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 Dwsrep_thd.cc806 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 Dwsrep_mysqld.h213 #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 Dwsrep_thd.cc806 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 Dwsrep_mysqld.h213 #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 Dservice_wsrep.h76 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 Dservice_wsrep.h76 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 Dservice_wsrep.h76 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 Dservice_wsrep.h76 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 Dwsrep_thd.cc672 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 Dwsrep_mysqld.h259 #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 Dwsrep_thd.cc706 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 Dwsrep_mysqld.h269 #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 Dha_prototypes.h213 THD* bf_thd,

123