Lines Matching refs:client_service_

55             : client_service_(client_service)  in scoped_storage_service()
63 client_service_.reset_globals(); in scoped_storage_service()
75 client_service_.store_globals(); in ~scoped_storage_service()
80 wsrep::client_service& client_service_; member in __anon83c57f780111::scoped_storage_service
91 , client_service_(client_state.client_service()) in transaction()
293 client_service_.debug_crash( in before_prepare()
296 if (client_service_.statement_allowed_for_streaming() == false) in before_prepare()
308 ret = client_service_.remove_fragments(); in before_prepare()
315 client_service_.debug_crash( in before_prepare()
501 client_service_.debug_sync("wsrep_before_commit_order_enter"); in before_commit()
565 client_service_.debug_sync("wsrep_before_commit_order_leave"); in ordered_commit()
568 client_service_.debug_sync("wsrep_after_commit_order_leave"); in ordered_commit()
617 client_service_, in after_commit()
618 server_service_.storage_service(client_service_), in after_commit()
673 client_service_.debug_sync("wsrep_before_SR_rollback"); in before_rollback()
756 client_service_, in after_rollback()
757 server_service_.storage_service(client_service_), in after_rollback()
797 server_service_.set_position(client_service_, ws_meta_.gtid()); in release_commit_order()
846 ret = client_service_.bf_rollback(); in after_statement()
870 !client_service_.is_xa_rollback()) in after_statement()
898 (!client_service_.is_explicit_xa() || in after_statement()
922 client_service_.bf_rollback(); in after_command_must_abort()
1199 client_service_.store_globals(); in xa_detach()
1200 client_service_.cleanup_transaction(); in xa_detach()
1225 status = client_service_.replay_unordered(); in xa_replay_common()
1226 client_service_.store_globals(); in xa_replay_common()
1231 client_service_.emergency_shutdown(); in xa_replay_common()
1243 client_service_.signal_replayed(); in xa_replay()
1253 enum wsrep::provider::status status(client_service_.commit_by_xid()); in xa_replay_commit()
1274 client_service_.signal_replayed(); in xa_replay_commit()
1342 client_service_.will_replay(); in state()
1369 else if (client_service_.interrupted(lock)) in abort_or_interrupt()
1387 if (client_service_.bytes_generated() < in streaming_step()
1393 << client_service_.bytes_generated() in streaming_step()
1401 const size_t bytes_to_replicate(client_service_.bytes_generated() - in streaming_step()
1445 client_service_.wait_for_replayers(lock); in certify_fragment()
1453 client_service_.debug_sync("wsrep_before_fragment_certification"); in certify_fragment()
1470 if (client_service_.prepare_fragment_for_replication(data, log_position)) in certify_fragment()
1527 client_service_, in certify_fragment()
1528 server_service_.storage_service(client_service_), in certify_fragment()
1561 client_service_.debug_crash( in certify_fragment()
1569 client_service_.debug_crash( in certify_fragment()
1595 client_service_.debug_crash( in certify_fragment()
1692 client_service_.wait_for_replayers(lock); in certify_commit()
1751 if (client_service_.prepare_data_for_replication()) in certify_commit()
1767 client_service_.debug_sync("wsrep_before_certification"); in certify_commit()
1773 client_service_.debug_sync("wsrep_after_certification"); in certify_commit()
1879 client_service_.emergency_shutdown(); in certify_commit()
1994 client_service_.debug_sync("wsrep_before_replay"); in replay()
1995 enum wsrep::provider::status replay_ret(client_service_.replay()); in replay()
1996 client_service_.signal_replayed(); in replay()
2022 client_service_.remove_fragments(); in replay()
2029 client_service_.emergency_shutdown(); in replay()
2063 client_service_.cleanup_transaction(); in cleanup()