xref: /OK3568_Linux_fs/kernel/arch/um/drivers/vde_user.c (revision 4882a59341e53eb6f0b4789bf948001014eff981)
1*4882a593Smuzhiyun // SPDX-License-Identifier: GPL-2.0
2*4882a593Smuzhiyun /*
3*4882a593Smuzhiyun  * Copyright (C) 2007 Luca Bigliardi (shammash@artha.org).
4*4882a593Smuzhiyun  */
5*4882a593Smuzhiyun 
6*4882a593Smuzhiyun #include <stddef.h>
7*4882a593Smuzhiyun #include <errno.h>
8*4882a593Smuzhiyun #include <libvdeplug.h>
9*4882a593Smuzhiyun #include <net_user.h>
10*4882a593Smuzhiyun #include <um_malloc.h>
11*4882a593Smuzhiyun #include "vde.h"
12*4882a593Smuzhiyun 
vde_user_init(void * data,void * dev)13*4882a593Smuzhiyun static int vde_user_init(void *data, void *dev)
14*4882a593Smuzhiyun {
15*4882a593Smuzhiyun 	struct vde_data *pri = data;
16*4882a593Smuzhiyun 	VDECONN *conn = NULL;
17*4882a593Smuzhiyun 	int err = -EINVAL;
18*4882a593Smuzhiyun 
19*4882a593Smuzhiyun 	pri->dev = dev;
20*4882a593Smuzhiyun 
21*4882a593Smuzhiyun 	conn = vde_open(pri->vde_switch, pri->descr, pri->args);
22*4882a593Smuzhiyun 
23*4882a593Smuzhiyun 	if (conn == NULL) {
24*4882a593Smuzhiyun 		err = -errno;
25*4882a593Smuzhiyun 		printk(UM_KERN_ERR "vde_user_init: vde_open failed, "
26*4882a593Smuzhiyun 		       "errno = %d\n", errno);
27*4882a593Smuzhiyun 		return err;
28*4882a593Smuzhiyun 	}
29*4882a593Smuzhiyun 
30*4882a593Smuzhiyun 	printk(UM_KERN_INFO "vde backend - connection opened\n");
31*4882a593Smuzhiyun 
32*4882a593Smuzhiyun 	pri->conn = conn;
33*4882a593Smuzhiyun 
34*4882a593Smuzhiyun 	return 0;
35*4882a593Smuzhiyun }
36*4882a593Smuzhiyun 
vde_user_open(void * data)37*4882a593Smuzhiyun static int vde_user_open(void *data)
38*4882a593Smuzhiyun {
39*4882a593Smuzhiyun 	struct vde_data *pri = data;
40*4882a593Smuzhiyun 
41*4882a593Smuzhiyun 	if (pri->conn != NULL)
42*4882a593Smuzhiyun 		return vde_datafd(pri->conn);
43*4882a593Smuzhiyun 
44*4882a593Smuzhiyun 	printk(UM_KERN_WARNING "vde_open - we have no VDECONN to open");
45*4882a593Smuzhiyun 	return -EINVAL;
46*4882a593Smuzhiyun }
47*4882a593Smuzhiyun 
vde_remove(void * data)48*4882a593Smuzhiyun static void vde_remove(void *data)
49*4882a593Smuzhiyun {
50*4882a593Smuzhiyun 	struct vde_data *pri = data;
51*4882a593Smuzhiyun 
52*4882a593Smuzhiyun 	if (pri->conn != NULL) {
53*4882a593Smuzhiyun 		printk(UM_KERN_INFO "vde backend - closing connection\n");
54*4882a593Smuzhiyun 		vde_close(pri->conn);
55*4882a593Smuzhiyun 		pri->conn = NULL;
56*4882a593Smuzhiyun 		kfree(pri->args);
57*4882a593Smuzhiyun 		pri->args = NULL;
58*4882a593Smuzhiyun 		return;
59*4882a593Smuzhiyun 	}
60*4882a593Smuzhiyun 
61*4882a593Smuzhiyun 	printk(UM_KERN_WARNING "vde_remove - we have no VDECONN to remove");
62*4882a593Smuzhiyun }
63*4882a593Smuzhiyun 
64*4882a593Smuzhiyun const struct net_user_info vde_user_info = {
65*4882a593Smuzhiyun 	.init		= vde_user_init,
66*4882a593Smuzhiyun 	.open		= vde_user_open,
67*4882a593Smuzhiyun 	.close	 	= NULL,
68*4882a593Smuzhiyun 	.remove	 	= vde_remove,
69*4882a593Smuzhiyun 	.add_address	= NULL,
70*4882a593Smuzhiyun 	.delete_address = NULL,
71*4882a593Smuzhiyun 	.mtu		= ETH_MAX_PACKET,
72*4882a593Smuzhiyun 	.max_packet	= ETH_MAX_PACKET + ETH_HEADER_OTHER,
73*4882a593Smuzhiyun };
74*4882a593Smuzhiyun 
vde_init_libstuff(struct vde_data * vpri,struct vde_init * init)75*4882a593Smuzhiyun void vde_init_libstuff(struct vde_data *vpri, struct vde_init *init)
76*4882a593Smuzhiyun {
77*4882a593Smuzhiyun 	struct vde_open_args *args;
78*4882a593Smuzhiyun 
79*4882a593Smuzhiyun 	vpri->args = uml_kmalloc(sizeof(struct vde_open_args), UM_GFP_KERNEL);
80*4882a593Smuzhiyun 	if (vpri->args == NULL) {
81*4882a593Smuzhiyun 		printk(UM_KERN_ERR "vde_init_libstuff - vde_open_args "
82*4882a593Smuzhiyun 		       "allocation failed");
83*4882a593Smuzhiyun 		return;
84*4882a593Smuzhiyun 	}
85*4882a593Smuzhiyun 
86*4882a593Smuzhiyun 	args = vpri->args;
87*4882a593Smuzhiyun 
88*4882a593Smuzhiyun 	args->port = init->port;
89*4882a593Smuzhiyun 	args->group = init->group;
90*4882a593Smuzhiyun 	args->mode = init->mode ? init->mode : 0700;
91*4882a593Smuzhiyun 
92*4882a593Smuzhiyun 	args->port ?  printk("port %d", args->port) :
93*4882a593Smuzhiyun 		printk("undefined port");
94*4882a593Smuzhiyun }
95*4882a593Smuzhiyun 
vde_user_read(void * conn,void * buf,int len)96*4882a593Smuzhiyun int vde_user_read(void *conn, void *buf, int len)
97*4882a593Smuzhiyun {
98*4882a593Smuzhiyun 	VDECONN *vconn = conn;
99*4882a593Smuzhiyun 	int rv;
100*4882a593Smuzhiyun 
101*4882a593Smuzhiyun 	if (vconn == NULL)
102*4882a593Smuzhiyun 		return 0;
103*4882a593Smuzhiyun 
104*4882a593Smuzhiyun 	rv = vde_recv(vconn, buf, len, 0);
105*4882a593Smuzhiyun 	if (rv < 0) {
106*4882a593Smuzhiyun 		if (errno == EAGAIN)
107*4882a593Smuzhiyun 			return 0;
108*4882a593Smuzhiyun 		return -errno;
109*4882a593Smuzhiyun 	}
110*4882a593Smuzhiyun 	else if (rv == 0)
111*4882a593Smuzhiyun 		return -ENOTCONN;
112*4882a593Smuzhiyun 
113*4882a593Smuzhiyun 	return rv;
114*4882a593Smuzhiyun }
115*4882a593Smuzhiyun 
vde_user_write(void * conn,void * buf,int len)116*4882a593Smuzhiyun int vde_user_write(void *conn, void *buf, int len)
117*4882a593Smuzhiyun {
118*4882a593Smuzhiyun 	VDECONN *vconn = conn;
119*4882a593Smuzhiyun 
120*4882a593Smuzhiyun 	if (vconn == NULL)
121*4882a593Smuzhiyun 		return 0;
122*4882a593Smuzhiyun 
123*4882a593Smuzhiyun 	return vde_send(vconn, buf, len, 0);
124*4882a593Smuzhiyun }
125*4882a593Smuzhiyun 
126