Commit bd99269f authored by Dominik Charousset's avatar Dominik Charousset

Fix constant used for credit generation

parent 8ef9851e
......@@ -124,7 +124,7 @@ void stream_manager::advance() {
using std::chrono::microseconds;
auto& cfg = self_->system().config();
microseconds bc{cfg.streaming_desired_batch_complexity_us};
microseconds interval{cfg.streaming_tick_duration_us()};
microseconds interval{cfg.streaming_credit_round_interval_us};
auto& mbox = self_->mailbox();
auto& qs = get<2>(mbox.queue().queues()).queues();
// Iterate all queues for inbound traffic.
......
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