Lines Matching refs:in_serv_agg

188 	struct qfq_aggregate	*in_serv_agg;   /* Aggregate being served. */  member
333 cl && q->in_serv_agg != agg) /* agg was inactive */ in qfq_add_to_agg()
348 if (q->in_serv_agg == agg) in qfq_destroy_agg()
349 q->in_serv_agg = qfq_choose_next_agg(q); in qfq_destroy_agg()
1106 struct qfq_aggregate *in_serv_agg = q->in_serv_agg; in qfq_dequeue() local
1112 if (in_serv_agg == NULL) in qfq_dequeue()
1115 if (!list_empty(&in_serv_agg->active)) in qfq_dequeue()
1116 skb = qfq_peek_skb(in_serv_agg, &cl, &len); in qfq_dequeue()
1123 if (len == 0 || in_serv_agg->budget < len) { in qfq_dequeue()
1124 charge_actual_service(in_serv_agg); in qfq_dequeue()
1127 in_serv_agg->initial_budget = in_serv_agg->budget = in qfq_dequeue()
1128 in_serv_agg->budgetmax; in qfq_dequeue()
1130 if (!list_empty(&in_serv_agg->active)) { in qfq_dequeue()
1141 qfq_update_agg_ts(q, in_serv_agg, requeue); in qfq_dequeue()
1142 qfq_schedule_agg(q, in_serv_agg); in qfq_dequeue()
1144 q->in_serv_agg = NULL; in qfq_dequeue()
1152 in_serv_agg = q->in_serv_agg = qfq_choose_next_agg(q); in qfq_dequeue()
1153 skb = qfq_peek_skb(in_serv_agg, &cl, &len); in qfq_dequeue()
1161 agg_dequeue(in_serv_agg, cl, len); in qfq_dequeue()
1166 if (unlikely(in_serv_agg->budget < len)) in qfq_dequeue()
1167 in_serv_agg->budget = 0; in qfq_dequeue()
1169 in_serv_agg->budget -= len; in qfq_dequeue()
1173 len, (unsigned long long) in_serv_agg->F, in qfq_dequeue()
1276 q->in_serv_agg == agg) in qfq_enqueue()
1314 q->in_serv_agg == NULL) in qfq_schedule_agg()
1340 if (q->in_serv_agg == NULL) { /* no aggr. in service or scheduled */ in qfq_activate_agg()
1341 q->in_serv_agg = agg; /* start serving this aggregate */ in qfq_activate_agg()
1344 } else if (agg != q->in_serv_agg) in qfq_activate_agg()
1378 if (agg == q->in_serv_agg) { in qfq_deactivate_agg()
1380 q->in_serv_agg = qfq_choose_next_agg(q); in qfq_deactivate_agg()