net.c

   1 /*
   2  * QEMU System Emulator
   3  *
   4  * Copyright (c) 2003-2008 Fabrice Bellard
   5  *
   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:
  12  *
  13  * The above copyright notice and this permission notice shall be included in
  14  * all copies or substantial portions of the Software.
  15  *
  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
  22  * THE SOFTWARE.
  23  */
  24 #include "net.h"
  25
  26 #include "config-host.h"
  27
  28 #include "net/tap.h"
  29 #include "net/socket.h"
  30 #include "net/dump.h"
  31 #include "net/slirp.h"
  32 #include "net/vde.h"
  33 #include "net/util.h"
  34 #include "monitor.h"
  35 #include "sysemu.h"
  36 #include "qemu-common.h"
  37 #include "qemu_socket.h"
  38 #include "hw/qdev.h"
  39
  40 static QTAILQ_HEAD(, VLANState) vlans;
  41 static QTAILQ_HEAD(, VLANClientState) non_vlan_clients;
  42
  43 int default_net = 1;
  44
  45 /***********************************************************/
  46 /* network device redirectors */
  47
  48 #if defined(DEBUG_NET)
  49 static void hex_dump(FILE *f, const uint8_t *buf, int size)
  50 {
  51     int len, i, j, c;
  52
  53     for(i=0;i<size;i+=16) {
  54         len = size - i;
  55         if (len > 16)
  56             len = 16;
  57         fprintf(f, "%08x ", i);
  58         for(j=0;j<16;j++) {
  59             if (j < len)
  60                 fprintf(f, " %02x", buf[i+j]);
  61             else
  62                 fprintf(f, "   ");
  63         }
  64         fprintf(f, " ");
  65         for(j=0;j<len;j++) {
  66             c = buf[i+j];
  67             if (c < ' ' || c > '~')
  68                 c = '.';
  69             fprintf(f, "%c", c);
  70         }
  71         fprintf(f, "\n");
  72     }
  73 }
  74 #endif
  75
  76 static int get_str_sep(char *buf, int buf_size, const char **pp, int sep)
  77 {
  78     const char *p, *p1;
  79     int len;
  80     p = *pp;
  81     p1 = strchr(p, sep);
  82     if (!p1)
  83         return -1;
  84     len = p1 - p;
  85     p1++;
  86     if (buf_size > 0) {
  87         if (len > buf_size - 1)
  88             len = buf_size - 1;
  89         memcpy(buf, p, len);
  90         buf[len] = '\0';
  91     }
  92     *pp = p1;
  93     return 0;
  94 }
  95
  96 int parse_host_src_port(struct sockaddr_in *haddr,
  97                         struct sockaddr_in *saddr,
  98                         const char *input_str)
  99 {
 100     char *str = qemu_strdup(input_str);
 101     char *host_str = str;
 102     char *src_str;
 103     const char *src_str2;
 104     char *ptr;
 105
 106     /*
 107      * Chop off any extra arguments at the end of the string which
 108      * would start with a comma, then fill in the src port information
 109      * if it was provided else use the "any address" and "any port".
 110      */
 111     if ((ptr = strchr(str,',')))
 112         *ptr = '\0';
 113
 114     if ((src_str = strchr(input_str,'@'))) {
 115         *src_str = '\0';
 116         src_str++;
 117     }
 118
 119     if (parse_host_port(haddr, host_str) < 0)
 120         goto fail;
 121
 122     src_str2 = src_str;
 123     if (!src_str || *src_str == '\0')
 124         src_str2 = ":0";
 125
 126     if (parse_host_port(saddr, src_str2) < 0)
 127         goto fail;
 128
 129     free(str);
 130     return(0);
 131
 132 fail:
 133     free(str);
 134     return -1;
 135 }
 136
 137 int parse_host_port(struct sockaddr_in *saddr, const char *str)
 138 {
 139     char buf[512];
 140     struct hostent *he;
 141     const char *p, *r;
 142     int port;
 143
 144     p = str;
 145     if (get_str_sep(buf, sizeof(buf), &p, ':') < 0)
 146         return -1;
 147     saddr->sin_family = AF_INET;
 148     if (buf[0] == '\0') {
 149         saddr->sin_addr.s_addr = 0;
 150     } else {
 151         if (qemu_isdigit(buf[0])) {
 152             if (!inet_aton(buf, &saddr->sin_addr))
 153                 return -1;
 154         } else {
 155             if ((he = gethostbyname(buf)) == NULL)
 156                 return - 1;
 157             saddr->sin_addr = *(struct in_addr *)he->h_addr;
 158         }
 159     }
 160     port = strtol(p, (char **)&r, 0);
 161     if (r == p)
 162         return -1;
 163     saddr->sin_port = htons(port);
 164     return 0;
 165 }
 166
 167 void qemu_format_nic_info_str(VLANClientState *vc, uint8_t macaddr[6])
 168 {
 169     snprintf(vc->info_str, sizeof(vc->info_str),
 170              "model=%s,macaddr=%02x:%02x:%02x:%02x:%02x:%02x",
 171              vc->model,
 172              macaddr[0], macaddr[1], macaddr[2],
 173              macaddr[3], macaddr[4], macaddr[5]);
 174 }
 175
 176 void qemu_macaddr_default_if_unset(MACAddr *macaddr)
 177 {
 178     static int index = 0;
 179     static const MACAddr zero = { .a = { 0,0,0,0,0,0 } };
 180
 181     if (memcmp(macaddr, &zero, sizeof(zero)) != 0)
 182         return;
 183     macaddr->a[0] = 0x52;
 184     macaddr->a[1] = 0x54;
 185     macaddr->a[2] = 0x00;
 186     macaddr->a[3] = 0x12;
 187     macaddr->a[4] = 0x34;
 188     macaddr->a[5] = 0x56 + index++;
 189 }
 190
 191 static char *assign_name(VLANClientState *vc1, const char *model)
 192 {
 193     VLANState *vlan;
 194     char buf[256];
 195     int id = 0;
 196
 197     QTAILQ_FOREACH(vlan, &vlans, next) {
 198         VLANClientState *vc;
 199
 200         QTAILQ_FOREACH(vc, &vlan->clients, next) {
 201             if (vc != vc1 && strcmp(vc->model, model) == 0) {
 202                 id++;
 203             }
 204         }
 205     }
 206
 207     snprintf(buf, sizeof(buf), "%s.%d", model, id);
 208
 209     return qemu_strdup(buf);
 210 }
 211
 212 static ssize_t qemu_deliver_packet(VLANClientState *sender,
 213                                    unsigned flags,
 214                                    const uint8_t *data,
 215                                    size_t size,
 216                                    void *opaque);
 217 static ssize_t qemu_deliver_packet_iov(VLANClientState *sender,
 218                                        unsigned flags,
 219                                        const struct iovec *iov,
 220                                        int iovcnt,
 221                                        void *opaque);
 222
 223 VLANClientState *qemu_new_net_client(NetClientInfo *info,
 224                                      VLANState *vlan,
 225                                      VLANClientState *peer,
 226                                      const char *model,
 227                                      const char *name)
 228 {
 229     VLANClientState *vc;
 230
 231     assert(info->size >= sizeof(VLANClientState));
 232
 233     vc = qemu_mallocz(info->size);
 234
 235     vc->info = info;
 236     vc->model = qemu_strdup(model);
 237     if (name) {
 238         vc->name = qemu_strdup(name);
 239     } else {
 240         vc->name = assign_name(vc, model);
 241     }
 242
 243     if (vlan) {
 244         assert(!peer);
 245         vc->vlan = vlan;
 246         QTAILQ_INSERT_TAIL(&vc->vlan->clients, vc, next);
 247     } else {
 248         if (peer) {
 249             assert(!peer->peer);
 250             vc->peer = peer;
 251             peer->peer = vc;
 252         }
 253         QTAILQ_INSERT_TAIL(&non_vlan_clients, vc, next);
 254
 255         vc->send_queue = qemu_new_net_queue(qemu_deliver_packet,
 256                                             qemu_deliver_packet_iov,
 257                                             vc);
 258     }
 259
 260     return vc;
 261 }
 262
 263 NICState *qemu_new_nic(NetClientInfo *info,
 264                        NICConf *conf,
 265                        const char *model,
 266                        const char *name,
 267                        void *opaque)
 268 {
 269     VLANClientState *nc;
 270     NICState *nic;
 271
 272     assert(info->type == NET_CLIENT_TYPE_NIC);
 273     assert(info->size >= sizeof(NICState));
 274
 275     nc = qemu_new_net_client(info, conf->vlan, conf->peer, model, name);
 276
 277     nic = DO_UPCAST(NICState, nc, nc);
 278     nic->conf = conf;
 279     nic->opaque = opaque;
 280
 281     return nic;
 282 }
 283
 284 void qemu_del_vlan_client(VLANClientState *vc)
 285 {
 286     if (vc->vlan) {
 287         QTAILQ_REMOVE(&vc->vlan->clients, vc, next);
 288     } else {
 289         if (vc->send_queue) {
 290             qemu_del_net_queue(vc->send_queue);
 291         }
 292         QTAILQ_REMOVE(&non_vlan_clients, vc, next);
 293         if (vc->peer) {
 294             vc->peer->peer = NULL;
 295         }
 296     }
 297
 298     if (vc->info->cleanup) {
 299         vc->info->cleanup(vc);
 300     }
 301
 302     qemu_free(vc->name);
 303     qemu_free(vc->model);
 304     qemu_free(vc);
 305 }
 306
 307 VLANClientState *
 308 qemu_find_vlan_client_by_name(Monitor *mon, int vlan_id,
 309                               const char *client_str)
 310 {
 311     VLANState *vlan;
 312     VLANClientState *vc;
 313
 314     vlan = qemu_find_vlan(vlan_id, 0);
 315     if (!vlan) {
 316         monitor_printf(mon, "unknown VLAN %d\n", vlan_id);
 317         return NULL;
 318     }
 319
 320     QTAILQ_FOREACH(vc, &vlan->clients, next) {
 321         if (!strcmp(vc->name, client_str)) {
 322             break;
 323         }
 324     }
 325     if (!vc) {
 326         monitor_printf(mon, "can't find device %s on VLAN %d\n",
 327                        client_str, vlan_id);
 328     }
 329
 330     return vc;
 331 }
 332
 333 void qemu_foreach_nic(qemu_nic_foreach func, void *opaque)
 334 {
 335     VLANClientState *nc;
 336     VLANState *vlan;
 337
 338     QTAILQ_FOREACH(nc, &non_vlan_clients, next) {
 339         if (nc->info->type == NET_CLIENT_TYPE_NIC) {
 340             func(DO_UPCAST(NICState, nc, nc), opaque);
 341         }
 342     }
 343
 344     QTAILQ_FOREACH(vlan, &vlans, next) {
 345         QTAILQ_FOREACH(nc, &vlan->clients, next) {
 346             if (nc->info->type == NET_CLIENT_TYPE_NIC) {
 347                 func(DO_UPCAST(NICState, nc, nc), opaque);
 348             }
 349         }
 350     }
 351 }
 352
 353 int qemu_can_send_packet(VLANClientState *sender)
 354 {
 355     VLANState *vlan = sender->vlan;
 356     VLANClientState *vc;
 357
 358     if (sender->peer) {
 359         if (sender->peer->receive_disabled) {
 360             return 0;
 361         } else if (sender->peer->info->can_receive &&
 362                    !sender->peer->info->can_receive(sender->peer)) {
 363             return 0;
 364         } else {
 365             return 1;
 366         }
 367     }
 368
 369     if (!sender->vlan) {
 370         return 1;
 371     }
 372
 373     QTAILQ_FOREACH(vc, &vlan->clients, next) {
 374         if (vc == sender) {
 375             continue;
 376         }
 377
 378         /* no can_receive() handler, they can always receive */
 379         if (!vc->info->can_receive || vc->info->can_receive(vc)) {
 380             return 1;
 381         }
 382     }
 383     return 0;
 384 }
 385
 386 static ssize_t qemu_deliver_packet(VLANClientState *sender,
 387                                    unsigned flags,
 388                                    const uint8_t *data,
 389                                    size_t size,
 390                                    void *opaque)
 391 {
 392     VLANClientState *vc = opaque;
 393     ssize_t ret;
 394
 395     if (vc->link_down) {
 396         return size;
 397     }
 398
 399     if (vc->receive_disabled) {
 400         return 0;
 401     }
 402
 403     if (flags & QEMU_NET_PACKET_FLAG_RAW && vc->info->receive_raw) {
 404         ret = vc->info->receive_raw(vc, data, size);
 405     } else {
 406         ret = vc->info->receive(vc, data, size);
 407     }
 408
 409     if (ret == 0) {
 410         vc->receive_disabled = 1;
 411     };
 412
 413     return ret;
 414 }
 415
 416 static ssize_t qemu_vlan_deliver_packet(VLANClientState *sender,
 417                                         unsigned flags,
 418                                         const uint8_t *buf,
 419                                         size_t size,
 420                                         void *opaque)
 421 {
 422     VLANState *vlan = opaque;
 423     VLANClientState *vc;
 424     ssize_t ret = -1;
 425
 426     QTAILQ_FOREACH(vc, &vlan->clients, next) {
 427         ssize_t len;
 428
 429         if (vc == sender) {
 430             continue;
 431         }
 432
 433         if (vc->link_down) {
 434             ret = size;
 435             continue;
 436         }
 437
 438         if (vc->receive_disabled) {
 439             ret = 0;
 440             continue;
 441         }
 442
 443         if (flags & QEMU_NET_PACKET_FLAG_RAW && vc->info->receive_raw) {
 444             len = vc->info->receive_raw(vc, buf, size);
 445         } else {
 446             len = vc->info->receive(vc, buf, size);
 447         }
 448
 449         if (len == 0) {
 450             vc->receive_disabled = 1;
 451         }
 452
 453         ret = (ret >= 0) ? ret : len;
 454
 455     }
 456
 457     return ret;
 458 }
 459
 460 void qemu_purge_queued_packets(VLANClientState *vc)
 461 {
 462     NetQueue *queue;
 463
 464     if (!vc->peer && !vc->vlan) {
 465         return;
 466     }
 467
 468     if (vc->peer) {
 469         queue = vc->peer->send_queue;
 470     } else {
 471         queue = vc->vlan->send_queue;
 472     }
 473
 474     qemu_net_queue_purge(queue, vc);
 475 }
 476
 477 void qemu_flush_queued_packets(VLANClientState *vc)
 478 {
 479     NetQueue *queue;
 480
 481     vc->receive_disabled = 0;
 482
 483     if (vc->vlan) {
 484         queue = vc->vlan->send_queue;
 485     } else {
 486         queue = vc->send_queue;
 487     }
 488
 489     qemu_net_queue_flush(queue);
 490 }
 491
 492 static ssize_t qemu_send_packet_async_with_flags(VLANClientState *sender,
 493                                                  unsigned flags,
 494                                                  const uint8_t *buf, int size,
 495                                                  NetPacketSent *sent_cb)
 496 {
 497     NetQueue *queue;
 498
 499 #ifdef DEBUG_NET
 500     printf("qemu_send_packet_async:\n");
 501     hex_dump(stdout, buf, size);
 502 #endif
 503
 504     if (sender->link_down || (!sender->peer && !sender->vlan)) {
 505         return size;
 506     }
 507
 508     if (sender->peer) {
 509         queue = sender->peer->send_queue;
 510     } else {
 511         queue = sender->vlan->send_queue;
 512     }
 513
 514     return qemu_net_queue_send(queue, sender, flags, buf, size, sent_cb);
 515 }
 516
 517 ssize_t qemu_send_packet_async(VLANClientState *sender,
 518                                const uint8_t *buf, int size,
 519                                NetPacketSent *sent_cb)
 520 {
 521     return qemu_send_packet_async_with_flags(sender, QEMU_NET_PACKET_FLAG_NONE,
 522                                              buf, size, sent_cb);
 523 }
 524
 525 void qemu_send_packet(VLANClientState *vc, const uint8_t *buf, int size)
 526 {
 527     qemu_send_packet_async(vc, buf, size, NULL);
 528 }
 529
 530 ssize_t qemu_send_packet_raw(VLANClientState *vc, const uint8_t *buf, int size)
 531 {
 532     return qemu_send_packet_async_with_flags(vc, QEMU_NET_PACKET_FLAG_RAW,
 533                                              buf, size, NULL);
 534 }
 535
 536 static ssize_t vc_sendv_compat(VLANClientState *vc, const struct iovec *iov,
 537                                int iovcnt)
 538 {
 539     uint8_t buffer[4096];
 540     size_t offset = 0;
 541     int i;
 542
 543     for (i = 0; i < iovcnt; i++) {
 544         size_t len;
 545
 546         len = MIN(sizeof(buffer) - offset, iov[i].iov_len);
 547         memcpy(buffer + offset, iov[i].iov_base, len);
 548         offset += len;
 549     }
 550
 551     return vc->info->receive(vc, buffer, offset);
 552 }
 553
 554 static ssize_t calc_iov_length(const struct iovec *iov, int iovcnt)
 555 {
 556     size_t offset = 0;
 557     int i;
 558
 559     for (i = 0; i < iovcnt; i++)
 560         offset += iov[i].iov_len;
 561     return offset;
 562 }
 563
 564 static ssize_t qemu_deliver_packet_iov(VLANClientState *sender,
 565                                        unsigned flags,
 566                                        const struct iovec *iov,
 567                                        int iovcnt,
 568                                        void *opaque)
 569 {
 570     VLANClientState *vc = opaque;
 571
 572     if (vc->link_down) {
 573         return calc_iov_length(iov, iovcnt);
 574     }
 575
 576     if (vc->info->receive_iov) {
 577         return vc->info->receive_iov(vc, iov, iovcnt);
 578     } else {
 579         return vc_sendv_compat(vc, iov, iovcnt);
 580     }
 581 }
 582
 583 static ssize_t qemu_vlan_deliver_packet_iov(VLANClientState *sender,
 584                                             unsigned flags,
 585                                             const struct iovec *iov,
 586                                             int iovcnt,
 587                                             void *opaque)
 588 {
 589     VLANState *vlan = opaque;
 590     VLANClientState *vc;
 591     ssize_t ret = -1;
 592
 593     QTAILQ_FOREACH(vc, &vlan->clients, next) {
 594         ssize_t len;
 595
 596         if (vc == sender) {
 597             continue;
 598         }
 599
 600         if (vc->link_down) {
 601             ret = calc_iov_length(iov, iovcnt);
 602             continue;
 603         }
 604
 605         assert(!(flags & QEMU_NET_PACKET_FLAG_RAW));
 606
 607         if (vc->info->receive_iov) {
 608             len = vc->info->receive_iov(vc, iov, iovcnt);
 609         } else {
 610             len = vc_sendv_compat(vc, iov, iovcnt);
 611         }
 612
 613         ret = (ret >= 0) ? ret : len;
 614     }
 615
 616     return ret;
 617 }
 618
 619 ssize_t qemu_sendv_packet_async(VLANClientState *sender,
 620                                 const struct iovec *iov, int iovcnt,
 621                                 NetPacketSent *sent_cb)
 622 {
 623     NetQueue *queue;
 624
 625     if (sender->link_down || (!sender->peer && !sender->vlan)) {
 626         return calc_iov_length(iov, iovcnt);
 627     }
 628
 629     if (sender->peer) {
 630         queue = sender->peer->send_queue;
 631     } else {
 632         queue = sender->vlan->send_queue;
 633     }
 634
 635     return qemu_net_queue_send_iov(queue, sender,
 636                                    QEMU_NET_PACKET_FLAG_NONE,
 637                                    iov, iovcnt, sent_cb);
 638 }
 639
 640 ssize_t
 641 qemu_sendv_packet(VLANClientState *vc, const struct iovec *iov, int iovcnt)
 642 {
 643     return qemu_sendv_packet_async(vc, iov, iovcnt, NULL);
 644 }
 645
 646 /* find or alloc a new VLAN */
 647 VLANState *qemu_find_vlan(int id, int allocate)
 648 {
 649     VLANState *vlan;
 650
 651     QTAILQ_FOREACH(vlan, &vlans, next) {
 652         if (vlan->id == id) {
 653             return vlan;
 654         }
 655     }
 656
 657     if (!allocate) {
 658         return NULL;
 659     }
 660
 661     vlan = qemu_mallocz(sizeof(VLANState));
 662     vlan->id = id;
 663     QTAILQ_INIT(&vlan->clients);
 664
 665     vlan->send_queue = qemu_new_net_queue(qemu_vlan_deliver_packet,
 666                                           qemu_vlan_deliver_packet_iov,
 667                                           vlan);
 668
 669     QTAILQ_INSERT_TAIL(&vlans, vlan, next);
 670
 671     return vlan;
 672 }
 673
 674 VLANClientState *qemu_find_netdev(const char *id)
 675 {
 676     VLANClientState *vc;
 677
 678     QTAILQ_FOREACH(vc, &non_vlan_clients, next) {
 679         if (!strcmp(vc->name, id)) {
 680             return vc;
 681         }
 682     }
 683
 684     return NULL;
 685 }
 686
 687 static int nic_get_free_idx(void)
 688 {
 689     int index;
 690
 691     for (index = 0; index < MAX_NICS; index++)
 692         if (!nd_table[index].used)
 693             return index;
 694     return -1;
 695 }
 696
 697 int qemu_show_nic_models(const char *arg, const char *const *models)
 698 {
 699     int i;
 700
 701     if (!arg || strcmp(arg, "?"))
 702         return 0;
 703
 704     fprintf(stderr, "qemu: Supported NIC models: ");
 705     for (i = 0 ; models[i]; i++)
 706         fprintf(stderr, "%s%c", models[i], models[i+1] ? ',' : '\n');
 707     return 1;
 708 }
 709
 710 void qemu_check_nic_model(NICInfo *nd, const char *model)
 711 {
 712     const char *models[2];
 713
 714     models[0] = model;
 715     models[1] = NULL;
 716
 717     if (qemu_show_nic_models(nd->model, models))
 718         exit(0);
 719     if (qemu_find_nic_model(nd, models, model) < 0)
 720         exit(1);
 721 }
 722
 723 int qemu_find_nic_model(NICInfo *nd, const char * const *models,
 724                         const char *default_model)
 725 {
 726     int i;
 727
 728     if (!nd->model)
 729         nd->model = qemu_strdup(default_model);
 730
 731     for (i = 0 ; models[i]; i++) {
 732         if (strcmp(nd->model, models[i]) == 0)
 733             return i;
 734     }
 735
 736     error_report("qemu: Unsupported NIC model: %s", nd->model);
 737     return -1;
 738 }
 739
 740 int net_handle_fd_param(Monitor *mon, const char *param)
 741 {
 742     if (!qemu_isdigit(param[0])) {
 743         int fd;
 744
 745         fd = monitor_get_fd(mon, param);
 746         if (fd == -1) {
 747             error_report("No file descriptor named %s found", param);
 748             return -1;
 749         }
 750
 751         return fd;
 752     } else {
 753         return strtol(param, NULL, 0);
 754     }
 755 }
 756
 757 static int net_init_nic(QemuOpts *opts,
 758                         Monitor *mon,
 759                         const char *name,
 760                         VLANState *vlan)
 761 {
 762     int idx;
 763     NICInfo *nd;
 764     const char *netdev;
 765
 766     idx = nic_get_free_idx();
 767     if (idx == -1 || nb_nics >= MAX_NICS) {
 768         error_report("Too Many NICs");
 769         return -1;
 770     }
 771
 772     nd = &nd_table[idx];
 773
 774     memset(nd, 0, sizeof(*nd));
 775
 776     if ((netdev = qemu_opt_get(opts, "netdev"))) {
 777         nd->netdev = qemu_find_netdev(netdev);
 778         if (!nd->netdev) {
 779             error_report("netdev '%s' not found", netdev);
 780             return -1;
 781         }
 782     } else {
 783         assert(vlan);
 784         nd->vlan = vlan;
 785     }
 786     if (name) {
 787         nd->name = qemu_strdup(name);
 788     }
 789     if (qemu_opt_get(opts, "model")) {
 790         nd->model = qemu_strdup(qemu_opt_get(opts, "model"));
 791     }
 792     if (qemu_opt_get(opts, "addr")) {
 793         nd->devaddr = qemu_strdup(qemu_opt_get(opts, "addr"));
 794     }
 795
 796     nd->macaddr[0] = 0x52;
 797     nd->macaddr[1] = 0x54;
 798     nd->macaddr[2] = 0x00;
 799     nd->macaddr[3] = 0x12;
 800     nd->macaddr[4] = 0x34;
 801     nd->macaddr[5] = 0x56 + idx;
 802
 803     if (qemu_opt_get(opts, "macaddr") &&
 804         net_parse_macaddr(nd->macaddr, qemu_opt_get(opts, "macaddr")) < 0) {
 805         error_report("invalid syntax for ethernet address");
 806         return -1;
 807     }
 808
 809     nd->nvectors = qemu_opt_get_number(opts, "vectors",
 810                                        DEV_NVECTORS_UNSPECIFIED);
 811     if (nd->nvectors != DEV_NVECTORS_UNSPECIFIED &&
 812         (nd->nvectors < 0 || nd->nvectors > 0x7ffffff)) {
 813         error_report("invalid # of vectors: %d", nd->nvectors);
 814         return -1;
 815     }
 816
 817     nd->used = 1;
 818     nb_nics++;
 819
 820     return idx;
 821 }
 822
 823 #define NET_COMMON_PARAMS_DESC                     \
 824     {                                              \
 825         .name = "type",                            \
 826         .type = QEMU_OPT_STRING,                   \
 827         .help = "net client type (nic, tap etc.)", \
 828      }, {                                          \
 829         .name = "vlan",                            \
 830         .type = QEMU_OPT_NUMBER,                   \
 831         .help = "vlan number",                     \
 832      }, {                                          \
 833         .name = "name",                            \
 834         .type = QEMU_OPT_STRING,                   \
 835         .help = "identifier for monitor commands", \
 836      }
 837
 838 typedef int (*net_client_init_func)(QemuOpts *opts,
 839                                     Monitor *mon,
 840                                     const char *name,
 841                                     VLANState *vlan);
 842
 843 /* magic number, but compiler will warn if too small */
 844 #define NET_MAX_DESC 20
 845
 846 static const struct {
 847     const char *type;
 848     net_client_init_func init;
 849     QemuOptDesc desc[NET_MAX_DESC];
 850 } net_client_types[] = {
 851     {
 852         .type = "none",
 853         .desc = {
 854             NET_COMMON_PARAMS_DESC,
 855             { /* end of list */ }
 856         },
 857     }, {
 858         .type = "nic",
 859         .init = net_init_nic,
 860         .desc = {
 861             NET_COMMON_PARAMS_DESC,
 862             {
 863                 .name = "netdev",
 864                 .type = QEMU_OPT_STRING,
 865                 .help = "id of -netdev to connect to",
 866             },
 867             {
 868                 .name = "macaddr",
 869                 .type = QEMU_OPT_STRING,
 870                 .help = "MAC address",
 871             }, {
 872                 .name = "model",
 873                 .type = QEMU_OPT_STRING,
 874                 .help = "device model (e1000, rtl8139, virtio etc.)",
 875             }, {
 876                 .name = "addr",
 877                 .type = QEMU_OPT_STRING,
 878                 .help = "PCI device address",
 879             }, {
 880                 .name = "vectors",
 881                 .type = QEMU_OPT_NUMBER,
 882                 .help = "number of MSI-x vectors, 0 to disable MSI-X",
 883             },
 884             { /* end of list */ }
 885         },
 886 #ifdef CONFIG_SLIRP
 887     }, {
 888         .type = "user",
 889         .init = net_init_slirp,
 890         .desc = {
 891             NET_COMMON_PARAMS_DESC,
 892             {
 893                 .name = "hostname",
 894                 .type = QEMU_OPT_STRING,
 895                 .help = "client hostname reported by the builtin DHCP server",
 896             }, {
 897                 .name = "restrict",
 898                 .type = QEMU_OPT_STRING,
 899                 .help = "isolate the guest from the host (y|yes|n|no)",
 900             }, {
 901                 .name = "ip",
 902                 .type = QEMU_OPT_STRING,
 903                 .help = "legacy parameter, use net= instead",
 904             }, {
 905                 .name = "net",
 906                 .type = QEMU_OPT_STRING,
 907                 .help = "IP address and optional netmask",
 908             }, {
 909                 .name = "host",
 910                 .type = QEMU_OPT_STRING,
 911                 .help = "guest-visible address of the host",
 912             }, {
 913                 .name = "tftp",
 914                 .type = QEMU_OPT_STRING,
 915                 .help = "root directory of the built-in TFTP server",
 916             }, {
 917                 .name = "bootfile",
 918                 .type = QEMU_OPT_STRING,
 919                 .help = "BOOTP filename, for use with tftp=",
 920             }, {
 921                 .name = "dhcpstart",
 922                 .type = QEMU_OPT_STRING,
 923                 .help = "the first of the 16 IPs the built-in DHCP server can assign",
 924             }, {
 925                 .name = "dns",
 926                 .type = QEMU_OPT_STRING,
 927                 .help = "guest-visible address of the virtual nameserver",
 928             }, {
 929                 .name = "smb",
 930                 .type = QEMU_OPT_STRING,
 931                 .help = "root directory of the built-in SMB server",
 932             }, {
 933                 .name = "smbserver",
 934                 .type = QEMU_OPT_STRING,
 935                 .help = "IP address of the built-in SMB server",
 936             }, {
 937                 .name = "hostfwd",
 938                 .type = QEMU_OPT_STRING,
 939                 .help = "guest port number to forward incoming TCP or UDP connections",
 940             }, {
 941                 .name = "guestfwd",
 942                 .type = QEMU_OPT_STRING,
 943                 .help = "IP address and port to forward guest TCP connections",
 944             },
 945             { /* end of list */ }
 946         },
 947 #endif
 948     }, {
 949         .type = "tap",
 950         .init = net_init_tap,
 951         .desc = {
 952             NET_COMMON_PARAMS_DESC,
 953             {
 954                 .name = "ifname",
 955                 .type = QEMU_OPT_STRING,
 956                 .help = "interface name",
 957             },
 958 #ifndef _WIN32
 959             {
 960                 .name = "fd",
 961                 .type = QEMU_OPT_STRING,
 962                 .help = "file descriptor of an already opened tap",
 963             }, {
 964                 .name = "script",
 965                 .type = QEMU_OPT_STRING,
 966                 .help = "script to initialize the interface",
 967             }, {
 968                 .name = "downscript",
 969                 .type = QEMU_OPT_STRING,
 970                 .help = "script to shut down the interface",
 971             }, {
 972                 .name = "sndbuf",
 973                 .type = QEMU_OPT_SIZE,
 974                 .help = "send buffer limit"
 975             }, {
 976                 .name = "vnet_hdr",
 977                 .type = QEMU_OPT_BOOL,
 978                 .help = "enable the IFF_VNET_HDR flag on the tap interface"
 979             }, {
 980                 .name = "vhost",
 981                 .type = QEMU_OPT_BOOL,
 982                 .help = "enable vhost-net network accelerator",
 983             }, {
 984                 .name = "vhostfd",
 985                 .type = QEMU_OPT_STRING,
 986                 .help = "file descriptor of an already opened vhost net device",
 987             },
 988 #endif /* _WIN32 */
 989             { /* end of list */ }
 990         },
 991     }, {
 992         .type = "socket",
 993         .init = net_init_socket,
 994         .desc = {
 995             NET_COMMON_PARAMS_DESC,
 996             {
 997                 .name = "fd",
 998                 .type = QEMU_OPT_STRING,
 999                 .help = "file descriptor of an already opened socket",
1000             }, {
1001                 .name = "listen",
1002                 .type = QEMU_OPT_STRING,
1003                 .help = "port number, and optional hostname, to listen on",
1004             }, {
1005                 .name = "connect",
1006                 .type = QEMU_OPT_STRING,
1007                 .help = "port number, and optional hostname, to connect to",
1008             }, {
1009                 .name = "mcast",
1010                 .type = QEMU_OPT_STRING,
1011                 .help = "UDP multicast address and port number",
1012             },
1013             { /* end of list */ }
1014         },
1015 #ifdef CONFIG_VDE
1016     }, {
1017         .type = "vde",
1018         .init = net_init_vde,
1019         .desc = {
1020             NET_COMMON_PARAMS_DESC,
1021             {
1022                 .name = "sock",
1023                 .type = QEMU_OPT_STRING,
1024                 .help = "socket path",
1025             }, {
1026                 .name = "port",
1027                 .type = QEMU_OPT_NUMBER,
1028                 .help = "port number",
1029             }, {
1030                 .name = "group",
1031                 .type = QEMU_OPT_STRING,
1032                 .help = "group owner of socket",
1033             }, {
1034                 .name = "mode",
1035                 .type = QEMU_OPT_NUMBER,
1036                 .help = "permissions for socket",
1037             },
1038             { /* end of list */ }
1039         },
1040 #endif
1041     }, {
1042         .type = "dump",
1043         .init = net_init_dump,
1044         .desc = {
1045             NET_COMMON_PARAMS_DESC,
1046             {
1047                 .name = "len",
1048                 .type = QEMU_OPT_SIZE,
1049                 .help = "per-packet size limit (64k default)",
1050             }, {
1051                 .name = "file",
1052                 .type = QEMU_OPT_STRING,
1053                 .help = "dump file path (default is qemu-vlan0.pcap)",
1054             },
1055             { /* end of list */ }
1056         },
1057     },
1058     { /* end of list */ }
1059 };
1060
1061 int net_client_init(Monitor *mon, QemuOpts *opts, int is_netdev)
1062 {
1063     const char *name;
1064     const char *type;
1065     int i;
1066
1067     type = qemu_opt_get(opts, "type");
1068     if (!type) {
1069         qerror_report(QERR_MISSING_PARAMETER, "type");
1070         return -1;
1071     }
1072
1073     if (is_netdev) {
1074         if (strcmp(type, "tap") != 0 &&
1075 #ifdef CONFIG_SLIRP
1076             strcmp(type, "user") != 0 &&
1077 #endif
1078 #ifdef CONFIG_VDE
1079             strcmp(type, "vde") != 0 &&
1080 #endif
1081             strcmp(type, "socket") != 0) {
1082             qerror_report(QERR_INVALID_PARAMETER_VALUE, "type",
1083                           "a netdev backend type");
1084             return -1;
1085         }
1086
1087         if (qemu_opt_get(opts, "vlan")) {
1088             qerror_report(QERR_INVALID_PARAMETER, "vlan");
1089             return -1;
1090         }
1091         if (qemu_opt_get(opts, "name")) {
1092             qerror_report(QERR_INVALID_PARAMETER, "name");
1093             return -1;
1094         }
1095         if (!qemu_opts_id(opts)) {
1096             qerror_report(QERR_MISSING_PARAMETER, "id");
1097             return -1;
1098         }
1099     }
1100
1101     name = qemu_opts_id(opts);
1102     if (!name) {
1103         name = qemu_opt_get(opts, "name");
1104     }
1105
1106     for (i = 0; net_client_types[i].type != NULL; i++) {
1107         if (!strcmp(net_client_types[i].type, type)) {
1108             VLANState *vlan = NULL;
1109             int ret;
1110
1111             if (qemu_opts_validate(opts, &net_client_types[i].desc[0]) == -1) {
1112                 return -1;
1113             }
1114
1115             /* Do not add to a vlan if it's a -netdev or a nic with a
1116              * netdev= parameter. */
1117             if (!(is_netdev ||
1118                   (strcmp(type, "nic") == 0 && qemu_opt_get(opts, "netdev")))) {
1119                 vlan = qemu_find_vlan(qemu_opt_get_number(opts, "vlan", 0), 1);
1120             }
1121
1122             ret = 0;
1123             if (net_client_types[i].init) {
1124                 ret = net_client_types[i].init(opts, mon, name, vlan);
1125                 if (ret < 0) {
1126                     /* TODO push error reporting into init() methods */
1127                     qerror_report(QERR_DEVICE_INIT_FAILED, type);
1128                     return -1;
1129                 }
1130             }
1131             return ret;
1132         }
1133     }
1134
1135     qerror_report(QERR_INVALID_PARAMETER_VALUE, "type",
1136                   "a network client type");
1137     return -1;
1138 }
1139
1140 static int net_host_check_device(const char *device)
1141 {
1142     int i;
1143     const char *valid_param_list[] = { "tap", "socket", "dump"
1144 #ifdef CONFIG_SLIRP
1145                                        ,"user"
1146 #endif
1147 #ifdef CONFIG_VDE
1148                                        ,"vde"
1149 #endif
1150     };
1151     for (i = 0; i < sizeof(valid_param_list) / sizeof(char *); i++) {
1152         if (!strncmp(valid_param_list[i], device,
1153                      strlen(valid_param_list[i])))
1154             return 1;
1155     }
1156
1157     return 0;
1158 }
1159
1160 void net_host_device_add(Monitor *mon, const QDict *qdict)
1161 {
1162     const char *device = qdict_get_str(qdict, "device");
1163     const char *opts_str = qdict_get_try_str(qdict, "opts");
1164     QemuOpts *opts;
1165
1166     if (!net_host_check_device(device)) {
1167         monitor_printf(mon, "invalid host network device %s\n", device);
1168         return;
1169     }
1170
1171     opts = qemu_opts_parse(&qemu_net_opts, opts_str ? opts_str : "", 0);
1172     if (!opts) {
1173         return;
1174     }
1175
1176     qemu_opt_set(opts, "type", device);
1177
1178     if (net_client_init(mon, opts, 0) < 0) {
1179         monitor_printf(mon, "adding host network device %s failed\n", device);
1180     }
1181 }
1182
1183 void net_host_device_remove(Monitor *mon, const QDict *qdict)
1184 {
1185     VLANClientState *vc;
1186     int vlan_id = qdict_get_int(qdict, "vlan_id");
1187     const char *device = qdict_get_str(qdict, "device");
1188
1189     vc = qemu_find_vlan_client_by_name(mon, vlan_id, device);
1190     if (!vc) {
1191         return;
1192     }
1193     if (!net_host_check_device(vc->model)) {
1194         monitor_printf(mon, "invalid host network device %s\n", device);
1195         return;
1196     }
1197     qemu_del_vlan_client(vc);
1198 }
1199
1200 int do_netdev_add(Monitor *mon, const QDict *qdict, QObject **ret_data)
1201 {
1202     QemuOpts *opts;
1203     int res;
1204
1205     opts = qemu_opts_from_qdict(&qemu_netdev_opts, qdict);
1206     if (!opts) {
1207         return -1;
1208     }
1209
1210     res = net_client_init(mon, opts, 1);
1211     if (res < 0) {
1212         qemu_opts_del(opts);
1213     }
1214
1215     return res;
1216 }
1217
1218 int do_netdev_del(Monitor *mon, const QDict *qdict, QObject **ret_data)
1219 {
1220     const char *id = qdict_get_str(qdict, "id");
1221     VLANClientState *vc;
1222
1223     vc = qemu_find_netdev(id);
1224     if (!vc || vc->info->type == NET_CLIENT_TYPE_NIC) {
1225         qerror_report(QERR_DEVICE_NOT_FOUND, id);
1226         return -1;
1227     }
1228     qemu_del_vlan_client(vc);
1229     qemu_opts_del(qemu_opts_find(&qemu_netdev_opts, id));
1230     return 0;
1231 }
1232
1233 void do_info_network(Monitor *mon)
1234 {
1235     VLANState *vlan;
1236     VLANClientState *vc;
1237
1238     QTAILQ_FOREACH(vlan, &vlans, next) {
1239         monitor_printf(mon, "VLAN %d devices:\n", vlan->id);
1240
1241         QTAILQ_FOREACH(vc, &vlan->clients, next) {
1242             monitor_printf(mon, "  %s: %s\n", vc->name, vc->info_str);
1243         }
1244     }
1245     monitor_printf(mon, "Devices not on any VLAN:\n");
1246     QTAILQ_FOREACH(vc, &non_vlan_clients, next) {
1247         monitor_printf(mon, "  %s: %s", vc->name, vc->info_str);
1248         if (vc->peer) {
1249             monitor_printf(mon, " peer=%s", vc->peer->name);
1250         }
1251         monitor_printf(mon, "\n");
1252     }
1253 }
1254
1255 int do_set_link(Monitor *mon, const QDict *qdict, QObject **ret_data)
1256 {
1257     VLANState *vlan;
1258     VLANClientState *vc = NULL;
1259     const char *name = qdict_get_str(qdict, "name");
1260     int up = qdict_get_bool(qdict, "up");
1261
1262     QTAILQ_FOREACH(vlan, &vlans, next) {
1263         QTAILQ_FOREACH(vc, &vlan->clients, next) {
1264             if (strcmp(vc->name, name) == 0) {
1265                 goto done;
1266             }
1267         }
1268     }
1269     vc = qemu_find_netdev(name);
1270 done:
1271
1272     if (!vc) {
1273         qerror_report(QERR_DEVICE_NOT_FOUND, name);
1274         return -1;
1275     }
1276
1277     vc->link_down = !up;
1278
1279     if (vc->info->link_status_changed) {
1280         vc->info->link_status_changed(vc);
1281     }
1282     return 0;
1283 }
1284
1285 void net_cleanup(void)
1286 {
1287     VLANState *vlan;
1288     VLANClientState *vc, *next_vc;
1289
1290     QTAILQ_FOREACH(vlan, &vlans, next) {
1291         QTAILQ_FOREACH_SAFE(vc, &vlan->clients, next, next_vc) {
1292             qemu_del_vlan_client(vc);
1293         }
1294     }
1295
1296     QTAILQ_FOREACH_SAFE(vc, &non_vlan_clients, next, next_vc) {
1297         qemu_del_vlan_client(vc);
1298     }
1299 }
1300
1301 void net_check_clients(void)
1302 {
1303     VLANState *vlan;
1304     VLANClientState *vc;
1305     int has_nic = 0, has_host_dev = 0;
1306
1307     QTAILQ_FOREACH(vlan, &vlans, next) {
1308         QTAILQ_FOREACH(vc, &vlan->clients, next) {
1309             switch (vc->info->type) {
1310             case NET_CLIENT_TYPE_NIC:
1311                 has_nic = 1;
1312                 break;
1313             case NET_CLIENT_TYPE_SLIRP:
1314             case NET_CLIENT_TYPE_TAP:
1315             case NET_CLIENT_TYPE_SOCKET:
1316             case NET_CLIENT_TYPE_VDE:
1317                 has_host_dev = 1;
1318                 break;
1319             default: ;
1320             }
1321         }
1322         if (has_host_dev && !has_nic)
1323             fprintf(stderr, "Warning: vlan %d with no nics\n", vlan->id);
1324         if (has_nic && !has_host_dev)
1325             fprintf(stderr,
1326                     "Warning: vlan %d is not connected to host network\n",
1327                     vlan->id);
1328     }
1329     QTAILQ_FOREACH(vc, &non_vlan_clients, next) {
1330         if (!vc->peer) {
1331             fprintf(stderr, "Warning: %s %s has no peer\n",
1332                     vc->info->type == NET_CLIENT_TYPE_NIC ? "nic" : "netdev",
1333                     vc->name);
1334         }
1335     }
1336 }
1337
1338 static int net_init_client(QemuOpts *opts, void *dummy)
1339 {
1340     if (net_client_init(NULL, opts, 0) < 0)
1341         return -1;
1342     return 0;
1343 }
1344
1345 static int net_init_netdev(QemuOpts *opts, void *dummy)
1346 {
1347     return net_client_init(NULL, opts, 1);
1348 }
1349
1350 int net_init_clients(void)
1351 {
1352     if (default_net) {
1353         /* if no clients, we use a default config */
1354         qemu_opts_set(&qemu_net_opts, NULL, "type", "nic");
1355 #ifdef CONFIG_SLIRP
1356         qemu_opts_set(&qemu_net_opts, NULL, "type", "user");
1357 #endif
1358     }
1359
1360     QTAILQ_INIT(&vlans);
1361     QTAILQ_INIT(&non_vlan_clients);
1362
1363     if (qemu_opts_foreach(&qemu_netdev_opts, net_init_netdev, NULL, 1) == -1)
1364         return -1;
1365
1366     if (qemu_opts_foreach(&qemu_net_opts, net_init_client, NULL, 1) == -1) {
1367         return -1;
1368     }
1369
1370     return 0;
1371 }
1372
1373 int net_client_parse(QemuOptsList *opts_list, const char *optarg)
1374 {
1375 #if defined(CONFIG_SLIRP)
1376     int ret;
1377     if (net_slirp_parse_legacy(opts_list, optarg, &ret)) {
1378         return ret;
1379     }
1380 #endif
1381
1382     if (!qemu_opts_parse(opts_list, optarg, 1)) {
1383         return -1;
1384     }
1385
1386     default_net = 0;
1387     return 0;
1388 }