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