LXR linux/arch/um/drivers/vde

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