Skip to content

Commit

Permalink
pkt_sched: Fix ingress deletion and filter attachment.
Browse files Browse the repository at this point in the history
Based upon bug reports by Stephen Hemminger.

We still had some cases using ->qdisc instead of ->qdisc_sleeping.

Also, qdisc_lookup() should return ingress qdiscs.

Signed-off-by: David S. Miller <davem@davemloft.net>
  • Loading branch information
David S. Miller committed Aug 9, 2008
1 parent 76aab2c commit 8123b42
Showing 1 changed file with 23 additions and 13 deletions.
36 changes: 23 additions & 13 deletions net/sched/sch_api.c
Original file line number Diff line number Diff line change
Expand Up @@ -183,6 +183,21 @@ EXPORT_SYMBOL(unregister_qdisc);
(root qdisc, all its children, children of children etc.)
*/

struct Qdisc *qdisc_match_from_root(struct Qdisc *root, u32 handle)
{
struct Qdisc *q;

if (!(root->flags & TCQ_F_BUILTIN) &&
root->handle == handle)
return root;

list_for_each_entry(q, &root->list, list) {
if (q->handle == handle)
return q;
}
return NULL;
}

struct Qdisc *qdisc_lookup(struct net_device *dev, u32 handle)
{
unsigned int i;
Expand All @@ -191,16 +206,11 @@ struct Qdisc *qdisc_lookup(struct net_device *dev, u32 handle)
struct netdev_queue *txq = netdev_get_tx_queue(dev, i);
struct Qdisc *q, *txq_root = txq->qdisc_sleeping;

if (!(txq_root->flags & TCQ_F_BUILTIN) &&
txq_root->handle == handle)
return txq_root;

list_for_each_entry(q, &txq_root->list, list) {
if (q->handle == handle)
return q;
}
q = qdisc_match_from_root(txq_root, handle);
if (q)
return q;
}
return NULL;
return qdisc_match_from_root(dev->rx_queue.qdisc_sleeping, handle);
}

static struct Qdisc *qdisc_leaf(struct Qdisc *p, u32 classid)
Expand Down Expand Up @@ -908,7 +918,7 @@ static int tc_get_qdisc(struct sk_buff *skb, struct nlmsghdr *n, void *arg)
return -ENOENT;
q = qdisc_leaf(p, clid);
} else { /* ingress */
q = dev->rx_queue.qdisc;
q = dev->rx_queue.qdisc_sleeping;
}
} else {
struct netdev_queue *dev_queue;
Expand Down Expand Up @@ -978,7 +988,7 @@ static int tc_modify_qdisc(struct sk_buff *skb, struct nlmsghdr *n, void *arg)
return -ENOENT;
q = qdisc_leaf(p, clid);
} else { /*ingress */
q = dev->rx_queue.qdisc;
q = dev->rx_queue.qdisc_sleeping;
}
} else {
struct netdev_queue *dev_queue;
Expand Down Expand Up @@ -1529,11 +1539,11 @@ static int tc_dump_tclass(struct sk_buff *skb, struct netlink_callback *cb)
t = 0;

dev_queue = netdev_get_tx_queue(dev, 0);
if (tc_dump_tclass_root(dev_queue->qdisc, skb, tcm, cb, &t, s_t) < 0)
if (tc_dump_tclass_root(dev_queue->qdisc_sleeping, skb, tcm, cb, &t, s_t) < 0)
goto done;

dev_queue = &dev->rx_queue;
if (tc_dump_tclass_root(dev_queue->qdisc, skb, tcm, cb, &t, s_t) < 0)
if (tc_dump_tclass_root(dev_queue->qdisc_sleeping, skb, tcm, cb, &t, s_t) < 0)
goto done;

done:
Expand Down

0 comments on commit 8123b42

Please sign in to comment.