Commit e3d02e56 authored by Dominik Charousset's avatar Dominik Charousset

Fix potential segfault

parent 568fb892
...@@ -1161,10 +1161,12 @@ scheduled_actor::advance_streams(actor_clock::time_point now) { ...@@ -1161,10 +1161,12 @@ scheduled_actor::advance_streams(actor_clock::time_point now) {
auto& qs = get_downstream_queue().queues(); auto& qs = get_downstream_queue().queues();
for (auto& kvp : qs) { for (auto& kvp : qs) {
auto inptr = kvp.second.policy().handler.get(); auto inptr = kvp.second.policy().handler.get();
if (inptr != nullptr) {
auto tts = static_cast<int32_t>(kvp.second.total_task_size()); auto tts = static_cast<int32_t>(kvp.second.total_task_size());
inptr->emit_ack_batch(this, tts, now, cycle); inptr->emit_ack_batch(this, tts, now, cycle);
} }
} }
}
return stream_ticks_.next_timeout(now, {max_batch_delay_ticks_, return stream_ticks_.next_timeout(now, {max_batch_delay_ticks_,
credit_round_ticks_}); credit_round_ticks_});
} }
......
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