Lines Matching refs:DownstreamQueue
34 DownstreamQueue::HostEntry::HostEntry(ImmutableString &&key) in HostEntry()
37 DownstreamQueue::DownstreamQueue(size_t conn_max_per_host, bool unified_host) in DownstreamQueue() function in shrpx::DownstreamQueue
43 DownstreamQueue::~DownstreamQueue() { in ~DownstreamQueue()
51 void DownstreamQueue::add_pending(std::unique_ptr<Downstream> downstream) { in add_pending()
56 void DownstreamQueue::mark_failure(Downstream *downstream) { in mark_failure()
60 DownstreamQueue::HostEntry &
61 DownstreamQueue::find_host_entry(const StringRef &host) { in find_host_entry()
78 StringRef DownstreamQueue::make_host_key(const StringRef &host) const { in make_host_key()
82 StringRef DownstreamQueue::make_host_key(Downstream *downstream) const { in make_host_key()
86 void DownstreamQueue::mark_active(Downstream *downstream) { in mark_active()
93 void DownstreamQueue::mark_blocked(Downstream *downstream) { in mark_blocked()
103 bool DownstreamQueue::can_activate(const StringRef &host) const { in can_activate()
113 bool remove_host_entry_if_empty(const DownstreamQueue::HostEntry &ent, in remove_host_entry_if_empty()
114 DownstreamQueue::HostEntryMap &host_entries, in remove_host_entry_if_empty()
124 Downstream *DownstreamQueue::remove_and_get_blocked(Downstream *downstream, in remove_and_get_blocked()
171 Downstream *DownstreamQueue::get_downstreams() const { in get_downstreams()