| /dports/databases/mariadb104-server/mariadb-10.4.24/wsrep-lib/include/wsrep/ |
| H A D | high_priority_service.hpp | 33 class ws_meta;
44 int apply(const ws_handle& ws_handle, const ws_meta& ws_meta, in apply() argument
58 virtual int next_fragment(const wsrep::ws_meta&) = 0;
83 virtual int apply_write_set(const wsrep::ws_meta& ws_meta,
99 const wsrep::ws_meta& ws_meta,
114 virtual int remove_fragments(const wsrep::ws_meta& ws_meta) = 0;
131 const wsrep::ws_meta& ws_meta) = 0;
148 const wsrep::ws_meta& ws_meta) = 0;
160 virtual int apply_toi(const wsrep::ws_meta& ws_meta,
181 virtual int apply_nbo_begin(const wsrep::ws_meta& ws_meta,
[all …]
|
| /dports/databases/mariadb104-client/mariadb-10.4.24/wsrep-lib/include/wsrep/ |
| H A D | high_priority_service.hpp | 33 class ws_meta;
44 int apply(const ws_handle& ws_handle, const ws_meta& ws_meta, in apply() argument
58 virtual int next_fragment(const wsrep::ws_meta&) = 0;
83 virtual int apply_write_set(const wsrep::ws_meta& ws_meta,
99 const wsrep::ws_meta& ws_meta,
114 virtual int remove_fragments(const wsrep::ws_meta& ws_meta) = 0;
131 const wsrep::ws_meta& ws_meta) = 0;
148 const wsrep::ws_meta& ws_meta) = 0;
160 virtual int apply_toi(const wsrep::ws_meta& ws_meta,
181 virtual int apply_nbo_begin(const wsrep::ws_meta& ws_meta,
[all …]
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/wsrep-lib/include/wsrep/ |
| H A D | high_priority_service.hpp | 33 class ws_meta;
44 int apply(const ws_handle& ws_handle, const ws_meta& ws_meta, in apply() argument
58 virtual int next_fragment(const wsrep::ws_meta&) = 0;
83 virtual int apply_write_set(const wsrep::ws_meta& ws_meta,
99 const wsrep::ws_meta& ws_meta,
114 virtual int remove_fragments(const wsrep::ws_meta& ws_meta) = 0;
131 const wsrep::ws_meta& ws_meta) = 0;
148 const wsrep::ws_meta& ws_meta) = 0;
160 virtual int apply_toi(const wsrep::ws_meta& ws_meta,
181 virtual int apply_nbo_begin(const wsrep::ws_meta& ws_meta,
[all …]
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/wsrep-lib/include/wsrep/ |
| H A D | high_priority_service.hpp | 33 class ws_meta;
44 int apply(const ws_handle& ws_handle, const ws_meta& ws_meta, in apply() argument
58 virtual int next_fragment(const wsrep::ws_meta&) = 0;
83 virtual int apply_write_set(const wsrep::ws_meta& ws_meta,
99 const wsrep::ws_meta& ws_meta,
114 virtual int remove_fragments(const wsrep::ws_meta& ws_meta) = 0;
131 const wsrep::ws_meta& ws_meta) = 0;
148 const wsrep::ws_meta& ws_meta) = 0;
160 virtual int apply_toi(const wsrep::ws_meta& ws_meta,
181 virtual int apply_nbo_begin(const wsrep::ws_meta& ws_meta,
[all …]
|
| /dports/databases/mariadb104-server/mariadb-10.4.24/wsrep-lib/dbsim/ |
| H A D | db_high_priority_service.cpp | 33 const wsrep::ws_meta& ws_meta) in start_transaction() argument
38 int db::high_priority_service::next_fragment(const wsrep::ws_meta& ws_meta) in next_fragment() argument
40 return client_.client_state().next_fragment(ws_meta); in next_fragment()
54 const wsrep::ws_meta&, in apply_write_set() argument
64 const wsrep::ws_meta&, in apply_toi() argument
72 const wsrep::ws_meta&, in apply_nbo_begin() argument
80 const wsrep::ws_meta& ws_meta) in commit() argument
84 if (ret == 0) client_.se_trx_.commit(ws_meta.gtid()); in commit()
91 const wsrep::ws_meta& ws_meta) in rollback() argument
114 const wsrep::ws_meta& ws_meta, in log_dummy_write_set() argument
[all …]
|
| /dports/databases/mariadb104-client/mariadb-10.4.24/wsrep-lib/dbsim/ |
| H A D | db_high_priority_service.cpp | 33 const wsrep::ws_meta& ws_meta)
38 int db::high_priority_service::next_fragment(const wsrep::ws_meta& ws_meta)
40 return client_.client_state().next_fragment(ws_meta);
54 const wsrep::ws_meta&,
64 const wsrep::ws_meta&, in client_state()
72 const wsrep::ws_meta&,
80 const wsrep::ws_meta& ws_meta)
84 if (ret == 0) client_.se_trx_.commit(ws_meta.gtid());
91 const wsrep::ws_meta& ws_meta)
114 const wsrep::ws_meta& ws_meta,
[all …]
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/wsrep-lib/dbsim/ |
| H A D | db_high_priority_service.cpp | 33 const wsrep::ws_meta& ws_meta) in start_transaction() argument
38 int db::high_priority_service::next_fragment(const wsrep::ws_meta& ws_meta) in next_fragment() argument
40 return client_.client_state().next_fragment(ws_meta); in next_fragment()
54 const wsrep::ws_meta&, in apply_write_set() argument
64 const wsrep::ws_meta&, in apply_toi() argument
72 const wsrep::ws_meta&, in apply_nbo_begin() argument
80 const wsrep::ws_meta& ws_meta) in commit() argument
84 if (ret == 0) client_.se_trx_.commit(ws_meta.gtid()); in commit()
91 const wsrep::ws_meta& ws_meta) in rollback() argument
114 const wsrep::ws_meta& ws_meta, in log_dummy_write_set() argument
[all …]
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/wsrep-lib/dbsim/ |
| H A D | db_high_priority_service.cpp | 33 const wsrep::ws_meta& ws_meta) in start_transaction() argument
38 int db::high_priority_service::next_fragment(const wsrep::ws_meta& ws_meta) in next_fragment() argument
40 return client_.client_state().next_fragment(ws_meta); in next_fragment()
54 const wsrep::ws_meta&, in apply_write_set() argument
64 const wsrep::ws_meta&, in apply_toi() argument
72 const wsrep::ws_meta&, in apply_nbo_begin() argument
80 const wsrep::ws_meta& ws_meta) in commit() argument
84 if (ret == 0) client_.se_trx_.commit(ws_meta.gtid()); in commit()
91 const wsrep::ws_meta& ws_meta) in rollback() argument
114 const wsrep::ws_meta& ws_meta, in log_dummy_write_set() argument
[all …]
|
| /dports/databases/mariadb104-server/mariadb-10.4.24/wsrep-lib/test/ |
| H A D | mock_high_priority_service.cpp | 25 const wsrep::ws_handle& ws_handle, const wsrep::ws_meta& ws_meta) in start_transaction() argument
31 const wsrep::ws_meta& ws_meta) in next_fragment() argument
33 return client_state_->next_fragment(ws_meta); in next_fragment()
48 const wsrep::ws_meta& meta, in apply_write_set()
83 const wsrep::ws_meta& ws_meta) in commit() argument
109 const wsrep::ws_meta& ws_meta) in rollback() argument
126 const wsrep::ws_meta& ws_meta, in apply_nbo_begin() argument
133 assert(ws_meta.flags() & nbo_begin_flags); in apply_nbo_begin()
134 assert((ws_meta.flags() & ~nbo_begin_flags) == 0); in apply_nbo_begin()
149 return nbo_cs_->enter_nbo_mode(ws_meta); in apply_nbo_begin()
[all …]
|
| /dports/databases/mariadb104-client/mariadb-10.4.24/wsrep-lib/test/ |
| H A D | mock_high_priority_service.cpp | 25 const wsrep::ws_handle& ws_handle, const wsrep::ws_meta& ws_meta) in start_transaction() argument
31 const wsrep::ws_meta& ws_meta) in next_fragment() argument
33 return client_state_->next_fragment(ws_meta); in next_fragment()
48 const wsrep::ws_meta& meta, in apply_write_set()
83 const wsrep::ws_meta& ws_meta) in commit() argument
109 const wsrep::ws_meta& ws_meta) in rollback() argument
126 const wsrep::ws_meta& ws_meta, in apply_nbo_begin() argument
133 assert(ws_meta.flags() & nbo_begin_flags); in apply_nbo_begin()
134 assert((ws_meta.flags() & ~nbo_begin_flags) == 0); in apply_nbo_begin()
149 return nbo_cs_->enter_nbo_mode(ws_meta); in apply_nbo_begin()
[all …]
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/wsrep-lib/test/ |
| H A D | mock_high_priority_service.cpp | 25 const wsrep::ws_handle& ws_handle, const wsrep::ws_meta& ws_meta) in start_transaction() argument
31 const wsrep::ws_meta& ws_meta) in next_fragment() argument
33 return client_state_->next_fragment(ws_meta); in next_fragment()
48 const wsrep::ws_meta& meta, in apply_write_set()
83 const wsrep::ws_meta& ws_meta) in commit() argument
109 const wsrep::ws_meta& ws_meta) in rollback() argument
126 const wsrep::ws_meta& ws_meta, in apply_nbo_begin() argument
133 assert(ws_meta.flags() & nbo_begin_flags); in apply_nbo_begin()
134 assert((ws_meta.flags() & ~nbo_begin_flags) == 0); in apply_nbo_begin()
149 return nbo_cs_->enter_nbo_mode(ws_meta); in apply_nbo_begin()
[all …]
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/wsrep-lib/test/ |
| H A D | mock_high_priority_service.cpp | 25 const wsrep::ws_handle& ws_handle, const wsrep::ws_meta& ws_meta) in start_transaction() argument
31 const wsrep::ws_meta& ws_meta) in next_fragment() argument
33 return client_state_->next_fragment(ws_meta); in next_fragment()
48 const wsrep::ws_meta& meta, in apply_write_set()
83 const wsrep::ws_meta& ws_meta) in commit() argument
109 const wsrep::ws_meta& ws_meta) in rollback() argument
126 const wsrep::ws_meta& ws_meta, in apply_nbo_begin() argument
133 assert(ws_meta.flags() & nbo_begin_flags); in apply_nbo_begin()
134 assert((ws_meta.flags() & ~nbo_begin_flags) == 0); in apply_nbo_begin()
149 return nbo_cs_->enter_nbo_mode(ws_meta); in apply_nbo_begin()
[all …]
|
| /dports/databases/mariadb104-server/mariadb-10.4.24/sql/ |
| H A D | wsrep_high_priority_service.cc | 41 Wsrep_non_trans_mode(THD* thd, const wsrep::ws_meta& ws_meta) in Wsrep_non_trans_mode() argument
196 const wsrep::ws_handle& ws_handle, const wsrep::ws_meta& ws_meta) in start_transaction() argument
209 int Wsrep_high_priority_service::next_fragment(const wsrep::ws_meta& ws_meta) in next_fragment() argument
234 const wsrep::ws_meta& ws_meta, in append_fragment_and_commit() argument
298 const wsrep::ws_meta& ws_meta) in commit() argument
353 const wsrep::ws_meta& ws_meta) in rollback() argument
366 int Wsrep_high_priority_service::apply_toi(const wsrep::ws_meta& ws_meta, in apply_toi() argument
449 if (ws_meta.ordered()) in log_dummy_write_set()
521 int Wsrep_applier_service::apply_write_set(const wsrep::ws_meta& ws_meta, in apply_write_set() argument
566 int Wsrep_applier_service::apply_nbo_begin(const wsrep::ws_meta& ws_meta, in apply_nbo_begin() argument
[all …]
|
| /dports/databases/mariadb104-client/mariadb-10.4.24/sql/ |
| H A D | wsrep_high_priority_service.cc | 41 Wsrep_non_trans_mode(THD* thd, const wsrep::ws_meta& ws_meta) in Wsrep_non_trans_mode() argument
196 const wsrep::ws_handle& ws_handle, const wsrep::ws_meta& ws_meta) in start_transaction() argument
209 int Wsrep_high_priority_service::next_fragment(const wsrep::ws_meta& ws_meta) in next_fragment() argument
234 const wsrep::ws_meta& ws_meta, in append_fragment_and_commit() argument
298 const wsrep::ws_meta& ws_meta) in commit() argument
353 const wsrep::ws_meta& ws_meta) in rollback() argument
366 int Wsrep_high_priority_service::apply_toi(const wsrep::ws_meta& ws_meta, in apply_toi() argument
449 if (ws_meta.ordered()) in log_dummy_write_set()
521 int Wsrep_applier_service::apply_write_set(const wsrep::ws_meta& ws_meta, in apply_write_set() argument
566 int Wsrep_applier_service::apply_nbo_begin(const wsrep::ws_meta& ws_meta, in apply_nbo_begin() argument
[all …]
|
| /dports/databases/mariadb104-client/mariadb-10.4.24/wsrep-lib/src/ |
| H A D | server_state.cpp | 76 const wsrep::ws_meta& ws_meta) in discard_streaming_applier() argument
79 ws_meta.server_id(), ws_meta.transaction_id()); in discard_streaming_applier()
89 const wsrep::ws_meta& ws_meta, in apply_fragment() argument
156 const wsrep::ws_meta& ws_meta, in commit_fragment() argument
216 const wsrep::ws_meta& ws_meta) in rollback_fragment() argument
273 const wsrep::ws_meta& ws_meta, in apply_write_set() argument
353 ws_meta.server_id(), ws_meta.transaction_id(), sa); in apply_write_set()
367 ws_meta.server_id(), ws_meta.transaction_id())); in apply_write_set()
450 const wsrep::ws_meta& ws_meta, in apply_toi() argument
1098 const wsrep::ws_meta& ws_meta, in on_apply() argument
[all …]
|
| /dports/databases/mariadb104-server/mariadb-10.4.24/wsrep-lib/src/ |
| H A D | server_state.cpp | 76 const wsrep::ws_meta& ws_meta) in discard_streaming_applier() argument
79 ws_meta.server_id(), ws_meta.transaction_id()); in discard_streaming_applier()
89 const wsrep::ws_meta& ws_meta, in apply_fragment() argument
156 const wsrep::ws_meta& ws_meta, in commit_fragment() argument
216 const wsrep::ws_meta& ws_meta) in rollback_fragment() argument
273 const wsrep::ws_meta& ws_meta, in apply_write_set() argument
353 ws_meta.server_id(), ws_meta.transaction_id(), sa); in apply_write_set()
367 ws_meta.server_id(), ws_meta.transaction_id())); in apply_write_set()
450 const wsrep::ws_meta& ws_meta, in apply_toi() argument
1098 const wsrep::ws_meta& ws_meta, in on_apply() argument
[all …]
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/wsrep-lib/src/ |
| H A D | server_state.cpp | 76 const wsrep::ws_meta& ws_meta) in discard_streaming_applier() argument
79 ws_meta.server_id(), ws_meta.transaction_id()); in discard_streaming_applier()
89 const wsrep::ws_meta& ws_meta, in apply_fragment() argument
156 const wsrep::ws_meta& ws_meta, in commit_fragment() argument
216 const wsrep::ws_meta& ws_meta) in rollback_fragment() argument
273 const wsrep::ws_meta& ws_meta, in apply_write_set() argument
353 ws_meta.server_id(), ws_meta.transaction_id(), sa); in apply_write_set()
367 ws_meta.server_id(), ws_meta.transaction_id())); in apply_write_set()
450 const wsrep::ws_meta& ws_meta, in apply_toi() argument
1098 const wsrep::ws_meta& ws_meta, in on_apply() argument
[all …]
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/wsrep-lib/src/ |
| H A D | server_state.cpp | 76 const wsrep::ws_meta& ws_meta) in discard_streaming_applier() argument
79 ws_meta.server_id(), ws_meta.transaction_id()); in discard_streaming_applier()
89 const wsrep::ws_meta& ws_meta, in apply_fragment() argument
156 const wsrep::ws_meta& ws_meta, in commit_fragment() argument
216 const wsrep::ws_meta& ws_meta) in rollback_fragment() argument
273 const wsrep::ws_meta& ws_meta, in apply_write_set() argument
353 ws_meta.server_id(), ws_meta.transaction_id(), sa); in apply_write_set()
367 ws_meta.server_id(), ws_meta.transaction_id())); in apply_write_set()
450 const wsrep::ws_meta& ws_meta, in apply_toi() argument
1098 const wsrep::ws_meta& ws_meta, in on_apply() argument
[all …]
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/sql/ |
| H A D | wsrep_high_priority_service.cc | 41 Wsrep_non_trans_mode(THD* thd, const wsrep::ws_meta& ws_meta) in Wsrep_non_trans_mode() argument
213 const wsrep::ws_handle& ws_handle, const wsrep::ws_meta& ws_meta) in start_transaction() argument
226 int Wsrep_high_priority_service::next_fragment(const wsrep::ws_meta& ws_meta) in next_fragment() argument
251 const wsrep::ws_meta& ws_meta, in append_fragment_and_commit() argument
314 const wsrep::ws_meta& ws_meta) in commit() argument
369 const wsrep::ws_meta& ws_meta) in rollback() argument
378 assert(ws_meta == wsrep::ws_meta()); in rollback()
390 int Wsrep_high_priority_service::apply_toi(const wsrep::ws_meta& ws_meta, in apply_toi() argument
546 int Wsrep_applier_service::apply_write_set(const wsrep::ws_meta& ws_meta, in apply_write_set() argument
588 int Wsrep_applier_service::apply_nbo_begin(const wsrep::ws_meta& ws_meta, in apply_nbo_begin() argument
[all …]
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/sql/ |
| H A D | wsrep_high_priority_service.cc | 41 Wsrep_non_trans_mode(THD* thd, const wsrep::ws_meta& ws_meta) in Wsrep_non_trans_mode() argument
213 const wsrep::ws_handle& ws_handle, const wsrep::ws_meta& ws_meta) in start_transaction() argument
226 int Wsrep_high_priority_service::next_fragment(const wsrep::ws_meta& ws_meta) in next_fragment() argument
251 const wsrep::ws_meta& ws_meta, in append_fragment_and_commit() argument
314 const wsrep::ws_meta& ws_meta) in commit() argument
369 const wsrep::ws_meta& ws_meta) in rollback() argument
378 assert(ws_meta == wsrep::ws_meta()); in rollback()
390 int Wsrep_high_priority_service::apply_toi(const wsrep::ws_meta& ws_meta, in apply_toi() argument
546 int Wsrep_applier_service::apply_write_set(const wsrep::ws_meta& ws_meta, in apply_write_set() argument
588 int Wsrep_applier_service::apply_nbo_begin(const wsrep::ws_meta& ws_meta, in apply_nbo_begin() argument
[all …]
|
| /dports/databases/galera26/galera-release_26.4.10/wsrep/src/examples/node/ |
| H A D | trx.c | 34 wsrep_trx_meta_t ws_meta; in node_trx_execute() local
66 if (ws_meta.gtid.seqno > 0) in node_trx_execute()
68 ret = wsrep->commit_order_enter(wsrep, &ws_handle, &ws_meta); in node_trx_execute()
72 "%d", (long long)(ws_meta.gtid.seqno), ret); in node_trx_execute()
81 node_store_update_gtid(store, &ws_meta.gtid); in node_trx_execute()
87 "%d", (long long)(ws_meta.gtid.seqno), ret); in node_trx_execute()
116 const wsrep_trx_meta_t* const ws_meta, in node_trx_apply() argument
120 assert(ws_meta->gtid.seqno > 0); in node_trx_apply()
143 ret = wsrep->commit_order_enter(wsrep, ws_handle, ws_meta); in node_trx_apply()
149 if (!app_err) node_store_commit(store, trx_id, &ws_meta->gtid); in node_trx_apply()
[all …]
|
| /dports/databases/mariadb104-server/mariadb-10.4.24/wsrep-lib/wsrep-API/v26/examples/node/ |
| H A D | trx.c | 34 wsrep_trx_meta_t ws_meta; in node_trx_execute() local
66 if (ws_meta.gtid.seqno > 0) in node_trx_execute()
68 ret = wsrep->commit_order_enter(wsrep, &ws_handle, &ws_meta); in node_trx_execute()
72 "%d", (long long)(ws_meta.gtid.seqno), ret); in node_trx_execute()
81 node_store_update_gtid(store, &ws_meta.gtid); in node_trx_execute()
87 "%d", (long long)(ws_meta.gtid.seqno), ret); in node_trx_execute()
116 const wsrep_trx_meta_t* const ws_meta, in node_trx_apply() argument
120 assert(ws_meta->gtid.seqno > 0); in node_trx_apply()
143 ret = wsrep->commit_order_enter(wsrep, ws_handle, ws_meta); in node_trx_apply()
149 if (!app_err) node_store_commit(store, trx_id, &ws_meta->gtid); in node_trx_apply()
[all …]
|
| /dports/databases/mariadb104-client/mariadb-10.4.24/wsrep-lib/wsrep-API/v26/examples/node/ |
| H A D | trx.c | 34 wsrep_trx_meta_t ws_meta; in node_trx_execute() local
66 if (ws_meta.gtid.seqno > 0) in node_trx_execute()
68 ret = wsrep->commit_order_enter(wsrep, &ws_handle, &ws_meta); in node_trx_execute()
72 "%d", (long long)(ws_meta.gtid.seqno), ret); in node_trx_execute()
81 node_store_update_gtid(store, &ws_meta.gtid); in node_trx_execute()
87 "%d", (long long)(ws_meta.gtid.seqno), ret); in node_trx_execute()
116 const wsrep_trx_meta_t* const ws_meta, in node_trx_apply() argument
120 assert(ws_meta->gtid.seqno > 0); in node_trx_apply()
143 ret = wsrep->commit_order_enter(wsrep, ws_handle, ws_meta); in node_trx_apply()
149 if (!app_err) node_store_commit(store, trx_id, &ws_meta->gtid); in node_trx_apply()
[all …]
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/wsrep-lib/wsrep-API/v26/examples/node/ |
| H A D | trx.c | 34 wsrep_trx_meta_t ws_meta; in node_trx_execute() local
66 if (ws_meta.gtid.seqno > 0) in node_trx_execute()
68 ret = wsrep->commit_order_enter(wsrep, &ws_handle, &ws_meta); in node_trx_execute()
72 "%d", (long long)(ws_meta.gtid.seqno), ret); in node_trx_execute()
81 node_store_update_gtid(store, &ws_meta.gtid); in node_trx_execute()
87 "%d", (long long)(ws_meta.gtid.seqno), ret); in node_trx_execute()
116 const wsrep_trx_meta_t* const ws_meta, in node_trx_apply() argument
120 assert(ws_meta->gtid.seqno > 0); in node_trx_apply()
143 ret = wsrep->commit_order_enter(wsrep, ws_handle, ws_meta); in node_trx_apply()
149 if (!app_err) node_store_commit(store, trx_id, &ws_meta->gtid); in node_trx_apply()
[all …]
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/wsrep-lib/wsrep-API/v26/examples/node/ |
| H A D | trx.c | 34 wsrep_trx_meta_t ws_meta; in node_trx_execute() local
66 if (ws_meta.gtid.seqno > 0) in node_trx_execute()
68 ret = wsrep->commit_order_enter(wsrep, &ws_handle, &ws_meta); in node_trx_execute()
72 "%d", (long long)(ws_meta.gtid.seqno), ret); in node_trx_execute()
81 node_store_update_gtid(store, &ws_meta.gtid); in node_trx_execute()
87 "%d", (long long)(ws_meta.gtid.seqno), ret); in node_trx_execute()
116 const wsrep_trx_meta_t* const ws_meta, in node_trx_apply() argument
120 assert(ws_meta->gtid.seqno > 0); in node_trx_apply()
143 ret = wsrep->commit_order_enter(wsrep, ws_handle, ws_meta); in node_trx_apply()
149 if (!app_err) node_store_commit(store, trx_id, &ws_meta->gtid); in node_trx_apply()
[all …]
|