Lines Matching refs:in_serv_agg
184 struct qfq_aggregate *in_serv_agg; /* Aggregate being served. */
325 cl && q->in_serv_agg != agg) /* agg was inactive */
339 if (q->in_serv_agg == agg)
340 q->in_serv_agg = qfq_choose_next_agg(q);
1088 struct qfq_aggregate *in_serv_agg = q->in_serv_agg;
1094 if (in_serv_agg == NULL)
1097 if (!list_empty(&in_serv_agg->active))
1098 skb = qfq_peek_skb(in_serv_agg, &cl, &len);
1105 if (len == 0 || in_serv_agg->budget < len) {
1106 charge_actual_service(in_serv_agg);
1109 in_serv_agg->initial_budget = in_serv_agg->budget =
1110 in_serv_agg->budgetmax;
1112 if (!list_empty(&in_serv_agg->active)) {
1123 qfq_update_agg_ts(q, in_serv_agg, requeue);
1124 qfq_schedule_agg(q, in_serv_agg);
1126 q->in_serv_agg = NULL;
1134 in_serv_agg = q->in_serv_agg = qfq_choose_next_agg(q);
1135 skb = qfq_peek_skb(in_serv_agg, &cl, &len);
1142 skb = agg_dequeue(in_serv_agg, cl, len);
1156 if (unlikely(in_serv_agg->budget < len))
1157 in_serv_agg->budget = 0;
1159 in_serv_agg->budget -= len;
1163 len, (unsigned long long) in_serv_agg->F,
1273 q->in_serv_agg == agg)
1311 q->in_serv_agg == NULL)
1337 if (q->in_serv_agg == NULL) { /* no aggr. in service or scheduled */
1338 q->in_serv_agg = agg; /* start serving this aggregate */
1341 } else if (agg != q->in_serv_agg)
1375 if (agg == q->in_serv_agg) {
1377 q->in_serv_agg = qfq_choose_next_agg(q);