Commit a7b2af12 authored by Dominik Charousset's avatar Dominik Charousset Committed by GitHub

Merge pull request #500 from ufownl/topic/fix_broker_quit_flow

Fix broker quit flow
parents 177277d6 4f733a59
...@@ -56,8 +56,14 @@ void manager::detach(execution_unit*, bool invoke_disconnect_message) { ...@@ -56,8 +56,14 @@ void manager::detach(execution_unit*, bool invoke_disconnect_message) {
if (invoke_disconnect_message) { if (invoke_disconnect_message) {
auto mptr = make_mailbox_element(nullptr, invalid_message_id, auto mptr = make_mailbox_element(nullptr, invalid_message_id,
{}, detach_message()); {}, detach_message());
if (raw_ptr->consume(*mptr) == im_skipped) switch (raw_ptr->consume(*mptr)) {
raw_ptr->push_to_cache(std::move(mptr)); case im_success:
raw_ptr->finalize();
break;
case im_skipped:
raw_ptr->push_to_cache(std::move(mptr));
break;
}
} }
} }
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment