]>
git.proxmox.com Git - qemu.git/blob - net/vde.c
4 * Copyright (c) 2003-2008 Fabrice Bellard
6 * Permission is hereby granted, free of charge, to any person obtaining a copy
7 * of this software and associated documentation files (the "Software"), to deal
8 * in the Software without restriction, including without limitation the rights
9 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
10 * copies of the Software, and to permit persons to whom the Software is
11 * furnished to do so, subject to the following conditions:
13 * The above copyright notice and this permission notice shall be included in
14 * all copies or substantial portions of the Software.
16 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
17 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
18 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
19 * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
20 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
21 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
26 #include "config-host.h"
28 #include <libvdeplug.h>
31 #include "qemu-char.h"
32 #include "qemu-common.h"
33 #include "qemu-option.h"
36 typedef struct VDEState
{
41 static void vde_to_qemu(void *opaque
)
47 size
= vde_recv(s
->vde
, (char *)buf
, sizeof(buf
), 0);
49 qemu_send_packet(s
->vc
, buf
, size
);
53 static ssize_t
vde_receive(VLANClientState
*vc
, const uint8_t *buf
, size_t size
)
55 VDEState
*s
= vc
->opaque
;
59 ret
= vde_send(s
->vde
, (const char *)buf
, size
, 0);
60 } while (ret
< 0 && errno
== EINTR
);
65 static void vde_cleanup(VLANClientState
*vc
)
67 VDEState
*s
= vc
->opaque
;
68 qemu_set_fd_handler(vde_datafd(s
->vde
), NULL
, NULL
, NULL
);
73 static int net_vde_init(VLANState
*vlan
, const char *model
,
74 const char *name
, const char *sock
,
75 int port
, const char *group
, int mode
)
78 char *init_group
= (char *)group
;
79 char *init_sock
= (char *)sock
;
81 struct vde_open_args args
= {
87 s
= qemu_mallocz(sizeof(VDEState
));
88 s
->vde
= vde_open(init_sock
, (char *)"QEMU", &args
);
93 s
->vc
= qemu_new_vlan_client(NET_CLIENT_TYPE_VDE
,
94 vlan
, NULL
, model
, name
, NULL
,
95 vde_receive
, NULL
, NULL
,
97 qemu_set_fd_handler(vde_datafd(s
->vde
), vde_to_qemu
, NULL
, s
);
98 snprintf(s
->vc
->info_str
, sizeof(s
->vc
->info_str
), "sock=%s,fd=%d",
99 sock
, vde_datafd(s
->vde
));
103 int net_init_vde(QemuOpts
*opts
, Monitor
*mon
, const char *name
, VLANState
*vlan
)
109 sock
= qemu_opt_get(opts
, "sock");
110 group
= qemu_opt_get(opts
, "group");
112 port
= qemu_opt_get_number(opts
, "port", 0);
113 mode
= qemu_opt_get_number(opts
, "mode", 0700);
115 if (net_vde_init(vlan
, "vde", name
, sock
, port
, group
, mode
) == -1) {
120 vlan
->nb_host_devs
++;