1df85a78bSMarc-André Lureau /* 2df85a78bSMarc-André Lureau * QEMU System Emulator 3df85a78bSMarc-André Lureau * 4df85a78bSMarc-André Lureau * Copyright (c) 2003-2008 Fabrice Bellard 5df85a78bSMarc-André Lureau * 6df85a78bSMarc-André Lureau * Permission is hereby granted, free of charge, to any person obtaining a copy 7df85a78bSMarc-André Lureau * of this software and associated documentation files (the "Software"), to deal 8df85a78bSMarc-André Lureau * in the Software without restriction, including without limitation the rights 9df85a78bSMarc-André Lureau * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell 10df85a78bSMarc-André Lureau * copies of the Software, and to permit persons to whom the Software is 11df85a78bSMarc-André Lureau * furnished to do so, subject to the following conditions: 12df85a78bSMarc-André Lureau * 13df85a78bSMarc-André Lureau * The above copyright notice and this permission notice shall be included in 14df85a78bSMarc-André Lureau * all copies or substantial portions of the Software. 15df85a78bSMarc-André Lureau * 16df85a78bSMarc-André Lureau * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR 17df85a78bSMarc-André Lureau * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, 18df85a78bSMarc-André Lureau * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL 19df85a78bSMarc-André Lureau * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER 20df85a78bSMarc-André Lureau * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, 21df85a78bSMarc-André Lureau * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN 22df85a78bSMarc-André Lureau * THE SOFTWARE. 23df85a78bSMarc-André Lureau */ 24922a01a0SMarkus Armbruster 25df85a78bSMarc-André Lureau #include "qemu/osdep.h" 26df85a78bSMarc-André Lureau #include "qapi/error.h" 270b8fa32fSMarkus Armbruster #include "qemu/module.h" 28922a01a0SMarkus Armbruster #include "qemu/option.h" 298228e353SMarc-André Lureau #include "chardev/char.h" 30df85a78bSMarc-André Lureau #include "sysemu/block-backend.h" 31c7278b43SPeter Xu #include "sysemu/sysemu.h" 32ffa0f7ebSPhilippe Mathieu-Daudé #include "chardev-internal.h" 33df85a78bSMarc-André Lureau 34df85a78bSMarc-André Lureau /* MUX driver for serial I/O splitting */ 35df85a78bSMarc-André Lureau 36*5a1ee607SPaolo Bonzini /* 37*5a1ee607SPaolo Bonzini * Set to false by suspend_mux_open. Open events are delayed until 38*5a1ee607SPaolo Bonzini * resume_mux_open. Usually suspend_mux_open is called before 39*5a1ee607SPaolo Bonzini * command line processing and resume_mux_open afterwards. 40*5a1ee607SPaolo Bonzini */ 41*5a1ee607SPaolo Bonzini static bool muxes_opened = true; 42*5a1ee607SPaolo Bonzini 43df85a78bSMarc-André Lureau /* Called with chr_write_lock held. */ 44df85a78bSMarc-André Lureau static int mux_chr_write(Chardev *chr, const uint8_t *buf, int len) 45df85a78bSMarc-André Lureau { 46df85a78bSMarc-André Lureau MuxChardev *d = MUX_CHARDEV(chr); 47df85a78bSMarc-André Lureau int ret; 48df85a78bSMarc-André Lureau if (!d->timestamps) { 49df85a78bSMarc-André Lureau ret = qemu_chr_fe_write(&d->chr, buf, len); 50df85a78bSMarc-André Lureau } else { 51df85a78bSMarc-André Lureau int i; 52df85a78bSMarc-André Lureau 53df85a78bSMarc-André Lureau ret = 0; 54df85a78bSMarc-André Lureau for (i = 0; i < len; i++) { 55df85a78bSMarc-André Lureau if (d->linestart) { 56df85a78bSMarc-André Lureau char buf1[64]; 57df85a78bSMarc-André Lureau int64_t ti; 58df85a78bSMarc-André Lureau int secs; 59df85a78bSMarc-André Lureau 60df85a78bSMarc-André Lureau ti = qemu_clock_get_ms(QEMU_CLOCK_REALTIME); 61df85a78bSMarc-André Lureau if (d->timestamps_start == -1) { 62df85a78bSMarc-André Lureau d->timestamps_start = ti; 63df85a78bSMarc-André Lureau } 64df85a78bSMarc-André Lureau ti -= d->timestamps_start; 65df85a78bSMarc-André Lureau secs = ti / 1000; 66df85a78bSMarc-André Lureau snprintf(buf1, sizeof(buf1), 67df85a78bSMarc-André Lureau "[%02d:%02d:%02d.%03d] ", 68df85a78bSMarc-André Lureau secs / 3600, 69df85a78bSMarc-André Lureau (secs / 60) % 60, 70df85a78bSMarc-André Lureau secs % 60, 71df85a78bSMarc-André Lureau (int)(ti % 1000)); 72df85a78bSMarc-André Lureau /* XXX this blocks entire thread. Rewrite to use 73df85a78bSMarc-André Lureau * qemu_chr_fe_write and background I/O callbacks */ 74df85a78bSMarc-André Lureau qemu_chr_fe_write_all(&d->chr, 75df85a78bSMarc-André Lureau (uint8_t *)buf1, strlen(buf1)); 76df85a78bSMarc-André Lureau d->linestart = 0; 77df85a78bSMarc-André Lureau } 78df85a78bSMarc-André Lureau ret += qemu_chr_fe_write(&d->chr, buf + i, 1); 79df85a78bSMarc-André Lureau if (buf[i] == '\n') { 80df85a78bSMarc-André Lureau d->linestart = 1; 81df85a78bSMarc-André Lureau } 82df85a78bSMarc-André Lureau } 83df85a78bSMarc-André Lureau } 84df85a78bSMarc-André Lureau return ret; 85df85a78bSMarc-André Lureau } 86df85a78bSMarc-André Lureau 87df85a78bSMarc-André Lureau static const char * const mux_help[] = { 88df85a78bSMarc-André Lureau "% h print this help\n\r", 89df85a78bSMarc-André Lureau "% x exit emulator\n\r", 90df85a78bSMarc-André Lureau "% s save disk data back to file (if -snapshot)\n\r", 91df85a78bSMarc-André Lureau "% t toggle console timestamps\n\r", 92df85a78bSMarc-André Lureau "% b send break (magic sysrq)\n\r", 93df85a78bSMarc-André Lureau "% c switch between console and monitor\n\r", 94df85a78bSMarc-André Lureau "% % sends %\n\r", 95df85a78bSMarc-André Lureau NULL 96df85a78bSMarc-André Lureau }; 97df85a78bSMarc-André Lureau 98df85a78bSMarc-André Lureau int term_escape_char = 0x01; /* ctrl-a is used for escape */ 99df85a78bSMarc-André Lureau static void mux_print_help(Chardev *chr) 100df85a78bSMarc-André Lureau { 101df85a78bSMarc-André Lureau int i, j; 102df85a78bSMarc-André Lureau char ebuf[15] = "Escape-Char"; 103df85a78bSMarc-André Lureau char cbuf[50] = "\n\r"; 104df85a78bSMarc-André Lureau 105df85a78bSMarc-André Lureau if (term_escape_char > 0 && term_escape_char < 26) { 106df85a78bSMarc-André Lureau snprintf(cbuf, sizeof(cbuf), "\n\r"); 107df85a78bSMarc-André Lureau snprintf(ebuf, sizeof(ebuf), "C-%c", term_escape_char - 1 + 'a'); 108df85a78bSMarc-André Lureau } else { 109df85a78bSMarc-André Lureau snprintf(cbuf, sizeof(cbuf), 110df85a78bSMarc-André Lureau "\n\rEscape-Char set to Ascii: 0x%02x\n\r\n\r", 111df85a78bSMarc-André Lureau term_escape_char); 112df85a78bSMarc-André Lureau } 113df85a78bSMarc-André Lureau /* XXX this blocks entire thread. Rewrite to use 114df85a78bSMarc-André Lureau * qemu_chr_fe_write and background I/O callbacks */ 115df85a78bSMarc-André Lureau qemu_chr_write_all(chr, (uint8_t *)cbuf, strlen(cbuf)); 116df85a78bSMarc-André Lureau for (i = 0; mux_help[i] != NULL; i++) { 117df85a78bSMarc-André Lureau for (j = 0; mux_help[i][j] != '\0'; j++) { 118df85a78bSMarc-André Lureau if (mux_help[i][j] == '%') { 119df85a78bSMarc-André Lureau qemu_chr_write_all(chr, (uint8_t *)ebuf, strlen(ebuf)); 120df85a78bSMarc-André Lureau } else { 121df85a78bSMarc-André Lureau qemu_chr_write_all(chr, (uint8_t *)&mux_help[i][j], 1); 122df85a78bSMarc-André Lureau } 123df85a78bSMarc-André Lureau } 124df85a78bSMarc-André Lureau } 125df85a78bSMarc-André Lureau } 126df85a78bSMarc-André Lureau 1272fa9044aSPaolo Bonzini static void mux_chr_send_event(MuxChardev *d, int mux_nr, QEMUChrEvent event) 128df85a78bSMarc-André Lureau { 129df85a78bSMarc-André Lureau CharBackend *be = d->backends[mux_nr]; 130df85a78bSMarc-André Lureau 131df85a78bSMarc-André Lureau if (be && be->chr_event) { 132df85a78bSMarc-André Lureau be->chr_event(be->opaque, event); 133df85a78bSMarc-André Lureau } 134df85a78bSMarc-André Lureau } 135df85a78bSMarc-André Lureau 1362fa9044aSPaolo Bonzini static void mux_chr_be_event(Chardev *chr, QEMUChrEvent event) 137d09c4a47SMarc-André Lureau { 138d09c4a47SMarc-André Lureau MuxChardev *d = MUX_CHARDEV(chr); 139d09c4a47SMarc-André Lureau 140d09c4a47SMarc-André Lureau if (d->focus != -1) { 141d09c4a47SMarc-André Lureau mux_chr_send_event(d, d->focus, event); 142d09c4a47SMarc-André Lureau } 143d09c4a47SMarc-André Lureau } 144d09c4a47SMarc-André Lureau 145df85a78bSMarc-André Lureau static int mux_proc_byte(Chardev *chr, MuxChardev *d, int ch) 146df85a78bSMarc-André Lureau { 147df85a78bSMarc-André Lureau if (d->term_got_escape) { 148df85a78bSMarc-André Lureau d->term_got_escape = 0; 149df85a78bSMarc-André Lureau if (ch == term_escape_char) { 150df85a78bSMarc-André Lureau goto send_char; 151df85a78bSMarc-André Lureau } 152df85a78bSMarc-André Lureau switch (ch) { 153df85a78bSMarc-André Lureau case '?': 154df85a78bSMarc-André Lureau case 'h': 155df85a78bSMarc-André Lureau mux_print_help(chr); 156df85a78bSMarc-André Lureau break; 157df85a78bSMarc-André Lureau case 'x': 158df85a78bSMarc-André Lureau { 159df85a78bSMarc-André Lureau const char *term = "QEMU: Terminated\n\r"; 160df85a78bSMarc-André Lureau qemu_chr_write_all(chr, (uint8_t *)term, strlen(term)); 161df85a78bSMarc-André Lureau exit(0); 162df85a78bSMarc-André Lureau break; 163df85a78bSMarc-André Lureau } 164df85a78bSMarc-André Lureau case 's': 165df85a78bSMarc-André Lureau blk_commit_all(); 166df85a78bSMarc-André Lureau break; 167df85a78bSMarc-André Lureau case 'b': 168df85a78bSMarc-André Lureau qemu_chr_be_event(chr, CHR_EVENT_BREAK); 169df85a78bSMarc-André Lureau break; 170df85a78bSMarc-André Lureau case 'c': 171df85a78bSMarc-André Lureau assert(d->mux_cnt > 0); /* handler registered with first fe */ 172df85a78bSMarc-André Lureau /* Switch to the next registered device */ 173df85a78bSMarc-André Lureau mux_set_focus(chr, (d->focus + 1) % d->mux_cnt); 174df85a78bSMarc-André Lureau break; 175df85a78bSMarc-André Lureau case 't': 176df85a78bSMarc-André Lureau d->timestamps = !d->timestamps; 177df85a78bSMarc-André Lureau d->timestamps_start = -1; 178df85a78bSMarc-André Lureau d->linestart = 0; 179df85a78bSMarc-André Lureau break; 180df85a78bSMarc-André Lureau } 181df85a78bSMarc-André Lureau } else if (ch == term_escape_char) { 182df85a78bSMarc-André Lureau d->term_got_escape = 1; 183df85a78bSMarc-André Lureau } else { 184df85a78bSMarc-André Lureau send_char: 185df85a78bSMarc-André Lureau return 1; 186df85a78bSMarc-André Lureau } 187df85a78bSMarc-André Lureau return 0; 188df85a78bSMarc-André Lureau } 189df85a78bSMarc-André Lureau 190df85a78bSMarc-André Lureau static void mux_chr_accept_input(Chardev *chr) 191df85a78bSMarc-André Lureau { 192df85a78bSMarc-André Lureau MuxChardev *d = MUX_CHARDEV(chr); 193df85a78bSMarc-André Lureau int m = d->focus; 194df85a78bSMarc-André Lureau CharBackend *be = d->backends[m]; 195df85a78bSMarc-André Lureau 196df85a78bSMarc-André Lureau while (be && d->prod[m] != d->cons[m] && 197df85a78bSMarc-André Lureau be->chr_can_read && be->chr_can_read(be->opaque)) { 198df85a78bSMarc-André Lureau be->chr_read(be->opaque, 199df85a78bSMarc-André Lureau &d->buffer[m][d->cons[m]++ & MUX_BUFFER_MASK], 1); 200df85a78bSMarc-André Lureau } 201df85a78bSMarc-André Lureau } 202df85a78bSMarc-André Lureau 203df85a78bSMarc-André Lureau static int mux_chr_can_read(void *opaque) 204df85a78bSMarc-André Lureau { 205df85a78bSMarc-André Lureau MuxChardev *d = MUX_CHARDEV(opaque); 206df85a78bSMarc-André Lureau int m = d->focus; 207df85a78bSMarc-André Lureau CharBackend *be = d->backends[m]; 208df85a78bSMarc-André Lureau 209df85a78bSMarc-André Lureau if ((d->prod[m] - d->cons[m]) < MUX_BUFFER_SIZE) { 210df85a78bSMarc-André Lureau return 1; 211df85a78bSMarc-André Lureau } 212df85a78bSMarc-André Lureau 213df85a78bSMarc-André Lureau if (be && be->chr_can_read) { 214df85a78bSMarc-André Lureau return be->chr_can_read(be->opaque); 215df85a78bSMarc-André Lureau } 216df85a78bSMarc-André Lureau 217df85a78bSMarc-André Lureau return 0; 218df85a78bSMarc-André Lureau } 219df85a78bSMarc-André Lureau 220df85a78bSMarc-André Lureau static void mux_chr_read(void *opaque, const uint8_t *buf, int size) 221df85a78bSMarc-André Lureau { 222df85a78bSMarc-André Lureau Chardev *chr = CHARDEV(opaque); 223df85a78bSMarc-André Lureau MuxChardev *d = MUX_CHARDEV(opaque); 224df85a78bSMarc-André Lureau int m = d->focus; 225df85a78bSMarc-André Lureau CharBackend *be = d->backends[m]; 226df85a78bSMarc-André Lureau int i; 227df85a78bSMarc-André Lureau 228df85a78bSMarc-André Lureau mux_chr_accept_input(opaque); 229df85a78bSMarc-André Lureau 230df85a78bSMarc-André Lureau for (i = 0; i < size; i++) 231df85a78bSMarc-André Lureau if (mux_proc_byte(chr, d, buf[i])) { 232df85a78bSMarc-André Lureau if (d->prod[m] == d->cons[m] && 233df85a78bSMarc-André Lureau be && be->chr_can_read && 234df85a78bSMarc-André Lureau be->chr_can_read(be->opaque)) { 235df85a78bSMarc-André Lureau be->chr_read(be->opaque, &buf[i], 1); 236df85a78bSMarc-André Lureau } else { 237df85a78bSMarc-André Lureau d->buffer[m][d->prod[m]++ & MUX_BUFFER_MASK] = buf[i]; 238df85a78bSMarc-André Lureau } 239df85a78bSMarc-André Lureau } 240df85a78bSMarc-André Lureau } 241df85a78bSMarc-André Lureau 2422fa9044aSPaolo Bonzini void mux_chr_send_all_event(Chardev *chr, QEMUChrEvent event) 243df85a78bSMarc-André Lureau { 244bed3bb9bSMarc-André Lureau MuxChardev *d = MUX_CHARDEV(chr); 245df85a78bSMarc-André Lureau int i; 246df85a78bSMarc-André Lureau 247*5a1ee607SPaolo Bonzini if (!muxes_opened) { 248df85a78bSMarc-André Lureau return; 249df85a78bSMarc-André Lureau } 250df85a78bSMarc-André Lureau 251df85a78bSMarc-André Lureau /* Send the event to all registered listeners */ 252df85a78bSMarc-André Lureau for (i = 0; i < d->mux_cnt; i++) { 253df85a78bSMarc-André Lureau mux_chr_send_event(d, i, event); 254df85a78bSMarc-André Lureau } 255df85a78bSMarc-André Lureau } 256df85a78bSMarc-André Lureau 257083b266fSPhilippe Mathieu-Daudé static void mux_chr_event(void *opaque, QEMUChrEvent event) 258bed3bb9bSMarc-André Lureau { 259bed3bb9bSMarc-André Lureau mux_chr_send_all_event(CHARDEV(opaque), event); 260bed3bb9bSMarc-André Lureau } 261bed3bb9bSMarc-André Lureau 262df85a78bSMarc-André Lureau static GSource *mux_chr_add_watch(Chardev *s, GIOCondition cond) 263df85a78bSMarc-André Lureau { 264df85a78bSMarc-André Lureau MuxChardev *d = MUX_CHARDEV(s); 265df85a78bSMarc-André Lureau Chardev *chr = qemu_chr_fe_get_driver(&d->chr); 266df85a78bSMarc-André Lureau ChardevClass *cc = CHARDEV_GET_CLASS(chr); 267df85a78bSMarc-André Lureau 268df85a78bSMarc-André Lureau if (!cc->chr_add_watch) { 269df85a78bSMarc-André Lureau return NULL; 270df85a78bSMarc-André Lureau } 271df85a78bSMarc-André Lureau 272df85a78bSMarc-André Lureau return cc->chr_add_watch(chr, cond); 273df85a78bSMarc-André Lureau } 274df85a78bSMarc-André Lureau 275df85a78bSMarc-André Lureau static void char_mux_finalize(Object *obj) 276df85a78bSMarc-André Lureau { 277df85a78bSMarc-André Lureau MuxChardev *d = MUX_CHARDEV(obj); 278df85a78bSMarc-André Lureau int i; 279df85a78bSMarc-André Lureau 280df85a78bSMarc-André Lureau for (i = 0; i < d->mux_cnt; i++) { 281df85a78bSMarc-André Lureau CharBackend *be = d->backends[i]; 282df85a78bSMarc-André Lureau if (be) { 283df85a78bSMarc-André Lureau be->chr = NULL; 284df85a78bSMarc-André Lureau } 285df85a78bSMarc-André Lureau } 2861ce2610cSMarc-André Lureau qemu_chr_fe_deinit(&d->chr, false); 287df85a78bSMarc-André Lureau } 288df85a78bSMarc-André Lureau 2893d9e2322SMarc-André Lureau static void mux_chr_update_read_handlers(Chardev *chr) 290df85a78bSMarc-André Lureau { 291df85a78bSMarc-André Lureau MuxChardev *d = MUX_CHARDEV(chr); 292df85a78bSMarc-André Lureau 293df85a78bSMarc-André Lureau /* Fix up the real driver with mux routines */ 2947a9657efSArtem Pisarenko qemu_chr_fe_set_handlers_full(&d->chr, 295df85a78bSMarc-André Lureau mux_chr_can_read, 296df85a78bSMarc-André Lureau mux_chr_read, 297df85a78bSMarc-André Lureau mux_chr_event, 29881517ba3SAnton Nefedov NULL, 299df85a78bSMarc-André Lureau chr, 3003d9e2322SMarc-André Lureau chr->gcontext, true, false); 301df85a78bSMarc-André Lureau } 302df85a78bSMarc-André Lureau 303df85a78bSMarc-André Lureau void mux_set_focus(Chardev *chr, int focus) 304df85a78bSMarc-André Lureau { 305df85a78bSMarc-André Lureau MuxChardev *d = MUX_CHARDEV(chr); 306df85a78bSMarc-André Lureau 307df85a78bSMarc-André Lureau assert(focus >= 0); 308df85a78bSMarc-André Lureau assert(focus < d->mux_cnt); 309df85a78bSMarc-André Lureau 310df85a78bSMarc-André Lureau if (d->focus != -1) { 311df85a78bSMarc-André Lureau mux_chr_send_event(d, d->focus, CHR_EVENT_MUX_OUT); 312df85a78bSMarc-André Lureau } 313df85a78bSMarc-André Lureau 314df85a78bSMarc-André Lureau d->focus = focus; 315eeaa6715SMarc-André Lureau chr->be = d->backends[focus]; 316df85a78bSMarc-André Lureau mux_chr_send_event(d, d->focus, CHR_EVENT_MUX_IN); 317df85a78bSMarc-André Lureau } 318df85a78bSMarc-André Lureau 319df85a78bSMarc-André Lureau static void qemu_chr_open_mux(Chardev *chr, 320df85a78bSMarc-André Lureau ChardevBackend *backend, 321df85a78bSMarc-André Lureau bool *be_opened, 322df85a78bSMarc-André Lureau Error **errp) 323df85a78bSMarc-André Lureau { 324df85a78bSMarc-André Lureau ChardevMux *mux = backend->u.mux.data; 325df85a78bSMarc-André Lureau Chardev *drv; 326df85a78bSMarc-André Lureau MuxChardev *d = MUX_CHARDEV(chr); 327df85a78bSMarc-André Lureau 328df85a78bSMarc-André Lureau drv = qemu_chr_find(mux->chardev); 329df85a78bSMarc-André Lureau if (drv == NULL) { 330df85a78bSMarc-André Lureau error_setg(errp, "mux: base chardev %s not found", mux->chardev); 331df85a78bSMarc-André Lureau return; 332df85a78bSMarc-André Lureau } 333df85a78bSMarc-André Lureau 334df85a78bSMarc-André Lureau d->focus = -1; 335df85a78bSMarc-André Lureau /* only default to opened state if we've realized the initial 336df85a78bSMarc-André Lureau * set of muxes 337df85a78bSMarc-André Lureau */ 338*5a1ee607SPaolo Bonzini *be_opened = muxes_opened; 339df85a78bSMarc-André Lureau qemu_chr_fe_init(&d->chr, drv, errp); 340df85a78bSMarc-André Lureau } 341df85a78bSMarc-André Lureau 342df85a78bSMarc-André Lureau static void qemu_chr_parse_mux(QemuOpts *opts, ChardevBackend *backend, 343df85a78bSMarc-André Lureau Error **errp) 344df85a78bSMarc-André Lureau { 345df85a78bSMarc-André Lureau const char *chardev = qemu_opt_get(opts, "chardev"); 346df85a78bSMarc-André Lureau ChardevMux *mux; 347df85a78bSMarc-André Lureau 348df85a78bSMarc-André Lureau if (chardev == NULL) { 349df85a78bSMarc-André Lureau error_setg(errp, "chardev: mux: no chardev given"); 350df85a78bSMarc-André Lureau return; 351df85a78bSMarc-André Lureau } 352df85a78bSMarc-André Lureau backend->type = CHARDEV_BACKEND_KIND_MUX; 353df85a78bSMarc-André Lureau mux = backend->u.mux.data = g_new0(ChardevMux, 1); 354df85a78bSMarc-André Lureau qemu_chr_parse_common(opts, qapi_ChardevMux_base(mux)); 355df85a78bSMarc-André Lureau mux->chardev = g_strdup(chardev); 356df85a78bSMarc-André Lureau } 357df85a78bSMarc-André Lureau 358c7278b43SPeter Xu /** 359c7278b43SPeter Xu * Called after processing of default and command-line-specified 360c7278b43SPeter Xu * chardevs to deliver CHR_EVENT_OPENED events to any FEs attached 361c7278b43SPeter Xu * to a mux chardev. This is done here to ensure that 362c7278b43SPeter Xu * output/prompts/banners are only displayed for the FE that has 363c7278b43SPeter Xu * focus when initial command-line processing/machine init is 364c7278b43SPeter Xu * completed. 365c7278b43SPeter Xu * 366c7278b43SPeter Xu * After this point, any new FE attached to any new or existing 367c7278b43SPeter Xu * mux will receive CHR_EVENT_OPENED notifications for the BE 368c7278b43SPeter Xu * immediately. 369c7278b43SPeter Xu */ 370*5a1ee607SPaolo Bonzini static void open_muxes(Chardev *chr) 371c7278b43SPeter Xu { 372c7278b43SPeter Xu /* send OPENED to all already-attached FEs */ 373c7278b43SPeter Xu mux_chr_send_all_event(chr, CHR_EVENT_OPENED); 374*5a1ee607SPaolo Bonzini 375c7278b43SPeter Xu /* 376c7278b43SPeter Xu * mark mux as OPENED so any new FEs will immediately receive 377c7278b43SPeter Xu * OPENED event 378c7278b43SPeter Xu */ 3797a9657efSArtem Pisarenko chr->be_open = 1; 380*5a1ee607SPaolo Bonzini } 381*5a1ee607SPaolo Bonzini 382*5a1ee607SPaolo Bonzini void suspend_mux_open(void) 383*5a1ee607SPaolo Bonzini { 384*5a1ee607SPaolo Bonzini muxes_opened = false; 385*5a1ee607SPaolo Bonzini } 386*5a1ee607SPaolo Bonzini 387*5a1ee607SPaolo Bonzini static int chardev_options_parsed_cb(Object *child, void *opaque) 388*5a1ee607SPaolo Bonzini { 389*5a1ee607SPaolo Bonzini Chardev *chr = (Chardev *)child; 390*5a1ee607SPaolo Bonzini ChardevClass *class = CHARDEV_GET_CLASS(chr); 391*5a1ee607SPaolo Bonzini 392*5a1ee607SPaolo Bonzini if (!chr->be_open && class->chr_options_parsed) { 393*5a1ee607SPaolo Bonzini class->chr_options_parsed(chr); 394*5a1ee607SPaolo Bonzini } 395c7278b43SPeter Xu 396c7278b43SPeter Xu return 0; 397c7278b43SPeter Xu } 398c7278b43SPeter Xu 399*5a1ee607SPaolo Bonzini void resume_mux_open(void) 400*5a1ee607SPaolo Bonzini { 401*5a1ee607SPaolo Bonzini muxes_opened = true; 402*5a1ee607SPaolo Bonzini object_child_foreach(get_chardevs_root(), 403*5a1ee607SPaolo Bonzini chardev_options_parsed_cb, NULL); 404*5a1ee607SPaolo Bonzini } 405*5a1ee607SPaolo Bonzini 406df85a78bSMarc-André Lureau static void char_mux_class_init(ObjectClass *oc, void *data) 407df85a78bSMarc-André Lureau { 408df85a78bSMarc-André Lureau ChardevClass *cc = CHARDEV_CLASS(oc); 409df85a78bSMarc-André Lureau 410df85a78bSMarc-André Lureau cc->parse = qemu_chr_parse_mux; 411df85a78bSMarc-André Lureau cc->open = qemu_chr_open_mux; 412df85a78bSMarc-André Lureau cc->chr_write = mux_chr_write; 413df85a78bSMarc-André Lureau cc->chr_accept_input = mux_chr_accept_input; 414df85a78bSMarc-André Lureau cc->chr_add_watch = mux_chr_add_watch; 415d09c4a47SMarc-André Lureau cc->chr_be_event = mux_chr_be_event; 416*5a1ee607SPaolo Bonzini cc->chr_options_parsed = open_muxes; 4173d9e2322SMarc-André Lureau cc->chr_update_read_handler = mux_chr_update_read_handlers; 418df85a78bSMarc-André Lureau } 419df85a78bSMarc-André Lureau 420df85a78bSMarc-André Lureau static const TypeInfo char_mux_type_info = { 421df85a78bSMarc-André Lureau .name = TYPE_CHARDEV_MUX, 422df85a78bSMarc-André Lureau .parent = TYPE_CHARDEV, 423df85a78bSMarc-André Lureau .class_init = char_mux_class_init, 424df85a78bSMarc-André Lureau .instance_size = sizeof(MuxChardev), 425df85a78bSMarc-André Lureau .instance_finalize = char_mux_finalize, 426df85a78bSMarc-André Lureau }; 427df85a78bSMarc-André Lureau 428df85a78bSMarc-André Lureau static void register_types(void) 429df85a78bSMarc-André Lureau { 430df85a78bSMarc-André Lureau type_register_static(&char_mux_type_info); 431df85a78bSMarc-André Lureau } 432df85a78bSMarc-André Lureau 433df85a78bSMarc-André Lureau type_init(register_types); 434