Searched refs:downstream_queue_ (Results 1 – 4 of 4) sorted by relevance
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()[all …]
118 downstream_queue_{downstream_queue_size(handler->get_worker()),264 downstream_queue_.add_pending(std::move(downstream)); in add_pending_downstream()1493 for (auto d = downstream_queue_.get_downstreams(); d; d = d->dlnext) { in on_handler_delete()2320 if (downstream_queue_.can_activate(downstream->request().authority)) { in start_downstream()2325 downstream_queue_.mark_blocked(downstream); in start_downstream()2349 downstream_queue_.mark_failure(downstream); in initiate_downstream()2372 downstream_queue_.mark_failure(downstream); in initiate_downstream()2390 downstream_queue_.mark_failure(downstream); in initiate_downstream()2395 downstream_queue_.mark_active(downstream); in initiate_downstream()2768 auto next_downstream = downstream_queue_.remove_and_get_blocked(downstream); in remove_downstream()[all …]
134 DownstreamQueue downstream_queue_; variable
168 DownstreamQueue downstream_queue_; variable