From a9e2fdccfc49202aea6110ec98d44717d282d79e Mon Sep 17 00:00:00 2001 From: Daniele Sciascia Date: Mon, 31 Dec 2018 11:50:06 +0100 Subject: [PATCH] Disable streaming on client_state::close() --- src/client_state.cpp | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/src/client_state.cpp b/src/client_state.cpp index f3ce728..4c96b87 100644 --- a/src/client_state.cpp +++ b/src/client_state.cpp @@ -54,6 +54,10 @@ void wsrep::client_state::close() client_service_.bf_rollback(); transaction_.after_statement(); } + if (mode_ == m_local) + { + disable_streaming(); + } debug_log_state("close: leave"); } @@ -277,7 +281,8 @@ int wsrep::client_state::enable_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(); }