lib/wsrep-lib
1
0
Fork 0
mirror of https://github.com/codership/wsrep-lib.git synced 2026-10-23 09:48:57 +03:00
Code Activity

enter_toi polling fix

Browse Source
This commit is contained in:
Leandro Pacheco
2019-09-19 10:03:39 -03:00
parent ac9f13b05f
commit 23b2b9d3ee
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/client_state.cpp
View File

@@ -349,12 +349,14 @@ wsrep::client_state::poll_enter_toi(
<< wait_until.time_since_epoch().count());
enum wsrep::provider::status status;
timed_out = false;
wsrep::ws_meta poll_meta; // tmp var for polling, as enter_toi may clear meta arg on errors
do
{
lock.unlock();
status = provider().enter_toi(id_, keys, buffer, meta, flags);
poll_meta = meta;
status = provider().enter_toi(id_, keys, buffer, poll_meta, flags);
if (status != wsrep::provider::success &&
not toi_meta_.gtid().is_undefined())
not poll_meta.gtid().is_undefined())
{
// Successfully entered TOI, but the provider reported failure.
// This may happen for example if certification fails.
@@ -365,7 +367,7 @@ wsrep::client_state::poll_enter_toi(
<< "Failed to leave TOI after failure in "
<< "poll_enter_toi()";
}
toi_meta_ = wsrep::ws_meta();
poll_meta = wsrep::ws_meta();
}
if (status == wsrep::provider::error_certification_failed ||
status == wsrep::provider::error_connection_failed)
@@ -380,6 +382,7 @@ wsrep::client_state::poll_enter_toi(
status == wsrep::provider::error_connection_failed) &&
not timed_out &&
not client_service_.interrupted(lock));
meta = poll_meta;
return status;
}