Lines Matching refs:in_serv_agg

185 	struct qfq_aggregate	*in_serv_agg;   /* Aggregate being served. */  member
321 cl && q->in_serv_agg != agg) /* agg was inactive */ in qfq_add_to_agg()
335 if (q->in_serv_agg == agg) in qfq_destroy_agg()
336 q->in_serv_agg = qfq_choose_next_agg(q); in qfq_destroy_agg()
1078 struct qfq_aggregate *in_serv_agg = q->in_serv_agg; in qfq_dequeue() local
1084 if (in_serv_agg == NULL) in qfq_dequeue()
1087 if (!list_empty(&in_serv_agg->active)) in qfq_dequeue()
1088 skb = qfq_peek_skb(in_serv_agg, &cl, &len); in qfq_dequeue()
1095 if (len == 0 || in_serv_agg->budget < len) { in qfq_dequeue()
1096 charge_actual_service(in_serv_agg); in qfq_dequeue()
1099 in_serv_agg->initial_budget = in_serv_agg->budget = in qfq_dequeue()
1100 in_serv_agg->budgetmax; in qfq_dequeue()
1102 if (!list_empty(&in_serv_agg->active)) { in qfq_dequeue()
1113 qfq_update_agg_ts(q, in_serv_agg, requeue); in qfq_dequeue()
1114 qfq_schedule_agg(q, in_serv_agg); in qfq_dequeue()
1116 q->in_serv_agg = NULL; in qfq_dequeue()
1124 in_serv_agg = q->in_serv_agg = qfq_choose_next_agg(q); in qfq_dequeue()
1125 skb = qfq_peek_skb(in_serv_agg, &cl, &len); in qfq_dequeue()
1134 agg_dequeue(in_serv_agg, cl, len); in qfq_dequeue()
1139 if (unlikely(in_serv_agg->budget < len)) in qfq_dequeue()
1140 in_serv_agg->budget = 0; in qfq_dequeue()
1142 in_serv_agg->budget -= len; in qfq_dequeue()
1146 len, (unsigned long long) in_serv_agg->F, in qfq_dequeue()
1257 q->in_serv_agg == agg) in qfq_enqueue()
1295 q->in_serv_agg == NULL) in qfq_schedule_agg()
1321 if (q->in_serv_agg == NULL) { /* no aggr. in service or scheduled */ in qfq_activate_agg()
1322 q->in_serv_agg = agg; /* start serving this aggregate */ in qfq_activate_agg()
1325 } else if (agg != q->in_serv_agg) in qfq_activate_agg()
1359 if (agg == q->in_serv_agg) { in qfq_deactivate_agg()
1361 q->in_serv_agg = qfq_choose_next_agg(q); in qfq_deactivate_agg()