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 "config-host.h" 25 26 #include "net/net.h" 27 #include "clients.h" 28 #include "hub.h" 29 #include "net/slirp.h" 30 #include "util.h" 31 32 #include "monitor/monitor.h" 33 #include "qemu-common.h" 34 #include "qemu/sockets.h" 35 #include "qemu/config-file.h" 36 #include "qmp-commands.h" 37 #include "hw/qdev.h" 38 #include "qemu/iov.h" 39 #include "qemu/main-loop.h" 40 #include "qapi-visit.h" 41 #include "qapi/opts-visitor.h" 42 #include "qapi/dealloc-visitor.h" 43 44 /* Net bridge is currently not supported for W32. */ 45 #if !defined(_WIN32) 46 # define CONFIG_NET_BRIDGE 47 #endif 48 49 static QTAILQ_HEAD(, NetClientState) net_clients; 50 51 int default_net = 1; 52 53 /***********************************************************/ 54 /* network device redirectors */ 55 56 #if defined(DEBUG_NET) 57 static void hex_dump(FILE *f, const uint8_t *buf, int size) 58 { 59 int len, i, j, c; 60 61 for(i=0;i<size;i+=16) { 62 len = size - i; 63 if (len > 16) 64 len = 16; 65 fprintf(f, "%08x ", i); 66 for(j=0;j<16;j++) { 67 if (j < len) 68 fprintf(f, " %02x", buf[i+j]); 69 else 70 fprintf(f, " "); 71 } 72 fprintf(f, " "); 73 for(j=0;j<len;j++) { 74 c = buf[i+j]; 75 if (c < ' ' || c > '~') 76 c = '.'; 77 fprintf(f, "%c", c); 78 } 79 fprintf(f, "\n"); 80 } 81 } 82 #endif 83 84 static int get_str_sep(char *buf, int buf_size, const char **pp, int sep) 85 { 86 const char *p, *p1; 87 int len; 88 p = *pp; 89 p1 = strchr(p, sep); 90 if (!p1) 91 return -1; 92 len = p1 - p; 93 p1++; 94 if (buf_size > 0) { 95 if (len > buf_size - 1) 96 len = buf_size - 1; 97 memcpy(buf, p, len); 98 buf[len] = '\0'; 99 } 100 *pp = p1; 101 return 0; 102 } 103 104 int parse_host_port(struct sockaddr_in *saddr, const char *str) 105 { 106 char buf[512]; 107 struct hostent *he; 108 const char *p, *r; 109 int port; 110 111 p = str; 112 if (get_str_sep(buf, sizeof(buf), &p, ':') < 0) 113 return -1; 114 saddr->sin_family = AF_INET; 115 if (buf[0] == '\0') { 116 saddr->sin_addr.s_addr = 0; 117 } else { 118 if (qemu_isdigit(buf[0])) { 119 if (!inet_aton(buf, &saddr->sin_addr)) 120 return -1; 121 } else { 122 if ((he = gethostbyname(buf)) == NULL) 123 return - 1; 124 saddr->sin_addr = *(struct in_addr *)he->h_addr; 125 } 126 } 127 port = strtol(p, (char **)&r, 0); 128 if (r == p) 129 return -1; 130 saddr->sin_port = htons(port); 131 return 0; 132 } 133 134 void qemu_format_nic_info_str(NetClientState *nc, uint8_t macaddr[6]) 135 { 136 snprintf(nc->info_str, sizeof(nc->info_str), 137 "model=%s,macaddr=%02x:%02x:%02x:%02x:%02x:%02x", 138 nc->model, 139 macaddr[0], macaddr[1], macaddr[2], 140 macaddr[3], macaddr[4], macaddr[5]); 141 } 142 143 void qemu_macaddr_default_if_unset(MACAddr *macaddr) 144 { 145 static int index = 0; 146 static const MACAddr zero = { .a = { 0,0,0,0,0,0 } }; 147 148 if (memcmp(macaddr, &zero, sizeof(zero)) != 0) 149 return; 150 macaddr->a[0] = 0x52; 151 macaddr->a[1] = 0x54; 152 macaddr->a[2] = 0x00; 153 macaddr->a[3] = 0x12; 154 macaddr->a[4] = 0x34; 155 macaddr->a[5] = 0x56 + index++; 156 } 157 158 /** 159 * Generate a name for net client 160 * 161 * Only net clients created with the legacy -net option and NICs need this. 162 */ 163 static char *assign_name(NetClientState *nc1, const char *model) 164 { 165 NetClientState *nc; 166 char buf[256]; 167 int id = 0; 168 169 QTAILQ_FOREACH(nc, &net_clients, next) { 170 if (nc == nc1) { 171 continue; 172 } 173 if (strcmp(nc->model, model) == 0) { 174 id++; 175 } 176 } 177 178 snprintf(buf, sizeof(buf), "%s.%d", model, id); 179 180 return g_strdup(buf); 181 } 182 183 static void qemu_net_client_destructor(NetClientState *nc) 184 { 185 g_free(nc); 186 } 187 188 static void qemu_net_client_setup(NetClientState *nc, 189 NetClientInfo *info, 190 NetClientState *peer, 191 const char *model, 192 const char *name, 193 NetClientDestructor *destructor) 194 { 195 nc->info = info; 196 nc->model = g_strdup(model); 197 if (name) { 198 nc->name = g_strdup(name); 199 } else { 200 nc->name = assign_name(nc, model); 201 } 202 203 if (peer) { 204 assert(!peer->peer); 205 nc->peer = peer; 206 peer->peer = nc; 207 } 208 QTAILQ_INSERT_TAIL(&net_clients, nc, next); 209 210 nc->send_queue = qemu_new_net_queue(nc); 211 nc->destructor = destructor; 212 } 213 214 NetClientState *qemu_new_net_client(NetClientInfo *info, 215 NetClientState *peer, 216 const char *model, 217 const char *name) 218 { 219 NetClientState *nc; 220 221 assert(info->size >= sizeof(NetClientState)); 222 223 nc = g_malloc0(info->size); 224 qemu_net_client_setup(nc, info, peer, model, name, 225 qemu_net_client_destructor); 226 227 return nc; 228 } 229 230 NICState *qemu_new_nic(NetClientInfo *info, 231 NICConf *conf, 232 const char *model, 233 const char *name, 234 void *opaque) 235 { 236 NetClientState **peers = conf->peers.ncs; 237 NICState *nic; 238 int i, queues = MAX(1, conf->queues); 239 240 assert(info->type == NET_CLIENT_OPTIONS_KIND_NIC); 241 assert(info->size >= sizeof(NICState)); 242 243 nic = g_malloc0(info->size + sizeof(NetClientState) * queues); 244 nic->ncs = (void *)nic + info->size; 245 nic->conf = conf; 246 nic->opaque = opaque; 247 248 for (i = 0; i < queues; i++) { 249 qemu_net_client_setup(&nic->ncs[i], info, peers[i], model, name, 250 NULL); 251 nic->ncs[i].queue_index = i; 252 } 253 254 return nic; 255 } 256 257 NetClientState *qemu_get_subqueue(NICState *nic, int queue_index) 258 { 259 return nic->ncs + queue_index; 260 } 261 262 NetClientState *qemu_get_queue(NICState *nic) 263 { 264 return qemu_get_subqueue(nic, 0); 265 } 266 267 NICState *qemu_get_nic(NetClientState *nc) 268 { 269 NetClientState *nc0 = nc - nc->queue_index; 270 271 return (NICState *)((void *)nc0 - nc->info->size); 272 } 273 274 void *qemu_get_nic_opaque(NetClientState *nc) 275 { 276 NICState *nic = qemu_get_nic(nc); 277 278 return nic->opaque; 279 } 280 281 static void qemu_cleanup_net_client(NetClientState *nc) 282 { 283 QTAILQ_REMOVE(&net_clients, nc, next); 284 285 if (nc->info->cleanup) { 286 nc->info->cleanup(nc); 287 } 288 } 289 290 static void qemu_free_net_client(NetClientState *nc) 291 { 292 if (nc->send_queue) { 293 qemu_del_net_queue(nc->send_queue); 294 } 295 if (nc->peer) { 296 nc->peer->peer = NULL; 297 } 298 g_free(nc->name); 299 g_free(nc->model); 300 if (nc->destructor) { 301 nc->destructor(nc); 302 } 303 } 304 305 void qemu_del_net_client(NetClientState *nc) 306 { 307 NetClientState *ncs[MAX_QUEUE_NUM]; 308 int queues, i; 309 310 /* If the NetClientState belongs to a multiqueue backend, we will change all 311 * other NetClientStates also. 312 */ 313 queues = qemu_find_net_clients_except(nc->name, ncs, 314 NET_CLIENT_OPTIONS_KIND_NIC, 315 MAX_QUEUE_NUM); 316 assert(queues != 0); 317 318 /* If there is a peer NIC, delete and cleanup client, but do not free. */ 319 if (nc->peer && nc->peer->info->type == NET_CLIENT_OPTIONS_KIND_NIC) { 320 NICState *nic = qemu_get_nic(nc->peer); 321 if (nic->peer_deleted) { 322 return; 323 } 324 nic->peer_deleted = true; 325 326 for (i = 0; i < queues; i++) { 327 ncs[i]->peer->link_down = true; 328 } 329 330 if (nc->peer->info->link_status_changed) { 331 nc->peer->info->link_status_changed(nc->peer); 332 } 333 334 for (i = 0; i < queues; i++) { 335 qemu_cleanup_net_client(ncs[i]); 336 } 337 338 return; 339 } 340 341 assert(nc->info->type != NET_CLIENT_OPTIONS_KIND_NIC); 342 343 for (i = 0; i < queues; i++) { 344 qemu_cleanup_net_client(ncs[i]); 345 qemu_free_net_client(ncs[i]); 346 } 347 } 348 349 void qemu_del_nic(NICState *nic) 350 { 351 int i, queues = MAX(nic->conf->queues, 1); 352 353 /* If this is a peer NIC and peer has already been deleted, free it now. */ 354 if (nic->peer_deleted) { 355 for (i = 0; i < queues; i++) { 356 qemu_free_net_client(qemu_get_subqueue(nic, i)->peer); 357 } 358 } 359 360 for (i = queues - 1; i >= 0; i--) { 361 NetClientState *nc = qemu_get_subqueue(nic, i); 362 363 qemu_cleanup_net_client(nc); 364 qemu_free_net_client(nc); 365 } 366 367 g_free(nic); 368 } 369 370 void qemu_foreach_nic(qemu_nic_foreach func, void *opaque) 371 { 372 NetClientState *nc; 373 374 QTAILQ_FOREACH(nc, &net_clients, next) { 375 if (nc->info->type == NET_CLIENT_OPTIONS_KIND_NIC) { 376 if (nc->queue_index == 0) { 377 func(qemu_get_nic(nc), opaque); 378 } 379 } 380 } 381 } 382 383 int qemu_can_send_packet(NetClientState *sender) 384 { 385 if (!sender->peer) { 386 return 1; 387 } 388 389 if (sender->peer->receive_disabled) { 390 return 0; 391 } else if (sender->peer->info->can_receive && 392 !sender->peer->info->can_receive(sender->peer)) { 393 return 0; 394 } 395 return 1; 396 } 397 398 ssize_t qemu_deliver_packet(NetClientState *sender, 399 unsigned flags, 400 const uint8_t *data, 401 size_t size, 402 void *opaque) 403 { 404 NetClientState *nc = opaque; 405 ssize_t ret; 406 407 if (nc->link_down) { 408 return size; 409 } 410 411 if (nc->receive_disabled) { 412 return 0; 413 } 414 415 if (flags & QEMU_NET_PACKET_FLAG_RAW && nc->info->receive_raw) { 416 ret = nc->info->receive_raw(nc, data, size); 417 } else { 418 ret = nc->info->receive(nc, data, size); 419 } 420 421 if (ret == 0) { 422 nc->receive_disabled = 1; 423 }; 424 425 return ret; 426 } 427 428 void qemu_purge_queued_packets(NetClientState *nc) 429 { 430 if (!nc->peer) { 431 return; 432 } 433 434 qemu_net_queue_purge(nc->peer->send_queue, nc); 435 } 436 437 void qemu_flush_queued_packets(NetClientState *nc) 438 { 439 nc->receive_disabled = 0; 440 441 if (nc->peer && nc->peer->info->type == NET_CLIENT_OPTIONS_KIND_HUBPORT) { 442 if (net_hub_flush(nc->peer)) { 443 qemu_notify_event(); 444 } 445 return; 446 } 447 if (qemu_net_queue_flush(nc->send_queue)) { 448 /* We emptied the queue successfully, signal to the IO thread to repoll 449 * the file descriptor (for tap, for example). 450 */ 451 qemu_notify_event(); 452 } 453 } 454 455 static ssize_t qemu_send_packet_async_with_flags(NetClientState *sender, 456 unsigned flags, 457 const uint8_t *buf, int size, 458 NetPacketSent *sent_cb) 459 { 460 NetQueue *queue; 461 462 #ifdef DEBUG_NET 463 printf("qemu_send_packet_async:\n"); 464 hex_dump(stdout, buf, size); 465 #endif 466 467 if (sender->link_down || !sender->peer) { 468 return size; 469 } 470 471 queue = sender->peer->send_queue; 472 473 return qemu_net_queue_send(queue, sender, flags, buf, size, sent_cb); 474 } 475 476 ssize_t qemu_send_packet_async(NetClientState *sender, 477 const uint8_t *buf, int size, 478 NetPacketSent *sent_cb) 479 { 480 return qemu_send_packet_async_with_flags(sender, QEMU_NET_PACKET_FLAG_NONE, 481 buf, size, sent_cb); 482 } 483 484 void qemu_send_packet(NetClientState *nc, const uint8_t *buf, int size) 485 { 486 qemu_send_packet_async(nc, buf, size, NULL); 487 } 488 489 ssize_t qemu_send_packet_raw(NetClientState *nc, const uint8_t *buf, int size) 490 { 491 return qemu_send_packet_async_with_flags(nc, QEMU_NET_PACKET_FLAG_RAW, 492 buf, size, NULL); 493 } 494 495 static ssize_t nc_sendv_compat(NetClientState *nc, const struct iovec *iov, 496 int iovcnt) 497 { 498 uint8_t buffer[NET_BUFSIZE]; 499 size_t offset; 500 501 offset = iov_to_buf(iov, iovcnt, 0, buffer, sizeof(buffer)); 502 503 return nc->info->receive(nc, buffer, offset); 504 } 505 506 ssize_t qemu_deliver_packet_iov(NetClientState *sender, 507 unsigned flags, 508 const struct iovec *iov, 509 int iovcnt, 510 void *opaque) 511 { 512 NetClientState *nc = opaque; 513 int ret; 514 515 if (nc->link_down) { 516 return iov_size(iov, iovcnt); 517 } 518 519 if (nc->receive_disabled) { 520 return 0; 521 } 522 523 if (nc->info->receive_iov) { 524 ret = nc->info->receive_iov(nc, iov, iovcnt); 525 } else { 526 ret = nc_sendv_compat(nc, iov, iovcnt); 527 } 528 529 if (ret == 0) { 530 nc->receive_disabled = 1; 531 } 532 533 return ret; 534 } 535 536 ssize_t qemu_sendv_packet_async(NetClientState *sender, 537 const struct iovec *iov, int iovcnt, 538 NetPacketSent *sent_cb) 539 { 540 NetQueue *queue; 541 542 if (sender->link_down || !sender->peer) { 543 return iov_size(iov, iovcnt); 544 } 545 546 queue = sender->peer->send_queue; 547 548 return qemu_net_queue_send_iov(queue, sender, 549 QEMU_NET_PACKET_FLAG_NONE, 550 iov, iovcnt, sent_cb); 551 } 552 553 ssize_t 554 qemu_sendv_packet(NetClientState *nc, const struct iovec *iov, int iovcnt) 555 { 556 return qemu_sendv_packet_async(nc, iov, iovcnt, NULL); 557 } 558 559 NetClientState *qemu_find_netdev(const char *id) 560 { 561 NetClientState *nc; 562 563 QTAILQ_FOREACH(nc, &net_clients, next) { 564 if (nc->info->type == NET_CLIENT_OPTIONS_KIND_NIC) 565 continue; 566 if (!strcmp(nc->name, id)) { 567 return nc; 568 } 569 } 570 571 return NULL; 572 } 573 574 int qemu_find_net_clients_except(const char *id, NetClientState **ncs, 575 NetClientOptionsKind type, int max) 576 { 577 NetClientState *nc; 578 int ret = 0; 579 580 QTAILQ_FOREACH(nc, &net_clients, next) { 581 if (nc->info->type == type) { 582 continue; 583 } 584 if (!strcmp(nc->name, id)) { 585 if (ret < max) { 586 ncs[ret] = nc; 587 } 588 ret++; 589 } 590 } 591 592 return ret; 593 } 594 595 static int nic_get_free_idx(void) 596 { 597 int index; 598 599 for (index = 0; index < MAX_NICS; index++) 600 if (!nd_table[index].used) 601 return index; 602 return -1; 603 } 604 605 int qemu_show_nic_models(const char *arg, const char *const *models) 606 { 607 int i; 608 609 if (!arg || !is_help_option(arg)) { 610 return 0; 611 } 612 613 fprintf(stderr, "qemu: Supported NIC models: "); 614 for (i = 0 ; models[i]; i++) 615 fprintf(stderr, "%s%c", models[i], models[i+1] ? ',' : '\n'); 616 return 1; 617 } 618 619 void qemu_check_nic_model(NICInfo *nd, const char *model) 620 { 621 const char *models[2]; 622 623 models[0] = model; 624 models[1] = NULL; 625 626 if (qemu_show_nic_models(nd->model, models)) 627 exit(0); 628 if (qemu_find_nic_model(nd, models, model) < 0) 629 exit(1); 630 } 631 632 int qemu_find_nic_model(NICInfo *nd, const char * const *models, 633 const char *default_model) 634 { 635 int i; 636 637 if (!nd->model) 638 nd->model = g_strdup(default_model); 639 640 for (i = 0 ; models[i]; i++) { 641 if (strcmp(nd->model, models[i]) == 0) 642 return i; 643 } 644 645 error_report("Unsupported NIC model: %s", nd->model); 646 return -1; 647 } 648 649 static int net_init_nic(const NetClientOptions *opts, const char *name, 650 NetClientState *peer) 651 { 652 int idx; 653 NICInfo *nd; 654 const NetLegacyNicOptions *nic; 655 656 assert(opts->kind == NET_CLIENT_OPTIONS_KIND_NIC); 657 nic = opts->nic; 658 659 idx = nic_get_free_idx(); 660 if (idx == -1 || nb_nics >= MAX_NICS) { 661 error_report("Too Many NICs"); 662 return -1; 663 } 664 665 nd = &nd_table[idx]; 666 667 memset(nd, 0, sizeof(*nd)); 668 669 if (nic->has_netdev) { 670 nd->netdev = qemu_find_netdev(nic->netdev); 671 if (!nd->netdev) { 672 error_report("netdev '%s' not found", nic->netdev); 673 return -1; 674 } 675 } else { 676 assert(peer); 677 nd->netdev = peer; 678 } 679 nd->name = g_strdup(name); 680 if (nic->has_model) { 681 nd->model = g_strdup(nic->model); 682 } 683 if (nic->has_addr) { 684 nd->devaddr = g_strdup(nic->addr); 685 } 686 687 if (nic->has_macaddr && 688 net_parse_macaddr(nd->macaddr.a, nic->macaddr) < 0) { 689 error_report("invalid syntax for ethernet address"); 690 return -1; 691 } 692 qemu_macaddr_default_if_unset(&nd->macaddr); 693 694 if (nic->has_vectors) { 695 if (nic->vectors > 0x7ffffff) { 696 error_report("invalid # of vectors: %"PRIu32, nic->vectors); 697 return -1; 698 } 699 nd->nvectors = nic->vectors; 700 } else { 701 nd->nvectors = DEV_NVECTORS_UNSPECIFIED; 702 } 703 704 nd->used = 1; 705 nb_nics++; 706 707 return idx; 708 } 709 710 711 static int (* const net_client_init_fun[NET_CLIENT_OPTIONS_KIND_MAX])( 712 const NetClientOptions *opts, 713 const char *name, 714 NetClientState *peer) = { 715 [NET_CLIENT_OPTIONS_KIND_NIC] = net_init_nic, 716 #ifdef CONFIG_SLIRP 717 [NET_CLIENT_OPTIONS_KIND_USER] = net_init_slirp, 718 #endif 719 [NET_CLIENT_OPTIONS_KIND_TAP] = net_init_tap, 720 [NET_CLIENT_OPTIONS_KIND_SOCKET] = net_init_socket, 721 #ifdef CONFIG_VDE 722 [NET_CLIENT_OPTIONS_KIND_VDE] = net_init_vde, 723 #endif 724 [NET_CLIENT_OPTIONS_KIND_DUMP] = net_init_dump, 725 #ifdef CONFIG_NET_BRIDGE 726 [NET_CLIENT_OPTIONS_KIND_BRIDGE] = net_init_bridge, 727 #endif 728 [NET_CLIENT_OPTIONS_KIND_HUBPORT] = net_init_hubport, 729 }; 730 731 732 static int net_client_init1(const void *object, int is_netdev, Error **errp) 733 { 734 union { 735 const Netdev *netdev; 736 const NetLegacy *net; 737 } u; 738 const NetClientOptions *opts; 739 const char *name; 740 741 if (is_netdev) { 742 u.netdev = object; 743 opts = u.netdev->opts; 744 name = u.netdev->id; 745 746 switch (opts->kind) { 747 #ifdef CONFIG_SLIRP 748 case NET_CLIENT_OPTIONS_KIND_USER: 749 #endif 750 case NET_CLIENT_OPTIONS_KIND_TAP: 751 case NET_CLIENT_OPTIONS_KIND_SOCKET: 752 #ifdef CONFIG_VDE 753 case NET_CLIENT_OPTIONS_KIND_VDE: 754 #endif 755 #ifdef CONFIG_NET_BRIDGE 756 case NET_CLIENT_OPTIONS_KIND_BRIDGE: 757 #endif 758 case NET_CLIENT_OPTIONS_KIND_HUBPORT: 759 break; 760 761 default: 762 error_set(errp, QERR_INVALID_PARAMETER_VALUE, "type", 763 "a netdev backend type"); 764 return -1; 765 } 766 } else { 767 u.net = object; 768 opts = u.net->opts; 769 /* missing optional values have been initialized to "all bits zero" */ 770 name = u.net->has_id ? u.net->id : u.net->name; 771 } 772 773 if (net_client_init_fun[opts->kind]) { 774 NetClientState *peer = NULL; 775 776 /* Do not add to a vlan if it's a -netdev or a nic with a netdev= 777 * parameter. */ 778 if (!is_netdev && 779 (opts->kind != NET_CLIENT_OPTIONS_KIND_NIC || 780 !opts->nic->has_netdev)) { 781 peer = net_hub_add_port(u.net->has_vlan ? u.net->vlan : 0, NULL); 782 } 783 784 if (net_client_init_fun[opts->kind](opts, name, peer) < 0) { 785 /* TODO push error reporting into init() methods */ 786 error_set(errp, QERR_DEVICE_INIT_FAILED, 787 NetClientOptionsKind_lookup[opts->kind]); 788 return -1; 789 } 790 } 791 return 0; 792 } 793 794 795 static void net_visit(Visitor *v, int is_netdev, void **object, Error **errp) 796 { 797 if (is_netdev) { 798 visit_type_Netdev(v, (Netdev **)object, NULL, errp); 799 } else { 800 visit_type_NetLegacy(v, (NetLegacy **)object, NULL, errp); 801 } 802 } 803 804 805 int net_client_init(QemuOpts *opts, int is_netdev, Error **errp) 806 { 807 void *object = NULL; 808 Error *err = NULL; 809 int ret = -1; 810 811 { 812 OptsVisitor *ov = opts_visitor_new(opts); 813 814 net_visit(opts_get_visitor(ov), is_netdev, &object, &err); 815 opts_visitor_cleanup(ov); 816 } 817 818 if (!err) { 819 ret = net_client_init1(object, is_netdev, &err); 820 } 821 822 if (object) { 823 QapiDeallocVisitor *dv = qapi_dealloc_visitor_new(); 824 825 net_visit(qapi_dealloc_get_visitor(dv), is_netdev, &object, NULL); 826 qapi_dealloc_visitor_cleanup(dv); 827 } 828 829 error_propagate(errp, err); 830 return ret; 831 } 832 833 834 static int net_host_check_device(const char *device) 835 { 836 int i; 837 const char *valid_param_list[] = { "tap", "socket", "dump" 838 #ifdef CONFIG_NET_BRIDGE 839 , "bridge" 840 #endif 841 #ifdef CONFIG_SLIRP 842 ,"user" 843 #endif 844 #ifdef CONFIG_VDE 845 ,"vde" 846 #endif 847 }; 848 for (i = 0; i < sizeof(valid_param_list) / sizeof(char *); i++) { 849 if (!strncmp(valid_param_list[i], device, 850 strlen(valid_param_list[i]))) 851 return 1; 852 } 853 854 return 0; 855 } 856 857 void net_host_device_add(Monitor *mon, const QDict *qdict) 858 { 859 const char *device = qdict_get_str(qdict, "device"); 860 const char *opts_str = qdict_get_try_str(qdict, "opts"); 861 Error *local_err = NULL; 862 QemuOpts *opts; 863 864 if (!net_host_check_device(device)) { 865 monitor_printf(mon, "invalid host network device %s\n", device); 866 return; 867 } 868 869 opts = qemu_opts_parse(qemu_find_opts("net"), opts_str ? opts_str : "", 0); 870 if (!opts) { 871 return; 872 } 873 874 qemu_opt_set(opts, "type", device); 875 876 net_client_init(opts, 0, &local_err); 877 if (error_is_set(&local_err)) { 878 qerror_report_err(local_err); 879 error_free(local_err); 880 monitor_printf(mon, "adding host network device %s failed\n", device); 881 } 882 } 883 884 void net_host_device_remove(Monitor *mon, const QDict *qdict) 885 { 886 NetClientState *nc; 887 int vlan_id = qdict_get_int(qdict, "vlan_id"); 888 const char *device = qdict_get_str(qdict, "device"); 889 890 nc = net_hub_find_client_by_name(vlan_id, device); 891 if (!nc) { 892 return; 893 } 894 if (!net_host_check_device(nc->model)) { 895 monitor_printf(mon, "invalid host network device %s\n", device); 896 return; 897 } 898 qemu_del_net_client(nc); 899 } 900 901 void netdev_add(QemuOpts *opts, Error **errp) 902 { 903 net_client_init(opts, 1, errp); 904 } 905 906 int qmp_netdev_add(Monitor *mon, const QDict *qdict, QObject **ret) 907 { 908 Error *local_err = NULL; 909 QemuOptsList *opts_list; 910 QemuOpts *opts; 911 912 opts_list = qemu_find_opts_err("netdev", &local_err); 913 if (error_is_set(&local_err)) { 914 goto exit_err; 915 } 916 917 opts = qemu_opts_from_qdict(opts_list, qdict, &local_err); 918 if (error_is_set(&local_err)) { 919 goto exit_err; 920 } 921 922 netdev_add(opts, &local_err); 923 if (error_is_set(&local_err)) { 924 qemu_opts_del(opts); 925 goto exit_err; 926 } 927 928 return 0; 929 930 exit_err: 931 qerror_report_err(local_err); 932 error_free(local_err); 933 return -1; 934 } 935 936 void qmp_netdev_del(const char *id, Error **errp) 937 { 938 NetClientState *nc; 939 QemuOpts *opts; 940 941 nc = qemu_find_netdev(id); 942 if (!nc) { 943 error_set(errp, QERR_DEVICE_NOT_FOUND, id); 944 return; 945 } 946 947 opts = qemu_opts_find(qemu_find_opts_err("netdev", NULL), id); 948 if (!opts) { 949 error_setg(errp, "Device '%s' is not a netdev", id); 950 return; 951 } 952 953 qemu_del_net_client(nc); 954 qemu_opts_del(opts); 955 } 956 957 void print_net_client(Monitor *mon, NetClientState *nc) 958 { 959 monitor_printf(mon, "%s: index=%d,type=%s,%s\n", nc->name, 960 nc->queue_index, 961 NetClientOptionsKind_lookup[nc->info->type], 962 nc->info_str); 963 } 964 965 RxFilterInfoList *qmp_query_rx_filter(bool has_name, const char *name, 966 Error **errp) 967 { 968 NetClientState *nc; 969 RxFilterInfoList *filter_list = NULL, *last_entry = NULL; 970 971 QTAILQ_FOREACH(nc, &net_clients, next) { 972 RxFilterInfoList *entry; 973 RxFilterInfo *info; 974 975 if (has_name && strcmp(nc->name, name) != 0) { 976 continue; 977 } 978 979 /* only query rx-filter information of NIC */ 980 if (nc->info->type != NET_CLIENT_OPTIONS_KIND_NIC) { 981 if (has_name) { 982 error_setg(errp, "net client(%s) isn't a NIC", name); 983 break; 984 } 985 continue; 986 } 987 988 if (nc->info->query_rx_filter) { 989 info = nc->info->query_rx_filter(nc); 990 entry = g_malloc0(sizeof(*entry)); 991 entry->value = info; 992 993 if (!filter_list) { 994 filter_list = entry; 995 } else { 996 last_entry->next = entry; 997 } 998 last_entry = entry; 999 } else if (has_name) { 1000 error_setg(errp, "net client(%s) doesn't support" 1001 " rx-filter querying", name); 1002 break; 1003 } 1004 } 1005 1006 if (filter_list == NULL && !error_is_set(errp) && has_name) { 1007 error_setg(errp, "invalid net client name: %s", name); 1008 } 1009 1010 return filter_list; 1011 } 1012 1013 void do_info_network(Monitor *mon, const QDict *qdict) 1014 { 1015 NetClientState *nc, *peer; 1016 NetClientOptionsKind type; 1017 1018 net_hub_info(mon); 1019 1020 QTAILQ_FOREACH(nc, &net_clients, next) { 1021 peer = nc->peer; 1022 type = nc->info->type; 1023 1024 /* Skip if already printed in hub info */ 1025 if (net_hub_id_for_client(nc, NULL) == 0) { 1026 continue; 1027 } 1028 1029 if (!peer || type == NET_CLIENT_OPTIONS_KIND_NIC) { 1030 print_net_client(mon, nc); 1031 } /* else it's a netdev connected to a NIC, printed with the NIC */ 1032 if (peer && type == NET_CLIENT_OPTIONS_KIND_NIC) { 1033 monitor_printf(mon, " \\ "); 1034 print_net_client(mon, peer); 1035 } 1036 } 1037 } 1038 1039 void qmp_set_link(const char *name, bool up, Error **errp) 1040 { 1041 NetClientState *ncs[MAX_QUEUE_NUM]; 1042 NetClientState *nc; 1043 int queues, i; 1044 1045 queues = qemu_find_net_clients_except(name, ncs, 1046 NET_CLIENT_OPTIONS_KIND_MAX, 1047 MAX_QUEUE_NUM); 1048 1049 if (queues == 0) { 1050 error_set(errp, QERR_DEVICE_NOT_FOUND, name); 1051 return; 1052 } 1053 nc = ncs[0]; 1054 1055 for (i = 0; i < queues; i++) { 1056 ncs[i]->link_down = !up; 1057 } 1058 1059 if (nc->info->link_status_changed) { 1060 nc->info->link_status_changed(nc); 1061 } 1062 1063 /* Notify peer. Don't update peer link status: this makes it possible to 1064 * disconnect from host network without notifying the guest. 1065 * FIXME: is disconnected link status change operation useful? 1066 * 1067 * Current behaviour is compatible with qemu vlans where there could be 1068 * multiple clients that can still communicate with each other in 1069 * disconnected mode. For now maintain this compatibility. */ 1070 if (nc->peer && nc->peer->info->link_status_changed) { 1071 nc->peer->info->link_status_changed(nc->peer); 1072 } 1073 } 1074 1075 void net_cleanup(void) 1076 { 1077 NetClientState *nc; 1078 1079 /* We may del multiple entries during qemu_del_net_client(), 1080 * so QTAILQ_FOREACH_SAFE() is also not safe here. 1081 */ 1082 while (!QTAILQ_EMPTY(&net_clients)) { 1083 nc = QTAILQ_FIRST(&net_clients); 1084 if (nc->info->type == NET_CLIENT_OPTIONS_KIND_NIC) { 1085 qemu_del_nic(qemu_get_nic(nc)); 1086 } else { 1087 qemu_del_net_client(nc); 1088 } 1089 } 1090 } 1091 1092 void net_check_clients(void) 1093 { 1094 NetClientState *nc; 1095 int i; 1096 1097 /* Don't warn about the default network setup that you get if 1098 * no command line -net or -netdev options are specified. There 1099 * are two cases that we would otherwise complain about: 1100 * (1) board doesn't support a NIC but the implicit "-net nic" 1101 * requested one 1102 * (2) CONFIG_SLIRP not set, in which case the implicit "-net nic" 1103 * sets up a nic that isn't connected to anything. 1104 */ 1105 if (default_net) { 1106 return; 1107 } 1108 1109 net_hub_check_clients(); 1110 1111 QTAILQ_FOREACH(nc, &net_clients, next) { 1112 if (!nc->peer) { 1113 fprintf(stderr, "Warning: %s %s has no peer\n", 1114 nc->info->type == NET_CLIENT_OPTIONS_KIND_NIC ? 1115 "nic" : "netdev", nc->name); 1116 } 1117 } 1118 1119 /* Check that all NICs requested via -net nic actually got created. 1120 * NICs created via -device don't need to be checked here because 1121 * they are always instantiated. 1122 */ 1123 for (i = 0; i < MAX_NICS; i++) { 1124 NICInfo *nd = &nd_table[i]; 1125 if (nd->used && !nd->instantiated) { 1126 fprintf(stderr, "Warning: requested NIC (%s, model %s) " 1127 "was not created (not supported by this machine?)\n", 1128 nd->name ? nd->name : "anonymous", 1129 nd->model ? nd->model : "unspecified"); 1130 } 1131 } 1132 } 1133 1134 static int net_init_client(QemuOpts *opts, void *dummy) 1135 { 1136 Error *local_err = NULL; 1137 1138 net_client_init(opts, 0, &local_err); 1139 if (error_is_set(&local_err)) { 1140 qerror_report_err(local_err); 1141 error_free(local_err); 1142 return -1; 1143 } 1144 1145 return 0; 1146 } 1147 1148 static int net_init_netdev(QemuOpts *opts, void *dummy) 1149 { 1150 Error *local_err = NULL; 1151 int ret; 1152 1153 ret = net_client_init(opts, 1, &local_err); 1154 if (error_is_set(&local_err)) { 1155 qerror_report_err(local_err); 1156 error_free(local_err); 1157 return -1; 1158 } 1159 1160 return ret; 1161 } 1162 1163 int net_init_clients(void) 1164 { 1165 QemuOptsList *net = qemu_find_opts("net"); 1166 1167 if (default_net) { 1168 /* if no clients, we use a default config */ 1169 qemu_opts_set(net, NULL, "type", "nic"); 1170 #ifdef CONFIG_SLIRP 1171 qemu_opts_set(net, NULL, "type", "user"); 1172 #endif 1173 } 1174 1175 QTAILQ_INIT(&net_clients); 1176 1177 if (qemu_opts_foreach(qemu_find_opts("netdev"), net_init_netdev, NULL, 1) == -1) 1178 return -1; 1179 1180 if (qemu_opts_foreach(net, net_init_client, NULL, 1) == -1) { 1181 return -1; 1182 } 1183 1184 return 0; 1185 } 1186 1187 int net_client_parse(QemuOptsList *opts_list, const char *optarg) 1188 { 1189 #if defined(CONFIG_SLIRP) 1190 int ret; 1191 if (net_slirp_parse_legacy(opts_list, optarg, &ret)) { 1192 return ret; 1193 } 1194 #endif 1195 1196 if (!qemu_opts_parse(opts_list, optarg, 1)) { 1197 return -1; 1198 } 1199 1200 default_net = 0; 1201 return 0; 1202 } 1203 1204 /* From FreeBSD */ 1205 /* XXX: optimize */ 1206 unsigned compute_mcast_idx(const uint8_t *ep) 1207 { 1208 uint32_t crc; 1209 int carry, i, j; 1210 uint8_t b; 1211 1212 crc = 0xffffffff; 1213 for (i = 0; i < 6; i++) { 1214 b = *ep++; 1215 for (j = 0; j < 8; j++) { 1216 carry = ((crc & 0x80000000L) ? 1 : 0) ^ (b & 0x01); 1217 crc <<= 1; 1218 b >>= 1; 1219 if (carry) { 1220 crc = ((crc ^ POLYNOMIAL) | carry); 1221 } 1222 } 1223 } 1224 return crc >> 26; 1225 } 1226 1227 QemuOptsList qemu_netdev_opts = { 1228 .name = "netdev", 1229 .implied_opt_name = "type", 1230 .head = QTAILQ_HEAD_INITIALIZER(qemu_netdev_opts.head), 1231 .desc = { 1232 /* 1233 * no elements => accept any params 1234 * validation will happen later 1235 */ 1236 { /* end of list */ } 1237 }, 1238 }; 1239 1240 QemuOptsList qemu_net_opts = { 1241 .name = "net", 1242 .implied_opt_name = "type", 1243 .head = QTAILQ_HEAD_INITIALIZER(qemu_net_opts.head), 1244 .desc = { 1245 /* 1246 * no elements => accept any params 1247 * validation will happen later 1248 */ 1249 { /* end of list */ } 1250 }, 1251 }; 1252