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"
35 typedef struct VDEState
{
40 static void vde_to_qemu(void *opaque
)
46 size
= vde_recv(s
->vde
, (char *)buf
, sizeof(buf
), 0);
48 qemu_send_packet(&s
->nc
, buf
, size
);
52 static ssize_t
vde_receive(VLANClientState
*nc
, const uint8_t *buf
, size_t size
)
54 VDEState
*s
= DO_UPCAST(VDEState
, nc
, nc
);
58 ret
= vde_send(s
->vde
, (const char *)buf
, size
, 0);
59 } while (ret
< 0 && errno
== EINTR
);
64 static void vde_cleanup(VLANClientState
*nc
)
66 VDEState
*s
= DO_UPCAST(VDEState
, nc
, nc
);
67 qemu_set_fd_handler(vde_datafd(s
->vde
), NULL
, NULL
, NULL
);
71 static NetClientInfo net_vde_info
= {
72 .type
= NET_CLIENT_TYPE_VDE
,
73 .size
= sizeof(VDEState
),
74 .receive
= vde_receive
,
75 .cleanup
= vde_cleanup
,
78 static int net_vde_init(VLANState
*vlan
, const char *model
,
79 const char *name
, const char *sock
,
80 int port
, const char *group
, int mode
)
85 char *init_group
= (char *)group
;
86 char *init_sock
= (char *)sock
;
88 struct vde_open_args args
= {
94 vde
= vde_open(init_sock
, (char *)"QEMU", &args
);
99 nc
= qemu_new_net_client(&net_vde_info
, vlan
, NULL
, model
, name
);
101 snprintf(nc
->info_str
, sizeof(nc
->info_str
), "sock=%s,fd=%d",
102 sock
, vde_datafd(vde
));
104 s
= DO_UPCAST(VDEState
, nc
, nc
);
108 qemu_set_fd_handler(vde_datafd(s
->vde
), vde_to_qemu
, NULL
, s
);
113 int net_init_vde(QemuOpts
*opts
, Monitor
*mon
, const char *name
, VLANState
*vlan
)
119 sock
= qemu_opt_get(opts
, "sock");
120 group
= qemu_opt_get(opts
, "group");
122 port
= qemu_opt_get_number(opts
, "port", 0);
123 mode
= qemu_opt_get_number(opts
, "mode", 0700);
125 if (net_vde_init(vlan
, "vde", name
, sock
, port
, group
, mode
) == -1) {