1 /* net/sched/sch_ingress.c - Ingress qdisc
2 * This program is free software; you can redistribute it and/or
3 * modify it under the terms of the GNU General Public License
4 * as published by the Free Software Foundation; either version
5 * 2 of the License, or (at your option) any later version.
7 * Authors: Jamal Hadi Salim 1999
10 #include <linux/config.h>
11 #include <linux/module.h>
12 #include <linux/types.h>
13 #include <linux/skbuff.h>
14 #include <linux/netdevice.h>
15 #include <linux/rtnetlink.h>
16 #include <linux/netfilter_ipv4.h>
17 #include <linux/netfilter.h>
18 #include <net/pkt_sched.h>
19 #include <asm/byteorder.h>
20 #include <asm/uaccess.h>
22 #include <linux/kmod.h>
23 #include <linux/stat.h>
24 #include <linux/interrupt.h>
25 #include <linux/list.h>
30 #ifdef DEBUG_INGRESS /* control */
31 #define DPRINTK(format,args...) printk(KERN_DEBUG format,##args)
33 #define DPRINTK(format,args...)
37 #define D2PRINTK(format,args...) printk(KERN_DEBUG format,##args)
39 #define D2PRINTK(format,args...)
43 #define PRIV(sch) ((struct ingress_qdisc_data *) (sch)->data)
47 struct ingress_qdisc_data
{
49 struct tcf_proto
*filter_list
;
53 /* ------------------------- Class/flow operations ------------------------- */
56 static int ingress_graft(struct Qdisc
*sch
,unsigned long arg
,
57 struct Qdisc
*new,struct Qdisc
**old
)
60 struct ingress_qdisc_data
*p
= PRIV(sch
);
63 DPRINTK("ingress_graft(sch %p,[qdisc %p],new %p,old %p)\n",
65 DPRINTK("\n ingress_graft: You cannot add qdiscs to classes");
70 static struct Qdisc
*ingress_leaf(struct Qdisc
*sch
, unsigned long arg
)
76 static unsigned long ingress_get(struct Qdisc
*sch
,u32 classid
)
79 struct ingress_qdisc_data
*p
= PRIV(sch
);
81 DPRINTK("ingress_get(sch %p,[qdisc %p],classid %x)\n", sch
, p
, classid
);
82 return TC_H_MIN(classid
) + 1;
86 static unsigned long ingress_bind_filter(struct Qdisc
*sch
,
87 unsigned long parent
, u32 classid
)
89 return ingress_get(sch
, classid
);
93 static void ingress_put(struct Qdisc
*sch
, unsigned long cl
)
98 static int ingress_change(struct Qdisc
*sch
, u32 classid
, u32 parent
,
99 struct rtattr
**tca
, unsigned long *arg
)
102 struct ingress_qdisc_data
*p
= PRIV(sch
);
104 DPRINTK("ingress_change(sch %p,[qdisc %p],classid %x,parent %x),"
105 "arg 0x%lx\n", sch
, p
, classid
, parent
, *arg
);
106 DPRINTK("No effect. sch_ingress doesnt maintain classes at the moment");
112 static void ingress_walk(struct Qdisc
*sch
,struct qdisc_walker
*walker
)
115 struct ingress_qdisc_data
*p
= PRIV(sch
);
117 DPRINTK("ingress_walk(sch %p,[qdisc %p],walker %p)\n", sch
, p
, walker
);
118 DPRINTK("No effect. sch_ingress doesnt maintain classes at the moment");
122 static struct tcf_proto
**ingress_find_tcf(struct Qdisc
*sch
,unsigned long cl
)
124 struct ingress_qdisc_data
*p
= PRIV(sch
);
126 return &p
->filter_list
;
130 /* --------------------------- Qdisc operations ---------------------------- */
133 static int ingress_enqueue(struct sk_buff
*skb
,struct Qdisc
*sch
)
135 struct ingress_qdisc_data
*p
= PRIV(sch
);
136 struct tcf_result res
;
139 D2PRINTK("ingress_enqueue(skb %p,sch %p,[qdisc %p])\n", skb
, sch
, p
);
140 result
= tc_classify(skb
, p
->filter_list
, &res
);
141 D2PRINTK("result %d class 0x%04x\n", result
, res
.classid
);
143 * Unlike normal "enqueue" functions, ingress_enqueue returns a
144 * firewall FW_* code.
147 #ifdef CONFIG_NET_CLS_POLICE
151 case TC_POLICE_RECLASSIFY
: /* DSCP remarking here ? */
153 case TC_POLICE_UNSPEC
:
160 #ifdef CONFIG_NET_CLS_TCINDEX
161 skb
->tc_index
= TC_H_MIN(res
.classid
);
167 static struct sk_buff
*ingress_dequeue(struct Qdisc
*sch
)
170 struct ingress_qdisc_data *p = PRIV(sch);
171 D2PRINTK("ingress_dequeue(sch %p,[qdisc %p])\n",sch,PRIV(p));
177 static int ingress_requeue(struct sk_buff
*skb
,struct Qdisc
*sch
)
180 struct ingress_qdisc_data *p = PRIV(sch);
181 D2PRINTK("ingress_requeue(skb %p,sch %p,[qdisc %p])\n",skb,sch,PRIV(p));
186 static int ingress_drop(struct Qdisc
*sch
)
189 struct ingress_qdisc_data
*p
= PRIV(sch
);
191 DPRINTK("ingress_drop(sch %p,[qdisc %p])\n", sch
, p
);
196 ing_hook(unsigned int hook
, struct sk_buff
**pskb
,
197 const struct net_device
*indev
,
198 const struct net_device
*outdev
,
199 int (*okfn
)(struct sk_buff
*))
203 struct sk_buff
*skb
= *pskb
;
204 struct net_device
*dev
= skb
->dev
;
207 DPRINTK("ing_hook: skb %s dev=%s len=%u\n",
208 skb
->sk
? "(owned)" : "(unowned)",
209 skb
->dev
? (*pskb
)->dev
->name
: "(no dev)",
213 revisit later: Use a private since lock dev->queue_lock is also
214 used on the egress (might slow things for an iota)
217 if (dev
->qdisc_ingress
) {
218 spin_lock(&dev
->queue_lock
);
219 if ((q
= dev
->qdisc_ingress
) != NULL
)
220 fwres
= q
->enqueue(skb
, q
);
221 spin_unlock(&dev
->queue_lock
);
227 /* after ipt_filter */
228 static struct nf_hook_ops ing_ops
=
237 int ingress_init(struct Qdisc
*sch
,struct rtattr
*opt
)
239 struct ingress_qdisc_data
*p
= PRIV(sch
);
241 DPRINTK("ingress_init(sch %p,[qdisc %p],opt %p)\n",sch
,p
,opt
);
242 memset(p
, 0, sizeof(*p
));
243 p
->filter_list
= NULL
;
246 if (nf_register_hook(&ing_ops
) < 0) {
247 printk("Unable to register ingress \n");
251 DPRINTK("ingress_init: qdisc %p\n", sch
);
261 static void ingress_reset(struct Qdisc
*sch
)
263 struct ingress_qdisc_data
*p
= PRIV(sch
);
265 DPRINTK("ingress_reset(sch %p,[qdisc %p])\n", sch
, p
);
277 /* ------------------------------------------------------------- */
280 /* ------------------------------------------------------------- */
282 static void ingress_destroy(struct Qdisc
*sch
)
284 struct ingress_qdisc_data
*p
= PRIV(sch
);
285 struct tcf_proto
*tp
;
287 DPRINTK("ingress_destroy(sch %p,[qdisc %p])\n", sch
, p
);
288 while (p
->filter_list
) {
290 p
->filter_list
= tp
->next
;
291 tp
->ops
->destroy(tp
);
293 memset(p
, 0, sizeof(*p
));
294 p
->filter_list
= NULL
;
302 nf_unregister_hook(&ing_ops
);
309 #ifdef CONFIG_RTNETLINK
312 static int ingress_dump(struct Qdisc
*sch
, struct sk_buff
*skb
)
314 unsigned char *b
= skb
->tail
;
317 rta
= (struct rtattr
*) b
;
318 RTA_PUT(skb
, TCA_OPTIONS
, 0, NULL
);
319 rta
->rta_len
= skb
->tail
- b
;
323 skb_trim(skb
, b
- skb
->data
);
330 static struct Qdisc_class_ops ingress_class_ops
=
332 ingress_graft
, /* graft */
333 ingress_leaf
, /* leaf */
334 ingress_get
, /* get */
335 ingress_put
, /* put */
336 ingress_change
, /* change */
338 ingress_walk
, /* walk */
340 ingress_find_tcf
, /* tcf_chain */
341 ingress_bind_filter
, /* bind_tcf */
342 ingress_put
, /* unbind_tcf */
344 #ifdef CONFIG_RTNETLINK
349 struct Qdisc_ops ingress_qdisc_ops
=
352 &ingress_class_ops
, /* cl_ops */
354 sizeof(struct ingress_qdisc_data
),
356 ingress_enqueue
, /* enqueue */
357 ingress_dequeue
, /* dequeue */
358 ingress_requeue
, /* requeue */
359 ingress_drop
, /* drop */
361 ingress_init
, /* init */
362 ingress_reset
, /* reset */
363 ingress_destroy
, /* destroy */
366 #ifdef CONFIG_RTNETLINK
367 ingress_dump
, /* dump */
372 int init_module(void)
376 if ((ret
= register_qdisc(&ingress_qdisc_ops
)) < 0) {
377 printk("Unable to register Ingress qdisc\n");
381 if (nf_register_hook(&ing_ops
) < 0) {
382 printk("Unable to register ingress on hook \n");
383 unregister_qdisc(&ingress_qdisc_ops
);
391 void cleanup_module(void)
393 nf_unregister_hook(&ing_ops
);
394 unregister_qdisc(&ingress_qdisc_ops
);