Statistics
| Branch: | Revision:

root / net.c @ 31a32289

History | View | Annotate | Download (26.2 kB)

1 63a01ef8 aliguori
/*
2 63a01ef8 aliguori
 * QEMU System Emulator
3 63a01ef8 aliguori
 *
4 63a01ef8 aliguori
 * Copyright (c) 2003-2008 Fabrice Bellard
5 63a01ef8 aliguori
 *
6 63a01ef8 aliguori
 * Permission is hereby granted, free of charge, to any person obtaining a copy
7 63a01ef8 aliguori
 * of this software and associated documentation files (the "Software"), to deal
8 63a01ef8 aliguori
 * in the Software without restriction, including without limitation the rights
9 63a01ef8 aliguori
 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
10 63a01ef8 aliguori
 * copies of the Software, and to permit persons to whom the Software is
11 63a01ef8 aliguori
 * furnished to do so, subject to the following conditions:
12 63a01ef8 aliguori
 *
13 63a01ef8 aliguori
 * The above copyright notice and this permission notice shall be included in
14 63a01ef8 aliguori
 * all copies or substantial portions of the Software.
15 63a01ef8 aliguori
 *
16 63a01ef8 aliguori
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
17 63a01ef8 aliguori
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
18 63a01ef8 aliguori
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
19 63a01ef8 aliguori
 * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
20 63a01ef8 aliguori
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
21 63a01ef8 aliguori
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
22 63a01ef8 aliguori
 * THE SOFTWARE.
23 63a01ef8 aliguori
 */
24 d40cdb10 blueswir1
#include "config-host.h"
25 d40cdb10 blueswir1
26 a245fc18 Paolo Bonzini
#include "net.h"
27 a245fc18 Paolo Bonzini
#include "net/clients.h"
28 f6c874e3 Stefan Hajnoczi
#include "net/hub.h"
29 a245fc18 Paolo Bonzini
#include "net/slirp.h"
30 f1d078c3 Mark McLoughlin
#include "net/util.h"
31 a245fc18 Paolo Bonzini
32 511d2b14 blueswir1
#include "monitor.h"
33 1df49e04 Mark McLoughlin
#include "qemu-common.h"
34 511d2b14 blueswir1
#include "qemu_socket.h"
35 4b37156c Luiz Capitulino
#include "qmp-commands.h"
36 75422b0d Amit Shah
#include "hw/qdev.h"
37 ce053661 Benjamin Poirier
#include "iov.h"
38 6687b79d Laszlo Ersek
#include "qapi-visit.h"
39 6687b79d Laszlo Ersek
#include "qapi/opts-visitor.h"
40 6687b79d Laszlo Ersek
#include "qapi/qapi-dealloc-visitor.h"
41 511d2b14 blueswir1
42 2944e4ec Stefan Weil
/* Net bridge is currently not supported for W32. */
43 2944e4ec Stefan Weil
#if !defined(_WIN32)
44 2944e4ec Stefan Weil
# define CONFIG_NET_BRIDGE
45 2944e4ec Stefan Weil
#endif
46 2944e4ec Stefan Weil
47 4e68f7a0 Stefan Hajnoczi
static QTAILQ_HEAD(, NetClientState) net_clients;
48 63a01ef8 aliguori
49 cb4522cc Gerd Hoffmann
int default_net = 1;
50 cb4522cc Gerd Hoffmann
51 63a01ef8 aliguori
/***********************************************************/
52 63a01ef8 aliguori
/* network device redirectors */
53 63a01ef8 aliguori
54 68ac40d2 Mark McLoughlin
#if defined(DEBUG_NET)
55 63a01ef8 aliguori
static void hex_dump(FILE *f, const uint8_t *buf, int size)
56 63a01ef8 aliguori
{
57 63a01ef8 aliguori
    int len, i, j, c;
58 63a01ef8 aliguori
59 63a01ef8 aliguori
    for(i=0;i<size;i+=16) {
60 63a01ef8 aliguori
        len = size - i;
61 63a01ef8 aliguori
        if (len > 16)
62 63a01ef8 aliguori
            len = 16;
63 63a01ef8 aliguori
        fprintf(f, "%08x ", i);
64 63a01ef8 aliguori
        for(j=0;j<16;j++) {
65 63a01ef8 aliguori
            if (j < len)
66 63a01ef8 aliguori
                fprintf(f, " %02x", buf[i+j]);
67 63a01ef8 aliguori
            else
68 63a01ef8 aliguori
                fprintf(f, "   ");
69 63a01ef8 aliguori
        }
70 63a01ef8 aliguori
        fprintf(f, " ");
71 63a01ef8 aliguori
        for(j=0;j<len;j++) {
72 63a01ef8 aliguori
            c = buf[i+j];
73 63a01ef8 aliguori
            if (c < ' ' || c > '~')
74 63a01ef8 aliguori
                c = '.';
75 63a01ef8 aliguori
            fprintf(f, "%c", c);
76 63a01ef8 aliguori
        }
77 63a01ef8 aliguori
        fprintf(f, "\n");
78 63a01ef8 aliguori
    }
79 63a01ef8 aliguori
}
80 63a01ef8 aliguori
#endif
81 63a01ef8 aliguori
82 63a01ef8 aliguori
static int get_str_sep(char *buf, int buf_size, const char **pp, int sep)
83 63a01ef8 aliguori
{
84 63a01ef8 aliguori
    const char *p, *p1;
85 63a01ef8 aliguori
    int len;
86 63a01ef8 aliguori
    p = *pp;
87 63a01ef8 aliguori
    p1 = strchr(p, sep);
88 63a01ef8 aliguori
    if (!p1)
89 63a01ef8 aliguori
        return -1;
90 63a01ef8 aliguori
    len = p1 - p;
91 63a01ef8 aliguori
    p1++;
92 63a01ef8 aliguori
    if (buf_size > 0) {
93 63a01ef8 aliguori
        if (len > buf_size - 1)
94 63a01ef8 aliguori
            len = buf_size - 1;
95 63a01ef8 aliguori
        memcpy(buf, p, len);
96 63a01ef8 aliguori
        buf[len] = '\0';
97 63a01ef8 aliguori
    }
98 63a01ef8 aliguori
    *pp = p1;
99 63a01ef8 aliguori
    return 0;
100 63a01ef8 aliguori
}
101 63a01ef8 aliguori
102 63a01ef8 aliguori
int parse_host_port(struct sockaddr_in *saddr, const char *str)
103 63a01ef8 aliguori
{
104 63a01ef8 aliguori
    char buf[512];
105 63a01ef8 aliguori
    struct hostent *he;
106 63a01ef8 aliguori
    const char *p, *r;
107 63a01ef8 aliguori
    int port;
108 63a01ef8 aliguori
109 63a01ef8 aliguori
    p = str;
110 63a01ef8 aliguori
    if (get_str_sep(buf, sizeof(buf), &p, ':') < 0)
111 63a01ef8 aliguori
        return -1;
112 63a01ef8 aliguori
    saddr->sin_family = AF_INET;
113 63a01ef8 aliguori
    if (buf[0] == '\0') {
114 63a01ef8 aliguori
        saddr->sin_addr.s_addr = 0;
115 63a01ef8 aliguori
    } else {
116 cd390083 blueswir1
        if (qemu_isdigit(buf[0])) {
117 63a01ef8 aliguori
            if (!inet_aton(buf, &saddr->sin_addr))
118 63a01ef8 aliguori
                return -1;
119 63a01ef8 aliguori
        } else {
120 63a01ef8 aliguori
            if ((he = gethostbyname(buf)) == NULL)
121 63a01ef8 aliguori
                return - 1;
122 63a01ef8 aliguori
            saddr->sin_addr = *(struct in_addr *)he->h_addr;
123 63a01ef8 aliguori
        }
124 63a01ef8 aliguori
    }
125 63a01ef8 aliguori
    port = strtol(p, (char **)&r, 0);
126 63a01ef8 aliguori
    if (r == p)
127 63a01ef8 aliguori
        return -1;
128 63a01ef8 aliguori
    saddr->sin_port = htons(port);
129 63a01ef8 aliguori
    return 0;
130 63a01ef8 aliguori
}
131 63a01ef8 aliguori
132 35277d14 Stefan Hajnoczi
void qemu_format_nic_info_str(NetClientState *nc, uint8_t macaddr[6])
133 7cb7434b aliguori
{
134 35277d14 Stefan Hajnoczi
    snprintf(nc->info_str, sizeof(nc->info_str),
135 4dda4063 aliguori
             "model=%s,macaddr=%02x:%02x:%02x:%02x:%02x:%02x",
136 35277d14 Stefan Hajnoczi
             nc->model,
137 7cb7434b aliguori
             macaddr[0], macaddr[1], macaddr[2],
138 7cb7434b aliguori
             macaddr[3], macaddr[4], macaddr[5]);
139 7cb7434b aliguori
}
140 7cb7434b aliguori
141 76d32cba Gerd Hoffmann
void qemu_macaddr_default_if_unset(MACAddr *macaddr)
142 76d32cba Gerd Hoffmann
{
143 76d32cba Gerd Hoffmann
    static int index = 0;
144 76d32cba Gerd Hoffmann
    static const MACAddr zero = { .a = { 0,0,0,0,0,0 } };
145 76d32cba Gerd Hoffmann
146 76d32cba Gerd Hoffmann
    if (memcmp(macaddr, &zero, sizeof(zero)) != 0)
147 76d32cba Gerd Hoffmann
        return;
148 76d32cba Gerd Hoffmann
    macaddr->a[0] = 0x52;
149 76d32cba Gerd Hoffmann
    macaddr->a[1] = 0x54;
150 76d32cba Gerd Hoffmann
    macaddr->a[2] = 0x00;
151 76d32cba Gerd Hoffmann
    macaddr->a[3] = 0x12;
152 76d32cba Gerd Hoffmann
    macaddr->a[4] = 0x34;
153 76d32cba Gerd Hoffmann
    macaddr->a[5] = 0x56 + index++;
154 76d32cba Gerd Hoffmann
}
155 76d32cba Gerd Hoffmann
156 d33d93b2 Stefan Hajnoczi
/**
157 d33d93b2 Stefan Hajnoczi
 * Generate a name for net client
158 d33d93b2 Stefan Hajnoczi
 *
159 d33d93b2 Stefan Hajnoczi
 * Only net clients created with the legacy -net option need this.  Naming is
160 d33d93b2 Stefan Hajnoczi
 * mandatory for net clients created with -netdev.
161 d33d93b2 Stefan Hajnoczi
 */
162 35277d14 Stefan Hajnoczi
static char *assign_name(NetClientState *nc1, const char *model)
163 676cff29 aliguori
{
164 35277d14 Stefan Hajnoczi
    NetClientState *nc;
165 676cff29 aliguori
    char buf[256];
166 676cff29 aliguori
    int id = 0;
167 676cff29 aliguori
168 35277d14 Stefan Hajnoczi
    QTAILQ_FOREACH(nc, &net_clients, next) {
169 35277d14 Stefan Hajnoczi
        if (nc == nc1) {
170 d33d93b2 Stefan Hajnoczi
            continue;
171 5610c3aa Mark McLoughlin
        }
172 d33d93b2 Stefan Hajnoczi
        /* For compatibility only bump id for net clients on a vlan */
173 35277d14 Stefan Hajnoczi
        if (strcmp(nc->model, model) == 0 &&
174 35277d14 Stefan Hajnoczi
            net_hub_id_for_client(nc, NULL) == 0) {
175 53e51d85 Markus Armbruster
            id++;
176 53e51d85 Markus Armbruster
        }
177 53e51d85 Markus Armbruster
    }
178 53e51d85 Markus Armbruster
179 676cff29 aliguori
    snprintf(buf, sizeof(buf), "%s.%d", model, id);
180 676cff29 aliguori
181 7267c094 Anthony Liguori
    return g_strdup(buf);
182 676cff29 aliguori
}
183 676cff29 aliguori
184 4e68f7a0 Stefan Hajnoczi
NetClientState *qemu_new_net_client(NetClientInfo *info,
185 4e68f7a0 Stefan Hajnoczi
                                    NetClientState *peer,
186 4e68f7a0 Stefan Hajnoczi
                                    const char *model,
187 4e68f7a0 Stefan Hajnoczi
                                    const char *name)
188 63a01ef8 aliguori
{
189 35277d14 Stefan Hajnoczi
    NetClientState *nc;
190 5610c3aa Mark McLoughlin
191 4e68f7a0 Stefan Hajnoczi
    assert(info->size >= sizeof(NetClientState));
192 45460d1a Mark McLoughlin
193 35277d14 Stefan Hajnoczi
    nc = g_malloc0(info->size);
194 5610c3aa Mark McLoughlin
195 35277d14 Stefan Hajnoczi
    nc->info = info;
196 35277d14 Stefan Hajnoczi
    nc->model = g_strdup(model);
197 45460d1a Mark McLoughlin
    if (name) {
198 35277d14 Stefan Hajnoczi
        nc->name = g_strdup(name);
199 45460d1a Mark McLoughlin
    } else {
200 35277d14 Stefan Hajnoczi
        nc->name = assign_name(nc, model);
201 45460d1a Mark McLoughlin
    }
202 5610c3aa Mark McLoughlin
203 ab5f3f84 Stefan Hajnoczi
    if (peer) {
204 ab5f3f84 Stefan Hajnoczi
        assert(!peer->peer);
205 35277d14 Stefan Hajnoczi
        nc->peer = peer;
206 35277d14 Stefan Hajnoczi
        peer->peer = nc;
207 d80b9fc6 Mark McLoughlin
    }
208 35277d14 Stefan Hajnoczi
    QTAILQ_INSERT_TAIL(&net_clients, nc, next);
209 63a01ef8 aliguori
210 86a77c38 Zhi Yong Wu
    nc->send_queue = qemu_new_net_queue(nc);
211 63a01ef8 aliguori
212 35277d14 Stefan Hajnoczi
    return nc;
213 63a01ef8 aliguori
}
214 63a01ef8 aliguori
215 ebef2c09 Mark McLoughlin
NICState *qemu_new_nic(NetClientInfo *info,
216 ebef2c09 Mark McLoughlin
                       NICConf *conf,
217 ebef2c09 Mark McLoughlin
                       const char *model,
218 ebef2c09 Mark McLoughlin
                       const char *name,
219 ebef2c09 Mark McLoughlin
                       void *opaque)
220 ebef2c09 Mark McLoughlin
{
221 4e68f7a0 Stefan Hajnoczi
    NetClientState *nc;
222 ebef2c09 Mark McLoughlin
    NICState *nic;
223 ebef2c09 Mark McLoughlin
224 2be64a68 Laszlo Ersek
    assert(info->type == NET_CLIENT_OPTIONS_KIND_NIC);
225 ebef2c09 Mark McLoughlin
    assert(info->size >= sizeof(NICState));
226 ebef2c09 Mark McLoughlin
227 ab5f3f84 Stefan Hajnoczi
    nc = qemu_new_net_client(info, conf->peer, model, name);
228 ebef2c09 Mark McLoughlin
229 ebef2c09 Mark McLoughlin
    nic = DO_UPCAST(NICState, nc, nc);
230 ebef2c09 Mark McLoughlin
    nic->conf = conf;
231 ebef2c09 Mark McLoughlin
    nic->opaque = opaque;
232 ebef2c09 Mark McLoughlin
233 ebef2c09 Mark McLoughlin
    return nic;
234 ebef2c09 Mark McLoughlin
}
235 ebef2c09 Mark McLoughlin
236 b20c6b9e Stefan Hajnoczi
static void qemu_cleanup_net_client(NetClientState *nc)
237 63a01ef8 aliguori
{
238 35277d14 Stefan Hajnoczi
    QTAILQ_REMOVE(&net_clients, nc, next);
239 63a01ef8 aliguori
240 35277d14 Stefan Hajnoczi
    if (nc->info->cleanup) {
241 35277d14 Stefan Hajnoczi
        nc->info->cleanup(nc);
242 5610c3aa Mark McLoughlin
    }
243 a083a89d Michael S. Tsirkin
}
244 5610c3aa Mark McLoughlin
245 b20c6b9e Stefan Hajnoczi
static void qemu_free_net_client(NetClientState *nc)
246 a083a89d Michael S. Tsirkin
{
247 35277d14 Stefan Hajnoczi
    if (nc->send_queue) {
248 35277d14 Stefan Hajnoczi
        qemu_del_net_queue(nc->send_queue);
249 a005d073 Stefan Hajnoczi
    }
250 35277d14 Stefan Hajnoczi
    if (nc->peer) {
251 35277d14 Stefan Hajnoczi
        nc->peer->peer = NULL;
252 a083a89d Michael S. Tsirkin
    }
253 35277d14 Stefan Hajnoczi
    g_free(nc->name);
254 35277d14 Stefan Hajnoczi
    g_free(nc->model);
255 35277d14 Stefan Hajnoczi
    g_free(nc);
256 63a01ef8 aliguori
}
257 63a01ef8 aliguori
258 b20c6b9e Stefan Hajnoczi
void qemu_del_net_client(NetClientState *nc)
259 a083a89d Michael S. Tsirkin
{
260 a083a89d Michael S. Tsirkin
    /* If there is a peer NIC, delete and cleanup client, but do not free. */
261 35277d14 Stefan Hajnoczi
    if (nc->peer && nc->peer->info->type == NET_CLIENT_OPTIONS_KIND_NIC) {
262 35277d14 Stefan Hajnoczi
        NICState *nic = DO_UPCAST(NICState, nc, nc->peer);
263 a083a89d Michael S. Tsirkin
        if (nic->peer_deleted) {
264 a083a89d Michael S. Tsirkin
            return;
265 a083a89d Michael S. Tsirkin
        }
266 a083a89d Michael S. Tsirkin
        nic->peer_deleted = true;
267 a083a89d Michael S. Tsirkin
        /* Let NIC know peer is gone. */
268 35277d14 Stefan Hajnoczi
        nc->peer->link_down = true;
269 35277d14 Stefan Hajnoczi
        if (nc->peer->info->link_status_changed) {
270 35277d14 Stefan Hajnoczi
            nc->peer->info->link_status_changed(nc->peer);
271 a083a89d Michael S. Tsirkin
        }
272 b20c6b9e Stefan Hajnoczi
        qemu_cleanup_net_client(nc);
273 a083a89d Michael S. Tsirkin
        return;
274 a083a89d Michael S. Tsirkin
    }
275 a083a89d Michael S. Tsirkin
276 a083a89d Michael S. Tsirkin
    /* If this is a peer NIC and peer has already been deleted, free it now. */
277 35277d14 Stefan Hajnoczi
    if (nc->peer && nc->info->type == NET_CLIENT_OPTIONS_KIND_NIC) {
278 35277d14 Stefan Hajnoczi
        NICState *nic = DO_UPCAST(NICState, nc, nc);
279 a083a89d Michael S. Tsirkin
        if (nic->peer_deleted) {
280 b20c6b9e Stefan Hajnoczi
            qemu_free_net_client(nc->peer);
281 1a609520 Jan Kiszka
        }
282 1a609520 Jan Kiszka
    }
283 1a609520 Jan Kiszka
284 b20c6b9e Stefan Hajnoczi
    qemu_cleanup_net_client(nc);
285 b20c6b9e Stefan Hajnoczi
    qemu_free_net_client(nc);
286 1a609520 Jan Kiszka
}
287 1a609520 Jan Kiszka
288 57f9ef17 Mark McLoughlin
void qemu_foreach_nic(qemu_nic_foreach func, void *opaque)
289 57f9ef17 Mark McLoughlin
{
290 4e68f7a0 Stefan Hajnoczi
    NetClientState *nc;
291 57f9ef17 Mark McLoughlin
292 94878994 Stefan Hajnoczi
    QTAILQ_FOREACH(nc, &net_clients, next) {
293 2be64a68 Laszlo Ersek
        if (nc->info->type == NET_CLIENT_OPTIONS_KIND_NIC) {
294 57f9ef17 Mark McLoughlin
            func(DO_UPCAST(NICState, nc, nc), opaque);
295 57f9ef17 Mark McLoughlin
        }
296 57f9ef17 Mark McLoughlin
    }
297 57f9ef17 Mark McLoughlin
}
298 57f9ef17 Mark McLoughlin
299 4e68f7a0 Stefan Hajnoczi
int qemu_can_send_packet(NetClientState *sender)
300 63a01ef8 aliguori
{
301 a005d073 Stefan Hajnoczi
    if (!sender->peer) {
302 d80b9fc6 Mark McLoughlin
        return 1;
303 d80b9fc6 Mark McLoughlin
    }
304 d80b9fc6 Mark McLoughlin
305 a005d073 Stefan Hajnoczi
    if (sender->peer->receive_disabled) {
306 a005d073 Stefan Hajnoczi
        return 0;
307 a005d073 Stefan Hajnoczi
    } else if (sender->peer->info->can_receive &&
308 a005d073 Stefan Hajnoczi
               !sender->peer->info->can_receive(sender->peer)) {
309 a005d073 Stefan Hajnoczi
        return 0;
310 63a01ef8 aliguori
    }
311 60c07d93 Vincent Palatin
    return 1;
312 63a01ef8 aliguori
}
313 63a01ef8 aliguori
314 86a77c38 Zhi Yong Wu
ssize_t qemu_deliver_packet(NetClientState *sender,
315 86a77c38 Zhi Yong Wu
                            unsigned flags,
316 86a77c38 Zhi Yong Wu
                            const uint8_t *data,
317 86a77c38 Zhi Yong Wu
                            size_t size,
318 86a77c38 Zhi Yong Wu
                            void *opaque)
319 9a6ecb30 Mark McLoughlin
{
320 35277d14 Stefan Hajnoczi
    NetClientState *nc = opaque;
321 893379ef Mark McLoughlin
    ssize_t ret;
322 9a6ecb30 Mark McLoughlin
323 35277d14 Stefan Hajnoczi
    if (nc->link_down) {
324 9a6ecb30 Mark McLoughlin
        return size;
325 9a6ecb30 Mark McLoughlin
    }
326 9a6ecb30 Mark McLoughlin
327 35277d14 Stefan Hajnoczi
    if (nc->receive_disabled) {
328 893379ef Mark McLoughlin
        return 0;
329 893379ef Mark McLoughlin
    }
330 893379ef Mark McLoughlin
331 35277d14 Stefan Hajnoczi
    if (flags & QEMU_NET_PACKET_FLAG_RAW && nc->info->receive_raw) {
332 35277d14 Stefan Hajnoczi
        ret = nc->info->receive_raw(nc, data, size);
333 893379ef Mark McLoughlin
    } else {
334 35277d14 Stefan Hajnoczi
        ret = nc->info->receive(nc, data, size);
335 893379ef Mark McLoughlin
    }
336 893379ef Mark McLoughlin
337 893379ef Mark McLoughlin
    if (ret == 0) {
338 35277d14 Stefan Hajnoczi
        nc->receive_disabled = 1;
339 893379ef Mark McLoughlin
    };
340 893379ef Mark McLoughlin
341 893379ef Mark McLoughlin
    return ret;
342 9a6ecb30 Mark McLoughlin
}
343 9a6ecb30 Mark McLoughlin
344 35277d14 Stefan Hajnoczi
void qemu_purge_queued_packets(NetClientState *nc)
345 8cad5516 Mark McLoughlin
{
346 35277d14 Stefan Hajnoczi
    if (!nc->peer) {
347 d80b9fc6 Mark McLoughlin
        return;
348 9a6ecb30 Mark McLoughlin
    }
349 d80b9fc6 Mark McLoughlin
350 35277d14 Stefan Hajnoczi
    qemu_net_queue_purge(nc->peer->send_queue, nc);
351 8cad5516 Mark McLoughlin
}
352 8cad5516 Mark McLoughlin
353 35277d14 Stefan Hajnoczi
void qemu_flush_queued_packets(NetClientState *nc)
354 e94667b9 Mark McLoughlin
{
355 35277d14 Stefan Hajnoczi
    nc->receive_disabled = 0;
356 9a6ecb30 Mark McLoughlin
357 987a9b48 Paolo Bonzini
    if (qemu_net_queue_flush(nc->send_queue)) {
358 987a9b48 Paolo Bonzini
        /* We emptied the queue successfully, signal to the IO thread to repoll
359 987a9b48 Paolo Bonzini
         * the file descriptor (for tap, for example).
360 987a9b48 Paolo Bonzini
         */
361 987a9b48 Paolo Bonzini
        qemu_notify_event();
362 987a9b48 Paolo Bonzini
    }
363 e94667b9 Mark McLoughlin
}
364 e94667b9 Mark McLoughlin
365 4e68f7a0 Stefan Hajnoczi
static ssize_t qemu_send_packet_async_with_flags(NetClientState *sender,
366 ca77d175 Mark McLoughlin
                                                 unsigned flags,
367 ca77d175 Mark McLoughlin
                                                 const uint8_t *buf, int size,
368 ca77d175 Mark McLoughlin
                                                 NetPacketSent *sent_cb)
369 764a4d1d aliguori
{
370 9a6ecb30 Mark McLoughlin
    NetQueue *queue;
371 436e5e53 aliguori
372 63a01ef8 aliguori
#ifdef DEBUG_NET
373 d80b9fc6 Mark McLoughlin
    printf("qemu_send_packet_async:\n");
374 63a01ef8 aliguori
    hex_dump(stdout, buf, size);
375 63a01ef8 aliguori
#endif
376 f3b6c7fc Mark McLoughlin
377 a005d073 Stefan Hajnoczi
    if (sender->link_down || !sender->peer) {
378 9a6ecb30 Mark McLoughlin
        return size;
379 9a6ecb30 Mark McLoughlin
    }
380 9a6ecb30 Mark McLoughlin
381 a005d073 Stefan Hajnoczi
    queue = sender->peer->send_queue;
382 9a6ecb30 Mark McLoughlin
383 ca77d175 Mark McLoughlin
    return qemu_net_queue_send(queue, sender, flags, buf, size, sent_cb);
384 ca77d175 Mark McLoughlin
}
385 ca77d175 Mark McLoughlin
386 4e68f7a0 Stefan Hajnoczi
ssize_t qemu_send_packet_async(NetClientState *sender,
387 ca77d175 Mark McLoughlin
                               const uint8_t *buf, int size,
388 ca77d175 Mark McLoughlin
                               NetPacketSent *sent_cb)
389 ca77d175 Mark McLoughlin
{
390 ca77d175 Mark McLoughlin
    return qemu_send_packet_async_with_flags(sender, QEMU_NET_PACKET_FLAG_NONE,
391 ca77d175 Mark McLoughlin
                                             buf, size, sent_cb);
392 f3b6c7fc Mark McLoughlin
}
393 f3b6c7fc Mark McLoughlin
394 35277d14 Stefan Hajnoczi
void qemu_send_packet(NetClientState *nc, const uint8_t *buf, int size)
395 f3b6c7fc Mark McLoughlin
{
396 35277d14 Stefan Hajnoczi
    qemu_send_packet_async(nc, buf, size, NULL);
397 63a01ef8 aliguori
}
398 63a01ef8 aliguori
399 35277d14 Stefan Hajnoczi
ssize_t qemu_send_packet_raw(NetClientState *nc, const uint8_t *buf, int size)
400 ca77d175 Mark McLoughlin
{
401 35277d14 Stefan Hajnoczi
    return qemu_send_packet_async_with_flags(nc, QEMU_NET_PACKET_FLAG_RAW,
402 ca77d175 Mark McLoughlin
                                             buf, size, NULL);
403 ca77d175 Mark McLoughlin
}
404 ca77d175 Mark McLoughlin
405 35277d14 Stefan Hajnoczi
static ssize_t nc_sendv_compat(NetClientState *nc, const struct iovec *iov,
406 fbe78f4f aliguori
                               int iovcnt)
407 fbe78f4f aliguori
{
408 fbe78f4f aliguori
    uint8_t buffer[4096];
409 ce053661 Benjamin Poirier
    size_t offset;
410 fbe78f4f aliguori
411 dcf6f5e1 Michael Tokarev
    offset = iov_to_buf(iov, iovcnt, 0, buffer, sizeof(buffer));
412 fbe78f4f aliguori
413 35277d14 Stefan Hajnoczi
    return nc->info->receive(nc, buffer, offset);
414 fbe78f4f aliguori
}
415 fbe78f4f aliguori
416 86a77c38 Zhi Yong Wu
ssize_t qemu_deliver_packet_iov(NetClientState *sender,
417 86a77c38 Zhi Yong Wu
                                unsigned flags,
418 86a77c38 Zhi Yong Wu
                                const struct iovec *iov,
419 86a77c38 Zhi Yong Wu
                                int iovcnt,
420 86a77c38 Zhi Yong Wu
                                void *opaque)
421 9a6ecb30 Mark McLoughlin
{
422 35277d14 Stefan Hajnoczi
    NetClientState *nc = opaque;
423 c67f5dc1 Stefan Hajnoczi
    int ret;
424 9a6ecb30 Mark McLoughlin
425 35277d14 Stefan Hajnoczi
    if (nc->link_down) {
426 ce053661 Benjamin Poirier
        return iov_size(iov, iovcnt);
427 9a6ecb30 Mark McLoughlin
    }
428 9a6ecb30 Mark McLoughlin
429 c67f5dc1 Stefan Hajnoczi
    if (nc->receive_disabled) {
430 c67f5dc1 Stefan Hajnoczi
        return 0;
431 c67f5dc1 Stefan Hajnoczi
    }
432 c67f5dc1 Stefan Hajnoczi
433 35277d14 Stefan Hajnoczi
    if (nc->info->receive_iov) {
434 c67f5dc1 Stefan Hajnoczi
        ret = nc->info->receive_iov(nc, iov, iovcnt);
435 9a6ecb30 Mark McLoughlin
    } else {
436 c67f5dc1 Stefan Hajnoczi
        ret = nc_sendv_compat(nc, iov, iovcnt);
437 c67f5dc1 Stefan Hajnoczi
    }
438 c67f5dc1 Stefan Hajnoczi
439 c67f5dc1 Stefan Hajnoczi
    if (ret == 0) {
440 c67f5dc1 Stefan Hajnoczi
        nc->receive_disabled = 1;
441 e94667b9 Mark McLoughlin
    }
442 c67f5dc1 Stefan Hajnoczi
443 c67f5dc1 Stefan Hajnoczi
    return ret;
444 e94667b9 Mark McLoughlin
}
445 e94667b9 Mark McLoughlin
446 4e68f7a0 Stefan Hajnoczi
ssize_t qemu_sendv_packet_async(NetClientState *sender,
447 f3b6c7fc Mark McLoughlin
                                const struct iovec *iov, int iovcnt,
448 f3b6c7fc Mark McLoughlin
                                NetPacketSent *sent_cb)
449 e94667b9 Mark McLoughlin
{
450 9a6ecb30 Mark McLoughlin
    NetQueue *queue;
451 9a6ecb30 Mark McLoughlin
452 a005d073 Stefan Hajnoczi
    if (sender->link_down || !sender->peer) {
453 ce053661 Benjamin Poirier
        return iov_size(iov, iovcnt);
454 e94667b9 Mark McLoughlin
    }
455 e94667b9 Mark McLoughlin
456 a005d073 Stefan Hajnoczi
    queue = sender->peer->send_queue;
457 9a6ecb30 Mark McLoughlin
458 c0b8e49c Mark McLoughlin
    return qemu_net_queue_send_iov(queue, sender,
459 c0b8e49c Mark McLoughlin
                                   QEMU_NET_PACKET_FLAG_NONE,
460 c0b8e49c Mark McLoughlin
                                   iov, iovcnt, sent_cb);
461 fbe78f4f aliguori
}
462 fbe78f4f aliguori
463 f3b6c7fc Mark McLoughlin
ssize_t
464 35277d14 Stefan Hajnoczi
qemu_sendv_packet(NetClientState *nc, const struct iovec *iov, int iovcnt)
465 f3b6c7fc Mark McLoughlin
{
466 35277d14 Stefan Hajnoczi
    return qemu_sendv_packet_async(nc, iov, iovcnt, NULL);
467 63a01ef8 aliguori
}
468 63a01ef8 aliguori
469 4e68f7a0 Stefan Hajnoczi
NetClientState *qemu_find_netdev(const char *id)
470 5869c4d5 Mark McLoughlin
{
471 35277d14 Stefan Hajnoczi
    NetClientState *nc;
472 5869c4d5 Mark McLoughlin
473 35277d14 Stefan Hajnoczi
    QTAILQ_FOREACH(nc, &net_clients, next) {
474 35277d14 Stefan Hajnoczi
        if (nc->info->type == NET_CLIENT_OPTIONS_KIND_NIC)
475 85dde9a9 Markus Armbruster
            continue;
476 35277d14 Stefan Hajnoczi
        if (!strcmp(nc->name, id)) {
477 35277d14 Stefan Hajnoczi
            return nc;
478 5869c4d5 Mark McLoughlin
        }
479 5869c4d5 Mark McLoughlin
    }
480 5869c4d5 Mark McLoughlin
481 5869c4d5 Mark McLoughlin
    return NULL;
482 5869c4d5 Mark McLoughlin
}
483 5869c4d5 Mark McLoughlin
484 7697079b aliguori
static int nic_get_free_idx(void)
485 7697079b aliguori
{
486 7697079b aliguori
    int index;
487 7697079b aliguori
488 7697079b aliguori
    for (index = 0; index < MAX_NICS; index++)
489 7697079b aliguori
        if (!nd_table[index].used)
490 7697079b aliguori
            return index;
491 7697079b aliguori
    return -1;
492 7697079b aliguori
}
493 7697079b aliguori
494 07caea31 Markus Armbruster
int qemu_show_nic_models(const char *arg, const char *const *models)
495 07caea31 Markus Armbruster
{
496 07caea31 Markus Armbruster
    int i;
497 07caea31 Markus Armbruster
498 c8057f95 Peter Maydell
    if (!arg || !is_help_option(arg)) {
499 07caea31 Markus Armbruster
        return 0;
500 c8057f95 Peter Maydell
    }
501 07caea31 Markus Armbruster
502 07caea31 Markus Armbruster
    fprintf(stderr, "qemu: Supported NIC models: ");
503 07caea31 Markus Armbruster
    for (i = 0 ; models[i]; i++)
504 07caea31 Markus Armbruster
        fprintf(stderr, "%s%c", models[i], models[i+1] ? ',' : '\n');
505 07caea31 Markus Armbruster
    return 1;
506 07caea31 Markus Armbruster
}
507 07caea31 Markus Armbruster
508 d07f22c5 aliguori
void qemu_check_nic_model(NICInfo *nd, const char *model)
509 d07f22c5 aliguori
{
510 d07f22c5 aliguori
    const char *models[2];
511 d07f22c5 aliguori
512 d07f22c5 aliguori
    models[0] = model;
513 d07f22c5 aliguori
    models[1] = NULL;
514 d07f22c5 aliguori
515 07caea31 Markus Armbruster
    if (qemu_show_nic_models(nd->model, models))
516 07caea31 Markus Armbruster
        exit(0);
517 07caea31 Markus Armbruster
    if (qemu_find_nic_model(nd, models, model) < 0)
518 07caea31 Markus Armbruster
        exit(1);
519 d07f22c5 aliguori
}
520 d07f22c5 aliguori
521 07caea31 Markus Armbruster
int qemu_find_nic_model(NICInfo *nd, const char * const *models,
522 07caea31 Markus Armbruster
                        const char *default_model)
523 d07f22c5 aliguori
{
524 07caea31 Markus Armbruster
    int i;
525 d07f22c5 aliguori
526 d07f22c5 aliguori
    if (!nd->model)
527 7267c094 Anthony Liguori
        nd->model = g_strdup(default_model);
528 d07f22c5 aliguori
529 07caea31 Markus Armbruster
    for (i = 0 ; models[i]; i++) {
530 07caea31 Markus Armbruster
        if (strcmp(nd->model, models[i]) == 0)
531 07caea31 Markus Armbruster
            return i;
532 d07f22c5 aliguori
    }
533 d07f22c5 aliguori
534 6daf194d Markus Armbruster
    error_report("Unsupported NIC model: %s", nd->model);
535 07caea31 Markus Armbruster
    return -1;
536 d07f22c5 aliguori
}
537 d07f22c5 aliguori
538 1a0c0958 Laszlo Ersek
static int net_init_nic(const NetClientOptions *opts, const char *name,
539 4e68f7a0 Stefan Hajnoczi
                        NetClientState *peer)
540 f83c6e10 Mark McLoughlin
{
541 f83c6e10 Mark McLoughlin
    int idx;
542 f83c6e10 Mark McLoughlin
    NICInfo *nd;
543 2456f36f Laszlo Ersek
    const NetLegacyNicOptions *nic;
544 2456f36f Laszlo Ersek
545 2456f36f Laszlo Ersek
    assert(opts->kind == NET_CLIENT_OPTIONS_KIND_NIC);
546 2456f36f Laszlo Ersek
    nic = opts->nic;
547 f83c6e10 Mark McLoughlin
548 f83c6e10 Mark McLoughlin
    idx = nic_get_free_idx();
549 f83c6e10 Mark McLoughlin
    if (idx == -1 || nb_nics >= MAX_NICS) {
550 1ecda02b Markus Armbruster
        error_report("Too Many NICs");
551 f83c6e10 Mark McLoughlin
        return -1;
552 f83c6e10 Mark McLoughlin
    }
553 f83c6e10 Mark McLoughlin
554 f83c6e10 Mark McLoughlin
    nd = &nd_table[idx];
555 f83c6e10 Mark McLoughlin
556 f83c6e10 Mark McLoughlin
    memset(nd, 0, sizeof(*nd));
557 f83c6e10 Mark McLoughlin
558 2456f36f Laszlo Ersek
    if (nic->has_netdev) {
559 2456f36f Laszlo Ersek
        nd->netdev = qemu_find_netdev(nic->netdev);
560 5869c4d5 Mark McLoughlin
        if (!nd->netdev) {
561 2456f36f Laszlo Ersek
            error_report("netdev '%s' not found", nic->netdev);
562 5869c4d5 Mark McLoughlin
            return -1;
563 5869c4d5 Mark McLoughlin
        }
564 5869c4d5 Mark McLoughlin
    } else {
565 d33d93b2 Stefan Hajnoczi
        assert(peer);
566 d33d93b2 Stefan Hajnoczi
        nd->netdev = peer;
567 5869c4d5 Mark McLoughlin
    }
568 6d952ebe Mark McLoughlin
    if (name) {
569 7267c094 Anthony Liguori
        nd->name = g_strdup(name);
570 6d952ebe Mark McLoughlin
    }
571 2456f36f Laszlo Ersek
    if (nic->has_model) {
572 2456f36f Laszlo Ersek
        nd->model = g_strdup(nic->model);
573 f83c6e10 Mark McLoughlin
    }
574 2456f36f Laszlo Ersek
    if (nic->has_addr) {
575 2456f36f Laszlo Ersek
        nd->devaddr = g_strdup(nic->addr);
576 f83c6e10 Mark McLoughlin
    }
577 f83c6e10 Mark McLoughlin
578 2456f36f Laszlo Ersek
    if (nic->has_macaddr &&
579 2456f36f Laszlo Ersek
        net_parse_macaddr(nd->macaddr.a, nic->macaddr) < 0) {
580 1ecda02b Markus Armbruster
        error_report("invalid syntax for ethernet address");
581 f83c6e10 Mark McLoughlin
        return -1;
582 f83c6e10 Mark McLoughlin
    }
583 6eed1856 Jan Kiszka
    qemu_macaddr_default_if_unset(&nd->macaddr);
584 f83c6e10 Mark McLoughlin
585 2456f36f Laszlo Ersek
    if (nic->has_vectors) {
586 2456f36f Laszlo Ersek
        if (nic->vectors > 0x7ffffff) {
587 2456f36f Laszlo Ersek
            error_report("invalid # of vectors: %"PRIu32, nic->vectors);
588 2456f36f Laszlo Ersek
            return -1;
589 2456f36f Laszlo Ersek
        }
590 2456f36f Laszlo Ersek
        nd->nvectors = nic->vectors;
591 2456f36f Laszlo Ersek
    } else {
592 2456f36f Laszlo Ersek
        nd->nvectors = DEV_NVECTORS_UNSPECIFIED;
593 f83c6e10 Mark McLoughlin
    }
594 f83c6e10 Mark McLoughlin
595 f83c6e10 Mark McLoughlin
    nd->used = 1;
596 f83c6e10 Mark McLoughlin
    nb_nics++;
597 f83c6e10 Mark McLoughlin
598 f83c6e10 Mark McLoughlin
    return idx;
599 f83c6e10 Mark McLoughlin
}
600 f83c6e10 Mark McLoughlin
601 6687b79d Laszlo Ersek
602 6687b79d Laszlo Ersek
static int (* const net_client_init_fun[NET_CLIENT_OPTIONS_KIND_MAX])(
603 1a0c0958 Laszlo Ersek
    const NetClientOptions *opts,
604 6687b79d Laszlo Ersek
    const char *name,
605 4e68f7a0 Stefan Hajnoczi
    NetClientState *peer) = {
606 f6c874e3 Stefan Hajnoczi
        [NET_CLIENT_OPTIONS_KIND_NIC]       = net_init_nic,
607 ec302ffd Mark McLoughlin
#ifdef CONFIG_SLIRP
608 f6c874e3 Stefan Hajnoczi
        [NET_CLIENT_OPTIONS_KIND_USER]      = net_init_slirp,
609 2944e4ec Stefan Weil
#endif
610 f6c874e3 Stefan Hajnoczi
        [NET_CLIENT_OPTIONS_KIND_TAP]       = net_init_tap,
611 f6c874e3 Stefan Hajnoczi
        [NET_CLIENT_OPTIONS_KIND_SOCKET]    = net_init_socket,
612 dd51058d Mark McLoughlin
#ifdef CONFIG_VDE
613 f6c874e3 Stefan Hajnoczi
        [NET_CLIENT_OPTIONS_KIND_VDE]       = net_init_vde,
614 dd51058d Mark McLoughlin
#endif
615 f6c874e3 Stefan Hajnoczi
        [NET_CLIENT_OPTIONS_KIND_DUMP]      = net_init_dump,
616 2944e4ec Stefan Weil
#ifdef CONFIG_NET_BRIDGE
617 f6c874e3 Stefan Hajnoczi
        [NET_CLIENT_OPTIONS_KIND_BRIDGE]    = net_init_bridge,
618 6687b79d Laszlo Ersek
#endif
619 f6c874e3 Stefan Hajnoczi
        [NET_CLIENT_OPTIONS_KIND_HUBPORT]   = net_init_hubport,
620 f83c6e10 Mark McLoughlin
};
621 f83c6e10 Mark McLoughlin
622 6687b79d Laszlo Ersek
623 1a0c0958 Laszlo Ersek
static int net_client_init1(const void *object, int is_netdev, Error **errp)
624 f83c6e10 Mark McLoughlin
{
625 6687b79d Laszlo Ersek
    union {
626 6687b79d Laszlo Ersek
        const Netdev    *netdev;
627 6687b79d Laszlo Ersek
        const NetLegacy *net;
628 6687b79d Laszlo Ersek
    } u;
629 6687b79d Laszlo Ersek
    const NetClientOptions *opts;
630 6d952ebe Mark McLoughlin
    const char *name;
631 f83c6e10 Mark McLoughlin
632 5294e2c7 Markus Armbruster
    if (is_netdev) {
633 6687b79d Laszlo Ersek
        u.netdev = object;
634 6687b79d Laszlo Ersek
        opts = u.netdev->opts;
635 6687b79d Laszlo Ersek
        name = u.netdev->id;
636 6687b79d Laszlo Ersek
637 6687b79d Laszlo Ersek
        switch (opts->kind) {
638 f6b134ac Mark McLoughlin
#ifdef CONFIG_SLIRP
639 6687b79d Laszlo Ersek
        case NET_CLIENT_OPTIONS_KIND_USER:
640 f6b134ac Mark McLoughlin
#endif
641 6687b79d Laszlo Ersek
        case NET_CLIENT_OPTIONS_KIND_TAP:
642 6687b79d Laszlo Ersek
        case NET_CLIENT_OPTIONS_KIND_SOCKET:
643 f6b134ac Mark McLoughlin
#ifdef CONFIG_VDE
644 6687b79d Laszlo Ersek
        case NET_CLIENT_OPTIONS_KIND_VDE:
645 6687b79d Laszlo Ersek
#endif
646 6687b79d Laszlo Ersek
#ifdef CONFIG_NET_BRIDGE
647 6687b79d Laszlo Ersek
        case NET_CLIENT_OPTIONS_KIND_BRIDGE:
648 f6b134ac Mark McLoughlin
#endif
649 f6c874e3 Stefan Hajnoczi
        case NET_CLIENT_OPTIONS_KIND_HUBPORT:
650 6687b79d Laszlo Ersek
            break;
651 6687b79d Laszlo Ersek
652 6687b79d Laszlo Ersek
        default:
653 4559a1db Luiz Capitulino
            error_set(errp, QERR_INVALID_PARAMETER_VALUE, "type",
654 4559a1db Luiz Capitulino
                      "a netdev backend type");
655 f6b134ac Mark McLoughlin
            return -1;
656 f6b134ac Mark McLoughlin
        }
657 6687b79d Laszlo Ersek
    } else {
658 6687b79d Laszlo Ersek
        u.net = object;
659 6687b79d Laszlo Ersek
        opts = u.net->opts;
660 6687b79d Laszlo Ersek
        /* missing optional values have been initialized to "all bits zero" */
661 6687b79d Laszlo Ersek
        name = u.net->has_id ? u.net->id : u.net->name;
662 6687b79d Laszlo Ersek
    }
663 f6b134ac Mark McLoughlin
664 6687b79d Laszlo Ersek
    if (net_client_init_fun[opts->kind]) {
665 4e68f7a0 Stefan Hajnoczi
        NetClientState *peer = NULL;
666 6687b79d Laszlo Ersek
667 6687b79d Laszlo Ersek
        /* Do not add to a vlan if it's a -netdev or a nic with a netdev=
668 6687b79d Laszlo Ersek
         * parameter. */
669 6687b79d Laszlo Ersek
        if (!is_netdev &&
670 6687b79d Laszlo Ersek
            (opts->kind != NET_CLIENT_OPTIONS_KIND_NIC ||
671 6687b79d Laszlo Ersek
             !opts->nic->has_netdev)) {
672 d33d93b2 Stefan Hajnoczi
            peer = net_hub_add_port(u.net->has_vlan ? u.net->vlan : 0, NULL);
673 f6b134ac Mark McLoughlin
        }
674 6687b79d Laszlo Ersek
675 d33d93b2 Stefan Hajnoczi
        if (net_client_init_fun[opts->kind](opts, name, peer) < 0) {
676 6687b79d Laszlo Ersek
            /* TODO push error reporting into init() methods */
677 6687b79d Laszlo Ersek
            error_set(errp, QERR_DEVICE_INIT_FAILED,
678 6687b79d Laszlo Ersek
                      NetClientOptionsKind_lookup[opts->kind]);
679 f6b134ac Mark McLoughlin
            return -1;
680 f6b134ac Mark McLoughlin
        }
681 f6b134ac Mark McLoughlin
    }
682 6687b79d Laszlo Ersek
    return 0;
683 6687b79d Laszlo Ersek
}
684 6687b79d Laszlo Ersek
685 f6b134ac Mark McLoughlin
686 6687b79d Laszlo Ersek
static void net_visit(Visitor *v, int is_netdev, void **object, Error **errp)
687 6687b79d Laszlo Ersek
{
688 6687b79d Laszlo Ersek
    if (is_netdev) {
689 6687b79d Laszlo Ersek
        visit_type_Netdev(v, (Netdev **)object, NULL, errp);
690 6687b79d Laszlo Ersek
    } else {
691 6687b79d Laszlo Ersek
        visit_type_NetLegacy(v, (NetLegacy **)object, NULL, errp);
692 6d952ebe Mark McLoughlin
    }
693 6687b79d Laszlo Ersek
}
694 6d952ebe Mark McLoughlin
695 f6b134ac Mark McLoughlin
696 6687b79d Laszlo Ersek
int net_client_init(QemuOpts *opts, int is_netdev, Error **errp)
697 6687b79d Laszlo Ersek
{
698 6687b79d Laszlo Ersek
    void *object = NULL;
699 6687b79d Laszlo Ersek
    Error *err = NULL;
700 6687b79d Laszlo Ersek
    int ret = -1;
701 f83c6e10 Mark McLoughlin
702 6687b79d Laszlo Ersek
    {
703 6687b79d Laszlo Ersek
        OptsVisitor *ov = opts_visitor_new(opts);
704 f6b134ac Mark McLoughlin
705 6687b79d Laszlo Ersek
        net_visit(opts_get_visitor(ov), is_netdev, &object, &err);
706 6687b79d Laszlo Ersek
        opts_visitor_cleanup(ov);
707 f83c6e10 Mark McLoughlin
    }
708 f83c6e10 Mark McLoughlin
709 6687b79d Laszlo Ersek
    if (!err) {
710 1a0c0958 Laszlo Ersek
        ret = net_client_init1(object, is_netdev, &err);
711 6687b79d Laszlo Ersek
    }
712 6687b79d Laszlo Ersek
713 6687b79d Laszlo Ersek
    if (object) {
714 6687b79d Laszlo Ersek
        QapiDeallocVisitor *dv = qapi_dealloc_visitor_new();
715 6687b79d Laszlo Ersek
716 6687b79d Laszlo Ersek
        net_visit(qapi_dealloc_get_visitor(dv), is_netdev, &object, NULL);
717 6687b79d Laszlo Ersek
        qapi_dealloc_visitor_cleanup(dv);
718 6687b79d Laszlo Ersek
    }
719 6687b79d Laszlo Ersek
720 6687b79d Laszlo Ersek
    error_propagate(errp, err);
721 6687b79d Laszlo Ersek
    return ret;
722 f83c6e10 Mark McLoughlin
}
723 f83c6e10 Mark McLoughlin
724 6687b79d Laszlo Ersek
725 6f338c34 aliguori
static int net_host_check_device(const char *device)
726 6f338c34 aliguori
{
727 6f338c34 aliguori
    int i;
728 bb9ea79e aliguori
    const char *valid_param_list[] = { "tap", "socket", "dump"
729 2944e4ec Stefan Weil
#ifdef CONFIG_NET_BRIDGE
730 2944e4ec Stefan Weil
                                       , "bridge"
731 2944e4ec Stefan Weil
#endif
732 6f338c34 aliguori
#ifdef CONFIG_SLIRP
733 6f338c34 aliguori
                                       ,"user"
734 6f338c34 aliguori
#endif
735 6f338c34 aliguori
#ifdef CONFIG_VDE
736 6f338c34 aliguori
                                       ,"vde"
737 6f338c34 aliguori
#endif
738 6f338c34 aliguori
    };
739 6f338c34 aliguori
    for (i = 0; i < sizeof(valid_param_list) / sizeof(char *); i++) {
740 6f338c34 aliguori
        if (!strncmp(valid_param_list[i], device,
741 6f338c34 aliguori
                     strlen(valid_param_list[i])))
742 6f338c34 aliguori
            return 1;
743 6f338c34 aliguori
    }
744 6f338c34 aliguori
745 6f338c34 aliguori
    return 0;
746 6f338c34 aliguori
}
747 6f338c34 aliguori
748 f18c16de Luiz Capitulino
void net_host_device_add(Monitor *mon, const QDict *qdict)
749 6f338c34 aliguori
{
750 f18c16de Luiz Capitulino
    const char *device = qdict_get_str(qdict, "device");
751 7f1c9d20 Mark McLoughlin
    const char *opts_str = qdict_get_try_str(qdict, "opts");
752 4559a1db Luiz Capitulino
    Error *local_err = NULL;
753 7f1c9d20 Mark McLoughlin
    QemuOpts *opts;
754 f18c16de Luiz Capitulino
755 6f338c34 aliguori
    if (!net_host_check_device(device)) {
756 376253ec aliguori
        monitor_printf(mon, "invalid host network device %s\n", device);
757 6f338c34 aliguori
        return;
758 6f338c34 aliguori
    }
759 7f1c9d20 Mark McLoughlin
760 3329f07b Gerd Hoffmann
    opts = qemu_opts_parse(qemu_find_opts("net"), opts_str ? opts_str : "", 0);
761 7f1c9d20 Mark McLoughlin
    if (!opts) {
762 7f1c9d20 Mark McLoughlin
        return;
763 7f1c9d20 Mark McLoughlin
    }
764 7f1c9d20 Mark McLoughlin
765 7f1c9d20 Mark McLoughlin
    qemu_opt_set(opts, "type", device);
766 7f1c9d20 Mark McLoughlin
767 4559a1db Luiz Capitulino
    net_client_init(opts, 0, &local_err);
768 4559a1db Luiz Capitulino
    if (error_is_set(&local_err)) {
769 4559a1db Luiz Capitulino
        qerror_report_err(local_err);
770 4559a1db Luiz Capitulino
        error_free(local_err);
771 5c8be678 aliguori
        monitor_printf(mon, "adding host network device %s failed\n", device);
772 5c8be678 aliguori
    }
773 6f338c34 aliguori
}
774 6f338c34 aliguori
775 f18c16de Luiz Capitulino
void net_host_device_remove(Monitor *mon, const QDict *qdict)
776 6f338c34 aliguori
{
777 35277d14 Stefan Hajnoczi
    NetClientState *nc;
778 f18c16de Luiz Capitulino
    int vlan_id = qdict_get_int(qdict, "vlan_id");
779 f18c16de Luiz Capitulino
    const char *device = qdict_get_str(qdict, "device");
780 6f338c34 aliguori
781 35277d14 Stefan Hajnoczi
    nc = net_hub_find_client_by_name(vlan_id, device);
782 35277d14 Stefan Hajnoczi
    if (!nc) {
783 6f338c34 aliguori
        return;
784 6f338c34 aliguori
    }
785 35277d14 Stefan Hajnoczi
    if (!net_host_check_device(nc->model)) {
786 e8f1f9db aliguori
        monitor_printf(mon, "invalid host network device %s\n", device);
787 e8f1f9db aliguori
        return;
788 e8f1f9db aliguori
    }
789 b20c6b9e Stefan Hajnoczi
    qemu_del_net_client(nc);
790 6f338c34 aliguori
}
791 6f338c34 aliguori
792 928059a3 Luiz Capitulino
void netdev_add(QemuOpts *opts, Error **errp)
793 928059a3 Luiz Capitulino
{
794 928059a3 Luiz Capitulino
    net_client_init(opts, 1, errp);
795 928059a3 Luiz Capitulino
}
796 928059a3 Luiz Capitulino
797 928059a3 Luiz Capitulino
int qmp_netdev_add(Monitor *mon, const QDict *qdict, QObject **ret)
798 ae82d324 Markus Armbruster
{
799 4e89978e Luiz Capitulino
    Error *local_err = NULL;
800 928059a3 Luiz Capitulino
    QemuOptsList *opts_list;
801 ae82d324 Markus Armbruster
    QemuOpts *opts;
802 ae82d324 Markus Armbruster
803 928059a3 Luiz Capitulino
    opts_list = qemu_find_opts_err("netdev", &local_err);
804 928059a3 Luiz Capitulino
    if (error_is_set(&local_err)) {
805 928059a3 Luiz Capitulino
        goto exit_err;
806 ae82d324 Markus Armbruster
    }
807 ae82d324 Markus Armbruster
808 928059a3 Luiz Capitulino
    opts = qemu_opts_from_qdict(opts_list, qdict, &local_err);
809 928059a3 Luiz Capitulino
    if (error_is_set(&local_err)) {
810 928059a3 Luiz Capitulino
        goto exit_err;
811 928059a3 Luiz Capitulino
    }
812 928059a3 Luiz Capitulino
813 928059a3 Luiz Capitulino
    netdev_add(opts, &local_err);
814 928059a3 Luiz Capitulino
    if (error_is_set(&local_err)) {
815 410cbafe Yoshiaki Tamura
        qemu_opts_del(opts);
816 928059a3 Luiz Capitulino
        goto exit_err;
817 410cbafe Yoshiaki Tamura
    }
818 410cbafe Yoshiaki Tamura
819 928059a3 Luiz Capitulino
    return 0;
820 928059a3 Luiz Capitulino
821 928059a3 Luiz Capitulino
exit_err:
822 928059a3 Luiz Capitulino
    qerror_report_err(local_err);
823 928059a3 Luiz Capitulino
    error_free(local_err);
824 928059a3 Luiz Capitulino
    return -1;
825 ae82d324 Markus Armbruster
}
826 ae82d324 Markus Armbruster
827 5f964155 Luiz Capitulino
void qmp_netdev_del(const char *id, Error **errp)
828 ae82d324 Markus Armbruster
{
829 35277d14 Stefan Hajnoczi
    NetClientState *nc;
830 645c9496 Stefan Hajnoczi
    QemuOpts *opts;
831 ae82d324 Markus Armbruster
832 35277d14 Stefan Hajnoczi
    nc = qemu_find_netdev(id);
833 35277d14 Stefan Hajnoczi
    if (!nc) {
834 5f964155 Luiz Capitulino
        error_set(errp, QERR_DEVICE_NOT_FOUND, id);
835 5f964155 Luiz Capitulino
        return;
836 ae82d324 Markus Armbruster
    }
837 5f964155 Luiz Capitulino
838 645c9496 Stefan Hajnoczi
    opts = qemu_opts_find(qemu_find_opts_err("netdev", NULL), id);
839 645c9496 Stefan Hajnoczi
    if (!opts) {
840 645c9496 Stefan Hajnoczi
        error_setg(errp, "Device '%s' is not a netdev", id);
841 645c9496 Stefan Hajnoczi
        return;
842 645c9496 Stefan Hajnoczi
    }
843 645c9496 Stefan Hajnoczi
844 b20c6b9e Stefan Hajnoczi
    qemu_del_net_client(nc);
845 645c9496 Stefan Hajnoczi
    qemu_opts_del(opts);
846 ae82d324 Markus Armbruster
}
847 ae82d324 Markus Armbruster
848 1a859593 Zhi Yong Wu
void print_net_client(Monitor *mon, NetClientState *nc)
849 44e798d3 Jan Kiszka
{
850 35277d14 Stefan Hajnoczi
    monitor_printf(mon, "%s: type=%s,%s\n", nc->name,
851 35277d14 Stefan Hajnoczi
                   NetClientOptionsKind_lookup[nc->info->type], nc->info_str);
852 44e798d3 Jan Kiszka
}
853 44e798d3 Jan Kiszka
854 376253ec aliguori
void do_info_network(Monitor *mon)
855 63a01ef8 aliguori
{
856 35277d14 Stefan Hajnoczi
    NetClientState *nc, *peer;
857 2be64a68 Laszlo Ersek
    NetClientOptionsKind type;
858 63a01ef8 aliguori
859 1a859593 Zhi Yong Wu
    net_hub_info(mon);
860 1a859593 Zhi Yong Wu
861 35277d14 Stefan Hajnoczi
    QTAILQ_FOREACH(nc, &net_clients, next) {
862 35277d14 Stefan Hajnoczi
        peer = nc->peer;
863 35277d14 Stefan Hajnoczi
        type = nc->info->type;
864 5610c3aa Mark McLoughlin
865 1a859593 Zhi Yong Wu
        /* Skip if already printed in hub info */
866 1a859593 Zhi Yong Wu
        if (net_hub_id_for_client(nc, NULL) == 0) {
867 1a859593 Zhi Yong Wu
            continue;
868 5610c3aa Mark McLoughlin
        }
869 1a859593 Zhi Yong Wu
870 2be64a68 Laszlo Ersek
        if (!peer || type == NET_CLIENT_OPTIONS_KIND_NIC) {
871 35277d14 Stefan Hajnoczi
            print_net_client(mon, nc);
872 19061e63 Jan Kiszka
        } /* else it's a netdev connected to a NIC, printed with the NIC */
873 2be64a68 Laszlo Ersek
        if (peer && type == NET_CLIENT_OPTIONS_KIND_NIC) {
874 1a859593 Zhi Yong Wu
            monitor_printf(mon, " \\ ");
875 44e798d3 Jan Kiszka
            print_net_client(mon, peer);
876 a0104e0e Markus Armbruster
        }
877 a0104e0e Markus Armbruster
    }
878 63a01ef8 aliguori
}
879 63a01ef8 aliguori
880 4b37156c Luiz Capitulino
void qmp_set_link(const char *name, bool up, Error **errp)
881 436e5e53 aliguori
{
882 35277d14 Stefan Hajnoczi
    NetClientState *nc = NULL;
883 436e5e53 aliguori
884 35277d14 Stefan Hajnoczi
    QTAILQ_FOREACH(nc, &net_clients, next) {
885 35277d14 Stefan Hajnoczi
        if (!strcmp(nc->name, name)) {
886 85dde9a9 Markus Armbruster
            goto done;
887 85dde9a9 Markus Armbruster
        }
888 85dde9a9 Markus Armbruster
    }
889 dd5de373 edgar_igl
done:
890 35277d14 Stefan Hajnoczi
    if (!nc) {
891 4b37156c Luiz Capitulino
        error_set(errp, QERR_DEVICE_NOT_FOUND, name);
892 4b37156c Luiz Capitulino
        return;
893 436e5e53 aliguori
    }
894 436e5e53 aliguori
895 35277d14 Stefan Hajnoczi
    nc->link_down = !up;
896 436e5e53 aliguori
897 35277d14 Stefan Hajnoczi
    if (nc->info->link_status_changed) {
898 35277d14 Stefan Hajnoczi
        nc->info->link_status_changed(nc);
899 665a3b07 Mark McLoughlin
    }
900 ab1cbe1c Michael S. Tsirkin
901 ab1cbe1c Michael S. Tsirkin
    /* Notify peer. Don't update peer link status: this makes it possible to
902 ab1cbe1c Michael S. Tsirkin
     * disconnect from host network without notifying the guest.
903 ab1cbe1c Michael S. Tsirkin
     * FIXME: is disconnected link status change operation useful?
904 ab1cbe1c Michael S. Tsirkin
     *
905 ab1cbe1c Michael S. Tsirkin
     * Current behaviour is compatible with qemu vlans where there could be
906 ab1cbe1c Michael S. Tsirkin
     * multiple clients that can still communicate with each other in
907 ab1cbe1c Michael S. Tsirkin
     * disconnected mode. For now maintain this compatibility. */
908 35277d14 Stefan Hajnoczi
    if (nc->peer && nc->peer->info->link_status_changed) {
909 35277d14 Stefan Hajnoczi
        nc->peer->info->link_status_changed(nc->peer);
910 ab1cbe1c Michael S. Tsirkin
    }
911 436e5e53 aliguori
}
912 436e5e53 aliguori
913 63a01ef8 aliguori
void net_cleanup(void)
914 63a01ef8 aliguori
{
915 35277d14 Stefan Hajnoczi
    NetClientState *nc, *next_vc;
916 577c4af9 Mark McLoughlin
917 35277d14 Stefan Hajnoczi
    QTAILQ_FOREACH_SAFE(nc, &net_clients, next, next_vc) {
918 b20c6b9e Stefan Hajnoczi
        qemu_del_net_client(nc);
919 577c4af9 Mark McLoughlin
    }
920 63a01ef8 aliguori
}
921 63a01ef8 aliguori
922 668680f7 Markus Armbruster
void net_check_clients(void)
923 63a01ef8 aliguori
{
924 35277d14 Stefan Hajnoczi
    NetClientState *nc;
925 48e2faf2 Peter Maydell
    int i;
926 63a01ef8 aliguori
927 641f6eae Peter Maydell
    /* Don't warn about the default network setup that you get if
928 641f6eae Peter Maydell
     * no command line -net or -netdev options are specified. There
929 641f6eae Peter Maydell
     * are two cases that we would otherwise complain about:
930 641f6eae Peter Maydell
     * (1) board doesn't support a NIC but the implicit "-net nic"
931 641f6eae Peter Maydell
     * requested one
932 641f6eae Peter Maydell
     * (2) CONFIG_SLIRP not set, in which case the implicit "-net nic"
933 641f6eae Peter Maydell
     * sets up a nic that isn't connected to anything.
934 641f6eae Peter Maydell
     */
935 641f6eae Peter Maydell
    if (default_net) {
936 641f6eae Peter Maydell
        return;
937 641f6eae Peter Maydell
    }
938 641f6eae Peter Maydell
939 81017645 Stefan Hajnoczi
    net_hub_check_clients();
940 ac60cc18 Tristan Gingold
941 35277d14 Stefan Hajnoczi
    QTAILQ_FOREACH(nc, &net_clients, next) {
942 35277d14 Stefan Hajnoczi
        if (!nc->peer) {
943 efe32fdd Markus Armbruster
            fprintf(stderr, "Warning: %s %s has no peer\n",
944 35277d14 Stefan Hajnoczi
                    nc->info->type == NET_CLIENT_OPTIONS_KIND_NIC ?
945 35277d14 Stefan Hajnoczi
                    "nic" : "netdev", nc->name);
946 efe32fdd Markus Armbruster
        }
947 efe32fdd Markus Armbruster
    }
948 48e2faf2 Peter Maydell
949 48e2faf2 Peter Maydell
    /* Check that all NICs requested via -net nic actually got created.
950 48e2faf2 Peter Maydell
     * NICs created via -device don't need to be checked here because
951 48e2faf2 Peter Maydell
     * they are always instantiated.
952 48e2faf2 Peter Maydell
     */
953 48e2faf2 Peter Maydell
    for (i = 0; i < MAX_NICS; i++) {
954 48e2faf2 Peter Maydell
        NICInfo *nd = &nd_table[i];
955 48e2faf2 Peter Maydell
        if (nd->used && !nd->instantiated) {
956 48e2faf2 Peter Maydell
            fprintf(stderr, "Warning: requested NIC (%s, model %s) "
957 48e2faf2 Peter Maydell
                    "was not created (not supported by this machine?)\n",
958 48e2faf2 Peter Maydell
                    nd->name ? nd->name : "anonymous",
959 48e2faf2 Peter Maydell
                    nd->model ? nd->model : "unspecified");
960 48e2faf2 Peter Maydell
        }
961 48e2faf2 Peter Maydell
    }
962 63a01ef8 aliguori
}
963 dc1c9fe8 Mark McLoughlin
964 dc1c9fe8 Mark McLoughlin
static int net_init_client(QemuOpts *opts, void *dummy)
965 dc1c9fe8 Mark McLoughlin
{
966 4559a1db Luiz Capitulino
    Error *local_err = NULL;
967 4559a1db Luiz Capitulino
968 4559a1db Luiz Capitulino
    net_client_init(opts, 0, &local_err);
969 4559a1db Luiz Capitulino
    if (error_is_set(&local_err)) {
970 4559a1db Luiz Capitulino
        qerror_report_err(local_err);
971 4559a1db Luiz Capitulino
        error_free(local_err);
972 c1671a08 Mark McLoughlin
        return -1;
973 4559a1db Luiz Capitulino
    }
974 4559a1db Luiz Capitulino
975 c1671a08 Mark McLoughlin
    return 0;
976 f6b134ac Mark McLoughlin
}
977 f6b134ac Mark McLoughlin
978 f6b134ac Mark McLoughlin
static int net_init_netdev(QemuOpts *opts, void *dummy)
979 f6b134ac Mark McLoughlin
{
980 4559a1db Luiz Capitulino
    Error *local_err = NULL;
981 4559a1db Luiz Capitulino
    int ret;
982 4559a1db Luiz Capitulino
983 4559a1db Luiz Capitulino
    ret = net_client_init(opts, 1, &local_err);
984 4559a1db Luiz Capitulino
    if (error_is_set(&local_err)) {
985 4559a1db Luiz Capitulino
        qerror_report_err(local_err);
986 4559a1db Luiz Capitulino
        error_free(local_err);
987 4559a1db Luiz Capitulino
        return -1;
988 4559a1db Luiz Capitulino
    }
989 4559a1db Luiz Capitulino
990 4559a1db Luiz Capitulino
    return ret;
991 dc1c9fe8 Mark McLoughlin
}
992 dc1c9fe8 Mark McLoughlin
993 dc1c9fe8 Mark McLoughlin
int net_init_clients(void)
994 dc1c9fe8 Mark McLoughlin
{
995 3329f07b Gerd Hoffmann
    QemuOptsList *net = qemu_find_opts("net");
996 3329f07b Gerd Hoffmann
997 cb4522cc Gerd Hoffmann
    if (default_net) {
998 dc1c9fe8 Mark McLoughlin
        /* if no clients, we use a default config */
999 3329f07b Gerd Hoffmann
        qemu_opts_set(net, NULL, "type", "nic");
1000 dc1c9fe8 Mark McLoughlin
#ifdef CONFIG_SLIRP
1001 3329f07b Gerd Hoffmann
        qemu_opts_set(net, NULL, "type", "user");
1002 dc1c9fe8 Mark McLoughlin
#endif
1003 dc1c9fe8 Mark McLoughlin
    }
1004 dc1c9fe8 Mark McLoughlin
1005 94878994 Stefan Hajnoczi
    QTAILQ_INIT(&net_clients);
1006 5610c3aa Mark McLoughlin
1007 3329f07b Gerd Hoffmann
    if (qemu_opts_foreach(qemu_find_opts("netdev"), net_init_netdev, NULL, 1) == -1)
1008 f6b134ac Mark McLoughlin
        return -1;
1009 f6b134ac Mark McLoughlin
1010 3329f07b Gerd Hoffmann
    if (qemu_opts_foreach(net, net_init_client, NULL, 1) == -1) {
1011 dc1c9fe8 Mark McLoughlin
        return -1;
1012 dc1c9fe8 Mark McLoughlin
    }
1013 dc1c9fe8 Mark McLoughlin
1014 dc1c9fe8 Mark McLoughlin
    return 0;
1015 dc1c9fe8 Mark McLoughlin
}
1016 dc1c9fe8 Mark McLoughlin
1017 7f161aae Mark McLoughlin
int net_client_parse(QemuOptsList *opts_list, const char *optarg)
1018 dc1c9fe8 Mark McLoughlin
{
1019 a3a766e7 Juan Quintela
#if defined(CONFIG_SLIRP)
1020 68ac40d2 Mark McLoughlin
    int ret;
1021 68ac40d2 Mark McLoughlin
    if (net_slirp_parse_legacy(opts_list, optarg, &ret)) {
1022 dc1c9fe8 Mark McLoughlin
        return ret;
1023 dc1c9fe8 Mark McLoughlin
    }
1024 a3a766e7 Juan Quintela
#endif
1025 68ac40d2 Mark McLoughlin
1026 8212c64f Markus Armbruster
    if (!qemu_opts_parse(opts_list, optarg, 1)) {
1027 dc1c9fe8 Mark McLoughlin
        return -1;
1028 dc1c9fe8 Mark McLoughlin
    }
1029 dc1c9fe8 Mark McLoughlin
1030 cb4522cc Gerd Hoffmann
    default_net = 0;
1031 dc1c9fe8 Mark McLoughlin
    return 0;
1032 dc1c9fe8 Mark McLoughlin
}
1033 7fc8d918 Jason Wang
1034 7fc8d918 Jason Wang
/* From FreeBSD */
1035 7fc8d918 Jason Wang
/* XXX: optimize */
1036 7fc8d918 Jason Wang
unsigned compute_mcast_idx(const uint8_t *ep)
1037 7fc8d918 Jason Wang
{
1038 7fc8d918 Jason Wang
    uint32_t crc;
1039 7fc8d918 Jason Wang
    int carry, i, j;
1040 7fc8d918 Jason Wang
    uint8_t b;
1041 7fc8d918 Jason Wang
1042 7fc8d918 Jason Wang
    crc = 0xffffffff;
1043 7fc8d918 Jason Wang
    for (i = 0; i < 6; i++) {
1044 7fc8d918 Jason Wang
        b = *ep++;
1045 7fc8d918 Jason Wang
        for (j = 0; j < 8; j++) {
1046 7fc8d918 Jason Wang
            carry = ((crc & 0x80000000L) ? 1 : 0) ^ (b & 0x01);
1047 7fc8d918 Jason Wang
            crc <<= 1;
1048 7fc8d918 Jason Wang
            b >>= 1;
1049 7fc8d918 Jason Wang
            if (carry) {
1050 7fc8d918 Jason Wang
                crc = ((crc ^ POLYNOMIAL) | carry);
1051 7fc8d918 Jason Wang
            }
1052 7fc8d918 Jason Wang
        }
1053 7fc8d918 Jason Wang
    }
1054 7fc8d918 Jason Wang
    return crc >> 26;
1055 7fc8d918 Jason Wang
}