Lines Matching refs:downstream_queue_
118 downstream_queue_{downstream_queue_size(handler->get_worker()),
264 downstream_queue_.add_pending(std::move(downstream));
1512 for (auto d = downstream_queue_.get_downstreams(); d; d = d->dlnext) {
2337 if (downstream_queue_.can_activate(downstream->request().authority)) {
2342 downstream_queue_.mark_blocked(downstream);
2366 downstream_queue_.mark_failure(downstream);
2389 downstream_queue_.mark_failure(downstream);
2407 downstream_queue_.mark_failure(downstream);
2412 downstream_queue_.mark_active(downstream);
2785 auto next_downstream = downstream_queue_.remove_and_get_blocked(downstream);
2791 if (downstream_queue_.get_downstreams() == nullptr) {