[net-next-2.6.git] / net / ipv4 / tunnel4.c

/* tunnel4.c: Generic IP tunnel transformer.
 *
 * Copyright (C) 2003 David S. Miller (davem@redhat.com)
 */

#include <linux/init.h>
#include <linux/module.h>
#include <linux/mutex.h>
#include <linux/netdevice.h>
#include <linux/skbuff.h>
#include <linux/slab.h>
#include <net/icmp.h>
#include <net/ip.h>
#include <net/protocol.h>
#include <net/xfrm.h>

static struct xfrm_tunnel __rcu *tunnel4_handlers __read_mostly;
static struct xfrm_tunnel __rcu *tunnel64_handlers __read_mostly;
static DEFINE_MUTEX(tunnel4_mutex);

static inline struct xfrm_tunnel __rcu **fam_handlers(unsigned short family)
{
	return (family == AF_INET) ? &tunnel4_handlers : &tunnel64_handlers;
}

int xfrm4_tunnel_register(struct xfrm_tunnel *handler, unsigned short family)
{
	struct xfrm_tunnel __rcu **pprev;
	struct xfrm_tunnel *t;

	int ret = -EEXIST;
	int priority = handler->priority;

	mutex_lock(&tunnel4_mutex);

	for (pprev = fam_handlers(family);
	     (t = rcu_dereference_protected(*pprev,
			lockdep_is_held(&tunnel4_mutex))) != NULL;
	     pprev = &t->next) {
		if (t->priority > priority)
			break;
		if (t->priority == priority)
			goto err;
	}

	handler->next = *pprev;
	rcu_assign_pointer(*pprev, handler);

	ret = 0;

err:
	mutex_unlock(&tunnel4_mutex);

	return ret;
}
EXPORT_SYMBOL(xfrm4_tunnel_register);

int xfrm4_tunnel_deregister(struct xfrm_tunnel *handler, unsigned short family)
{
	struct xfrm_tunnel __rcu **pprev;
	struct xfrm_tunnel *t;
	int ret = -ENOENT;

	mutex_lock(&tunnel4_mutex);

	for (pprev = fam_handlers(family);
	     (t = rcu_dereference_protected(*pprev,
			lockdep_is_held(&tunnel4_mutex))) != NULL;
	     pprev = &t->next) {
		if (t == handler) {
			*pprev = handler->next;
			ret = 0;
			break;
		}
	}

	mutex_unlock(&tunnel4_mutex);

	synchronize_net();

	return ret;
}
EXPORT_SYMBOL(xfrm4_tunnel_deregister);

#define for_each_tunnel_rcu(head, handler)		\
	for (handler = rcu_dereference(head);		\
	     handler != NULL;				\
	     handler = rcu_dereference(handler->next))	\
	
static int tunnel4_rcv(struct sk_buff *skb)
{
	struct xfrm_tunnel *handler;

	if (!pskb_may_pull(skb, sizeof(struct iphdr)))
		goto drop;

	for_each_tunnel_rcu(tunnel4_handlers, handler)
		if (!handler->handler(skb))
			return 0;

	icmp_send(skb, ICMP_DEST_UNREACH, ICMP_PORT_UNREACH, 0);

drop:
	kfree_skb(skb);
	return 0;
}

#if defined(CONFIG_IPV6) || defined(CONFIG_IPV6_MODULE)
static int tunnel64_rcv(struct sk_buff *skb)
{
	struct xfrm_tunnel *handler;

	if (!pskb_may_pull(skb, sizeof(struct ipv6hdr)))
		goto drop;

	for_each_tunnel_rcu(tunnel64_handlers, handler)
		if (!handler->handler(skb))
			return 0;

	icmp_send(skb, ICMP_DEST_UNREACH, ICMP_PORT_UNREACH, 0);

drop:
	kfree_skb(skb);
	return 0;
}
#endif

static void tunnel4_err(struct sk_buff *skb, u32 info)
{
	struct xfrm_tunnel *handler;

	for_each_tunnel_rcu(tunnel4_handlers, handler)
		if (!handler->err_handler(skb, info))
			break;
}

#if defined(CONFIG_IPV6) || defined(CONFIG_IPV6_MODULE)
static void tunnel64_err(struct sk_buff *skb, u32 info)
{
	struct xfrm_tunnel *handler;

	for_each_tunnel_rcu(tunnel64_handlers, handler)
		if (!handler->err_handler(skb, info))
			break;
}
#endif

static const struct net_protocol tunnel4_protocol = {
	.handler	=	tunnel4_rcv,
	.err_handler	=	tunnel4_err,
	.no_policy	=	1,
	.netns_ok	=	1,
};

#if defined(CONFIG_IPV6) || defined(CONFIG_IPV6_MODULE)
static const struct net_protocol tunnel64_protocol = {
	.handler	=	tunnel64_rcv,
	.err_handler	=	tunnel64_err,
	.no_policy	=	1,
	.netns_ok	=	1,
};
#endif

static int __init tunnel4_init(void)
{
	if (inet_add_protocol(&tunnel4_protocol, IPPROTO_IPIP)) {
		printk(KERN_ERR "tunnel4 init: can't add protocol\n");
		return -EAGAIN;
	}
#if defined(CONFIG_IPV6) || defined(CONFIG_IPV6_MODULE)
	if (inet_add_protocol(&tunnel64_protocol, IPPROTO_IPV6)) {
		printk(KERN_ERR "tunnel64 init: can't add protocol\n");
		inet_del_protocol(&tunnel4_protocol, IPPROTO_IPIP);
		return -EAGAIN;
	}
#endif
	return 0;
}

static void __exit tunnel4_fini(void)
{
#if defined(CONFIG_IPV6) || defined(CONFIG_IPV6_MODULE)
	if (inet_del_protocol(&tunnel64_protocol, IPPROTO_IPV6))
		printk(KERN_ERR "tunnel64 close: can't remove protocol\n");
#endif
	if (inet_del_protocol(&tunnel4_protocol, IPPROTO_IPIP))
		printk(KERN_ERR "tunnel4 close: can't remove protocol\n");
}

module_init(tunnel4_init);
module_exit(tunnel4_fini);
MODULE_LICENSE("GPL");
Commit	Line	Data
d2acc347 HX	1	/* tunnel4.c: Generic IP tunnel transformer.
	2	*
	3	* Copyright (C) 2003 David S. Miller (davem@redhat.com)
	4	*/
	5
	6	#include <linux/init.h>
	7	#include <linux/module.h>
	8	#include <linux/mutex.h>
	9	#include <linux/netdevice.h>
	10	#include <linux/skbuff.h>
5a0e3ad6	11	#include <linux/slab.h>
50fba2aa HX	12	#include <net/icmp.h>
50fba2aa HX	13	#include <net/ip.h>
d2acc347 HX	14	#include <net/protocol.h>
	15	#include <net/xfrm.h>
	16
b33eab08 ED	17	static struct xfrm_tunnel __rcu *tunnel4_handlers __read_mostly;
b33eab08 ED	18	static struct xfrm_tunnel __rcu *tunnel64_handlers __read_mostly;
d2acc347 HX	19	static DEFINE_MUTEX(tunnel4_mutex);
d2acc347 HX	20
b33eab08	21	static inline struct xfrm_tunnel __rcu **fam_handlers(unsigned short family)
358352b8 PE	22	{
	23	return (family == AF_INET) ? &tunnel4_handlers : &tunnel64_handlers;
	24	}
	25
c0d56408	26	int xfrm4_tunnel_register(struct xfrm_tunnel *handler, unsigned short family)
d2acc347	27	{
b33eab08 ED	28	struct xfrm_tunnel __rcu **pprev;
	29	struct xfrm_tunnel *t;
	30
d2acc347 HX	31	int ret = -EEXIST;
	32	int priority = handler->priority;
	33
	34	mutex_lock(&tunnel4_mutex);
	35
b33eab08 ED	36	for (pprev = fam_handlers(family);
	37	(t = rcu_dereference_protected(*pprev,
	38	lockdep_is_held(&tunnel4_mutex))) != NULL;
	39	pprev = &t->next) {
	40	if (t->priority > priority)
d2acc347	41	break;
b33eab08	42	if (t->priority == priority)
d2acc347 HX	43	goto err;
	44	}
	45
	46	handler->next = *pprev;
49d61e23	47	rcu_assign_pointer(*pprev, handler);
d2acc347 HX	48
	49	ret = 0;
	50
	51	err:
	52	mutex_unlock(&tunnel4_mutex);
	53
	54	return ret;
	55	}
d2acc347 HX	56	EXPORT_SYMBOL(xfrm4_tunnel_register);
d2acc347 HX	57
c0d56408	58	int xfrm4_tunnel_deregister(struct xfrm_tunnel *handler, unsigned short family)
d2acc347	59	{
b33eab08 ED	60	struct xfrm_tunnel __rcu **pprev;
b33eab08 ED	61	struct xfrm_tunnel *t;
d2acc347 HX	62	int ret = -ENOENT;
	63
	64	mutex_lock(&tunnel4_mutex);
	65
b33eab08 ED	66	for (pprev = fam_handlers(family);
	67	(t = rcu_dereference_protected(*pprev,
	68	lockdep_is_held(&tunnel4_mutex))) != NULL;
	69	pprev = &t->next) {
	70	if (t == handler) {
d2acc347 HX	71	*pprev = handler->next;
	72	ret = 0;
	73	break;
	74	}
	75	}
	76
	77	mutex_unlock(&tunnel4_mutex);
	78
	79	synchronize_net();
	80
	81	return ret;
	82	}
d2acc347 HX	83	EXPORT_SYMBOL(xfrm4_tunnel_deregister);
d2acc347 HX	84
875168a9 ED	85	#define for_each_tunnel_rcu(head, handler) \
	86	for (handler = rcu_dereference(head); \
	87	handler != NULL; \
	88	handler = rcu_dereference(handler->next)) \
	89
d2acc347 HX	90	static int tunnel4_rcv(struct sk_buff *skb)
	91	{
	92	struct xfrm_tunnel *handler;
	93
50fba2aa HX	94	if (!pskb_may_pull(skb, sizeof(struct iphdr)))
	95	goto drop;
	96
875168a9	97	for_each_tunnel_rcu(tunnel4_handlers, handler)
d2acc347 HX	98	if (!handler->handler(skb))
	99	return 0;
	100
50fba2aa HX	101	icmp_send(skb, ICMP_DEST_UNREACH, ICMP_PORT_UNREACH, 0);
	102
	103	drop:
d2acc347 HX	104	kfree_skb(skb);
	105	return 0;
	106	}
	107
c0d56408 KM	108	#if defined(CONFIG_IPV6) \|\| defined(CONFIG_IPV6_MODULE)
	109	static int tunnel64_rcv(struct sk_buff *skb)
	110	{
	111	struct xfrm_tunnel *handler;
	112
baa2bfb8	113	if (!pskb_may_pull(skb, sizeof(struct ipv6hdr)))
c0d56408 KM	114	goto drop;
c0d56408 KM	115
875168a9	116	for_each_tunnel_rcu(tunnel64_handlers, handler)
c0d56408 KM	117	if (!handler->handler(skb))
	118	return 0;
	119
	120	icmp_send(skb, ICMP_DEST_UNREACH, ICMP_PORT_UNREACH, 0);
	121
	122	drop:
	123	kfree_skb(skb);
	124	return 0;
	125	}
	126	#endif
	127
d2acc347 HX	128	static void tunnel4_err(struct sk_buff *skb, u32 info)
	129	{
	130	struct xfrm_tunnel *handler;
	131
875168a9	132	for_each_tunnel_rcu(tunnel4_handlers, handler)
d2acc347 HX	133	if (!handler->err_handler(skb, info))
	134	break;
	135	}
	136
99f93326 PE	137	#if defined(CONFIG_IPV6) \|\| defined(CONFIG_IPV6_MODULE)
	138	static void tunnel64_err(struct sk_buff *skb, u32 info)
	139	{
	140	struct xfrm_tunnel *handler;
	141
875168a9	142	for_each_tunnel_rcu(tunnel64_handlers, handler)
99f93326 PE	143	if (!handler->err_handler(skb, info))
	144	break;
	145	}
	146	#endif
	147
32613090	148	static const struct net_protocol tunnel4_protocol = {
d2acc347 HX	149	.handler = tunnel4_rcv,
	150	.err_handler = tunnel4_err,
	151	.no_policy = 1,
4597a0ce	152	.netns_ok = 1,
d2acc347 HX	153	};
d2acc347 HX	154
c0d56408	155	#if defined(CONFIG_IPV6) \|\| defined(CONFIG_IPV6_MODULE)
32613090	156	static const struct net_protocol tunnel64_protocol = {
c0d56408	157	.handler = tunnel64_rcv,
99f93326	158	.err_handler = tunnel64_err,
c0d56408	159	.no_policy = 1,
b0970c42	160	.netns_ok = 1,
c0d56408 KM	161	};
	162	#endif
	163
d2acc347 HX	164	static int __init tunnel4_init(void)
	165	{
	166	if (inet_add_protocol(&tunnel4_protocol, IPPROTO_IPIP)) {
	167	printk(KERN_ERR "tunnel4 init: can't add protocol\n");
	168	return -EAGAIN;
	169	}
c0d56408 KM	170	#if defined(CONFIG_IPV6) \|\| defined(CONFIG_IPV6_MODULE)
	171	if (inet_add_protocol(&tunnel64_protocol, IPPROTO_IPV6)) {
	172	printk(KERN_ERR "tunnel64 init: can't add protocol\n");
	173	inet_del_protocol(&tunnel4_protocol, IPPROTO_IPIP);
	174	return -EAGAIN;
	175	}
	176	#endif
d2acc347 HX	177	return 0;
	178	}
	179
	180	static void __exit tunnel4_fini(void)
	181	{
c0d56408 KM	182	#if defined(CONFIG_IPV6) \|\| defined(CONFIG_IPV6_MODULE)
	183	if (inet_del_protocol(&tunnel64_protocol, IPPROTO_IPV6))
	184	printk(KERN_ERR "tunnel64 close: can't remove protocol\n");
	185	#endif
d2acc347 HX	186	if (inet_del_protocol(&tunnel4_protocol, IPPROTO_IPIP))
	187	printk(KERN_ERR "tunnel4 close: can't remove protocol\n");
	188	}
	189
	190	module_init(tunnel4_init);
	191	module_exit(tunnel4_fini);
	192	MODULE_LICENSE("GPL");