Lines Matching refs:ent
46 auto &ent = p.second; in ~DownstreamQueue() local
47 dlist_delete_all(ent.blocked); in ~DownstreamQueue()
87 auto &ent = find_host_entry(make_host_key(downstream)); in mark_active() local
88 ++ent.num_active; in mark_active()
94 auto &ent = find_host_entry(make_host_key(downstream)); in mark_blocked() local
100 ent.blocked.append(link); in mark_blocked()
108 auto &ent = (*itr).second; in can_activate() local
109 return ent.num_active < conn_max_per_host_; in can_activate()
113 bool remove_host_entry_if_empty(const DownstreamQueue::HostEntry &ent, in remove_host_entry_if_empty() argument
116 if (ent.blocked.empty() && ent.num_active == 0) { in remove_host_entry_if_empty()
132 auto &ent = find_host_entry(host); in remove_and_get_blocked() local
135 --ent.num_active; in remove_and_get_blocked()
140 ent.blocked.remove(link); in remove_and_get_blocked()
145 if (remove_host_entry_if_empty(ent, host_entries_, host)) { in remove_and_get_blocked()
149 if (!next_blocked || ent.num_active >= conn_max_per_host_) { in remove_and_get_blocked()
153 auto link = ent.blocked.head; in remove_and_get_blocked()
164 ent.blocked.remove(link); in remove_and_get_blocked()
166 remove_host_entry_if_empty(ent, host_entries_, host); in remove_and_get_blocked()