Loading...
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 | // SPDX-License-Identifier: GPL-2.0 /* * Copyright (C) 2007 Luca Bigliardi (shammash@artha.org). */ #include <stddef.h> #include <errno.h> #include <libvdeplug.h> #include <net_user.h> #include <um_malloc.h> #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, .mtu = ETH_MAX_PACKET, .max_packet = ETH_MAX_PACKET + ETH_HEADER_OTHER, }; void vde_init_libstuff(struct vde_data *vpri, struct vde_init *init) { struct vde_open_args *args; vpri->args = uml_kmalloc(sizeof(struct vde_open_args), UM_GFP_KERNEL); if (vpri->args == NULL) { printk(UM_KERN_ERR "vde_init_libstuff - vde_open_args " "allocation failed"); return; } args = vpri->args; args->port = init->port; args->group = init->group; args->mode = init->mode ? init->mode : 0700; args->port ? printk("port %d", args->port) : printk("undefined port"); } 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); } |