Commit 1003c017 authored by Dominik Charousset's avatar Dominik Charousset

Log extra information in caf.flow ACCEPT

parent ac2aa8f1
...@@ -489,8 +489,9 @@ inline caf::actor_id caf_set_aid_dummy() { return 0; } ...@@ -489,8 +489,9 @@ inline caf::actor_id caf_set_aid_dummy() { return 0; }
#define CAF_LOG_REJECT_EVENT() \ #define CAF_LOG_REJECT_EVENT() \
CAF_LOG_IMPL(CAF_LOG_FLOW_COMPONENT, CAF_LOG_LEVEL_DEBUG, "REJECT") CAF_LOG_IMPL(CAF_LOG_FLOW_COMPONENT, CAF_LOG_LEVEL_DEBUG, "REJECT")
#define CAF_LOG_ACCEPT_EVENT() \ #define CAF_LOG_ACCEPT_EVENT(unblocked) \
CAF_LOG_IMPL(CAF_LOG_FLOW_COMPONENT, CAF_LOG_LEVEL_DEBUG, "ACCEPT") CAF_LOG_IMPL(CAF_LOG_FLOW_COMPONENT, CAF_LOG_LEVEL_DEBUG, \
"ACCEPT ; UNBLOCKED =" << unblocked)
#define CAF_LOG_DROP_EVENT() \ #define CAF_LOG_DROP_EVENT() \
CAF_LOG_IMPL(CAF_LOG_FLOW_COMPONENT, CAF_LOG_LEVEL_DEBUG, "DROP") CAF_LOG_IMPL(CAF_LOG_FLOW_COMPONENT, CAF_LOG_LEVEL_DEBUG, "DROP")
......
...@@ -75,7 +75,7 @@ void blocking_actor::enqueue(mailbox_element_ptr ptr, execution_unit*) { ...@@ -75,7 +75,7 @@ void blocking_actor::enqueue(mailbox_element_ptr ptr, execution_unit*) {
srb(src, mid); srb(src, mid);
} }
} else { } else {
CAF_LOG_ACCEPT_EVENT(); CAF_LOG_ACCEPT_EVENT(false);
} }
} }
......
...@@ -128,7 +128,7 @@ void scheduled_actor::enqueue(mailbox_element_ptr ptr, execution_unit* eu) { ...@@ -128,7 +128,7 @@ void scheduled_actor::enqueue(mailbox_element_ptr ptr, execution_unit* eu) {
auto sender = ptr->sender; auto sender = ptr->sender;
switch (mailbox().enqueue(ptr.release())) { switch (mailbox().enqueue(ptr.release())) {
case detail::enqueue_result::unblocked_reader: { case detail::enqueue_result::unblocked_reader: {
CAF_LOG_ACCEPT_EVENT(); CAF_LOG_ACCEPT_EVENT(true);
// add a reference count to this actor and re-schedule it // add a reference count to this actor and re-schedule it
intrusive_ptr_add_ref(ctrl()); intrusive_ptr_add_ref(ctrl());
if (getf(is_detached_flag)) { if (getf(is_detached_flag)) {
...@@ -152,7 +152,7 @@ void scheduled_actor::enqueue(mailbox_element_ptr ptr, execution_unit* eu) { ...@@ -152,7 +152,7 @@ void scheduled_actor::enqueue(mailbox_element_ptr ptr, execution_unit* eu) {
} }
case detail::enqueue_result::success: case detail::enqueue_result::success:
// enqueued to a running actors' mailbox; nothing to do // enqueued to a running actors' mailbox; nothing to do
CAF_LOG_ACCEPT_EVENT(); CAF_LOG_ACCEPT_EVENT(false);
break; break;
} }
} }
......
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