Lines Matching refs:in_serv_agg
184 struct qfq_aggregate *in_serv_agg; /* Aggregate being served. */ member
325 cl && q->in_serv_agg != agg) /* agg was inactive */ in qfq_add_to_agg()
339 if (q->in_serv_agg == agg) in qfq_destroy_agg()
340 q->in_serv_agg = qfq_choose_next_agg(q); in qfq_destroy_agg()
1088 struct qfq_aggregate *in_serv_agg = q->in_serv_agg; in qfq_dequeue() local
1094 if (in_serv_agg == NULL) in qfq_dequeue()
1097 if (!list_empty(&in_serv_agg->active)) in qfq_dequeue()
1098 skb = qfq_peek_skb(in_serv_agg, &cl, &len); in qfq_dequeue()
1105 if (len == 0 || in_serv_agg->budget < len) { in qfq_dequeue()
1106 charge_actual_service(in_serv_agg); in qfq_dequeue()
1109 in_serv_agg->initial_budget = in_serv_agg->budget = in qfq_dequeue()
1110 in_serv_agg->budgetmax; in qfq_dequeue()
1112 if (!list_empty(&in_serv_agg->active)) { in qfq_dequeue()
1123 qfq_update_agg_ts(q, in_serv_agg, requeue); in qfq_dequeue()
1124 qfq_schedule_agg(q, in_serv_agg); in qfq_dequeue()
1126 q->in_serv_agg = NULL; in qfq_dequeue()
1134 in_serv_agg = q->in_serv_agg = qfq_choose_next_agg(q); in qfq_dequeue()
1135 skb = qfq_peek_skb(in_serv_agg, &cl, &len); in qfq_dequeue()
1142 skb = agg_dequeue(in_serv_agg, cl, len); in qfq_dequeue()
1156 if (unlikely(in_serv_agg->budget < len)) in qfq_dequeue()
1157 in_serv_agg->budget = 0; in qfq_dequeue()
1159 in_serv_agg->budget -= len; in qfq_dequeue()
1163 len, (unsigned long long) in_serv_agg->F, in qfq_dequeue()
1273 q->in_serv_agg == agg) in qfq_enqueue()
1311 q->in_serv_agg == NULL) in qfq_schedule_agg()
1337 if (q->in_serv_agg == NULL) { /* no aggr. in service or scheduled */ in qfq_activate_agg()
1338 q->in_serv_agg = agg; /* start serving this aggregate */ in qfq_activate_agg()
1341 } else if (agg != q->in_serv_agg) in qfq_activate_agg()
1375 if (agg == q->in_serv_agg) { in qfq_deactivate_agg()
1377 q->in_serv_agg = qfq_choose_next_agg(q); in qfq_deactivate_agg()