Commit ac6b8041 authored by Dominik Charousset's avatar Dominik Charousset

Properly clean up state in MM actor, close #686

parent 693f0476
...@@ -71,6 +71,12 @@ middleman_actor_impl::middleman_actor_impl(actor_config& cfg, ...@@ -71,6 +71,12 @@ middleman_actor_impl::middleman_actor_impl(actor_config& cfg,
void middleman_actor_impl::on_exit() { void middleman_actor_impl::on_exit() {
CAF_LOG_TRACE(""); CAF_LOG_TRACE("");
broker_ = nullptr; broker_ = nullptr;
cached_tcp_.clear();
cached_udp_.clear();
for (auto& kvp : pending_)
for (auto& promise : kvp.second)
promise.deliver(make_error(sec::cannot_connect_to_node));
pending_.clear();
} }
const char* middleman_actor_impl::name() const { const char* middleman_actor_impl::name() const {
......
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