Lines Matching defs:in_serv_agg
186 struct qfq_aggregate *in_serv_agg; /* Aggregate being served. */
327 cl && q->in_serv_agg != agg) /* agg was inactive */
341 if (q->in_serv_agg == agg)
342 q->in_serv_agg = qfq_choose_next_agg(q);
1093 struct qfq_aggregate *in_serv_agg = q->in_serv_agg;
1099 if (in_serv_agg == NULL)
1102 if (!list_empty(&in_serv_agg->active))
1103 skb = qfq_peek_skb(in_serv_agg, &cl, &len);
1110 if (len == 0 || in_serv_agg->budget < len) {
1111 charge_actual_service(in_serv_agg);
1114 in_serv_agg->initial_budget = in_serv_agg->budget =
1115 in_serv_agg->budgetmax;
1117 if (!list_empty(&in_serv_agg->active)) {
1128 qfq_update_agg_ts(q, in_serv_agg, requeue);
1129 qfq_schedule_agg(q, in_serv_agg);
1131 q->in_serv_agg = NULL;
1139 in_serv_agg = q->in_serv_agg = qfq_choose_next_agg(q);
1140 skb = qfq_peek_skb(in_serv_agg, &cl, &len);
1147 skb = agg_dequeue(in_serv_agg, cl, len);
1161 if (unlikely(in_serv_agg->budget < len))
1162 in_serv_agg->budget = 0;
1164 in_serv_agg->budget -= len;
1168 len, (unsigned long long) in_serv_agg->F,
1279 q->in_serv_agg == agg)
1317 q->in_serv_agg == NULL)
1343 if (q->in_serv_agg == NULL) { /* no aggr. in service or scheduled */
1344 q->in_serv_agg = agg; /* start serving this aggregate */
1347 } else if (agg != q->in_serv_agg)
1381 if (agg == q->in_serv_agg) {
1383 q->in_serv_agg = qfq_choose_next_agg(q);