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()
1072 struct qfq_aggregate *in_serv_agg = q->in_serv_agg; in qfq_dequeue() local
1078 if (in_serv_agg == NULL) in qfq_dequeue()
1081 if (!list_empty(&in_serv_agg->active)) in qfq_dequeue()
1082 skb = qfq_peek_skb(in_serv_agg, &cl, &len); in qfq_dequeue()
1089 if (len == 0 || in_serv_agg->budget < len) { in qfq_dequeue()
1090 charge_actual_service(in_serv_agg); in qfq_dequeue()
1093 in_serv_agg->initial_budget = in_serv_agg->budget = in qfq_dequeue()
1094 in_serv_agg->budgetmax; in qfq_dequeue()
1096 if (!list_empty(&in_serv_agg->active)) { in qfq_dequeue()
1107 qfq_update_agg_ts(q, in_serv_agg, requeue); in qfq_dequeue()
1108 qfq_schedule_agg(q, in_serv_agg); in qfq_dequeue()
1110 q->in_serv_agg = NULL; in qfq_dequeue()
1118 in_serv_agg = q->in_serv_agg = qfq_choose_next_agg(q); in qfq_dequeue()
1119 skb = qfq_peek_skb(in_serv_agg, &cl, &len); in qfq_dequeue()
1128 agg_dequeue(in_serv_agg, cl, len); in qfq_dequeue()
1133 if (unlikely(in_serv_agg->budget < len)) in qfq_dequeue()
1134 in_serv_agg->budget = 0; in qfq_dequeue()
1136 in_serv_agg->budget -= len; in qfq_dequeue()
1140 len, (unsigned long long) in_serv_agg->F, in qfq_dequeue()
1250 q->in_serv_agg == agg) in qfq_enqueue()
1288 q->in_serv_agg == NULL) in qfq_schedule_agg()
1314 if (q->in_serv_agg == NULL) { /* no aggr. in service or scheduled */ in qfq_activate_agg()
1315 q->in_serv_agg = agg; /* start serving this aggregate */ in qfq_activate_agg()
1318 } else if (agg != q->in_serv_agg) in qfq_activate_agg()
1352 if (agg == q->in_serv_agg) { in qfq_deactivate_agg()
1354 q->in_serv_agg = qfq_choose_next_agg(q); in qfq_deactivate_agg()