downstream_queue_ (reference) in projects: third_party - OpenGrok search results

Repository(s)

Full Search		Search through all text tokens(words,strings,identifiers,numbers) in index.
Definition		Only finds symbol definitions(where e.g a variable(function,...) is defined).
Symbol		Only finds symbol(e.g. methods classes,function,variables).
File Path		Path of the source file(use "/").If you want just exact path,enclose it in "".Source files end with: .jar/.bz2/.a/.h/.java...
History		History log comments.
Type		Type of analyzer used to filter file types include with selected(e.g. just C sources).

Help

Searched refs:downstream_queue_ (Results 1 - 4 of 4) sorted by relevance

/third_party/nghttp2/src/
H A D	shrpx_http2_upstream.cc	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_ in add_pending_downstream() [all...]
H A D	shrpx_http3_upstream.cc	118 downstream_queue_{downstream_queue_size(handler->get_worker()), 264 downstream_queue_.add_pending(std::move(downstream)); in add_pending_downstream() 1512 for (auto d = downstream_queue_.get_downstreams(); d; d = d->dlnext) { in on_handler_delete() 2337 if (downstream_queue_.can_activate(downstream->request().authority)) { in start_downstream() 2342 downstream_queue_.mark_blocked(downstream); in start_downstream() 2366 downstream_queue_.mark_failure(downstream); in initiate_downstream() 2389 downstream_queue_.mark_failure(downstream); in initiate_downstream() 2407 downstream_queue_.mark_failure(downstream); in initiate_downstream() 2412 downstream_queue_.mark_active(downstream); in initiate_downstream() 2785 auto next_downstream = downstream_queue_ in remove_downstream() [all...]
H A D	shrpx_http2_upstream.h	`134 DownstreamQueue downstream_queue_; member in shrpx::Http2Upstream`
H A D	shrpx_http3_upstream.h	`170 DownstreamQueue downstream_queue_; member in shrpx::Http3Upstream`

Completed in 8 milliseconds