1 /* net/sched/sch_ingress.c - Ingress and clsact qdisc
3 * This program is free software; you can redistribute it and/or
4 * modify it under the terms of the GNU General Public License
5 * as published by the Free Software Foundation; either version
6 * 2 of the License, or (at your option) any later version.
8 * Authors: Jamal Hadi Salim 1999
11 #include <linux/module.h>
12 #include <linux/types.h>
13 #include <linux/list.h>
14 #include <linux/skbuff.h>
15 #include <linux/rtnetlink.h>
17 #include <net/netlink.h>
18 #include <net/pkt_sched.h>
19 #include <net/pkt_cls.h>
21 struct ingress_sched_data {
22 struct tcf_block *block;
25 static struct Qdisc *ingress_leaf(struct Qdisc *sch, unsigned long arg)
30 static unsigned long ingress_find(struct Qdisc *sch, u32 classid)
32 return TC_H_MIN(classid) + 1;
35 static unsigned long ingress_bind_filter(struct Qdisc *sch,
36 unsigned long parent, u32 classid)
38 return ingress_find(sch, classid);
41 static void ingress_unbind_filter(struct Qdisc *sch, unsigned long cl)
45 static void ingress_walk(struct Qdisc *sch, struct qdisc_walker *walker)
49 static struct tcf_block *ingress_tcf_block(struct Qdisc *sch, unsigned long cl)
51 struct ingress_sched_data *q = qdisc_priv(sch);
56 static int ingress_init(struct Qdisc *sch, struct nlattr *opt)
58 struct ingress_sched_data *q = qdisc_priv(sch);
59 struct net_device *dev = qdisc_dev(sch);
62 net_inc_ingress_queue();
64 err = tcf_block_get(&q->block, &dev->ingress_cl_list);
68 sch->flags |= TCQ_F_CPUSTATS;
73 static void ingress_destroy(struct Qdisc *sch)
75 struct ingress_sched_data *q = qdisc_priv(sch);
77 tcf_block_put(q->block);
78 net_dec_ingress_queue();
81 static int ingress_dump(struct Qdisc *sch, struct sk_buff *skb)
85 nest = nla_nest_start(skb, TCA_OPTIONS);
89 return nla_nest_end(skb, nest);
92 nla_nest_cancel(skb, nest);
96 static const struct Qdisc_class_ops ingress_class_ops = {
100 .tcf_block = ingress_tcf_block,
101 .bind_tcf = ingress_bind_filter,
102 .unbind_tcf = ingress_unbind_filter,
105 static struct Qdisc_ops ingress_qdisc_ops __read_mostly = {
106 .cl_ops = &ingress_class_ops,
108 .priv_size = sizeof(struct ingress_sched_data),
109 .init = ingress_init,
110 .destroy = ingress_destroy,
111 .dump = ingress_dump,
112 .owner = THIS_MODULE,
115 struct clsact_sched_data {
116 struct tcf_block *ingress_block;
117 struct tcf_block *egress_block;
120 static unsigned long clsact_find(struct Qdisc *sch, u32 classid)
122 switch (TC_H_MIN(classid)) {
123 case TC_H_MIN(TC_H_MIN_INGRESS):
124 case TC_H_MIN(TC_H_MIN_EGRESS):
125 return TC_H_MIN(classid);
131 static unsigned long clsact_bind_filter(struct Qdisc *sch,
132 unsigned long parent, u32 classid)
134 return clsact_find(sch, classid);
137 static struct tcf_block *clsact_tcf_block(struct Qdisc *sch, unsigned long cl)
139 struct clsact_sched_data *q = qdisc_priv(sch);
142 case TC_H_MIN(TC_H_MIN_INGRESS):
143 return q->ingress_block;
144 case TC_H_MIN(TC_H_MIN_EGRESS):
145 return q->egress_block;
151 static int clsact_init(struct Qdisc *sch, struct nlattr *opt)
153 struct clsact_sched_data *q = qdisc_priv(sch);
154 struct net_device *dev = qdisc_dev(sch);
157 net_inc_ingress_queue();
158 net_inc_egress_queue();
160 err = tcf_block_get(&q->ingress_block, &dev->ingress_cl_list);
164 err = tcf_block_get(&q->egress_block, &dev->egress_cl_list);
168 sch->flags |= TCQ_F_CPUSTATS;
173 static void clsact_destroy(struct Qdisc *sch)
175 struct clsact_sched_data *q = qdisc_priv(sch);
177 tcf_block_put(q->egress_block);
178 tcf_block_put(q->ingress_block);
180 net_dec_ingress_queue();
181 net_dec_egress_queue();
184 static const struct Qdisc_class_ops clsact_class_ops = {
185 .leaf = ingress_leaf,
187 .walk = ingress_walk,
188 .tcf_block = clsact_tcf_block,
189 .bind_tcf = clsact_bind_filter,
190 .unbind_tcf = ingress_unbind_filter,
193 static struct Qdisc_ops clsact_qdisc_ops __read_mostly = {
194 .cl_ops = &clsact_class_ops,
196 .priv_size = sizeof(struct clsact_sched_data),
198 .destroy = clsact_destroy,
199 .dump = ingress_dump,
200 .owner = THIS_MODULE,
203 static int __init ingress_module_init(void)
207 ret = register_qdisc(&ingress_qdisc_ops);
209 ret = register_qdisc(&clsact_qdisc_ops);
211 unregister_qdisc(&ingress_qdisc_ops);
217 static void __exit ingress_module_exit(void)
219 unregister_qdisc(&ingress_qdisc_ops);
220 unregister_qdisc(&clsact_qdisc_ops);
223 module_init(ingress_module_init);
224 module_exit(ingress_module_exit);
226 MODULE_ALIAS("sch_clsact");
227 MODULE_LICENSE("GPL");