Searched refs:wgpq (Results 1 – 2 of 2) sorted by relevance
926 auto &wgpq = shared_addr->pq; in get_downstream_addr() local929 if (wgpq.empty()) { in get_downstream_addr()935 auto wg = wgpq.top().wg; in get_downstream_addr()936 wgpq.pop(); in get_downstream_addr()953 reschedule_wg(wgpq, wg); in get_downstream_addr()
211 WeightGroupEntryGreater> &wgpq, in ensure_enqueue_addr() argument227 if (!wgpq.empty()) { in ensure_enqueue_addr()228 auto &top = wgpq.top(); in ensure_enqueue_addr()236 wgpq.push(WeightGroupEntry{wg, wg->seq, wg->cycle}); in ensure_enqueue_addr()