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

Check if client was interrupted before fragment replication

Browse Source
This commit is contained in:
Daniele Sciascia
2018-12-21 14:23:19 +01:00
parent 653d2526eb
commit cc67313515
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/transaction.cpp
View File

@ -1039,6 +1039,14 @@ int wsrep::transaction::certify_fragment(
lock.unlock(); lock.unlock();
if (client_service_.interrupted())
{
lock.lock();
state(lock, s_must_abort);
client_state_.override_error(wsrep::e_interrupted_error);
return 1;
}
wsrep::mutable_buffer data; wsrep::mutable_buffer data;
if (client_service_.prepare_fragment_for_replication(data)) if (client_service_.prepare_fragment_for_replication(data))
{ {