diff options
author | Eric Dumazet <edumazet@google.com> | 2016-05-15 21:16:38 -0400 |
---|---|---|
committer | David S. Miller <davem@davemloft.net> | 2016-05-16 21:54:24 -0400 |
commit | 77f57761466e9aef2b57acf8ce07df11bf360e34 (patch) | |
tree | 5b60d91757574c917d979ff83c37f69671350c44 | |
parent | fd24d72ca9b52558b1511edc814951cdfe5f21cf (diff) |
fq_codel: fix memory limitation drift
memory_usage must be decreased in dequeue_func(), not in
fq_codel_dequeue(), otherwise packets dropped by Codel algo
are missing this decrease.
Also we need to clear memory_usage in fq_codel_reset()
Fixes: 95b58430abe7 ("fq_codel: add memory limitation per queue")
Signed-off-by: Eric Dumazet <edumazet@google.com>
Signed-off-by: David S. Miller <davem@davemloft.net>
-rw-r--r-- | net/sched/sch_fq_codel.c | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/net/sched/sch_fq_codel.c b/net/sched/sch_fq_codel.c index bb8bd9314629..6883a8971562 100644 --- a/net/sched/sch_fq_codel.c +++ b/net/sched/sch_fq_codel.c | |||
@@ -262,6 +262,7 @@ static struct sk_buff *dequeue_func(struct codel_vars *vars, void *ctx) | |||
262 | if (flow->head) { | 262 | if (flow->head) { |
263 | skb = dequeue_head(flow); | 263 | skb = dequeue_head(flow); |
264 | q->backlogs[flow - q->flows] -= qdisc_pkt_len(skb); | 264 | q->backlogs[flow - q->flows] -= qdisc_pkt_len(skb); |
265 | q->memory_usage -= skb->truesize; | ||
265 | sch->q.qlen--; | 266 | sch->q.qlen--; |
266 | sch->qstats.backlog -= qdisc_pkt_len(skb); | 267 | sch->qstats.backlog -= qdisc_pkt_len(skb); |
267 | } | 268 | } |
@@ -318,7 +319,6 @@ begin: | |||
318 | list_del_init(&flow->flowchain); | 319 | list_del_init(&flow->flowchain); |
319 | goto begin; | 320 | goto begin; |
320 | } | 321 | } |
321 | q->memory_usage -= skb->truesize; | ||
322 | qdisc_bstats_update(sch, skb); | 322 | qdisc_bstats_update(sch, skb); |
323 | flow->deficit -= qdisc_pkt_len(skb); | 323 | flow->deficit -= qdisc_pkt_len(skb); |
324 | /* We cant call qdisc_tree_reduce_backlog() if our qlen is 0, | 324 | /* We cant call qdisc_tree_reduce_backlog() if our qlen is 0, |
@@ -355,6 +355,7 @@ static void fq_codel_reset(struct Qdisc *sch) | |||
355 | } | 355 | } |
356 | memset(q->backlogs, 0, q->flows_cnt * sizeof(u32)); | 356 | memset(q->backlogs, 0, q->flows_cnt * sizeof(u32)); |
357 | sch->q.qlen = 0; | 357 | sch->q.qlen = 0; |
358 | q->memory_usage = 0; | ||
358 | } | 359 | } |
359 | 360 | ||
360 | static const struct nla_policy fq_codel_policy[TCA_FQ_CODEL_MAX + 1] = { | 361 | static const struct nla_policy fq_codel_policy[TCA_FQ_CODEL_MAX + 1] = { |