Commit a32890db authored by Dominik Charousset's avatar Dominik Charousset

Log whenever a stream handler is removed

parent b71aa335
...@@ -650,6 +650,7 @@ bool scheduled_actor::finalize() { ...@@ -650,6 +650,7 @@ bool scheduled_actor::finalize() {
bool scheduled_actor::handle_stream_msg(mailbox_element& x, bool scheduled_actor::handle_stream_msg(mailbox_element& x,
behavior* active_behavior) { behavior* active_behavior) {
CAF_LOG_TRACE(CAF_ARG(x));
CAF_ASSERT(x.content().match_elements<stream_msg>()); CAF_ASSERT(x.content().match_elements<stream_msg>());
auto& sm = x.content().get_mutable_as<stream_msg>(0); auto& sm = x.content().get_mutable_as<stream_msg>(0);
auto e = streams_.end(); auto e = streams_.end();
...@@ -665,6 +666,9 @@ bool scheduled_actor::handle_stream_msg(mailbox_element& x, ...@@ -665,6 +666,9 @@ bool scheduled_actor::handle_stream_msg(mailbox_element& x,
} else if (i != e) { } else if (i != e) {
if (i->second->done()) { if (i->second->done()) {
streams_.erase(i); streams_.erase(i);
CAF_LOG_DEBUG("Stream is done and could be safely erased"
<< CAF_ARG(sm.sid) << ", remaining streams ="
<< deep_to_string(streams_).c_str());
if (streams_.empty() && !has_behavior()) if (streams_.empty() && !has_behavior())
quit(exit_reason::normal); quit(exit_reason::normal);
} }
......
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