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

Fix build with profiling enabled

parent 24635441
...@@ -563,10 +563,10 @@ public: ...@@ -563,10 +563,10 @@ public:
profiler_->remove_actor(self); profiler_->remove_actor(self);
} }
void profiler_before_processing(const local_actor& self, template <class... Ts>
const mailbox_element& element) { void profiler_before_processing(const local_actor& self, Ts&&... xs) {
if (profiler_) if (profiler_)
profiler_->before_processing(self, element); profiler_->before_processing(self, std::forward<Ts>(xs)...);
} }
void profiler_after_processing(const local_actor& self, void profiler_after_processing(const local_actor& self,
......
...@@ -140,7 +140,7 @@ void blocking_actor::receive_response(message_id id, ...@@ -140,7 +140,7 @@ void blocking_actor::receive_response(message_id id,
if (id != x.mid) if (id != x.mid)
return intrusive::task_result::skip; return intrusive::task_result::skip;
CAF_LOG_RECEIVE_EVENT((&x)); CAF_LOG_RECEIVE_EVENT((&x));
CAF_BEFORE_PROCESSING(self, x, id, send_time); CAF_BEFORE_PROCESSING(this, x, id, send_time);
// Blocking actors can nest receives => push/pop `current_element_` // Blocking actors can nest receives => push/pop `current_element_`
auto prev = current_element_; auto prev = current_element_;
current_element_ = &x; current_element_ = &x;
......
...@@ -63,7 +63,7 @@ invoke_message_result raw_event_based_actor::consume(mailbox_element& x) { ...@@ -63,7 +63,7 @@ invoke_message_result raw_event_based_actor::consume(mailbox_element& x) {
return invoke_message_result::dropped; return invoke_message_result::dropped;
} }
CAF_LOG_RECEIVE_EVENT(current_element_); CAF_LOG_RECEIVE_EVENT(current_element_);
CAF_BEFORE_PROCESSING(this, x, mrh->first, mrth->second.send_time); CAF_BEFORE_PROCESSING(this, x, mrh->first, mrh->second.send_time);
auto bhvr = std::move(mrh->second.bhvr); auto bhvr = std::move(mrh->second.bhvr);
multiplexed_responses_.erase(mrh); multiplexed_responses_.erase(mrh);
if (!invoke(bhvr, x)) { if (!invoke(bhvr, x)) {
......
...@@ -665,7 +665,7 @@ invoke_message_result scheduled_actor::consume(mailbox_element& x) { ...@@ -665,7 +665,7 @@ invoke_message_result scheduled_actor::consume(mailbox_element& x) {
return invoke_message_result::dropped; return invoke_message_result::dropped;
} }
CAF_LOG_RECEIVE_EVENT(current_element_); CAF_LOG_RECEIVE_EVENT(current_element_);
CAF_BEFORE_PROCESSING(this, x, mrh->first, mrth->second.send_time); CAF_BEFORE_PROCESSING(this, x, mrh->first, mrh->second.send_time);
auto bhvr = std::move(mrh->second.bhvr); auto bhvr = std::move(mrh->second.bhvr);
multiplexed_responses_.erase(mrh); multiplexed_responses_.erase(mrh);
if (!invoke(bhvr, x)) { if (!invoke(bhvr, x)) {
......
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