Commit 6a73baa0 authored by Dominik Charousset's avatar Dominik Charousset

maintenance

parent 2d0fb731
...@@ -111,6 +111,7 @@ void abstract_event_based_actor::resume(util::fiber*, resume_callback* callback) ...@@ -111,6 +111,7 @@ void abstract_event_based_actor::resume(util::fiber*, resume_callback* callback)
{ {
if (m_loop_stack.empty()) if (m_loop_stack.empty())
{ {
cleanup(exit_reason::normal);
done_cb(); done_cb();
return; return;
} }
......
...@@ -171,7 +171,7 @@ auto abstract_scheduled_actor::filter_msg(any_tuple const& msg) -> filter_result ...@@ -171,7 +171,7 @@ auto abstract_scheduled_actor::filter_msg(any_tuple const& msg) -> filter_result
} }
auto abstract_scheduled_actor::dq(queue_node& node, auto abstract_scheduled_actor::dq(queue_node& node,
partial_function& rules) -> dq_result partial_function& fun) -> dq_result
{ {
if (node.marked) return dq_indeterminate; if (node.marked) return dq_indeterminate;
switch (filter_msg(node.msg)) switch (filter_msg(node.msg))
...@@ -201,7 +201,7 @@ auto abstract_scheduled_actor::dq(queue_node& node, ...@@ -201,7 +201,7 @@ auto abstract_scheduled_actor::dq(queue_node& node,
// make sure nested receives do not process this node again // make sure nested receives do not process this node again
queue_node_guard qguard{&node}; queue_node_guard qguard{&node};
// try to invoke given function // try to invoke given function
if (rules(m_last_dequeued)) if (fun(m_last_dequeued))
{ {
// client erases node later (keep it marked until it's removed) // client erases node later (keep it marked until it's removed)
qguard.release(); qguard.release();
......
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