/dports/databases/mariadb104-server/mariadb-10.4.24/sql/ |
H A D | wsrep_trans_observer.h | 43 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 D | wsrep_thd.cc | 149 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 D | wsrep_client_service.cc | 79 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 D | wsrep_high_priority_service.cc | 206 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 D | wsrep_storage_service.cc | 135 m_thd->wsrep_trx().server_id(), in remove_fragments() 136 m_thd->wsrep_trx().id(), in remove_fragments()
|
H A D | wsrep_binlog.cc | 361 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 D | wsrep_trans_observer.h | 43 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 D | wsrep_thd.cc | 149 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 D | wsrep_client_service.cc | 79 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 D | wsrep_high_priority_service.cc | 206 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 D | wsrep_storage_service.cc | 135 m_thd->wsrep_trx().server_id(), in remove_fragments() 136 m_thd->wsrep_trx().id(), in remove_fragments()
|
H A D | wsrep_binlog.cc | 361 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 D | wsrep_trans_observer.h | 46 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 D | wsrep_thd.cc | 149 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 D | wsrep_client_service.cc | 78 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 D | wsrep_high_priority_service.cc | 223 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 D | service_wsrep.cc | 351 (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 D | wsrep_storage_service.cc | 135 m_thd->wsrep_trx().server_id(), in remove_fragments() 136 m_thd->wsrep_trx().id(), in remove_fragments()
|
H A D | wsrep_binlog.cc | 361 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 D | wsrep_trans_observer.h | 46 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 D | wsrep_thd.cc | 149 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 D | wsrep_client_service.cc | 78 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 D | wsrep_high_priority_service.cc | 223 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 D | service_wsrep.cc | 351 (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 D | wsrep_storage_service.cc | 135 m_thd->wsrep_trx().server_id(), in remove_fragments() 136 m_thd->wsrep_trx().id(), in remove_fragments()
|