[deliverable/linux.git] / net / openvswitch / vport.h

/*
 * Copyright (c) 2007-2012 Nicira, Inc.
 *
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of version 2 of the GNU General Public
 * License as published by the Free Software Foundation.
 *
 * This program is distributed in the hope that 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, write to the Free Software
 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
 * 02110-1301, USA
 */

#ifndef VPORT_H
#define VPORT_H 1

#include <linux/if_tunnel.h>
#include <linux/list.h>
#include <linux/netlink.h>
#include <linux/openvswitch.h>
#include <linux/reciprocal_div.h>
#include <linux/skbuff.h>
#include <linux/spinlock.h>
#include <linux/u64_stats_sync.h>

#include "datapath.h"

struct vport;
struct vport_parms;

/* The following definitions are for users of the vport subsytem: */

struct vport_net {
	struct vport __rcu *gre_vport;
};

int ovs_vport_init(void);
void ovs_vport_exit(void);

struct vport *ovs_vport_add(const struct vport_parms *);
void ovs_vport_del(struct vport *);

struct vport *ovs_vport_locate(const struct net *net, const char *name);

void ovs_vport_get_stats(struct vport *, struct ovs_vport_stats *);

int ovs_vport_set_options(struct vport *, struct nlattr *options);
int ovs_vport_get_options(const struct vport *, struct sk_buff *);

int ovs_vport_set_upcall_portids(struct vport *, const struct nlattr *pids);
int ovs_vport_get_upcall_portids(const struct vport *, struct sk_buff *);
u32 ovs_vport_find_upcall_portid(const struct vport *, struct sk_buff *);

int ovs_vport_send(struct vport *, struct sk_buff *);

int ovs_tunnel_get_egress_info(struct ovs_tunnel_info *egress_tun_info,
			       struct net *net,
			       const struct ovs_tunnel_info *tun_info,
			       u8 ipproto,
			       u32 skb_mark,
			       __be16 tp_src,
			       __be16 tp_dst);
int ovs_vport_get_egress_tun_info(struct vport *vport, struct sk_buff *skb,
				  struct ovs_tunnel_info *info);

/* The following definitions are for implementers of vport devices: */

struct vport_err_stats {
	atomic_long_t rx_dropped;
	atomic_long_t rx_errors;
	atomic_long_t tx_dropped;
	atomic_long_t tx_errors;
};
/**
 * struct vport_portids - array of netlink portids of a vport.
 *                        must be protected by rcu.
 * @rn_ids: The reciprocal value of @n_ids.
 * @rcu: RCU callback head for deferred destruction.
 * @n_ids: Size of @ids array.
 * @ids: Array storing the Netlink socket pids to be used for packets received
 * on this port that miss the flow table.
 */
struct vport_portids {
	struct reciprocal_value rn_ids;
	struct rcu_head rcu;
	u32 n_ids;
	u32 ids[];
};

/**
 * struct vport - one port within a datapath
 * @rcu: RCU callback head for deferred destruction.
 * @dp: Datapath to which this port belongs.
 * @upcall_portids: RCU protected 'struct vport_portids'.
 * @port_no: Index into @dp's @ports array.
 * @hash_node: Element in @dev_table hash table in vport.c.
 * @dp_hash_node: Element in @datapath->ports hash table in datapath.c.
 * @ops: Class structure.
 * @percpu_stats: Points to per-CPU statistics used and maintained by vport
 * @err_stats: Points to error statistics used and maintained by vport
 * @detach_list: list used for detaching vport in net-exit call.
 */
struct vport {
	struct rcu_head rcu;
	struct datapath	*dp;
	struct vport_portids __rcu *upcall_portids;
	u16 port_no;

	struct hlist_node hash_node;
	struct hlist_node dp_hash_node;
	const struct vport_ops *ops;

	struct pcpu_sw_netstats __percpu *percpu_stats;

	struct vport_err_stats err_stats;
	struct list_head detach_list;
};

/**
 * struct vport_parms - parameters for creating a new vport
 *
 * @name: New vport's name.
 * @type: New vport's type.
 * @options: %OVS_VPORT_ATTR_OPTIONS attribute from Netlink message, %NULL if
 * none was supplied.
 * @dp: New vport's datapath.
 * @port_no: New vport's port number.
 */
struct vport_parms {
	const char *name;
	enum ovs_vport_type type;
	struct nlattr *options;

	/* For ovs_vport_alloc(). */
	struct datapath *dp;
	u16 port_no;
	struct nlattr *upcall_portids;
};

/**
 * struct vport_ops - definition of a type of virtual port
 *
 * @type: %OVS_VPORT_TYPE_* value for this type of virtual port.
 * @create: Create a new vport configured as specified.  On success returns
 * a new vport allocated with ovs_vport_alloc(), otherwise an ERR_PTR() value.
 * @destroy: Destroys a vport.  Must call vport_free() on the vport but not
 * before an RCU grace period has elapsed.
 * @set_options: Modify the configuration of an existing vport.  May be %NULL
 * if modification is not supported.
 * @get_options: Appends vport-specific attributes for the configuration of an
 * existing vport to a &struct sk_buff.  May be %NULL for a vport that does not
 * have any configuration.
 * @get_name: Get the device's name.
 * @send: Send a packet on the device.  Returns the length of the packet sent,
 * zero for dropped packets or negative for error.
 * @get_egress_tun_info: Get the egress tunnel 5-tuple and other info for
 * a packet.
 */
struct vport_ops {
	enum ovs_vport_type type;

	/* Called with ovs_mutex. */
	struct vport *(*create)(const struct vport_parms *);
	void (*destroy)(struct vport *);

	int (*set_options)(struct vport *, struct nlattr *);
	int (*get_options)(const struct vport *, struct sk_buff *);

	/* Called with rcu_read_lock or ovs_mutex. */
	const char *(*get_name)(const struct vport *);

	int (*send)(struct vport *, struct sk_buff *);
	int (*get_egress_tun_info)(struct vport *, struct sk_buff *,
				   struct ovs_tunnel_info *);

	struct module *owner;
	struct list_head list;
};

enum vport_err_type {
	VPORT_E_RX_DROPPED,
	VPORT_E_RX_ERROR,
	VPORT_E_TX_DROPPED,
	VPORT_E_TX_ERROR,
};

struct vport *ovs_vport_alloc(int priv_size, const struct vport_ops *,
			      const struct vport_parms *);
void ovs_vport_free(struct vport *);
void ovs_vport_deferred_free(struct vport *vport);

#define VPORT_ALIGN 8

/**
 *	vport_priv - access private data area of vport
 *
 * @vport: vport to access
 *
 * If a nonzero size was passed in priv_size of vport_alloc() a private data
 * area was allocated on creation.  This allows that area to be accessed and
 * used for any purpose needed by the vport implementer.
 */
static inline void *vport_priv(const struct vport *vport)
{
	return (u8 *)(uintptr_t)vport + ALIGN(sizeof(struct vport), VPORT_ALIGN);
}

/**
 *	vport_from_priv - lookup vport from private data pointer
 *
 * @priv: Start of private data area.
 *
 * It is sometimes useful to translate from a pointer to the private data
 * area to the vport, such as in the case where the private data pointer is
 * the result of a hash table lookup.  @priv must point to the start of the
 * private data area.
 */
static inline struct vport *vport_from_priv(void *priv)
{
	return (struct vport *)((u8 *)priv - ALIGN(sizeof(struct vport), VPORT_ALIGN));
}

void ovs_vport_receive(struct vport *, struct sk_buff *,
		       const struct ovs_tunnel_info *);

static inline void ovs_skb_postpush_rcsum(struct sk_buff *skb,
				      const void *start, unsigned int len)
{
	if (skb->ip_summed == CHECKSUM_COMPLETE)
		skb->csum = csum_add(skb->csum, csum_partial(start, len, 0));
}

int ovs_vport_ops_register(struct vport_ops *ops);
void ovs_vport_ops_unregister(struct vport_ops *ops);

static inline struct rtable *ovs_tunnel_route_lookup(struct net *net,
						     const struct ovs_key_ipv4_tunnel *key,
						     u32 mark,
						     struct flowi4 *fl,
						     u8 protocol)
{
	struct rtable *rt;

	memset(fl, 0, sizeof(*fl));
	fl->daddr = key->ipv4_dst;
	fl->saddr = key->ipv4_src;
	fl->flowi4_tos = RT_TOS(key->ipv4_tos);
	fl->flowi4_mark = mark;
	fl->flowi4_proto = protocol;

	rt = ip_route_output_key(net, fl);
	return rt;
}
#endif /* vport.h */
Commit	Line	Data
ccb1352e	1	/*
caf2ee14	2	* Copyright (c) 2007-2012 Nicira, Inc.
ccb1352e JG	3	*
	4	* This program is free software; you can redistribute it and/or
	5	* modify it under the terms of version 2 of the GNU General Public
	6	* License as published by the Free Software Foundation.
	7	*
	8	* This program is distributed in the hope that it will be useful, but
	9	* WITHOUT ANY WARRANTY; without even the implied warranty of
	10	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
	11	* General Public License for more details.
	12	*
	13	* You should have received a copy of the GNU General Public License
	14	* along with this program; if not, write to the Free Software
	15	* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
	16	* 02110-1301, USA
	17	*/
	18
	19	#ifndef VPORT_H
	20	#define VPORT_H 1
	21
e0f0ecf3	22	#include <linux/if_tunnel.h>
ccb1352e	23	#include <linux/list.h>
46df7b81	24	#include <linux/netlink.h>
ccb1352e	25	#include <linux/openvswitch.h>
5cd667b0	26	#include <linux/reciprocal_div.h>
ccb1352e JG	27	#include <linux/skbuff.h>
	28	#include <linux/spinlock.h>
	29	#include <linux/u64_stats_sync.h>
	30
	31	#include "datapath.h"
	32
	33	struct vport;
	34	struct vport_parms;
	35
	36	/* The following definitions are for users of the vport subsytem: */
	37
aa310701 PS	38	struct vport_net {
	39	struct vport __rcu *gre_vport;
	40	};
	41
ccb1352e JG	42	int ovs_vport_init(void);
	43	void ovs_vport_exit(void);
	44
	45	struct vport ovs_vport_add(const struct vport_parms );
	46	void ovs_vport_del(struct vport *);
	47
12eb18f7	48	struct vport ovs_vport_locate(const struct net net, const char *name);
ccb1352e JG	49
	50	void ovs_vport_get_stats(struct vport , struct ovs_vport_stats );
	51
	52	int ovs_vport_set_options(struct vport , struct nlattr options);
	53	int ovs_vport_get_options(const struct vport , struct sk_buff );
	54
12eb18f7	55	int ovs_vport_set_upcall_portids(struct vport , const struct nlattr pids);
5cd667b0 AW	56	int ovs_vport_get_upcall_portids(const struct vport , struct sk_buff );
	57	u32 ovs_vport_find_upcall_portid(const struct vport , struct sk_buff );
	58
ccb1352e JG	59	int ovs_vport_send(struct vport , struct sk_buff );
ccb1352e JG	60
8f0aad6f WZ	61	int ovs_tunnel_get_egress_info(struct ovs_tunnel_info *egress_tun_info,
	62	struct net *net,
	63	const struct ovs_tunnel_info *tun_info,
	64	u8 ipproto,
	65	u32 skb_mark,
	66	__be16 tp_src,
	67	__be16 tp_dst);
	68	int ovs_vport_get_egress_tun_info(struct vport vport, struct sk_buff skb,
	69	struct ovs_tunnel_info *info);
	70
ccb1352e JG	71	/* The following definitions are for implementers of vport devices: */
ccb1352e JG	72
ccb1352e	73	struct vport_err_stats {
e403aded LR	74	atomic_long_t rx_dropped;
	75	atomic_long_t rx_errors;
	76	atomic_long_t tx_dropped;
	77	atomic_long_t tx_errors;
ccb1352e	78	};
5cd667b0 AW	79	/**
	80	* struct vport_portids - array of netlink portids of a vport.
	81	* must be protected by rcu.
	82	* @rn_ids: The reciprocal value of @n_ids.
	83	* @rcu: RCU callback head for deferred destruction.
	84	* @n_ids: Size of @ids array.
	85	* @ids: Array storing the Netlink socket pids to be used for packets received
	86	* on this port that miss the flow table.
	87	*/
	88	struct vport_portids {
	89	struct reciprocal_value rn_ids;
	90	struct rcu_head rcu;
	91	u32 n_ids;
	92	u32 ids[];
	93	};
ccb1352e JG	94
	95	/**
	96	* struct vport - one port within a datapath
	97	* @rcu: RCU callback head for deferred destruction.
ccb1352e	98	* @dp: Datapath to which this port belongs.
5cd667b0	99	* @upcall_portids: RCU protected 'struct vport_portids'.
03599c94	100	* @port_no: Index into @dp's @ports array.
ccb1352e	101	* @hash_node: Element in @dev_table hash table in vport.c.
15eac2a7	102	* @dp_hash_node: Element in @datapath->ports hash table in datapath.c.
ccb1352e JG	103	* @ops: Class structure.
ccb1352e JG	104	* @percpu_stats: Points to per-CPU statistics used and maintained by vport
ccb1352e	105	* @err_stats: Points to error statistics used and maintained by vport
7b4577a9	106	* @detach_list: list used for detaching vport in net-exit call.
ccb1352e JG	107	*/
	108	struct vport {
	109	struct rcu_head rcu;
ccb1352e	110	struct datapath *dp;
5cd667b0	111	struct vport_portids __rcu *upcall_portids;
03599c94	112	u16 port_no;
ccb1352e JG	113
ccb1352e JG	114	struct hlist_node hash_node;
15eac2a7	115	struct hlist_node dp_hash_node;
ccb1352e JG	116	const struct vport_ops *ops;
ccb1352e JG	117
8f84985f	118	struct pcpu_sw_netstats __percpu *percpu_stats;
ccb1352e	119
ccb1352e	120	struct vport_err_stats err_stats;
7b4577a9	121	struct list_head detach_list;
ccb1352e JG	122	};
	123
	124	/**
	125	* struct vport_parms - parameters for creating a new vport
	126	*
	127	* @name: New vport's name.
	128	* @type: New vport's type.
	129	* @options: %OVS_VPORT_ATTR_OPTIONS attribute from Netlink message, %NULL if
	130	* none was supplied.
	131	* @dp: New vport's datapath.
	132	* @port_no: New vport's port number.
	133	*/
	134	struct vport_parms {
	135	const char *name;
	136	enum ovs_vport_type type;
	137	struct nlattr *options;
	138
	139	/* For ovs_vport_alloc(). */
	140	struct datapath *dp;
	141	u16 port_no;
5cd667b0	142	struct nlattr *upcall_portids;
ccb1352e JG	143	};
	144
	145	/**
	146	* struct vport_ops - definition of a type of virtual port
	147	*
	148	* @type: %OVS_VPORT_TYPE_* value for this type of virtual port.
	149	* @create: Create a new vport configured as specified. On success returns
	150	* a new vport allocated with ovs_vport_alloc(), otherwise an ERR_PTR() value.
	151	* @destroy: Destroys a vport. Must call vport_free() on the vport but not
	152	* before an RCU grace period has elapsed.
	153	* @set_options: Modify the configuration of an existing vport. May be %NULL
	154	* if modification is not supported.
	155	* @get_options: Appends vport-specific attributes for the configuration of an
	156	* existing vport to a &struct sk_buff. May be %NULL for a vport that does not
	157	* have any configuration.
	158	* @get_name: Get the device's name.
91b7514c PS	159	* @send: Send a packet on the device. Returns the length of the packet sent,
91b7514c PS	160	* zero for dropped packets or negative for error.
8f0aad6f WZ	161	* @get_egress_tun_info: Get the egress tunnel 5-tuple and other info for
8f0aad6f WZ	162	* a packet.
ccb1352e JG	163	*/
	164	struct vport_ops {
	165	enum ovs_vport_type type;
	166
8e4e1713	167	/* Called with ovs_mutex. */
ccb1352e JG	168	struct vport (create)(const struct vport_parms *);
	169	void (destroy)(struct vport );
	170
	171	int (set_options)(struct vport , struct nlattr *);
	172	int (get_options)(const struct vport , struct sk_buff *);
	173
8e4e1713	174	/* Called with rcu_read_lock or ovs_mutex. */
ccb1352e	175	const char (get_name)(const struct vport *);
ccb1352e JG	176
ccb1352e JG	177	int (send)(struct vport , struct sk_buff *);
8f0aad6f WZ	178	int (get_egress_tun_info)(struct vport , struct sk_buff *,
8f0aad6f WZ	179	struct ovs_tunnel_info *);
62b9c8d0 TG	180
	181	struct module *owner;
	182	struct list_head list;
ccb1352e JG	183	};
	184
	185	enum vport_err_type {
	186	VPORT_E_RX_DROPPED,
	187	VPORT_E_RX_ERROR,
	188	VPORT_E_TX_DROPPED,
	189	VPORT_E_TX_ERROR,
	190	};
	191
	192	struct vport ovs_vport_alloc(int priv_size, const struct vport_ops ,
	193	const struct vport_parms *);
	194	void ovs_vport_free(struct vport *);
aa310701	195	void ovs_vport_deferred_free(struct vport *vport);
ccb1352e JG	196
	197	#define VPORT_ALIGN 8
	198
	199	/**
	200	* vport_priv - access private data area of vport
	201	*
	202	* @vport: vport to access
	203	*
	204	* If a nonzero size was passed in priv_size of vport_alloc() a private data
	205	* area was allocated on creation. This allows that area to be accessed and
	206	* used for any purpose needed by the vport implementer.
	207	*/
	208	static inline void vport_priv(const struct vport vport)
	209	{
07dc0602	210	return (u8 *)(uintptr_t)vport + ALIGN(sizeof(struct vport), VPORT_ALIGN);
ccb1352e JG	211	}
	212
	213	/**
	214	* vport_from_priv - lookup vport from private data pointer
	215	*
	216	* @priv: Start of private data area.
	217	*
	218	* It is sometimes useful to translate from a pointer to the private data
	219	* area to the vport, such as in the case where the private data pointer is
	220	* the result of a hash table lookup. @priv must point to the start of the
	221	* private data area.
	222	*/
d0b4da13	223	static inline struct vport vport_from_priv(void priv)
ccb1352e	224	{
d0b4da13	225	return (struct vport )((u8 )priv - ALIGN(sizeof(struct vport), VPORT_ALIGN));
ccb1352e JG	226	}
ccb1352e JG	227
7d5437c7	228	void ovs_vport_receive(struct vport , struct sk_buff ,
12eb18f7	229	const struct ovs_tunnel_info *);
ccb1352e	230
b34df5e8 PS	231	static inline void ovs_skb_postpush_rcsum(struct sk_buff *skb,
	232	const void *start, unsigned int len)
	233	{
	234	if (skb->ip_summed == CHECKSUM_COMPLETE)
	235	skb->csum = csum_add(skb->csum, csum_partial(start, len, 0));
	236	}
	237
62b9c8d0 TG	238	int ovs_vport_ops_register(struct vport_ops *ops);
	239	void ovs_vport_ops_unregister(struct vport_ops *ops);
	240
3f4c1d87 FD	241	static inline struct rtable ovs_tunnel_route_lookup(struct net net,
	242	const struct ovs_key_ipv4_tunnel *key,
	243	u32 mark,
	244	struct flowi4 *fl,
	245	u8 protocol)
	246	{
	247	struct rtable *rt;
	248
	249	memset(fl, 0, sizeof(*fl));
	250	fl->daddr = key->ipv4_dst;
	251	fl->saddr = key->ipv4_src;
	252	fl->flowi4_tos = RT_TOS(key->ipv4_tos);
	253	fl->flowi4_mark = mark;
	254	fl->flowi4_proto = protocol;
	255
	256	rt = ip_route_output_key(net, fl);
	257	return rt;
	258	}
ccb1352e	259	#endif /* vport.h */