Commit c0419e31 authored by Dominik Charousset's avatar Dominik Charousset

Tweak formatting for more consistency

parent 257a11d2
...@@ -120,8 +120,7 @@ behavior basp_broker::make_behavior() { ...@@ -120,8 +120,7 @@ behavior basp_broker::make_behavior() {
CAF_LOG_DEBUG("enable heartbeat" << CAF_ARG(heartbeat_interval)); CAF_LOG_DEBUG("enable heartbeat" << CAF_ARG(heartbeat_interval));
send(this, tick_atom::value, heartbeat_interval); send(this, tick_atom::value, heartbeat_interval);
} }
return { return behavior{
// received from underlying broker implementation // received from underlying broker implementation
[=](new_data_msg& msg) { [=](new_data_msg& msg) {
CAF_LOG_TRACE(CAF_ARG(msg.handle)); CAF_LOG_TRACE(CAF_ARG(msg.handle));
...@@ -148,8 +147,9 @@ behavior basp_broker::make_behavior() { ...@@ -148,8 +147,9 @@ behavior basp_broker::make_behavior() {
CAF_LOG_TRACE(CAF_ARG(src) CAF_LOG_TRACE(CAF_ARG(src)
<< CAF_ARG(dest) << CAF_ARG(mid) << CAF_ARG(msg)); << CAF_ARG(dest) << CAF_ARG(mid) << CAF_ARG(msg));
if (!dest || system().node() == dest->node()) { if (!dest || system().node() == dest->node()) {
CAF_LOG_WARNING( CAF_LOG_WARNING("cannot forward to invalid "
"cannot forward to invalid or local actor:" << CAF_ARG(dest)); "or local actor:"
<< CAF_ARG(dest));
return; return;
} }
if (src && system().node() == src->node()) if (src && system().node() == src->node())
......
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