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