[deliverable/linux.git] / net / sched / sch_ingress.c

/* net/sched/sch_ingress.c - Ingress qdisc
 *              This program is free software; you can redistribute it and/or
 *              modify it under the terms of the GNU General Public License
 *              as published by the Free Software Foundation; either version
 *              2 of the License, or (at your option) any later version.
 *
 * Authors:     Jamal Hadi Salim 1999
 */

#include <linux/module.h>
#include <linux/types.h>
#include <linux/list.h>
#include <linux/skbuff.h>
#include <linux/rtnetlink.h>
#include <net/netlink.h>
#include <net/pkt_sched.h>


struct ingress_qdisc_data {
	struct tcf_proto	*filter_list;
};

/* ------------------------- Class/flow operations ------------------------- */

static struct Qdisc *ingress_leaf(struct Qdisc *sch, unsigned long arg)
{
	return NULL;
}

static unsigned long ingress_get(struct Qdisc *sch, u32 classid)
{
	return TC_H_MIN(classid) + 1;
}

static unsigned long ingress_bind_filter(struct Qdisc *sch,
					 unsigned long parent, u32 classid)
{
	return ingress_get(sch, classid);
}

static void ingress_put(struct Qdisc *sch, unsigned long cl)
{
}

static void ingress_walk(struct Qdisc *sch, struct qdisc_walker *walker)
{
}

static struct tcf_proto **ingress_find_tcf(struct Qdisc *sch, unsigned long cl)
{
	struct ingress_qdisc_data *p = qdisc_priv(sch);

	return &p->filter_list;
}

/* --------------------------- Qdisc operations ---------------------------- */

static int ingress_enqueue(struct sk_buff *skb, struct Qdisc *sch)
{
	struct ingress_qdisc_data *p = qdisc_priv(sch);
	struct tcf_result res;
	int result;

	result = tc_classify(skb, p->filter_list, &res);

	qdisc_bstats_update(sch, skb);
	switch (result) {
	case TC_ACT_SHOT:
		result = TC_ACT_SHOT;
		sch->qstats.drops++;
		break;
	case TC_ACT_STOLEN:
	case TC_ACT_QUEUED:
		result = TC_ACT_STOLEN;
		break;
	case TC_ACT_RECLASSIFY:
	case TC_ACT_OK:
		skb->tc_index = TC_H_MIN(res.classid);
	default:
		result = TC_ACT_OK;
		break;
	}

	return result;
}

/* ------------------------------------------------------------- */

static void ingress_destroy(struct Qdisc *sch)
{
	struct ingress_qdisc_data *p = qdisc_priv(sch);

	tcf_destroy_chain(&p->filter_list);
}

static int ingress_dump(struct Qdisc *sch, struct sk_buff *skb)
{
	struct nlattr *nest;

	nest = nla_nest_start(skb, TCA_OPTIONS);
	if (nest == NULL)
		goto nla_put_failure;
	return nla_nest_end(skb, nest);

nla_put_failure:
	nla_nest_cancel(skb, nest);
	return -1;
}

static const struct Qdisc_class_ops ingress_class_ops = {
	.leaf		=	ingress_leaf,
	.get		=	ingress_get,
	.put		=	ingress_put,
	.walk		=	ingress_walk,
	.tcf_chain	=	ingress_find_tcf,
	.bind_tcf	=	ingress_bind_filter,
	.unbind_tcf	=	ingress_put,
};

static struct Qdisc_ops ingress_qdisc_ops __read_mostly = {
	.cl_ops		=	&ingress_class_ops,
	.id		=	"ingress",
	.priv_size	=	sizeof(struct ingress_qdisc_data),
	.enqueue	=	ingress_enqueue,
	.destroy	=	ingress_destroy,
	.dump		=	ingress_dump,
	.owner		=	THIS_MODULE,
};

static int __init ingress_module_init(void)
{
	return register_qdisc(&ingress_qdisc_ops);
}

static void __exit ingress_module_exit(void)
{
	unregister_qdisc(&ingress_qdisc_ops);
}

module_init(ingress_module_init)
module_exit(ingress_module_exit)
MODULE_LICENSE("GPL");
Commit	Line	Data
10297b99	1	/* net/sched/sch_ingress.c - Ingress qdisc
1da177e4 LT	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.
	6	*
	7	* Authors: Jamal Hadi Salim 1999
	8	*/
	9
1da177e4 LT	10	#include <linux/module.h>
1da177e4 LT	11	#include <linux/types.h>
0ba48053	12	#include <linux/list.h>
1da177e4	13	#include <linux/skbuff.h>
1da177e4	14	#include <linux/rtnetlink.h>
dc5fc579	15	#include <net/netlink.h>
1da177e4	16	#include <net/pkt_sched.h>
1da177e4 LT	17
1da177e4 LT	18
1da177e4	19	struct ingress_qdisc_data {
1da177e4 LT	20	struct tcf_proto *filter_list;
	21	};
	22
1da177e4 LT	23	/* ------------------------- Class/flow operations ------------------------- */
1da177e4 LT	24
1da177e4 LT	25	static struct Qdisc ingress_leaf(struct Qdisc sch, unsigned long arg)
	26	{
	27	return NULL;
	28	}
	29
58f4df42	30	static unsigned long ingress_get(struct Qdisc *sch, u32 classid)
1da177e4	31	{
1da177e4 LT	32	return TC_H_MIN(classid) + 1;
	33	}
	34
1da177e4	35	static unsigned long ingress_bind_filter(struct Qdisc *sch,
58f4df42	36	unsigned long parent, u32 classid)
1da177e4 LT	37	{
	38	return ingress_get(sch, classid);
	39	}
	40
1da177e4 LT	41	static void ingress_put(struct Qdisc *sch, unsigned long cl)
	42	{
	43	}
	44
58f4df42	45	static void ingress_walk(struct Qdisc sch, struct qdisc_walker walker)
1da177e4	46	{
1da177e4 LT	47	}
1da177e4 LT	48
58f4df42	49	static struct tcf_proto *ingress_find_tcf(struct Qdisc sch, unsigned long cl)
1da177e4	50	{
cb53c048	51	struct ingress_qdisc_data *p = qdisc_priv(sch);
1da177e4 LT	52
	53	return &p->filter_list;
	54	}
	55
1da177e4 LT	56	/* --------------------------- Qdisc operations ---------------------------- */
1da177e4 LT	57
58f4df42	58	static int ingress_enqueue(struct sk_buff skb, struct Qdisc sch)
1da177e4	59	{
cb53c048	60	struct ingress_qdisc_data *p = qdisc_priv(sch);
1da177e4 LT	61	struct tcf_result res;
	62	int result;
	63
1da177e4	64	result = tc_classify(skb, p->filter_list, &res);
a4781221	65
bfe0d029	66	qdisc_bstats_update(sch, skb);
1da177e4	67	switch (result) {
58f4df42 PM	68	case TC_ACT_SHOT:
	69	result = TC_ACT_SHOT;
	70	sch->qstats.drops++;
	71	break;
	72	case TC_ACT_STOLEN:
	73	case TC_ACT_QUEUED:
	74	result = TC_ACT_STOLEN;
	75	break;
	76	case TC_ACT_RECLASSIFY:
	77	case TC_ACT_OK:
	78	skb->tc_index = TC_H_MIN(res.classid);
	79	default:
	80	result = TC_ACT_OK;
	81	break;
3ff50b79	82	}
1da177e4 LT	83
	84	return result;
	85	}
	86
1da177e4 LT	87	/* ------------------------------------------------------------- */
	88
	89	static void ingress_destroy(struct Qdisc *sch)
	90	{
cb53c048	91	struct ingress_qdisc_data *p = qdisc_priv(sch);
1da177e4	92
ff31ab56	93	tcf_destroy_chain(&p->filter_list);
1da177e4 LT	94	}
1da177e4 LT	95
1da177e4 LT	96	static int ingress_dump(struct Qdisc sch, struct sk_buff skb)
1da177e4 LT	97	{
4b3550ef	98	struct nlattr *nest;
1da177e4	99
4b3550ef PM	100	nest = nla_nest_start(skb, TCA_OPTIONS);
	101	if (nest == NULL)
	102	goto nla_put_failure;
d59b7d80	103	return nla_nest_end(skb, nest);
1da177e4	104
1e90474c	105	nla_put_failure:
4b3550ef	106	nla_nest_cancel(skb, nest);
1da177e4 LT	107	return -1;
	108	}
	109
20fea08b	110	static const struct Qdisc_class_ops ingress_class_ops = {
1da177e4 LT	111	.leaf = ingress_leaf,
	112	.get = ingress_get,
	113	.put = ingress_put,
1da177e4 LT	114	.walk = ingress_walk,
	115	.tcf_chain = ingress_find_tcf,
	116	.bind_tcf = ingress_bind_filter,
	117	.unbind_tcf = ingress_put,
1da177e4 LT	118	};
1da177e4 LT	119
20fea08b	120	static struct Qdisc_ops ingress_qdisc_ops __read_mostly = {
1da177e4 LT	121	.cl_ops = &ingress_class_ops,
	122	.id = "ingress",
	123	.priv_size = sizeof(struct ingress_qdisc_data),
	124	.enqueue = ingress_enqueue,
1da177e4	125	.destroy = ingress_destroy,
1da177e4 LT	126	.dump = ingress_dump,
	127	.owner = THIS_MODULE,
	128	};
	129
	130	static int __init ingress_module_init(void)
	131	{
89168764	132	return register_qdisc(&ingress_qdisc_ops);
1da177e4	133	}
58f4df42	134
10297b99	135	static void __exit ingress_module_exit(void)
1da177e4 LT	136	{
1da177e4 LT	137	unregister_qdisc(&ingress_qdisc_ops);
1da177e4	138	}
58f4df42	139
1da177e4 LT	140	module_init(ingress_module_init)
	141	module_exit(ingress_module_exit)
	142	MODULE_LICENSE("GPL");