Home
last modified time | relevance | path

Searched refs:wsrep_trx (Results 1 – 25 of 86) sorted by relevance

1234

/dports/databases/mariadb104-server/mariadb-10.4.24/sql/
H A Dwsrep_trans_observer.h43 return thd->wsrep_trx().ordered(); in wsrep_is_ordered()
91 return (thd->wsrep_trx().is_empty() == false); in wsrep_has_changes()
99 return (thd->wsrep_trx().active() && thd->wsrep_trx().bf_aborted()); in wsrep_is_bf_aborted()
131 return thd->wsrep_trx().fragments_certified_for_statement(); in wsrep_fragments_certified_for_stmt()
149 if (thd->wsrep_trx().active() == false) in wsrep_start_trx_if_not_started()
234 DBUG_ASSERT(!thd->wsrep_trx().ws_meta().gtid().is_undefined()); in wsrep_before_prepare()
236 thd->wsrep_trx().ws_meta().gtid()); in wsrep_before_prepare()
275 DBUG_ASSERT(!thd->wsrep_trx().ws_meta().gtid().is_undefined()); in wsrep_before_commit()
277 thd->wsrep_trx().ws_meta().gtid()); in wsrep_before_commit()
347 if (thd->wsrep_trx().is_streaming() && in wsrep_before_rollback()
[all …]
H A Dwsrep_thd.cc149 wsrep::transaction_id transaction_id(thd->wsrep_trx().id()); in wsrep_remove_streaming_fragments()
152 storage_service->adopt_transaction(thd->wsrep_trx()); in wsrep_remove_streaming_fragments()
170 DBUG_ASSERT(thd->wsrep_trx().is_streaming()); in wsrep_rollback_high_priority()
172 thd->wsrep_trx().server_id(), in wsrep_rollback_high_priority()
173 thd->wsrep_trx().id())); in wsrep_rollback_high_priority()
198 if (thd->wsrep_trx().is_streaming()) in wsrep_rollback_local()
300 DBUG_ASSERT(thd->wsrep_trx().state() == wsrep::transaction::s_aborting); in wsrep_fire_rollbacker()
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()
382 wsrep::seqno bf_seqno(bf_thd->wsrep_trx().ws_meta().seqno()); in wsrep_bf_abort()
H A Dwsrep_client_service.cc79 m_thd->killed, m_thd->wsrep_trx().state()); in interrupted()
108 !m_thd->wsrep_trx().is_streaming()) in prepare_data_for_replication()
201 m_thd->wsrep_trx().id(), in remove_fragments()
206 m_thd->thread_id, m_thd->wsrep_trx().id().get()); in remove_fragments()
277 ret= provider.replay(replayer_thd->wsrep_trx().ws_handle(), in replay()
H A Dwsrep_high_priority_service.cc206 DBUG_RETURN(m_thd->wsrep_trx()); in transaction()
302 DBUG_ASSERT(thd->wsrep_trx().active()); in commit()
329 else if (m_thd->wsrep_trx().state() == wsrep::transaction::s_executing) in commit()
530 DBUG_ASSERT(thd->wsrep_trx().active()); in apply_write_set()
531 DBUG_ASSERT(thd->wsrep_trx().state() == wsrep::transaction::s_executing); in apply_write_set()
647 replayer_thd->wsrep_cs().clone_transaction_for_replay(orig_thd->wsrep_trx()); in Wsrep_replayer_service()
692 DBUG_ASSERT(thd->wsrep_trx().active()); in apply_write_set()
693 DBUG_ASSERT(thd->wsrep_trx().state() == wsrep::transaction::s_replaying); in apply_write_set()
711 DBUG_ASSERT(thd->wsrep_trx().is_streaming()); in apply_write_set()
H A Dwsrep_storage_service.cc135 m_thd->wsrep_trx().server_id(), in remove_fragments()
136 m_thd->wsrep_trx().id(), in remove_fragments()
H A Dwsrep_binlog.cc361 DBUG_ASSERT(thd->wsrep_trx().ordered()); in wsrep_register_for_group_commit()
384 DBUG_ASSERT(thd->wsrep_trx().ordered()); in wsrep_unregister_from_group_commit()
/dports/databases/mariadb104-client/mariadb-10.4.24/sql/
H A Dwsrep_trans_observer.h43 return thd->wsrep_trx().ordered();
91 return (thd->wsrep_trx().is_empty() == false);
99 return (thd->wsrep_trx().active() && thd->wsrep_trx().bf_aborted());
131 return thd->wsrep_trx().fragments_certified_for_statement();
149 if (thd->wsrep_trx().active() == false)
234 DBUG_ASSERT(!thd->wsrep_trx().ws_meta().gtid().is_undefined());
236 thd->wsrep_trx().ws_meta().gtid());
275 DBUG_ASSERT(!thd->wsrep_trx().ws_meta().gtid().is_undefined());
277 thd->wsrep_trx().ws_meta().gtid());
347 if (thd->wsrep_trx().is_streaming() &&
[all …]
H A Dwsrep_thd.cc149 wsrep::transaction_id transaction_id(thd->wsrep_trx().id()); in wsrep_remove_streaming_fragments()
152 storage_service->adopt_transaction(thd->wsrep_trx()); in wsrep_remove_streaming_fragments()
170 DBUG_ASSERT(thd->wsrep_trx().is_streaming()); in wsrep_rollback_high_priority()
172 thd->wsrep_trx().server_id(), in wsrep_rollback_high_priority()
173 thd->wsrep_trx().id())); in wsrep_rollback_high_priority()
198 if (thd->wsrep_trx().is_streaming()) in wsrep_rollback_local()
300 DBUG_ASSERT(thd->wsrep_trx().state() == wsrep::transaction::s_aborting); in wsrep_fire_rollbacker()
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()
382 wsrep::seqno bf_seqno(bf_thd->wsrep_trx().ws_meta().seqno()); in wsrep_bf_abort()
H A Dwsrep_client_service.cc79 m_thd->killed, m_thd->wsrep_trx().state());
108 !m_thd->wsrep_trx().is_streaming())
201 m_thd->wsrep_trx().id(),
206 m_thd->thread_id, m_thd->wsrep_trx().id().get());
277 ret= provider.replay(replayer_thd->wsrep_trx().ws_handle(),
H A Dwsrep_high_priority_service.cc206 DBUG_RETURN(m_thd->wsrep_trx()); in transaction()
302 DBUG_ASSERT(thd->wsrep_trx().active()); in commit()
329 else if (m_thd->wsrep_trx().state() == wsrep::transaction::s_executing) in commit()
530 DBUG_ASSERT(thd->wsrep_trx().active()); in apply_write_set()
531 DBUG_ASSERT(thd->wsrep_trx().state() == wsrep::transaction::s_executing); in apply_write_set()
647 replayer_thd->wsrep_cs().clone_transaction_for_replay(orig_thd->wsrep_trx()); in Wsrep_replayer_service()
692 DBUG_ASSERT(thd->wsrep_trx().active()); in apply_write_set()
693 DBUG_ASSERT(thd->wsrep_trx().state() == wsrep::transaction::s_replaying); in apply_write_set()
711 DBUG_ASSERT(thd->wsrep_trx().is_streaming()); in apply_write_set()
H A Dwsrep_storage_service.cc135 m_thd->wsrep_trx().server_id(), in remove_fragments()
136 m_thd->wsrep_trx().id(), in remove_fragments()
H A Dwsrep_binlog.cc361 DBUG_ASSERT(thd->wsrep_trx().ordered()); in wsrep_register_for_group_commit()
384 DBUG_ASSERT(thd->wsrep_trx().ordered()); in wsrep_unregister_from_group_commit()
/dports/databases/mariadb105-client/mariadb-10.5.15/sql/
H A Dwsrep_trans_observer.h46 return thd->wsrep_trx().ordered(); in wsrep_is_ordered()
94 return (thd->wsrep_trx().is_empty() == false); in wsrep_has_changes()
102 return (thd->wsrep_trx().active() && thd->wsrep_trx().bf_aborted()); in wsrep_is_bf_aborted()
134 return thd->wsrep_trx().fragments_certified_for_statement(); in wsrep_fragments_certified_for_stmt()
152 if (thd->wsrep_trx().active() == false) in wsrep_start_trx_if_not_started()
214 if (thd->wsrep_trx().state() == wsrep::transaction::s_executing) in wsrep_run_commit_hook()
237 DBUG_ASSERT(!thd->wsrep_trx().ws_meta().gtid().is_undefined()); in wsrep_before_prepare()
239 thd->wsrep_trx().ws_meta().gtid(), in wsrep_before_prepare()
279 DBUG_ASSERT(!thd->wsrep_trx().ws_meta().gtid().is_undefined()); in wsrep_before_commit()
305 thd->wsrep_trx().ws_meta().gtid(), in wsrep_before_commit()
[all …]
H A Dwsrep_thd.cc149 wsrep::transaction_id transaction_id(thd->wsrep_trx().id()); in wsrep_remove_streaming_fragments()
152 storage_service->adopt_transaction(thd->wsrep_trx()); in wsrep_remove_streaming_fragments()
170 DBUG_ASSERT(thd->wsrep_trx().is_streaming()); in wsrep_rollback_high_priority()
172 thd->wsrep_trx().server_id(), in wsrep_rollback_high_priority()
173 thd->wsrep_trx().id())); in wsrep_rollback_high_priority()
198 if (thd->wsrep_trx().is_streaming()) in wsrep_rollback_local()
300 DBUG_ASSERT(thd->wsrep_trx().state() == wsrep::transaction::s_aborting); in wsrep_fire_rollbacker()
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()
382 wsrep::seqno bf_seqno(bf_thd->wsrep_trx().ws_meta().seqno()); in wsrep_bf_abort()
H A Dwsrep_client_service.cc78 m_thd->killed, m_thd->wsrep_trx().state()); in interrupted()
107 !m_thd->wsrep_trx().is_streaming()) in prepare_data_for_replication()
200 m_thd->wsrep_trx().id(), in remove_fragments()
205 m_thd->thread_id, m_thd->wsrep_trx().id().get()); in remove_fragments()
276 ret= provider.replay(replayer_thd->wsrep_trx().ws_handle(), in replay()
H A Dwsrep_high_priority_service.cc223 DBUG_RETURN(m_thd->wsrep_trx()); in transaction()
318 DBUG_ASSERT(thd->wsrep_trx().active()); in commit()
345 else if (m_thd->wsrep_trx().state() == wsrep::transaction::s_executing) in commit()
555 DBUG_ASSERT(thd->wsrep_trx().active()); in apply_write_set()
556 DBUG_ASSERT(thd->wsrep_trx().state() == wsrep::transaction::s_executing); in apply_write_set()
669 replayer_thd->wsrep_cs().clone_transaction_for_replay(orig_thd->wsrep_trx()); in Wsrep_replayer_service()
714 DBUG_ASSERT(thd->wsrep_trx().active()); in apply_write_set()
715 DBUG_ASSERT(thd->wsrep_trx().state() == wsrep::transaction::s_replaying); in apply_write_set()
733 DBUG_ASSERT(thd->wsrep_trx().is_streaming()); in apply_write_set()
H A Dservice_wsrep.cc351 (thd->wsrep_trx().state() == wsrep::transaction::s_committing || in wsrep_commit_ordered()
352 thd->wsrep_trx().state() == wsrep::transaction::s_ordered_commit)) in wsrep_commit_ordered()
359 if (thd->wsrep_trx().state() != wsrep::transaction::s_ordered_commit && in wsrep_commit_ordered()
H A Dwsrep_storage_service.cc135 m_thd->wsrep_trx().server_id(), in remove_fragments()
136 m_thd->wsrep_trx().id(), in remove_fragments()
H A Dwsrep_binlog.cc361 DBUG_ASSERT(thd->wsrep_trx().ordered()); in wsrep_register_for_group_commit()
384 DBUG_ASSERT(thd->wsrep_trx().ordered()); in wsrep_unregister_from_group_commit()
/dports/databases/mariadb105-server/mariadb-10.5.15/sql/
H A Dwsrep_trans_observer.h46 return thd->wsrep_trx().ordered(); in wsrep_is_ordered()
94 return (thd->wsrep_trx().is_empty() == false); in wsrep_has_changes()
102 return (thd->wsrep_trx().active() && thd->wsrep_trx().bf_aborted()); in wsrep_is_bf_aborted()
134 return thd->wsrep_trx().fragments_certified_for_statement(); in wsrep_fragments_certified_for_stmt()
152 if (thd->wsrep_trx().active() == false) in wsrep_start_trx_if_not_started()
214 if (thd->wsrep_trx().state() == wsrep::transaction::s_executing) in wsrep_run_commit_hook()
237 DBUG_ASSERT(!thd->wsrep_trx().ws_meta().gtid().is_undefined()); in wsrep_before_prepare()
239 thd->wsrep_trx().ws_meta().gtid(), in wsrep_before_prepare()
279 DBUG_ASSERT(!thd->wsrep_trx().ws_meta().gtid().is_undefined()); in wsrep_before_commit()
305 thd->wsrep_trx().ws_meta().gtid(), in wsrep_before_commit()
[all …]
H A Dwsrep_thd.cc149 wsrep::transaction_id transaction_id(thd->wsrep_trx().id()); in wsrep_remove_streaming_fragments()
152 storage_service->adopt_transaction(thd->wsrep_trx()); in wsrep_remove_streaming_fragments()
170 DBUG_ASSERT(thd->wsrep_trx().is_streaming()); in wsrep_rollback_high_priority()
172 thd->wsrep_trx().server_id(), in wsrep_rollback_high_priority()
173 thd->wsrep_trx().id())); in wsrep_rollback_high_priority()
198 if (thd->wsrep_trx().is_streaming()) in wsrep_rollback_local()
300 DBUG_ASSERT(thd->wsrep_trx().state() == wsrep::transaction::s_aborting); in wsrep_fire_rollbacker()
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()
382 wsrep::seqno bf_seqno(bf_thd->wsrep_trx().ws_meta().seqno()); in wsrep_bf_abort()
H A Dwsrep_client_service.cc78 m_thd->killed, m_thd->wsrep_trx().state()); in interrupted()
107 !m_thd->wsrep_trx().is_streaming()) in prepare_data_for_replication()
200 m_thd->wsrep_trx().id(), in remove_fragments()
205 m_thd->thread_id, m_thd->wsrep_trx().id().get()); in remove_fragments()
276 ret= provider.replay(replayer_thd->wsrep_trx().ws_handle(), in replay()
H A Dwsrep_high_priority_service.cc223 DBUG_RETURN(m_thd->wsrep_trx()); in transaction()
318 DBUG_ASSERT(thd->wsrep_trx().active()); in commit()
345 else if (m_thd->wsrep_trx().state() == wsrep::transaction::s_executing) in commit()
555 DBUG_ASSERT(thd->wsrep_trx().active()); in apply_write_set()
556 DBUG_ASSERT(thd->wsrep_trx().state() == wsrep::transaction::s_executing); in apply_write_set()
669 replayer_thd->wsrep_cs().clone_transaction_for_replay(orig_thd->wsrep_trx()); in Wsrep_replayer_service()
714 DBUG_ASSERT(thd->wsrep_trx().active()); in apply_write_set()
715 DBUG_ASSERT(thd->wsrep_trx().state() == wsrep::transaction::s_replaying); in apply_write_set()
733 DBUG_ASSERT(thd->wsrep_trx().is_streaming()); in apply_write_set()
H A Dservice_wsrep.cc351 (thd->wsrep_trx().state() == wsrep::transaction::s_committing || in wsrep_commit_ordered()
352 thd->wsrep_trx().state() == wsrep::transaction::s_ordered_commit)) in wsrep_commit_ordered()
359 if (thd->wsrep_trx().state() != wsrep::transaction::s_ordered_commit && in wsrep_commit_ordered()
H A Dwsrep_storage_service.cc135 m_thd->wsrep_trx().server_id(), in remove_fragments()
136 m_thd->wsrep_trx().id(), in remove_fragments()

1234