diff options
| author | Paolo Abeni | 2019-03-28 16:53:13 +0100 |
|---|---|---|
| committer | David S. Miller | 2019-04-01 23:50:13 +0200 |
| commit | e5f0e8f8e456589d56e4955154ed5d468cd6d286 (patch) | |
| tree | 394e064316a0965588c3784a36a24fca3a7b352d /net/sched/sch_drr.c | |
| parent | net: sched: introduce and use qstats read helpers (diff) | |
| download | kernel-qcow2-linux-e5f0e8f8e456589d56e4955154ed5d468cd6d286.tar.gz kernel-qcow2-linux-e5f0e8f8e456589d56e4955154ed5d468cd6d286.tar.xz kernel-qcow2-linux-e5f0e8f8e456589d56e4955154ed5d468cd6d286.zip | |
net: sched: introduce and use qdisc tree flush/purge helpers
The same code to flush qdisc tree and purge the qdisc queue
is duplicated in many places and in most cases it does not
respect NOLOCK qdisc: the global backlog len is used and the
per CPU values are ignored.
This change addresses the above, factoring-out the relevant
code and using the helpers introduced by the previous patch
to fetch the correct backlog len.
Fixes: c5ad119fb6c0 ("net: sched: pfifo_fast use skb_array")
Signed-off-by: Paolo Abeni <pabeni@redhat.com>
Signed-off-by: David S. Miller <davem@davemloft.net>
Diffstat (limited to 'net/sched/sch_drr.c')
| -rw-r--r-- | net/sched/sch_drr.c | 11 |
1 files changed, 1 insertions, 10 deletions
diff --git a/net/sched/sch_drr.c b/net/sched/sch_drr.c index 8a181591b0ea..430df9a55ec4 100644 --- a/net/sched/sch_drr.c +++ b/net/sched/sch_drr.c @@ -50,15 +50,6 @@ static struct drr_class *drr_find_class(struct Qdisc *sch, u32 classid) return container_of(clc, struct drr_class, common); } -static void drr_purge_queue(struct drr_class *cl) -{ - unsigned int len = cl->qdisc->q.qlen; - unsigned int backlog = cl->qdisc->qstats.backlog; - - qdisc_reset(cl->qdisc); - qdisc_tree_reduce_backlog(cl->qdisc, len, backlog); -} - static const struct nla_policy drr_policy[TCA_DRR_MAX + 1] = { [TCA_DRR_QUANTUM] = { .type = NLA_U32 }, }; @@ -167,7 +158,7 @@ static int drr_delete_class(struct Qdisc *sch, unsigned long arg) sch_tree_lock(sch); - drr_purge_queue(cl); + qdisc_purge_queue(cl->qdisc); qdisc_class_hash_remove(&q->clhash, &cl->common); sch_tree_unlock(sch); |