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()
347 if (q->in_serv_agg == agg) in qfq_destroy_agg()
348 q->in_serv_agg = qfq_choose_next_agg(q); in qfq_destroy_agg()
1101 struct qfq_aggregate *in_serv_agg = q->in_serv_agg; in qfq_dequeue() local
1107 if (in_serv_agg == NULL) in qfq_dequeue()
1110 if (!list_empty(&in_serv_agg->active)) in qfq_dequeue()
1111 skb = qfq_peek_skb(in_serv_agg, &cl, &len); in qfq_dequeue()
1118 if (len == 0 || in_serv_agg->budget < len) { in qfq_dequeue()
1119 charge_actual_service(in_serv_agg); in qfq_dequeue()
1122 in_serv_agg->initial_budget = in_serv_agg->budget = in qfq_dequeue()
1123 in_serv_agg->budgetmax; in qfq_dequeue()
1125 if (!list_empty(&in_serv_agg->active)) { in qfq_dequeue()
1136 qfq_update_agg_ts(q, in_serv_agg, requeue); in qfq_dequeue()
1137 qfq_schedule_agg(q, in_serv_agg); in qfq_dequeue()
1139 q->in_serv_agg = NULL; in qfq_dequeue()
1147 in_serv_agg = q->in_serv_agg = qfq_choose_next_agg(q); in qfq_dequeue()
1148 skb = qfq_peek_skb(in_serv_agg, &cl, &len); in qfq_dequeue()
1156 agg_dequeue(in_serv_agg, cl, len); in qfq_dequeue()
1161 if (unlikely(in_serv_agg->budget < len)) in qfq_dequeue()
1162 in_serv_agg->budget = 0; in qfq_dequeue()
1164 in_serv_agg->budget -= len; in qfq_dequeue()
1168 len, (unsigned long long) in_serv_agg->F, in qfq_dequeue()
1271 q->in_serv_agg == agg) in qfq_enqueue()
1309 q->in_serv_agg == NULL) in qfq_schedule_agg()
1335 if (q->in_serv_agg == NULL) { /* no aggr. in service or scheduled */ in qfq_activate_agg()
1336 q->in_serv_agg = agg; /* start serving this aggregate */ in qfq_activate_agg()
1339 } else if (agg != q->in_serv_agg) in qfq_activate_agg()
1373 if (agg == q->in_serv_agg) { in qfq_deactivate_agg()
1375 q->in_serv_agg = qfq_choose_next_agg(q); in qfq_deactivate_agg()