| 
									
										
										
										
											2007-10-16 01:26:48 -07:00
										 |  |  | /*
 | 
					
						
							|  |  |  |  * Copyright (C) 2007 Luca Bigliardi (shammash@artha.org). | 
					
						
							|  |  |  |  * Licensed under the GPL. | 
					
						
							|  |  |  |  */ | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2007-10-16 01:27:29 -07:00
										 |  |  | #include <stddef.h>
 | 
					
						
							| 
									
										
										
										
											2007-10-16 01:26:48 -07:00
										 |  |  | #include <errno.h>
 | 
					
						
							|  |  |  | #include <libvdeplug.h>
 | 
					
						
							| 
									
										
										
										
											2012-10-08 03:27:32 +01:00
										 |  |  | #include <net_user.h>
 | 
					
						
							|  |  |  | #include <um_malloc.h>
 | 
					
						
							| 
									
										
										
										
											2007-10-16 01:26:48 -07:00
										 |  |  | #include "vde.h"
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | static int vde_user_init(void *data, void *dev) | 
					
						
							|  |  |  | { | 
					
						
							|  |  |  | 	struct vde_data *pri = data; | 
					
						
							|  |  |  | 	VDECONN *conn = NULL; | 
					
						
							|  |  |  | 	int err = -EINVAL; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	pri->dev = dev; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	conn = vde_open(pri->vde_switch, pri->descr, pri->args); | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	if (conn == NULL) { | 
					
						
							|  |  |  | 		err = -errno; | 
					
						
							|  |  |  | 		printk(UM_KERN_ERR "vde_user_init: vde_open failed, " | 
					
						
							|  |  |  | 		       "errno = %d\n", errno); | 
					
						
							|  |  |  | 		return err; | 
					
						
							|  |  |  | 	} | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	printk(UM_KERN_INFO "vde backend - connection opened\n"); | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	pri->conn = conn; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	return 0; | 
					
						
							|  |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | static int vde_user_open(void *data) | 
					
						
							|  |  |  | { | 
					
						
							|  |  |  | 	struct vde_data *pri = data; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	if (pri->conn != NULL) | 
					
						
							|  |  |  | 		return vde_datafd(pri->conn); | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	printk(UM_KERN_WARNING "vde_open - we have no VDECONN to open"); | 
					
						
							|  |  |  | 	return -EINVAL; | 
					
						
							|  |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | static void vde_remove(void *data) | 
					
						
							|  |  |  | { | 
					
						
							|  |  |  | 	struct vde_data *pri = data; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	if (pri->conn != NULL) { | 
					
						
							|  |  |  | 		printk(UM_KERN_INFO "vde backend - closing connection\n"); | 
					
						
							|  |  |  | 		vde_close(pri->conn); | 
					
						
							|  |  |  | 		pri->conn = NULL; | 
					
						
							|  |  |  | 		kfree(pri->args); | 
					
						
							|  |  |  | 		pri->args = NULL; | 
					
						
							|  |  |  | 		return; | 
					
						
							|  |  |  | 	} | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	printk(UM_KERN_WARNING "vde_remove - we have no VDECONN to remove"); | 
					
						
							|  |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | const struct net_user_info vde_user_info = { | 
					
						
							|  |  |  | 	.init		= vde_user_init, | 
					
						
							|  |  |  | 	.open		= vde_user_open, | 
					
						
							|  |  |  | 	.close	 	= NULL, | 
					
						
							|  |  |  | 	.remove	 	= vde_remove, | 
					
						
							|  |  |  | 	.add_address	= NULL, | 
					
						
							|  |  |  | 	.delete_address = NULL, | 
					
						
							| 
									
										
										
										
											2007-10-16 01:27:31 -07:00
										 |  |  | 	.mtu		= ETH_MAX_PACKET, | 
					
						
							|  |  |  | 	.max_packet	= ETH_MAX_PACKET + ETH_HEADER_OTHER, | 
					
						
							| 
									
										
										
										
											2007-10-16 01:26:48 -07:00
										 |  |  | }; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | void vde_init_libstuff(struct vde_data *vpri, struct vde_init *init) | 
					
						
							|  |  |  | { | 
					
						
							|  |  |  | 	struct vde_open_args *args; | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2009-02-20 15:38:36 -08:00
										 |  |  | 	vpri->args = uml_kmalloc(sizeof(struct vde_open_args), UM_GFP_KERNEL); | 
					
						
							| 
									
										
										
										
											2007-10-16 01:26:48 -07:00
										 |  |  | 	if (vpri->args == NULL) { | 
					
						
							| 
									
										
										
										
											2008-02-04 22:30:59 -08:00
										 |  |  | 		printk(UM_KERN_ERR "vde_init_libstuff - vde_open_args " | 
					
						
							| 
									
										
										
										
											2007-10-16 01:26:48 -07:00
										 |  |  | 		       "allocation failed"); | 
					
						
							|  |  |  | 		return; | 
					
						
							|  |  |  | 	} | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	args = vpri->args; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	args->port = init->port; | 
					
						
							|  |  |  | 	args->group = init->group; | 
					
						
							|  |  |  | 	args->mode = init->mode ? init->mode : 0700; | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2009-02-20 15:38:36 -08:00
										 |  |  | 	args->port ?  printk("port %d", args->port) : | 
					
						
							|  |  |  | 		printk("undefined port"); | 
					
						
							| 
									
										
										
										
											2007-10-16 01:26:48 -07:00
										 |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | int vde_user_read(void *conn, void *buf, int len) | 
					
						
							|  |  |  | { | 
					
						
							|  |  |  | 	VDECONN *vconn = conn; | 
					
						
							|  |  |  | 	int rv; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	if (vconn == NULL) | 
					
						
							|  |  |  | 		return 0; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	rv = vde_recv(vconn, buf, len, 0); | 
					
						
							|  |  |  | 	if (rv < 0) { | 
					
						
							|  |  |  | 		if (errno == EAGAIN) | 
					
						
							|  |  |  | 			return 0; | 
					
						
							|  |  |  | 		return -errno; | 
					
						
							|  |  |  | 	} | 
					
						
							|  |  |  | 	else if (rv == 0) | 
					
						
							|  |  |  | 		return -ENOTCONN; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	return rv; | 
					
						
							|  |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | int vde_user_write(void *conn, void *buf, int len) | 
					
						
							|  |  |  | { | 
					
						
							|  |  |  | 	VDECONN *vconn = conn; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	if (vconn == NULL) | 
					
						
							|  |  |  | 		return 0; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	return vde_send(vconn, buf, len, 0); | 
					
						
							|  |  |  | } | 
					
						
							|  |  |  | 
 |