[linux-2.6-block.git] / net / sched / act_skbedit.c

/*
 * Copyright (c) 2008, Intel Corporation.
 *
 * This program is free software; you can redistribute it and/or modify it
 * under the terms and conditions of the GNU General Public License,
 * version 2, as published by the Free Software Foundation.
 *
 * This program is distributed in the hope it will be useful, but WITHOUT
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
 * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License for
 * more details.
 *
 * You should have received a copy of the GNU General Public License along with
 * this program; if not, see <http://www.gnu.org/licenses/>.
 *
 * Author: Alexander Duyck <alexander.h.duyck@intel.com>
 */

#include <linux/module.h>
#include <linux/init.h>
#include <linux/kernel.h>
#include <linux/skbuff.h>
#include <linux/rtnetlink.h>
#include <net/netlink.h>
#include <net/pkt_sched.h>

#include <linux/tc_act/tc_skbedit.h>
#include <net/tc_act/tc_skbedit.h>

#define SKBEDIT_TAB_MASK     15

static int tcf_skbedit(struct sk_buff *skb, const struct tc_action *a,
		       struct tcf_result *res)
{
	struct tcf_skbedit *d = a->priv;

	spin_lock(&d->tcf_lock);
	d->tcf_tm.lastuse = jiffies;
	bstats_update(&d->tcf_bstats, skb);

	if (d->flags & SKBEDIT_F_PRIORITY)
		skb->priority = d->priority;
	if (d->flags & SKBEDIT_F_QUEUE_MAPPING &&
	    skb->dev->real_num_tx_queues > d->queue_mapping)
		skb_set_queue_mapping(skb, d->queue_mapping);
	if (d->flags & SKBEDIT_F_MARK)
		skb->mark = d->mark;

	spin_unlock(&d->tcf_lock);
	return d->tcf_action;
}

static const struct nla_policy skbedit_policy[TCA_SKBEDIT_MAX + 1] = {
	[TCA_SKBEDIT_PARMS]		= { .len = sizeof(struct tc_skbedit) },
	[TCA_SKBEDIT_PRIORITY]		= { .len = sizeof(u32) },
	[TCA_SKBEDIT_QUEUE_MAPPING]	= { .len = sizeof(u16) },
	[TCA_SKBEDIT_MARK]		= { .len = sizeof(u32) },
};

static int tcf_skbedit_init(struct net *net, struct nlattr *nla,
			    struct nlattr *est, struct tc_action *a,
			    int ovr, int bind)
{
	struct nlattr *tb[TCA_SKBEDIT_MAX + 1];
	struct tc_skbedit *parm;
	struct tcf_skbedit *d;
	u32 flags = 0, *priority = NULL, *mark = NULL;
	u16 *queue_mapping = NULL;
	int ret = 0, err;

	if (nla == NULL)
		return -EINVAL;

	err = nla_parse_nested(tb, TCA_SKBEDIT_MAX, nla, skbedit_policy);
	if (err < 0)
		return err;

	if (tb[TCA_SKBEDIT_PARMS] == NULL)
		return -EINVAL;

	if (tb[TCA_SKBEDIT_PRIORITY] != NULL) {
		flags |= SKBEDIT_F_PRIORITY;
		priority = nla_data(tb[TCA_SKBEDIT_PRIORITY]);
	}

	if (tb[TCA_SKBEDIT_QUEUE_MAPPING] != NULL) {
		flags |= SKBEDIT_F_QUEUE_MAPPING;
		queue_mapping = nla_data(tb[TCA_SKBEDIT_QUEUE_MAPPING]);
	}

	if (tb[TCA_SKBEDIT_MARK] != NULL) {
		flags |= SKBEDIT_F_MARK;
		mark = nla_data(tb[TCA_SKBEDIT_MARK]);
	}

	if (!flags)
		return -EINVAL;

	parm = nla_data(tb[TCA_SKBEDIT_PARMS]);

	if (!tcf_hash_check(parm->index, a, bind)) {
		ret = tcf_hash_create(parm->index, est, a, sizeof(*d), bind);
		if (ret)
			return ret;

		d = to_skbedit(a);
		ret = ACT_P_CREATED;
	} else {
		d = to_skbedit(a);
		if (bind)
			return 0;
		tcf_hash_release(a, bind);
		if (!ovr)
			return -EEXIST;
	}

	spin_lock_bh(&d->tcf_lock);

	d->flags = flags;
	if (flags & SKBEDIT_F_PRIORITY)
		d->priority = *priority;
	if (flags & SKBEDIT_F_QUEUE_MAPPING)
		d->queue_mapping = *queue_mapping;
	if (flags & SKBEDIT_F_MARK)
		d->mark = *mark;

	d->tcf_action = parm->action;

	spin_unlock_bh(&d->tcf_lock);

	if (ret == ACT_P_CREATED)
		tcf_hash_insert(a);
	return ret;
}

static int tcf_skbedit_dump(struct sk_buff *skb, struct tc_action *a,
			    int bind, int ref)
{
	unsigned char *b = skb_tail_pointer(skb);
	struct tcf_skbedit *d = a->priv;
	struct tc_skbedit opt = {
		.index   = d->tcf_index,
		.refcnt  = d->tcf_refcnt - ref,
		.bindcnt = d->tcf_bindcnt - bind,
		.action  = d->tcf_action,
	};
	struct tcf_t t;

	if (nla_put(skb, TCA_SKBEDIT_PARMS, sizeof(opt), &opt))
		goto nla_put_failure;
	if ((d->flags & SKBEDIT_F_PRIORITY) &&
	    nla_put(skb, TCA_SKBEDIT_PRIORITY, sizeof(d->priority),
		    &d->priority))
		goto nla_put_failure;
	if ((d->flags & SKBEDIT_F_QUEUE_MAPPING) &&
	    nla_put(skb, TCA_SKBEDIT_QUEUE_MAPPING,
		    sizeof(d->queue_mapping), &d->queue_mapping))
		goto nla_put_failure;
	if ((d->flags & SKBEDIT_F_MARK) &&
	    nla_put(skb, TCA_SKBEDIT_MARK, sizeof(d->mark),
		    &d->mark))
		goto nla_put_failure;
	t.install = jiffies_to_clock_t(jiffies - d->tcf_tm.install);
	t.lastuse = jiffies_to_clock_t(jiffies - d->tcf_tm.lastuse);
	t.expires = jiffies_to_clock_t(d->tcf_tm.expires);
	if (nla_put(skb, TCA_SKBEDIT_TM, sizeof(t), &t))
		goto nla_put_failure;
	return skb->len;

nla_put_failure:
	nlmsg_trim(skb, b);
	return -1;
}

static struct tc_action_ops act_skbedit_ops = {
	.kind		=	"skbedit",
	.type		=	TCA_ACT_SKBEDIT,
	.owner		=	THIS_MODULE,
	.act		=	tcf_skbedit,
	.dump		=	tcf_skbedit_dump,
	.init		=	tcf_skbedit_init,
};

MODULE_AUTHOR("Alexander Duyck, <alexander.h.duyck@intel.com>");
MODULE_DESCRIPTION("SKB Editing");
MODULE_LICENSE("GPL");

static int __init skbedit_init_module(void)
{
	return tcf_register_action(&act_skbedit_ops, SKBEDIT_TAB_MASK);
}

static void __exit skbedit_cleanup_module(void)
{
	tcf_unregister_action(&act_skbedit_ops);
}

module_init(skbedit_init_module);
module_exit(skbedit_cleanup_module);
Commit	Line	Data
ca9b0e27 AD	1	/*
	2	* Copyright (c) 2008, Intel Corporation.
	3	*
	4	* This program is free software; you can redistribute it and/or modify it
	5	* under the terms and conditions of the GNU General Public License,
	6	* version 2, as published by the Free Software Foundation.
	7	*
	8	* This program is distributed in the hope it will be useful, but WITHOUT
	9	* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
	10	* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
	11	* more details.
	12	*
	13	* You should have received a copy of the GNU General Public License along with
c057b190	14	* this program; if not, see <http://www.gnu.org/licenses/>.
ca9b0e27 AD	15	*
	16	* Author: Alexander Duyck <alexander.h.duyck@intel.com>
	17	*/
	18
	19	#include <linux/module.h>
	20	#include <linux/init.h>
	21	#include <linux/kernel.h>
	22	#include <linux/skbuff.h>
	23	#include <linux/rtnetlink.h>
	24	#include <net/netlink.h>
	25	#include <net/pkt_sched.h>
	26
	27	#include <linux/tc_act/tc_skbedit.h>
	28	#include <net/tc_act/tc_skbedit.h>
	29
	30	#define SKBEDIT_TAB_MASK 15
ca9b0e27	31
dc7f9f6e	32	static int tcf_skbedit(struct sk_buff skb, const struct tc_action a,
ca9b0e27 AD	33	struct tcf_result *res)
	34	{
	35	struct tcf_skbedit *d = a->priv;
	36
	37	spin_lock(&d->tcf_lock);
	38	d->tcf_tm.lastuse = jiffies;
bfe0d029	39	bstats_update(&d->tcf_bstats, skb);
ca9b0e27 AD	40
	41	if (d->flags & SKBEDIT_F_PRIORITY)
	42	skb->priority = d->priority;
	43	if (d->flags & SKBEDIT_F_QUEUE_MAPPING &&
	44	skb->dev->real_num_tx_queues > d->queue_mapping)
	45	skb_set_queue_mapping(skb, d->queue_mapping);
1c55d62e	46	if (d->flags & SKBEDIT_F_MARK)
1c55d62e	47	skb->mark = d->mark;
ca9b0e27 AD	48
	49	spin_unlock(&d->tcf_lock);
	50	return d->tcf_action;
	51	}
	52
	53	static const struct nla_policy skbedit_policy[TCA_SKBEDIT_MAX + 1] = {
	54	[TCA_SKBEDIT_PARMS] = { .len = sizeof(struct tc_skbedit) },
	55	[TCA_SKBEDIT_PRIORITY] = { .len = sizeof(u32) },
	56	[TCA_SKBEDIT_QUEUE_MAPPING] = { .len = sizeof(u16) },
1c55d62e	57	[TCA_SKBEDIT_MARK] = { .len = sizeof(u32) },
ca9b0e27 AD	58	};
ca9b0e27 AD	59
c1b52739 BL	60	static int tcf_skbedit_init(struct net net, struct nlattr nla,
	61	struct nlattr est, struct tc_action a,
	62	int ovr, int bind)
ca9b0e27 AD	63	{
	64	struct nlattr *tb[TCA_SKBEDIT_MAX + 1];
	65	struct tc_skbedit *parm;
	66	struct tcf_skbedit *d;
1c55d62e	67	u32 flags = 0, priority = NULL, mark = NULL;
ca9b0e27 AD	68	u16 *queue_mapping = NULL;
	69	int ret = 0, err;
	70
	71	if (nla == NULL)
	72	return -EINVAL;
	73
	74	err = nla_parse_nested(tb, TCA_SKBEDIT_MAX, nla, skbedit_policy);
	75	if (err < 0)
	76	return err;
	77
	78	if (tb[TCA_SKBEDIT_PARMS] == NULL)
	79	return -EINVAL;
	80
	81	if (tb[TCA_SKBEDIT_PRIORITY] != NULL) {
	82	flags \|= SKBEDIT_F_PRIORITY;
	83	priority = nla_data(tb[TCA_SKBEDIT_PRIORITY]);
	84	}
	85
	86	if (tb[TCA_SKBEDIT_QUEUE_MAPPING] != NULL) {
	87	flags \|= SKBEDIT_F_QUEUE_MAPPING;
	88	queue_mapping = nla_data(tb[TCA_SKBEDIT_QUEUE_MAPPING]);
	89	}
1c55d62e	90
	91	if (tb[TCA_SKBEDIT_MARK] != NULL) {
	92	flags \|= SKBEDIT_F_MARK;
	93	mark = nla_data(tb[TCA_SKBEDIT_MARK]);
	94	}
	95
ca9b0e27 AD	96	if (!flags)
	97	return -EINVAL;
	98
	99	parm = nla_data(tb[TCA_SKBEDIT_PARMS]);
	100
86062033 WC	101	if (!tcf_hash_check(parm->index, a, bind)) {
	102	ret = tcf_hash_create(parm->index, est, a, sizeof(*d), bind);
	103	if (ret)
	104	return ret;
ca9b0e27	105
86062033	106	d = to_skbedit(a);
ca9b0e27 AD	107	ret = ACT_P_CREATED;
ca9b0e27 AD	108	} else {
86062033	109	d = to_skbedit(a);
1a29321e JHS	110	if (bind)
1a29321e JHS	111	return 0;
86062033	112	tcf_hash_release(a, bind);
1a29321e	113	if (!ovr)
ca9b0e27	114	return -EEXIST;
ca9b0e27 AD	115	}
	116
	117	spin_lock_bh(&d->tcf_lock);
	118
	119	d->flags = flags;
	120	if (flags & SKBEDIT_F_PRIORITY)
	121	d->priority = *priority;
	122	if (flags & SKBEDIT_F_QUEUE_MAPPING)
	123	d->queue_mapping = *queue_mapping;
1c55d62e	124	if (flags & SKBEDIT_F_MARK)
	125	d->mark = *mark;
	126
ca9b0e27 AD	127	d->tcf_action = parm->action;
	128
	129	spin_unlock_bh(&d->tcf_lock);
	130
	131	if (ret == ACT_P_CREATED)
86062033	132	tcf_hash_insert(a);
ca9b0e27 AD	133	return ret;
	134	}
	135
cc7ec456 ED	136	static int tcf_skbedit_dump(struct sk_buff skb, struct tc_action a,
cc7ec456 ED	137	int bind, int ref)
ca9b0e27 AD	138	{
	139	unsigned char *b = skb_tail_pointer(skb);
	140	struct tcf_skbedit *d = a->priv;
1c40be12 ED	141	struct tc_skbedit opt = {
	142	.index = d->tcf_index,
	143	.refcnt = d->tcf_refcnt - ref,
	144	.bindcnt = d->tcf_bindcnt - bind,
	145	.action = d->tcf_action,
	146	};
ca9b0e27 AD	147	struct tcf_t t;
ca9b0e27 AD	148
1b34ec43 DM	149	if (nla_put(skb, TCA_SKBEDIT_PARMS, sizeof(opt), &opt))
	150	goto nla_put_failure;
	151	if ((d->flags & SKBEDIT_F_PRIORITY) &&
	152	nla_put(skb, TCA_SKBEDIT_PRIORITY, sizeof(d->priority),
	153	&d->priority))
	154	goto nla_put_failure;
	155	if ((d->flags & SKBEDIT_F_QUEUE_MAPPING) &&
	156	nla_put(skb, TCA_SKBEDIT_QUEUE_MAPPING,
	157	sizeof(d->queue_mapping), &d->queue_mapping))
	158	goto nla_put_failure;
	159	if ((d->flags & SKBEDIT_F_MARK) &&
	160	nla_put(skb, TCA_SKBEDIT_MARK, sizeof(d->mark),
	161	&d->mark))
	162	goto nla_put_failure;
ca9b0e27 AD	163	t.install = jiffies_to_clock_t(jiffies - d->tcf_tm.install);
	164	t.lastuse = jiffies_to_clock_t(jiffies - d->tcf_tm.lastuse);
	165	t.expires = jiffies_to_clock_t(d->tcf_tm.expires);
1b34ec43 DM	166	if (nla_put(skb, TCA_SKBEDIT_TM, sizeof(t), &t))
1b34ec43 DM	167	goto nla_put_failure;
ca9b0e27 AD	168	return skb->len;
	169
	170	nla_put_failure:
	171	nlmsg_trim(skb, b);
	172	return -1;
	173	}
	174
	175	static struct tc_action_ops act_skbedit_ops = {
	176	.kind = "skbedit",
ca9b0e27	177	.type = TCA_ACT_SKBEDIT,
ca9b0e27 AD	178	.owner = THIS_MODULE,
	179	.act = tcf_skbedit,
	180	.dump = tcf_skbedit_dump,
ca9b0e27	181	.init = tcf_skbedit_init,
ca9b0e27 AD	182	};
	183
	184	MODULE_AUTHOR("Alexander Duyck, <alexander.h.duyck@intel.com>");
	185	MODULE_DESCRIPTION("SKB Editing");
	186	MODULE_LICENSE("GPL");
	187
	188	static int __init skbedit_init_module(void)
	189	{
4f1e9d89	190	return tcf_register_action(&act_skbedit_ops, SKBEDIT_TAB_MASK);
ca9b0e27 AD	191	}
	192
	193	static void __exit skbedit_cleanup_module(void)
	194	{
	195	tcf_unregister_action(&act_skbedit_ops);
	196	}
	197
	198	module_init(skbedit_init_module);
	199	module_exit(skbedit_cleanup_module);