Commit e14558b0 authored by Dominik Charousset's avatar Dominik Charousset

Respect shutdown mode in I/O servants

parent 54164c1d
...@@ -92,7 +92,8 @@ protected: ...@@ -92,7 +92,8 @@ protected:
invoke_mailbox_element_impl(ctx, value_); invoke_mailbox_element_impl(ctx, value_);
// only consume an activity token if actor did not produce them now // only consume an activity token if actor did not produce them now
if (prev && activity_tokens_ && --(*activity_tokens_) == 0) { if (prev && activity_tokens_ && --(*activity_tokens_) == 0) {
if (this->parent()->getf(abstract_actor::is_terminated_flag)) if (this->parent()->getf(abstract_actor::is_shutting_down_flag
| abstract_actor::is_terminated_flag))
return false; return false;
// tell broker it entered passive mode, this can result in // tell broker it entered passive mode, this can result in
// producing, why we check the condition again afterwards // producing, why we check the condition again afterwards
......
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