net: sched: delete duplicate cleanup of backlog and qlen
authorZhengchao Shao <shaozhengchao@huawei.com>
Wed, 24 Aug 2022 00:52:31 +0000 (08:52 +0800)
committerPaolo Abeni <pabeni@redhat.com>
Thu, 25 Aug 2022 13:10:17 +0000 (15:10 +0200)
qdisc_reset() is clearing qdisc->q.qlen and qdisc->qstats.backlog
_after_ calling qdisc->ops->reset. There is no need to clear them
again in the specific reset function.

Signed-off-by: Zhengchao Shao <shaozhengchao@huawei.com>
Link: https://lore.kernel.org/r/20220824005231.345727-1-shaozhengchao@huawei.com
Signed-off-by: Paolo Abeni <pabeni@redhat.com>
21 files changed:
include/net/sch_generic.h
net/sched/sch_atm.c
net/sched/sch_cbq.c
net/sched/sch_choke.c
net/sched/sch_drr.c
net/sched/sch_dsmark.c
net/sched/sch_etf.c
net/sched/sch_ets.c
net/sched/sch_fq_codel.c
net/sched/sch_fq_pie.c
net/sched/sch_hfsc.c
net/sched/sch_htb.c
net/sched/sch_multiq.c
net/sched/sch_prio.c
net/sched/sch_qfq.c
net/sched/sch_red.c
net/sched/sch_sfb.c
net/sched/sch_skbprio.c
net/sched/sch_taprio.c
net/sched/sch_tbf.c
net/sched/sch_teql.c

index ec693fe..f2958fb 100644 (file)
@@ -1137,7 +1137,6 @@ static inline void __qdisc_reset_queue(struct qdisc_skb_head *qh)
 static inline void qdisc_reset_queue(struct Qdisc *sch)
 {
        __qdisc_reset_queue(&sch->q);
-       sch->qstats.backlog = 0;
 }
 
 static inline struct Qdisc *qdisc_replace(struct Qdisc *sch, struct Qdisc *new,
index 4c8e994..816fd0d 100644 (file)
@@ -577,7 +577,6 @@ static void atm_tc_reset(struct Qdisc *sch)
        pr_debug("atm_tc_reset(sch %p,[qdisc %p])\n", sch, p);
        list_for_each_entry(flow, &p->flows, list)
                qdisc_reset(flow->q);
-       sch->q.qlen = 0;
 }
 
 static void atm_tc_destroy(struct Qdisc *sch)
index 91a0dc4..ba99ce0 100644 (file)
@@ -975,7 +975,6 @@ cbq_reset(struct Qdisc *sch)
                        cl->cpriority = cl->priority;
                }
        }
-       sch->q.qlen = 0;
 }
 
 
index 2adbd94..25d2daa 100644 (file)
@@ -315,8 +315,6 @@ static void choke_reset(struct Qdisc *sch)
                rtnl_qdisc_drop(skb, sch);
        }
 
-       sch->q.qlen = 0;
-       sch->qstats.backlog = 0;
        if (q->tab)
                memset(q->tab, 0, (q->tab_mask + 1) * sizeof(struct sk_buff *));
        q->head = q->tail = 0;
index 18e4f7a..4e5b1cf 100644 (file)
@@ -441,8 +441,6 @@ static void drr_reset_qdisc(struct Qdisc *sch)
                        qdisc_reset(cl->qdisc);
                }
        }
-       sch->qstats.backlog = 0;
-       sch->q.qlen = 0;
 }
 
 static void drr_destroy_qdisc(struct Qdisc *sch)
index 4c100d1..7da6dc3 100644 (file)
@@ -409,8 +409,6 @@ static void dsmark_reset(struct Qdisc *sch)
        pr_debug("%s(sch %p,[qdisc %p])\n", __func__, sch, p);
        if (p->q)
                qdisc_reset(p->q);
-       sch->qstats.backlog = 0;
-       sch->q.qlen = 0;
 }
 
 static void dsmark_destroy(struct Qdisc *sch)
index c48f910..d96103b 100644 (file)
@@ -445,9 +445,6 @@ static void etf_reset(struct Qdisc *sch)
        timesortedlist_clear(sch);
        __qdisc_reset_queue(&sch->q);
 
-       sch->qstats.backlog = 0;
-       sch->q.qlen = 0;
-
        q->last = 0;
 }
 
index d733934..8de4365 100644 (file)
@@ -727,8 +727,6 @@ static void ets_qdisc_reset(struct Qdisc *sch)
        }
        for (band = 0; band < q->nbands; band++)
                qdisc_reset(q->classes[band].qdisc);
-       sch->qstats.backlog = 0;
-       sch->q.qlen = 0;
 }
 
 static void ets_qdisc_destroy(struct Qdisc *sch)
index 839e123..23a042a 100644 (file)
@@ -347,8 +347,6 @@ static void fq_codel_reset(struct Qdisc *sch)
                codel_vars_init(&flow->cvars);
        }
        memset(q->backlogs, 0, q->flows_cnt * sizeof(u32));
-       sch->q.qlen = 0;
-       sch->qstats.backlog = 0;
        q->memory_usage = 0;
 }
 
index d6aba6e..35c3546 100644 (file)
@@ -521,9 +521,6 @@ static void fq_pie_reset(struct Qdisc *sch)
                INIT_LIST_HEAD(&flow->flowchain);
                pie_vars_init(&flow->vars);
        }
-
-       sch->q.qlen = 0;
-       sch->qstats.backlog = 0;
 }
 
 static void fq_pie_destroy(struct Qdisc *sch)
index d3979a6..03efc40 100644 (file)
@@ -1484,8 +1484,6 @@ hfsc_reset_qdisc(struct Qdisc *sch)
        }
        q->eligible = RB_ROOT;
        qdisc_watchdog_cancel(&q->watchdog);
-       sch->qstats.backlog = 0;
-       sch->q.qlen = 0;
 }
 
 static void
index 23a9d62..cb5872d 100644 (file)
@@ -1008,8 +1008,6 @@ static void htb_reset(struct Qdisc *sch)
        }
        qdisc_watchdog_cancel(&q->watchdog);
        __qdisc_reset_queue(&q->direct_queue);
-       sch->q.qlen = 0;
-       sch->qstats.backlog = 0;
        memset(q->hlevel, 0, sizeof(q->hlevel));
        memset(q->row_mask, 0, sizeof(q->row_mask));
 }
index cd8ab90..f28050c 100644 (file)
@@ -152,7 +152,6 @@ multiq_reset(struct Qdisc *sch)
 
        for (band = 0; band < q->bands; band++)
                qdisc_reset(q->queues[band]);
-       sch->q.qlen = 0;
        q->curband = 0;
 }
 
index 3b8d719..c03a11d 100644 (file)
@@ -135,8 +135,6 @@ prio_reset(struct Qdisc *sch)
 
        for (prio = 0; prio < q->bands; prio++)
                qdisc_reset(q->queues[prio]);
-       sch->qstats.backlog = 0;
-       sch->q.qlen = 0;
 }
 
 static int prio_offload(struct Qdisc *sch, struct tc_prio_qopt *qopt)
index d4ce58c..13246a9 100644 (file)
@@ -1458,8 +1458,6 @@ static void qfq_reset_qdisc(struct Qdisc *sch)
                        qdisc_reset(cl->qdisc);
                }
        }
-       sch->qstats.backlog = 0;
-       sch->q.qlen = 0;
 }
 
 static void qfq_destroy_qdisc(struct Qdisc *sch)
index 40adf1f..f1e013e 100644 (file)
@@ -176,8 +176,6 @@ static void red_reset(struct Qdisc *sch)
        struct red_sched_data *q = qdisc_priv(sch);
 
        qdisc_reset(q->qdisc);
-       sch->qstats.backlog = 0;
-       sch->q.qlen = 0;
        red_restart(&q->vars);
 }
 
index 3d061a1..31717fa 100644 (file)
@@ -453,8 +453,6 @@ static void sfb_reset(struct Qdisc *sch)
        struct sfb_sched_data *q = qdisc_priv(sch);
 
        qdisc_reset(q->qdisc);
-       sch->qstats.backlog = 0;
-       sch->q.qlen = 0;
        q->slot = 0;
        q->double_buffering = false;
        sfb_zero_all_buckets(q);
index 7a5e4c4..df72fb8 100644 (file)
@@ -213,9 +213,6 @@ static void skbprio_reset(struct Qdisc *sch)
        struct skbprio_sched_data *q = qdisc_priv(sch);
        int prio;
 
-       sch->qstats.backlog = 0;
-       sch->q.qlen = 0;
-
        for (prio = 0; prio < SKBPRIO_MAX_PRIORITY; prio++)
                __skb_queue_purge(&q->qdiscs[prio]);
 
index 0b941dd..db88a69 100644 (file)
@@ -1636,8 +1636,6 @@ static void taprio_reset(struct Qdisc *sch)
                        if (q->qdiscs[i])
                                qdisc_reset(q->qdiscs[i]);
        }
-       sch->qstats.backlog = 0;
-       sch->q.qlen = 0;
 }
 
 static void taprio_destroy(struct Qdisc *sch)
index 7210227..d0288e2 100644 (file)
@@ -330,8 +330,6 @@ static void tbf_reset(struct Qdisc *sch)
        struct tbf_sched_data *q = qdisc_priv(sch);
 
        qdisc_reset(q->qdisc);
-       sch->qstats.backlog = 0;
-       sch->q.qlen = 0;
        q->t_c = ktime_get_ns();
        q->tokens = q->buffer;
        q->ptokens = q->mtu;
index 1f447b7..16f9238 100644 (file)
@@ -124,7 +124,6 @@ teql_reset(struct Qdisc *sch)
        struct teql_sched_data *dat = qdisc_priv(sch);
 
        skb_queue_purge(&dat->q);
-       sch->q.qlen = 0;
 }
 
 static void