Lines Matching refs:downstream
51 void DownstreamQueue::add_pending(std::unique_ptr<Downstream> downstream) {
52 downstream->set_dispatch_state(DispatchState::PENDING);
53 downstreams_.append(downstream.release());
56 void DownstreamQueue::mark_failure(Downstream *downstream) {
57 downstream->set_dispatch_state(DispatchState::FAILURE);
82 StringRef DownstreamQueue::make_host_key(Downstream *downstream) const {
83 return make_host_key(downstream->request().authority);
86 void DownstreamQueue::mark_active(Downstream *downstream) {
87 auto &ent = find_host_entry(make_host_key(downstream));
90 downstream->set_dispatch_state(DispatchState::ACTIVE);
93 void DownstreamQueue::mark_blocked(Downstream *downstream) {
94 auto &ent = find_host_entry(make_host_key(downstream));
96 downstream->set_dispatch_state(DispatchState::BLOCKED);
99 downstream->attach_blocked_link(link);
124 Downstream *DownstreamQueue::remove_and_get_blocked(Downstream *downstream,
126 // Delete downstream when this function returns.
127 auto delptr = std::unique_ptr<Downstream>(downstream);
129 downstreams_.remove(downstream);
131 auto host = make_host_key(downstream);
134 if (downstream->get_dispatch_state() == DispatchState::ACTIVE) {
138 auto link = downstream->detach_blocked_link();
159 auto next_downstream = link->downstream;