[mirror_ovs.git] / datapath / vport-internal_dev.c

/*
 * Copyright (c) 2009, 2010 Nicira Networks.
 * Distributed under the terms of the GNU GPL version 2.
 *
 * Significant portions of this file may be copied from parts of the Linux
 * kernel, by Linus Torvalds and others.
 */

#include <linux/kernel.h>
#include <linux/netdevice.h>
#include <linux/etherdevice.h>
#include <linux/ethtool.h>
#include <linux/percpu.h>
#include <linux/preempt.h>
#include <linux/rcupdate.h>
#include <linux/skbuff.h>
#include <linux/workqueue.h>

#include "datapath.h"
#include "openvswitch/internal_dev.h"
#include "vport-internal_dev.h"
#include "vport-netdev.h"

struct pcpu_lstats {
	unsigned long rx_packets;
	unsigned long rx_bytes;
	unsigned long tx_packets;
	unsigned long tx_bytes;
};

struct internal_dev {
	struct vport *vport;

	struct net_device_stats stats;
	struct pcpu_lstats *lstats;

	/* This is warty support for XAPI, which does not support summing bond
	 * device statistics itself.  'extra_stats' can be set by userspace via
	 * the DP_DEV_SET_STATS ioctl and, if they are, then they are added to
	 * the real device stats. */
	struct pcpu_lstats extra_stats;
};

struct vport_ops internal_vport_ops;

static inline struct internal_dev *internal_dev_priv(struct net_device *netdev)
{
	return netdev_priv(netdev);
}

static struct net_device_stats *internal_dev_get_stats(struct net_device *netdev)
{
	struct internal_dev *internal_dev = internal_dev_priv(netdev);
	struct net_device_stats *stats;
	int i;

	stats = &internal_dev->stats;
	stats->rx_bytes = internal_dev->extra_stats.rx_bytes;
	stats->rx_packets = internal_dev->extra_stats.rx_packets;
	stats->tx_bytes = internal_dev->extra_stats.tx_bytes;
	stats->tx_packets = internal_dev->extra_stats.tx_packets;
	for_each_possible_cpu(i) {
		const struct pcpu_lstats *lb_stats;

		lb_stats = per_cpu_ptr(internal_dev->lstats, i);
		stats->rx_bytes   += lb_stats->rx_bytes;
		stats->rx_packets += lb_stats->rx_packets;
		stats->tx_bytes   += lb_stats->tx_bytes;
		stats->tx_packets += lb_stats->tx_packets;
	}
	return stats;
}

static int internal_dev_mac_addr(struct net_device *dev, void *p)
{
	struct sockaddr *addr = p;

	if (!is_valid_ether_addr(addr->sa_data))
		return -EADDRNOTAVAIL;
	memcpy(dev->dev_addr, addr->sa_data, dev->addr_len);
	return 0;
}

/* Not reentrant (because it is called with BHs disabled), but may be called
 * simultaneously on different CPUs. */
static int internal_dev_xmit(struct sk_buff *skb, struct net_device *netdev)
{
	struct internal_dev *internal_dev = internal_dev_priv(netdev);
	struct vport *vport = internal_dev_get_vport(netdev);
	struct pcpu_lstats *lb_stats;

	/* We need our own clone. */
	skb = skb_share_check(skb, GFP_ATOMIC);
	if (!skb)
		return 0;

	lb_stats = per_cpu_ptr(internal_dev->lstats, smp_processor_id());
	lb_stats->tx_packets++;
	lb_stats->tx_bytes += skb->len;

	skb_reset_mac_header(skb);
	rcu_read_lock_bh();
	vport_receive(vport, skb);
	rcu_read_unlock_bh();

	return 0;
}

static int internal_dev_open(struct net_device *netdev)
{
	netif_start_queue(netdev);
	return 0;
}

static int internal_dev_stop(struct net_device *netdev)
{
	netif_stop_queue(netdev);
	return 0;
}

static void internal_dev_getinfo(struct net_device *netdev,
				 struct ethtool_drvinfo *info)
{
	struct dp_port *dp_port = vport_get_dp_port(internal_dev_get_vport(netdev));

	strcpy(info->driver, "openvswitch");
	if (dp_port)
		sprintf(info->bus_info, "%d.%d", dp_port->dp->dp_idx, dp_port->port_no);
}

static struct ethtool_ops internal_dev_ethtool_ops = {
	.get_drvinfo = internal_dev_getinfo,
	.get_link = ethtool_op_get_link,
	.get_sg = ethtool_op_get_sg,
	.get_tx_csum = ethtool_op_get_tx_csum,
	.get_tso = ethtool_op_get_tso,
};

static int internal_dev_change_mtu(struct net_device *netdev, int new_mtu)
{
	struct dp_port *dp_port = vport_get_dp_port(internal_dev_get_vport(netdev));

	if (new_mtu < 68)
		return -EINVAL;

	if (dp_port) {
		int min_mtu;

		mutex_lock(&dp_port->dp->mutex);
		min_mtu = dp_min_mtu(dp_port->dp);
		mutex_unlock(&dp_port->dp->mutex);

		if (new_mtu > min_mtu)
			return -EINVAL;
	}

	netdev->mtu = new_mtu;
	return 0;
}

static int internal_dev_init(struct net_device *netdev)
{
	struct internal_dev *internal_dev = internal_dev_priv(netdev);

	internal_dev->lstats = alloc_percpu(struct pcpu_lstats);
	if (!internal_dev->lstats)
		return -ENOMEM;

	return 0;
}

static void internal_dev_free(struct net_device *netdev)
{
	struct internal_dev *internal_dev = internal_dev_priv(netdev);

	free_percpu(internal_dev->lstats);
	free_netdev(netdev);
}

static int internal_dev_do_ioctl(struct net_device *dev, struct ifreq *ifr, int cmd)
{
	struct internal_dev *internal_dev = internal_dev_priv(dev);

	if (cmd == INTERNAL_DEV_SET_STATS) {
		struct internal_dev_stats stats;

		if (copy_from_user(&stats, ifr->ifr_data, sizeof(stats)))
			return -EFAULT;

		internal_dev->extra_stats.rx_bytes = stats.rx_bytes;
		internal_dev->extra_stats.rx_packets = stats.rx_packets;
		internal_dev->extra_stats.tx_bytes = stats.tx_bytes;
		internal_dev->extra_stats.tx_packets = stats.tx_packets;

		return 0;
	}

	if (dp_ioctl_hook)
		return dp_ioctl_hook(dev, ifr, cmd);
	return -EOPNOTSUPP;
}

#ifdef HAVE_NET_DEVICE_OPS
static const struct net_device_ops internal_dev_netdev_ops = {
	.ndo_init = internal_dev_init,
	.ndo_open = internal_dev_open,
	.ndo_stop = internal_dev_stop,
	.ndo_start_xmit = internal_dev_xmit,
	.ndo_set_mac_address = internal_dev_mac_addr,
	.ndo_do_ioctl = internal_dev_do_ioctl,
	.ndo_change_mtu = internal_dev_change_mtu,
	.ndo_get_stats = internal_dev_get_stats,
};
#endif

static void
do_setup(struct net_device *netdev)
{
	ether_setup(netdev);

#ifdef HAVE_NET_DEVICE_OPS
	netdev->netdev_ops = &internal_dev_netdev_ops;
#else
	netdev->do_ioctl = internal_dev_do_ioctl;
	netdev->get_stats = internal_dev_get_stats;
	netdev->hard_start_xmit = internal_dev_xmit;
	netdev->open = internal_dev_open;
	netdev->stop = internal_dev_stop;
	netdev->set_mac_address = internal_dev_mac_addr;
	netdev->change_mtu = internal_dev_change_mtu;
	netdev->init = internal_dev_init;
#endif

	netdev->destructor = internal_dev_free;
	SET_ETHTOOL_OPS(netdev, &internal_dev_ethtool_ops);
	netdev->tx_queue_len = 0;

	netdev->flags = IFF_BROADCAST | IFF_MULTICAST;
	netdev->features = NETIF_F_LLTX; /* XXX other features? */

	vport_gen_ether_addr(netdev->dev_addr);
}

static struct vport *
internal_dev_create(const char *name, const void __user *config)
{
	struct vport *vport;
	struct netdev_vport *netdev_vport;
	struct internal_dev *internal_dev;
	int err;

	vport = vport_alloc(sizeof(struct netdev_vport), &internal_vport_ops);
	if (IS_ERR(vport)) {
		err = PTR_ERR(vport);
		goto error;
	}

	netdev_vport = netdev_vport_priv(vport);

	netdev_vport->dev = alloc_netdev(sizeof(struct internal_dev), name, do_setup);
	if (!netdev_vport->dev) {
		err = -ENOMEM;
		goto error_free_vport;
	}

	internal_dev = internal_dev_priv(netdev_vport->dev);
	internal_dev->vport = vport;

	err = register_netdevice(netdev_vport->dev);
	if (err)
		goto error_free_netdev;

	return vport;

error_free_netdev:
	free_netdev(netdev_vport->dev);
error_free_vport:
	vport_free(vport);
error:
	return ERR_PTR(err);
}

static int
internal_dev_destroy(struct vport *vport)
{
	struct netdev_vport *netdev_vport = netdev_vport_priv(vport);

	unregister_netdevice(netdev_vport->dev);
	vport_free(vport);

	return 0;
}

static int
internal_dev_attach(struct vport *vport)
{
	struct netdev_vport *netdev_vport = netdev_vport_priv(vport);

	dev_set_promiscuity(netdev_vport->dev, 1);

	/* It would make sense to assign dev->br_port here too, but
	 * that causes packets received on internal ports to get caught
	 * in netdev_frame_hook().  In turn netdev_frame_hook() can reject them
	 * back to the network stack, but that's a waste of time. */

	return 0;
}

static int
internal_dev_detach(struct vport *vport)
{
	struct netdev_vport *netdev_vport = netdev_vport_priv(vport);

	dev_set_promiscuity(netdev_vport->dev, -1);

	/* Make sure that no packets arrive from now on, since
	 * internal_dev_xmit() will try to find itself through
	 * p->dp->ports[], and we're about to set that to null. */
	netif_tx_disable(netdev_vport->dev);

	return 0;
}

static int
internal_dev_recv(struct vport *vport, struct sk_buff *skb)
{
	struct net_device *netdev = netdev_vport_priv(vport)->dev;
	struct internal_dev *internal_dev = internal_dev_priv(netdev);
	struct pcpu_lstats *lb_stats;
	int len;

	skb->dev = netdev;
	len = skb->len;
	skb->pkt_type = PACKET_HOST;
	skb->protocol = eth_type_trans(skb, netdev);

	if (in_interrupt())
		netif_rx(skb);
	else
		netif_rx_ni(skb);
	netdev->last_rx = jiffies;

	preempt_disable();
	lb_stats = per_cpu_ptr(internal_dev->lstats, smp_processor_id());
	lb_stats->rx_packets++;
	lb_stats->rx_bytes += len;
	preempt_enable();

	return len;
}

struct vport_ops internal_vport_ops = {
	.type		= "internal",
	.flags		= VPORT_F_REQUIRED,
	.create		= internal_dev_create,
	.destroy	= internal_dev_destroy,
	.attach		= internal_dev_attach,
	.detach		= internal_dev_detach,
	.set_mtu	= netdev_set_mtu,
	.set_addr	= netdev_set_addr,
	.get_name	= netdev_get_name,
	.get_addr	= netdev_get_addr,
	.get_kobj	= netdev_get_kobj,
	.get_stats	= netdev_get_stats,
	.get_dev_flags	= netdev_get_dev_flags,
	.is_running	= netdev_is_running,
	.get_operstate	= netdev_get_operstate,
	.get_ifindex	= netdev_get_ifindex,
	.get_iflink	= netdev_get_iflink,
	.get_mtu	= netdev_get_mtu,
	.send		= internal_dev_recv,
};

int is_internal_dev(const struct net_device *netdev)
{
#ifdef HAVE_NET_DEVICE_OPS
	return netdev->netdev_ops == &internal_dev_netdev_ops;
#else
	return netdev->open == internal_dev_open;
#endif
}

int
is_internal_vport(const struct vport *vport)
{
	return vport->ops == &internal_vport_ops;
}

struct vport *
internal_dev_get_vport(struct net_device *netdev)
{
	struct internal_dev *internal_dev = internal_dev_priv(netdev);
	return rcu_dereference(internal_dev->vport);
}
Commit	Line	Data
f2459fe7 JG	1	/*
	2	* Copyright (c) 2009, 2010 Nicira Networks.
	3	* Distributed under the terms of the GNU GPL version 2.
	4	*
	5	* Significant portions of this file may be copied from parts of the Linux
	6	* kernel, by Linus Torvalds and others.
	7	*/
	8
	9	#include <linux/kernel.h>
	10	#include <linux/netdevice.h>
	11	#include <linux/etherdevice.h>
	12	#include <linux/ethtool.h>
	13	#include <linux/percpu.h>
	14	#include <linux/preempt.h>
	15	#include <linux/rcupdate.h>
	16	#include <linux/skbuff.h>
	17	#include <linux/workqueue.h>
	18
	19	#include "datapath.h"
8722022c	20	#include "openvswitch/internal_dev.h"
f2459fe7 JG	21	#include "vport-internal_dev.h"
	22	#include "vport-netdev.h"
	23
	24	struct pcpu_lstats {
	25	unsigned long rx_packets;
	26	unsigned long rx_bytes;
	27	unsigned long tx_packets;
	28	unsigned long tx_bytes;
	29	};
	30
	31	struct internal_dev {
	32	struct vport *vport;
	33
	34	struct net_device_stats stats;
	35	struct pcpu_lstats *lstats;
8722022c BP	36
	37	/* This is warty support for XAPI, which does not support summing bond
	38	* device statistics itself. 'extra_stats' can be set by userspace via
	39	* the DP_DEV_SET_STATS ioctl and, if they are, then they are added to
	40	* the real device stats. */
	41	struct pcpu_lstats extra_stats;
f2459fe7 JG	42	};
	43
	44	struct vport_ops internal_vport_ops;
	45
	46	static inline struct internal_dev internal_dev_priv(struct net_device netdev)
	47	{
	48	return netdev_priv(netdev);
	49	}
	50
	51	static struct net_device_stats internal_dev_get_stats(struct net_device netdev)
	52	{
	53	struct internal_dev *internal_dev = internal_dev_priv(netdev);
	54	struct net_device_stats *stats;
	55	int i;
	56
	57	stats = &internal_dev->stats;
8722022c BP	58	stats->rx_bytes = internal_dev->extra_stats.rx_bytes;
	59	stats->rx_packets = internal_dev->extra_stats.rx_packets;
	60	stats->tx_bytes = internal_dev->extra_stats.tx_bytes;
	61	stats->tx_packets = internal_dev->extra_stats.tx_packets;
f2459fe7 JG	62	for_each_possible_cpu(i) {
	63	const struct pcpu_lstats *lb_stats;
	64
	65	lb_stats = per_cpu_ptr(internal_dev->lstats, i);
	66	stats->rx_bytes += lb_stats->rx_bytes;
	67	stats->rx_packets += lb_stats->rx_packets;
	68	stats->tx_bytes += lb_stats->tx_bytes;
	69	stats->tx_packets += lb_stats->tx_packets;
	70	}
	71	return stats;
	72	}
	73
	74	static int internal_dev_mac_addr(struct net_device dev, void p)
	75	{
	76	struct sockaddr *addr = p;
	77
	78	if (!is_valid_ether_addr(addr->sa_data))
	79	return -EADDRNOTAVAIL;
	80	memcpy(dev->dev_addr, addr->sa_data, dev->addr_len);
	81	return 0;
	82	}
	83
	84	/* Not reentrant (because it is called with BHs disabled), but may be called
	85	* simultaneously on different CPUs. */
	86	static int internal_dev_xmit(struct sk_buff skb, struct net_device netdev)
	87	{
	88	struct internal_dev *internal_dev = internal_dev_priv(netdev);
	89	struct vport *vport = internal_dev_get_vport(netdev);
	90	struct pcpu_lstats *lb_stats;
	91
	92	/* We need our own clone. */
	93	skb = skb_share_check(skb, GFP_ATOMIC);
	94	if (!skb)
	95	return 0;
	96
	97	lb_stats = per_cpu_ptr(internal_dev->lstats, smp_processor_id());
	98	lb_stats->tx_packets++;
	99	lb_stats->tx_bytes += skb->len;
	100
	101	skb_reset_mac_header(skb);
	102	rcu_read_lock_bh();
	103	vport_receive(vport, skb);
	104	rcu_read_unlock_bh();
	105
	106	return 0;
	107	}
	108
	109	static int internal_dev_open(struct net_device *netdev)
	110	{
	111	netif_start_queue(netdev);
	112	return 0;
	113	}
	114
	115	static int internal_dev_stop(struct net_device *netdev)
	116	{
	117	netif_stop_queue(netdev);
	118	return 0;
	119	}
	120
	121	static void internal_dev_getinfo(struct net_device *netdev,
	122	struct ethtool_drvinfo *info)
	123	{
	124	struct dp_port *dp_port = vport_get_dp_port(internal_dev_get_vport(netdev));
	125
126	strcpy(info->driver, "openvswitch");
127	if (dp_port)
128	sprintf(info->bus_info, "%d.%d", dp_port->dp->dp_idx, dp_port->port_no);
129	}
130
131	static struct ethtool_ops internal_dev_ethtool_ops = {
132	.get_drvinfo = internal_dev_getinfo,
133	.get_link = ethtool_op_get_link,
134	.get_sg = ethtool_op_get_sg,
135	.get_tx_csum = ethtool_op_get_tx_csum,
136	.get_tso = ethtool_op_get_tso,
137	};
138
139	static int internal_dev_change_mtu(struct net_device *netdev, int new_mtu)
140	{
141	struct dp_port *dp_port = vport_get_dp_port(internal_dev_get_vport(netdev));
142
143	if (new_mtu < 68)
144	return -EINVAL;
145
146	if (dp_port) {
147	int min_mtu;
148
149	mutex_lock(&dp_port->dp->mutex);
150	min_mtu = dp_min_mtu(dp_port->dp);
151	mutex_unlock(&dp_port->dp->mutex);
152
153	if (new_mtu > min_mtu)
154	return -EINVAL;
155	}
156
157	netdev->mtu = new_mtu;
158	return 0;
159	}
160
161	static int internal_dev_init(struct net_device *netdev)
162	{
163	struct internal_dev *internal_dev = internal_dev_priv(netdev);
164
165	internal_dev->lstats = alloc_percpu(struct pcpu_lstats);
166	if (!internal_dev->lstats)
167	return -ENOMEM;
168
169	return 0;
170	}
171
172	static void internal_dev_free(struct net_device *netdev)
173	{
174	struct internal_dev *internal_dev = internal_dev_priv(netdev);
175
176	free_percpu(internal_dev->lstats);
177	free_netdev(netdev);
178	}
179
180	static int internal_dev_do_ioctl(struct net_device dev, struct ifreq ifr, int cmd)
181	{
8722022c BP	182	struct internal_dev *internal_dev = internal_dev_priv(dev);
	183
	184	if (cmd == INTERNAL_DEV_SET_STATS) {
	185	struct internal_dev_stats stats;
	186
	187	if (copy_from_user(&stats, ifr->ifr_data, sizeof(stats)))
	188	return -EFAULT;
	189
	190	internal_dev->extra_stats.rx_bytes = stats.rx_bytes;
	191	internal_dev->extra_stats.rx_packets = stats.rx_packets;
	192	internal_dev->extra_stats.tx_bytes = stats.tx_bytes;
	193	internal_dev->extra_stats.tx_packets = stats.tx_packets;
	194
	195	return 0;
	196	}
	197
f2459fe7 JG	198	if (dp_ioctl_hook)
	199	return dp_ioctl_hook(dev, ifr, cmd);
	200	return -EOPNOTSUPP;
	201	}
	202
	203	#ifdef HAVE_NET_DEVICE_OPS
	204	static const struct net_device_ops internal_dev_netdev_ops = {
	205	.ndo_init = internal_dev_init,
	206	.ndo_open = internal_dev_open,
	207	.ndo_stop = internal_dev_stop,
	208	.ndo_start_xmit = internal_dev_xmit,
	209	.ndo_set_mac_address = internal_dev_mac_addr,
	210	.ndo_do_ioctl = internal_dev_do_ioctl,
	211	.ndo_change_mtu = internal_dev_change_mtu,
	212	.ndo_get_stats = internal_dev_get_stats,
	213	};
	214	#endif
	215
	216	static void
	217	do_setup(struct net_device *netdev)
	218	{
	219	ether_setup(netdev);
	220
	221	#ifdef HAVE_NET_DEVICE_OPS
	222	netdev->netdev_ops = &internal_dev_netdev_ops;
	223	#else
	224	netdev->do_ioctl = internal_dev_do_ioctl;
	225	netdev->get_stats = internal_dev_get_stats;
	226	netdev->hard_start_xmit = internal_dev_xmit;
	227	netdev->open = internal_dev_open;
	228	netdev->stop = internal_dev_stop;
	229	netdev->set_mac_address = internal_dev_mac_addr;
	230	netdev->change_mtu = internal_dev_change_mtu;
	231	netdev->init = internal_dev_init;
	232	#endif
	233
	234	netdev->destructor = internal_dev_free;
	235	SET_ETHTOOL_OPS(netdev, &internal_dev_ethtool_ops);
	236	netdev->tx_queue_len = 0;
	237
	238	netdev->flags = IFF_BROADCAST \| IFF_MULTICAST;
	239	netdev->features = NETIF_F_LLTX; /* XXX other features? */
	240
	241	vport_gen_ether_addr(netdev->dev_addr);
	242	}
	243
	244	static struct vport *
	245	internal_dev_create(const char name, const void __user config)
	246	{
	247	struct vport *vport;
	248	struct netdev_vport *netdev_vport;
	249	struct internal_dev *internal_dev;
	250	int err;
	251
	252	vport = vport_alloc(sizeof(struct netdev_vport), &internal_vport_ops);
	253	if (IS_ERR(vport)) {
	254	err = PTR_ERR(vport);
	255	goto error;
	256	}
	257
	258	netdev_vport = netdev_vport_priv(vport);
	259
	260	netdev_vport->dev = alloc_netdev(sizeof(struct internal_dev), name, do_setup);
	261	if (!netdev_vport->dev) {
262	err = -ENOMEM;
263	goto error_free_vport;
264	}
265
266	internal_dev = internal_dev_priv(netdev_vport->dev);
267	internal_dev->vport = vport;
268
269	err = register_netdevice(netdev_vport->dev);
270	if (err)
271	goto error_free_netdev;
272
273	return vport;
274
275	error_free_netdev:
276	free_netdev(netdev_vport->dev);
277	error_free_vport:
278	vport_free(vport);
279	error:
280	return ERR_PTR(err);
281	}
282
283	static int
284	internal_dev_destroy(struct vport *vport)
285	{
286	struct netdev_vport *netdev_vport = netdev_vport_priv(vport);
287
288	unregister_netdevice(netdev_vport->dev);
289	vport_free(vport);
290
291	return 0;
292	}
293
294	static int
295	internal_dev_attach(struct vport *vport)
296	{
297	struct netdev_vport *netdev_vport = netdev_vport_priv(vport);
298
299	dev_set_promiscuity(netdev_vport->dev, 1);
300
301	/* It would make sense to assign dev->br_port here too, but
302	* that causes packets received on internal ports to get caught
303	* in netdev_frame_hook(). In turn netdev_frame_hook() can reject them
304	* back to the network stack, but that's a waste of time. */
305
306	return 0;
307	}
308
309	static int
310	internal_dev_detach(struct vport *vport)
311	{
312	struct netdev_vport *netdev_vport = netdev_vport_priv(vport);
313
314	dev_set_promiscuity(netdev_vport->dev, -1);
315
316	/* Make sure that no packets arrive from now on, since
317	* internal_dev_xmit() will try to find itself through
318	* p->dp->ports[], and we're about to set that to null. */
319	netif_tx_disable(netdev_vport->dev);
320
321	return 0;
322	}
323
324	static int
325	internal_dev_recv(struct vport vport, struct sk_buff skb)
326	{
327	struct net_device *netdev = netdev_vport_priv(vport)->dev;
328	struct internal_dev *internal_dev = internal_dev_priv(netdev);
329	struct pcpu_lstats *lb_stats;
330	int len;
331
332	skb->dev = netdev;
333	len = skb->len;
334	skb->pkt_type = PACKET_HOST;
335	skb->protocol = eth_type_trans(skb, netdev);
336
337	if (in_interrupt())
338	netif_rx(skb);
339	else
340	netif_rx_ni(skb);
341	netdev->last_rx = jiffies;
342
343	preempt_disable();
344	lb_stats = per_cpu_ptr(internal_dev->lstats, smp_processor_id());
345	lb_stats->rx_packets++;
346	lb_stats->rx_bytes += len;
347	preempt_enable();
348
349	return len;
350	}
351
352	struct vport_ops internal_vport_ops = {
353	.type = "internal",
354	.flags = VPORT_F_REQUIRED,
355	.create = internal_dev_create,
356	.destroy = internal_dev_destroy,
357	.attach = internal_dev_attach,
358	.detach = internal_dev_detach,
359	.set_mtu = netdev_set_mtu,
360	.set_addr = netdev_set_addr,
361	.get_name = netdev_get_name,
362	.get_addr = netdev_get_addr,
363	.get_kobj = netdev_get_kobj,
364	.get_stats = netdev_get_stats,
365	.get_dev_flags = netdev_get_dev_flags,
366	.is_running = netdev_is_running,
367	.get_operstate = netdev_get_operstate,
368	.get_ifindex = netdev_get_ifindex,
369	.get_iflink = netdev_get_iflink,
370	.get_mtu = netdev_get_mtu,
371	.send = internal_dev_recv,
372	};
373
374	int is_internal_dev(const struct net_device *netdev)
375	{
376	#ifdef HAVE_NET_DEVICE_OPS
377	return netdev->netdev_ops == &internal_dev_netdev_ops;
378	#else
379	return netdev->open == internal_dev_open;
380	#endif
381	}
382
383	int
384	is_internal_vport(const struct vport *vport)
385	{
386	return vport->ops == &internal_vport_ops;
387	}
388
389	struct vport *
390	internal_dev_get_vport(struct net_device *netdev)
391	{
392	struct internal_dev *internal_dev = internal_dev_priv(netdev);
393	return rcu_dereference(internal_dev->vport);
394	}