Commit b85e2d99 authored by Dominik Charousset's avatar Dominik Charousset

catch redundant KILL_PROXY messages

parent a306fff8
...@@ -157,11 +157,16 @@ void remote_actor_proxy::enqueue(msg_hdr_cref hdr, any_tuple msg, ...@@ -157,11 +157,16 @@ void remote_actor_proxy::enqueue(msg_hdr_cref hdr, any_tuple msg,
"enqueue$kill_proxy_helper", "enqueue$kill_proxy_helper",
"KILL_PROXY " << to_string(_this->address()) "KILL_PROXY " << to_string(_this->address())
<< " with exit reason " << reason); << " with exit reason " << reason);
if (_this->m_pending_requests.closed()) {
CPPA_LOG_WARNING("received KILL_PROXY twice");
}
else {
_this->cleanup(reason); _this->cleanup(reason);
detail::sync_request_bouncer f{reason}; detail::sync_request_bouncer f{reason};
_this->m_pending_requests.close([&](const sync_request_info& e) { _this->m_pending_requests.close([&](const sync_request_info& e) {
f(e.sender, e.mid); f(e.sender, e.mid);
}); });
}
}); });
} }
else forward_msg(hdr, move(msg)); else forward_msg(hdr, move(msg));
......
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