]> git.proxmox.com Git - mirror_qemu.git/blame - chardev/char.c
projects / mirror_qemu.git / blame
? search:
summary | shortlog | log | commit | commitdiff | tree
blob | blame (incremental) | history | HEAD
char: remove unused READ_RETRIES
[mirror_qemu.git] / chardev / char.c
CommitLineData
6f97dba0
AL		 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 */
d38ea87a 24#include "qemu/osdep.h"
6f97dba0 25#include "qemu-common.h"
f348b6d1 26#include "qemu/cutils.h"
83c9089e 27#include "monitor/monitor.h"
9c17d615 28#include "sysemu/sysemu.h"
da31d594 29#include "sysemu/block-backend.h"
d49b6836 30#include "qemu/error-report.h"
1de7afc9 31#include "qemu/timer.h"
dccfcd0e 32#include "sysemu/char.h"
cf3ebac7 33#include "hw/usb.h"
c5a415a0 34#include "qmp-commands.h"
37f9e0a2 35#include "qapi/clone-visitor.h"
cfb429cb 36#include "qapi-visit.h"
e9cf2fe0 37#include "qemu/base64.h"
9894dc0c
DB		 38#include "io/channel-socket.h"
39#include "io/channel-file.h"
a8fb5427 40#include "io/channel-tls.h"
33577b47 41#include "sysemu/replay.h"
517b3d40 42#include "qemu/help_option.h"
6f97dba0 43
6f97dba0
AL		 44#include <zlib.h>
45
46#ifndef _WIN32
47#include <sys/times.h>
48#include <sys/wait.h>
49#include <termios.h>
6f97dba0 50#include <sys/ioctl.h>
24646c7e 51#include <sys/resource.h>
6f97dba0
AL		 52#include <sys/socket.h>
53#include <netinet/in.h>
24646c7e 54#include <net/if.h>
24646c7e 55#include <arpa/inet.h>
6f97dba0
AL		 56#include <netdb.h>
57#include <sys/select.h>
71e72a19 58#ifdef CONFIG_BSD
3294ce18
MT		 59#if defined(__FreeBSD__) || defined(__FreeBSD_kernel__)
60#include <dev/ppbus/ppi.h>
61#include <dev/ppbus/ppbconf.h>
c5e97233 62#elif defined(__DragonFly__)
c5e97233
BS		 63#include <dev/misc/ppi/ppi.h>
64#include <bus/ppbus/ppbconf.h>
6f97dba0 65#endif
bbe813a2 66#else
6f97dba0 67#ifdef __linux__
6f97dba0
AL		 68#include <linux/ppdev.h>
69#include <linux/parport.h>
70#endif
71#ifdef __sun__
6f97dba0
AL		 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>
6f97dba0
AL		 81#endif
82#endif
83#endif
84
1de7afc9 85#include "qemu/sockets.h"
cbcc6336 86#include "ui/qemu-spice.h"
6f97dba0 87
df85a78b
MAL		 88#include "char-mux.h"
89
c4095726 90#define TCP_MAX_FDS 16
9bd7854e 91
cfb429cb
CM		 92/***********************************************************/
93/* Socket address helpers */
cfb429cb 94
0ff0fad2
DB		 95static char *SocketAddress_to_str(const char *prefix, SocketAddress *addr,
96 bool is_listen, bool is_telnet)
16cc4ffe 97{
130257dc 98 switch (addr->type) {
16cc4ffe 99 case SOCKET_ADDRESS_KIND_INET:
0ff0fad2 100 return g_strdup_printf("%s%s:%s:%s%s", prefix,
32bafa8f
EB		 101 is_telnet ? "telnet" : "tcp",
102 addr->u.inet.data->host,
103 addr->u.inet.data->port,
104 is_listen ? ",server" : "");
16cc4ffe
CM		 105 break;
106 case SOCKET_ADDRESS_KIND_UNIX:
0ff0fad2 107 return g_strdup_printf("%sunix:%s%s", prefix,
32bafa8f 108 addr->u.q_unix.data->path,
0ff0fad2 109 is_listen ? ",server" : "");
16cc4ffe
CM		 110 break;
111 case SOCKET_ADDRESS_KIND_FD:
32bafa8f 112 return g_strdup_printf("%sfd:%s%s", prefix, addr->u.fd.data->str,
0ff0fad2 113 is_listen ? ",server" : "");
16cc4ffe
CM		 114 break;
115 default:
116 abort();
117 }
118}
119
0ff0fad2
DB		 120static 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)
16cc4ffe 123{
01ca519f
CM		 124 char shost[NI_MAXHOST], sserv[NI_MAXSERV];
125 char phost[NI_MAXHOST], pserv[NI_MAXSERV];
16cc4ffe
CM		 126 const char *left = "", *right = "";
127
128 switch (ss->ss_family) {
129#ifndef _WIN32
130 case AF_UNIX:
0ff0fad2
DB		 131 return g_strdup_printf("unix:%s%s",
132 ((struct sockaddr_un *)(ss))->sun_path,
133 is_listen ? ",server" : "");
16cc4ffe
CM		 134#endif
135 case AF_INET6:
136 left = "[";
137 right = "]";
138 /* fall through */
139 case AF_INET:
01ca519f
CM		 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);
0ff0fad2
DB		 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);
16cc4ffe
CM		 149
150 default:
0ff0fad2 151 return g_strdup_printf("unknown");
16cc4ffe
CM		 152 }
153}
154
6f97dba0
AL		 155/***********************************************************/
156/* character device */
157
0ec7b3e7 158static QTAILQ_HEAD(ChardevHead, Chardev) chardevs =
72cf2d4f 159 QTAILQ_HEAD_INITIALIZER(chardevs);
2970a6c9 160
0ec7b3e7 161void qemu_chr_be_event(Chardev *s, int event)
6f97dba0 162{
a4afa548
MAL		 163 CharBackend *be = s->be;
164
73cdf3f2
AG		 165 /* Keep track if the char device is open */
166 switch (event) {
167 case CHR_EVENT_OPENED:
16665b94 168 s->be_open = 1;
73cdf3f2
AG		 169 break;
170 case CHR_EVENT_CLOSED:
16665b94 171 s->be_open = 0;
73cdf3f2
AG		 172 break;
173 }
174
a4afa548 175 if (!be || !be->chr_event) {
6f97dba0 176 return;
a4afa548
MAL		 177 }
178
179 be->chr_event(be->opaque, event);
6f97dba0
AL		 180}
181
0ec7b3e7 182void qemu_chr_be_generic_open(Chardev *s)
6f97dba0 183{
bd5c51ee 184 qemu_chr_be_event(s, CHR_EVENT_OPENED);
6f97dba0
AL		 185}
186
d0d7708b
DB		 187
188/* Not reporting errors from writing to logfile, as logs are
189 * defined to be "best effort" only */
0ec7b3e7 190static void qemu_chr_fe_write_log(Chardev *s,
d0d7708b
DB		 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) {
53628efb
DB		 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 }
d0d7708b
DB		 207
208 if (ret <= 0) {
209 return;
210 }
211 done += ret;
212 }
213}
214
0ec7b3e7
MAL		 215static int qemu_chr_fe_write_buffer(Chardev *s,
216 const uint8_t *buf, int len, int *offset)
33577b47 217{
777357d7 218 ChardevClass *cc = CHARDEV_GET_CLASS(s);
33577b47
PD		 219 int res = 0;
220 *offset = 0;
221
222 qemu_mutex_lock(&s->chr_write_lock);
223 while (*offset < len) {
53628efb 224 retry:
777357d7 225 res = cc->chr_write(s, buf + *offset, len - *offset);
53628efb
DB		 226 if (res < 0 && errno == EAGAIN) {
227 g_usleep(100);
228 goto retry;
229 }
33577b47
PD		 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
0ec7b3e7 245static bool qemu_chr_replay(Chardev *chr)
5ebd6703
MAL		 246{
247 return qemu_chr_has_feature(chr, QEMU_CHAR_FEATURE_REPLAY);
248}
249
5345fdb4 250int qemu_chr_fe_write(CharBackend *be, const uint8_t *buf, int len)
6f97dba0 251{
0ec7b3e7 252 Chardev *s = be->chr;
777357d7 253 ChardevClass *cc;
9005b2a7
PB		 254 int ret;
255
fa394ed6
MAL		 256 if (!s) {
257 return 0;
258 }
259
5ebd6703 260 if (qemu_chr_replay(s) && replay_mode == REPLAY_MODE_PLAY) {
33577b47
PD		 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
777357d7 268 cc = CHARDEV_GET_CLASS(s);
9005b2a7 269 qemu_mutex_lock(&s->chr_write_lock);
777357d7 270 ret = cc->chr_write(s, buf, len);
d0d7708b
DB		 271
272 if (ret > 0) {
273 qemu_chr_fe_write_log(s, buf, ret);
274 }
275
9005b2a7 276 qemu_mutex_unlock(&s->chr_write_lock);
33577b47 277
5ebd6703 278 if (qemu_chr_replay(s) && replay_mode == REPLAY_MODE_RECORD) {
33577b47
PD		 279 replay_char_write_event_save(ret, ret < 0 ? 0 : ret);
280 }
281
9005b2a7 282 return ret;
6f97dba0
AL		 283}
284
df85a78b 285int qemu_chr_write_all(Chardev *s, const uint8_t *buf, int len)
cd18720a 286{
33577b47
PD		 287 int offset;
288 int res;
cd18720a 289
5ebd6703 290 if (qemu_chr_replay(s) && replay_mode == REPLAY_MODE_PLAY) {
33577b47
PD		 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 }
cd18720a 296
33577b47 297 res = qemu_chr_fe_write_buffer(s, buf, len, &offset);
cd18720a 298
5ebd6703 299 if (qemu_chr_replay(s) && replay_mode == REPLAY_MODE_RECORD) {
33577b47 300 replay_char_write_event_save(res, offset);
cd18720a
AL		 301 }
302
9005b2a7
PB		 303 if (res < 0) {
304 return res;
305 }
cd18720a
AL		 306 return offset;
307}
308
5345fdb4 309int qemu_chr_fe_write_all(CharBackend *be, const uint8_t *buf, int len)
7b0bfdf5 310{
0ec7b3e7 311 Chardev *s = be->chr;
5345fdb4 312
fa394ed6
MAL		 313 if (!s) {
314 return 0;
315 }
316
5345fdb4
MAL		 317 return qemu_chr_write_all(s, buf, len);
318}
319
320int qemu_chr_fe_read_all(CharBackend *be, uint8_t *buf, int len)
321{
0ec7b3e7 322 Chardev *s = be->chr;
7b0bfdf5
NN		 323 int offset = 0, counter = 10;
324 int res;
325
777357d7 326 if (!s || !CHARDEV_GET_CLASS(s)->chr_sync_read) {
7b0bfdf5
NN		 327 return 0;
328 }
fa394ed6 329
5ebd6703 330 if (qemu_chr_replay(s) && replay_mode == REPLAY_MODE_PLAY) {
33577b47
PD		 331 return replay_char_read_all_load(buf);
332 }
7b0bfdf5
NN		 333
334 while (offset < len) {
53628efb 335 retry:
777357d7
MAL		 336 res = CHARDEV_GET_CLASS(s)->chr_sync_read(s, buf + offset,
337 len - offset);
53628efb
DB		 338 if (res == -1 && errno == EAGAIN) {
339 g_usleep(100);
340 goto retry;
341 }
7b0bfdf5
NN		 342
343 if (res == 0) {
344 break;
345 }
346
347 if (res < 0) {
5ebd6703 348 if (qemu_chr_replay(s) && replay_mode == REPLAY_MODE_RECORD) {
33577b47
PD		 349 replay_char_read_all_save_error(res);
350 }
7b0bfdf5
NN		 351 return res;
352 }
353
354 offset += res;
355
356 if (!counter--) {
357 break;
358 }
359 }
360
5ebd6703 361 if (qemu_chr_replay(s) && replay_mode == REPLAY_MODE_RECORD) {
33577b47
PD		 362 replay_char_read_all_save_buf(buf, offset);
363 }
7b0bfdf5
NN		 364 return offset;
365}
366
5345fdb4 367int qemu_chr_fe_ioctl(CharBackend *be, int cmd, void *arg)
6f97dba0 368{
0ec7b3e7 369 Chardev *s = be->chr;
33577b47 370 int res;
fa394ed6 371
777357d7 372 if (!s || !CHARDEV_GET_CLASS(s)->chr_ioctl || qemu_chr_replay(s)) {
33577b47
PD		 373 res = -ENOTSUP;
374 } else {
777357d7 375 res = CHARDEV_GET_CLASS(s)->chr_ioctl(s, cmd, arg);
33577b47
PD		 376 }
377
378 return res;
6f97dba0
AL		 379}
380
0ec7b3e7 381int qemu_chr_be_can_write(Chardev *s)
6f97dba0 382{
a4afa548
MAL		 383 CharBackend *be = s->be;
384
385 if (!be || !be->chr_can_read) {
6f97dba0 386 return 0;
a4afa548
MAL		 387 }
388
389 return be->chr_can_read(be->opaque);
6f97dba0
AL		 390}
391
0ec7b3e7 392void qemu_chr_be_write_impl(Chardev *s, uint8_t *buf, int len)
6f97dba0 393{
a4afa548
MAL		 394 CharBackend *be = s->be;
395
396 if (be && be->chr_read) {
397 be->chr_read(be->opaque, buf, len);
ac310734 398 }
6f97dba0
AL		 399}
400
0ec7b3e7 401void qemu_chr_be_write(Chardev *s, uint8_t *buf, int len)
33577b47 402{
5ebd6703 403 if (qemu_chr_replay(s)) {
33577b47
PD		 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
5345fdb4 413int qemu_chr_fe_get_msgfd(CharBackend *be)
7d174059 414{
0ec7b3e7 415 Chardev *s = be->chr;
c76bf6bb 416 int fd;
5345fdb4 417 int res = (qemu_chr_fe_get_msgfds(be, &fd, 1) == 1) ? fd : -1;
5ebd6703 418 if (s && qemu_chr_replay(s)) {
776a32a0
MAL		 419 error_report("Replay: get msgfd is not supported "
420 "for serial devices yet");
33577b47
PD		 421 exit(1);
422 }
423 return res;
c76bf6bb
NN		 424}
425
5345fdb4 426int qemu_chr_fe_get_msgfds(CharBackend *be, int *fds, int len)
c76bf6bb 427{
0ec7b3e7 428 Chardev *s = be->chr;
5345fdb4 429
fa394ed6
MAL		 430 if (!s) {
431 return -1;
432 }
433
777357d7
MAL		 434 return CHARDEV_GET_CLASS(s)->get_msgfds ?
435 CHARDEV_GET_CLASS(s)->get_msgfds(s, fds, len) : -1;
7d174059
MM		 436}
437
5345fdb4 438int qemu_chr_fe_set_msgfds(CharBackend *be, int *fds, int num)
d39aac7a 439{
0ec7b3e7 440 Chardev *s = be->chr;
5345fdb4 441
fa394ed6
MAL		 442 if (!s) {
443 return -1;
444 }
445
777357d7
MAL		 446 return CHARDEV_GET_CLASS(s)->set_msgfds ?
447 CHARDEV_GET_CLASS(s)->set_msgfds(s, fds, num) : -1;
d39aac7a
NN		 448}
449
0ec7b3e7 450int qemu_chr_add_client(Chardev *s, int fd)
13661089 451{
777357d7
MAL		 452 return CHARDEV_GET_CLASS(s)->chr_add_client ?
453 CHARDEV_GET_CLASS(s)->chr_add_client(s, fd) : -1;
13661089
DB		 454}
455
5345fdb4 456void qemu_chr_fe_accept_input(CharBackend *be)
6f97dba0 457{
0ec7b3e7 458 Chardev *s = be->chr;
5345fdb4 459
fa394ed6
MAL		 460 if (!s) {
461 return;
462 }
463
777357d7
MAL		 464 if (CHARDEV_GET_CLASS(s)->chr_accept_input) {
465 CHARDEV_GET_CLASS(s)->chr_accept_input(s);
b68e956a 466 }
98c8ee1d 467 qemu_notify_event();
6f97dba0
AL		 468}
469
5345fdb4 470void qemu_chr_fe_printf(CharBackend *be, const char *fmt, ...)
6f97dba0 471{
f612143a 472 char buf[CHR_READ_BUF_LEN];
6f97dba0
AL		 473 va_list ap;
474 va_start(ap, fmt);
475 vsnprintf(buf, sizeof(buf), fmt, ap);
90f998f5
DB		 476 /* XXX this blocks entire thread. Rewrite to use
477 * qemu_chr_fe_write and background I/O callbacks */
5345fdb4 478 qemu_chr_fe_write_all(be, (uint8_t *)buf, strlen(buf));
6f97dba0
AL		 479 va_end(ap);
480}
481
0ec7b3e7 482static void remove_fd_in_watch(Chardev *chr);
6dfa8298 483
777357d7
MAL		 484static void qemu_char_open(Chardev *chr, ChardevBackend *backend,
485 bool *be_opened, Error **errp)
6f97dba0 486{
777357d7
MAL		 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 }
6f97dba0
AL		 511}
512
777357d7 513static void char_init(Object *obj)
6f97dba0 514{
777357d7 515 Chardev *chr = CHARDEV(obj);
6f97dba0 516
777357d7
MAL		 517 chr->logfd = -1;
518 qemu_mutex_init(&chr->chr_write_lock);
519}
520
eb314a94
MAL		 521static int null_chr_write(Chardev *chr, const uint8_t *buf, int len)
522{
523 return len;
524}
525
526static 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
777357d7
MAL		 533static 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);
d0d7708b 544 }
777357d7
MAL		 545 qemu_mutex_destroy(&chr->chr_write_lock);
546}
547
548static 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),
eb314a94 556 .class_init = char_class_init,
777357d7
MAL		 557};
558
7b7ab18d
MR		 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 */
571static void muxes_realize_done(Notifier *notifier, void *unused)
572{
0ec7b3e7 573 Chardev *chr;
7b7ab18d
MR		 574
575 QTAILQ_FOREACH(chr, &chardevs, next) {
777357d7
MAL		 576 if (CHARDEV_IS_MUX(chr)) {
577 MuxChardev *d = MUX_CHARDEV(chr);
7b7ab18d
MR		 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
593static Notifier muxes_realize_notify = {
594 .notify = muxes_realize_done,
595};
596
0ec7b3e7 597Chardev *qemu_chr_fe_get_driver(CharBackend *be)
94a40fc5
MAL		 598{
599 return be->chr;
600}
601
0ec7b3e7 602bool qemu_chr_fe_init(CharBackend *b, Chardev *s, Error **errp)
94a40fc5
MAL		 603{
604 int tag = 0;
605
777357d7
MAL		 606 if (CHARDEV_IS_MUX(s)) {
607 MuxChardev *d = MUX_CHARDEV(s);
3aef23d7
MAL		 608
609 if (d->mux_cnt >= MAX_MUX) {
610 goto unavailable;
94a40fc5 611 }
3aef23d7
MAL		 612
613 d->backends[d->mux_cnt] = b;
614 tag = d->mux_cnt++;
615 } else if (s->be) {
616 goto unavailable;
a4afa548
MAL		 617 } else {
618 s->be = b;
94a40fc5
MAL		 619 }
620
830896af 621 b->fe_open = false;
94a40fc5
MAL		 622 b->tag = tag;
623 b->chr = s;
94a40fc5 624 return true;
3aef23d7
MAL		 625
626unavailable:
627 error_setg(errp, QERR_DEVICE_IN_USE, s->label);
628 return false;
94a40fc5
MAL		 629}
630
0ec7b3e7 631static bool qemu_chr_is_busy(Chardev *s)
a4afa548 632{
777357d7
MAL		 633 if (CHARDEV_IS_MUX(s)) {
634 MuxChardev *d = MUX_CHARDEV(s);
a4afa548
MAL		 635 return d->mux_cnt >= 0;
636 } else {
637 return s->be != NULL;
638 }
639}
640
c39860e6
MAL		 641void qemu_chr_fe_deinit(CharBackend *b)
642{
643 assert(b);
644
645 if (b->chr) {
39ab61c6 646 qemu_chr_fe_set_handlers(b, NULL, NULL, NULL, NULL, NULL, true);
fb5e19d2
MAL		 647 if (b->chr->be == b) {
648 b->chr->be = NULL;
649 }
777357d7
MAL		 650 if (CHARDEV_IS_MUX(b->chr)) {
651 MuxChardev *d = MUX_CHARDEV(b->chr);
a4afa548
MAL		 652 d->backends[b->tag] = NULL;
653 }
c39860e6
MAL		 654 b->chr = NULL;
655 }
656}
657
94a40fc5
MAL		 658void qemu_chr_fe_set_handlers(CharBackend *b,
659 IOCanReadHandler *fd_can_read,
660 IOReadHandler *fd_read,
661 IOEventHandler *fd_event,
662 void *opaque,
39ab61c6
MAL		 663 GMainContext *context,
664 bool set_open)
94a40fc5 665{
0ec7b3e7 666 Chardev *s;
777357d7 667 ChardevClass *cc;
386f07d1
MAL		 668 int fe_open;
669
670 s = b->chr;
671 if (!s) {
94a40fc5
MAL		 672 return;
673 }
674
777357d7 675 cc = CHARDEV_GET_CLASS(s);
386f07d1
MAL		 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 }
a4afa548
MAL		 682 b->chr_can_read = fd_can_read;
683 b->chr_read = fd_read;
684 b->chr_event = fd_event;
685 b->opaque = opaque;
777357d7
MAL		 686 if (cc->chr_update_read_handler) {
687 cc->chr_update_read_handler(s, context);
386f07d1
MAL		 688 }
689
39ab61c6 690 if (set_open) {
386f07d1
MAL		 691 qemu_chr_fe_set_open(b, fe_open);
692 }
94a40fc5 693
386f07d1
MAL		 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
777357d7 703 if (CHARDEV_IS_MUX(s)) {
386f07d1 704 mux_chr_set_handlers(s, context);
94a40fc5
MAL		 705 }
706}
707
708void qemu_chr_fe_take_focus(CharBackend *b)
709{
fa394ed6
MAL		 710 if (!b->chr) {
711 return;
712 }
713
777357d7 714 if (CHARDEV_IS_MUX(b->chr)) {
fb5e19d2 715 mux_set_focus(b->chr, b->tag);
94a40fc5
MAL		 716 }
717}
6f97dba0 718
96c63847
AL		 719typedef struct IOWatchPoll
720{
d185c094
PB		 721 GSource parent;
722
9894dc0c 723 QIOChannel *ioc;
96c63847 724 GSource *src;
96c63847
AL		 725
726 IOCanReadHandler *fd_can_read;
1e885b25 727 GSourceFunc fd_read;
96c63847 728 void *opaque;
e92aa36a 729 GMainContext *context;
96c63847
AL		 730} IOWatchPoll;
731
96c63847
AL		 732static IOWatchPoll *io_watch_poll_from_source(GSource *source)
733{
d185c094 734 return container_of(source, IOWatchPoll, parent);
96c63847
AL		 735}
736
e92aa36a
ZC		 737static gboolean io_watch_poll_prepare(GSource *source,
738 gint *timeout_)
96c63847
AL		 739{
740 IOWatchPoll *iwp = io_watch_poll_from_source(source);
d185c094 741 bool now_active = iwp->fd_can_read(iwp->opaque) > 0;
1e885b25 742 bool was_active = iwp->src != NULL;
d185c094 743 if (was_active == now_active) {
96c63847
AL		 744 return FALSE;
745 }
746
d185c094 747 if (now_active) {
9894dc0c
DB		 748 iwp->src = qio_channel_create_watch(
749 iwp->ioc, G_IO_IN | G_IO_ERR | G_IO_HUP | G_IO_NVAL);
1e885b25 750 g_source_set_callback(iwp->src, iwp->fd_read, iwp->opaque, NULL);
e92aa36a 751 g_source_attach(iwp->src, iwp->context);
d185c094 752 } else {
1e885b25
PB		 753 g_source_destroy(iwp->src);
754 g_source_unref(iwp->src);
755 iwp->src = NULL;
d185c094
PB		 756 }
757 return FALSE;
96c63847
AL		 758}
759
760static gboolean io_watch_poll_check(GSource *source)
761{
d185c094 762 return FALSE;
96c63847
AL		 763}
764
765static gboolean io_watch_poll_dispatch(GSource *source, GSourceFunc callback,
766 gpointer user_data)
767{
d185c094 768 abort();
96c63847
AL		 769}
770
771static void io_watch_poll_finalize(GSource *source)
772{
2b316774
PB		 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 */
96c63847 783 IOWatchPoll *iwp = io_watch_poll_from_source(source);
2b316774 784 assert(iwp->src == NULL);
96c63847
AL		 785}
786
787static 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 */
0ec7b3e7 795static guint io_add_watch_poll(Chardev *chr,
e93a68e1 796 QIOChannel *ioc,
96c63847 797 IOCanReadHandler *fd_can_read,
9894dc0c 798 QIOChannelFunc fd_read,
e92aa36a
ZC		 799 gpointer user_data,
800 GMainContext *context)
96c63847
AL		 801{
802 IOWatchPoll *iwp;
0ca5aa4f 803 int tag;
e93a68e1 804 char *name;
96c63847 805
e92aa36a
ZC		 806 iwp = (IOWatchPoll *) g_source_new(&io_watch_poll_funcs,
807 sizeof(IOWatchPoll));
96c63847
AL		 808 iwp->fd_can_read = fd_can_read;
809 iwp->opaque = user_data;
9894dc0c 810 iwp->ioc = ioc;
1e885b25
PB		 811 iwp->fd_read = (GSourceFunc) fd_read;
812 iwp->src = NULL;
e92aa36a 813 iwp->context = context;
96c63847 814
e93a68e1
DB		 815 name = g_strdup_printf("chardev-iowatch-%s", chr->label);
816 g_source_set_name((GSource *)iwp, name);
817 g_free(name);
818
e92aa36a 819 tag = g_source_attach(&iwp->parent, context);
0ca5aa4f
PB		 820 g_source_unref(&iwp->parent);
821 return tag;
96c63847
AL		 822}
823
2b316774
PB		 824static 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
0ec7b3e7 843static void remove_fd_in_watch(Chardev *chr)
26da70c7
AS		 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
96c63847 851
9894dc0c
DB		 852static int io_channel_send_full(QIOChannel *ioc,
853 const void *buf, size_t len,
854 int *fds, size_t nfds)
76a9644b 855{
9894dc0c 856 size_t offset = 0;
76a9644b 857
9894dc0c
DB		 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) {
9894dc0c
DB		 867 if (offset) {
868 return offset;
869 }
76a9644b 870
e046fb44
DB		 871 errno = EAGAIN;
872 return -1;
873 } else if (ret < 0) {
9894dc0c
DB		 874 errno = EINVAL;
875 return -1;
876 }
76a9644b 877
9894dc0c
DB		 878 offset += ret;
879 }
76a9644b 880
9894dc0c 881 return offset;
76a9644b
AL		 882}
883
9894dc0c 884
0ff0fad2 885#ifndef _WIN32
9894dc0c 886static int io_channel_send(QIOChannel *ioc, const void *buf, size_t len)
96c63847 887{
9894dc0c 888 return io_channel_send_full(ioc, buf, len, NULL, 0);
96c63847 889}
96c63847 890
0ec7b3e7
MAL		 891typedef struct FDChardev {
892 Chardev parent;
893 Chardev *chr;
9894dc0c 894 QIOChannel *ioc_in, *ioc_out;
6f97dba0 895 int max_size;
0ec7b3e7 896} FDChardev;
6f97dba0 897
777357d7
MAL		 898#define TYPE_CHARDEV_FD "chardev-fd"
899#define FD_CHARDEV(obj) OBJECT_CHECK(FDChardev, (obj), TYPE_CHARDEV_FD)
900
9005b2a7 901/* Called with chr_write_lock held. */
0ec7b3e7 902static int fd_chr_write(Chardev *chr, const uint8_t *buf, int len)
6f97dba0 903{
777357d7 904 FDChardev *s = FD_CHARDEV(chr);
41ac54b2 905
9894dc0c 906 return io_channel_send(s->ioc_out, buf, len);
6f97dba0
AL		 907}
908
9894dc0c 909static gboolean fd_chr_read(QIOChannel *chan, GIOCondition cond, void *opaque)
6f97dba0 910{
777357d7
MAL		 911 Chardev *chr = CHARDEV(opaque);
912 FDChardev *s = FD_CHARDEV(opaque);
a29753f8 913 int len;
f612143a 914 uint8_t buf[CHR_READ_BUF_LEN];
9894dc0c 915 ssize_t ret;
6f97dba0
AL		 916
917 len = sizeof(buf);
a29753f8 918 if (len > s->max_size) {
6f97dba0 919 len = s->max_size;
a29753f8
AL		 920 }
921 if (len == 0) {
cdbf6e16 922 return TRUE;
a29753f8
AL		 923 }
924
9894dc0c
DB		 925 ret = qio_channel_read(
926 chan, (gchar *)buf, len, NULL);
927 if (ret == 0) {
26da70c7 928 remove_fd_in_watch(chr);
a425d23f 929 qemu_chr_be_event(chr, CHR_EVENT_CLOSED);
a29753f8 930 return FALSE;
6f97dba0 931 }
9894dc0c
DB		 932 if (ret > 0) {
933 qemu_chr_be_write(chr, buf, ret);
6f97dba0 934 }
a29753f8
AL		 935
936 return TRUE;
937}
938
939static int fd_chr_read_poll(void *opaque)
940{
777357d7
MAL		 941 Chardev *chr = CHARDEV(opaque);
942 FDChardev *s = FD_CHARDEV(opaque);
a29753f8
AL		 943
944 s->max_size = qemu_chr_be_can_write(chr);
945 return s->max_size;
6f97dba0
AL		 946}
947
0ec7b3e7 948static GSource *fd_chr_add_watch(Chardev *chr, GIOCondition cond)
23673ca7 949{
777357d7 950 FDChardev *s = FD_CHARDEV(chr);
9894dc0c 951 return qio_channel_create_watch(s->ioc_out, cond);
23673ca7
AL		 952}
953
0ec7b3e7 954static void fd_chr_update_read_handler(Chardev *chr,
a4afa548 955 GMainContext *context)
6f97dba0 956{
777357d7 957 FDChardev *s = FD_CHARDEV(chr);
6f97dba0 958
26da70c7 959 remove_fd_in_watch(chr);
9894dc0c 960 if (s->ioc_in) {
e93a68e1 961 chr->fd_in_tag = io_add_watch_poll(chr, s->ioc_in,
9894dc0c 962 fd_chr_read_poll,
e92aa36a
ZC		 963 fd_chr_read, chr,
964 context);
6f97dba0
AL		 965 }
966}
967
7f2fe073 968static void char_fd_finalize(Object *obj)
6f97dba0 969{
7f2fe073
MAL		 970 Chardev *chr = CHARDEV(obj);
971 FDChardev *s = FD_CHARDEV(obj);
6f97dba0 972
26da70c7 973 remove_fd_in_watch(chr);
9894dc0c
DB		 974 if (s->ioc_in) {
975 object_unref(OBJECT(s->ioc_in));
a29753f8 976 }
9894dc0c
DB		 977 if (s->ioc_out) {
978 object_unref(OBJECT(s->ioc_out));
6f97dba0
AL		 979 }
980
a425d23f 981 qemu_chr_be_event(chr, CHR_EVENT_CLOSED);
6f97dba0
AL		 982}
983
984/* open a character device to a unix fd */
777357d7
MAL		 985static void qemu_chr_open_fd(Chardev *chr,
986 int fd_in, int fd_out)
6f97dba0 987{
777357d7 988 FDChardev *s = FD_CHARDEV(chr);
e93a68e1 989 char *name;
6f97dba0 990
9894dc0c 991 s->ioc_in = QIO_CHANNEL(qio_channel_file_new_fd(fd_in));
e93a68e1
DB		 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);
9894dc0c 995 s->ioc_out = QIO_CHANNEL(qio_channel_file_new_fd(fd_out));
e93a68e1
DB		 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);
4ff12bdb 999 qemu_set_nonblock(fd_out);
a29753f8 1000 s->chr = chr;
777357d7 1001}
6f97dba0 1002
777357d7
MAL		 1003static 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;
6f97dba0
AL		 1010}
1011
777357d7
MAL		 1012static const TypeInfo char_fd_type_info = {
1013 .name = TYPE_CHARDEV_FD,
1014 .parent = TYPE_CHARDEV,
1015 .instance_size = sizeof(FDChardev),
7f2fe073 1016 .instance_finalize = char_fd_finalize,
777357d7
MAL		 1017 .class_init = char_fd_class_init,
1018 .abstract = true,
1019};
1020
1021static void qemu_chr_open_pipe(Chardev *chr,
1022 ChardevBackend *backend,
1023 bool *be_opened,
1024 Error **errp)
6f97dba0 1025{
32bafa8f 1026 ChardevHostdev *opts = backend->u.pipe.data;
6f97dba0 1027 int fd_in, fd_out;
0ff0fad2
DB		 1028 char *filename_in;
1029 char *filename_out;
548cbb36 1030 const char *filename = opts->device;
0ff0fad2
DB		 1031
1032 filename_in = g_strdup_printf("%s.in", filename);
1033 filename_out = g_strdup_printf("%s.out", filename);
40ff6d7e
KW		 1034 TFR(fd_in = qemu_open(filename_in, O_RDWR | O_BINARY));
1035 TFR(fd_out = qemu_open(filename_out, O_RDWR | O_BINARY));
0ff0fad2
DB		 1036 g_free(filename_in);
1037 g_free(filename_out);
6f97dba0
AL		 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);
b181e047 1043 TFR(fd_in = fd_out = qemu_open(filename, O_RDWR | O_BINARY));
a89dd6c3 1044 if (fd_in < 0) {
20cbe7a2 1045 error_setg_file_open(errp, errno, filename);
777357d7 1046 return;
a89dd6c3 1047 }
6f97dba0 1048 }
777357d7 1049 qemu_chr_open_fd(chr, fd_in, fd_out);
6f97dba0
AL		 1050}
1051
6f97dba0
AL		 1052/* init terminal so that we can grab keys */
1053static struct termios oldtty;
1054static int old_fd0_flags;
c88930a6 1055static bool stdio_in_use;
bb002513 1056static bool stdio_allow_signal;
e76d4420
GH		 1057static bool stdio_echo_state;
1058
0ec7b3e7 1059static void qemu_chr_set_echo_stdio(Chardev *chr, bool echo);
6f97dba0
AL		 1060
1061static void term_exit(void)
1062{
1063 tcsetattr (0, TCSANOW, &oldtty);
1064 fcntl(0, F_SETFL, old_fd0_flags);
1065}
1066
e76d4420
GH		 1067static 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
0ec7b3e7 1073static void qemu_chr_set_echo_stdio(Chardev *chr, bool echo)
6f97dba0
AL		 1074{
1075 struct termios tty;
1076
e76d4420 1077 stdio_echo_state = echo;
0369364b 1078 tty = oldtty;
bb002513
PB		 1079 if (!echo) {
1080 tty.c_iflag &= ~(IGNBRK|BRKINT|PARMRK|ISTRIP
6f97dba0 1081 |INLCR|IGNCR|ICRNL|IXON);
bb002513
PB		 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 }
bb002513 1089 if (!stdio_allow_signal)
6f97dba0 1090 tty.c_lflag &= ~ISIG;
6f97dba0
AL		 1091
1092 tcsetattr (0, TCSANOW, &tty);
6f97dba0
AL		 1093}
1094
4d833ada 1095static void char_stdio_finalize(Object *obj)
6f97dba0
AL		 1096{
1097 term_exit();
6f97dba0
AL		 1098}
1099
777357d7
MAL		 1100static void qemu_chr_open_stdio(Chardev *chr,
1101 ChardevBackend *backend,
1102 bool *be_opened,
1103 Error **errp)
6f97dba0 1104{
32bafa8f 1105 ChardevStdio *opts = backend->u.stdio.data;
e76d4420 1106 struct sigaction act;
6f97dba0 1107
ab51b1d5 1108 if (is_daemonized()) {
8c84b25d 1109 error_setg(errp, "cannot use stdio with -daemonize");
777357d7 1110 return;
ab51b1d5 1111 }
c88930a6
LL		 1112
1113 if (stdio_in_use) {
8c84b25d 1114 error_setg(errp, "cannot use stdio by multiple character devices");
777357d7 1115 return;
c88930a6
LL		 1116 }
1117
1118 stdio_in_use = true;
ed7a1540 1119 old_fd0_flags = fcntl(0, F_GETFL);
c88930a6 1120 tcgetattr(0, &oldtty);
4ff12bdb 1121 qemu_set_nonblock(0);
ed7a1540 1122 atexit(term_exit);
0369364b 1123
e76d4420
GH		 1124 memset(&act, 0, sizeof(act));
1125 act.sa_handler = term_stdio_handler;
1126 sigaction(SIGCONT, &act, NULL);
1127
777357d7
MAL		 1128 qemu_chr_open_fd(chr, 0, 1);
1129
7c358031
GH		 1130 if (opts->has_signal) {
1131 stdio_allow_signal = opts->signal;
1132 }
5345fdb4 1133 qemu_chr_set_echo_stdio(chr, false);
6f97dba0
AL		 1134}
1135
6f97dba0 1136#if defined(__linux__) || defined(__sun__) || defined(__FreeBSD__) \
a167ba50
AJ		 1137 || defined(__NetBSD__) || defined(__OpenBSD__) || defined(__DragonFly__) \
1138 || defined(__GLIBC__)
6f97dba0 1139
d809ab95
PB		 1140#define HAVE_CHARDEV_SERIAL 1
1141#define HAVE_CHARDEV_PTY 1
e551498e 1142
6f97dba0 1143typedef struct {
0ec7b3e7 1144 Chardev parent;
9894dc0c 1145 QIOChannel *ioc;
6f97dba0 1146 int read_bytes;
9005b2a7 1147
0ec7b3e7 1148 /* Protected by the Chardev chr_write_lock. */
9005b2a7 1149 int connected;
8aa33caf 1150 guint timer_tag;
7b3621f4 1151 guint open_tag;
0ec7b3e7 1152} PtyChardev;
6f97dba0 1153
777357d7
MAL		 1154#define PTY_CHARDEV(obj) OBJECT_CHECK(PtyChardev, (obj), TYPE_CHARDEV_PTY)
1155
0ec7b3e7
MAL		 1156static void pty_chr_update_read_handler_locked(Chardev *chr);
1157static void pty_chr_state(Chardev *chr, int connected);
6f97dba0 1158
8aa33caf
AL		 1159static gboolean pty_chr_timer(gpointer opaque)
1160{
777357d7
MAL		 1161 struct Chardev *chr = CHARDEV(opaque);
1162 PtyChardev *s = PTY_CHARDEV(opaque);
8aa33caf 1163
9005b2a7 1164 qemu_mutex_lock(&chr->chr_write_lock);
79f20075 1165 s->timer_tag = 0;
7b3621f4 1166 s->open_tag = 0;
b0d768c3
GH		 1167 if (!s->connected) {
1168 /* Next poll ... */
9005b2a7 1169 pty_chr_update_read_handler_locked(chr);
b0d768c3 1170 }
9005b2a7 1171 qemu_mutex_unlock(&chr->chr_write_lock);
8aa33caf
AL		 1172 return FALSE;
1173}
1174
9005b2a7 1175/* Called with chr_write_lock held. */
0ec7b3e7 1176static void pty_chr_rearm_timer(Chardev *chr, int ms)
8aa33caf 1177{
777357d7 1178 PtyChardev *s = PTY_CHARDEV(chr);
e93a68e1 1179 char *name;
8aa33caf
AL		 1180
1181 if (s->timer_tag) {
1182 g_source_remove(s->timer_tag);
1183 s->timer_tag = 0;
1184 }
1185
1186 if (ms == 1000) {
e93a68e1 1187 name = g_strdup_printf("pty-timer-secs-%s", chr->label);
8aa33caf
AL		 1188 s->timer_tag = g_timeout_add_seconds(1, pty_chr_timer, chr);
1189 } else {
e93a68e1 1190 name = g_strdup_printf("pty-timer-ms-%s", chr->label);
8aa33caf
AL		 1191 s->timer_tag = g_timeout_add(ms, pty_chr_timer, chr);
1192 }
e93a68e1
DB		 1193 g_source_set_name_by_id(s->timer_tag, name);
1194 g_free(name);
8aa33caf
AL		 1195}
1196
9005b2a7 1197/* Called with chr_write_lock held. */
0ec7b3e7 1198static void pty_chr_update_read_handler_locked(Chardev *chr)
1bb7fe72 1199{
777357d7 1200 PtyChardev *s = PTY_CHARDEV(chr);
1bb7fe72 1201 GPollFD pfd;
c1f24489 1202 int rc;
9894dc0c 1203 QIOChannelFile *fioc = QIO_CHANNEL_FILE(s->ioc);
1bb7fe72 1204
9894dc0c 1205 pfd.fd = fioc->fd;
1bb7fe72
PB		 1206 pfd.events = G_IO_OUT;
1207 pfd.revents = 0;
c1f24489
PB		 1208 do {
1209 rc = g_poll(&pfd, 1, 0);
1210 } while (rc == -1 && errno == EINTR);
1211 assert(rc >= 0);
1212
1bb7fe72
PB		 1213 if (pfd.revents & G_IO_HUP) {
1214 pty_chr_state(chr, 0);
1215 } else {
1216 pty_chr_state(chr, 1);
1217 }
1218}
1219
0ec7b3e7 1220static void pty_chr_update_read_handler(Chardev *chr,
a4afa548 1221 GMainContext *context)
9005b2a7
PB		 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. */
777357d7 1229static int char_pty_chr_write(Chardev *chr, const uint8_t *buf, int len)
6f97dba0 1230{
777357d7 1231 PtyChardev *s = PTY_CHARDEV(chr);
6f97dba0
AL		 1232
1233 if (!s->connected) {
1234 /* guest sends data, check for (re-)connect */
9005b2a7 1235 pty_chr_update_read_handler_locked(chr);
cf7330c7
ST		 1236 if (!s->connected) {
1237 return 0;
1238 }
6f97dba0 1239 }
9894dc0c 1240 return io_channel_send(s->ioc, buf, len);
6f97dba0
AL		 1241}
1242
0ec7b3e7 1243static GSource *pty_chr_add_watch(Chardev *chr, GIOCondition cond)
e6a87ed8 1244{
777357d7 1245 PtyChardev *s = PTY_CHARDEV(chr);
62c339c5
PB		 1246 if (!s->connected) {
1247 return NULL;
1248 }
9894dc0c 1249 return qio_channel_create_watch(s->ioc, cond);
e6a87ed8
AL		 1250}
1251
6f97dba0
AL		 1252static int pty_chr_read_poll(void *opaque)
1253{
777357d7
MAL		 1254 Chardev *chr = CHARDEV(opaque);
1255 PtyChardev *s = PTY_CHARDEV(opaque);
6f97dba0 1256
909cda12 1257 s->read_bytes = qemu_chr_be_can_write(chr);
6f97dba0
AL		 1258 return s->read_bytes;
1259}
1260
9894dc0c 1261static gboolean pty_chr_read(QIOChannel *chan, GIOCondition cond, void *opaque)
6f97dba0 1262{
777357d7
MAL		 1263 Chardev *chr = CHARDEV(opaque);
1264 PtyChardev *s = PTY_CHARDEV(opaque);
9894dc0c 1265 gsize len;
f612143a 1266 uint8_t buf[CHR_READ_BUF_LEN];
9894dc0c 1267 ssize_t ret;
6f97dba0
AL		 1268
1269 len = sizeof(buf);
1270 if (len > s->read_bytes)
1271 len = s->read_bytes;
cdbf6e16
PB		 1272 if (len == 0) {
1273 return TRUE;
1274 }
9894dc0c
DB		 1275 ret = qio_channel_read(s->ioc, (char *)buf, len, NULL);
1276 if (ret <= 0) {
6f97dba0 1277 pty_chr_state(chr, 0);
093d3a20
AL		 1278 return FALSE;
1279 } else {
6f97dba0 1280 pty_chr_state(chr, 1);
9894dc0c 1281 qemu_chr_be_write(chr, buf, ret);
6f97dba0 1282 }
093d3a20 1283 return TRUE;
6f97dba0
AL		 1284}
1285
7b3621f4
PB		 1286static gboolean qemu_chr_be_generic_open_func(gpointer opaque)
1287{
777357d7
MAL		 1288 Chardev *chr = CHARDEV(opaque);
1289 PtyChardev *s = PTY_CHARDEV(opaque);
7b3621f4
PB		 1290
1291 s->open_tag = 0;
1292 qemu_chr_be_generic_open(chr);
1293 return FALSE;
1294}
1295
9005b2a7 1296/* Called with chr_write_lock held. */
0ec7b3e7 1297static void pty_chr_state(Chardev *chr, int connected)
6f97dba0 1298{
777357d7 1299 PtyChardev *s = PTY_CHARDEV(chr);
6f97dba0
AL		 1300
1301 if (!connected) {
7b3621f4
PB		 1302 if (s->open_tag) {
1303 g_source_remove(s->open_tag);
1304 s->open_tag = 0;
1305 }
26da70c7 1306 remove_fd_in_watch(chr);
6f97dba0 1307 s->connected = 0;
6f97dba0
AL		 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. */
8aa33caf 1311 pty_chr_rearm_timer(chr, 1000);
6f97dba0 1312 } else {
85a67692
PB		 1313 if (s->timer_tag) {
1314 g_source_remove(s->timer_tag);
1315 s->timer_tag = 0;
1316 }
1317 if (!s->connected) {
7b3621f4 1318 g_assert(s->open_tag == 0);
85a67692 1319 s->connected = 1;
7b3621f4 1320 s->open_tag = g_idle_add(qemu_chr_be_generic_open_func, chr);
ac1b84dd
GH		 1321 }
1322 if (!chr->fd_in_tag) {
e93a68e1 1323 chr->fd_in_tag = io_add_watch_poll(chr, s->ioc,
9894dc0c 1324 pty_chr_read_poll,
e92aa36a
ZC		 1325 pty_chr_read,
1326 chr, NULL);
85a67692 1327 }
6f97dba0
AL		 1328 }
1329}
1330
fa943b5e 1331static void char_pty_finalize(Object *obj)
6f97dba0 1332{
fa943b5e
MAL		 1333 Chardev *chr = CHARDEV(obj);
1334 PtyChardev *s = PTY_CHARDEV(obj);
6f97dba0 1335
7b3621f4
PB		 1336 qemu_mutex_lock(&chr->chr_write_lock);
1337 pty_chr_state(chr, 0);
9894dc0c 1338 object_unref(OBJECT(s->ioc));
8aa33caf
AL		 1339 if (s->timer_tag) {
1340 g_source_remove(s->timer_tag);
910b6368 1341 s->timer_tag = 0;
8aa33caf 1342 }
7b3621f4 1343 qemu_mutex_unlock(&chr->chr_write_lock);
a425d23f 1344 qemu_chr_be_event(chr, CHR_EVENT_CLOSED);
6f97dba0
AL		 1345}
1346
777357d7
MAL		 1347static void char_pty_open(Chardev *chr,
1348 ChardevBackend *backend,
1349 bool *be_opened,
1350 Error **errp)
6f97dba0 1351{
0ec7b3e7 1352 PtyChardev *s;
e68c5958 1353 int master_fd, slave_fd;
6f97dba0 1354 char pty_name[PATH_MAX];
e93a68e1 1355 char *name;
6f97dba0 1356
4efeabbb
MT		 1357 master_fd = qemu_openpty_raw(&slave_fd, pty_name);
1358 if (master_fd < 0) {
c2e75a43 1359 error_setg_errno(errp, errno, "Failed to create PTY");
777357d7 1360 return;
6f97dba0
AL		 1361 }
1362
837a183f 1363 close(slave_fd);
fac6688a 1364 qemu_set_nonblock(master_fd);
6f97dba0 1365
4efeabbb 1366 chr->filename = g_strdup_printf("pty:%s", pty_name);
776a32a0 1367 error_report("char device redirected to %s (label %s)",
777357d7 1368 pty_name, chr->label);
6f97dba0 1369
777357d7 1370 s = PTY_CHARDEV(chr);
9894dc0c 1371 s->ioc = QIO_CHANNEL(qio_channel_file_new_fd(master_fd));
e93a68e1
DB		 1372 name = g_strdup_printf("chardev-pty-%s", chr->label);
1373 qio_channel_set_name(QIO_CHANNEL(s->ioc), name);
1374 g_free(name);
8aa33caf 1375 s->timer_tag = 0;
41ac54b2 1376 *be_opened = false;
6f97dba0
AL		 1377}
1378
777357d7
MAL		 1379static 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;
777357d7
MAL		 1387}
1388
1389static const TypeInfo char_pty_type_info = {
1390 .name = TYPE_CHARDEV_PTY,
1391 .parent = TYPE_CHARDEV,
1392 .instance_size = sizeof(PtyChardev),
fa943b5e 1393 .instance_finalize = char_pty_finalize,
777357d7 1394 .class_init = char_pty_class_init,
b68e956a
MAL		 1395};
1396
6f97dba0
AL		 1397static 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
45eea13b
SW		 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
6f97dba0 1469 spd = B115200;
45eea13b 1470 } while (0);
6f97dba0
AL		 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
0ec7b3e7 1512static int tty_serial_ioctl(Chardev *chr, int cmd, void *arg)
6f97dba0 1513{
777357d7 1514 FDChardev *s = FD_CHARDEV(chr);
9894dc0c 1515 QIOChannelFile *fioc = QIO_CHANNEL_FILE(s->ioc_in);
6f97dba0
AL		 1516
1517 switch(cmd) {
1518 case CHR_IOCTL_SERIAL_SET_PARAMS:
1519 {
1520 QEMUSerialSetParams *ssp = arg;
9894dc0c 1521 tty_serial_init(fioc->fd,
a29753f8 1522 ssp->speed, ssp->parity,
6f97dba0
AL		 1523 ssp->data_bits, ssp->stop_bits);
1524 }
1525 break;
1526 case CHR_IOCTL_SERIAL_SET_BREAK:
1527 {
1528 int enable = *(int *)arg;
a29753f8 1529 if (enable) {
9894dc0c 1530 tcsendbreak(fioc->fd, 1);
a29753f8 1531 }
6f97dba0
AL		 1532 }
1533 break;
1534 case CHR_IOCTL_SERIAL_GET_TIOCM:
1535 {
1536 int sarg = 0;
1537 int *targ = (int *)arg;
9894dc0c 1538 ioctl(fioc->fd, TIOCMGET, &sarg);
6f97dba0 1539 *targ = 0;
b4abdfa4 1540 if (sarg & TIOCM_CTS)
6f97dba0 1541 *targ |= CHR_TIOCM_CTS;
b4abdfa4 1542 if (sarg & TIOCM_CAR)
6f97dba0 1543 *targ |= CHR_TIOCM_CAR;
b4abdfa4 1544 if (sarg & TIOCM_DSR)
6f97dba0 1545 *targ |= CHR_TIOCM_DSR;
b4abdfa4 1546 if (sarg & TIOCM_RI)
6f97dba0 1547 *targ |= CHR_TIOCM_RI;
b4abdfa4 1548 if (sarg & TIOCM_DTR)
6f97dba0 1549 *targ |= CHR_TIOCM_DTR;
b4abdfa4 1550 if (sarg & TIOCM_RTS)
6f97dba0
AL		 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;
9894dc0c 1558 ioctl(fioc->fd, TIOCMGET, &targ);
b4abdfa4
AJ		 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)
6f97dba0 1570 targ |= TIOCM_DTR;
b4abdfa4 1571 if (sarg & CHR_TIOCM_RTS)
6f97dba0 1572 targ |= TIOCM_RTS;
9894dc0c 1573 ioctl(fioc->fd, TIOCMSET, &targ);
6f97dba0
AL		 1574 }
1575 break;
1576 default:
1577 return -ENOTSUP;
1578 }
1579 return 0;
1580}
6f97dba0
AL		 1581#endif /* __linux__ || __sun__ */
1582
1583#if defined(__linux__)
e551498e
GH		 1584
1585#define HAVE_CHARDEV_PARPORT 1
1586
6f97dba0 1587typedef struct {
0ec7b3e7 1588 Chardev parent;
6f97dba0
AL		 1589 int fd;
1590 int mode;
0ec7b3e7 1591} ParallelChardev;
6f97dba0 1592
777357d7
MAL		 1593#define PARALLEL_CHARDEV(obj) \
1594 OBJECT_CHECK(ParallelChardev, (obj), TYPE_CHARDEV_PARALLEL)
1595
0ec7b3e7 1596static int pp_hw_mode(ParallelChardev *s, uint16_t mode)
6f97dba0
AL		 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
0ec7b3e7 1607static int pp_ioctl(Chardev *chr, int cmd, void *arg)
6f97dba0 1608{
777357d7 1609 ParallelChardev *drv = PARALLEL_CHARDEV(chr);
6f97dba0
AL		 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
777357d7
MAL		 1688static void qemu_chr_open_pp_fd(Chardev *chr,
1689 int fd,
1690 bool *be_opened,
1691 Error **errp)
6f97dba0 1692{
777357d7 1693 ParallelChardev *drv = PARALLEL_CHARDEV(chr);
6f97dba0
AL		 1694
1695 if (ioctl(fd, PPCLAIM) < 0) {
38bfb1a6 1696 error_setg_errno(errp, errno, "not a parallel port");
6f97dba0 1697 close(fd);
777357d7 1698 return;
d0d7708b 1699 }
27ef9cb0 1700
27ef9cb0
PB		 1701 drv->fd = fd;
1702 drv->mode = IEEE1284_MODE_COMPAT;
6f97dba0
AL		 1703}
1704#endif /* __linux__ */
1705
a167ba50 1706#if defined(__FreeBSD__) || defined(__FreeBSD_kernel__) || defined(__DragonFly__)
e551498e
GH		 1707
1708#define HAVE_CHARDEV_PARPORT 1
1709
41ac54b2 1710typedef struct {
0ec7b3e7 1711 Chardev parent;
41ac54b2 1712 int fd;
0ec7b3e7 1713} ParallelChardev;
41ac54b2 1714
777357d7
MAL		 1715#define PARALLEL_CHARDEV(obj) \
1716 OBJECT_CHECK(ParallelChardev, (obj), TYPE_CHARDEV_PARALLEL)
1717
0ec7b3e7 1718static int pp_ioctl(Chardev *chr, int cmd, void *arg)
6972f935 1719{
777357d7 1720 ParallelChardev *drv = PARALLEL_CHARDEV(chr);
6972f935
BS		 1721 uint8_t b;
1722
41ac54b2 1723 switch (cmd) {
6972f935 1724 case CHR_IOCTL_PP_READ_DATA:
41ac54b2 1725 if (ioctl(drv->fd, PPIGDATA, &b) < 0) {
6972f935 1726 return -ENOTSUP;
41ac54b2 1727 }
6972f935
BS		 1728 *(uint8_t *)arg = b;
1729 break;
1730 case CHR_IOCTL_PP_WRITE_DATA:
1731 b = *(uint8_t *)arg;
41ac54b2 1732 if (ioctl(drv->fd, PPISDATA, &b) < 0) {
6972f935 1733 return -ENOTSUP;
41ac54b2 1734 }
6972f935
BS		 1735 break;
1736 case CHR_IOCTL_PP_READ_CONTROL:
41ac54b2 1737 if (ioctl(drv->fd, PPIGCTRL, &b) < 0) {
6972f935 1738 return -ENOTSUP;
41ac54b2 1739 }
6972f935
BS		 1740 *(uint8_t *)arg = b;
1741 break;
1742 case CHR_IOCTL_PP_WRITE_CONTROL:
1743 b = *(uint8_t *)arg;
41ac54b2 1744 if (ioctl(drv->fd, PPISCTRL, &b) < 0) {
6972f935 1745 return -ENOTSUP;
41ac54b2 1746 }
6972f935
BS		 1747 break;
1748 case CHR_IOCTL_PP_READ_STATUS:
41ac54b2 1749 if (ioctl(drv->fd, PPIGSTATUS, &b) < 0) {
6972f935 1750 return -ENOTSUP;
41ac54b2 1751 }
6972f935
BS		 1752 *(uint8_t *)arg = b;
1753 break;
1754 default:
1755 return -ENOTSUP;
1756 }
1757 return 0;
1758}
1759
777357d7
MAL		 1760static void qemu_chr_open_pp_fd(Chardev *chr,
1761 int fd,
1762 bool *be_opened,
1763 Error **errp)
6972f935 1764{
777357d7 1765 ParallelChardev *drv = PARALLEL_CHARDEV(chr);
41ac54b2 1766 drv->fd = fd;
82878dac 1767 *be_opened = false;
6972f935
BS		 1768}
1769#endif
1770
6f97dba0
AL		 1771#else /* _WIN32 */
1772
d809ab95
PB		 1773#define HAVE_CHARDEV_SERIAL 1
1774
6f97dba0 1775typedef struct {
0ec7b3e7 1776 Chardev parent;
6f97dba0
AL		 1777 int max_size;
1778 HANDLE hcom, hrecv, hsend;
9005b2a7 1779 OVERLAPPED orecv;
6f97dba0
AL		 1780 BOOL fpipe;
1781 DWORD len;
9005b2a7 1782
0ec7b3e7 1783 /* Protected by the Chardev chr_write_lock. */
9005b2a7 1784 OVERLAPPED osend;
c266d94e
MAL		 1785 /* FIXME: file/console do not finalize */
1786 bool skip_free;
0ec7b3e7 1787} WinChardev;
6f97dba0 1788
777357d7
MAL		 1789#define TYPE_CHARDEV_WIN "chardev-win"
1790#define WIN_CHARDEV(obj) OBJECT_CHECK(WinChardev, (obj), TYPE_CHARDEV_WIN)
1791
db418a0a 1792typedef struct {
0ec7b3e7 1793 Chardev parent;
db418a0a
FC		 1794 HANDLE hStdIn;
1795 HANDLE hInputReadyEvent;
1796 HANDLE hInputDoneEvent;
1797 HANDLE hInputThread;
1798 uint8_t win_stdio_buf;
0ec7b3e7 1799} WinStdioChardev;
db418a0a 1800
777357d7
MAL		 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
6f97dba0
AL		 1805#define NSENDBUF 2048
1806#define NRECVBUF 2048
1807#define MAXCONNECT 1
1808#define NTIMEOUT 5000
1809
1810static int win_chr_poll(void *opaque);
1811static int win_chr_pipe_poll(void *opaque);
1812
53a5736f 1813static void char_win_finalize(Object *obj)
6f97dba0 1814{
53a5736f 1815 Chardev *chr = CHARDEV(obj);
777357d7 1816 WinChardev *s = WIN_CHARDEV(chr);
6f97dba0 1817
c266d94e
MAL		 1818 if (s->skip_free) {
1819 return;
1820 }
1821
6f97dba0
AL		 1822 if (s->hsend) {
1823 CloseHandle(s->hsend);
6f97dba0
AL		 1824 }
1825 if (s->hrecv) {
1826 CloseHandle(s->hrecv);
6f97dba0
AL		 1827 }
1828 if (s->hcom) {
1829 CloseHandle(s->hcom);
6f97dba0
AL		 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);
793cbfb5 1835
a425d23f 1836 qemu_chr_be_event(chr, CHR_EVENT_CLOSED);
6f97dba0
AL		 1837}
1838
0ec7b3e7 1839static int win_chr_init(Chardev *chr, const char *filename, Error **errp)
6f97dba0 1840{
777357d7 1841 WinChardev *s = WIN_CHARDEV(chr);
6f97dba0
AL		 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) {
6511d396 1850 error_setg(errp, "Failed CreateEvent");
6f97dba0
AL		 1851 goto fail;
1852 }
1853 s->hrecv = CreateEvent(NULL, TRUE, FALSE, NULL);
1854 if (!s->hrecv) {
6511d396 1855 error_setg(errp, "Failed CreateEvent");
6f97dba0
AL		 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) {
6511d396 1862 error_setg(errp, "Failed CreateFile (%lu)", GetLastError());
6f97dba0
AL		 1863 s->hcom = NULL;
1864 goto fail;
1865 }
1866
1867 if (!SetupComm(s->hcom, NRECVBUF, NSENDBUF)) {
6511d396 1868 error_setg(errp, "Failed SetupComm");
6f97dba0
AL		 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)) {
6511d396 1879 error_setg(errp, "Failed SetCommState");
6f97dba0
AL		 1880 goto fail;
1881 }
1882
1883 if (!SetCommMask(s->hcom, EV_ERR)) {
6511d396 1884 error_setg(errp, "Failed SetCommMask");
6f97dba0
AL		 1885 goto fail;
1886 }
1887
1888 cto.ReadIntervalTimeout = MAXDWORD;
1889 if (!SetCommTimeouts(s->hcom, &cto)) {
6511d396 1890 error_setg(errp, "Failed SetCommTimeouts");
6f97dba0
AL		 1891 goto fail;
1892 }
1893
1894 if (!ClearCommError(s->hcom, &err, &comstat)) {
6511d396 1895 error_setg(errp, "Failed ClearCommError");
6f97dba0
AL		 1896 goto fail;
1897 }
1898 qemu_add_polling_cb(win_chr_poll, chr);
1899 return 0;
1900
1901 fail:
6f97dba0
AL		 1902 return -1;
1903}
1904
9005b2a7 1905/* Called with chr_write_lock held. */
0ec7b3e7 1906static int win_chr_write(Chardev *chr, const uint8_t *buf, int len1)
6f97dba0 1907{
777357d7 1908 WinChardev *s = WIN_CHARDEV(chr);
6f97dba0
AL		 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
0ec7b3e7 1940static int win_chr_read_poll(Chardev *chr)
6f97dba0 1941{
777357d7 1942 WinChardev *s = WIN_CHARDEV(chr);
6f97dba0 1943
909cda12 1944 s->max_size = qemu_chr_be_can_write(chr);
6f97dba0
AL		 1945 return s->max_size;
1946}
1947
0ec7b3e7 1948static void win_chr_readfile(Chardev *chr)
6f97dba0 1949{
777357d7
MAL		 1950 WinChardev *s = WIN_CHARDEV(chr);
1951
6f97dba0 1952 int ret, err;
f612143a 1953 uint8_t buf[CHR_READ_BUF_LEN];
6f97dba0
AL		 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) {
fa5efccb 1967 qemu_chr_be_write(chr, buf, size);
6f97dba0
AL		 1968 }
1969}
1970
0ec7b3e7 1971static void win_chr_read(Chardev *chr)
6f97dba0 1972{
777357d7 1973 WinChardev *s = WIN_CHARDEV(chr);
6f97dba0
AL		 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
1983static int win_chr_poll(void *opaque)
1984{
777357d7
MAL		 1985 Chardev *chr = CHARDEV(opaque);
1986 WinChardev *s = WIN_CHARDEV(opaque);
6f97dba0
AL		 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
6f97dba0
AL		 2000static int win_chr_pipe_poll(void *opaque)
2001{
777357d7
MAL		 2002 Chardev *chr = CHARDEV(opaque);
2003 WinChardev *s = WIN_CHARDEV(opaque);
6f97dba0
AL		 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
0ec7b3e7 2016static int win_chr_pipe_init(Chardev *chr, const char *filename,
20cbe7a2 2017 Error **errp)
6f97dba0 2018{
777357d7 2019 WinChardev *s = WIN_CHARDEV(chr);
6f97dba0
AL		 2020 OVERLAPPED ov;
2021 int ret;
2022 DWORD size;
0ff0fad2 2023 char *openname;
6f97dba0
AL		 2024
2025 s->fpipe = TRUE;
2026
2027 s->hsend = CreateEvent(NULL, TRUE, FALSE, NULL);
2028 if (!s->hsend) {
20cbe7a2 2029 error_setg(errp, "Failed CreateEvent");
6f97dba0
AL		 2030 goto fail;
2031 }
2032 s->hrecv = CreateEvent(NULL, TRUE, FALSE, NULL);
2033 if (!s->hrecv) {
20cbe7a2 2034 error_setg(errp, "Failed CreateEvent");
6f97dba0
AL		 2035 goto fail;
2036 }
2037
0ff0fad2 2038 openname = g_strdup_printf("\\\\.\\pipe\\%s", filename);
6f97dba0
AL		 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);
0ff0fad2 2043 g_free(openname);
6f97dba0 2044 if (s->hcom == INVALID_HANDLE_VALUE) {
20cbe7a2 2045 error_setg(errp, "Failed CreateNamedPipe (%lu)", GetLastError());
6f97dba0
AL		 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) {
20cbe7a2 2054 error_setg(errp, "Failed ConnectNamedPipe");
6f97dba0
AL		 2055 goto fail;
2056 }
2057
2058 ret = GetOverlappedResult(s->hcom, &ov, &size, TRUE);
2059 if (!ret) {
20cbe7a2 2060 error_setg(errp, "Failed GetOverlappedResult");
6f97dba0
AL		 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:
6f97dba0
AL		 2076 return -1;
2077}
2078
2079
777357d7
MAL		 2080static void qemu_chr_open_pipe(Chardev *chr,
2081 ChardevBackend *backend,
2082 bool *be_opened,
2083 Error **errp)
6f97dba0 2084{
32bafa8f 2085 ChardevHostdev *opts = backend->u.pipe.data;
548cbb36 2086 const char *filename = opts->device;
6f97dba0 2087
20cbe7a2 2088 if (win_chr_pipe_init(chr, filename, errp) < 0) {
777357d7 2089 return;
6f97dba0 2090 }
6f97dba0
AL		 2091}
2092
777357d7 2093static void qemu_chr_open_win_file(Chardev *chr, HANDLE fd_out)
6f97dba0 2094{
777357d7 2095 WinChardev *s = WIN_CHARDEV(chr);
6f97dba0 2096
c266d94e 2097 s->skip_free = true;
6f97dba0 2098 s->hcom = fd_out;
6f97dba0
AL		 2099}
2100
777357d7 2101static void char_win_class_init(ObjectClass *oc, void *data)
6f97dba0 2102{
777357d7
MAL		 2103 ChardevClass *cc = CHARDEV_CLASS(oc);
2104
2105 cc->chr_write = win_chr_write;
6f97dba0
AL		 2106}
2107
777357d7
MAL		 2108static const TypeInfo char_win_type_info = {
2109 .name = TYPE_CHARDEV_WIN,
2110 .parent = TYPE_CHARDEV,
0ec7b3e7 2111 .instance_size = sizeof(WinChardev),
53a5736f 2112 .instance_finalize = char_win_finalize,
777357d7
MAL		 2113 .class_init = char_win_class_init,
2114 .abstract = true,
2115};
2116
2117static 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
777357d7
MAL		 2125static 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;
777357d7
MAL		 2130}
2131
2132static const TypeInfo char_console_type_info = {
2133 .name = TYPE_CHARDEV_CONSOLE,
2134 .parent = TYPE_CHARDEV_WIN,
2135 .class_init = char_console_class_init,
b68e956a
MAL		 2136};
2137
0ec7b3e7 2138static int win_stdio_write(Chardev *chr, const uint8_t *buf, int len)
db418a0a
FC		 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
2157static void win_stdio_wait_func(void *opaque)
2158{
777357d7
MAL		 2159 Chardev *chr = CHARDEV(opaque);
2160 WinStdioChardev *stdio = WIN_STDIO_CHARDEV(opaque);
db418a0a
FC		 2161 INPUT_RECORD buf[4];
2162 int ret;
2163 DWORD dwSize;
2164 int i;
2165
dff7424d 2166 ret = ReadConsoleInput(stdio->hStdIn, buf, ARRAY_SIZE(buf), &dwSize);
db418a0a
FC		 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
2191static DWORD WINAPI win_stdio_thread(LPVOID param)
2192{
777357d7 2193 WinStdioChardev *stdio = WIN_STDIO_CHARDEV(param);
db418a0a
FC		 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
2229static void win_stdio_thread_wait_func(void *opaque)
2230{
777357d7
MAL		 2231 Chardev *chr = CHARDEV(opaque);
2232 WinStdioChardev *stdio = WIN_STDIO_CHARDEV(opaque);
db418a0a
FC		 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
0ec7b3e7 2241static void qemu_chr_set_echo_win_stdio(Chardev *chr, bool echo)
db418a0a 2242{
777357d7 2243 WinStdioChardev *stdio = WIN_STDIO_CHARDEV(chr);
db418a0a
FC		 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
1566b0c4 2255static void char_win_stdio_finalize(Object *obj)
db418a0a 2256{
1566b0c4 2257 WinStdioChardev *stdio = WIN_STDIO_CHARDEV(obj);
db418a0a
FC		 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 }
db418a0a
FC		 2268}
2269
777357d7
MAL		 2270static const TypeInfo char_win_stdio_type_info = {
2271 .name = TYPE_CHARDEV_WIN_STDIO,
2272 .parent = TYPE_CHARDEV,
2273 .instance_size = sizeof(WinStdioChardev),
1566b0c4 2274 .instance_finalize = char_win_stdio_finalize,
777357d7
MAL		 2275 .abstract = true,
2276};
2277
2278static void qemu_chr_open_stdio(Chardev *chr,
2279 ChardevBackend *backend,
2280 bool *be_opened,
2281 Error **errp)
db418a0a 2282{
777357d7 2283 WinStdioChardev *stdio = WIN_STDIO_CHARDEV(chr);
db418a0a
FC		 2284 DWORD dwMode;
2285 int is_console = 0;
db418a0a
FC		 2286
2287 stdio->hStdIn = GetStdHandle(STD_INPUT_HANDLE);
2288 if (stdio->hStdIn == INVALID_HANDLE_VALUE) {
8c84b25d 2289 error_setg(errp, "cannot open stdio: invalid handle");
777357d7 2290 return;
db418a0a
FC		 2291 }
2292
2293 is_console = GetConsoleMode(stdio->hStdIn, &dwMode) != 0;
2294
ed7a1540
AL		 2295 if (is_console) {
2296 if (qemu_add_wait_object(stdio->hStdIn,
2297 win_stdio_wait_func, chr)) {
8c84b25d
PB		 2298 error_setg(errp, "qemu_add_wait_object: failed");
2299 goto err1;
ed7a1540
AL		 2300 }
2301 } else {
2302 DWORD dwId;
2303
2304 stdio->hInputReadyEvent = CreateEvent(NULL, FALSE, FALSE, NULL);
2305 stdio->hInputDoneEvent = CreateEvent(NULL, FALSE, FALSE, NULL);
8c84b25d 2306 if (stdio->hInputReadyEvent == INVALID_HANDLE_VALUE
ed7a1540 2307 || stdio->hInputDoneEvent == INVALID_HANDLE_VALUE) {
8c84b25d
PB		 2308 error_setg(errp, "cannot create event");
2309 goto err2;
ed7a1540
AL		 2310 }
2311 if (qemu_add_wait_object(stdio->hInputReadyEvent,
2312 win_stdio_thread_wait_func, chr)) {
8c84b25d
PB		 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;
db418a0a
FC		 2322 }
2323 }
2324
2325 dwMode |= ENABLE_LINE_INPUT;
2326
ed7a1540 2327 if (is_console) {
db418a0a
FC		 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
5345fdb4 2335 qemu_chr_set_echo_win_stdio(chr, false);
db418a0a 2336
777357d7 2337 return;
8c84b25d
PB		 2338
2339err3:
2340 qemu_del_wait_object(stdio->hInputReadyEvent, NULL, NULL);
2341err2:
2342 CloseHandle(stdio->hInputReadyEvent);
2343 CloseHandle(stdio->hInputDoneEvent);
2344err1:
2345 qemu_del_wait_object(stdio->hStdIn, NULL, NULL);
db418a0a 2346}
6f97dba0
AL		 2347#endif /* !_WIN32 */
2348
2349/***********************************************************/
2350/* UDP Net console */
2351
2352typedef struct {
0ec7b3e7 2353 Chardev parent;
9894dc0c 2354 QIOChannel *ioc;
f612143a 2355 uint8_t buf[CHR_READ_BUF_LEN];
6f97dba0
AL		 2356 int bufcnt;
2357 int bufptr;
2358 int max_size;
1876ed04 2359} UdpChardev;
6f97dba0 2360
777357d7
MAL		 2361#define UDP_CHARDEV(obj) OBJECT_CHECK(UdpChardev, (obj), TYPE_CHARDEV_UDP)
2362
9005b2a7 2363/* Called with chr_write_lock held. */
0ec7b3e7 2364static int udp_chr_write(Chardev *chr, const uint8_t *buf, int len)
6f97dba0 2365{
777357d7 2366 UdpChardev *s = UDP_CHARDEV(chr);
76a9644b 2367
9894dc0c
DB		 2368 return qio_channel_write(
2369 s->ioc, (const char *)buf, len, NULL);
6f97dba0
AL		 2370}
2371
2372static int udp_chr_read_poll(void *opaque)
2373{
777357d7
MAL		 2374 Chardev *chr = CHARDEV(opaque);
2375 UdpChardev *s = UDP_CHARDEV(opaque);
6f97dba0 2376
909cda12 2377 s->max_size = qemu_chr_be_can_write(chr);
6f97dba0
AL		 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) {
fa5efccb 2383 qemu_chr_be_write(chr, &s->buf[s->bufptr], 1);
6f97dba0 2384 s->bufptr++;
909cda12 2385 s->max_size = qemu_chr_be_can_write(chr);
6f97dba0
AL		 2386 }
2387 return s->max_size;
2388}
2389
9894dc0c 2390static gboolean udp_chr_read(QIOChannel *chan, GIOCondition cond, void *opaque)
6f97dba0 2391{
777357d7
MAL		 2392 Chardev *chr = CHARDEV(opaque);
2393 UdpChardev *s = UDP_CHARDEV(opaque);
9894dc0c 2394 ssize_t ret;
6f97dba0 2395
cdbf6e16
PB		 2396 if (s->max_size == 0) {
2397 return TRUE;
2398 }
9894dc0c
DB		 2399 ret = qio_channel_read(
2400 s->ioc, (char *)s->buf, sizeof(s->buf), NULL);
2401 if (ret <= 0) {
26da70c7 2402 remove_fd_in_watch(chr);
76a9644b
AL		 2403 return FALSE;
2404 }
9894dc0c 2405 s->bufcnt = ret;
6f97dba0
AL		 2406
2407 s->bufptr = 0;
2408 while (s->max_size > 0 && s->bufptr < s->bufcnt) {
fa5efccb 2409 qemu_chr_be_write(chr, &s->buf[s->bufptr], 1);
6f97dba0 2410 s->bufptr++;
909cda12 2411 s->max_size = qemu_chr_be_can_write(chr);
6f97dba0 2412 }
76a9644b
AL		 2413
2414 return TRUE;
6f97dba0
AL		 2415}
2416
0ec7b3e7 2417static void udp_chr_update_read_handler(Chardev *chr,
a4afa548 2418 GMainContext *context)
6f97dba0 2419{
777357d7 2420 UdpChardev *s = UDP_CHARDEV(chr);
6f97dba0 2421
26da70c7 2422 remove_fd_in_watch(chr);
9894dc0c 2423 if (s->ioc) {
e93a68e1 2424 chr->fd_in_tag = io_add_watch_poll(chr, s->ioc,
9894dc0c 2425 udp_chr_read_poll,
e92aa36a
ZC		 2426 udp_chr_read, chr,
2427 context);
6f97dba0
AL		 2428 }
2429}
2430
819aad23 2431static void char_udp_finalize(Object *obj)
819f56b7 2432{
819aad23
MAL		 2433 Chardev *chr = CHARDEV(obj);
2434 UdpChardev *s = UDP_CHARDEV(obj);
26da70c7
AS		 2435
2436 remove_fd_in_watch(chr);
9894dc0c
DB		 2437 if (s->ioc) {
2438 object_unref(OBJECT(s->ioc));
819f56b7 2439 }
a425d23f 2440 qemu_chr_be_event(chr, CHR_EVENT_CLOSED);
819f56b7
AL		 2441}
2442
6f97dba0
AL		 2443/***********************************************************/
2444/* TCP Net console */
2445
2446typedef struct {
0ec7b3e7 2447 Chardev parent;
a8fb5427
DB		 2448 QIOChannel *ioc; /* Client I/O channel */
2449 QIOChannelSocket *sioc; /* Client master channel */
9894dc0c 2450 QIOChannelSocket *listen_ioc;
7ba9addc 2451 guint listen_tag;
a8fb5427 2452 QCryptoTLSCreds *tls_creds;
6f97dba0
AL		 2453 int connected;
2454 int max_size;
2455 int do_telnetopt;
2456 int do_nodelay;
2457 int is_unix;
c76bf6bb 2458 int *read_msgfds;
9894dc0c 2459 size_t read_msgfds_num;
d39aac7a 2460 int *write_msgfds;
9894dc0c 2461 size_t write_msgfds_num;
cfb429cb
CM		 2462
2463 SocketAddress *addr;
2464 bool is_listen;
2465 bool is_telnet;
5dd1f02b
CM		 2466
2467 guint reconnect_timer;
2468 int64_t reconnect_time;
5008e5b7 2469 bool connect_err_reported;
1876ed04 2470} SocketChardev;
6f97dba0 2471
777357d7
MAL		 2472#define SOCKET_CHARDEV(obj) \
2473 OBJECT_CHECK(SocketChardev, (obj), TYPE_CHARDEV_SOCKET)
2474
5dd1f02b
CM		 2475static gboolean socket_reconnect_timeout(gpointer opaque);
2476
0ec7b3e7 2477static void qemu_chr_socket_restart_timer(Chardev *chr)
5dd1f02b 2478{
777357d7 2479 SocketChardev *s = SOCKET_CHARDEV(chr);
e93a68e1 2480 char *name;
41ac54b2 2481
5dd1f02b
CM		 2482 assert(s->connected == 0);
2483 s->reconnect_timer = g_timeout_add_seconds(s->reconnect_time,
2484 socket_reconnect_timeout, chr);
e93a68e1
DB		 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);
5dd1f02b
CM		 2488}
2489
0ec7b3e7 2490static void check_report_connect_error(Chardev *chr,
5008e5b7
CM		 2491 Error *err)
2492{
777357d7 2493 SocketChardev *s = SOCKET_CHARDEV(chr);
5008e5b7
CM		 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
9894dc0c
DB		 2503static gboolean tcp_chr_accept(QIOChannel *chan,
2504 GIOCondition cond,
2505 void *opaque);
d39aac7a 2506
9005b2a7 2507/* Called with chr_write_lock held. */
0ec7b3e7 2508static int tcp_chr_write(Chardev *chr, const uint8_t *buf, int len)
6f97dba0 2509{
777357d7 2510 SocketChardev *s = SOCKET_CHARDEV(chr);
41ac54b2 2511
6f97dba0 2512 if (s->connected) {
9894dc0c
DB		 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;
d39aac7a 2522 }
9894dc0c
DB		 2523
2524 return ret;
455aa1e0 2525 } else {
6db0fdce 2526 /* XXX: indicate an error ? */
455aa1e0 2527 return len;
6f97dba0
AL		 2528 }
2529}
2530
2531static int tcp_chr_read_poll(void *opaque)
2532{
777357d7
MAL		 2533 Chardev *chr = CHARDEV(opaque);
2534 SocketChardev *s = SOCKET_CHARDEV(opaque);
6f97dba0
AL		 2535 if (!s->connected)
2536 return 0;
909cda12 2537 s->max_size = qemu_chr_be_can_write(chr);
6f97dba0
AL		 2538 return s->max_size;
2539}
2540
2541#define IAC 255
2542#define IAC_BREAK 243
0ec7b3e7 2543static void tcp_chr_process_IAC_bytes(Chardev *chr,
1876ed04 2544 SocketChardev *s,
6f97dba0
AL		 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 */
a425d23f 2570 qemu_chr_be_event(chr, CHR_EVENT_BREAK);
6f97dba0
AL		 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
0ec7b3e7 2591static int tcp_get_msgfds(Chardev *chr, int *fds, int num)
7d174059 2592{
777357d7 2593 SocketChardev *s = SOCKET_CHARDEV(chr);
41ac54b2 2594
c76bf6bb
NN		 2595 int to_copy = (s->read_msgfds_num < num) ? s->read_msgfds_num : num;
2596
c4095726
MT		 2597 assert(num <= TCP_MAX_FDS);
2598
c76bf6bb 2599 if (to_copy) {
d2fc39b4
SH		 2600 int i;
2601
c76bf6bb
NN		 2602 memcpy(fds, s->read_msgfds, to_copy * sizeof(int));
2603
d2fc39b4
SH		 2604 /* Close unused fds */
2605 for (i = to_copy; i < s->read_msgfds_num; i++) {
2606 close(s->read_msgfds[i]);
2607 }
2608
c76bf6bb
NN		 2609 g_free(s->read_msgfds);
2610 s->read_msgfds = 0;
2611 s->read_msgfds_num = 0;
2612 }
2613
2614 return to_copy;
7d174059
MM		 2615}
2616
0ec7b3e7 2617static int tcp_set_msgfds(Chardev *chr, int *fds, int num)
d39aac7a 2618{
777357d7 2619 SocketChardev *s = SOCKET_CHARDEV(chr);
d39aac7a
NN		 2620
2621 /* clear old pending fd array */
ef1e1e07 2622 g_free(s->write_msgfds);
869a58af 2623 s->write_msgfds = NULL;
5b498459 2624 s->write_msgfds_num = 0;
d39aac7a 2625
5c7eaabf
MAL		 2626 if (!s->connected ||
2627 !qio_channel_has_feature(s->ioc,
2628 QIO_CHANNEL_FEATURE_FD_PASS)) {
2629 return -1;
2630 }
2631
d39aac7a 2632 if (num) {
2d528d45 2633 s->write_msgfds = g_new(int, num);
d39aac7a
NN		 2634 memcpy(s->write_msgfds, fds, num * sizeof(int));
2635 }
2636
2637 s->write_msgfds_num = num;
2638
2639 return 0;
2640}
2641
0ec7b3e7 2642static ssize_t tcp_chr_recv(Chardev *chr, char *buf, size_t len)
7d174059 2643{
777357d7 2644 SocketChardev *s = SOCKET_CHARDEV(chr);
9894dc0c
DB		 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 }
7d174059 2660
b6572b4f
MAL		 2661 if (ret == QIO_CHANNEL_ERR_BLOCK) {
2662 errno = EAGAIN;
2663 ret = -1;
2664 } else if (ret == -1) {
2665 errno = EIO;
2666 }
2667
9894dc0c 2668 if (msgfds_num) {
c76bf6bb
NN		 2669 /* close and clean read_msgfds */
2670 for (i = 0; i < s->read_msgfds_num; i++) {
2671 close(s->read_msgfds[i]);
2672 }
9b938c72 2673
c76bf6bb
NN		 2674 if (s->read_msgfds_num) {
2675 g_free(s->read_msgfds);
2676 }
2677
9894dc0c
DB		 2678 s->read_msgfds = msgfds;
2679 s->read_msgfds_num = msgfds_num;
7d174059 2680 }
7d174059 2681
9894dc0c
DB		 2682 for (i = 0; i < s->read_msgfds_num; i++) {
2683 int fd = s->read_msgfds[i];
2684 if (fd < 0) {
2685 continue;
2686 }
9977c894 2687
9894dc0c
DB		 2688 /* O_NONBLOCK is preserved across SCM_RIGHTS so reset it */
2689 qemu_set_block(fd);
7d174059 2690
9894dc0c
DB		 2691#ifndef MSG_CMSG_CLOEXEC
2692 qemu_set_cloexec(fd);
06138651 2693#endif
06138651 2694 }
9977c894 2695
7d174059 2696 return ret;
9977c894 2697}
9977c894 2698
0ec7b3e7 2699static GSource *tcp_chr_add_watch(Chardev *chr, GIOCondition cond)
d3cc5bc4 2700{
777357d7 2701 SocketChardev *s = SOCKET_CHARDEV(chr);
9894dc0c 2702 return qio_channel_create_watch(s->ioc, cond);
d3cc5bc4
AS		 2703}
2704
0ec7b3e7 2705static void tcp_chr_free_connection(Chardev *chr)
7b0bfdf5 2706{
777357d7 2707 SocketChardev *s = SOCKET_CHARDEV(chr);
5b498459 2708 int i;
7b0bfdf5 2709
342f7a9d
MAL		 2710 if (!s->connected) {
2711 return;
2712 }
2713
5b498459
MAL		 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;
7b0bfdf5 2721 }
5b498459 2722
6167ebbd 2723 tcp_set_msgfds(chr, NULL, 0);
7b0bfdf5 2724 remove_fd_in_watch(chr);
a8fb5427
DB		 2725 object_unref(OBJECT(s->sioc));
2726 s->sioc = NULL;
9894dc0c
DB		 2727 object_unref(OBJECT(s->ioc));
2728 s->ioc = NULL;
0ff0fad2 2729 g_free(chr->filename);
5b498459
MAL		 2730 chr->filename = NULL;
2731 s->connected = 0;
2732}
2733
0ec7b3e7 2734static void tcp_chr_disconnect(Chardev *chr)
5b498459 2735{
777357d7 2736 SocketChardev *s = SOCKET_CHARDEV(chr);
5b498459
MAL		 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 }
0ff0fad2
DB		 2748 chr->filename = SocketAddress_to_str("disconnected:", s->addr,
2749 s->is_listen, s->is_telnet);
7b0bfdf5 2750 qemu_chr_be_event(chr, CHR_EVENT_CLOSED);
5dd1f02b
CM		 2751 if (s->reconnect_time) {
2752 qemu_chr_socket_restart_timer(chr);
2753 }
7b0bfdf5
NN		 2754}
2755
9894dc0c 2756static gboolean tcp_chr_read(QIOChannel *chan, GIOCondition cond, void *opaque)
6f97dba0 2757{
777357d7
MAL		 2758 Chardev *chr = CHARDEV(opaque);
2759 SocketChardev *s = SOCKET_CHARDEV(opaque);
f612143a 2760 uint8_t buf[CHR_READ_BUF_LEN];
6f97dba0
AL		 2761 int len, size;
2762
2ea5a7af 2763 if (!s->connected || s->max_size <= 0) {
cdbf6e16 2764 return TRUE;
2ea5a7af 2765 }
6f97dba0
AL		 2766 len = sizeof(buf);
2767 if (len > s->max_size)
2768 len = s->max_size;
9977c894 2769 size = tcp_chr_recv(chr, (void *)buf, len);
9894dc0c 2770 if (size == 0 || size == -1) {
6f97dba0 2771 /* connection closed */
7b0bfdf5 2772 tcp_chr_disconnect(chr);
6f97dba0
AL		 2773 } else if (size > 0) {
2774 if (s->do_telnetopt)
2775 tcp_chr_process_IAC_bytes(chr, s, buf, &size);
2776 if (size > 0)
fa5efccb 2777 qemu_chr_be_write(chr, buf, size);
6f97dba0 2778 }
2ea5a7af
AL		 2779
2780 return TRUE;
6f97dba0
AL		 2781}
2782
0ec7b3e7 2783static int tcp_chr_sync_read(Chardev *chr, const uint8_t *buf, int len)
7b0bfdf5 2784{
777357d7 2785 SocketChardev *s = SOCKET_CHARDEV(chr);
7b0bfdf5
NN		 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
6f97dba0
AL		 2801static void tcp_chr_connect(void *opaque)
2802{
777357d7
MAL		 2803 Chardev *chr = CHARDEV(opaque);
2804 SocketChardev *s = SOCKET_CHARDEV(opaque);
16cc4ffe 2805
0ff0fad2 2806 g_free(chr->filename);
a8fb5427
DB		 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);
6f97dba0
AL		 2811
2812 s->connected = 1;
9894dc0c 2813 if (s->ioc) {
e93a68e1 2814 chr->fd_in_tag = io_add_watch_poll(chr, s->ioc,
9894dc0c 2815 tcp_chr_read_poll,
e92aa36a
ZC		 2816 tcp_chr_read,
2817 chr, NULL);
bbdd2ad0 2818 }
fee204fd 2819 qemu_chr_be_generic_open(chr);
6f97dba0
AL		 2820}
2821
0ec7b3e7 2822static void tcp_chr_update_read_handler(Chardev *chr,
a4afa548 2823 GMainContext *context)
ac1b84dd 2824{
777357d7 2825 SocketChardev *s = SOCKET_CHARDEV(chr);
ac1b84dd 2826
1e94f23d
DB		 2827 if (!s->connected) {
2828 return;
2829 }
2830
ac1b84dd 2831 remove_fd_in_watch(chr);
9894dc0c 2832 if (s->ioc) {
e93a68e1 2833 chr->fd_in_tag = io_add_watch_poll(chr, s->ioc,
9894dc0c 2834 tcp_chr_read_poll,
e92aa36a
ZC		 2835 tcp_chr_read, chr,
2836 context);
ac1b84dd
GH		 2837 }
2838}
2839
f2001a7e 2840typedef struct {
0ec7b3e7 2841 Chardev *chr;
f2001a7e
DB		 2842 char buf[12];
2843 size_t buflen;
279b066e 2844} TCPChardevTelnetInit;
f2001a7e
DB		 2845
2846static gboolean tcp_chr_telnet_init_io(QIOChannel *ioc,
2847 GIOCondition cond G_GNUC_UNUSED,
2848 gpointer user_data)
6f97dba0 2849{
279b066e 2850 TCPChardevTelnetInit *init = user_data;
f2001a7e
DB		 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
0ec7b3e7 2874static void tcp_chr_telnet_init(Chardev *chr)
f2001a7e 2875{
777357d7 2876 SocketChardev *s = SOCKET_CHARDEV(chr);
279b066e 2877 TCPChardevTelnetInit *init = g_new0(TCPChardevTelnetInit, 1);
f2001a7e
DB		 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);
6f97dba0
AL		 2903}
2904
a8fb5427 2905
60e705c5 2906static void tcp_chr_tls_handshake(QIOTask *task,
a8fb5427
DB		 2907 gpointer user_data)
2908{
0ec7b3e7 2909 Chardev *chr = user_data;
1876ed04 2910 SocketChardev *s = user_data;
a8fb5427 2911
60e705c5 2912 if (qio_task_propagate_error(task, NULL)) {
a8fb5427
DB		 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
0ec7b3e7 2924static void tcp_chr_tls_init(Chardev *chr)
a8fb5427 2925{
777357d7 2926 SocketChardev *s = SOCKET_CHARDEV(chr);
a8fb5427
DB		 2927 QIOChannelTLS *tioc;
2928 Error *err = NULL;
e93a68e1 2929 gchar *name;
a8fb5427
DB		 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,
32bafa8f 2939 s->addr->u.inet.data->host,
a8fb5427
DB		 2940 &err);
2941 }
2942 if (tioc == NULL) {
2943 error_free(err);
2944 tcp_chr_disconnect(chr);
660a2d83 2945 return;
a8fb5427 2946 }
e93a68e1
DB		 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);
a8fb5427
DB		 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
0ec7b3e7 2962static void tcp_chr_set_client_ioc_name(Chardev *chr,
e93a68e1
DB		 2963 QIOChannelSocket *sioc)
2964{
777357d7 2965 SocketChardev *s = SOCKET_CHARDEV(chr);
e93a68e1
DB		 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
0ec7b3e7 2975static int tcp_chr_new_client(Chardev *chr, QIOChannelSocket *sioc)
13661089 2976{
777357d7 2977 SocketChardev *s = SOCKET_CHARDEV(chr);
41ac54b2 2978
9894dc0c 2979 if (s->ioc != NULL) {
13661089 2980 return -1;
9894dc0c 2981 }
13661089 2982
9894dc0c
DB		 2983 s->ioc = QIO_CHANNEL(sioc);
2984 object_ref(OBJECT(sioc));
a8fb5427
DB		 2985 s->sioc = sioc;
2986 object_ref(OBJECT(sioc));
9894dc0c 2987
64c800f8
DB		 2988 qio_channel_set_blocking(s->ioc, false, NULL);
2989
9894dc0c
DB		 2990 if (s->do_nodelay) {
2991 qio_channel_set_delay(s->ioc, false);
2992 }
910b6368
PB		 2993 if (s->listen_tag) {
2994 g_source_remove(s->listen_tag);
2995 s->listen_tag = 0;
2996 }
f2001a7e 2997
a8fb5427
DB		 2998 if (s->tls_creds) {
2999 tcp_chr_tls_init(chr);
f2001a7e 3000 } else {
a8fb5427
DB		 3001 if (s->do_telnetopt) {
3002 tcp_chr_telnet_init(chr);
3003 } else {
3004 tcp_chr_connect(chr);
3005 }
f2001a7e 3006 }
13661089
DB		 3007
3008 return 0;
3009}
3010
9894dc0c 3011
0ec7b3e7 3012static int tcp_chr_add_client(Chardev *chr, int fd)
9894dc0c
DB		 3013{
3014 int ret;
3015 QIOChannelSocket *sioc;
3016
3017 sioc = qio_channel_socket_new_fd(fd, NULL);
3018 if (!sioc) {
3019 return -1;
3020 }
e93a68e1 3021 tcp_chr_set_client_ioc_name(chr, sioc);
9894dc0c
DB		 3022 ret = tcp_chr_new_client(chr, sioc);
3023 object_unref(OBJECT(sioc));
3024 return ret;
3025}
3026
3027static gboolean tcp_chr_accept(QIOChannel *channel,
3028 GIOCondition cond,
3029 void *opaque)
6f97dba0 3030{
777357d7 3031 Chardev *chr = CHARDEV(opaque);
9894dc0c 3032 QIOChannelSocket *sioc;
6f97dba0 3033
9894dc0c
DB		 3034 sioc = qio_channel_socket_accept(QIO_CHANNEL_SOCKET(channel),
3035 NULL);
3036 if (!sioc) {
3037 return TRUE;
6f97dba0 3038 }
9894dc0c 3039
9894dc0c
DB		 3040 tcp_chr_new_client(chr, sioc);
3041
3042 object_unref(OBJECT(sioc));
2ea5a7af
AL		 3043
3044 return TRUE;
6f97dba0
AL		 3045}
3046
0ec7b3e7 3047static int tcp_chr_wait_connected(Chardev *chr, Error **errp)
d7a04fd7 3048{
777357d7 3049 SocketChardev *s = SOCKET_CHARDEV(chr);
d7a04fd7
MAL		 3050 QIOChannelSocket *sioc;
3051
1dc8a669
MAL		 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) {
d7a04fd7 3055 if (s->is_listen) {
776a32a0
MAL		 3056 error_report("QEMU waiting for connection on: %s",
3057 chr->filename);
d7a04fd7
MAL		 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();
e93a68e1 3063 tcp_chr_set_client_ioc_name(chr, sioc);
d7a04fd7
MAL		 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
0ec7b3e7 3076static int qemu_chr_wait_connected(Chardev *chr, Error **errp)
6b6723c3 3077{
777357d7
MAL		 3078 ChardevClass *cc = CHARDEV_GET_CLASS(chr);
3079
3080 if (cc->chr_wait_connected) {
3081 return cc->chr_wait_connected(chr, errp);
6b6723c3
MAL		 3082 }
3083
3084 return 0;
3085}
3086
5345fdb4
MAL		 3087int qemu_chr_fe_wait_connected(CharBackend *be, Error **errp)
3088{
fa394ed6
MAL		 3089 if (!be->chr) {
3090 error_setg(errp, "missing associated backend");
3091 return -1;
3092 }
3093
5345fdb4
MAL		 3094 return qemu_chr_wait_connected(be->chr, errp);
3095}
3096
2c3a5dcb 3097static void char_socket_finalize(Object *obj)
6f97dba0 3098{
2c3a5dcb
MAL		 3099 Chardev *chr = CHARDEV(obj);
3100 SocketChardev *s = SOCKET_CHARDEV(obj);
5b498459
MAL		 3101
3102 tcp_chr_free_connection(chr);
cfb429cb 3103
5dd1f02b
CM		 3104 if (s->reconnect_timer) {
3105 g_source_remove(s->reconnect_timer);
3106 s->reconnect_timer = 0;
3107 }
cfb429cb 3108 qapi_free_SocketAddress(s->addr);
9894dc0c
DB		 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));
819f56b7 3115 }
a8fb5427
DB		 3116 if (s->tls_creds) {
3117 object_unref(OBJECT(s->tls_creds));
3118 }
41ac54b2 3119
a425d23f 3120 qemu_chr_be_event(chr, CHR_EVENT_CLOSED);
6f97dba0
AL		 3121}
3122
43ded1a0 3123
60e705c5 3124static void qemu_chr_socket_connected(QIOTask *task, void *opaque)
5dd1f02b 3125{
60e705c5 3126 QIOChannelSocket *sioc = QIO_CHANNEL_SOCKET(qio_task_get_source(task));
777357d7
MAL		 3127 Chardev *chr = CHARDEV(opaque);
3128 SocketChardev *s = SOCKET_CHARDEV(chr);
60e705c5 3129 Error *err = NULL;
5dd1f02b 3130
60e705c5 3131 if (qio_task_propagate_error(task, &err)) {
5008e5b7 3132 check_report_connect_error(chr, err);
60e705c5
DB		 3133 error_free(err);
3134 goto cleanup;
5dd1f02b
CM		 3135 }
3136
5008e5b7 3137 s->connect_err_reported = false;
f50dfe45 3138 tcp_chr_new_client(chr, sioc);
60e705c5
DB		 3139
3140 cleanup:
f50dfe45 3141 object_unref(OBJECT(sioc));
5dd1f02b
CM		 3142}
3143
f6bd5d6e 3144
33521634 3145QemuOpts *qemu_chr_parse_compat(const char *label, const char *filename)
191bc01b 3146{
6ea314d9 3147 char host[65], port[33], width[8], height[8];
aeb2c47a 3148 int pos;
7d31544f 3149 const char *p;
191bc01b 3150 QemuOpts *opts;
8be7e7e4 3151 Error *local_err = NULL;
191bc01b 3152
8be7e7e4 3153 opts = qemu_opts_create(qemu_find_opts("chardev"), label, 1, &local_err);
84d18f06 3154 if (local_err) {
33394884 3155 error_report_err(local_err);
191bc01b 3156 return NULL;
8be7e7e4 3157 }
191bc01b 3158
7591c5c1
GH		 3159 if (strstart(filename, "mon:", &p)) {
3160 filename = p;
f43e47db 3161 qemu_opt_set(opts, "mux", "on", &error_abort);
02c4bdf1
PB		 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. */
f43e47db 3168 qemu_opt_set(opts, "signal", "off", &error_abort);
02c4bdf1 3169 }
7591c5c1
GH		 3170 }
3171
f0457e8d
GH		 3172 if (strcmp(filename, "null") == 0 ||
3173 strcmp(filename, "pty") == 0 ||
3174 strcmp(filename, "msmouse") == 0 ||
dc1c21e6 3175 strcmp(filename, "braille") == 0 ||
5692399f 3176 strcmp(filename, "testdev") == 0 ||
f0457e8d 3177 strcmp(filename, "stdio") == 0) {
f43e47db 3178 qemu_opt_set(opts, "backend", filename, &error_abort);
191bc01b
GH		 3179 return opts;
3180 }
6ea314d9 3181 if (strstart(filename, "vc", &p)) {
f43e47db 3182 qemu_opt_set(opts, "backend", "vc", &error_abort);
6ea314d9 3183 if (*p == ':') {
49aa4058 3184 if (sscanf(p+1, "%7[0-9]x%7[0-9]", width, height) == 2) {
6ea314d9 3185 /* pixels */
f43e47db
MA		 3186 qemu_opt_set(opts, "width", width, &error_abort);
3187 qemu_opt_set(opts, "height", height, &error_abort);
49aa4058 3188 } else if (sscanf(p+1, "%7[0-9]Cx%7[0-9]C", width, height) == 2) {
6ea314d9 3189 /* chars */
f43e47db
MA		 3190 qemu_opt_set(opts, "cols", width, &error_abort);
3191 qemu_opt_set(opts, "rows", height, &error_abort);
6ea314d9
GH		 3192 } else {
3193 goto fail;
3194 }
3195 }
3196 return opts;
3197 }
d6c983cd 3198 if (strcmp(filename, "con:") == 0) {
f43e47db 3199 qemu_opt_set(opts, "backend", "console", &error_abort);
d6c983cd
GH		 3200 return opts;
3201 }
48b76496 3202 if (strstart(filename, "COM", NULL)) {
f43e47db
MA		 3203 qemu_opt_set(opts, "backend", "serial", &error_abort);
3204 qemu_opt_set(opts, "path", filename, &error_abort);
48b76496
GH		 3205 return opts;
3206 }
7d31544f 3207 if (strstart(filename, "file:", &p)) {
f43e47db
MA		 3208 qemu_opt_set(opts, "backend", "file", &error_abort);
3209 qemu_opt_set(opts, "path", p, &error_abort);
7d31544f
GH		 3210 return opts;
3211 }
3212 if (strstart(filename, "pipe:", &p)) {
f43e47db
MA		 3213 qemu_opt_set(opts, "backend", "pipe", &error_abort);
3214 qemu_opt_set(opts, "path", p, &error_abort);
7d31544f
GH		 3215 return opts;
3216 }
aeb2c47a
GH		 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 }
f43e47db
MA		 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);
aeb2c47a 3227 if (p[pos] == ',') {
dc523cd3
MA		 3228 qemu_opts_do_parse(opts, p+pos+1, NULL, &local_err);
3229 if (local_err) {
3230 error_report_err(local_err);
aeb2c47a 3231 goto fail;
dc523cd3 3232 }
aeb2c47a
GH		 3233 }
3234 if (strstart(filename, "telnet:", &p))
f43e47db 3235 qemu_opt_set(opts, "telnet", "on", &error_abort);
aeb2c47a
GH		 3236 return opts;
3237 }
7e1b35b4 3238 if (strstart(filename, "udp:", &p)) {
f43e47db 3239 qemu_opt_set(opts, "backend", "udp", &error_abort);
7e1b35b4
GH		 3240 if (sscanf(p, "%64[^:]:%32[^@,]%n", host, port, &pos) < 2) {
3241 host[0] = 0;
39324ca4 3242 if (sscanf(p, ":%32[^@,]%n", port, &pos) < 1) {
7e1b35b4
GH		 3243 goto fail;
3244 }
3245 }
f43e47db
MA		 3246 qemu_opt_set(opts, "host", host, &error_abort);
3247 qemu_opt_set(opts, "port", port, &error_abort);
7e1b35b4
GH		 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) {
7e1b35b4
GH		 3253 goto fail;
3254 }
3255 }
f43e47db
MA		 3256 qemu_opt_set(opts, "localaddr", host, &error_abort);
3257 qemu_opt_set(opts, "localport", port, &error_abort);
7e1b35b4
GH		 3258 }
3259 return opts;
3260 }
aeb2c47a 3261 if (strstart(filename, "unix:", &p)) {
f43e47db 3262 qemu_opt_set(opts, "backend", "socket", &error_abort);
dc523cd3
MA		 3263 qemu_opts_do_parse(opts, p, "path", &local_err);
3264 if (local_err) {
3265 error_report_err(local_err);
aeb2c47a 3266 goto fail;
dc523cd3 3267 }
aeb2c47a
GH		 3268 return opts;
3269 }
48b76496
GH		 3270 if (strstart(filename, "/dev/parport", NULL) ||
3271 strstart(filename, "/dev/ppi", NULL)) {
f43e47db
MA		 3272 qemu_opt_set(opts, "backend", "parport", &error_abort);
3273 qemu_opt_set(opts, "path", filename, &error_abort);
48b76496
GH		 3274 return opts;
3275 }
3276 if (strstart(filename, "/dev/", NULL)) {
f43e47db
MA		 3277 qemu_opt_set(opts, "backend", "tty", &error_abort);
3278 qemu_opt_set(opts, "path", filename, &error_abort);
48b76496
GH		 3279 return opts;
3280 }
191bc01b 3281
aeb2c47a 3282fail:
191bc01b
GH		 3283 qemu_opts_del(opts);
3284 return NULL;
3285}
3286
21a933ea 3287void qemu_chr_parse_common(QemuOpts *opts, ChardevCommon *backend)
d0d7708b
DB		 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
846e2e49
GH		 3299static void qemu_chr_parse_file_out(QemuOpts *opts, ChardevBackend *backend,
3300 Error **errp)
3301{
3302 const char *path = qemu_opt_get(opts, "path");
f194a1ae 3303 ChardevFile *file;
846e2e49 3304
0b663b7d 3305 backend->type = CHARDEV_BACKEND_KIND_FILE;
846e2e49
GH		 3306 if (path == NULL) {
3307 error_setg(errp, "chardev: file: no filename given");
3308 return;
3309 }
32bafa8f 3310 file = backend->u.file.data = g_new0(ChardevFile, 1);
f194a1ae
EB		 3311 qemu_chr_parse_common(opts, qapi_ChardevFile_base(file));
3312 file->out = g_strdup(path);
31e38a22 3313
f194a1ae
EB		 3314 file->has_append = true;
3315 file->append = qemu_opt_get_bool(opts, "append", false);
846e2e49
GH		 3316}
3317
7c358031
GH		 3318static void qemu_chr_parse_stdio(QemuOpts *opts, ChardevBackend *backend,
3319 Error **errp)
3320{
f194a1ae
EB		 3321 ChardevStdio *stdio;
3322
0b663b7d 3323 backend->type = CHARDEV_BACKEND_KIND_STDIO;
32bafa8f 3324 stdio = backend->u.stdio.data = g_new0(ChardevStdio, 1);
f194a1ae
EB		 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);
7c358031
GH		 3328}
3329
777357d7
MAL		 3330static void char_stdio_class_init(ObjectClass *oc, void *data)
3331{
3332 ChardevClass *cc = CHARDEV_CLASS(oc);
3333
88cace9f 3334 cc->parse = qemu_chr_parse_stdio;
777357d7 3335 cc->open = qemu_chr_open_stdio;
b68e956a 3336#ifdef _WIN32
777357d7
MAL		 3337 cc->chr_write = win_stdio_write;
3338 cc->chr_set_echo = qemu_chr_set_echo_win_stdio;
b68e956a 3339#else
777357d7 3340 cc->chr_set_echo = qemu_chr_set_echo_stdio;
b68e956a 3341#endif
777357d7
MAL		 3342}
3343
3344static 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,
4d833ada 3350 .instance_finalize = char_stdio_finalize,
777357d7
MAL		 3351#endif
3352 .class_init = char_stdio_class_init,
b68e956a
MAL		 3353};
3354
6511d396 3355#ifdef HAVE_CHARDEV_SERIAL
0f1cb51d
GH		 3356static void qemu_chr_parse_serial(QemuOpts *opts, ChardevBackend *backend,
3357 Error **errp)
3358{
3359 const char *device = qemu_opt_get(opts, "path");
f194a1ae 3360 ChardevHostdev *serial;
0f1cb51d 3361
0b663b7d 3362 backend->type = CHARDEV_BACKEND_KIND_SERIAL;
0f1cb51d
GH		 3363 if (device == NULL) {
3364 error_setg(errp, "chardev: serial/tty: no device path given");
3365 return;
3366 }
32bafa8f 3367 serial = backend->u.serial.data = g_new0(ChardevHostdev, 1);
f194a1ae
EB		 3368 qemu_chr_parse_common(opts, qapi_ChardevHostdev_base(serial));
3369 serial->device = g_strdup(device);
0f1cb51d 3370}
6511d396 3371#endif
0f1cb51d 3372
38bfb1a6 3373#ifdef HAVE_CHARDEV_PARPORT
dc375097
GH		 3374static void qemu_chr_parse_parallel(QemuOpts *opts, ChardevBackend *backend,
3375 Error **errp)
3376{
3377 const char *device = qemu_opt_get(opts, "path");
f194a1ae 3378 ChardevHostdev *parallel;
dc375097 3379
0b663b7d 3380 backend->type = CHARDEV_BACKEND_KIND_PARALLEL;
dc375097
GH		 3381 if (device == NULL) {
3382 error_setg(errp, "chardev: parallel: no device path given");
3383 return;
3384 }
32bafa8f 3385 parallel = backend->u.parallel.data = g_new0(ChardevHostdev, 1);
f194a1ae
EB		 3386 qemu_chr_parse_common(opts, qapi_ChardevHostdev_base(parallel));
3387 parallel->device = g_strdup(device);
dc375097 3388}
38bfb1a6 3389#endif
dc375097 3390
548cbb36
GH		 3391static void qemu_chr_parse_pipe(QemuOpts *opts, ChardevBackend *backend,
3392 Error **errp)
3393{
3394 const char *device = qemu_opt_get(opts, "path");
f194a1ae 3395 ChardevHostdev *dev;
548cbb36 3396
0b663b7d 3397 backend->type = CHARDEV_BACKEND_KIND_PIPE;
548cbb36
GH		 3398 if (device == NULL) {
3399 error_setg(errp, "chardev: pipe: no device path given");
3400 return;
3401 }
32bafa8f 3402 dev = backend->u.pipe.data = g_new0(ChardevHostdev, 1);
f194a1ae
EB		 3403 qemu_chr_parse_common(opts, qapi_ChardevHostdev_base(dev));
3404 dev->device = g_strdup(device);
548cbb36
GH		 3405}
3406
777357d7
MAL		 3407static void char_pipe_class_init(ObjectClass *oc, void *data)
3408{
3409 ChardevClass *cc = CHARDEV_CLASS(oc);
3410
88cace9f 3411 cc->parse = qemu_chr_parse_pipe;
777357d7
MAL		 3412 cc->open = qemu_chr_open_pipe;
3413}
3414
3415static const TypeInfo char_pipe_type_info = {
3416 .name = TYPE_CHARDEV_PIPE,
b68e956a 3417#ifdef _WIN32
777357d7 3418 .parent = TYPE_CHARDEV_WIN,
b68e956a 3419#else
777357d7 3420 .parent = TYPE_CHARDEV_FD,
b68e956a 3421#endif
777357d7 3422 .class_init = char_pipe_class_init,
b68e956a
MAL		 3423};
3424
dafd325d
PM		 3425static 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);
5dd1f02b 3432 int64_t reconnect = qemu_opt_get_number(opts, "reconnect", 0);
dafd325d
PM		 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");
a8fb5427 3436 const char *tls_creds = qemu_opt_get(opts, "tls-creds");
dafd325d 3437 SocketAddress *addr;
f194a1ae 3438 ChardevSocket *sock;
dafd325d 3439
0b663b7d 3440 backend->type = CHARDEV_BACKEND_KIND_SOCKET;
dafd325d
PM		 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 }
a8fb5427
DB		 3450 } else {
3451 if (tls_creds) {
3452 error_setg(errp, "TLS can only be used over TCP socket");
3453 return;
3454 }
dafd325d
PM		 3455 }
3456
32bafa8f 3457 sock = backend->u.socket.data = g_new0(ChardevSocket, 1);
f194a1ae 3458 qemu_chr_parse_common(opts, qapi_ChardevSocket_base(sock));
dafd325d 3459
f194a1ae
EB		 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);
dafd325d
PM		 3471
3472 addr = g_new0(SocketAddress, 1);
3473 if (path) {
0399293e 3474 UnixSocketAddress *q_unix;
130257dc 3475 addr->type = SOCKET_ADDRESS_KIND_UNIX;
32bafa8f 3476 q_unix = addr->u.q_unix.data = g_new0(UnixSocketAddress, 1);
0399293e 3477 q_unix->path = g_strdup(path);
dafd325d 3478 } else {
130257dc 3479 addr->type = SOCKET_ADDRESS_KIND_INET;
32bafa8f
EB		 3480 addr->u.inet.data = g_new(InetSocketAddress, 1);
3481 *addr->u.inet.data = (InetSocketAddress) {
0399293e
EB		 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 };
dafd325d 3491 }
f194a1ae 3492 sock->addr = addr;
dafd325d
PM		 3493}
3494
90a14bfe
PM		 3495static 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;
f194a1ae 3504 ChardevUdp *udp;
90a14bfe 3505
0b663b7d 3506 backend->type = CHARDEV_BACKEND_KIND_UDP;
90a14bfe
PM		 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
32bafa8f 3525 udp = backend->u.udp.data = g_new0(ChardevUdp, 1);
f194a1ae 3526 qemu_chr_parse_common(opts, qapi_ChardevUdp_base(udp));
90a14bfe
PM		 3527
3528 addr = g_new0(SocketAddress, 1);
130257dc 3529 addr->type = SOCKET_ADDRESS_KIND_INET;
32bafa8f
EB		 3530 addr->u.inet.data = g_new(InetSocketAddress, 1);
3531 *addr->u.inet.data = (InetSocketAddress) {
0399293e
EB		 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 };
f194a1ae 3539 udp->remote = addr;
90a14bfe
PM		 3540
3541 if (has_local) {
f194a1ae 3542 udp->has_local = true;
90a14bfe 3543 addr = g_new0(SocketAddress, 1);
130257dc 3544 addr->type = SOCKET_ADDRESS_KIND_INET;
32bafa8f
EB		 3545 addr->u.inet.data = g_new(InetSocketAddress, 1);
3546 *addr->u.inet.data = (InetSocketAddress) {
0399293e
EB		 3547 .host = g_strdup(localaddr),
3548 .port = g_strdup(localport),
3549 };
f194a1ae 3550 udp->local = addr;
90a14bfe
PM		 3551 }
3552}
3553
88cace9f
MAL		 3554static 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 }
d654f34e 3567
88cace9f
MAL		 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
0b663b7d
MAL		 3583static 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
88cace9f
MAL		 3603static 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
3615typedef struct ChadevClassFE {
3616 void (*fn)(const char *name, void *opaque);
3617 void *opaque;
3618} ChadevClassFE;
3619
3620static void
3621chardev_class_foreach(ObjectClass *klass, void *opaque)
2c5f4882 3622{
88cace9f
MAL		 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
3633static void
3634chardev_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
3646static void
3647help_string_append(const char *name, void *opaque)
3648{
3649 GString *str = opaque;
3650
3651 g_string_append_printf(str, "\n%s", name);
2c5f4882
GH		 3652}
3653
0ec7b3e7
MAL		 3654Chardev *qemu_chr_new_from_opts(QemuOpts *opts,
3655 Error **errp)
191bc01b 3656{
0aff637e 3657 Error *local_err = NULL;
88cace9f 3658 const ChardevClass *cc;
0ec7b3e7 3659 Chardev *chr;
a1698bf1 3660 int i;
0b663b7d 3661 ChardevBackend *backend = NULL;
0b812f31 3662 const char *name = qemu_opt_get(opts, "backend");
a61ae7f8
PM		 3663 const char *id = qemu_opts_id(opts);
3664 char *bid = NULL;
191bc01b 3665
0b812f31 3666 if (name == NULL) {
312fd5f2 3667 error_setg(errp, "chardev: \"%s\" missing backend",
bd2d80b2 3668 qemu_opts_id(opts));
0b663b7d 3669 return NULL;
1bbd185f 3670 }
517b3d40 3671
0b812f31 3672 if (is_help_option(name)) {
776a32a0 3673 GString *str = g_string_new("");
88cace9f
MAL		 3674
3675 chardev_name_foreach(help_string_append, str);
776a32a0
MAL		 3676
3677 error_report("Available chardev backend types: %s", str->str);
3678 g_string_free(str, true);
0b812f31 3679 exit(0);
517b3d40
LM		 3680 }
3681
3682 if (id == NULL) {
3683 error_setg(errp, "chardev: no id specified");
0b663b7d 3684 return NULL;
517b3d40
LM		 3685 }
3686
88cace9f
MAL		 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;
191bc01b 3690 break;
d654f34e 3691 }
191bc01b 3692 }
88cace9f
MAL		 3693
3694 cc = char_get_class(name, errp);
3695 if (cc == NULL) {
0b663b7d 3696 return NULL;
191bc01b
GH		 3697 }
3698
a61ae7f8 3699 backend = g_new0(ChardevBackend, 1);
0b663b7d 3700 backend->type = CHARDEV_BACKEND_KIND_NULL;
edb2fb3c 3701
a61ae7f8
PM		 3702 if (qemu_opt_get_bool(opts, "mux", 0)) {
3703 bid = g_strdup_printf("%s-base", id);
3704 }
2c5f4882 3705
a61ae7f8 3706 chr = NULL;
88cace9f
MAL		 3707 if (cc->parse) {
3708 cc->parse(opts, backend, &local_err);
a61ae7f8
PM		 3709 if (local_err) {
3710 error_propagate(errp, local_err);
0b663b7d 3711 goto out;
2c5f4882 3712 }
d0d7708b 3713 } else {
88cace9f
MAL		 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 */
2c5f4882 3717 }
d0d7708b 3718
0b663b7d
MAL		 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;
191bc01b
GH		 3724 }
3725
a61ae7f8 3726 if (bid) {
0b663b7d 3727 Chardev *mux;
a61ae7f8 3728 qapi_free_ChardevBackend(backend);
a61ae7f8 3729 backend = g_new0(ChardevBackend, 1);
130257dc 3730 backend->type = CHARDEV_BACKEND_KIND_MUX;
0b663b7d 3731 backend->u.mux.data = g_new0(ChardevMux, 1);
32bafa8f 3732 backend->u.mux.data->chardev = g_strdup(bid);
0b663b7d
MAL		 3733 mux = qemu_chardev_add(id, TYPE_CHARDEV_MUX, backend, errp);
3734 if (mux == NULL) {
a61ae7f8
PM		 3735 qemu_chr_delete(chr);
3736 chr = NULL;
0b663b7d 3737 goto out;
a61ae7f8 3738 }
0b663b7d 3739 chr = mux;
bd5c51ee 3740 }
7591c5c1 3741
0b663b7d 3742out:
a61ae7f8 3743 qapi_free_ChardevBackend(backend);
a61ae7f8 3744 g_free(bid);
191bc01b
GH		 3745 return chr;
3746}
3747
0ec7b3e7 3748Chardev *qemu_chr_new_noreplay(const char *label, const char *filename)
6f97dba0
AL		 3749{
3750 const char *p;
0ec7b3e7 3751 Chardev *chr;
191bc01b 3752 QemuOpts *opts;
bd2d80b2 3753 Error *err = NULL;
191bc01b 3754
c845f401
GH		 3755 if (strstart(filename, "chardev:", &p)) {
3756 return qemu_chr_find(p);
3757 }
3758
191bc01b 3759 opts = qemu_chr_parse_compat(label, filename);
7e1b35b4
GH		 3760 if (!opts)
3761 return NULL;
6f97dba0 3762
b4948be9 3763 chr = qemu_chr_new_from_opts(opts, &err);
84d18f06 3764 if (err) {
565f65d2 3765 error_report_err(err);
bd2d80b2 3766 }
7e1b35b4
GH		 3767 if (chr && qemu_opt_get_bool(opts, "mux", 0)) {
3768 monitor_init(chr, MONITOR_USE_READLINE);
6f97dba0 3769 }
0a73336d 3770 qemu_opts_del(opts);
6f97dba0
AL		 3771 return chr;
3772}
3773
0ec7b3e7 3774Chardev *qemu_chr_new(const char *label, const char *filename)
33577b47 3775{
0ec7b3e7 3776 Chardev *chr;
b4948be9 3777 chr = qemu_chr_new_noreplay(label, filename);
33577b47 3778 if (chr) {
5ebd6703
MAL		 3779 if (replay_mode != REPLAY_MODE_NONE) {
3780 qemu_chr_set_feature(chr, QEMU_CHAR_FEATURE_REPLAY);
3781 }
777357d7 3782 if (qemu_chr_replay(chr) && CHARDEV_GET_CLASS(chr)->chr_ioctl) {
776a32a0
MAL		 3783 error_report("Replay: ioctl is not supported "
3784 "for serial devices yet");
33577b47
PD		 3785 }
3786 replay_register_char_driver(chr);
3787 }
3788 return chr;
3789}
3790
5345fdb4 3791void qemu_chr_fe_set_echo(CharBackend *be, bool echo)
c48855e1 3792{
0ec7b3e7 3793 Chardev *chr = be->chr;
5345fdb4 3794
777357d7
MAL		 3795 if (chr && CHARDEV_GET_CLASS(chr)->chr_set_echo) {
3796 CHARDEV_GET_CLASS(chr)->chr_set_echo(chr, echo);
c48855e1
PB		 3797 }
3798}
3799
5345fdb4 3800void qemu_chr_fe_set_open(CharBackend *be, int fe_open)
7c32c4fe 3801{
0ec7b3e7 3802 Chardev *chr = be->chr;
5345fdb4 3803
fa394ed6
MAL		 3804 if (!chr) {
3805 return;
3806 }
3807
830896af 3808 if (be->fe_open == fe_open) {
c0c4bd2c
HG		 3809 return;
3810 }
830896af 3811 be->fe_open = fe_open;
777357d7
MAL		 3812 if (CHARDEV_GET_CLASS(chr)->chr_set_fe_open) {
3813 CHARDEV_GET_CLASS(chr)->chr_set_fe_open(chr, fe_open);
7c32c4fe
HG		 3814 }
3815}
3816
5345fdb4 3817guint qemu_chr_fe_add_watch(CharBackend *be, GIOCondition cond,
6f1de6b7 3818 GIOFunc func, void *user_data)
23673ca7 3819{
0ec7b3e7 3820 Chardev *s = be->chr;
23673ca7
AL		 3821 GSource *src;
3822 guint tag;
3823
777357d7 3824 if (!s || CHARDEV_GET_CLASS(s)->chr_add_watch == NULL) {
6f1de6b7 3825 return 0;
23673ca7
AL		 3826 }
3827
777357d7 3828 src = CHARDEV_GET_CLASS(s)->chr_add_watch(s, cond);
62c339c5 3829 if (!src) {
6f1de6b7 3830 return 0;
62c339c5
PB		 3831 }
3832
23673ca7
AL		 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
5345fdb4 3840void qemu_chr_fe_disconnect(CharBackend *be)
7d9d17f7 3841{
0ec7b3e7 3842 Chardev *chr = be->chr;
5345fdb4 3843
777357d7
MAL		 3844 if (chr && CHARDEV_GET_CLASS(chr)->chr_disconnect) {
3845 CHARDEV_GET_CLASS(chr)->chr_disconnect(chr);
7d9d17f7
TM		 3846 }
3847}
3848
0ec7b3e7 3849void qemu_chr_delete(Chardev *chr)
1ad78ea5
MAL		 3850{
3851 QTAILQ_REMOVE(&chardevs, chr, next);
8cddc469 3852 object_unref(OBJECT(chr));
1ad78ea5
MAL		 3853}
3854
c5a415a0 3855ChardevInfoList *qmp_query_chardev(Error **errp)
6f97dba0 3856{
c5a415a0 3857 ChardevInfoList *chr_list = NULL;
0ec7b3e7 3858 Chardev *chr;
6f97dba0 3859
72cf2d4f 3860 QTAILQ_FOREACH(chr, &chardevs, next) {
c5a415a0
LC		 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);
830896af 3865 info->value->frontend_open = chr->be && chr->be->fe_open;
c5a415a0
LC		 3866
3867 info->next = chr_list;
3868 chr_list = info;
6f97dba0 3869 }
588b3832 3870
c5a415a0 3871 return chr_list;
6f97dba0 3872}
c845f401 3873
88cace9f
MAL		 3874static void
3875qmp_prepend_backend(const char *name, void *opaque)
0b812f31 3876{
88cace9f 3877 ChardevBackendInfoList **list = opaque;
0b812f31 3878 ChardevBackendInfoList *info = g_malloc0(sizeof(*info));
88cace9f 3879
0b812f31
MAL		 3880 info->value = g_malloc0(sizeof(*info->value));
3881 info->value->name = g_strdup(name);
88cace9f
MAL		 3882 info->next = *list;
3883 *list = info;
0b812f31
MAL		 3884}
3885
77d1c3c6
MK		 3886ChardevBackendInfoList *qmp_query_chardev_backends(Error **errp)
3887{
3888 ChardevBackendInfoList *backend_list = NULL;
a1698bf1 3889
88cace9f 3890 chardev_name_foreach(qmp_prepend_backend, &backend_list);
77d1c3c6
MK		 3891
3892 return backend_list;
3893}
3894
0ec7b3e7 3895Chardev *qemu_chr_find(const char *name)
c845f401 3896{
0ec7b3e7 3897 Chardev *chr;
c845f401 3898
72cf2d4f 3899 QTAILQ_FOREACH(chr, &chardevs, next) {
c845f401
GH		 3900 if (strcmp(chr->label, name) != 0)
3901 continue;
3902 return chr;
3903 }
3904 return NULL;
3905}
0beb4942 3906
4d454574
PB		 3907QemuOptsList 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,
5dd1f02b
CM		 3948 },{
3949 .name = "reconnect",
3950 .type = QEMU_OPT_NUMBER,
4d454574
PB		 3951 },{
3952 .name = "telnet",
3953 .type = QEMU_OPT_BOOL,
a8fb5427
DB		 3954 },{
3955 .name = "tls-creds",
3956 .type = QEMU_OPT_STRING,
4d454574
PB		 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,
51767e7c 3981 },{
3949e594 3982 .name = "size",
de1cc36e 3983 .type = QEMU_OPT_SIZE,
bb6fb7c0
GH		 3984 },{
3985 .name = "chardev",
3986 .type = QEMU_OPT_STRING,
31e38a22
OK		 3987 },{
3988 .name = "append",
3989 .type = QEMU_OPT_BOOL,
d0d7708b
DB		 3990 },{
3991 .name = "logfile",
3992 .type = QEMU_OPT_STRING,
3993 },{
3994 .name = "logappend",
3995 .type = QEMU_OPT_BOOL,
4d454574
PB		 3996 },
3997 { /* end of list */ }
3998 },
3999};
f1a1a356 4000
ffbdbe59
GH		 4001#ifdef _WIN32
4002
777357d7
MAL		 4003static void qmp_chardev_open_file(Chardev *chr,
4004 ChardevBackend *backend,
4005 bool *be_opened,
4006 Error **errp)
ffbdbe59 4007{
32bafa8f 4008 ChardevFile *file = backend->u.file.data;
ffbdbe59 4009 HANDLE out;
c025f689
SW		 4010 DWORD accessmode;
4011 DWORD flags;
ffbdbe59 4012
e859eda5 4013 if (file->has_in) {
ffbdbe59 4014 error_setg(errp, "input file not supported");
777357d7 4015 return;
ffbdbe59
GH		 4016 }
4017
c025f689
SW		 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);
ffbdbe59
GH		 4030 if (out == INVALID_HANDLE_VALUE) {
4031 error_setg(errp, "open %s failed", file->out);
777357d7 4032 return;
ffbdbe59 4033 }
777357d7
MAL		 4034
4035 qemu_chr_open_win_file(chr, out);
ffbdbe59
GH		 4036}
4037
777357d7
MAL		 4038static void qmp_chardev_open_serial(Chardev *chr,
4039 ChardevBackend *backend,
4040 bool *be_opened,
4041 Error **errp)
d59044ef 4042{
32bafa8f 4043 ChardevHostdev *serial = backend->u.serial.data;
acbfbe4a 4044
777357d7 4045 win_chr_init(chr, serial->device, errp);
d36b2b90
MA		 4046}
4047
ffbdbe59
GH		 4048#else /* WIN32 */
4049
4050static 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) {
20c39760 4057 error_setg_file_open(errp, errno, src);
ffbdbe59
GH		 4058 }
4059 return fd;
4060}
4061
777357d7
MAL		 4062static void qmp_chardev_open_file(Chardev *chr,
4063 ChardevBackend *backend,
4064 bool *be_opened,
4065 Error **errp)
ffbdbe59 4066{
32bafa8f 4067 ChardevFile *file = backend->u.file.data;
5f758366 4068 int flags, in = -1, out;
ffbdbe59 4069
31e38a22
OK		 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
ffbdbe59 4077 out = qmp_chardev_open_file_source(file->out, flags, errp);
5f758366 4078 if (out < 0) {
777357d7 4079 return;
ffbdbe59
GH		 4080 }
4081
e859eda5 4082 if (file->has_in) {
ffbdbe59
GH		 4083 flags = O_RDONLY;
4084 in = qmp_chardev_open_file_source(file->in, flags, errp);
5f758366 4085 if (in < 0) {
ffbdbe59 4086 qemu_close(out);
777357d7 4087 return;
ffbdbe59
GH		 4088 }
4089 }
4090
777357d7 4091 qemu_chr_open_fd(chr, in, out);
ffbdbe59
GH		 4092}
4093
d809ab95 4094#ifdef HAVE_CHARDEV_SERIAL
777357d7
MAL		 4095static void qmp_chardev_open_serial(Chardev *chr,
4096 ChardevBackend *backend,
4097 bool *be_opened,
4098 Error **errp)
d59044ef 4099{
32bafa8f 4100 ChardevHostdev *serial = backend->u.serial.data;
d36b2b90
MA		 4101 int fd;
4102
4103 fd = qmp_chardev_open_file_source(serial->device, O_RDWR, errp);
5f758366 4104 if (fd < 0) {
777357d7 4105 return;
39099991 4106 }
f9e8cacc 4107 qemu_set_nonblock(fd);
acbfbe4a 4108 tty_serial_init(fd, 115200, 'N', 8, 1);
b68e956a 4109
777357d7 4110 qemu_chr_open_fd(chr, fd, fd);
d36b2b90 4111}
6511d396 4112#endif
d36b2b90 4113
d809ab95 4114#ifdef HAVE_CHARDEV_PARPORT
777357d7
MAL		 4115static void qmp_chardev_open_parallel(Chardev *chr,
4116 ChardevBackend *backend,
4117 bool *be_opened,
4118 Error **errp)
d36b2b90 4119{
32bafa8f 4120 ChardevHostdev *parallel = backend->u.parallel.data;
d36b2b90
MA		 4121 int fd;
4122
4123 fd = qmp_chardev_open_file_source(parallel->device, O_RDWR, errp);
5f758366 4124 if (fd < 0) {
777357d7 4125 return;
d59044ef 4126 }
777357d7 4127 qemu_chr_open_pp_fd(chr, fd, be_opened, errp);
d59044ef 4128}
b68e956a 4129
777357d7
MAL		 4130static void char_parallel_class_init(ObjectClass *oc, void *data)
4131{
4132 ChardevClass *cc = CHARDEV_CLASS(oc);
4133
88cace9f 4134 cc->parse = qemu_chr_parse_parallel;
777357d7 4135 cc->open = qmp_chardev_open_parallel;
b68e956a 4136#if defined(__linux__)
777357d7 4137 cc->chr_ioctl = pp_ioctl;
b68e956a 4138#elif defined(__FreeBSD__) || defined(__FreeBSD_kernel__) || defined(__DragonFly__)
777357d7 4139 cc->chr_ioctl = pp_ioctl;
b68e956a 4140#endif
777357d7
MAL		 4141}
4142
c9305728
MAL		 4143static 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
777357d7
MAL		 4159static const TypeInfo char_parallel_type_info = {
4160 .name = TYPE_CHARDEV_PARALLEL,
4161 .parent = TYPE_CHARDEV,
4162 .instance_size = sizeof(ParallelChardev),
c9305728 4163 .instance_finalize = char_parallel_finalize,
777357d7 4164 .class_init = char_parallel_class_init,
b68e956a 4165};
d809ab95 4166#endif
d59044ef 4167
ffbdbe59
GH		 4168#endif /* WIN32 */
4169
777357d7
MAL		 4170static void char_file_class_init(ObjectClass *oc, void *data)
4171{
4172 ChardevClass *cc = CHARDEV_CLASS(oc);
4173
88cace9f 4174 cc->parse = qemu_chr_parse_file_out;
777357d7 4175 cc->open = qmp_chardev_open_file;
777357d7
MAL		 4176}
4177
4178static const TypeInfo char_file_type_info = {
4179 .name = TYPE_CHARDEV_FILE,
4180#ifdef _WIN32
4181 .parent = TYPE_CHARDEV_WIN,
b68e956a 4182#else
777357d7 4183 .parent = TYPE_CHARDEV_FD,
b68e956a 4184#endif
777357d7 4185 .class_init = char_file_class_init,
b68e956a
MAL		 4186};
4187
4188#ifdef HAVE_CHARDEV_SERIAL
777357d7 4189
777357d7
MAL		 4190static void char_serial_class_init(ObjectClass *oc, void *data)
4191{
4192 ChardevClass *cc = CHARDEV_CLASS(oc);
4193
88cace9f 4194 cc->parse = qemu_chr_parse_serial;
777357d7
MAL		 4195 cc->open = qmp_chardev_open_serial;
4196#ifndef _WIN32
4197 cc->chr_ioctl = tty_serial_ioctl;
777357d7
MAL		 4198#endif
4199}
4200
4201static const TypeInfo char_serial_type_info = {
4202 .name = TYPE_CHARDEV_SERIAL,
b68e956a 4203#ifdef _WIN32
777357d7 4204 .parent = TYPE_CHARDEV_WIN,
b68e956a 4205#else
777357d7 4206 .parent = TYPE_CHARDEV_FD,
b68e956a 4207#endif
777357d7 4208 .class_init = char_serial_class_init,
b68e956a
MAL		 4209};
4210#endif
4211
5dd1f02b
CM		 4212static gboolean socket_reconnect_timeout(gpointer opaque)
4213{
777357d7
MAL		 4214 Chardev *chr = CHARDEV(opaque);
4215 SocketChardev *s = SOCKET_CHARDEV(opaque);
317856ca 4216 QIOChannelSocket *sioc;
5dd1f02b
CM		 4217
4218 s->reconnect_timer = 0;
4219
4220 if (chr->be_open) {
4221 return false;
4222 }
4223
317856ca 4224 sioc = qio_channel_socket_new();
e93a68e1 4225 tcp_chr_set_client_ioc_name(chr, sioc);
317856ca
DB		 4226 qio_channel_socket_connect_async(sioc, s->addr,
4227 qemu_chr_socket_connected,
4228 chr, NULL);
5dd1f02b
CM		 4229
4230 return false;
4231}
4232
777357d7
MAL		 4233static void qmp_chardev_open_socket(Chardev *chr,
4234 ChardevBackend *backend,
4235 bool *be_opened,
4236 Error **errp)
f6bd5d6e 4237{
777357d7 4238 SocketChardev *s = SOCKET_CHARDEV(chr);
32bafa8f 4239 ChardevSocket *sock = backend->u.socket.data;
f6bd5d6e
GH		 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;
5dd1f02b 4245 int64_t reconnect = sock->has_reconnect ? sock->reconnect : 0;
317856ca 4246 QIOChannelSocket *sioc = NULL;
43ded1a0 4247
130257dc 4248 s->is_unix = addr->type == SOCKET_ADDRESS_KIND_UNIX;
cfb429cb
CM		 4249 s->is_listen = is_listen;
4250 s->is_telnet = is_telnet;
43ded1a0 4251 s->do_nodelay = do_nodelay;
a8fb5427
DB		 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
37f9e0a2 4285 s->addr = QAPI_CLONE(SocketAddress, sock->addr);
43ded1a0 4286
0a73336d
DB		 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
43ded1a0 4292 /* be isn't opened until we get a connection */
82878dac 4293 *be_opened = false;
43ded1a0 4294
0ff0fad2
DB		 4295 chr->filename = SocketAddress_to_str("disconnected:",
4296 addr, is_listen, is_telnet);
f6bd5d6e
GH		 4297
4298 if (is_listen) {
43ded1a0
CM		 4299 if (is_telnet) {
4300 s->do_telnetopt = 1;
4301 }
5dd1f02b
CM		 4302 } else if (reconnect > 0) {
4303 s->reconnect_time = reconnect;
f6bd5d6e 4304 }
43ded1a0 4305
5008e5b7 4306 if (s->reconnect_time) {
d7a04fd7 4307 sioc = qio_channel_socket_new();
e93a68e1 4308 tcp_chr_set_client_ioc_name(chr, sioc);
317856ca
DB		 4309 qio_channel_socket_connect_async(sioc, s->addr,
4310 qemu_chr_socket_connected,
4311 chr, NULL);
08b758b4 4312 } else {
d7a04fd7 4313 if (s->is_listen) {
e93a68e1 4314 char *name;
d7a04fd7 4315 sioc = qio_channel_socket_new();
e93a68e1
DB		 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
d7a04fd7
MAL		 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) {
2c3a5dcb 4327 return;
d7a04fd7
MAL		 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) {
08b758b4
DB		 4335 goto error;
4336 }
43ded1a0
CM		 4337 }
4338
777357d7 4339 return;
a8fb5427 4340
777357d7 4341error:
08b758b4
DB		 4342 if (sioc) {
4343 object_unref(OBJECT(sioc));
4344 }
f6bd5d6e
GH		 4345}
4346
777357d7
MAL		 4347static void char_socket_class_init(ObjectClass *oc, void *data)
4348{
4349 ChardevClass *cc = CHARDEV_CLASS(oc);
4350
88cace9f 4351 cc->parse = qemu_chr_parse_socket;
777357d7
MAL		 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;
777357d7
MAL		 4362}
4363
4364static const TypeInfo char_socket_type_info = {
4365 .name = TYPE_CHARDEV_SOCKET,
4366 .parent = TYPE_CHARDEV,
4367 .instance_size = sizeof(SocketChardev),
2c3a5dcb 4368 .instance_finalize = char_socket_finalize,
777357d7
MAL		 4369 .class_init = char_socket_class_init,
4370};
4371
4372static void qmp_chardev_open_udp(Chardev *chr,
4373 ChardevBackend *backend,
4374 bool *be_opened,
4375 Error **errp)
3ecc059d 4376{
32bafa8f 4377 ChardevUdp *udp = backend->u.udp.data;
9894dc0c 4378 QIOChannelSocket *sioc = qio_channel_socket_new();
e93a68e1 4379 char *name;
777357d7 4380 UdpChardev *s = UDP_CHARDEV(chr);
3ecc059d 4381
9894dc0c 4382 if (qio_channel_socket_dgram_sync(sioc,
150dcd1a 4383 udp->local, udp->remote,
9894dc0c
DB		 4384 errp) < 0) {
4385 object_unref(OBJECT(sioc));
777357d7 4386 return;
acbfbe4a 4387 }
e93a68e1
DB		 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
acbfbe4a 4393 s->ioc = QIO_CHANNEL(sioc);
acbfbe4a
MAL		 4394 /* be isn't opened until we get a connection */
4395 *be_opened = false;
3ecc059d
GH		 4396}
4397
777357d7
MAL		 4398static void char_udp_class_init(ObjectClass *oc, void *data)
4399{
4400 ChardevClass *cc = CHARDEV_CLASS(oc);
4401
88cace9f 4402 cc->parse = qemu_chr_parse_udp;
777357d7
MAL		 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;
777357d7
MAL		 4406}
4407
4408static const TypeInfo char_udp_type_info = {
4409 .name = TYPE_CHARDEV_UDP,
4410 .parent = TYPE_CHARDEV,
4411 .instance_size = sizeof(UdpChardev),
819aad23 4412 .instance_finalize = char_udp_finalize,
777357d7 4413 .class_init = char_udp_class_init,
b68e956a 4414};
0a73336d 4415
0ec7b3e7 4416bool qemu_chr_has_feature(Chardev *chr,
279b066e 4417 ChardevFeature feature)
0a73336d
DB		 4418{
4419 return test_bit(feature, chr->features);
4420}
4421
0ec7b3e7 4422void qemu_chr_set_feature(Chardev *chr,
279b066e 4423 ChardevFeature feature)
0a73336d
DB		 4424{
4425 return set_bit(feature, chr->features);
4426}
4427
777357d7
MAL		 4428Chardev *qemu_chardev_new(const char *id, const char *typename,
4429 ChardevBackend *backend, Error **errp)
f1a1a356 4430{
0ec7b3e7 4431 Chardev *chr = NULL;
eaeba653 4432 Error *local_err = NULL;
82878dac 4433 bool be_opened = true;
f1a1a356 4434
777357d7 4435 assert(g_str_has_prefix(typename, "chardev-"));
f1a1a356 4436
777357d7
MAL		 4437 chr = CHARDEV(object_new(typename));
4438 chr->label = g_strdup(id);
4ca17281 4439
777357d7 4440 qemu_char_open(chr, backend, &be_opened, &local_err);
a1698bf1
MAL		 4441 if (local_err) {
4442 error_propagate(errp, local_err);
777357d7
MAL		 4443 object_unref(OBJECT(chr));
4444 return NULL;
eaeba653
PB		 4445 }
4446
eaeba653 4447 if (!chr->filename) {
777357d7 4448 chr->filename = g_strdup(typename + 8);
f1a1a356 4449 }
82878dac 4450 if (be_opened) {
eaeba653
PB		 4451 qemu_chr_be_event(chr, CHR_EVENT_OPENED);
4452 }
777357d7
MAL		 4453
4454 return chr;
4455}
4456
4457ChardevReturn *qmp_chardev_add(const char *id, ChardevBackend *backend,
4458 Error **errp)
4459{
4460 const ChardevClass *cc;
4461 ChardevReturn *ret;
4462 Chardev *chr;
4463
777357d7
MAL		 4464 cc = char_get_class(ChardevBackendKind_lookup[backend->type], errp);
4465 if (!cc) {
4466 return NULL;
4467 }
4468
0b663b7d 4469 chr = qemu_chardev_add(id, object_class_get_name(OBJECT_CLASS(cc)),
777357d7
MAL		 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
eaeba653 4481 return ret;
f1a1a356
GH		 4482}
4483
4484void qmp_chardev_remove(const char *id, Error **errp)
4485{
0ec7b3e7 4486 Chardev *chr;
f1a1a356
GH		 4487
4488 chr = qemu_chr_find(id);
8108fd3e 4489 if (chr == NULL) {
f1a1a356
GH		 4490 error_setg(errp, "Chardev '%s' not found", id);
4491 return;
4492 }
a4afa548 4493 if (qemu_chr_is_busy(chr)) {
f1a1a356
GH		 4494 error_setg(errp, "Chardev '%s' is busy", id);
4495 return;
4496 }
5ebd6703 4497 if (qemu_chr_replay(chr)) {
33577b47
PD		 4498 error_setg(errp,
4499 "Chardev '%s' cannot be unplugged in record/replay mode", id);
4500 return;
4501 }
f1a1a356
GH		 4502 qemu_chr_delete(chr);
4503}
d654f34e 4504
aa5cb7f5 4505void qemu_chr_cleanup(void)
c1111a24 4506{
0ec7b3e7 4507 Chardev *chr, *tmp;
c1111a24
MAL		 4508
4509 QTAILQ_FOREACH_SAFE(chr, &chardevs, next, tmp) {
4510 qemu_chr_delete(chr);
4511 }
4512}
4513
d654f34e
AL		 4514static void register_types(void)
4515{
88cace9f
MAL		 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
88cace9f
MAL		 4523 type_register_static(&char_socket_type_info);
4524 type_register_static(&char_udp_type_info);
88cace9f
MAL		 4525 type_register_static(&char_file_type_info);
4526 type_register_static(&char_stdio_type_info);
b68e956a 4527#ifdef HAVE_CHARDEV_SERIAL
88cace9f 4528 type_register_static(&char_serial_type_info);
6511d396 4529#endif
38bfb1a6 4530#ifdef HAVE_CHARDEV_PARPORT
88cace9f 4531 type_register_static(&char_parallel_type_info);
38bfb1a6 4532#endif
c2e75a43 4533#ifdef HAVE_CHARDEV_PTY
88cace9f 4534 type_register_static(&char_pty_type_info);
c2e75a43 4535#endif
122e5ed4 4536#ifdef _WIN32
88cace9f 4537 type_register_static(&char_console_type_info);
122e5ed4 4538#endif
88cace9f 4539 type_register_static(&char_pipe_type_info);
0b812f31 4540
7b7ab18d
MR		 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);
d654f34e
AL		 4546}
4547
4548type_init(register_types);
QEMU mirror