Lines Matching refs:downstream_queue_
140 downstream_queue_.add_pending(std::move(downstream));
141 downstream_queue_.mark_active(ptr);
458 if (downstream_queue_.can_activate(downstream->request().authority)) {
463 downstream_queue_.mark_blocked(downstream);
486 downstream_queue_.mark_failure(downstream);
509 downstream_queue_.mark_failure(downstream);
527 downstream_queue_.mark_failure(downstream);
532 downstream_queue_.mark_active(downstream);
1024 downstream_queue_(downstream_queue_size(handler->get_worker()),
1625 downstream_queue_.add_pending(std::move(downstream));
1636 auto next_downstream = downstream_queue_.remove_and_get_blocked(downstream);
1642 if (downstream_queue_.get_downstreams() == nullptr) {
2051 for (auto d = downstream_queue_.get_downstreams(); d; d = d->dlnext) {
2345 downstream_queue_.mark_active(ptr);
2381 downstream_queue_.remove_and_get_blocked(promised_downstream, false);