67 static struct sk_buff *dequeue(struct codel_vars *vars, struct Qdisc *sch)  in dequeue()  argument
69 	struct sk_buff *skb = __skb_dequeue(&sch->q);  in dequeue()
75 static struct sk_buff *codel_qdisc_dequeue(struct Qdisc *sch)  in codel_qdisc_dequeue()  argument
77 	struct codel_sched_data *q = qdisc_priv(sch);  in codel_qdisc_dequeue()
80 	skb = codel_dequeue(sch, &q->params, &q->vars, &q->stats, dequeue);  in codel_qdisc_dequeue()
85 	if (q->stats.drop_count && sch->q.qlen) {  in codel_qdisc_dequeue()
86 		qdisc_tree_decrease_qlen(sch, q->stats.drop_count);  in codel_qdisc_dequeue()
90 		qdisc_bstats_update(sch, skb);  in codel_qdisc_dequeue()
94 static int codel_qdisc_enqueue(struct sk_buff *skb, struct Qdisc *sch)  in codel_qdisc_enqueue()  argument
98 	if (likely(qdisc_qlen(sch) < sch->limit)) {  in codel_qdisc_enqueue()
100 		return qdisc_enqueue_tail(skb, sch);  in codel_qdisc_enqueue()
102 	q = qdisc_priv(sch);  in codel_qdisc_enqueue()
104 	return qdisc_drop(skb, sch);  in codel_qdisc_enqueue()
114 static int codel_change(struct Qdisc *sch, struct nlattr *opt)  in codel_change()  argument
116 	struct codel_sched_data *q = qdisc_priv(sch);  in codel_change()
128 	sch_tree_lock(sch);  in codel_change()
143 		sch->limit = nla_get_u32(tb[TCA_CODEL_LIMIT]);  in codel_change()
148 	qlen = sch->q.qlen;  in codel_change()
149 	while (sch->q.qlen > sch->limit) {  in codel_change()
150 		struct sk_buff *skb = __skb_dequeue(&sch->q);  in codel_change()
152 		qdisc_qstats_backlog_dec(sch, skb);  in codel_change()
153 		qdisc_drop(skb, sch);  in codel_change()
155 	qdisc_tree_decrease_qlen(sch, qlen - sch->q.qlen);  in codel_change()
157 	sch_tree_unlock(sch);  in codel_change()
161 static int codel_init(struct Qdisc *sch, struct nlattr *opt)  in codel_init()  argument
163 	struct codel_sched_data *q = qdisc_priv(sch);  in codel_init()
165 	sch->limit = DEFAULT_CODEL_LIMIT;  in codel_init()
167 	codel_params_init(&q->params, sch);  in codel_init()
172 		int err = codel_change(sch, opt);  in codel_init()
178 	if (sch->limit >= 1)  in codel_init()
179 		sch->flags |= TCQ_F_CAN_BYPASS;  in codel_init()
181 		sch->flags &= ~TCQ_F_CAN_BYPASS;  in codel_init()
186 static int codel_dump(struct Qdisc *sch, struct sk_buff *skb)  in codel_dump()  argument
188 	struct codel_sched_data *q = qdisc_priv(sch);  in codel_dump()
198 			sch->limit) ||  in codel_dump()
212 static int codel_dump_stats(struct Qdisc *sch, struct gnet_dump *d)  in codel_dump_stats()  argument
214 	const struct codel_sched_data *q = qdisc_priv(sch);  in codel_dump_stats()
237 static void codel_reset(struct Qdisc *sch)  in codel_reset()  argument
239 	struct codel_sched_data *q = qdisc_priv(sch);  in codel_reset()
241 	qdisc_reset_queue(sch);  in codel_reset()