Commit 1ad06ce2 authored by Dominik Charousset's avatar Dominik Charousset

Clear pending responses in local_actor::cleanup

parent 98f05215
...@@ -155,9 +155,7 @@ void local_actor::request_sync_timeout_msg(const duration& d, message_id mid) { ...@@ -155,9 +155,7 @@ void local_actor::request_sync_timeout_msg(const duration& d, message_id mid) {
if (! d.valid()) { if (! d.valid()) {
return; return;
} }
auto sched_cd = detail::singletons::get_scheduling_coordinator(); delayed_send_impl(mid, this, d, make_message(sync_timeout_msg{}));
sched_cd->delayed_send(d, address(), this, mid,
make_message(sync_timeout_msg{}));
} }
void local_actor::handle_timeout(behavior& bhvr, uint32_t timeout_id) { void local_actor::handle_timeout(behavior& bhvr, uint32_t timeout_id) {
...@@ -844,6 +842,7 @@ void local_actor::cleanup(uint32_t reason) { ...@@ -844,6 +842,7 @@ void local_actor::cleanup(uint32_t reason) {
CAF_LOG_TRACE(CAF_ARG(reason)); CAF_LOG_TRACE(CAF_ARG(reason));
detail::sync_request_bouncer f{reason}; detail::sync_request_bouncer f{reason};
mailbox_.close(f); mailbox_.close(f);
pending_responses_.clear();
abstract_actor::cleanup(reason); abstract_actor::cleanup(reason);
// tell registry we're done // tell registry we're done
is_registered(false); is_registered(false);
......
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