diff --git a/src/server_state.cpp b/src/server_state.cpp index 79a720b..f07de3d 100644 --- a/src/server_state.cpp +++ b/src/server_state.cpp @@ -251,7 +251,11 @@ static int rollback_fragment(wsrep::server_state& server_state, { ret = high_priority_service.remove_fragments(ws_meta); ret = ret || high_priority_service.commit(ws_handle, ws_meta); - ret = ret || (high_priority_service.after_apply(), 0); + if (ret) + { + high_priority_service.rollback(ws_handle, ws_meta); + } + high_priority_service.after_apply(); } else {