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"
31*a00e37a4SAlex Bennée #include "qapi/qapi-commands-control.h"
32ffa0f7ebSPhilippe Mathieu-Daudé #include "chardev-internal.h"
33df85a78bSMarc-André Lureau
34df85a78bSMarc-André Lureau /* MUX driver for serial I/O splitting */
35df85a78bSMarc-André Lureau
365a1ee607SPaolo Bonzini /*
375a1ee607SPaolo Bonzini * Set to false by suspend_mux_open. Open events are delayed until
385a1ee607SPaolo Bonzini * resume_mux_open. Usually suspend_mux_open is called before
395a1ee607SPaolo Bonzini * command line processing and resume_mux_open afterwards.
405a1ee607SPaolo Bonzini */
415a1ee607SPaolo Bonzini static bool muxes_opened = true;
425a1ee607SPaolo Bonzini
43df85a78bSMarc-André Lureau /* Called with chr_write_lock held. */
mux_chr_write(Chardev * chr,const uint8_t * buf,int len)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 */
mux_print_help(Chardev * chr)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
mux_chr_send_event(MuxChardev * d,int mux_nr,QEMUChrEvent event)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
mux_chr_be_event(Chardev * chr,QEMUChrEvent event)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
mux_proc_byte(Chardev * chr,MuxChardev * d,int ch)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));
161*a00e37a4SAlex Bennée qmp_quit(NULL);
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
mux_chr_accept_input(Chardev * chr)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
mux_chr_can_read(void * opaque)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
mux_chr_read(void * opaque,const uint8_t * buf,int size)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
mux_chr_send_all_event(Chardev * chr,QEMUChrEvent event)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
2475a1ee607SPaolo 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
mux_chr_event(void * opaque,QEMUChrEvent event)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
mux_chr_add_watch(Chardev * s,GIOCondition cond)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
char_mux_finalize(Object * obj)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
mux_chr_update_read_handlers(Chardev * chr)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
mux_set_focus(Chardev * chr,int focus)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
qemu_chr_open_mux(Chardev * chr,ChardevBackend * backend,bool * be_opened,Error ** errp)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 */
3385a1ee607SPaolo Bonzini *be_opened = muxes_opened;
339df85a78bSMarc-André Lureau qemu_chr_fe_init(&d->chr, drv, errp);
340df85a78bSMarc-André Lureau }
341df85a78bSMarc-André Lureau
qemu_chr_parse_mux(QemuOpts * opts,ChardevBackend * backend,Error ** errp)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 */
open_muxes(Chardev * chr)3705a1ee607SPaolo 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);
3745a1ee607SPaolo 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;
3805a1ee607SPaolo Bonzini }
3815a1ee607SPaolo Bonzini
suspend_mux_open(void)3825a1ee607SPaolo Bonzini void suspend_mux_open(void)
3835a1ee607SPaolo Bonzini {
3845a1ee607SPaolo Bonzini muxes_opened = false;
3855a1ee607SPaolo Bonzini }
3865a1ee607SPaolo Bonzini
chardev_options_parsed_cb(Object * child,void * opaque)3875a1ee607SPaolo Bonzini static int chardev_options_parsed_cb(Object *child, void *opaque)
3885a1ee607SPaolo Bonzini {
3895a1ee607SPaolo Bonzini Chardev *chr = (Chardev *)child;
3905a1ee607SPaolo Bonzini
3915eed493dSMarc-André Lureau if (!chr->be_open && CHARDEV_IS_MUX(chr)) {
3925eed493dSMarc-André Lureau open_muxes(chr);
3935a1ee607SPaolo Bonzini }
394c7278b43SPeter Xu
395c7278b43SPeter Xu return 0;
396c7278b43SPeter Xu }
397c7278b43SPeter Xu
resume_mux_open(void)3985a1ee607SPaolo Bonzini void resume_mux_open(void)
3995a1ee607SPaolo Bonzini {
4005a1ee607SPaolo Bonzini muxes_opened = true;
4015a1ee607SPaolo Bonzini object_child_foreach(get_chardevs_root(),
4025a1ee607SPaolo Bonzini chardev_options_parsed_cb, NULL);
4035a1ee607SPaolo Bonzini }
4045a1ee607SPaolo Bonzini
char_mux_class_init(ObjectClass * oc,void * data)405df85a78bSMarc-André Lureau static void char_mux_class_init(ObjectClass *oc, void *data)
406df85a78bSMarc-André Lureau {
407df85a78bSMarc-André Lureau ChardevClass *cc = CHARDEV_CLASS(oc);
408df85a78bSMarc-André Lureau
409df85a78bSMarc-André Lureau cc->parse = qemu_chr_parse_mux;
410df85a78bSMarc-André Lureau cc->open = qemu_chr_open_mux;
411df85a78bSMarc-André Lureau cc->chr_write = mux_chr_write;
412df85a78bSMarc-André Lureau cc->chr_accept_input = mux_chr_accept_input;
413df85a78bSMarc-André Lureau cc->chr_add_watch = mux_chr_add_watch;
414d09c4a47SMarc-André Lureau cc->chr_be_event = mux_chr_be_event;
4153d9e2322SMarc-André Lureau cc->chr_update_read_handler = mux_chr_update_read_handlers;
416df85a78bSMarc-André Lureau }
417df85a78bSMarc-André Lureau
418df85a78bSMarc-André Lureau static const TypeInfo char_mux_type_info = {
419df85a78bSMarc-André Lureau .name = TYPE_CHARDEV_MUX,
420df85a78bSMarc-André Lureau .parent = TYPE_CHARDEV,
421df85a78bSMarc-André Lureau .class_init = char_mux_class_init,
422df85a78bSMarc-André Lureau .instance_size = sizeof(MuxChardev),
423df85a78bSMarc-André Lureau .instance_finalize = char_mux_finalize,
424df85a78bSMarc-André Lureau };
425df85a78bSMarc-André Lureau
register_types(void)426df85a78bSMarc-André Lureau static void register_types(void)
427df85a78bSMarc-André Lureau {
428df85a78bSMarc-André Lureau type_register_static(&char_mux_type_info);
429df85a78bSMarc-André Lureau }
430df85a78bSMarc-André Lureau
431df85a78bSMarc-André Lureau type_init(register_types);
432