blob: 56533db25343129bcd60c152744966a2b84241cc [file] [log] [blame]
Jeff Dikead43c352007-10-16 01:26:48 -07001/*
2 * Copyright (C) 2007 Luca Bigliardi (shammash@artha.org).
3 * Licensed under the GPL.
4 */
5
Jeff Dikecd1ae0e2007-10-16 01:27:29 -07006#include <stddef.h>
Jeff Dikead43c352007-10-16 01:26:48 -07007#include <errno.h>
Jeff Dikead43c352007-10-16 01:26:48 -07008#include <libvdeplug.h>
Jeff Dikead43c352007-10-16 01:26:48 -07009#include "kern_constants.h"
Jeff Dikecd1ae0e2007-10-16 01:27:29 -070010#include "net_user.h"
Jeff Dikead43c352007-10-16 01:26:48 -070011#include "um_malloc.h"
Jeff Dikecd1ae0e2007-10-16 01:27:29 -070012#include "user.h"
Jeff Dikead43c352007-10-16 01:26:48 -070013#include "vde.h"
14
Jeff Dikead43c352007-10-16 01:26:48 -070015static 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
Jeff Dikead43c352007-10-16 01:26:48 -070066const struct net_user_info vde_user_info = {
67 .init = vde_user_init,
68 .open = vde_user_open,
69 .close = NULL,
70 .remove = vde_remove,
Jeff Dikead43c352007-10-16 01:26:48 -070071 .add_address = NULL,
72 .delete_address = NULL,
Jeff Dikeb53f35a2007-10-16 01:27:31 -070073 .mtu = ETH_MAX_PACKET,
74 .max_packet = ETH_MAX_PACKET + ETH_HEADER_OTHER,
Jeff Dikead43c352007-10-16 01:26:48 -070075};
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) {
Joe Perchesb7c000c2008-02-04 22:30:59 -080083 printk(UM_KERN_ERR "vde_init_libstuff - vde_open_args "
Jeff Dikead43c352007-10-16 01:26:48 -070084 "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