lib/wsrep-lib
1
0
Fork 0
mirror of https://github.com/codership/wsrep-lib.git synced 2025-07-31 18:24:25 +03:00
Code Activity

Added aborted parameter for set_position() method

Browse Source
This commit is contained in:
sjaakola
2020-04-15 23:41:46 +03:00
parent d0255569b0
commit b0f2bca2db
5 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
dbsim/db_server_service.cpp
View File

@ -145,7 +145,8 @@ wsrep::gtid db::server_service::get_position(wsrep::client_service&)
} }
void db::server_service::set_position(wsrep::client_service&, void db::server_service::set_position(wsrep::client_service&,
const wsrep::gtid& gtid) const wsrep::gtid& gtid,
bool)
{ {
return server_.storage_engine().store_position(gtid); return server_.storage_engine().store_position(gtid);
} }

2
dbsim/db_server_service.hpp
View File

@ -53,7 +53,7 @@ namespace db
wsrep::view get_view(wsrep::client_service&, const wsrep::id&) wsrep::view get_view(wsrep::client_service&, const wsrep::id&)
override; override;
wsrep::gtid get_position(wsrep::client_service&) override; wsrep::gtid get_position(wsrep::client_service&) override;
void set_position(wsrep::client_service&, const wsrep::gtid&) override; void set_position(wsrep::client_service&, const wsrep::gtid&, bool) override;
void log_state_change(enum wsrep::server_state::state, void log_state_change(enum wsrep::server_state::state,
enum wsrep::server_state::state) override; enum wsrep::server_state::state) override;
int wait_committing_transactions(int) override; int wait_committing_transactions(int) override;

3
include/wsrep/server_service.hpp
View File

@ -190,7 +190,8 @@ namespace wsrep
*/ */
virtual void set_position( virtual void set_position(
wsrep::client_service& client_service, wsrep::client_service& client_service,
const wsrep::gtid& gtid) = 0; const wsrep::gtid& gtid,
bool aborted) = 0;
/** /**
* Log a state change event. * Log a state change event.

3
src/transaction.cpp
View File

@ -760,7 +760,8 @@ int wsrep::transaction::release_commit_order(
lock.lock(); lock.lock();
if (!ret) if (!ret)
{ {
server_service_.set_position(client_service_, ws_meta_.gtid()); server_service_.set_position(client_service_, ws_meta_.gtid(),
(state() == s_aborted));
ret = provider().commit_order_leave(ws_handle_, ws_meta_, ret = provider().commit_order_leave(ws_handle_, ws_meta_,
apply_error_buf_); apply_error_buf_);
} }

3
test/mock_server_state.hpp
View File

@ -158,7 +158,8 @@ namespace wsrep
} }
void set_position(wsrep::client_service&, void set_position(wsrep::client_service&,
const wsrep::gtid& gtid) WSREP_OVERRIDE const wsrep::gtid& gtid,
bool) WSREP_OVERRIDE
{ {
position_ = gtid; position_ = gtid;
} }