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