Commit 196d97f6 authored by Eric Dumazet's avatar Eric Dumazet Committed by David S. Miller

htb: fix two bugs

Commit 56b765b7 (htb: improved accuracy at high rates)
introduced two bugs :

1) one bstats_update() was inadvertently removed from
   htb_dequeue_tree(), breaking statistics/rate estimation.

2) Missing qdisc_put_rtab() calls in htb_change_class(),
   leaking kernel memory, now struct htb_class no longer
   retains pointers to qdisc_rate_table structs.

   Since only rate is used, dont use qdisc_get_rtab() calls
   copying data we ignore anyway.
Signed-off-by: default avatarEric Dumazet <edumazet@google.com>
Cc: Vimalkumar <j.vimal@gmail.com>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent bd473da3
...@@ -879,6 +879,7 @@ static struct sk_buff *htb_dequeue_tree(struct htb_sched *q, int prio, ...@@ -879,6 +879,7 @@ static struct sk_buff *htb_dequeue_tree(struct htb_sched *q, int prio,
} while (cl != start); } while (cl != start);
if (likely(skb != NULL)) { if (likely(skb != NULL)) {
bstats_update(&cl->bstats, skb);
cl->un.leaf.deficit[level] -= qdisc_pkt_len(skb); cl->un.leaf.deficit[level] -= qdisc_pkt_len(skb);
if (cl->un.leaf.deficit[level] < 0) { if (cl->un.leaf.deficit[level] < 0) {
cl->un.leaf.deficit[level] += cl->quantum; cl->un.leaf.deficit[level] += cl->quantum;
...@@ -1355,7 +1356,6 @@ static int htb_change_class(struct Qdisc *sch, u32 classid, ...@@ -1355,7 +1356,6 @@ static int htb_change_class(struct Qdisc *sch, u32 classid,
struct htb_sched *q = qdisc_priv(sch); struct htb_sched *q = qdisc_priv(sch);
struct htb_class *cl = (struct htb_class *)*arg, *parent; struct htb_class *cl = (struct htb_class *)*arg, *parent;
struct nlattr *opt = tca[TCA_OPTIONS]; struct nlattr *opt = tca[TCA_OPTIONS];
struct qdisc_rate_table *rtab = NULL, *ctab = NULL;
struct nlattr *tb[__TCA_HTB_MAX]; struct nlattr *tb[__TCA_HTB_MAX];
struct tc_htb_opt *hopt; struct tc_htb_opt *hopt;
...@@ -1374,10 +1374,7 @@ static int htb_change_class(struct Qdisc *sch, u32 classid, ...@@ -1374,10 +1374,7 @@ static int htb_change_class(struct Qdisc *sch, u32 classid,
parent = parentid == TC_H_ROOT ? NULL : htb_find(parentid, sch); parent = parentid == TC_H_ROOT ? NULL : htb_find(parentid, sch);
hopt = nla_data(tb[TCA_HTB_PARMS]); hopt = nla_data(tb[TCA_HTB_PARMS]);
if (!hopt->rate.rate || !hopt->ceil.rate)
rtab = qdisc_get_rtab(&hopt->rate, tb[TCA_HTB_RTAB]);
ctab = qdisc_get_rtab(&hopt->ceil, tb[TCA_HTB_CTAB]);
if (!rtab || !ctab)
goto failure; goto failure;
if (!cl) { /* new class */ if (!cl) { /* new class */
...@@ -1487,7 +1484,7 @@ static int htb_change_class(struct Qdisc *sch, u32 classid, ...@@ -1487,7 +1484,7 @@ static int htb_change_class(struct Qdisc *sch, u32 classid,
* is really leaf before changing cl->un.leaf ! * is really leaf before changing cl->un.leaf !
*/ */
if (!cl->level) { if (!cl->level) {
cl->quantum = rtab->rate.rate / q->rate2quantum; cl->quantum = hopt->rate.rate / q->rate2quantum;
if (!hopt->quantum && cl->quantum < 1000) { if (!hopt->quantum && cl->quantum < 1000) {
pr_warning( pr_warning(
"HTB: quantum of class %X is small. Consider r2q change.\n", "HTB: quantum of class %X is small. Consider r2q change.\n",
...@@ -1509,8 +1506,8 @@ static int htb_change_class(struct Qdisc *sch, u32 classid, ...@@ -1509,8 +1506,8 @@ static int htb_change_class(struct Qdisc *sch, u32 classid,
cl->buffer = hopt->buffer; cl->buffer = hopt->buffer;
cl->cbuffer = hopt->cbuffer; cl->cbuffer = hopt->cbuffer;
cl->rate.rate_bps = (u64)rtab->rate.rate << 3; cl->rate.rate_bps = (u64)hopt->rate.rate << 3;
cl->ceil.rate_bps = (u64)ctab->rate.rate << 3; cl->ceil.rate_bps = (u64)hopt->ceil.rate << 3;
htb_precompute_ratedata(&cl->rate); htb_precompute_ratedata(&cl->rate);
htb_precompute_ratedata(&cl->ceil); htb_precompute_ratedata(&cl->ceil);
...@@ -1526,10 +1523,6 @@ static int htb_change_class(struct Qdisc *sch, u32 classid, ...@@ -1526,10 +1523,6 @@ static int htb_change_class(struct Qdisc *sch, u32 classid,
return 0; return 0;
failure: failure:
if (rtab)
qdisc_put_rtab(rtab);
if (ctab)
qdisc_put_rtab(ctab);
return err; return err;
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment