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