vde_user.c

Go to the documentation of this file.

/*
 * Copyright (C) 2007 Luca Bigliardi ([email protected]).
 * Licensed under the GPL.
 */

#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);
}