chardev/char.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 "qemu/osdep.h"
  25 #include "qemu-common.h"
  26 #include "qemu/cutils.h"
  27 #include "monitor/monitor.h"
  28 #include "sysemu/sysemu.h"
  29 #include "sysemu/block-backend.h"
  30 #include "qemu/error-report.h"
  31 #include "qemu/timer.h"
  32 #include "sysemu/char.h"
  33 #include "hw/usb.h"
  34 #include "qmp-commands.h"
  35 #include "qapi/clone-visitor.h"
  36 #include "qapi-visit.h"
  37 #include "qemu/base64.h"
  38 #include "io/channel-socket.h"
  39 #include "io/channel-file.h"
  40 #include "io/channel-tls.h"
  41 #include "sysemu/replay.h"
  42 #include "qemu/help_option.h"
  43
  44 #include <zlib.h>
  45
  46 #ifndef _WIN32
  47 #include <sys/times.h>
  48 #include <sys/wait.h>
  49 #include <termios.h>
  50 #include <sys/ioctl.h>
  51 #include <sys/resource.h>
  52 #include <sys/socket.h>
  53 #include <netinet/in.h>
  54 #include <net/if.h>
  55 #include <arpa/inet.h>
  56 #include <netdb.h>
  57 #include <sys/select.h>
  58 #ifdef CONFIG_BSD
  59 #if defined(__FreeBSD__) || defined(__FreeBSD_kernel__)
  60 #include <dev/ppbus/ppi.h>
  61 #include <dev/ppbus/ppbconf.h>
  62 #elif defined(__DragonFly__)
  63 #include <dev/misc/ppi/ppi.h>
  64 #include <bus/ppbus/ppbconf.h>
  65 #endif
  66 #else
  67 #ifdef __linux__
  68 #include <linux/ppdev.h>
  69 #include <linux/parport.h>
  70 #endif
  71 #ifdef __sun__
  72 #include <sys/ethernet.h>
  73 #include <sys/sockio.h>
  74 #include <netinet/arp.h>
  75 #include <netinet/in.h>
  76 #include <netinet/in_systm.h>
  77 #include <netinet/ip.h>
  78 #include <netinet/ip_icmp.h> // must come after ip.h
  79 #include <netinet/udp.h>
  80 #include <netinet/tcp.h>
  81 #endif
  82 #endif
  83 #endif
  84
  85 #include "qemu/sockets.h"
  86 #include "ui/qemu-spice.h"
  87
  88 #include "char-mux.h"
  89
  90 #define TCP_MAX_FDS 16
  91
  92 /***********************************************************/
  93 /* Socket address helpers */
  94
  95 static char *SocketAddress_to_str(const char *prefix, SocketAddress *addr,
  96                                   bool is_listen, bool is_telnet)
  97 {
  98     switch (addr->type) {
  99     case SOCKET_ADDRESS_KIND_INET:
 100         return g_strdup_printf("%s%s:%s:%s%s", prefix,
 101                                is_telnet ? "telnet" : "tcp",
 102                                addr->u.inet.data->host,
 103                                addr->u.inet.data->port,
 104                                is_listen ? ",server" : "");
 105         break;
 106     case SOCKET_ADDRESS_KIND_UNIX:
 107         return g_strdup_printf("%sunix:%s%s", prefix,
 108                                addr->u.q_unix.data->path,
 109                                is_listen ? ",server" : "");
 110         break;
 111     case SOCKET_ADDRESS_KIND_FD:
 112         return g_strdup_printf("%sfd:%s%s", prefix, addr->u.fd.data->str,
 113                                is_listen ? ",server" : "");
 114         break;
 115     default:
 116         abort();
 117     }
 118 }
 119
 120 static char *sockaddr_to_str(struct sockaddr_storage *ss, socklen_t ss_len,
 121                              struct sockaddr_storage *ps, socklen_t ps_len,
 122                              bool is_listen, bool is_telnet)
 123 {
 124     char shost[NI_MAXHOST], sserv[NI_MAXSERV];
 125     char phost[NI_MAXHOST], pserv[NI_MAXSERV];
 126     const char *left = "", *right = "";
 127
 128     switch (ss->ss_family) {
 129 #ifndef _WIN32
 130     case AF_UNIX:
 131         return g_strdup_printf("unix:%s%s",
 132                                ((struct sockaddr_un *)(ss))->sun_path,
 133                                is_listen ? ",server" : "");
 134 #endif
 135     case AF_INET6:
 136         left  = "[";
 137         right = "]";
 138         /* fall through */
 139     case AF_INET:
 140         getnameinfo((struct sockaddr *) ss, ss_len, shost, sizeof(shost),
 141                     sserv, sizeof(sserv), NI_NUMERICHOST | NI_NUMERICSERV);
 142         getnameinfo((struct sockaddr *) ps, ps_len, phost, sizeof(phost),
 143                     pserv, sizeof(pserv), NI_NUMERICHOST | NI_NUMERICSERV);
 144         return g_strdup_printf("%s:%s%s%s:%s%s <-> %s%s%s:%s",
 145                                is_telnet ? "telnet" : "tcp",
 146                                left, shost, right, sserv,
 147                                is_listen ? ",server" : "",
 148                                left, phost, right, pserv);
 149
 150     default:
 151         return g_strdup_printf("unknown");
 152     }
 153 }
 154
 155 /***********************************************************/
 156 /* character device */
 157
 158 static QTAILQ_HEAD(ChardevHead, Chardev) chardevs =
 159     QTAILQ_HEAD_INITIALIZER(chardevs);
 160
 161 void qemu_chr_be_event(Chardev *s, int event)
 162 {
 163     CharBackend *be = s->be;
 164
 165     /* Keep track if the char device is open */
 166     switch (event) {
 167         case CHR_EVENT_OPENED:
 168             s->be_open = 1;
 169             break;
 170         case CHR_EVENT_CLOSED:
 171             s->be_open = 0;
 172             break;
 173     }
 174
 175     if (!be || !be->chr_event) {
 176         return;
 177     }
 178
 179     be->chr_event(be->opaque, event);
 180 }
 181
 182 void qemu_chr_be_generic_open(Chardev *s)
 183 {
 184     qemu_chr_be_event(s, CHR_EVENT_OPENED);
 185 }
 186
 187
 188 /* Not reporting errors from writing to logfile, as logs are
 189  * defined to be "best effort" only */
 190 static void qemu_chr_fe_write_log(Chardev *s,
 191                                   const uint8_t *buf, size_t len)
 192 {
 193     size_t done = 0;
 194     ssize_t ret;
 195
 196     if (s->logfd < 0) {
 197         return;
 198     }
 199
 200     while (done < len) {
 201     retry:
 202         ret = write(s->logfd, buf + done, len - done);
 203         if (ret == -1 && errno == EAGAIN) {
 204             g_usleep(100);
 205             goto retry;
 206         }
 207
 208         if (ret <= 0) {
 209             return;
 210         }
 211         done += ret;
 212     }
 213 }
 214
 215 static int qemu_chr_fe_write_buffer(Chardev *s,
 216                                     const uint8_t *buf, int len, int *offset)
 217 {
 218     ChardevClass *cc = CHARDEV_GET_CLASS(s);
 219     int res = 0;
 220     *offset = 0;
 221
 222     qemu_mutex_lock(&s->chr_write_lock);
 223     while (*offset < len) {
 224     retry:
 225         res = cc->chr_write(s, buf + *offset, len - *offset);
 226         if (res < 0 && errno == EAGAIN) {
 227             g_usleep(100);
 228             goto retry;
 229         }
 230
 231         if (res <= 0) {
 232             break;
 233         }
 234
 235         *offset += res;
 236     }
 237     if (*offset > 0) {
 238         qemu_chr_fe_write_log(s, buf, *offset);
 239     }
 240     qemu_mutex_unlock(&s->chr_write_lock);
 241
 242     return res;
 243 }
 244
 245 static bool qemu_chr_replay(Chardev *chr)
 246 {
 247     return qemu_chr_has_feature(chr, QEMU_CHAR_FEATURE_REPLAY);
 248 }
 249
 250 int qemu_chr_fe_write(CharBackend *be, const uint8_t *buf, int len)
 251 {
 252     Chardev *s = be->chr;
 253     ChardevClass *cc;
 254     int ret;
 255
 256     if (!s) {
 257         return 0;
 258     }
 259
 260     if (qemu_chr_replay(s) && replay_mode == REPLAY_MODE_PLAY) {
 261         int offset;
 262         replay_char_write_event_load(&ret, &offset);
 263         assert(offset <= len);
 264         qemu_chr_fe_write_buffer(s, buf, offset, &offset);
 265         return ret;
 266     }
 267
 268     cc = CHARDEV_GET_CLASS(s);
 269     qemu_mutex_lock(&s->chr_write_lock);
 270     ret = cc->chr_write(s, buf, len);
 271
 272     if (ret > 0) {
 273         qemu_chr_fe_write_log(s, buf, ret);
 274     }
 275
 276     qemu_mutex_unlock(&s->chr_write_lock);
 277
 278     if (qemu_chr_replay(s) && replay_mode == REPLAY_MODE_RECORD) {
 279         replay_char_write_event_save(ret, ret < 0 ? 0 : ret);
 280     }
 281
 282     return ret;
 283 }
 284
 285 int qemu_chr_write_all(Chardev *s, const uint8_t *buf, int len)
 286 {
 287     int offset;
 288     int res;
 289
 290     if (qemu_chr_replay(s) && replay_mode == REPLAY_MODE_PLAY) {
 291         replay_char_write_event_load(&res, &offset);
 292         assert(offset <= len);
 293         qemu_chr_fe_write_buffer(s, buf, offset, &offset);
 294         return res;
 295     }
 296
 297     res = qemu_chr_fe_write_buffer(s, buf, len, &offset);
 298
 299     if (qemu_chr_replay(s) && replay_mode == REPLAY_MODE_RECORD) {
 300         replay_char_write_event_save(res, offset);
 301     }
 302
 303     if (res < 0) {
 304         return res;
 305     }
 306     return offset;
 307 }
 308
 309 int qemu_chr_fe_write_all(CharBackend *be, const uint8_t *buf, int len)
 310 {
 311     Chardev *s = be->chr;
 312
 313     if (!s) {
 314         return 0;
 315     }
 316
 317     return qemu_chr_write_all(s, buf, len);
 318 }
 319
 320 int qemu_chr_fe_read_all(CharBackend *be, uint8_t *buf, int len)
 321 {
 322     Chardev *s = be->chr;
 323     int offset = 0, counter = 10;
 324     int res;
 325
 326     if (!s || !CHARDEV_GET_CLASS(s)->chr_sync_read) {
 327         return 0;
 328     }
 329
 330     if (qemu_chr_replay(s) && replay_mode == REPLAY_MODE_PLAY) {
 331         return replay_char_read_all_load(buf);
 332     }
 333
 334     while (offset < len) {
 335     retry:
 336         res = CHARDEV_GET_CLASS(s)->chr_sync_read(s, buf + offset,
 337                                                   len - offset);
 338         if (res == -1 && errno == EAGAIN) {
 339             g_usleep(100);
 340             goto retry;
 341         }
 342
 343         if (res == 0) {
 344             break;
 345         }
 346
 347         if (res < 0) {
 348             if (qemu_chr_replay(s) && replay_mode == REPLAY_MODE_RECORD) {
 349                 replay_char_read_all_save_error(res);
 350             }
 351             return res;
 352         }
 353
 354         offset += res;
 355
 356         if (!counter--) {
 357             break;
 358         }
 359     }
 360
 361     if (qemu_chr_replay(s) && replay_mode == REPLAY_MODE_RECORD) {
 362         replay_char_read_all_save_buf(buf, offset);
 363     }
 364     return offset;
 365 }
 366
 367 int qemu_chr_fe_ioctl(CharBackend *be, int cmd, void *arg)
 368 {
 369     Chardev *s = be->chr;
 370     int res;
 371
 372     if (!s || !CHARDEV_GET_CLASS(s)->chr_ioctl || qemu_chr_replay(s)) {
 373         res = -ENOTSUP;
 374     } else {
 375         res = CHARDEV_GET_CLASS(s)->chr_ioctl(s, cmd, arg);
 376     }
 377
 378     return res;
 379 }
 380
 381 int qemu_chr_be_can_write(Chardev *s)
 382 {
 383     CharBackend *be = s->be;
 384
 385     if (!be || !be->chr_can_read) {
 386         return 0;
 387     }
 388
 389     return be->chr_can_read(be->opaque);
 390 }
 391
 392 void qemu_chr_be_write_impl(Chardev *s, uint8_t *buf, int len)
 393 {
 394     CharBackend *be = s->be;
 395
 396     if (be && be->chr_read) {
 397         be->chr_read(be->opaque, buf, len);
 398     }
 399 }
 400
 401 void qemu_chr_be_write(Chardev *s, uint8_t *buf, int len)
 402 {
 403     if (qemu_chr_replay(s)) {
 404         if (replay_mode == REPLAY_MODE_PLAY) {
 405             return;
 406         }
 407         replay_chr_be_write(s, buf, len);
 408     } else {
 409         qemu_chr_be_write_impl(s, buf, len);
 410     }
 411 }
 412
 413 int qemu_chr_fe_get_msgfd(CharBackend *be)
 414 {
 415     Chardev *s = be->chr;
 416     int fd;
 417     int res = (qemu_chr_fe_get_msgfds(be, &fd, 1) == 1) ? fd : -1;
 418     if (s && qemu_chr_replay(s)) {
 419         error_report("Replay: get msgfd is not supported "
 420                      "for serial devices yet");
 421         exit(1);
 422     }
 423     return res;
 424 }
 425
 426 int qemu_chr_fe_get_msgfds(CharBackend *be, int *fds, int len)
 427 {
 428     Chardev *s = be->chr;
 429
 430     if (!s) {
 431         return -1;
 432     }
 433
 434     return CHARDEV_GET_CLASS(s)->get_msgfds ?
 435         CHARDEV_GET_CLASS(s)->get_msgfds(s, fds, len) : -1;
 436 }
 437
 438 int qemu_chr_fe_set_msgfds(CharBackend *be, int *fds, int num)
 439 {
 440     Chardev *s = be->chr;
 441
 442     if (!s) {
 443         return -1;
 444     }
 445
 446     return CHARDEV_GET_CLASS(s)->set_msgfds ?
 447         CHARDEV_GET_CLASS(s)->set_msgfds(s, fds, num) : -1;
 448 }
 449
 450 int qemu_chr_add_client(Chardev *s, int fd)
 451 {
 452     return CHARDEV_GET_CLASS(s)->chr_add_client ?
 453         CHARDEV_GET_CLASS(s)->chr_add_client(s, fd) : -1;
 454 }
 455
 456 void qemu_chr_fe_accept_input(CharBackend *be)
 457 {
 458     Chardev *s = be->chr;
 459
 460     if (!s) {
 461         return;
 462     }
 463
 464     if (CHARDEV_GET_CLASS(s)->chr_accept_input) {
 465         CHARDEV_GET_CLASS(s)->chr_accept_input(s);
 466     }
 467     qemu_notify_event();
 468 }
 469
 470 void qemu_chr_fe_printf(CharBackend *be, const char *fmt, ...)
 471 {
 472     char buf[CHR_READ_BUF_LEN];
 473     va_list ap;
 474     va_start(ap, fmt);
 475     vsnprintf(buf, sizeof(buf), fmt, ap);
 476     /* XXX this blocks entire thread. Rewrite to use
 477      * qemu_chr_fe_write and background I/O callbacks */
 478     qemu_chr_fe_write_all(be, (uint8_t *)buf, strlen(buf));
 479     va_end(ap);
 480 }
 481
 482 static void remove_fd_in_watch(Chardev *chr);
 483
 484 static void qemu_char_open(Chardev *chr, ChardevBackend *backend,
 485                            bool *be_opened, Error **errp)
 486 {
 487     ChardevClass *cc = CHARDEV_GET_CLASS(chr);
 488     /* Any ChardevCommon member would work */
 489     ChardevCommon *common = backend ? backend->u.null.data : NULL;
 490
 491     if (common && common->has_logfile) {
 492         int flags = O_WRONLY | O_CREAT;
 493         if (common->has_logappend &&
 494             common->logappend) {
 495             flags |= O_APPEND;
 496         } else {
 497             flags |= O_TRUNC;
 498         }
 499         chr->logfd = qemu_open(common->logfile, flags, 0666);
 500         if (chr->logfd < 0) {
 501             error_setg_errno(errp, errno,
 502                              "Unable to open logfile %s",
 503                              common->logfile);
 504             return;
 505         }
 506     }
 507
 508     if (cc->open) {
 509         cc->open(chr, backend, be_opened, errp);
 510     }
 511 }
 512
 513 static void char_init(Object *obj)
 514 {
 515     Chardev *chr = CHARDEV(obj);
 516
 517     chr->logfd = -1;
 518     qemu_mutex_init(&chr->chr_write_lock);
 519 }
 520
 521 static int null_chr_write(Chardev *chr, const uint8_t *buf, int len)
 522 {
 523     return len;
 524 }
 525
 526 static void char_class_init(ObjectClass *oc, void *data)
 527 {
 528     ChardevClass *cc = CHARDEV_CLASS(oc);
 529
 530     cc->chr_write = null_chr_write;
 531 }
 532
 533 static void char_finalize(Object *obj)
 534 {
 535     Chardev *chr = CHARDEV(obj);
 536
 537     if (chr->be) {
 538         chr->be->chr = NULL;
 539     }
 540     g_free(chr->filename);
 541     g_free(chr->label);
 542     if (chr->logfd != -1) {
 543         close(chr->logfd);
 544     }
 545     qemu_mutex_destroy(&chr->chr_write_lock);
 546 }
 547
 548 static const TypeInfo char_type_info = {
 549     .name = TYPE_CHARDEV,
 550     .parent = TYPE_OBJECT,
 551     .instance_size = sizeof(Chardev),
 552     .instance_init = char_init,
 553     .instance_finalize = char_finalize,
 554     .abstract = true,
 555     .class_size = sizeof(ChardevClass),
 556     .class_init = char_class_init,
 557 };
 558
 559 /**
 560  * Called after processing of default and command-line-specified
 561  * chardevs to deliver CHR_EVENT_OPENED events to any FEs attached
 562  * to a mux chardev. This is done here to ensure that
 563  * output/prompts/banners are only displayed for the FE that has
 564  * focus when initial command-line processing/machine init is
 565  * completed.
 566  *
 567  * After this point, any new FE attached to any new or existing
 568  * mux will receive CHR_EVENT_OPENED notifications for the BE
 569  * immediately.
 570  */
 571 static void muxes_realize_done(Notifier *notifier, void *unused)
 572 {
 573     Chardev *chr;
 574
 575     QTAILQ_FOREACH(chr, &chardevs, next) {
 576         if (CHARDEV_IS_MUX(chr)) {
 577             MuxChardev *d = MUX_CHARDEV(chr);
 578             int i;
 579
 580             /* send OPENED to all already-attached FEs */
 581             for (i = 0; i < d->mux_cnt; i++) {
 582                 mux_chr_send_event(d, i, CHR_EVENT_OPENED);
 583             }
 584             /* mark mux as OPENED so any new FEs will immediately receive
 585              * OPENED event
 586              */
 587             qemu_chr_be_generic_open(chr);
 588         }
 589     }
 590     muxes_realized = true;
 591 }
 592
 593 static Notifier muxes_realize_notify = {
 594     .notify = muxes_realize_done,
 595 };
 596
 597 Chardev *qemu_chr_fe_get_driver(CharBackend *be)
 598 {
 599     return be->chr;
 600 }
 601
 602 bool qemu_chr_fe_init(CharBackend *b, Chardev *s, Error **errp)
 603 {
 604     int tag = 0;
 605
 606     if (CHARDEV_IS_MUX(s)) {
 607         MuxChardev *d = MUX_CHARDEV(s);
 608
 609         if (d->mux_cnt >= MAX_MUX) {
 610             goto unavailable;
 611         }
 612
 613         d->backends[d->mux_cnt] = b;
 614         tag = d->mux_cnt++;
 615     } else if (s->be) {
 616         goto unavailable;
 617     } else {
 618         s->be = b;
 619     }
 620
 621     b->fe_open = false;
 622     b->tag = tag;
 623     b->chr = s;
 624     return true;
 625
 626 unavailable:
 627     error_setg(errp, QERR_DEVICE_IN_USE, s->label);
 628     return false;
 629 }
 630
 631 static bool qemu_chr_is_busy(Chardev *s)
 632 {
 633     if (CHARDEV_IS_MUX(s)) {
 634         MuxChardev *d = MUX_CHARDEV(s);
 635         return d->mux_cnt >= 0;
 636     } else {
 637         return s->be != NULL;
 638     }
 639 }
 640
 641 void qemu_chr_fe_deinit(CharBackend *b)
 642 {
 643     assert(b);
 644
 645     if (b->chr) {
 646         qemu_chr_fe_set_handlers(b, NULL, NULL, NULL, NULL, NULL, true);
 647         if (b->chr->be == b) {
 648             b->chr->be = NULL;
 649         }
 650         if (CHARDEV_IS_MUX(b->chr)) {
 651             MuxChardev *d = MUX_CHARDEV(b->chr);
 652             d->backends[b->tag] = NULL;
 653         }
 654         b->chr = NULL;
 655     }
 656 }
 657
 658 void qemu_chr_fe_set_handlers(CharBackend *b,
 659                               IOCanReadHandler *fd_can_read,
 660                               IOReadHandler *fd_read,
 661                               IOEventHandler *fd_event,
 662                               void *opaque,
 663                               GMainContext *context,
 664                               bool set_open)
 665 {
 666     Chardev *s;
 667     ChardevClass *cc;
 668     int fe_open;
 669
 670     s = b->chr;
 671     if (!s) {
 672         return;
 673     }
 674
 675     cc = CHARDEV_GET_CLASS(s);
 676     if (!opaque && !fd_can_read && !fd_read && !fd_event) {
 677         fe_open = 0;
 678         remove_fd_in_watch(s);
 679     } else {
 680         fe_open = 1;
 681     }
 682     b->chr_can_read = fd_can_read;
 683     b->chr_read = fd_read;
 684     b->chr_event = fd_event;
 685     b->opaque = opaque;
 686     if (cc->chr_update_read_handler) {
 687         cc->chr_update_read_handler(s, context);
 688     }
 689
 690     if (set_open) {
 691         qemu_chr_fe_set_open(b, fe_open);
 692     }
 693
 694     if (fe_open) {
 695         qemu_chr_fe_take_focus(b);
 696         /* We're connecting to an already opened device, so let's make sure we
 697            also get the open event */
 698         if (s->be_open) {
 699             qemu_chr_be_generic_open(s);
 700         }
 701     }
 702
 703     if (CHARDEV_IS_MUX(s)) {
 704         mux_chr_set_handlers(s, context);
 705     }
 706 }
 707
 708 void qemu_chr_fe_take_focus(CharBackend *b)
 709 {
 710     if (!b->chr) {
 711         return;
 712     }
 713
 714     if (CHARDEV_IS_MUX(b->chr)) {
 715         mux_set_focus(b->chr, b->tag);
 716     }
 717 }
 718
 719 typedef struct IOWatchPoll
 720 {
 721     GSource parent;
 722
 723     QIOChannel *ioc;
 724     GSource *src;
 725
 726     IOCanReadHandler *fd_can_read;
 727     GSourceFunc fd_read;
 728     void *opaque;
 729     GMainContext *context;
 730 } IOWatchPoll;
 731
 732 static IOWatchPoll *io_watch_poll_from_source(GSource *source)
 733 {
 734     return container_of(source, IOWatchPoll, parent);
 735 }
 736
 737 static gboolean io_watch_poll_prepare(GSource *source,
 738                                       gint *timeout_)
 739 {
 740     IOWatchPoll *iwp = io_watch_poll_from_source(source);
 741     bool now_active = iwp->fd_can_read(iwp->opaque) > 0;
 742     bool was_active = iwp->src != NULL;
 743     if (was_active == now_active) {
 744         return FALSE;
 745     }
 746
 747     if (now_active) {
 748         iwp->src = qio_channel_create_watch(
 749             iwp->ioc, G_IO_IN | G_IO_ERR | G_IO_HUP | G_IO_NVAL);
 750         g_source_set_callback(iwp->src, iwp->fd_read, iwp->opaque, NULL);
 751         g_source_attach(iwp->src, iwp->context);
 752     } else {
 753         g_source_destroy(iwp->src);
 754         g_source_unref(iwp->src);
 755         iwp->src = NULL;
 756     }
 757     return FALSE;
 758 }
 759
 760 static gboolean io_watch_poll_check(GSource *source)
 761 {
 762     return FALSE;
 763 }
 764
 765 static gboolean io_watch_poll_dispatch(GSource *source, GSourceFunc callback,
 766                                        gpointer user_data)
 767 {
 768     abort();
 769 }
 770
 771 static void io_watch_poll_finalize(GSource *source)
 772 {
 773     /* Due to a glib bug, removing the last reference to a source
 774      * inside a finalize callback causes recursive locking (and a
 775      * deadlock).  This is not a problem inside other callbacks,
 776      * including dispatch callbacks, so we call io_remove_watch_poll
 777      * to remove this source.  At this point, iwp->src must
 778      * be NULL, or we would leak it.
 779      *
 780      * This would be solved much more elegantly by child sources,
 781      * but we support older glib versions that do not have them.
 782      */
 783     IOWatchPoll *iwp = io_watch_poll_from_source(source);
 784     assert(iwp->src == NULL);
 785 }
 786
 787 static GSourceFuncs io_watch_poll_funcs = {
 788     .prepare = io_watch_poll_prepare,
 789     .check = io_watch_poll_check,
 790     .dispatch = io_watch_poll_dispatch,
 791     .finalize = io_watch_poll_finalize,
 792 };
 793
 794 /* Can only be used for read */
 795 static guint io_add_watch_poll(Chardev *chr,
 796                                QIOChannel *ioc,
 797                                IOCanReadHandler *fd_can_read,
 798                                QIOChannelFunc fd_read,
 799                                gpointer user_data,
 800                                GMainContext *context)
 801 {
 802     IOWatchPoll *iwp;
 803     int tag;
 804     char *name;
 805
 806     iwp = (IOWatchPoll *) g_source_new(&io_watch_poll_funcs,
 807                                        sizeof(IOWatchPoll));
 808     iwp->fd_can_read = fd_can_read;
 809     iwp->opaque = user_data;
 810     iwp->ioc = ioc;
 811     iwp->fd_read = (GSourceFunc) fd_read;
 812     iwp->src = NULL;
 813     iwp->context = context;
 814
 815     name = g_strdup_printf("chardev-iowatch-%s", chr->label);
 816     g_source_set_name((GSource *)iwp, name);
 817     g_free(name);
 818
 819     tag = g_source_attach(&iwp->parent, context);
 820     g_source_unref(&iwp->parent);
 821     return tag;
 822 }
 823
 824 static void io_remove_watch_poll(guint tag)
 825 {
 826     GSource *source;
 827     IOWatchPoll *iwp;
 828
 829     g_return_if_fail (tag > 0);
 830
 831     source = g_main_context_find_source_by_id(NULL, tag);
 832     g_return_if_fail (source != NULL);
 833
 834     iwp = io_watch_poll_from_source(source);
 835     if (iwp->src) {
 836         g_source_destroy(iwp->src);
 837         g_source_unref(iwp->src);
 838         iwp->src = NULL;
 839     }
 840     g_source_destroy(&iwp->parent);
 841 }
 842
 843 static void remove_fd_in_watch(Chardev *chr)
 844 {
 845     if (chr->fd_in_tag) {
 846         io_remove_watch_poll(chr->fd_in_tag);
 847         chr->fd_in_tag = 0;
 848     }
 849 }
 850
 851
 852 static int io_channel_send_full(QIOChannel *ioc,
 853                                 const void *buf, size_t len,
 854                                 int *fds, size_t nfds)
 855 {
 856     size_t offset = 0;
 857
 858     while (offset < len) {
 859         ssize_t ret = 0;
 860         struct iovec iov = { .iov_base = (char *)buf + offset,
 861                              .iov_len = len - offset };
 862
 863         ret = qio_channel_writev_full(
 864             ioc, &iov, 1,
 865             fds, nfds, NULL);
 866         if (ret == QIO_CHANNEL_ERR_BLOCK) {
 867             if (offset) {
 868                 return offset;
 869             }
 870
 871             errno = EAGAIN;
 872             return -1;
 873         } else if (ret < 0) {
 874             errno = EINVAL;
 875             return -1;
 876         }
 877
 878         offset += ret;
 879     }
 880
 881     return offset;
 882 }
 883
 884
 885 #ifndef _WIN32
 886 static int io_channel_send(QIOChannel *ioc, const void *buf, size_t len)
 887 {
 888     return io_channel_send_full(ioc, buf, len, NULL, 0);
 889 }
 890
 891 typedef struct FDChardev {
 892     Chardev parent;
 893     Chardev *chr;
 894     QIOChannel *ioc_in, *ioc_out;
 895     int max_size;
 896 } FDChardev;
 897
 898 #define TYPE_CHARDEV_FD "chardev-fd"
 899 #define FD_CHARDEV(obj) OBJECT_CHECK(FDChardev, (obj), TYPE_CHARDEV_FD)
 900
 901 /* Called with chr_write_lock held.  */
 902 static int fd_chr_write(Chardev *chr, const uint8_t *buf, int len)
 903 {
 904     FDChardev *s = FD_CHARDEV(chr);
 905
 906     return io_channel_send(s->ioc_out, buf, len);
 907 }
 908
 909 static gboolean fd_chr_read(QIOChannel *chan, GIOCondition cond, void *opaque)
 910 {
 911     Chardev *chr = CHARDEV(opaque);
 912     FDChardev *s = FD_CHARDEV(opaque);
 913     int len;
 914     uint8_t buf[CHR_READ_BUF_LEN];
 915     ssize_t ret;
 916
 917     len = sizeof(buf);
 918     if (len > s->max_size) {
 919         len = s->max_size;
 920     }
 921     if (len == 0) {
 922         return TRUE;
 923     }
 924
 925     ret = qio_channel_read(
 926         chan, (gchar *)buf, len, NULL);
 927     if (ret == 0) {
 928         remove_fd_in_watch(chr);
 929         qemu_chr_be_event(chr, CHR_EVENT_CLOSED);
 930         return FALSE;
 931     }
 932     if (ret > 0) {
 933         qemu_chr_be_write(chr, buf, ret);
 934     }
 935
 936     return TRUE;
 937 }
 938
 939 static int fd_chr_read_poll(void *opaque)
 940 {
 941     Chardev *chr = CHARDEV(opaque);
 942     FDChardev *s = FD_CHARDEV(opaque);
 943
 944     s->max_size = qemu_chr_be_can_write(chr);
 945     return s->max_size;
 946 }
 947
 948 static GSource *fd_chr_add_watch(Chardev *chr, GIOCondition cond)
 949 {
 950     FDChardev *s = FD_CHARDEV(chr);
 951     return qio_channel_create_watch(s->ioc_out, cond);
 952 }
 953
 954 static void fd_chr_update_read_handler(Chardev *chr,
 955                                        GMainContext *context)
 956 {
 957     FDChardev *s = FD_CHARDEV(chr);
 958
 959     remove_fd_in_watch(chr);
 960     if (s->ioc_in) {
 961         chr->fd_in_tag = io_add_watch_poll(chr, s->ioc_in,
 962                                            fd_chr_read_poll,
 963                                            fd_chr_read, chr,
 964                                            context);
 965     }
 966 }
 967
 968 static void char_fd_finalize(Object *obj)
 969 {
 970     Chardev *chr = CHARDEV(obj);
 971     FDChardev *s = FD_CHARDEV(obj);
 972
 973     remove_fd_in_watch(chr);
 974     if (s->ioc_in) {
 975         object_unref(OBJECT(s->ioc_in));
 976     }
 977     if (s->ioc_out) {
 978         object_unref(OBJECT(s->ioc_out));
 979     }
 980
 981     qemu_chr_be_event(chr, CHR_EVENT_CLOSED);
 982 }
 983
 984 /* open a character device to a unix fd */
 985 static void qemu_chr_open_fd(Chardev *chr,
 986                              int fd_in, int fd_out)
 987 {
 988     FDChardev *s = FD_CHARDEV(chr);
 989     char *name;
 990
 991     s->ioc_in = QIO_CHANNEL(qio_channel_file_new_fd(fd_in));
 992     name = g_strdup_printf("chardev-file-in-%s", chr->label);
 993     qio_channel_set_name(QIO_CHANNEL(s->ioc_in), name);
 994     g_free(name);
 995     s->ioc_out = QIO_CHANNEL(qio_channel_file_new_fd(fd_out));
 996     name = g_strdup_printf("chardev-file-out-%s", chr->label);
 997     qio_channel_set_name(QIO_CHANNEL(s->ioc_out), name);
 998     g_free(name);
 999     qemu_set_nonblock(fd_out);
1000     s->chr = chr;
1001 }
1002
1003 static void char_fd_class_init(ObjectClass *oc, void *data)
1004 {
1005     ChardevClass *cc = CHARDEV_CLASS(oc);
1006
1007     cc->chr_add_watch = fd_chr_add_watch;
1008     cc->chr_write = fd_chr_write;
1009     cc->chr_update_read_handler = fd_chr_update_read_handler;
1010 }
1011
1012 static const TypeInfo char_fd_type_info = {
1013     .name = TYPE_CHARDEV_FD,
1014     .parent = TYPE_CHARDEV,
1015     .instance_size = sizeof(FDChardev),
1016     .instance_finalize = char_fd_finalize,
1017     .class_init = char_fd_class_init,
1018     .abstract = true,
1019 };
1020
1021 static void qemu_chr_open_pipe(Chardev *chr,
1022                                ChardevBackend *backend,
1023                                bool *be_opened,
1024                                Error **errp)
1025 {
1026     ChardevHostdev *opts = backend->u.pipe.data;
1027     int fd_in, fd_out;
1028     char *filename_in;
1029     char *filename_out;
1030     const char *filename = opts->device;
1031
1032     filename_in = g_strdup_printf("%s.in", filename);
1033     filename_out = g_strdup_printf("%s.out", filename);
1034     TFR(fd_in = qemu_open(filename_in, O_RDWR | O_BINARY));
1035     TFR(fd_out = qemu_open(filename_out, O_RDWR | O_BINARY));
1036     g_free(filename_in);
1037     g_free(filename_out);
1038     if (fd_in < 0 || fd_out < 0) {
1039         if (fd_in >= 0)
1040             close(fd_in);
1041         if (fd_out >= 0)
1042             close(fd_out);
1043         TFR(fd_in = fd_out = qemu_open(filename, O_RDWR | O_BINARY));
1044         if (fd_in < 0) {
1045             error_setg_file_open(errp, errno, filename);
1046             return;
1047         }
1048     }
1049     qemu_chr_open_fd(chr, fd_in, fd_out);
1050 }
1051
1052 /* init terminal so that we can grab keys */
1053 static struct termios oldtty;
1054 static int old_fd0_flags;
1055 static bool stdio_in_use;
1056 static bool stdio_allow_signal;
1057 static bool stdio_echo_state;
1058
1059 static void qemu_chr_set_echo_stdio(Chardev *chr, bool echo);
1060
1061 static void term_exit(void)
1062 {
1063     tcsetattr (0, TCSANOW, &oldtty);
1064     fcntl(0, F_SETFL, old_fd0_flags);
1065 }
1066
1067 static void term_stdio_handler(int sig)
1068 {
1069     /* restore echo after resume from suspend. */
1070     qemu_chr_set_echo_stdio(NULL, stdio_echo_state);
1071 }
1072
1073 static void qemu_chr_set_echo_stdio(Chardev *chr, bool echo)
1074 {
1075     struct termios tty;
1076
1077     stdio_echo_state = echo;
1078     tty = oldtty;
1079     if (!echo) {
1080         tty.c_iflag &= ~(IGNBRK|BRKINT|PARMRK|ISTRIP
1081                           |INLCR|IGNCR|ICRNL|IXON);
1082         tty.c_oflag |= OPOST;
1083         tty.c_lflag &= ~(ECHO|ECHONL|ICANON|IEXTEN);
1084         tty.c_cflag &= ~(CSIZE|PARENB);
1085         tty.c_cflag |= CS8;
1086         tty.c_cc[VMIN] = 1;
1087         tty.c_cc[VTIME] = 0;
1088     }
1089     if (!stdio_allow_signal)
1090         tty.c_lflag &= ~ISIG;
1091
1092     tcsetattr (0, TCSANOW, &tty);
1093 }
1094
1095 static void char_stdio_finalize(Object *obj)
1096 {
1097     term_exit();
1098 }
1099
1100 static void qemu_chr_open_stdio(Chardev *chr,
1101                                 ChardevBackend *backend,
1102                                 bool *be_opened,
1103                                 Error **errp)
1104 {
1105     ChardevStdio *opts = backend->u.stdio.data;
1106     struct sigaction act;
1107
1108     if (is_daemonized()) {
1109         error_setg(errp, "cannot use stdio with -daemonize");
1110         return;
1111     }
1112
1113     if (stdio_in_use) {
1114         error_setg(errp, "cannot use stdio by multiple character devices");
1115         return;
1116     }
1117
1118     stdio_in_use = true;
1119     old_fd0_flags = fcntl(0, F_GETFL);
1120     tcgetattr(0, &oldtty);
1121     qemu_set_nonblock(0);
1122     atexit(term_exit);
1123
1124     memset(&act, 0, sizeof(act));
1125     act.sa_handler = term_stdio_handler;
1126     sigaction(SIGCONT, &act, NULL);
1127
1128     qemu_chr_open_fd(chr, 0, 1);
1129
1130     if (opts->has_signal) {
1131         stdio_allow_signal = opts->signal;
1132     }
1133     qemu_chr_set_echo_stdio(chr, false);
1134 }
1135
1136 #if defined(__linux__) || defined(__sun__) || defined(__FreeBSD__) \
1137     || defined(__NetBSD__) || defined(__OpenBSD__) || defined(__DragonFly__) \
1138     || defined(__GLIBC__)
1139
1140 #define HAVE_CHARDEV_SERIAL 1
1141 #define HAVE_CHARDEV_PTY 1
1142
1143 typedef struct {
1144     Chardev parent;
1145     QIOChannel *ioc;
1146     int read_bytes;
1147
1148     /* Protected by the Chardev chr_write_lock.  */
1149     int connected;
1150     guint timer_tag;
1151     guint open_tag;
1152 } PtyChardev;
1153
1154 #define PTY_CHARDEV(obj) OBJECT_CHECK(PtyChardev, (obj), TYPE_CHARDEV_PTY)
1155
1156 static void pty_chr_update_read_handler_locked(Chardev *chr);
1157 static void pty_chr_state(Chardev *chr, int connected);
1158
1159 static gboolean pty_chr_timer(gpointer opaque)
1160 {
1161     struct Chardev *chr = CHARDEV(opaque);
1162     PtyChardev *s = PTY_CHARDEV(opaque);
1163
1164     qemu_mutex_lock(&chr->chr_write_lock);
1165     s->timer_tag = 0;
1166     s->open_tag = 0;
1167     if (!s->connected) {
1168         /* Next poll ... */
1169         pty_chr_update_read_handler_locked(chr);
1170     }
1171     qemu_mutex_unlock(&chr->chr_write_lock);
1172     return FALSE;
1173 }
1174
1175 /* Called with chr_write_lock held.  */
1176 static void pty_chr_rearm_timer(Chardev *chr, int ms)
1177 {
1178     PtyChardev *s = PTY_CHARDEV(chr);
1179     char *name;
1180
1181     if (s->timer_tag) {
1182         g_source_remove(s->timer_tag);
1183         s->timer_tag = 0;
1184     }
1185
1186     if (ms == 1000) {
1187         name = g_strdup_printf("pty-timer-secs-%s", chr->label);
1188         s->timer_tag = g_timeout_add_seconds(1, pty_chr_timer, chr);
1189     } else {
1190         name = g_strdup_printf("pty-timer-ms-%s", chr->label);
1191         s->timer_tag = g_timeout_add(ms, pty_chr_timer, chr);
1192     }
1193     g_source_set_name_by_id(s->timer_tag, name);
1194     g_free(name);
1195 }
1196
1197 /* Called with chr_write_lock held.  */
1198 static void pty_chr_update_read_handler_locked(Chardev *chr)
1199 {
1200     PtyChardev *s = PTY_CHARDEV(chr);
1201     GPollFD pfd;
1202     int rc;
1203     QIOChannelFile *fioc = QIO_CHANNEL_FILE(s->ioc);
1204
1205     pfd.fd = fioc->fd;
1206     pfd.events = G_IO_OUT;
1207     pfd.revents = 0;
1208     do {
1209         rc = g_poll(&pfd, 1, 0);
1210     } while (rc == -1 && errno == EINTR);
1211     assert(rc >= 0);
1212
1213     if (pfd.revents & G_IO_HUP) {
1214         pty_chr_state(chr, 0);
1215     } else {
1216         pty_chr_state(chr, 1);
1217     }
1218 }
1219
1220 static void pty_chr_update_read_handler(Chardev *chr,
1221                                         GMainContext *context)
1222 {
1223     qemu_mutex_lock(&chr->chr_write_lock);
1224     pty_chr_update_read_handler_locked(chr);
1225     qemu_mutex_unlock(&chr->chr_write_lock);
1226 }
1227
1228 /* Called with chr_write_lock held.  */
1229 static int char_pty_chr_write(Chardev *chr, const uint8_t *buf, int len)
1230 {
1231     PtyChardev *s = PTY_CHARDEV(chr);
1232
1233     if (!s->connected) {
1234         /* guest sends data, check for (re-)connect */
1235         pty_chr_update_read_handler_locked(chr);
1236         if (!s->connected) {
1237             return 0;
1238         }
1239     }
1240     return io_channel_send(s->ioc, buf, len);
1241 }
1242
1243 static GSource *pty_chr_add_watch(Chardev *chr, GIOCondition cond)
1244 {
1245     PtyChardev *s = PTY_CHARDEV(chr);
1246     if (!s->connected) {
1247         return NULL;
1248     }
1249     return qio_channel_create_watch(s->ioc, cond);
1250 }
1251
1252 static int pty_chr_read_poll(void *opaque)
1253 {
1254     Chardev *chr = CHARDEV(opaque);
1255     PtyChardev *s = PTY_CHARDEV(opaque);
1256
1257     s->read_bytes = qemu_chr_be_can_write(chr);
1258     return s->read_bytes;
1259 }
1260
1261 static gboolean pty_chr_read(QIOChannel *chan, GIOCondition cond, void *opaque)
1262 {
1263     Chardev *chr = CHARDEV(opaque);
1264     PtyChardev *s = PTY_CHARDEV(opaque);
1265     gsize len;
1266     uint8_t buf[CHR_READ_BUF_LEN];
1267     ssize_t ret;
1268
1269     len = sizeof(buf);
1270     if (len > s->read_bytes)
1271         len = s->read_bytes;
1272     if (len == 0) {
1273         return TRUE;
1274     }
1275     ret = qio_channel_read(s->ioc, (char *)buf, len, NULL);
1276     if (ret <= 0) {
1277         pty_chr_state(chr, 0);
1278         return FALSE;
1279     } else {
1280         pty_chr_state(chr, 1);
1281         qemu_chr_be_write(chr, buf, ret);
1282     }
1283     return TRUE;
1284 }
1285
1286 static gboolean qemu_chr_be_generic_open_func(gpointer opaque)
1287 {
1288     Chardev *chr = CHARDEV(opaque);
1289     PtyChardev *s = PTY_CHARDEV(opaque);
1290
1291     s->open_tag = 0;
1292     qemu_chr_be_generic_open(chr);
1293     return FALSE;
1294 }
1295
1296 /* Called with chr_write_lock held.  */
1297 static void pty_chr_state(Chardev *chr, int connected)
1298 {
1299     PtyChardev *s = PTY_CHARDEV(chr);
1300
1301     if (!connected) {
1302         if (s->open_tag) {
1303             g_source_remove(s->open_tag);
1304             s->open_tag = 0;
1305         }
1306         remove_fd_in_watch(chr);
1307         s->connected = 0;
1308         /* (re-)connect poll interval for idle guests: once per second.
1309          * We check more frequently in case the guests sends data to
1310          * the virtual device linked to our pty. */
1311         pty_chr_rearm_timer(chr, 1000);
1312     } else {
1313         if (s->timer_tag) {
1314             g_source_remove(s->timer_tag);
1315             s->timer_tag = 0;
1316         }
1317         if (!s->connected) {
1318             g_assert(s->open_tag == 0);
1319             s->connected = 1;
1320             s->open_tag = g_idle_add(qemu_chr_be_generic_open_func, chr);
1321         }
1322         if (!chr->fd_in_tag) {
1323             chr->fd_in_tag = io_add_watch_poll(chr, s->ioc,
1324                                                pty_chr_read_poll,
1325                                                pty_chr_read,
1326                                                chr, NULL);
1327         }
1328     }
1329 }
1330
1331 static void char_pty_finalize(Object *obj)
1332 {
1333     Chardev *chr = CHARDEV(obj);
1334     PtyChardev *s = PTY_CHARDEV(obj);
1335
1336     qemu_mutex_lock(&chr->chr_write_lock);
1337     pty_chr_state(chr, 0);
1338     object_unref(OBJECT(s->ioc));
1339     if (s->timer_tag) {
1340         g_source_remove(s->timer_tag);
1341         s->timer_tag = 0;
1342     }
1343     qemu_mutex_unlock(&chr->chr_write_lock);
1344     qemu_chr_be_event(chr, CHR_EVENT_CLOSED);
1345 }
1346
1347 static void char_pty_open(Chardev *chr,
1348                           ChardevBackend *backend,
1349                           bool *be_opened,
1350                           Error **errp)
1351 {
1352     PtyChardev *s;
1353     int master_fd, slave_fd;
1354     char pty_name[PATH_MAX];
1355     char *name;
1356
1357     master_fd = qemu_openpty_raw(&slave_fd, pty_name);
1358     if (master_fd < 0) {
1359         error_setg_errno(errp, errno, "Failed to create PTY");
1360         return;
1361     }
1362
1363     close(slave_fd);
1364     qemu_set_nonblock(master_fd);
1365
1366     chr->filename = g_strdup_printf("pty:%s", pty_name);
1367     error_report("char device redirected to %s (label %s)",
1368                  pty_name, chr->label);
1369
1370     s = PTY_CHARDEV(chr);
1371     s->ioc = QIO_CHANNEL(qio_channel_file_new_fd(master_fd));
1372     name = g_strdup_printf("chardev-pty-%s", chr->label);
1373     qio_channel_set_name(QIO_CHANNEL(s->ioc), name);
1374     g_free(name);
1375     s->timer_tag = 0;
1376     *be_opened = false;
1377 }
1378
1379 static void char_pty_class_init(ObjectClass *oc, void *data)
1380 {
1381     ChardevClass *cc = CHARDEV_CLASS(oc);
1382
1383     cc->open = char_pty_open;
1384     cc->chr_write = char_pty_chr_write;
1385     cc->chr_update_read_handler = pty_chr_update_read_handler;
1386     cc->chr_add_watch = pty_chr_add_watch;
1387 }
1388
1389 static const TypeInfo char_pty_type_info = {
1390     .name = TYPE_CHARDEV_PTY,
1391     .parent = TYPE_CHARDEV,
1392     .instance_size = sizeof(PtyChardev),
1393     .instance_finalize = char_pty_finalize,
1394     .class_init = char_pty_class_init,
1395 };
1396
1397 static void tty_serial_init(int fd, int speed,
1398                             int parity, int data_bits, int stop_bits)
1399 {
1400     struct termios tty;
1401     speed_t spd;
1402
1403 #if 0
1404     printf("tty_serial_init: speed=%d parity=%c data=%d stop=%d\n",
1405            speed, parity, data_bits, stop_bits);
1406 #endif
1407     tcgetattr (fd, &tty);
1408
1409 #define check_speed(val) if (speed <= val) { spd = B##val; break; }
1410     speed = speed * 10 / 11;
1411     do {
1412         check_speed(50);
1413         check_speed(75);
1414         check_speed(110);
1415         check_speed(134);
1416         check_speed(150);
1417         check_speed(200);
1418         check_speed(300);
1419         check_speed(600);
1420         check_speed(1200);
1421         check_speed(1800);
1422         check_speed(2400);
1423         check_speed(4800);
1424         check_speed(9600);
1425         check_speed(19200);
1426         check_speed(38400);
1427         /* Non-Posix values follow. They may be unsupported on some systems. */
1428         check_speed(57600);
1429         check_speed(115200);
1430 #ifdef B230400
1431         check_speed(230400);
1432 #endif
1433 #ifdef B460800
1434         check_speed(460800);
1435 #endif
1436 #ifdef B500000
1437         check_speed(500000);
1438 #endif
1439 #ifdef B576000
1440         check_speed(576000);
1441 #endif
1442 #ifdef B921600
1443         check_speed(921600);
1444 #endif
1445 #ifdef B1000000
1446         check_speed(1000000);
1447 #endif
1448 #ifdef B1152000
1449         check_speed(1152000);
1450 #endif
1451 #ifdef B1500000
1452         check_speed(1500000);
1453 #endif
1454 #ifdef B2000000
1455         check_speed(2000000);
1456 #endif
1457 #ifdef B2500000
1458         check_speed(2500000);
1459 #endif
1460 #ifdef B3000000
1461         check_speed(3000000);
1462 #endif
1463 #ifdef B3500000
1464         check_speed(3500000);
1465 #endif
1466 #ifdef B4000000
1467         check_speed(4000000);
1468 #endif
1469         spd = B115200;
1470     } while (0);
1471
1472     cfsetispeed(&tty, spd);
1473     cfsetospeed(&tty, spd);
1474
1475     tty.c_iflag &= ~(IGNBRK|BRKINT|PARMRK|ISTRIP
1476                           |INLCR|IGNCR|ICRNL|IXON);
1477     tty.c_oflag |= OPOST;
1478     tty.c_lflag &= ~(ECHO|ECHONL|ICANON|IEXTEN|ISIG);
1479     tty.c_cflag &= ~(CSIZE|PARENB|PARODD|CRTSCTS|CSTOPB);
1480     switch(data_bits) {
1481     default:
1482     case 8:
1483         tty.c_cflag |= CS8;
1484         break;
1485     case 7:
1486         tty.c_cflag |= CS7;
1487         break;
1488     case 6:
1489         tty.c_cflag |= CS6;
1490         break;
1491     case 5:
1492         tty.c_cflag |= CS5;
1493         break;
1494     }
1495     switch(parity) {
1496     default:
1497     case 'N':
1498         break;
1499     case 'E':
1500         tty.c_cflag |= PARENB;
1501         break;
1502     case 'O':
1503         tty.c_cflag |= PARENB | PARODD;
1504         break;
1505     }
1506     if (stop_bits == 2)
1507         tty.c_cflag |= CSTOPB;
1508
1509     tcsetattr (fd, TCSANOW, &tty);
1510 }
1511
1512 static int tty_serial_ioctl(Chardev *chr, int cmd, void *arg)
1513 {
1514     FDChardev *s = FD_CHARDEV(chr);
1515     QIOChannelFile *fioc = QIO_CHANNEL_FILE(s->ioc_in);
1516
1517     switch(cmd) {
1518     case CHR_IOCTL_SERIAL_SET_PARAMS:
1519         {
1520             QEMUSerialSetParams *ssp = arg;
1521             tty_serial_init(fioc->fd,
1522                             ssp->speed, ssp->parity,
1523                             ssp->data_bits, ssp->stop_bits);
1524         }
1525         break;
1526     case CHR_IOCTL_SERIAL_SET_BREAK:
1527         {
1528             int enable = *(int *)arg;
1529             if (enable) {
1530                 tcsendbreak(fioc->fd, 1);
1531             }
1532         }
1533         break;
1534     case CHR_IOCTL_SERIAL_GET_TIOCM:
1535         {
1536             int sarg = 0;
1537             int *targ = (int *)arg;
1538             ioctl(fioc->fd, TIOCMGET, &sarg);
1539             *targ = 0;
1540             if (sarg & TIOCM_CTS)
1541                 *targ |= CHR_TIOCM_CTS;
1542             if (sarg & TIOCM_CAR)
1543                 *targ |= CHR_TIOCM_CAR;
1544             if (sarg & TIOCM_DSR)
1545                 *targ |= CHR_TIOCM_DSR;
1546             if (sarg & TIOCM_RI)
1547                 *targ |= CHR_TIOCM_RI;
1548             if (sarg & TIOCM_DTR)
1549                 *targ |= CHR_TIOCM_DTR;
1550             if (sarg & TIOCM_RTS)
1551                 *targ |= CHR_TIOCM_RTS;
1552         }
1553         break;
1554     case CHR_IOCTL_SERIAL_SET_TIOCM:
1555         {
1556             int sarg = *(int *)arg;
1557             int targ = 0;
1558             ioctl(fioc->fd, TIOCMGET, &targ);
1559             targ &= ~(CHR_TIOCM_CTS | CHR_TIOCM_CAR | CHR_TIOCM_DSR
1560                      | CHR_TIOCM_RI | CHR_TIOCM_DTR | CHR_TIOCM_RTS);
1561             if (sarg & CHR_TIOCM_CTS)
1562                 targ |= TIOCM_CTS;
1563             if (sarg & CHR_TIOCM_CAR)
1564                 targ |= TIOCM_CAR;
1565             if (sarg & CHR_TIOCM_DSR)
1566                 targ |= TIOCM_DSR;
1567             if (sarg & CHR_TIOCM_RI)
1568                 targ |= TIOCM_RI;
1569             if (sarg & CHR_TIOCM_DTR)
1570                 targ |= TIOCM_DTR;
1571             if (sarg & CHR_TIOCM_RTS)
1572                 targ |= TIOCM_RTS;
1573             ioctl(fioc->fd, TIOCMSET, &targ);
1574         }
1575         break;
1576     default:
1577         return -ENOTSUP;
1578     }
1579     return 0;
1580 }
1581 #endif /* __linux__ || __sun__ */
1582
1583 #if defined(__linux__)
1584
1585 #define HAVE_CHARDEV_PARPORT 1
1586
1587 typedef struct {
1588     Chardev parent;
1589     int fd;
1590     int mode;
1591 } ParallelChardev;
1592
1593 #define PARALLEL_CHARDEV(obj) \
1594     OBJECT_CHECK(ParallelChardev, (obj), TYPE_CHARDEV_PARALLEL)
1595
1596 static int pp_hw_mode(ParallelChardev *s, uint16_t mode)
1597 {
1598     if (s->mode != mode) {
1599         int m = mode;
1600         if (ioctl(s->fd, PPSETMODE, &m) < 0)
1601             return 0;
1602         s->mode = mode;
1603     }
1604     return 1;
1605 }
1606
1607 static int pp_ioctl(Chardev *chr, int cmd, void *arg)
1608 {
1609     ParallelChardev *drv = PARALLEL_CHARDEV(chr);
1610     int fd = drv->fd;
1611     uint8_t b;
1612
1613     switch(cmd) {
1614     case CHR_IOCTL_PP_READ_DATA:
1615         if (ioctl(fd, PPRDATA, &b) < 0)
1616             return -ENOTSUP;
1617         *(uint8_t *)arg = b;
1618         break;
1619     case CHR_IOCTL_PP_WRITE_DATA:
1620         b = *(uint8_t *)arg;
1621         if (ioctl(fd, PPWDATA, &b) < 0)
1622             return -ENOTSUP;
1623         break;
1624     case CHR_IOCTL_PP_READ_CONTROL:
1625         if (ioctl(fd, PPRCONTROL, &b) < 0)
1626             return -ENOTSUP;
1627         /* Linux gives only the lowest bits, and no way to know data
1628            direction! For better compatibility set the fixed upper
1629            bits. */
1630         *(uint8_t *)arg = b | 0xc0;
1631         break;
1632     case CHR_IOCTL_PP_WRITE_CONTROL:
1633         b = *(uint8_t *)arg;
1634         if (ioctl(fd, PPWCONTROL, &b) < 0)
1635             return -ENOTSUP;
1636         break;
1637     case CHR_IOCTL_PP_READ_STATUS:
1638         if (ioctl(fd, PPRSTATUS, &b) < 0)
1639             return -ENOTSUP;
1640         *(uint8_t *)arg = b;
1641         break;
1642     case CHR_IOCTL_PP_DATA_DIR:
1643         if (ioctl(fd, PPDATADIR, (int *)arg) < 0)
1644             return -ENOTSUP;
1645         break;
1646     case CHR_IOCTL_PP_EPP_READ_ADDR:
1647         if (pp_hw_mode(drv, IEEE1284_MODE_EPP|IEEE1284_ADDR)) {
1648             struct ParallelIOArg *parg = arg;
1649             int n = read(fd, parg->buffer, parg->count);
1650             if (n != parg->count) {
1651                 return -EIO;
1652             }
1653         }
1654         break;
1655     case CHR_IOCTL_PP_EPP_READ:
1656         if (pp_hw_mode(drv, IEEE1284_MODE_EPP)) {
1657             struct ParallelIOArg *parg = arg;
1658             int n = read(fd, parg->buffer, parg->count);
1659             if (n != parg->count) {
1660                 return -EIO;
1661             }
1662         }
1663         break;
1664     case CHR_IOCTL_PP_EPP_WRITE_ADDR:
1665         if (pp_hw_mode(drv, IEEE1284_MODE_EPP|IEEE1284_ADDR)) {
1666             struct ParallelIOArg *parg = arg;
1667             int n = write(fd, parg->buffer, parg->count);
1668             if (n != parg->count) {
1669                 return -EIO;
1670             }
1671         }
1672         break;
1673     case CHR_IOCTL_PP_EPP_WRITE:
1674         if (pp_hw_mode(drv, IEEE1284_MODE_EPP)) {
1675             struct ParallelIOArg *parg = arg;
1676             int n = write(fd, parg->buffer, parg->count);
1677             if (n != parg->count) {
1678                 return -EIO;
1679             }
1680         }
1681         break;
1682     default:
1683         return -ENOTSUP;
1684     }
1685     return 0;
1686 }
1687
1688 static void qemu_chr_open_pp_fd(Chardev *chr,
1689                                 int fd,
1690                                 bool *be_opened,
1691                                 Error **errp)
1692 {
1693     ParallelChardev *drv = PARALLEL_CHARDEV(chr);
1694
1695     if (ioctl(fd, PPCLAIM) < 0) {
1696         error_setg_errno(errp, errno, "not a parallel port");
1697         close(fd);
1698         return;
1699     }
1700
1701     drv->fd = fd;
1702     drv->mode = IEEE1284_MODE_COMPAT;
1703 }
1704 #endif /* __linux__ */
1705
1706 #if defined(__FreeBSD__) || defined(__FreeBSD_kernel__) || defined(__DragonFly__)
1707
1708 #define HAVE_CHARDEV_PARPORT 1
1709
1710 typedef struct {
1711     Chardev parent;
1712     int fd;
1713 } ParallelChardev;
1714
1715 #define PARALLEL_CHARDEV(obj)                                   \
1716     OBJECT_CHECK(ParallelChardev, (obj), TYPE_CHARDEV_PARALLEL)
1717
1718 static int pp_ioctl(Chardev *chr, int cmd, void *arg)
1719 {
1720     ParallelChardev *drv = PARALLEL_CHARDEV(chr);
1721     uint8_t b;
1722
1723     switch (cmd) {
1724     case CHR_IOCTL_PP_READ_DATA:
1725         if (ioctl(drv->fd, PPIGDATA, &b) < 0) {
1726             return -ENOTSUP;
1727         }
1728         *(uint8_t *)arg = b;
1729         break;
1730     case CHR_IOCTL_PP_WRITE_DATA:
1731         b = *(uint8_t *)arg;
1732         if (ioctl(drv->fd, PPISDATA, &b) < 0) {
1733             return -ENOTSUP;
1734         }
1735         break;
1736     case CHR_IOCTL_PP_READ_CONTROL:
1737         if (ioctl(drv->fd, PPIGCTRL, &b) < 0) {
1738             return -ENOTSUP;
1739         }
1740         *(uint8_t *)arg = b;
1741         break;
1742     case CHR_IOCTL_PP_WRITE_CONTROL:
1743         b = *(uint8_t *)arg;
1744         if (ioctl(drv->fd, PPISCTRL, &b) < 0) {
1745             return -ENOTSUP;
1746         }
1747         break;
1748     case CHR_IOCTL_PP_READ_STATUS:
1749         if (ioctl(drv->fd, PPIGSTATUS, &b) < 0) {
1750             return -ENOTSUP;
1751         }
1752         *(uint8_t *)arg = b;
1753         break;
1754     default:
1755         return -ENOTSUP;
1756     }
1757     return 0;
1758 }
1759
1760 static void qemu_chr_open_pp_fd(Chardev *chr,
1761                                 int fd,
1762                                 bool *be_opened,
1763                                 Error **errp)
1764 {
1765     ParallelChardev *drv = PARALLEL_CHARDEV(chr);
1766     drv->fd = fd;
1767     *be_opened = false;
1768 }
1769 #endif
1770
1771 #else /* _WIN32 */
1772
1773 #define HAVE_CHARDEV_SERIAL 1
1774
1775 typedef struct {
1776     Chardev parent;
1777     int max_size;
1778     HANDLE hcom, hrecv, hsend;
1779     OVERLAPPED orecv;
1780     BOOL fpipe;
1781     DWORD len;
1782
1783     /* Protected by the Chardev chr_write_lock.  */
1784     OVERLAPPED osend;
1785     /* FIXME: file/console do not finalize */
1786     bool skip_free;
1787 } WinChardev;
1788
1789 #define TYPE_CHARDEV_WIN "chardev-win"
1790 #define WIN_CHARDEV(obj) OBJECT_CHECK(WinChardev, (obj), TYPE_CHARDEV_WIN)
1791
1792 typedef struct {
1793     Chardev parent;
1794     HANDLE  hStdIn;
1795     HANDLE  hInputReadyEvent;
1796     HANDLE  hInputDoneEvent;
1797     HANDLE  hInputThread;
1798     uint8_t win_stdio_buf;
1799 } WinStdioChardev;
1800
1801 #define TYPE_CHARDEV_WIN_STDIO "chardev-win-stdio"
1802 #define WIN_STDIO_CHARDEV(obj)                                  \
1803     OBJECT_CHECK(WinStdioChardev, (obj), TYPE_CHARDEV_WIN_STDIO)
1804
1805 #define NSENDBUF 2048
1806 #define NRECVBUF 2048
1807 #define MAXCONNECT 1
1808 #define NTIMEOUT 5000
1809
1810 static int win_chr_poll(void *opaque);
1811 static int win_chr_pipe_poll(void *opaque);
1812
1813 static void char_win_finalize(Object *obj)
1814 {
1815     Chardev *chr = CHARDEV(obj);
1816     WinChardev *s = WIN_CHARDEV(chr);
1817
1818     if (s->skip_free) {
1819         return;
1820     }
1821
1822     if (s->hsend) {
1823         CloseHandle(s->hsend);
1824     }
1825     if (s->hrecv) {
1826         CloseHandle(s->hrecv);
1827     }
1828     if (s->hcom) {
1829         CloseHandle(s->hcom);
1830     }
1831     if (s->fpipe)
1832         qemu_del_polling_cb(win_chr_pipe_poll, chr);
1833     else
1834         qemu_del_polling_cb(win_chr_poll, chr);
1835
1836     qemu_chr_be_event(chr, CHR_EVENT_CLOSED);
1837 }
1838
1839 static int win_chr_init(Chardev *chr, const char *filename, Error **errp)
1840 {
1841     WinChardev *s = WIN_CHARDEV(chr);
1842     COMMCONFIG comcfg;
1843     COMMTIMEOUTS cto = { 0, 0, 0, 0, 0};
1844     COMSTAT comstat;
1845     DWORD size;
1846     DWORD err;
1847
1848     s->hsend = CreateEvent(NULL, TRUE, FALSE, NULL);
1849     if (!s->hsend) {
1850         error_setg(errp, "Failed CreateEvent");
1851         goto fail;
1852     }
1853     s->hrecv = CreateEvent(NULL, TRUE, FALSE, NULL);
1854     if (!s->hrecv) {
1855         error_setg(errp, "Failed CreateEvent");
1856         goto fail;
1857     }
1858
1859     s->hcom = CreateFile(filename, GENERIC_READ|GENERIC_WRITE, 0, NULL,
1860                       OPEN_EXISTING, FILE_FLAG_OVERLAPPED, 0);
1861     if (s->hcom == INVALID_HANDLE_VALUE) {
1862         error_setg(errp, "Failed CreateFile (%lu)", GetLastError());
1863         s->hcom = NULL;
1864         goto fail;
1865     }
1866
1867     if (!SetupComm(s->hcom, NRECVBUF, NSENDBUF)) {
1868         error_setg(errp, "Failed SetupComm");
1869         goto fail;
1870     }
1871
1872     ZeroMemory(&comcfg, sizeof(COMMCONFIG));
1873     size = sizeof(COMMCONFIG);
1874     GetDefaultCommConfig(filename, &comcfg, &size);
1875     comcfg.dcb.DCBlength = sizeof(DCB);
1876     CommConfigDialog(filename, NULL, &comcfg);
1877
1878     if (!SetCommState(s->hcom, &comcfg.dcb)) {
1879         error_setg(errp, "Failed SetCommState");
1880         goto fail;
1881     }
1882
1883     if (!SetCommMask(s->hcom, EV_ERR)) {
1884         error_setg(errp, "Failed SetCommMask");
1885         goto fail;
1886     }
1887
1888     cto.ReadIntervalTimeout = MAXDWORD;
1889     if (!SetCommTimeouts(s->hcom, &cto)) {
1890         error_setg(errp, "Failed SetCommTimeouts");
1891         goto fail;
1892     }
1893
1894     if (!ClearCommError(s->hcom, &err, &comstat)) {
1895         error_setg(errp, "Failed ClearCommError");
1896         goto fail;
1897     }
1898     qemu_add_polling_cb(win_chr_poll, chr);
1899     return 0;
1900
1901  fail:
1902     return -1;
1903 }
1904
1905 /* Called with chr_write_lock held.  */
1906 static int win_chr_write(Chardev *chr, const uint8_t *buf, int len1)
1907 {
1908     WinChardev *s = WIN_CHARDEV(chr);
1909     DWORD len, ret, size, err;
1910
1911     len = len1;
1912     ZeroMemory(&s->osend, sizeof(s->osend));
1913     s->osend.hEvent = s->hsend;
1914     while (len > 0) {
1915         if (s->hsend)
1916             ret = WriteFile(s->hcom, buf, len, &size, &s->osend);
1917         else
1918             ret = WriteFile(s->hcom, buf, len, &size, NULL);
1919         if (!ret) {
1920             err = GetLastError();
1921             if (err == ERROR_IO_PENDING) {
1922                 ret = GetOverlappedResult(s->hcom, &s->osend, &size, TRUE);
1923                 if (ret) {
1924                     buf += size;
1925                     len -= size;
1926                 } else {
1927                     break;
1928                 }
1929             } else {
1930                 break;
1931             }
1932         } else {
1933             buf += size;
1934             len -= size;
1935         }
1936     }
1937     return len1 - len;
1938 }
1939
1940 static int win_chr_read_poll(Chardev *chr)
1941 {
1942     WinChardev *s = WIN_CHARDEV(chr);
1943
1944     s->max_size = qemu_chr_be_can_write(chr);
1945     return s->max_size;
1946 }
1947
1948 static void win_chr_readfile(Chardev *chr)
1949 {
1950     WinChardev *s = WIN_CHARDEV(chr);
1951
1952     int ret, err;
1953     uint8_t buf[CHR_READ_BUF_LEN];
1954     DWORD size;
1955
1956     ZeroMemory(&s->orecv, sizeof(s->orecv));
1957     s->orecv.hEvent = s->hrecv;
1958     ret = ReadFile(s->hcom, buf, s->len, &size, &s->orecv);
1959     if (!ret) {
1960         err = GetLastError();
1961         if (err == ERROR_IO_PENDING) {
1962             ret = GetOverlappedResult(s->hcom, &s->orecv, &size, TRUE);
1963         }
1964     }
1965
1966     if (size > 0) {
1967         qemu_chr_be_write(chr, buf, size);
1968     }
1969 }
1970
1971 static void win_chr_read(Chardev *chr)
1972 {
1973     WinChardev *s = WIN_CHARDEV(chr);
1974
1975     if (s->len > s->max_size)
1976         s->len = s->max_size;
1977     if (s->len == 0)
1978         return;
1979
1980     win_chr_readfile(chr);
1981 }
1982
1983 static int win_chr_poll(void *opaque)
1984 {
1985     Chardev *chr = CHARDEV(opaque);
1986     WinChardev *s = WIN_CHARDEV(opaque);
1987     COMSTAT status;
1988     DWORD comerr;
1989
1990     ClearCommError(s->hcom, &comerr, &status);
1991     if (status.cbInQue > 0) {
1992         s->len = status.cbInQue;
1993         win_chr_read_poll(chr);
1994         win_chr_read(chr);
1995         return 1;
1996     }
1997     return 0;
1998 }
1999
2000 static int win_chr_pipe_poll(void *opaque)
2001 {
2002     Chardev *chr = CHARDEV(opaque);
2003     WinChardev *s = WIN_CHARDEV(opaque);
2004     DWORD size;
2005
2006     PeekNamedPipe(s->hcom, NULL, 0, NULL, &size, NULL);
2007     if (size > 0) {
2008         s->len = size;
2009         win_chr_read_poll(chr);
2010         win_chr_read(chr);
2011         return 1;
2012     }
2013     return 0;
2014 }
2015
2016 static int win_chr_pipe_init(Chardev *chr, const char *filename,
2017                              Error **errp)
2018 {
2019     WinChardev *s = WIN_CHARDEV(chr);
2020     OVERLAPPED ov;
2021     int ret;
2022     DWORD size;
2023     char *openname;
2024
2025     s->fpipe = TRUE;
2026
2027     s->hsend = CreateEvent(NULL, TRUE, FALSE, NULL);
2028     if (!s->hsend) {
2029         error_setg(errp, "Failed CreateEvent");
2030         goto fail;
2031     }
2032     s->hrecv = CreateEvent(NULL, TRUE, FALSE, NULL);
2033     if (!s->hrecv) {
2034         error_setg(errp, "Failed CreateEvent");
2035         goto fail;
2036     }
2037
2038     openname = g_strdup_printf("\\\\.\\pipe\\%s", filename);
2039     s->hcom = CreateNamedPipe(openname, PIPE_ACCESS_DUPLEX | FILE_FLAG_OVERLAPPED,
2040                               PIPE_TYPE_BYTE | PIPE_READMODE_BYTE |
2041                               PIPE_WAIT,
2042                               MAXCONNECT, NSENDBUF, NRECVBUF, NTIMEOUT, NULL);
2043     g_free(openname);
2044     if (s->hcom == INVALID_HANDLE_VALUE) {
2045         error_setg(errp, "Failed CreateNamedPipe (%lu)", GetLastError());
2046         s->hcom = NULL;
2047         goto fail;
2048     }
2049
2050     ZeroMemory(&ov, sizeof(ov));
2051     ov.hEvent = CreateEvent(NULL, TRUE, FALSE, NULL);
2052     ret = ConnectNamedPipe(s->hcom, &ov);
2053     if (ret) {
2054         error_setg(errp, "Failed ConnectNamedPipe");
2055         goto fail;
2056     }
2057
2058     ret = GetOverlappedResult(s->hcom, &ov, &size, TRUE);
2059     if (!ret) {
2060         error_setg(errp, "Failed GetOverlappedResult");
2061         if (ov.hEvent) {
2062             CloseHandle(ov.hEvent);
2063             ov.hEvent = NULL;
2064         }
2065         goto fail;
2066     }
2067
2068     if (ov.hEvent) {
2069         CloseHandle(ov.hEvent);
2070         ov.hEvent = NULL;
2071     }
2072     qemu_add_polling_cb(win_chr_pipe_poll, chr);
2073     return 0;
2074
2075  fail:
2076     return -1;
2077 }
2078
2079
2080 static void qemu_chr_open_pipe(Chardev *chr,
2081                                ChardevBackend *backend,
2082                                bool *be_opened,
2083                                Error **errp)
2084 {
2085     ChardevHostdev *opts = backend->u.pipe.data;
2086     const char *filename = opts->device;
2087
2088     if (win_chr_pipe_init(chr, filename, errp) < 0) {
2089         return;
2090     }
2091 }
2092
2093 static void qemu_chr_open_win_file(Chardev *chr, HANDLE fd_out)
2094 {
2095     WinChardev *s = WIN_CHARDEV(chr);
2096
2097     s->skip_free = true;
2098     s->hcom = fd_out;
2099 }
2100
2101 static void char_win_class_init(ObjectClass *oc, void *data)
2102 {
2103     ChardevClass *cc = CHARDEV_CLASS(oc);
2104
2105     cc->chr_write = win_chr_write;
2106 }
2107
2108 static const TypeInfo char_win_type_info = {
2109     .name = TYPE_CHARDEV_WIN,
2110     .parent = TYPE_CHARDEV,
2111     .instance_size = sizeof(WinChardev),
2112     .instance_finalize = char_win_finalize,
2113     .class_init = char_win_class_init,
2114     .abstract = true,
2115 };
2116
2117 static void qemu_chr_open_win_con(Chardev *chr,
2118                                   ChardevBackend *backend,
2119                                   bool *be_opened,
2120                                   Error **errp)
2121 {
2122     qemu_chr_open_win_file(chr, GetStdHandle(STD_OUTPUT_HANDLE));
2123 }
2124
2125 static void char_console_class_init(ObjectClass *oc, void *data)
2126 {
2127     ChardevClass *cc = CHARDEV_CLASS(oc);
2128
2129     cc->open = qemu_chr_open_win_con;
2130 }
2131
2132 static const TypeInfo char_console_type_info = {
2133     .name = TYPE_CHARDEV_CONSOLE,
2134     .parent = TYPE_CHARDEV_WIN,
2135     .class_init = char_console_class_init,
2136 };
2137
2138 static int win_stdio_write(Chardev *chr, const uint8_t *buf, int len)
2139 {
2140     HANDLE  hStdOut = GetStdHandle(STD_OUTPUT_HANDLE);
2141     DWORD   dwSize;
2142     int     len1;
2143
2144     len1 = len;
2145
2146     while (len1 > 0) {
2147         if (!WriteFile(hStdOut, buf, len1, &dwSize, NULL)) {
2148             break;
2149         }
2150         buf  += dwSize;
2151         len1 -= dwSize;
2152     }
2153
2154     return len - len1;
2155 }
2156
2157 static void win_stdio_wait_func(void *opaque)
2158 {
2159     Chardev *chr = CHARDEV(opaque);
2160     WinStdioChardev *stdio = WIN_STDIO_CHARDEV(opaque);
2161     INPUT_RECORD       buf[4];
2162     int                ret;
2163     DWORD              dwSize;
2164     int                i;
2165
2166     ret = ReadConsoleInput(stdio->hStdIn, buf, ARRAY_SIZE(buf), &dwSize);
2167
2168     if (!ret) {
2169         /* Avoid error storm */
2170         qemu_del_wait_object(stdio->hStdIn, NULL, NULL);
2171         return;
2172     }
2173
2174     for (i = 0; i < dwSize; i++) {
2175         KEY_EVENT_RECORD *kev = &buf[i].Event.KeyEvent;
2176
2177         if (buf[i].EventType == KEY_EVENT && kev->bKeyDown) {
2178             int j;
2179             if (kev->uChar.AsciiChar != 0) {
2180                 for (j = 0; j < kev->wRepeatCount; j++) {
2181                     if (qemu_chr_be_can_write(chr)) {
2182                         uint8_t c = kev->uChar.AsciiChar;
2183                         qemu_chr_be_write(chr, &c, 1);
2184                     }
2185                 }
2186             }
2187         }
2188     }
2189 }
2190
2191 static DWORD WINAPI win_stdio_thread(LPVOID param)
2192 {
2193     WinStdioChardev *stdio = WIN_STDIO_CHARDEV(param);
2194     int                ret;
2195     DWORD              dwSize;
2196
2197     while (1) {
2198
2199         /* Wait for one byte */
2200         ret = ReadFile(stdio->hStdIn, &stdio->win_stdio_buf, 1, &dwSize, NULL);
2201
2202         /* Exit in case of error, continue if nothing read */
2203         if (!ret) {
2204             break;
2205         }
2206         if (!dwSize) {
2207             continue;
2208         }
2209
2210         /* Some terminal emulator returns \r\n for Enter, just pass \n */
2211         if (stdio->win_stdio_buf == '\r') {
2212             continue;
2213         }
2214
2215         /* Signal the main thread and wait until the byte was eaten */
2216         if (!SetEvent(stdio->hInputReadyEvent)) {
2217             break;
2218         }
2219         if (WaitForSingleObject(stdio->hInputDoneEvent, INFINITE)
2220             != WAIT_OBJECT_0) {
2221             break;
2222         }
2223     }
2224
2225     qemu_del_wait_object(stdio->hInputReadyEvent, NULL, NULL);
2226     return 0;
2227 }
2228
2229 static void win_stdio_thread_wait_func(void *opaque)
2230 {
2231     Chardev *chr = CHARDEV(opaque);
2232     WinStdioChardev *stdio = WIN_STDIO_CHARDEV(opaque);
2233
2234     if (qemu_chr_be_can_write(chr)) {
2235         qemu_chr_be_write(chr, &stdio->win_stdio_buf, 1);
2236     }
2237
2238     SetEvent(stdio->hInputDoneEvent);
2239 }
2240
2241 static void qemu_chr_set_echo_win_stdio(Chardev *chr, bool echo)
2242 {
2243     WinStdioChardev *stdio = WIN_STDIO_CHARDEV(chr);
2244     DWORD              dwMode = 0;
2245
2246     GetConsoleMode(stdio->hStdIn, &dwMode);
2247
2248     if (echo) {
2249         SetConsoleMode(stdio->hStdIn, dwMode | ENABLE_ECHO_INPUT);
2250     } else {
2251         SetConsoleMode(stdio->hStdIn, dwMode & ~ENABLE_ECHO_INPUT);
2252     }
2253 }
2254
2255 static void char_win_stdio_finalize(Object *obj)
2256 {
2257     WinStdioChardev *stdio = WIN_STDIO_CHARDEV(obj);
2258
2259     if (stdio->hInputReadyEvent != INVALID_HANDLE_VALUE) {
2260         CloseHandle(stdio->hInputReadyEvent);
2261     }
2262     if (stdio->hInputDoneEvent != INVALID_HANDLE_VALUE) {
2263         CloseHandle(stdio->hInputDoneEvent);
2264     }
2265     if (stdio->hInputThread != INVALID_HANDLE_VALUE) {
2266         TerminateThread(stdio->hInputThread, 0);
2267     }
2268 }
2269
2270 static const TypeInfo char_win_stdio_type_info = {
2271     .name = TYPE_CHARDEV_WIN_STDIO,
2272     .parent = TYPE_CHARDEV,
2273     .instance_size = sizeof(WinStdioChardev),
2274     .instance_finalize = char_win_stdio_finalize,
2275     .abstract = true,
2276 };
2277
2278 static void qemu_chr_open_stdio(Chardev *chr,
2279                                 ChardevBackend *backend,
2280                                 bool *be_opened,
2281                                 Error **errp)
2282 {
2283     WinStdioChardev *stdio = WIN_STDIO_CHARDEV(chr);
2284     DWORD              dwMode;
2285     int                is_console = 0;
2286
2287     stdio->hStdIn = GetStdHandle(STD_INPUT_HANDLE);
2288     if (stdio->hStdIn == INVALID_HANDLE_VALUE) {
2289         error_setg(errp, "cannot open stdio: invalid handle");
2290         return;
2291     }
2292
2293     is_console = GetConsoleMode(stdio->hStdIn, &dwMode) != 0;
2294
2295     if (is_console) {
2296         if (qemu_add_wait_object(stdio->hStdIn,
2297                                  win_stdio_wait_func, chr)) {
2298             error_setg(errp, "qemu_add_wait_object: failed");
2299             goto err1;
2300         }
2301     } else {
2302         DWORD   dwId;
2303
2304         stdio->hInputReadyEvent = CreateEvent(NULL, FALSE, FALSE, NULL);
2305         stdio->hInputDoneEvent  = CreateEvent(NULL, FALSE, FALSE, NULL);
2306         if (stdio->hInputReadyEvent == INVALID_HANDLE_VALUE
2307             || stdio->hInputDoneEvent == INVALID_HANDLE_VALUE) {
2308             error_setg(errp, "cannot create event");
2309             goto err2;
2310         }
2311         if (qemu_add_wait_object(stdio->hInputReadyEvent,
2312                                  win_stdio_thread_wait_func, chr)) {
2313             error_setg(errp, "qemu_add_wait_object: failed");
2314             goto err2;
2315         }
2316         stdio->hInputThread     = CreateThread(NULL, 0, win_stdio_thread,
2317                                                chr, 0, &dwId);
2318
2319         if (stdio->hInputThread == INVALID_HANDLE_VALUE) {
2320             error_setg(errp, "cannot create stdio thread");
2321             goto err3;
2322         }
2323     }
2324
2325     dwMode |= ENABLE_LINE_INPUT;
2326
2327     if (is_console) {
2328         /* set the terminal in raw mode */
2329         /* ENABLE_QUICK_EDIT_MODE | ENABLE_EXTENDED_FLAGS */
2330         dwMode |= ENABLE_PROCESSED_INPUT;
2331     }
2332
2333     SetConsoleMode(stdio->hStdIn, dwMode);
2334
2335     qemu_chr_set_echo_win_stdio(chr, false);
2336
2337     return;
2338
2339 err3:
2340     qemu_del_wait_object(stdio->hInputReadyEvent, NULL, NULL);
2341 err2:
2342     CloseHandle(stdio->hInputReadyEvent);
2343     CloseHandle(stdio->hInputDoneEvent);
2344 err1:
2345     qemu_del_wait_object(stdio->hStdIn, NULL, NULL);
2346 }
2347 #endif /* !_WIN32 */
2348
2349 /***********************************************************/
2350 /* UDP Net console */
2351
2352 typedef struct {
2353     Chardev parent;
2354     QIOChannel *ioc;
2355     uint8_t buf[CHR_READ_BUF_LEN];
2356     int bufcnt;
2357     int bufptr;
2358     int max_size;
2359 } UdpChardev;
2360
2361 #define UDP_CHARDEV(obj) OBJECT_CHECK(UdpChardev, (obj), TYPE_CHARDEV_UDP)
2362
2363 /* Called with chr_write_lock held.  */
2364 static int udp_chr_write(Chardev *chr, const uint8_t *buf, int len)
2365 {
2366     UdpChardev *s = UDP_CHARDEV(chr);
2367
2368     return qio_channel_write(
2369         s->ioc, (const char *)buf, len, NULL);
2370 }
2371
2372 static int udp_chr_read_poll(void *opaque)
2373 {
2374     Chardev *chr = CHARDEV(opaque);
2375     UdpChardev *s = UDP_CHARDEV(opaque);
2376
2377     s->max_size = qemu_chr_be_can_write(chr);
2378
2379     /* If there were any stray characters in the queue process them
2380      * first
2381      */
2382     while (s->max_size > 0 && s->bufptr < s->bufcnt) {
2383         qemu_chr_be_write(chr, &s->buf[s->bufptr], 1);
2384         s->bufptr++;
2385         s->max_size = qemu_chr_be_can_write(chr);
2386     }
2387     return s->max_size;
2388 }
2389
2390 static gboolean udp_chr_read(QIOChannel *chan, GIOCondition cond, void *opaque)
2391 {
2392     Chardev *chr = CHARDEV(opaque);
2393     UdpChardev *s = UDP_CHARDEV(opaque);
2394     ssize_t ret;
2395
2396     if (s->max_size == 0) {
2397         return TRUE;
2398     }
2399     ret = qio_channel_read(
2400         s->ioc, (char *)s->buf, sizeof(s->buf), NULL);
2401     if (ret <= 0) {
2402         remove_fd_in_watch(chr);
2403         return FALSE;
2404     }
2405     s->bufcnt = ret;
2406
2407     s->bufptr = 0;
2408     while (s->max_size > 0 && s->bufptr < s->bufcnt) {
2409         qemu_chr_be_write(chr, &s->buf[s->bufptr], 1);
2410         s->bufptr++;
2411         s->max_size = qemu_chr_be_can_write(chr);
2412     }
2413
2414     return TRUE;
2415 }
2416
2417 static void udp_chr_update_read_handler(Chardev *chr,
2418                                         GMainContext *context)
2419 {
2420     UdpChardev *s = UDP_CHARDEV(chr);
2421
2422     remove_fd_in_watch(chr);
2423     if (s->ioc) {
2424         chr->fd_in_tag = io_add_watch_poll(chr, s->ioc,
2425                                            udp_chr_read_poll,
2426                                            udp_chr_read, chr,
2427                                            context);
2428     }
2429 }
2430
2431 static void char_udp_finalize(Object *obj)
2432 {
2433     Chardev *chr = CHARDEV(obj);
2434     UdpChardev *s = UDP_CHARDEV(obj);
2435
2436     remove_fd_in_watch(chr);
2437     if (s->ioc) {
2438         object_unref(OBJECT(s->ioc));
2439     }
2440     qemu_chr_be_event(chr, CHR_EVENT_CLOSED);
2441 }
2442
2443 /***********************************************************/
2444 /* TCP Net console */
2445
2446 typedef struct {
2447     Chardev parent;
2448     QIOChannel *ioc; /* Client I/O channel */
2449     QIOChannelSocket *sioc; /* Client master channel */
2450     QIOChannelSocket *listen_ioc;
2451     guint listen_tag;
2452     QCryptoTLSCreds *tls_creds;
2453     int connected;
2454     int max_size;
2455     int do_telnetopt;
2456     int do_nodelay;
2457     int is_unix;
2458     int *read_msgfds;
2459     size_t read_msgfds_num;
2460     int *write_msgfds;
2461     size_t write_msgfds_num;
2462
2463     SocketAddress *addr;
2464     bool is_listen;
2465     bool is_telnet;
2466
2467     guint reconnect_timer;
2468     int64_t reconnect_time;
2469     bool connect_err_reported;
2470 } SocketChardev;
2471
2472 #define SOCKET_CHARDEV(obj)                                     \
2473     OBJECT_CHECK(SocketChardev, (obj), TYPE_CHARDEV_SOCKET)
2474
2475 static gboolean socket_reconnect_timeout(gpointer opaque);
2476
2477 static void qemu_chr_socket_restart_timer(Chardev *chr)
2478 {
2479     SocketChardev *s = SOCKET_CHARDEV(chr);
2480     char *name;
2481
2482     assert(s->connected == 0);
2483     s->reconnect_timer = g_timeout_add_seconds(s->reconnect_time,
2484                                                socket_reconnect_timeout, chr);
2485     name = g_strdup_printf("chardev-socket-reconnect-%s", chr->label);
2486     g_source_set_name_by_id(s->reconnect_timer, name);
2487     g_free(name);
2488 }
2489
2490 static void check_report_connect_error(Chardev *chr,
2491                                        Error *err)
2492 {
2493     SocketChardev *s = SOCKET_CHARDEV(chr);
2494
2495     if (!s->connect_err_reported) {
2496         error_report("Unable to connect character device %s: %s",
2497                      chr->label, error_get_pretty(err));
2498         s->connect_err_reported = true;
2499     }
2500     qemu_chr_socket_restart_timer(chr);
2501 }
2502
2503 static gboolean tcp_chr_accept(QIOChannel *chan,
2504                                GIOCondition cond,
2505                                void *opaque);
2506
2507 /* Called with chr_write_lock held.  */
2508 static int tcp_chr_write(Chardev *chr, const uint8_t *buf, int len)
2509 {
2510     SocketChardev *s = SOCKET_CHARDEV(chr);
2511
2512     if (s->connected) {
2513         int ret =  io_channel_send_full(s->ioc, buf, len,
2514                                         s->write_msgfds,
2515                                         s->write_msgfds_num);
2516
2517         /* free the written msgfds, no matter what */
2518         if (s->write_msgfds_num) {
2519             g_free(s->write_msgfds);
2520             s->write_msgfds = 0;
2521             s->write_msgfds_num = 0;
2522         }
2523
2524         return ret;
2525     } else {
2526         /* XXX: indicate an error ? */
2527         return len;
2528     }
2529 }
2530
2531 static int tcp_chr_read_poll(void *opaque)
2532 {
2533     Chardev *chr = CHARDEV(opaque);
2534     SocketChardev *s = SOCKET_CHARDEV(opaque);
2535     if (!s->connected)
2536         return 0;
2537     s->max_size = qemu_chr_be_can_write(chr);
2538     return s->max_size;
2539 }
2540
2541 #define IAC 255
2542 #define IAC_BREAK 243
2543 static void tcp_chr_process_IAC_bytes(Chardev *chr,
2544                                       SocketChardev *s,
2545                                       uint8_t *buf, int *size)
2546 {
2547     /* Handle any telnet client's basic IAC options to satisfy char by
2548      * char mode with no echo.  All IAC options will be removed from
2549      * the buf and the do_telnetopt variable will be used to track the
2550      * state of the width of the IAC information.
2551      *
2552      * IAC commands come in sets of 3 bytes with the exception of the
2553      * "IAC BREAK" command and the double IAC.
2554      */
2555
2556     int i;
2557     int j = 0;
2558
2559     for (i = 0; i < *size; i++) {
2560         if (s->do_telnetopt > 1) {
2561             if ((unsigned char)buf[i] == IAC && s->do_telnetopt == 2) {
2562                 /* Double IAC means send an IAC */
2563                 if (j != i)
2564                     buf[j] = buf[i];
2565                 j++;
2566                 s->do_telnetopt = 1;
2567             } else {
2568                 if ((unsigned char)buf[i] == IAC_BREAK && s->do_telnetopt == 2) {
2569                     /* Handle IAC break commands by sending a serial break */
2570                     qemu_chr_be_event(chr, CHR_EVENT_BREAK);
2571                     s->do_telnetopt++;
2572                 }
2573                 s->do_telnetopt++;
2574             }
2575             if (s->do_telnetopt >= 4) {
2576                 s->do_telnetopt = 1;
2577             }
2578         } else {
2579             if ((unsigned char)buf[i] == IAC) {
2580                 s->do_telnetopt = 2;
2581             } else {
2582                 if (j != i)
2583                     buf[j] = buf[i];
2584                 j++;
2585             }
2586         }
2587     }
2588     *size = j;
2589 }
2590
2591 static int tcp_get_msgfds(Chardev *chr, int *fds, int num)
2592 {
2593     SocketChardev *s = SOCKET_CHARDEV(chr);
2594
2595     int to_copy = (s->read_msgfds_num < num) ? s->read_msgfds_num : num;
2596
2597     assert(num <= TCP_MAX_FDS);
2598
2599     if (to_copy) {
2600         int i;
2601
2602         memcpy(fds, s->read_msgfds, to_copy * sizeof(int));
2603
2604         /* Close unused fds */
2605         for (i = to_copy; i < s->read_msgfds_num; i++) {
2606             close(s->read_msgfds[i]);
2607         }
2608
2609         g_free(s->read_msgfds);
2610         s->read_msgfds = 0;
2611         s->read_msgfds_num = 0;
2612     }
2613
2614     return to_copy;
2615 }
2616
2617 static int tcp_set_msgfds(Chardev *chr, int *fds, int num)
2618 {
2619     SocketChardev *s = SOCKET_CHARDEV(chr);
2620
2621     /* clear old pending fd array */
2622     g_free(s->write_msgfds);
2623     s->write_msgfds = NULL;
2624     s->write_msgfds_num = 0;
2625
2626     if (!s->connected ||
2627         !qio_channel_has_feature(s->ioc,
2628                                  QIO_CHANNEL_FEATURE_FD_PASS)) {
2629         return -1;
2630     }
2631
2632     if (num) {
2633         s->write_msgfds = g_new(int, num);
2634         memcpy(s->write_msgfds, fds, num * sizeof(int));
2635     }
2636
2637     s->write_msgfds_num = num;
2638
2639     return 0;
2640 }
2641
2642 static ssize_t tcp_chr_recv(Chardev *chr, char *buf, size_t len)
2643 {
2644     SocketChardev *s = SOCKET_CHARDEV(chr);
2645     struct iovec iov = { .iov_base = buf, .iov_len = len };
2646     int ret;
2647     size_t i;
2648     int *msgfds = NULL;
2649     size_t msgfds_num = 0;
2650
2651     if (qio_channel_has_feature(s->ioc, QIO_CHANNEL_FEATURE_FD_PASS)) {
2652         ret = qio_channel_readv_full(s->ioc, &iov, 1,
2653                                      &msgfds, &msgfds_num,
2654                                      NULL);
2655     } else {
2656         ret = qio_channel_readv_full(s->ioc, &iov, 1,
2657                                      NULL, NULL,
2658                                      NULL);
2659     }
2660
2661     if (ret == QIO_CHANNEL_ERR_BLOCK) {
2662         errno = EAGAIN;
2663         ret = -1;
2664     } else if (ret == -1) {
2665         errno = EIO;
2666     }
2667
2668     if (msgfds_num) {
2669         /* close and clean read_msgfds */
2670         for (i = 0; i < s->read_msgfds_num; i++) {
2671             close(s->read_msgfds[i]);
2672         }
2673
2674         if (s->read_msgfds_num) {
2675             g_free(s->read_msgfds);
2676         }
2677
2678         s->read_msgfds = msgfds;
2679         s->read_msgfds_num = msgfds_num;
2680     }
2681
2682     for (i = 0; i < s->read_msgfds_num; i++) {
2683         int fd = s->read_msgfds[i];
2684         if (fd < 0) {
2685             continue;
2686         }
2687
2688         /* O_NONBLOCK is preserved across SCM_RIGHTS so reset it */
2689         qemu_set_block(fd);
2690
2691 #ifndef MSG_CMSG_CLOEXEC
2692         qemu_set_cloexec(fd);
2693 #endif
2694     }
2695
2696     return ret;
2697 }
2698
2699 static GSource *tcp_chr_add_watch(Chardev *chr, GIOCondition cond)
2700 {
2701     SocketChardev *s = SOCKET_CHARDEV(chr);
2702     return qio_channel_create_watch(s->ioc, cond);
2703 }
2704
2705 static void tcp_chr_free_connection(Chardev *chr)
2706 {
2707     SocketChardev *s = SOCKET_CHARDEV(chr);
2708     int i;
2709
2710     if (!s->connected) {
2711         return;
2712     }
2713
2714     if (s->read_msgfds_num) {
2715         for (i = 0; i < s->read_msgfds_num; i++) {
2716             close(s->read_msgfds[i]);
2717         }
2718         g_free(s->read_msgfds);
2719         s->read_msgfds = NULL;
2720         s->read_msgfds_num = 0;
2721     }
2722
2723     tcp_set_msgfds(chr, NULL, 0);
2724     remove_fd_in_watch(chr);
2725     object_unref(OBJECT(s->sioc));
2726     s->sioc = NULL;
2727     object_unref(OBJECT(s->ioc));
2728     s->ioc = NULL;
2729     g_free(chr->filename);
2730     chr->filename = NULL;
2731     s->connected = 0;
2732 }
2733
2734 static void tcp_chr_disconnect(Chardev *chr)
2735 {
2736     SocketChardev *s = SOCKET_CHARDEV(chr);
2737
2738     if (!s->connected) {
2739         return;
2740     }
2741
2742     tcp_chr_free_connection(chr);
2743
2744     if (s->listen_ioc) {
2745         s->listen_tag = qio_channel_add_watch(
2746             QIO_CHANNEL(s->listen_ioc), G_IO_IN, tcp_chr_accept, chr, NULL);
2747     }
2748     chr->filename = SocketAddress_to_str("disconnected:", s->addr,
2749                                          s->is_listen, s->is_telnet);
2750     qemu_chr_be_event(chr, CHR_EVENT_CLOSED);
2751     if (s->reconnect_time) {
2752         qemu_chr_socket_restart_timer(chr);
2753     }
2754 }
2755
2756 static gboolean tcp_chr_read(QIOChannel *chan, GIOCondition cond, void *opaque)
2757 {
2758     Chardev *chr = CHARDEV(opaque);
2759     SocketChardev *s = SOCKET_CHARDEV(opaque);
2760     uint8_t buf[CHR_READ_BUF_LEN];
2761     int len, size;
2762
2763     if (!s->connected || s->max_size <= 0) {
2764         return TRUE;
2765     }
2766     len = sizeof(buf);
2767     if (len > s->max_size)
2768         len = s->max_size;
2769     size = tcp_chr_recv(chr, (void *)buf, len);
2770     if (size == 0 || size == -1) {
2771         /* connection closed */
2772         tcp_chr_disconnect(chr);
2773     } else if (size > 0) {
2774         if (s->do_telnetopt)
2775             tcp_chr_process_IAC_bytes(chr, s, buf, &size);
2776         if (size > 0)
2777             qemu_chr_be_write(chr, buf, size);
2778     }
2779
2780     return TRUE;
2781 }
2782
2783 static int tcp_chr_sync_read(Chardev *chr, const uint8_t *buf, int len)
2784 {
2785     SocketChardev *s = SOCKET_CHARDEV(chr);
2786     int size;
2787
2788     if (!s->connected) {
2789         return 0;
2790     }
2791
2792     size = tcp_chr_recv(chr, (void *) buf, len);
2793     if (size == 0) {
2794         /* connection closed */
2795         tcp_chr_disconnect(chr);
2796     }
2797
2798     return size;
2799 }
2800
2801 static void tcp_chr_connect(void *opaque)
2802 {
2803     Chardev *chr = CHARDEV(opaque);
2804     SocketChardev *s = SOCKET_CHARDEV(opaque);
2805
2806     g_free(chr->filename);
2807     chr->filename = sockaddr_to_str(
2808         &s->sioc->localAddr, s->sioc->localAddrLen,
2809         &s->sioc->remoteAddr, s->sioc->remoteAddrLen,
2810         s->is_listen, s->is_telnet);
2811
2812     s->connected = 1;
2813     if (s->ioc) {
2814         chr->fd_in_tag = io_add_watch_poll(chr, s->ioc,
2815                                            tcp_chr_read_poll,
2816                                            tcp_chr_read,
2817                                            chr, NULL);
2818     }
2819     qemu_chr_be_generic_open(chr);
2820 }
2821
2822 static void tcp_chr_update_read_handler(Chardev *chr,
2823                                         GMainContext *context)
2824 {
2825     SocketChardev *s = SOCKET_CHARDEV(chr);
2826
2827     if (!s->connected) {
2828         return;
2829     }
2830
2831     remove_fd_in_watch(chr);
2832     if (s->ioc) {
2833         chr->fd_in_tag = io_add_watch_poll(chr, s->ioc,
2834                                            tcp_chr_read_poll,
2835                                            tcp_chr_read, chr,
2836                                            context);
2837     }
2838 }
2839
2840 typedef struct {
2841     Chardev *chr;
2842     char buf[12];
2843     size_t buflen;
2844 } TCPChardevTelnetInit;
2845
2846 static gboolean tcp_chr_telnet_init_io(QIOChannel *ioc,
2847                                        GIOCondition cond G_GNUC_UNUSED,
2848                                        gpointer user_data)
2849 {
2850     TCPChardevTelnetInit *init = user_data;
2851     ssize_t ret;
2852
2853     ret = qio_channel_write(ioc, init->buf, init->buflen, NULL);
2854     if (ret < 0) {
2855         if (ret == QIO_CHANNEL_ERR_BLOCK) {
2856             ret = 0;
2857         } else {
2858             tcp_chr_disconnect(init->chr);
2859             return FALSE;
2860         }
2861     }
2862     init->buflen -= ret;
2863
2864     if (init->buflen == 0) {
2865         tcp_chr_connect(init->chr);
2866         return FALSE;
2867     }
2868
2869     memmove(init->buf, init->buf + ret, init->buflen);
2870
2871     return TRUE;
2872 }
2873
2874 static void tcp_chr_telnet_init(Chardev *chr)
2875 {
2876     SocketChardev *s = SOCKET_CHARDEV(chr);
2877     TCPChardevTelnetInit *init = g_new0(TCPChardevTelnetInit, 1);
2878     size_t n = 0;
2879
2880     init->chr = chr;
2881     init->buflen = 12;
2882
2883 #define IACSET(x, a, b, c)                      \
2884     do {                                        \
2885         x[n++] = a;                             \
2886         x[n++] = b;                             \
2887         x[n++] = c;                             \
2888     } while (0)
2889
2890     /* Prep the telnet negotion to put telnet in binary,
2891      * no echo, single char mode */
2892     IACSET(init->buf, 0xff, 0xfb, 0x01);  /* IAC WILL ECHO */
2893     IACSET(init->buf, 0xff, 0xfb, 0x03);  /* IAC WILL Suppress go ahead */
2894     IACSET(init->buf, 0xff, 0xfb, 0x00);  /* IAC WILL Binary */
2895     IACSET(init->buf, 0xff, 0xfd, 0x00);  /* IAC DO Binary */
2896
2897 #undef IACSET
2898
2899     qio_channel_add_watch(
2900         s->ioc, G_IO_OUT,
2901         tcp_chr_telnet_init_io,
2902         init, NULL);
2903 }
2904
2905
2906 static void tcp_chr_tls_handshake(QIOTask *task,
2907                                   gpointer user_data)
2908 {
2909     Chardev *chr = user_data;
2910     SocketChardev *s = user_data;
2911
2912     if (qio_task_propagate_error(task, NULL)) {
2913         tcp_chr_disconnect(chr);
2914     } else {
2915         if (s->do_telnetopt) {
2916             tcp_chr_telnet_init(chr);
2917         } else {
2918             tcp_chr_connect(chr);
2919         }
2920     }
2921 }
2922
2923
2924 static void tcp_chr_tls_init(Chardev *chr)
2925 {
2926     SocketChardev *s = SOCKET_CHARDEV(chr);
2927     QIOChannelTLS *tioc;
2928     Error *err = NULL;
2929     gchar *name;
2930
2931     if (s->is_listen) {
2932         tioc = qio_channel_tls_new_server(
2933             s->ioc, s->tls_creds,
2934             NULL, /* XXX Use an ACL */
2935             &err);
2936     } else {
2937         tioc = qio_channel_tls_new_client(
2938             s->ioc, s->tls_creds,
2939             s->addr->u.inet.data->host,
2940             &err);
2941     }
2942     if (tioc == NULL) {
2943         error_free(err);
2944         tcp_chr_disconnect(chr);
2945         return;
2946     }
2947     name = g_strdup_printf("chardev-tls-%s-%s",
2948                            s->is_listen ? "server" : "client",
2949                            chr->label);
2950     qio_channel_set_name(QIO_CHANNEL(tioc), name);
2951     g_free(name);
2952     object_unref(OBJECT(s->ioc));
2953     s->ioc = QIO_CHANNEL(tioc);
2954
2955     qio_channel_tls_handshake(tioc,
2956                               tcp_chr_tls_handshake,
2957                               chr,
2958                               NULL);
2959 }
2960
2961
2962 static void tcp_chr_set_client_ioc_name(Chardev *chr,
2963                                         QIOChannelSocket *sioc)
2964 {
2965     SocketChardev *s = SOCKET_CHARDEV(chr);
2966     char *name;
2967     name = g_strdup_printf("chardev-tcp-%s-%s",
2968                            s->is_listen ? "server" : "client",
2969                            chr->label);
2970     qio_channel_set_name(QIO_CHANNEL(sioc), name);
2971     g_free(name);
2972
2973 }
2974
2975 static int tcp_chr_new_client(Chardev *chr, QIOChannelSocket *sioc)
2976 {
2977     SocketChardev *s = SOCKET_CHARDEV(chr);
2978
2979     if (s->ioc != NULL) {
2980         return -1;
2981     }
2982
2983     s->ioc = QIO_CHANNEL(sioc);
2984     object_ref(OBJECT(sioc));
2985     s->sioc = sioc;
2986     object_ref(OBJECT(sioc));
2987
2988     qio_channel_set_blocking(s->ioc, false, NULL);
2989
2990     if (s->do_nodelay) {
2991         qio_channel_set_delay(s->ioc, false);
2992     }
2993     if (s->listen_tag) {
2994         g_source_remove(s->listen_tag);
2995         s->listen_tag = 0;
2996     }
2997
2998     if (s->tls_creds) {
2999         tcp_chr_tls_init(chr);
3000     } else {
3001         if (s->do_telnetopt) {
3002             tcp_chr_telnet_init(chr);
3003         } else {
3004             tcp_chr_connect(chr);
3005         }
3006     }
3007
3008     return 0;
3009 }
3010
3011
3012 static int tcp_chr_add_client(Chardev *chr, int fd)
3013 {
3014     int ret;
3015     QIOChannelSocket *sioc;
3016
3017     sioc = qio_channel_socket_new_fd(fd, NULL);
3018     if (!sioc) {
3019         return -1;
3020     }
3021     tcp_chr_set_client_ioc_name(chr, sioc);
3022     ret = tcp_chr_new_client(chr, sioc);
3023     object_unref(OBJECT(sioc));
3024     return ret;
3025 }
3026
3027 static gboolean tcp_chr_accept(QIOChannel *channel,
3028                                GIOCondition cond,
3029                                void *opaque)
3030 {
3031     Chardev *chr = CHARDEV(opaque);
3032     QIOChannelSocket *sioc;
3033
3034     sioc = qio_channel_socket_accept(QIO_CHANNEL_SOCKET(channel),
3035                                      NULL);
3036     if (!sioc) {
3037         return TRUE;
3038     }
3039
3040     tcp_chr_new_client(chr, sioc);
3041
3042     object_unref(OBJECT(sioc));
3043
3044     return TRUE;
3045 }
3046
3047 static int tcp_chr_wait_connected(Chardev *chr, Error **errp)
3048 {
3049     SocketChardev *s = SOCKET_CHARDEV(chr);
3050     QIOChannelSocket *sioc;
3051
3052     /* It can't wait on s->connected, since it is set asynchronously
3053      * in TLS and telnet cases, only wait for an accepted socket */
3054     while (!s->ioc) {
3055         if (s->is_listen) {
3056             error_report("QEMU waiting for connection on: %s",
3057                          chr->filename);
3058             qio_channel_set_blocking(QIO_CHANNEL(s->listen_ioc), true, NULL);
3059             tcp_chr_accept(QIO_CHANNEL(s->listen_ioc), G_IO_IN, chr);
3060             qio_channel_set_blocking(QIO_CHANNEL(s->listen_ioc), false, NULL);
3061         } else {
3062             sioc = qio_channel_socket_new();
3063             tcp_chr_set_client_ioc_name(chr, sioc);
3064             if (qio_channel_socket_connect_sync(sioc, s->addr, errp) < 0) {
3065                 object_unref(OBJECT(sioc));
3066                 return -1;
3067             }
3068             tcp_chr_new_client(chr, sioc);
3069             object_unref(OBJECT(sioc));
3070         }
3071     }
3072
3073     return 0;
3074 }
3075
3076 static int qemu_chr_wait_connected(Chardev *chr, Error **errp)
3077 {
3078     ChardevClass *cc = CHARDEV_GET_CLASS(chr);
3079
3080     if (cc->chr_wait_connected) {
3081         return cc->chr_wait_connected(chr, errp);
3082     }
3083
3084     return 0;
3085 }
3086
3087 int qemu_chr_fe_wait_connected(CharBackend *be, Error **errp)
3088 {
3089     if (!be->chr) {
3090         error_setg(errp, "missing associated backend");
3091         return -1;
3092     }
3093
3094     return qemu_chr_wait_connected(be->chr, errp);
3095 }
3096
3097 static void char_socket_finalize(Object *obj)
3098 {
3099     Chardev *chr = CHARDEV(obj);
3100     SocketChardev *s = SOCKET_CHARDEV(obj);
3101
3102     tcp_chr_free_connection(chr);
3103
3104     if (s->reconnect_timer) {
3105         g_source_remove(s->reconnect_timer);
3106         s->reconnect_timer = 0;
3107     }
3108     qapi_free_SocketAddress(s->addr);
3109     if (s->listen_tag) {
3110         g_source_remove(s->listen_tag);
3111         s->listen_tag = 0;
3112     }
3113     if (s->listen_ioc) {
3114         object_unref(OBJECT(s->listen_ioc));
3115     }
3116     if (s->tls_creds) {
3117         object_unref(OBJECT(s->tls_creds));
3118     }
3119
3120     qemu_chr_be_event(chr, CHR_EVENT_CLOSED);
3121 }
3122
3123
3124 static void qemu_chr_socket_connected(QIOTask *task, void *opaque)
3125 {
3126     QIOChannelSocket *sioc = QIO_CHANNEL_SOCKET(qio_task_get_source(task));
3127     Chardev *chr = CHARDEV(opaque);
3128     SocketChardev *s = SOCKET_CHARDEV(chr);
3129     Error *err = NULL;
3130
3131     if (qio_task_propagate_error(task, &err)) {
3132         check_report_connect_error(chr, err);
3133         error_free(err);
3134         goto cleanup;
3135     }
3136
3137     s->connect_err_reported = false;
3138     tcp_chr_new_client(chr, sioc);
3139
3140  cleanup:
3141     object_unref(OBJECT(sioc));
3142 }
3143
3144
3145 QemuOpts *qemu_chr_parse_compat(const char *label, const char *filename)
3146 {
3147     char host[65], port[33], width[8], height[8];
3148     int pos;
3149     const char *p;
3150     QemuOpts *opts;
3151     Error *local_err = NULL;
3152
3153     opts = qemu_opts_create(qemu_find_opts("chardev"), label, 1, &local_err);
3154     if (local_err) {
3155         error_report_err(local_err);
3156         return NULL;
3157     }
3158
3159     if (strstart(filename, "mon:", &p)) {
3160         filename = p;
3161         qemu_opt_set(opts, "mux", "on", &error_abort);
3162         if (strcmp(filename, "stdio") == 0) {
3163             /* Monitor is muxed to stdio: do not exit on Ctrl+C by default
3164              * but pass it to the guest.  Handle this only for compat syntax,
3165              * for -chardev syntax we have special option for this.
3166              * This is what -nographic did, redirecting+muxing serial+monitor
3167              * to stdio causing Ctrl+C to be passed to guest. */
3168             qemu_opt_set(opts, "signal", "off", &error_abort);
3169         }
3170     }
3171
3172     if (strcmp(filename, "null")    == 0 ||
3173         strcmp(filename, "pty")     == 0 ||
3174         strcmp(filename, "msmouse") == 0 ||
3175         strcmp(filename, "braille") == 0 ||
3176         strcmp(filename, "testdev") == 0 ||
3177         strcmp(filename, "stdio")   == 0) {
3178         qemu_opt_set(opts, "backend", filename, &error_abort);
3179         return opts;
3180     }
3181     if (strstart(filename, "vc", &p)) {
3182         qemu_opt_set(opts, "backend", "vc", &error_abort);
3183         if (*p == ':') {
3184             if (sscanf(p+1, "%7[0-9]x%7[0-9]", width, height) == 2) {
3185                 /* pixels */
3186                 qemu_opt_set(opts, "width", width, &error_abort);
3187                 qemu_opt_set(opts, "height", height, &error_abort);
3188             } else if (sscanf(p+1, "%7[0-9]Cx%7[0-9]C", width, height) == 2) {
3189                 /* chars */
3190                 qemu_opt_set(opts, "cols", width, &error_abort);
3191                 qemu_opt_set(opts, "rows", height, &error_abort);
3192             } else {
3193                 goto fail;
3194             }
3195         }
3196         return opts;
3197     }
3198     if (strcmp(filename, "con:") == 0) {
3199         qemu_opt_set(opts, "backend", "console", &error_abort);
3200         return opts;
3201     }
3202     if (strstart(filename, "COM", NULL)) {
3203         qemu_opt_set(opts, "backend", "serial", &error_abort);
3204         qemu_opt_set(opts, "path", filename, &error_abort);
3205         return opts;
3206     }
3207     if (strstart(filename, "file:", &p)) {
3208         qemu_opt_set(opts, "backend", "file", &error_abort);
3209         qemu_opt_set(opts, "path", p, &error_abort);
3210         return opts;
3211     }
3212     if (strstart(filename, "pipe:", &p)) {
3213         qemu_opt_set(opts, "backend", "pipe", &error_abort);
3214         qemu_opt_set(opts, "path", p, &error_abort);
3215         return opts;
3216     }
3217     if (strstart(filename, "tcp:", &p) ||
3218         strstart(filename, "telnet:", &p)) {
3219         if (sscanf(p, "%64[^:]:%32[^,]%n", host, port, &pos) < 2) {
3220             host[0] = 0;
3221             if (sscanf(p, ":%32[^,]%n", port, &pos) < 1)
3222                 goto fail;
3223         }
3224         qemu_opt_set(opts, "backend", "socket", &error_abort);
3225         qemu_opt_set(opts, "host", host, &error_abort);
3226         qemu_opt_set(opts, "port", port, &error_abort);
3227         if (p[pos] == ',') {
3228             qemu_opts_do_parse(opts, p+pos+1, NULL, &local_err);
3229             if (local_err) {
3230                 error_report_err(local_err);
3231                 goto fail;
3232             }
3233         }
3234         if (strstart(filename, "telnet:", &p))
3235             qemu_opt_set(opts, "telnet", "on", &error_abort);
3236         return opts;
3237     }
3238     if (strstart(filename, "udp:", &p)) {
3239         qemu_opt_set(opts, "backend", "udp", &error_abort);
3240         if (sscanf(p, "%64[^:]:%32[^@,]%n", host, port, &pos) < 2) {
3241             host[0] = 0;
3242             if (sscanf(p, ":%32[^@,]%n", port, &pos) < 1) {
3243                 goto fail;
3244             }
3245         }
3246         qemu_opt_set(opts, "host", host, &error_abort);
3247         qemu_opt_set(opts, "port", port, &error_abort);
3248         if (p[pos] == '@') {
3249             p += pos + 1;
3250             if (sscanf(p, "%64[^:]:%32[^,]%n", host, port, &pos) < 2) {
3251                 host[0] = 0;
3252                 if (sscanf(p, ":%32[^,]%n", port, &pos) < 1) {
3253                     goto fail;
3254                 }
3255             }
3256             qemu_opt_set(opts, "localaddr", host, &error_abort);
3257             qemu_opt_set(opts, "localport", port, &error_abort);
3258         }
3259         return opts;
3260     }
3261     if (strstart(filename, "unix:", &p)) {
3262         qemu_opt_set(opts, "backend", "socket", &error_abort);
3263         qemu_opts_do_parse(opts, p, "path", &local_err);
3264         if (local_err) {
3265             error_report_err(local_err);
3266             goto fail;
3267         }
3268         return opts;
3269     }
3270     if (strstart(filename, "/dev/parport", NULL) ||
3271         strstart(filename, "/dev/ppi", NULL)) {
3272         qemu_opt_set(opts, "backend", "parport", &error_abort);
3273         qemu_opt_set(opts, "path", filename, &error_abort);
3274         return opts;
3275     }
3276     if (strstart(filename, "/dev/", NULL)) {
3277         qemu_opt_set(opts, "backend", "tty", &error_abort);
3278         qemu_opt_set(opts, "path", filename, &error_abort);
3279         return opts;
3280     }
3281
3282 fail:
3283     qemu_opts_del(opts);
3284     return NULL;
3285 }
3286
3287 void qemu_chr_parse_common(QemuOpts *opts, ChardevCommon *backend)
3288 {
3289     const char *logfile = qemu_opt_get(opts, "logfile");
3290
3291     backend->has_logfile = logfile != NULL;
3292     backend->logfile = logfile ? g_strdup(logfile) : NULL;
3293
3294     backend->has_logappend = true;
3295     backend->logappend = qemu_opt_get_bool(opts, "logappend", false);
3296 }
3297
3298
3299 static void qemu_chr_parse_file_out(QemuOpts *opts, ChardevBackend *backend,
3300                                     Error **errp)
3301 {
3302     const char *path = qemu_opt_get(opts, "path");
3303     ChardevFile *file;
3304
3305     backend->type = CHARDEV_BACKEND_KIND_FILE;
3306     if (path == NULL) {
3307         error_setg(errp, "chardev: file: no filename given");
3308         return;
3309     }
3310     file = backend->u.file.data = g_new0(ChardevFile, 1);
3311     qemu_chr_parse_common(opts, qapi_ChardevFile_base(file));
3312     file->out = g_strdup(path);
3313
3314     file->has_append = true;
3315     file->append = qemu_opt_get_bool(opts, "append", false);
3316 }
3317
3318 static void qemu_chr_parse_stdio(QemuOpts *opts, ChardevBackend *backend,
3319                                  Error **errp)
3320 {
3321     ChardevStdio *stdio;
3322
3323     backend->type = CHARDEV_BACKEND_KIND_STDIO;
3324     stdio = backend->u.stdio.data = g_new0(ChardevStdio, 1);
3325     qemu_chr_parse_common(opts, qapi_ChardevStdio_base(stdio));
3326     stdio->has_signal = true;
3327     stdio->signal = qemu_opt_get_bool(opts, "signal", true);
3328 }
3329
3330 static void char_stdio_class_init(ObjectClass *oc, void *data)
3331 {
3332     ChardevClass *cc = CHARDEV_CLASS(oc);
3333
3334     cc->parse = qemu_chr_parse_stdio;
3335     cc->open = qemu_chr_open_stdio;
3336 #ifdef _WIN32
3337     cc->chr_write = win_stdio_write;
3338     cc->chr_set_echo = qemu_chr_set_echo_win_stdio;
3339 #else
3340     cc->chr_set_echo = qemu_chr_set_echo_stdio;
3341 #endif
3342 }
3343
3344 static const TypeInfo char_stdio_type_info = {
3345     .name = TYPE_CHARDEV_STDIO,
3346 #ifdef _WIN32
3347     .parent = TYPE_CHARDEV_WIN_STDIO,
3348 #else
3349     .parent = TYPE_CHARDEV_FD,
3350     .instance_finalize = char_stdio_finalize,
3351 #endif
3352     .class_init = char_stdio_class_init,
3353 };
3354
3355 #ifdef HAVE_CHARDEV_SERIAL
3356 static void qemu_chr_parse_serial(QemuOpts *opts, ChardevBackend *backend,
3357                                   Error **errp)
3358 {
3359     const char *device = qemu_opt_get(opts, "path");
3360     ChardevHostdev *serial;
3361
3362     backend->type = CHARDEV_BACKEND_KIND_SERIAL;
3363     if (device == NULL) {
3364         error_setg(errp, "chardev: serial/tty: no device path given");
3365         return;
3366     }
3367     serial = backend->u.serial.data = g_new0(ChardevHostdev, 1);
3368     qemu_chr_parse_common(opts, qapi_ChardevHostdev_base(serial));
3369     serial->device = g_strdup(device);
3370 }
3371 #endif
3372
3373 #ifdef HAVE_CHARDEV_PARPORT
3374 static void qemu_chr_parse_parallel(QemuOpts *opts, ChardevBackend *backend,
3375                                     Error **errp)
3376 {
3377     const char *device = qemu_opt_get(opts, "path");
3378     ChardevHostdev *parallel;
3379
3380     backend->type = CHARDEV_BACKEND_KIND_PARALLEL;
3381     if (device == NULL) {
3382         error_setg(errp, "chardev: parallel: no device path given");
3383         return;
3384     }
3385     parallel = backend->u.parallel.data = g_new0(ChardevHostdev, 1);
3386     qemu_chr_parse_common(opts, qapi_ChardevHostdev_base(parallel));
3387     parallel->device = g_strdup(device);
3388 }
3389 #endif
3390
3391 static void qemu_chr_parse_pipe(QemuOpts *opts, ChardevBackend *backend,
3392                                 Error **errp)
3393 {
3394     const char *device = qemu_opt_get(opts, "path");
3395     ChardevHostdev *dev;
3396
3397     backend->type = CHARDEV_BACKEND_KIND_PIPE;
3398     if (device == NULL) {
3399         error_setg(errp, "chardev: pipe: no device path given");
3400         return;
3401     }
3402     dev = backend->u.pipe.data = g_new0(ChardevHostdev, 1);
3403     qemu_chr_parse_common(opts, qapi_ChardevHostdev_base(dev));
3404     dev->device = g_strdup(device);
3405 }
3406
3407 static void char_pipe_class_init(ObjectClass *oc, void *data)
3408 {
3409     ChardevClass *cc = CHARDEV_CLASS(oc);
3410
3411     cc->parse = qemu_chr_parse_pipe;
3412     cc->open = qemu_chr_open_pipe;
3413 }
3414
3415 static const TypeInfo char_pipe_type_info = {
3416     .name = TYPE_CHARDEV_PIPE,
3417 #ifdef _WIN32
3418     .parent = TYPE_CHARDEV_WIN,
3419 #else
3420     .parent = TYPE_CHARDEV_FD,
3421 #endif
3422     .class_init = char_pipe_class_init,
3423 };
3424
3425 static void qemu_chr_parse_socket(QemuOpts *opts, ChardevBackend *backend,
3426                                   Error **errp)
3427 {
3428     bool is_listen      = qemu_opt_get_bool(opts, "server", false);
3429     bool is_waitconnect = is_listen && qemu_opt_get_bool(opts, "wait", true);
3430     bool is_telnet      = qemu_opt_get_bool(opts, "telnet", false);
3431     bool do_nodelay     = !qemu_opt_get_bool(opts, "delay", true);
3432     int64_t reconnect   = qemu_opt_get_number(opts, "reconnect", 0);
3433     const char *path = qemu_opt_get(opts, "path");
3434     const char *host = qemu_opt_get(opts, "host");
3435     const char *port = qemu_opt_get(opts, "port");
3436     const char *tls_creds = qemu_opt_get(opts, "tls-creds");
3437     SocketAddress *addr;
3438     ChardevSocket *sock;
3439
3440     backend->type = CHARDEV_BACKEND_KIND_SOCKET;
3441     if (!path) {
3442         if (!host) {
3443             error_setg(errp, "chardev: socket: no host given");
3444             return;
3445         }
3446         if (!port) {
3447             error_setg(errp, "chardev: socket: no port given");
3448             return;
3449         }
3450     } else {
3451         if (tls_creds) {
3452             error_setg(errp, "TLS can only be used over TCP socket");
3453             return;
3454         }
3455     }
3456
3457     sock = backend->u.socket.data = g_new0(ChardevSocket, 1);
3458     qemu_chr_parse_common(opts, qapi_ChardevSocket_base(sock));
3459
3460     sock->has_nodelay = true;
3461     sock->nodelay = do_nodelay;
3462     sock->has_server = true;
3463     sock->server = is_listen;
3464     sock->has_telnet = true;
3465     sock->telnet = is_telnet;
3466     sock->has_wait = true;
3467     sock->wait = is_waitconnect;
3468     sock->has_reconnect = true;
3469     sock->reconnect = reconnect;
3470     sock->tls_creds = g_strdup(tls_creds);
3471
3472     addr = g_new0(SocketAddress, 1);
3473     if (path) {
3474         UnixSocketAddress *q_unix;
3475         addr->type = SOCKET_ADDRESS_KIND_UNIX;
3476         q_unix = addr->u.q_unix.data = g_new0(UnixSocketAddress, 1);
3477         q_unix->path = g_strdup(path);
3478     } else {
3479         addr->type = SOCKET_ADDRESS_KIND_INET;
3480         addr->u.inet.data = g_new(InetSocketAddress, 1);
3481         *addr->u.inet.data = (InetSocketAddress) {
3482             .host = g_strdup(host),
3483             .port = g_strdup(port),
3484             .has_to = qemu_opt_get(opts, "to"),
3485             .to = qemu_opt_get_number(opts, "to", 0),
3486             .has_ipv4 = qemu_opt_get(opts, "ipv4"),
3487             .ipv4 = qemu_opt_get_bool(opts, "ipv4", 0),
3488             .has_ipv6 = qemu_opt_get(opts, "ipv6"),
3489             .ipv6 = qemu_opt_get_bool(opts, "ipv6", 0),
3490         };
3491     }
3492     sock->addr = addr;
3493 }
3494
3495 static void qemu_chr_parse_udp(QemuOpts *opts, ChardevBackend *backend,
3496                                Error **errp)
3497 {
3498     const char *host = qemu_opt_get(opts, "host");
3499     const char *port = qemu_opt_get(opts, "port");
3500     const char *localaddr = qemu_opt_get(opts, "localaddr");
3501     const char *localport = qemu_opt_get(opts, "localport");
3502     bool has_local = false;
3503     SocketAddress *addr;
3504     ChardevUdp *udp;
3505
3506     backend->type = CHARDEV_BACKEND_KIND_UDP;
3507     if (host == NULL || strlen(host) == 0) {
3508         host = "localhost";
3509     }
3510     if (port == NULL || strlen(port) == 0) {
3511         error_setg(errp, "chardev: udp: remote port not specified");
3512         return;
3513     }
3514     if (localport == NULL || strlen(localport) == 0) {
3515         localport = "0";
3516     } else {
3517         has_local = true;
3518     }
3519     if (localaddr == NULL || strlen(localaddr) == 0) {
3520         localaddr = "";
3521     } else {
3522         has_local = true;
3523     }
3524
3525     udp = backend->u.udp.data = g_new0(ChardevUdp, 1);
3526     qemu_chr_parse_common(opts, qapi_ChardevUdp_base(udp));
3527
3528     addr = g_new0(SocketAddress, 1);
3529     addr->type = SOCKET_ADDRESS_KIND_INET;
3530     addr->u.inet.data = g_new(InetSocketAddress, 1);
3531     *addr->u.inet.data = (InetSocketAddress) {
3532         .host = g_strdup(host),
3533         .port = g_strdup(port),
3534         .has_ipv4 = qemu_opt_get(opts, "ipv4"),
3535         .ipv4 = qemu_opt_get_bool(opts, "ipv4", 0),
3536         .has_ipv6 = qemu_opt_get(opts, "ipv6"),
3537         .ipv6 = qemu_opt_get_bool(opts, "ipv6", 0),
3538     };
3539     udp->remote = addr;
3540
3541     if (has_local) {
3542         udp->has_local = true;
3543         addr = g_new0(SocketAddress, 1);
3544         addr->type = SOCKET_ADDRESS_KIND_INET;
3545         addr->u.inet.data = g_new(InetSocketAddress, 1);
3546         *addr->u.inet.data = (InetSocketAddress) {
3547             .host = g_strdup(localaddr),
3548             .port = g_strdup(localport),
3549         };
3550         udp->local = addr;
3551     }
3552 }
3553
3554 static const ChardevClass *char_get_class(const char *driver, Error **errp)
3555 {
3556     ObjectClass *oc;
3557     const ChardevClass *cc;
3558     char *typename = g_strdup_printf("chardev-%s", driver);
3559
3560     oc = object_class_by_name(typename);
3561     g_free(typename);
3562
3563     if (!object_class_dynamic_cast(oc, TYPE_CHARDEV)) {
3564         error_setg(errp, "'%s' is not a valid char driver name", driver);
3565         return NULL;
3566     }
3567
3568     if (object_class_is_abstract(oc)) {
3569         error_setg(errp, QERR_INVALID_PARAMETER_VALUE, "driver",
3570                    "abstract device type");
3571         return NULL;
3572     }
3573
3574     cc = CHARDEV_CLASS(oc);
3575     if (cc->internal) {
3576         error_setg(errp, "'%s' is not a valid char driver name", driver);
3577         return NULL;
3578     }
3579
3580     return cc;
3581 }
3582
3583 static Chardev *qemu_chardev_add(const char *id, const char *typename,
3584                                  ChardevBackend *backend, Error **errp)
3585 {
3586     Chardev *chr;
3587
3588     chr = qemu_chr_find(id);
3589     if (chr) {
3590         error_setg(errp, "Chardev '%s' already exists", id);
3591         return NULL;
3592     }
3593
3594     chr = qemu_chardev_new(id, typename, backend, errp);
3595     if (!chr) {
3596         return NULL;
3597     }
3598
3599     QTAILQ_INSERT_TAIL(&chardevs, chr, next);
3600     return chr;
3601 }
3602
3603 static const struct ChardevAlias {
3604     const char *typename;
3605     const char *alias;
3606 } chardev_alias_table[] = {
3607 #ifdef HAVE_CHARDEV_PARPORT
3608     { "parallel", "parport" },
3609 #endif
3610 #ifdef HAVE_CHARDEV_SERIAL
3611     { "serial", "tty" },
3612 #endif
3613 };
3614
3615 typedef struct ChadevClassFE {
3616     void (*fn)(const char *name, void *opaque);
3617     void *opaque;
3618 } ChadevClassFE;
3619
3620 static void
3621 chardev_class_foreach(ObjectClass *klass, void *opaque)
3622 {
3623     ChadevClassFE *fe = opaque;
3624
3625     assert(g_str_has_prefix(object_class_get_name(klass), "chardev-"));
3626     if (CHARDEV_CLASS(klass)->internal) {
3627         return;
3628     }
3629
3630     fe->fn(object_class_get_name(klass) + 8, fe->opaque);
3631 }
3632
3633 static void
3634 chardev_name_foreach(void (*fn)(const char *name, void *opaque), void *opaque)
3635 {
3636     ChadevClassFE fe = { .fn = fn, .opaque = opaque };
3637     int i;
3638
3639     object_class_foreach(chardev_class_foreach, TYPE_CHARDEV, false, &fe);
3640
3641     for (i = 0; i < ARRAY_SIZE(chardev_alias_table); i++) {
3642         fn(chardev_alias_table[i].alias, opaque);
3643     }
3644 }
3645
3646 static void
3647 help_string_append(const char *name, void *opaque)
3648 {
3649     GString *str = opaque;
3650
3651     g_string_append_printf(str, "\n%s", name);
3652 }
3653
3654 Chardev *qemu_chr_new_from_opts(QemuOpts *opts,
3655                                 Error **errp)
3656 {
3657     Error *local_err = NULL;
3658     const ChardevClass *cc;
3659     Chardev *chr;
3660     int i;
3661     ChardevBackend *backend = NULL;
3662     const char *name = qemu_opt_get(opts, "backend");
3663     const char *id = qemu_opts_id(opts);
3664     char *bid = NULL;
3665
3666     if (name == NULL) {
3667         error_setg(errp, "chardev: \"%s\" missing backend",
3668                    qemu_opts_id(opts));
3669         return NULL;
3670     }
3671
3672     if (is_help_option(name)) {
3673         GString *str = g_string_new("");
3674
3675         chardev_name_foreach(help_string_append, str);
3676
3677         error_report("Available chardev backend types: %s", str->str);
3678         g_string_free(str, true);
3679         exit(0);
3680     }
3681
3682     if (id == NULL) {
3683         error_setg(errp, "chardev: no id specified");
3684         return NULL;
3685     }
3686
3687     for (i = 0; i < ARRAY_SIZE(chardev_alias_table); i++) {
3688         if (g_strcmp0(chardev_alias_table[i].alias, name) == 0) {
3689             name = chardev_alias_table[i].typename;
3690             break;
3691         }
3692     }
3693
3694     cc = char_get_class(name, errp);
3695     if (cc == NULL) {
3696         return NULL;
3697     }
3698
3699     backend = g_new0(ChardevBackend, 1);
3700     backend->type = CHARDEV_BACKEND_KIND_NULL;
3701
3702     if (qemu_opt_get_bool(opts, "mux", 0)) {
3703         bid = g_strdup_printf("%s-base", id);
3704     }
3705
3706     chr = NULL;
3707     if (cc->parse) {
3708         cc->parse(opts, backend, &local_err);
3709         if (local_err) {
3710             error_propagate(errp, local_err);
3711             goto out;
3712         }
3713     } else {
3714         ChardevCommon *ccom = g_new0(ChardevCommon, 1);
3715         qemu_chr_parse_common(opts, ccom);
3716         backend->u.null.data = ccom; /* Any ChardevCommon member would work */
3717     }
3718
3719     chr = qemu_chardev_add(bid ? bid : id,
3720                            object_class_get_name(OBJECT_CLASS(cc)),
3721                            backend, errp);
3722     if (chr == NULL) {
3723         goto out;
3724     }
3725
3726     if (bid) {
3727         Chardev *mux;
3728         qapi_free_ChardevBackend(backend);
3729         backend = g_new0(ChardevBackend, 1);
3730         backend->type = CHARDEV_BACKEND_KIND_MUX;
3731         backend->u.mux.data = g_new0(ChardevMux, 1);
3732         backend->u.mux.data->chardev = g_strdup(bid);
3733         mux = qemu_chardev_add(id, TYPE_CHARDEV_MUX, backend, errp);
3734         if (mux == NULL) {
3735             qemu_chr_delete(chr);
3736             chr = NULL;
3737             goto out;
3738         }
3739         chr = mux;
3740     }
3741
3742 out:
3743     qapi_free_ChardevBackend(backend);
3744     g_free(bid);
3745     return chr;
3746 }
3747
3748 Chardev *qemu_chr_new_noreplay(const char *label, const char *filename)
3749 {
3750     const char *p;
3751     Chardev *chr;
3752     QemuOpts *opts;
3753     Error *err = NULL;
3754
3755     if (strstart(filename, "chardev:", &p)) {
3756         return qemu_chr_find(p);
3757     }
3758
3759     opts = qemu_chr_parse_compat(label, filename);
3760     if (!opts)
3761         return NULL;
3762
3763     chr = qemu_chr_new_from_opts(opts, &err);
3764     if (err) {
3765         error_report_err(err);
3766     }
3767     if (chr && qemu_opt_get_bool(opts, "mux", 0)) {
3768         monitor_init(chr, MONITOR_USE_READLINE);
3769     }
3770     qemu_opts_del(opts);
3771     return chr;
3772 }
3773
3774 Chardev *qemu_chr_new(const char *label, const char *filename)
3775 {
3776     Chardev *chr;
3777     chr = qemu_chr_new_noreplay(label, filename);
3778     if (chr) {
3779         if (replay_mode != REPLAY_MODE_NONE) {
3780             qemu_chr_set_feature(chr, QEMU_CHAR_FEATURE_REPLAY);
3781         }
3782         if (qemu_chr_replay(chr) && CHARDEV_GET_CLASS(chr)->chr_ioctl) {
3783             error_report("Replay: ioctl is not supported "
3784                          "for serial devices yet");
3785         }
3786         replay_register_char_driver(chr);
3787     }
3788     return chr;
3789 }
3790
3791 void qemu_chr_fe_set_echo(CharBackend *be, bool echo)
3792 {
3793     Chardev *chr = be->chr;
3794
3795     if (chr && CHARDEV_GET_CLASS(chr)->chr_set_echo) {
3796         CHARDEV_GET_CLASS(chr)->chr_set_echo(chr, echo);
3797     }
3798 }
3799
3800 void qemu_chr_fe_set_open(CharBackend *be, int fe_open)
3801 {
3802     Chardev *chr = be->chr;
3803
3804     if (!chr) {
3805         return;
3806     }
3807
3808     if (be->fe_open == fe_open) {
3809         return;
3810     }
3811     be->fe_open = fe_open;
3812     if (CHARDEV_GET_CLASS(chr)->chr_set_fe_open) {
3813         CHARDEV_GET_CLASS(chr)->chr_set_fe_open(chr, fe_open);
3814     }
3815 }
3816
3817 guint qemu_chr_fe_add_watch(CharBackend *be, GIOCondition cond,
3818                             GIOFunc func, void *user_data)
3819 {
3820     Chardev *s = be->chr;
3821     GSource *src;
3822     guint tag;
3823
3824     if (!s || CHARDEV_GET_CLASS(s)->chr_add_watch == NULL) {
3825         return 0;
3826     }
3827
3828     src = CHARDEV_GET_CLASS(s)->chr_add_watch(s, cond);
3829     if (!src) {
3830         return 0;
3831     }
3832
3833     g_source_set_callback(src, (GSourceFunc)func, user_data, NULL);
3834     tag = g_source_attach(src, NULL);
3835     g_source_unref(src);
3836
3837     return tag;
3838 }
3839
3840 void qemu_chr_fe_disconnect(CharBackend *be)
3841 {
3842     Chardev *chr = be->chr;
3843
3844     if (chr && CHARDEV_GET_CLASS(chr)->chr_disconnect) {
3845         CHARDEV_GET_CLASS(chr)->chr_disconnect(chr);
3846     }
3847 }
3848
3849 void qemu_chr_delete(Chardev *chr)
3850 {
3851     QTAILQ_REMOVE(&chardevs, chr, next);
3852     object_unref(OBJECT(chr));
3853 }
3854
3855 ChardevInfoList *qmp_query_chardev(Error **errp)
3856 {
3857     ChardevInfoList *chr_list = NULL;
3858     Chardev *chr;
3859
3860     QTAILQ_FOREACH(chr, &chardevs, next) {
3861         ChardevInfoList *info = g_malloc0(sizeof(*info));
3862         info->value = g_malloc0(sizeof(*info->value));
3863         info->value->label = g_strdup(chr->label);
3864         info->value->filename = g_strdup(chr->filename);
3865         info->value->frontend_open = chr->be && chr->be->fe_open;
3866
3867         info->next = chr_list;
3868         chr_list = info;
3869     }
3870
3871     return chr_list;
3872 }
3873
3874 static void
3875 qmp_prepend_backend(const char *name, void *opaque)
3876 {
3877     ChardevBackendInfoList **list = opaque;
3878     ChardevBackendInfoList *info = g_malloc0(sizeof(*info));
3879
3880     info->value = g_malloc0(sizeof(*info->value));
3881     info->value->name = g_strdup(name);
3882     info->next = *list;
3883     *list = info;
3884 }
3885
3886 ChardevBackendInfoList *qmp_query_chardev_backends(Error **errp)
3887 {
3888     ChardevBackendInfoList *backend_list = NULL;
3889
3890     chardev_name_foreach(qmp_prepend_backend, &backend_list);
3891
3892     return backend_list;
3893 }
3894
3895 Chardev *qemu_chr_find(const char *name)
3896 {
3897     Chardev *chr;
3898
3899     QTAILQ_FOREACH(chr, &chardevs, next) {
3900         if (strcmp(chr->label, name) != 0)
3901             continue;
3902         return chr;
3903     }
3904     return NULL;
3905 }
3906
3907 QemuOptsList qemu_chardev_opts = {
3908     .name = "chardev",
3909     .implied_opt_name = "backend",
3910     .head = QTAILQ_HEAD_INITIALIZER(qemu_chardev_opts.head),
3911     .desc = {
3912         {
3913             .name = "backend",
3914             .type = QEMU_OPT_STRING,
3915         },{
3916             .name = "path",
3917             .type = QEMU_OPT_STRING,
3918         },{
3919             .name = "host",
3920             .type = QEMU_OPT_STRING,
3921         },{
3922             .name = "port",
3923             .type = QEMU_OPT_STRING,
3924         },{
3925             .name = "localaddr",
3926             .type = QEMU_OPT_STRING,
3927         },{
3928             .name = "localport",
3929             .type = QEMU_OPT_STRING,
3930         },{
3931             .name = "to",
3932             .type = QEMU_OPT_NUMBER,
3933         },{
3934             .name = "ipv4",
3935             .type = QEMU_OPT_BOOL,
3936         },{
3937             .name = "ipv6",
3938             .type = QEMU_OPT_BOOL,
3939         },{
3940             .name = "wait",
3941             .type = QEMU_OPT_BOOL,
3942         },{
3943             .name = "server",
3944             .type = QEMU_OPT_BOOL,
3945         },{
3946             .name = "delay",
3947             .type = QEMU_OPT_BOOL,
3948         },{
3949             .name = "reconnect",
3950             .type = QEMU_OPT_NUMBER,
3951         },{
3952             .name = "telnet",
3953             .type = QEMU_OPT_BOOL,
3954         },{
3955             .name = "tls-creds",
3956             .type = QEMU_OPT_STRING,
3957         },{
3958             .name = "width",
3959             .type = QEMU_OPT_NUMBER,
3960         },{
3961             .name = "height",
3962             .type = QEMU_OPT_NUMBER,
3963         },{
3964             .name = "cols",
3965             .type = QEMU_OPT_NUMBER,
3966         },{
3967             .name = "rows",
3968             .type = QEMU_OPT_NUMBER,
3969         },{
3970             .name = "mux",
3971             .type = QEMU_OPT_BOOL,
3972         },{
3973             .name = "signal",
3974             .type = QEMU_OPT_BOOL,
3975         },{
3976             .name = "name",
3977             .type = QEMU_OPT_STRING,
3978         },{
3979             .name = "debug",
3980             .type = QEMU_OPT_NUMBER,
3981         },{
3982             .name = "size",
3983             .type = QEMU_OPT_SIZE,
3984         },{
3985             .name = "chardev",
3986             .type = QEMU_OPT_STRING,
3987         },{
3988             .name = "append",
3989             .type = QEMU_OPT_BOOL,
3990         },{
3991             .name = "logfile",
3992             .type = QEMU_OPT_STRING,
3993         },{
3994             .name = "logappend",
3995             .type = QEMU_OPT_BOOL,
3996         },
3997         { /* end of list */ }
3998     },
3999 };
4000
4001 #ifdef _WIN32
4002
4003 static void qmp_chardev_open_file(Chardev *chr,
4004                                   ChardevBackend *backend,
4005                                   bool *be_opened,
4006                                   Error **errp)
4007 {
4008     ChardevFile *file = backend->u.file.data;
4009     HANDLE out;
4010     DWORD accessmode;
4011     DWORD flags;
4012
4013     if (file->has_in) {
4014         error_setg(errp, "input file not supported");
4015         return;
4016     }
4017
4018     if (file->has_append && file->append) {
4019         /* Append to file if it already exists. */
4020         accessmode = FILE_GENERIC_WRITE & ~FILE_WRITE_DATA;
4021         flags = OPEN_ALWAYS;
4022     } else {
4023         /* Truncate file if it already exists. */
4024         accessmode = GENERIC_WRITE;
4025         flags = CREATE_ALWAYS;
4026     }
4027
4028     out = CreateFile(file->out, accessmode, FILE_SHARE_READ, NULL, flags,
4029                      FILE_ATTRIBUTE_NORMAL, NULL);
4030     if (out == INVALID_HANDLE_VALUE) {
4031         error_setg(errp, "open %s failed", file->out);
4032         return;
4033     }
4034
4035     qemu_chr_open_win_file(chr, out);
4036 }
4037
4038 static void qmp_chardev_open_serial(Chardev *chr,
4039                                     ChardevBackend *backend,
4040                                     bool *be_opened,
4041                                     Error **errp)
4042 {
4043     ChardevHostdev *serial = backend->u.serial.data;
4044
4045     win_chr_init(chr, serial->device, errp);
4046 }
4047
4048 #else /* WIN32 */
4049
4050 static int qmp_chardev_open_file_source(char *src, int flags,
4051                                         Error **errp)
4052 {
4053     int fd = -1;
4054
4055     TFR(fd = qemu_open(src, flags, 0666));
4056     if (fd == -1) {
4057         error_setg_file_open(errp, errno, src);
4058     }
4059     return fd;
4060 }
4061
4062 static void qmp_chardev_open_file(Chardev *chr,
4063                                   ChardevBackend *backend,
4064                                   bool *be_opened,
4065                                   Error **errp)
4066 {
4067     ChardevFile *file = backend->u.file.data;
4068     int flags, in = -1, out;
4069
4070     flags = O_WRONLY | O_CREAT | O_BINARY;
4071     if (file->has_append && file->append) {
4072         flags |= O_APPEND;
4073     } else {
4074         flags |= O_TRUNC;
4075     }
4076
4077     out = qmp_chardev_open_file_source(file->out, flags, errp);
4078     if (out < 0) {
4079         return;
4080     }
4081
4082     if (file->has_in) {
4083         flags = O_RDONLY;
4084         in = qmp_chardev_open_file_source(file->in, flags, errp);
4085         if (in < 0) {
4086             qemu_close(out);
4087             return;
4088         }
4089     }
4090
4091     qemu_chr_open_fd(chr, in, out);
4092 }
4093
4094 #ifdef HAVE_CHARDEV_SERIAL
4095 static void qmp_chardev_open_serial(Chardev *chr,
4096                                     ChardevBackend *backend,
4097                                     bool *be_opened,
4098                                     Error **errp)
4099 {
4100     ChardevHostdev *serial = backend->u.serial.data;
4101     int fd;
4102
4103     fd = qmp_chardev_open_file_source(serial->device, O_RDWR, errp);
4104     if (fd < 0) {
4105         return;
4106     }
4107     qemu_set_nonblock(fd);
4108     tty_serial_init(fd, 115200, 'N', 8, 1);
4109
4110     qemu_chr_open_fd(chr, fd, fd);
4111 }
4112 #endif
4113
4114 #ifdef HAVE_CHARDEV_PARPORT
4115 static void qmp_chardev_open_parallel(Chardev *chr,
4116                                       ChardevBackend *backend,
4117                                       bool *be_opened,
4118                                       Error **errp)
4119 {
4120     ChardevHostdev *parallel = backend->u.parallel.data;
4121     int fd;
4122
4123     fd = qmp_chardev_open_file_source(parallel->device, O_RDWR, errp);
4124     if (fd < 0) {
4125         return;
4126     }
4127     qemu_chr_open_pp_fd(chr, fd, be_opened, errp);
4128 }
4129
4130 static void char_parallel_class_init(ObjectClass *oc, void *data)
4131 {
4132     ChardevClass *cc = CHARDEV_CLASS(oc);
4133
4134     cc->parse = qemu_chr_parse_parallel;
4135     cc->open = qmp_chardev_open_parallel;
4136 #if defined(__linux__)
4137     cc->chr_ioctl = pp_ioctl;
4138 #elif defined(__FreeBSD__) || defined(__FreeBSD_kernel__) || defined(__DragonFly__)
4139     cc->chr_ioctl = pp_ioctl;
4140 #endif
4141 }
4142
4143 static void char_parallel_finalize(Object *obj)
4144 {
4145 #if defined(__linux__)
4146     Chardev *chr = CHARDEV(obj);
4147     ParallelChardev *drv = PARALLEL_CHARDEV(chr);
4148     int fd = drv->fd;
4149
4150     pp_hw_mode(drv, IEEE1284_MODE_COMPAT);
4151     ioctl(fd, PPRELEASE);
4152     close(fd);
4153     qemu_chr_be_event(chr, CHR_EVENT_CLOSED);
4154 #elif defined(__FreeBSD__) || defined(__FreeBSD_kernel__) || defined(__DragonFly__)
4155     /* FIXME: close fd? */
4156 #endif
4157 }
4158
4159 static const TypeInfo char_parallel_type_info = {
4160     .name = TYPE_CHARDEV_PARALLEL,
4161     .parent = TYPE_CHARDEV,
4162     .instance_size = sizeof(ParallelChardev),
4163     .instance_finalize = char_parallel_finalize,
4164     .class_init = char_parallel_class_init,
4165 };
4166 #endif
4167
4168 #endif /* WIN32 */
4169
4170 static void char_file_class_init(ObjectClass *oc, void *data)
4171 {
4172     ChardevClass *cc = CHARDEV_CLASS(oc);
4173
4174     cc->parse = qemu_chr_parse_file_out;
4175     cc->open = qmp_chardev_open_file;
4176 }
4177
4178 static const TypeInfo char_file_type_info = {
4179     .name = TYPE_CHARDEV_FILE,
4180 #ifdef _WIN32
4181     .parent = TYPE_CHARDEV_WIN,
4182 #else
4183     .parent = TYPE_CHARDEV_FD,
4184 #endif
4185     .class_init = char_file_class_init,
4186 };
4187
4188 #ifdef HAVE_CHARDEV_SERIAL
4189
4190 static void char_serial_class_init(ObjectClass *oc, void *data)
4191 {
4192     ChardevClass *cc = CHARDEV_CLASS(oc);
4193
4194     cc->parse = qemu_chr_parse_serial;
4195     cc->open = qmp_chardev_open_serial;
4196 #ifndef _WIN32
4197     cc->chr_ioctl = tty_serial_ioctl;
4198 #endif
4199 }
4200
4201 static const TypeInfo char_serial_type_info = {
4202     .name = TYPE_CHARDEV_SERIAL,
4203 #ifdef _WIN32
4204     .parent = TYPE_CHARDEV_WIN,
4205 #else
4206     .parent = TYPE_CHARDEV_FD,
4207 #endif
4208     .class_init = char_serial_class_init,
4209 };
4210 #endif
4211
4212 static gboolean socket_reconnect_timeout(gpointer opaque)
4213 {
4214     Chardev *chr = CHARDEV(opaque);
4215     SocketChardev *s = SOCKET_CHARDEV(opaque);
4216     QIOChannelSocket *sioc;
4217
4218     s->reconnect_timer = 0;
4219
4220     if (chr->be_open) {
4221         return false;
4222     }
4223
4224     sioc = qio_channel_socket_new();
4225     tcp_chr_set_client_ioc_name(chr, sioc);
4226     qio_channel_socket_connect_async(sioc, s->addr,
4227                                      qemu_chr_socket_connected,
4228                                      chr, NULL);
4229
4230     return false;
4231 }
4232
4233 static void qmp_chardev_open_socket(Chardev *chr,
4234                                     ChardevBackend *backend,
4235                                     bool *be_opened,
4236                                     Error **errp)
4237 {
4238     SocketChardev *s = SOCKET_CHARDEV(chr);
4239     ChardevSocket *sock = backend->u.socket.data;
4240     SocketAddress *addr = sock->addr;
4241     bool do_nodelay     = sock->has_nodelay ? sock->nodelay : false;
4242     bool is_listen      = sock->has_server  ? sock->server  : true;
4243     bool is_telnet      = sock->has_telnet  ? sock->telnet  : false;
4244     bool is_waitconnect = sock->has_wait    ? sock->wait    : false;
4245     int64_t reconnect   = sock->has_reconnect ? sock->reconnect : 0;
4246     QIOChannelSocket *sioc = NULL;
4247
4248     s->is_unix = addr->type == SOCKET_ADDRESS_KIND_UNIX;
4249     s->is_listen = is_listen;
4250     s->is_telnet = is_telnet;
4251     s->do_nodelay = do_nodelay;
4252     if (sock->tls_creds) {
4253         Object *creds;
4254         creds = object_resolve_path_component(
4255             object_get_objects_root(), sock->tls_creds);
4256         if (!creds) {
4257             error_setg(errp, "No TLS credentials with id '%s'",
4258                        sock->tls_creds);
4259             goto error;
4260         }
4261         s->tls_creds = (QCryptoTLSCreds *)
4262             object_dynamic_cast(creds,
4263                                 TYPE_QCRYPTO_TLS_CREDS);
4264         if (!s->tls_creds) {
4265             error_setg(errp, "Object with id '%s' is not TLS credentials",
4266                        sock->tls_creds);
4267             goto error;
4268         }
4269         object_ref(OBJECT(s->tls_creds));
4270         if (is_listen) {
4271             if (s->tls_creds->endpoint != QCRYPTO_TLS_CREDS_ENDPOINT_SERVER) {
4272                 error_setg(errp, "%s",
4273                            "Expected TLS credentials for server endpoint");
4274                 goto error;
4275             }
4276         } else {
4277             if (s->tls_creds->endpoint != QCRYPTO_TLS_CREDS_ENDPOINT_CLIENT) {
4278                 error_setg(errp, "%s",
4279                            "Expected TLS credentials for client endpoint");
4280                 goto error;
4281             }
4282         }
4283     }
4284
4285     s->addr = QAPI_CLONE(SocketAddress, sock->addr);
4286
4287     qemu_chr_set_feature(chr, QEMU_CHAR_FEATURE_RECONNECTABLE);
4288     if (s->is_unix) {
4289         qemu_chr_set_feature(chr, QEMU_CHAR_FEATURE_FD_PASS);
4290     }
4291
4292     /* be isn't opened until we get a connection */
4293     *be_opened = false;
4294
4295     chr->filename = SocketAddress_to_str("disconnected:",
4296                                          addr, is_listen, is_telnet);
4297
4298     if (is_listen) {
4299         if (is_telnet) {
4300             s->do_telnetopt = 1;
4301         }
4302     } else if (reconnect > 0) {
4303         s->reconnect_time = reconnect;
4304     }
4305
4306     if (s->reconnect_time) {
4307         sioc = qio_channel_socket_new();
4308         tcp_chr_set_client_ioc_name(chr, sioc);
4309         qio_channel_socket_connect_async(sioc, s->addr,
4310                                          qemu_chr_socket_connected,
4311                                          chr, NULL);
4312     } else {
4313         if (s->is_listen) {
4314             char *name;
4315             sioc = qio_channel_socket_new();
4316
4317             name = g_strdup_printf("chardev-tcp-listener-%s", chr->label);
4318             qio_channel_set_name(QIO_CHANNEL(sioc), name);
4319             g_free(name);
4320
4321             if (qio_channel_socket_listen_sync(sioc, s->addr, errp) < 0) {
4322                 goto error;
4323             }
4324             s->listen_ioc = sioc;
4325             if (is_waitconnect &&
4326                 qemu_chr_wait_connected(chr, errp) < 0) {
4327                 return;
4328             }
4329             if (!s->ioc) {
4330                 s->listen_tag = qio_channel_add_watch(
4331                     QIO_CHANNEL(s->listen_ioc), G_IO_IN,
4332                     tcp_chr_accept, chr, NULL);
4333             }
4334         } else if (qemu_chr_wait_connected(chr, errp) < 0) {
4335             goto error;
4336         }
4337     }
4338
4339     return;
4340
4341 error:
4342     if (sioc) {
4343         object_unref(OBJECT(sioc));
4344     }
4345 }
4346
4347 static void char_socket_class_init(ObjectClass *oc, void *data)
4348 {
4349     ChardevClass *cc = CHARDEV_CLASS(oc);
4350
4351     cc->parse = qemu_chr_parse_socket;
4352     cc->open = qmp_chardev_open_socket;
4353     cc->chr_wait_connected = tcp_chr_wait_connected;
4354     cc->chr_write = tcp_chr_write;
4355     cc->chr_sync_read = tcp_chr_sync_read;
4356     cc->chr_disconnect = tcp_chr_disconnect;
4357     cc->get_msgfds = tcp_get_msgfds;
4358     cc->set_msgfds = tcp_set_msgfds;
4359     cc->chr_add_client = tcp_chr_add_client;
4360     cc->chr_add_watch = tcp_chr_add_watch;
4361     cc->chr_update_read_handler = tcp_chr_update_read_handler;
4362 }
4363
4364 static const TypeInfo char_socket_type_info = {
4365     .name = TYPE_CHARDEV_SOCKET,
4366     .parent = TYPE_CHARDEV,
4367     .instance_size = sizeof(SocketChardev),
4368     .instance_finalize = char_socket_finalize,
4369     .class_init = char_socket_class_init,
4370 };
4371
4372 static void qmp_chardev_open_udp(Chardev *chr,
4373                                  ChardevBackend *backend,
4374                                  bool *be_opened,
4375                                  Error **errp)
4376 {
4377     ChardevUdp *udp = backend->u.udp.data;
4378     QIOChannelSocket *sioc = qio_channel_socket_new();
4379     char *name;
4380     UdpChardev *s = UDP_CHARDEV(chr);
4381
4382     if (qio_channel_socket_dgram_sync(sioc,
4383                                       udp->local, udp->remote,
4384                                       errp) < 0) {
4385         object_unref(OBJECT(sioc));
4386         return;
4387     }
4388
4389     name = g_strdup_printf("chardev-udp-%s", chr->label);
4390     qio_channel_set_name(QIO_CHANNEL(sioc), name);
4391     g_free(name);
4392
4393     s->ioc = QIO_CHANNEL(sioc);
4394     /* be isn't opened until we get a connection */
4395     *be_opened = false;
4396 }
4397
4398 static void char_udp_class_init(ObjectClass *oc, void *data)
4399 {
4400     ChardevClass *cc = CHARDEV_CLASS(oc);
4401
4402     cc->parse = qemu_chr_parse_udp;
4403     cc->open = qmp_chardev_open_udp;
4404     cc->chr_write = udp_chr_write;
4405     cc->chr_update_read_handler = udp_chr_update_read_handler;
4406 }
4407
4408 static const TypeInfo char_udp_type_info = {
4409     .name = TYPE_CHARDEV_UDP,
4410     .parent = TYPE_CHARDEV,
4411     .instance_size = sizeof(UdpChardev),
4412     .instance_finalize = char_udp_finalize,
4413     .class_init = char_udp_class_init,
4414 };
4415
4416 bool qemu_chr_has_feature(Chardev *chr,
4417                           ChardevFeature feature)
4418 {
4419     return test_bit(feature, chr->features);
4420 }
4421
4422 void qemu_chr_set_feature(Chardev *chr,
4423                            ChardevFeature feature)
4424 {
4425     return set_bit(feature, chr->features);
4426 }
4427
4428 Chardev *qemu_chardev_new(const char *id, const char *typename,
4429                           ChardevBackend *backend, Error **errp)
4430 {
4431     Chardev *chr = NULL;
4432     Error *local_err = NULL;
4433     bool be_opened = true;
4434
4435     assert(g_str_has_prefix(typename, "chardev-"));
4436
4437     chr = CHARDEV(object_new(typename));
4438     chr->label = g_strdup(id);
4439
4440     qemu_char_open(chr, backend, &be_opened, &local_err);
4441     if (local_err) {
4442         error_propagate(errp, local_err);
4443         object_unref(OBJECT(chr));
4444         return NULL;
4445     }
4446
4447     if (!chr->filename) {
4448         chr->filename = g_strdup(typename + 8);
4449     }
4450     if (be_opened) {
4451         qemu_chr_be_event(chr, CHR_EVENT_OPENED);
4452     }
4453
4454     return chr;
4455 }
4456
4457 ChardevReturn *qmp_chardev_add(const char *id, ChardevBackend *backend,
4458                                Error **errp)
4459 {
4460     const ChardevClass *cc;
4461     ChardevReturn *ret;
4462     Chardev *chr;
4463
4464     cc = char_get_class(ChardevBackendKind_lookup[backend->type], errp);
4465     if (!cc) {
4466         return NULL;
4467     }
4468
4469     chr = qemu_chardev_add(id, object_class_get_name(OBJECT_CLASS(cc)),
4470                            backend, errp);
4471     if (!chr) {
4472         return NULL;
4473     }
4474
4475     ret = g_new0(ChardevReturn, 1);
4476     if (CHARDEV_IS_PTY(chr)) {
4477         ret->pty = g_strdup(chr->filename + 4);
4478         ret->has_pty = true;
4479     }
4480
4481     return ret;
4482 }
4483
4484 void qmp_chardev_remove(const char *id, Error **errp)
4485 {
4486     Chardev *chr;
4487
4488     chr = qemu_chr_find(id);
4489     if (chr == NULL) {
4490         error_setg(errp, "Chardev '%s' not found", id);
4491         return;
4492     }
4493     if (qemu_chr_is_busy(chr)) {
4494         error_setg(errp, "Chardev '%s' is busy", id);
4495         return;
4496     }
4497     if (qemu_chr_replay(chr)) {
4498         error_setg(errp,
4499             "Chardev '%s' cannot be unplugged in record/replay mode", id);
4500         return;
4501     }
4502     qemu_chr_delete(chr);
4503 }
4504
4505 void qemu_chr_cleanup(void)
4506 {
4507     Chardev *chr, *tmp;
4508
4509     QTAILQ_FOREACH_SAFE(chr, &chardevs, next, tmp) {
4510         qemu_chr_delete(chr);
4511     }
4512 }
4513
4514 static void register_types(void)
4515 {
4516     type_register_static(&char_type_info);
4517 #ifndef _WIN32
4518     type_register_static(&char_fd_type_info);
4519 #else
4520     type_register_static(&char_win_type_info);
4521     type_register_static(&char_win_stdio_type_info);
4522 #endif
4523     type_register_static(&char_socket_type_info);
4524     type_register_static(&char_udp_type_info);
4525     type_register_static(&char_file_type_info);
4526     type_register_static(&char_stdio_type_info);
4527 #ifdef HAVE_CHARDEV_SERIAL
4528     type_register_static(&char_serial_type_info);
4529 #endif
4530 #ifdef HAVE_CHARDEV_PARPORT
4531     type_register_static(&char_parallel_type_info);
4532 #endif
4533 #ifdef HAVE_CHARDEV_PTY
4534     type_register_static(&char_pty_type_info);
4535 #endif
4536 #ifdef _WIN32
4537     type_register_static(&char_console_type_info);
4538 #endif
4539     type_register_static(&char_pipe_type_info);
4540
4541     /* this must be done after machine init, since we register FEs with muxes
4542      * as part of realize functions like serial_isa_realizefn when -nographic
4543      * is specified
4544      */
4545     qemu_add_machine_init_done_notifier(&muxes_realize_notify);
4546 }
4547
4548 type_init(register_types);