Lines Matching refs:wg
213 WeightGroup *wg, DownstreamAddr *addr) {
215 if (!wg->pq.empty()) {
216 auto &top = wg->pq.top();
224 wg->pq.push(DownstreamAddrEntry{addr, addr->seq, addr->cycle});
227 if (!wg->queued) {
235 wg->cycle = cycle;
236 wg->pending_penalty = 0;
237 wgpq.push(WeightGroupEntry{wg, wg->seq, wg->cycle});
238 wg->queued = true;
347 if (!addr.wg) {
350 ensure_enqueue_addr(shared_addr_ptr->pq, addr.wg, &addr);
381 auto &wg = wgs[addr.group];
382 if (wg == nullptr) {
383 wg = &shared_addr->wgs[--num_wgs];
384 wg->seq = num_wgs;
387 wg->weight = addr.group_weight;
388 wg->pq.push(DownstreamAddrEntry{&addr, addr.seq, addr.cycle});
390 addr.wg = wg;