Commit 8b47ed51 authored by Dominik Charousset's avatar Dominik Charousset

Fix debug build

parent b23bf288
...@@ -337,7 +337,7 @@ resumable::resume_result scheduled_actor::resume(execution_unit* ctx, ...@@ -337,7 +337,7 @@ resumable::resume_result scheduled_actor::resume(execution_unit* ctx,
return run_with_metrics(x, [this, max_throughput, &consumed, &q, &x] { return run_with_metrics(x, [this, max_throughput, &consumed, &q, &x] {
current_mailbox_element(&x); current_mailbox_element(&x);
CAF_LOG_RECEIVE_EVENT((&x)); CAF_LOG_RECEIVE_EVENT((&x));
CAF_BEFORE_PROCESSING(self, x); CAF_BEFORE_PROCESSING(this, x);
CAF_ASSERT(x.content().match_elements<downstream_msg>()); CAF_ASSERT(x.content().match_elements<downstream_msg>());
auto& dm = x.content().get_mutable_as<downstream_msg>(0); auto& dm = x.content().get_mutable_as<downstream_msg>(0);
auto f = [&, this](auto& content) { auto f = [&, this](auto& content) {
...@@ -383,7 +383,7 @@ resumable::resume_result scheduled_actor::resume(execution_unit* ctx, ...@@ -383,7 +383,7 @@ resumable::resume_result scheduled_actor::resume(execution_unit* ctx,
return intrusive::task_result::resume; return intrusive::task_result::resume;
}; };
auto res = visit(f, dm.content); auto res = visit(f, dm.content);
CAF_AFTER_PROCESSING(self, invoke_message_result::consumed); CAF_AFTER_PROCESSING(this, invoke_message_result::consumed);
return ++consumed < max_throughput ? res return ++consumed < max_throughput ? res
: intrusive::task_result::stop_all; : intrusive::task_result::stop_all;
}); });
......
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