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

Disable streaming on client_state::close()

Browse Source
This commit is contained in:
Daniele Sciascia
2018-12-31 11:50:06 +01:00
parent 0441746368
commit a9e2fdccfc
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/client_state.cpp
View File

@ -54,6 +54,10 @@ void wsrep::client_state::close()
client_service_.bf_rollback(); client_service_.bf_rollback();
transaction_.after_statement(); transaction_.after_statement();
} }
if (mode_ == m_local)
{
disable_streaming();
}
debug_log_state("close: leave"); debug_log_state("close: leave");
} }
@ -277,7 +281,8 @@ int wsrep::client_state::enable_streaming(
void wsrep::client_state::disable_streaming() void wsrep::client_state::disable_streaming()
{ {
assert(state_ == s_exec && mode_ == m_local); assert(mode_ == m_local);
assert(state_ == s_exec || state_ == s_quitting);
transaction_.streaming_context().disable(); transaction_.streaming_context().disable();
} }