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

Add debug logging to transaction::commit_or_rollback_by_xid

Browse Source
This commit is contained in:
Daniele Sciascia
2020-06-26 16:25:04 +02:00
parent 0172d0fe4f
commit 588166e183
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/transaction.cpp
View File

@ -1108,6 +1108,7 @@ int wsrep::transaction::restore_to_prepared_state(const wsrep::xid& xid)
int wsrep::transaction::commit_or_rollback_by_xid(const wsrep::xid& xid, int wsrep::transaction::commit_or_rollback_by_xid(const wsrep::xid& xid,
bool commit) bool commit)
{ {
debug_log_state("commit_or_rollback_by_xid enter");
wsrep::unique_lock<wsrep::mutex> lock(client_state_.mutex_); wsrep::unique_lock<wsrep::mutex> lock(client_state_.mutex_);
wsrep::server_state& server_state(client_state_.server_state()); wsrep::server_state& server_state(client_state_.server_state());
wsrep::high_priority_service* sa(server_state.find_streaming_applier(xid)); wsrep::high_priority_service* sa(server_state.find_streaming_applier(xid));
@ -1140,6 +1141,7 @@ int wsrep::transaction::commit_or_rollback_by_xid(const wsrep::xid& xid,
flags, flags,
meta)); meta));
int ret;
if (cert_ret == wsrep::provider::success) if (cert_ret == wsrep::provider::success)
{ {
if (commit) if (commit)
@ -1153,7 +1155,7 @@ int wsrep::transaction::commit_or_rollback_by_xid(const wsrep::xid& xid,
state(lock, s_aborting); state(lock, s_aborting);
state(lock, s_aborted); state(lock, s_aborted);
} }
return 0; ret = 0;
} }
else else
{ {
@ -1162,8 +1164,10 @@ int wsrep::transaction::commit_or_rollback_by_xid(const wsrep::xid& xid,
wsrep::log_error() << "Failed to commit_or_rollback_by_xid," wsrep::log_error() << "Failed to commit_or_rollback_by_xid,"
<< " xid: " << xid << " xid: " << xid
<< " error: " << cert_ret; << " error: " << cert_ret;
return 1; ret = 1;
} }
debug_log_state("commit_or_rollback_by_xid leave");
return ret;
} }
void wsrep::transaction::xa_detach() void wsrep::transaction::xa_detach()