Commit ceb54c2d authored by Dominik Charousset's avatar Dominik Charousset

Fix log statement

parent 4febfcb1
...@@ -111,7 +111,7 @@ void inbound_path::emit_ack_batch(local_actor* self, long queued_items, ...@@ -111,7 +111,7 @@ void inbound_path::emit_ack_batch(local_actor* self, long queued_items,
desired_batch_size = static_cast<int32_t>(x.items_per_batch); desired_batch_size = static_cast<int32_t>(x.items_per_batch);
if (credit != 0) if (credit != 0)
assigned_credit += credit; assigned_credit += credit;
CAF_LOG_DEBUG(CAF_ARG(credit) << CAF_ARG(batch_size)); CAF_LOG_DEBUG(CAF_ARG(credit) << CAF_ARG(desired_batch_size));
unsafe_send_as(self, hdl, unsafe_send_as(self, hdl,
make<upstream_msg::ack_batch>(slots.invert(), make<upstream_msg::ack_batch>(slots.invert(),
self->address(), self->address(),
......
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