}
}
-static void baum_chr_open(Chardev *chr,
- ChardevBackend *backend,
- bool *be_opened,
- Error **errp)
+static void baum_chr_open(Chardev *chr, ChardevBackend *backend, Error **errp)
{
BaumChardev *baum = BAUM_CHARDEV(chr);
brlapi_handle_t *handle;
* as an integer, but in practice it seems to work
*/
qemu_set_fd_handler(baum->brlapi_fd, baum_chr_read, NULL, baum);
+
+ qemu_chr_be_event(chr, CHR_EVENT_OPENED);
}
static void char_braille_class_init(ObjectClass *oc, const void *data)
#include "chardev/char-win.h"
#include "qemu/module.h"
-static void console_chr_open(Chardev *chr,
- ChardevBackend *backend,
- bool *be_opened,
+static void console_chr_open(Chardev *chr, ChardevBackend *backend,
Error **errp)
{
win_chr_set_file(chr, GetStdHandle(STD_OUTPUT_HANDLE), true);
+ qemu_chr_be_event(chr, CHR_EVENT_OPENED);
}
static void char_console_class_init(ObjectClass *oc, const void *data)
#include "chardev/char-fd.h"
#endif
-static void file_chr_open(Chardev *chr,
- ChardevBackend *backend,
- bool *be_opened,
- Error **errp)
+static void file_chr_open(Chardev *chr, ChardevBackend *backend, Error **errp)
{
ChardevFile *file = backend->u.file.data;
#ifdef _WIN32
return;
}
#endif
+
+ qemu_chr_be_event(chr, CHR_EVENT_OPENED);
}
static void file_chr_parse(QemuOpts *opts, ChardevBackend *backend,
}
}
-static void hub_chr_open(Chardev *chr,
- ChardevBackend *backend,
- bool *be_opened,
- Error **errp)
+static void hub_chr_open(Chardev *chr, ChardevBackend *backend, Error **errp)
{
ChardevHub *hub = backend->u.hub.data;
HubChardev *d = HUB_CHARDEV(chr);
list = list->next;
}
- /* Closed until an explicit event from backend */
- *be_opened = false;
+ /*
+ * Closed until an explicit event from backend, so we don't
+ * send CHR_EVENT_OPENED now.
+ */
}
static void hub_chr_parse(QemuOpts *opts, ChardevBackend *backend, Error **errp)
mux_chr_send_event(d, d->focus, CHR_EVENT_MUX_IN);
}
-static void mux_chr_open(Chardev *chr,
- ChardevBackend *backend,
- bool *be_opened,
- Error **errp)
+static void mux_chr_open(Chardev *chr, ChardevBackend *backend, Error **errp)
{
ChardevMux *mux = backend->u.mux.data;
Chardev *drv;
}
d->focus = -1;
- /* only default to opened state if we've realized the initial
- * set of muxes
+ if (!qemu_chr_fe_init(&d->chr, drv, errp)) {
+ return;
+ }
+
+ /*
+ * Only move to opened state if we've realized
+ * the initial set of muxes:
*/
- *be_opened = muxes_opened;
- qemu_chr_fe_init(&d->chr, drv, errp);
+ if (muxes_opened) {
+ qemu_chr_be_event(chr, CHR_EVENT_OPENED);
+ }
}
static void mux_chr_parse(QemuOpts *opts, ChardevBackend *backend, Error **errp)
#include "chardev/char.h"
#include "qemu/module.h"
-static void null_chr_open(Chardev *chr,
- ChardevBackend *backend,
- bool *be_opened,
- Error **errp)
+static void null_chr_open(Chardev *chr, ChardevBackend *backend, Error **errp)
{
- *be_opened = false;
+ /* do not send CHR_EVENT_OPENED */
}
static void char_null_class_init(ObjectClass *oc, const void *data)
return 0;
}
-static void parallel_chr_open_fd(Chardev *chr,
- int fd,
- bool *be_opened,
- Error **errp)
+static void parallel_chr_open_fd(Chardev *chr, int fd, Error **errp)
{
ParallelChardev *drv = PARALLEL_CHARDEV(chr);
}
drv->mode = IEEE1284_MODE_COMPAT;
+ qemu_chr_be_event(chr, CHR_EVENT_OPENED);
}
#endif /* __linux__ */
return 0;
}
-static void parallel_chr_open_fd(Chardev *chr,
- int fd,
- bool *be_opened,
- Error **errp)
+static void parallel_chr_open_fd(Chardev *chr, int fd, Error **errp)
{
ParallelChardev *drv = PARALLEL_CHARDEV(chr);
drv->fd = fd;
- *be_opened = false;
}
#endif
#ifdef HAVE_CHARDEV_PARALLEL
static void parallel_chr_open(Chardev *chr,
ChardevBackend *backend,
- bool *be_opened,
Error **errp)
{
ChardevHostdev *parallel = backend->u.parallel.data;
if (fd < 0) {
return;
}
- parallel_chr_open_fd(chr, fd, be_opened, errp);
+ parallel_chr_open_fd(chr, fd, errp);
}
static void parallel_chr_parse(QemuOpts *opts, ChardevBackend *backend,
return -1;
}
-static void pipe_chr_open(Chardev *chr,
- ChardevBackend *backend,
- bool *be_opened,
- Error **errp)
+static void pipe_chr_open(Chardev *chr, ChardevBackend *backend, Error **errp)
{
ChardevHostdev *opts = backend->u.pipe.data;
const char *filename = opts->device;
if (win_chr_pipe_init(chr, filename, errp) < 0) {
return;
}
+
+ qemu_chr_be_event(chr, CHR_EVENT_OPENED);
}
#else
-static void pipe_chr_open(Chardev *chr,
- ChardevBackend *backend,
- bool *be_opened,
- Error **errp)
+static void pipe_chr_open(Chardev *chr, ChardevBackend *backend, Error **errp)
{
ChardevHostdev *opts = backend->u.pipe.data;
int fd_in, fd_out;
}
return;
}
+
+ qemu_chr_be_event(chr, CHR_EVENT_OPENED);
}
#endif /* !_WIN32 */
return amaster;
}
-static void pty_chr_open(Chardev *chr,
- ChardevBackend *backend,
- bool *be_opened,
- Error **errp)
+static void pty_chr_open(Chardev *chr, ChardevBackend *backend, Error **errp)
{
PtyChardev *s;
int master_fd, slave_fd;
qio_channel_set_name(s->ioc, name);
g_free(name);
s->timer_src = NULL;
- *be_opened = false;
/* create symbolic link */
if (path) {
static void ringbuf_chr_open(Chardev *chr,
ChardevBackend *backend,
- bool *be_opened,
Error **errp)
{
ChardevRingbuf *opts = backend->u.ringbuf.data;
d->prod = 0;
d->cons = 0;
d->cbuf = g_malloc0(d->size);
+
+ qemu_chr_be_event(chr, CHR_EVENT_OPENED);
}
void qmp_ringbuf_write(const char *device, const char *data,
#ifdef _WIN32
-static void serial_chr_open(Chardev *chr,
- ChardevBackend *backend,
- bool *be_opened,
- Error **errp)
+static void serial_chr_open(Chardev *chr, ChardevBackend *backend, Error **errp)
{
ChardevHostdev *serial = backend->u.serial.data;
+ int ret = win_chr_serial_init(chr, serial->device, errp);
+ if (ret < 0) {
+ return;
+ }
- win_chr_serial_init(chr, serial->device, errp);
+ qemu_chr_be_event(chr, CHR_EVENT_OPENED);
}
#elif defined(__linux__) || defined(__sun__) || defined(__FreeBSD__) \
return 0;
}
-static void serial_chr_open(Chardev *chr,
- ChardevBackend *backend,
- bool *be_opened,
- Error **errp)
+static void serial_chr_open(Chardev *chr, ChardevBackend *backend, Error **errp)
{
ChardevHostdev *serial = backend->u.serial.data;
int fd;
close(fd);
return;
}
+
+ qemu_chr_be_event(chr, CHR_EVENT_OPENED);
}
#endif /* __linux__ || __sun__ */
}
-static void tcp_chr_open(Chardev *chr,
- ChardevBackend *backend,
- bool *be_opened,
- Error **errp)
+static void tcp_chr_open(Chardev *chr, ChardevBackend *backend, Error **errp)
{
SocketChardev *s = SOCKET_CHARDEV(chr);
ChardevSocket *sock = backend->u.socket.data;
}
s->registered_yank = true;
- /* be isn't opened until we get a connection */
- *be_opened = false;
-
update_disconnected_filename(s);
if (s->is_listen) {
return;
}
}
+
+ /* be isn't opened until we get a connection */
}
static void tcp_chr_parse(QemuOpts *opts, ChardevBackend *backend, Error **errp)
stdio_chr_set_echo(NULL, stdio_echo_state);
}
-static void stdio_chr_open(Chardev *chr,
- ChardevBackend *backend,
- bool *be_opened,
- Error **errp)
+static void stdio_chr_open(Chardev *chr, ChardevBackend *backend, Error **errp)
{
ChardevStdio *opts = backend->u.stdio.data;
struct sigaction act;
stdio_allow_signal = !opts->has_signal || opts->signal;
stdio_chr_set_echo(chr, false);
+
+ qemu_chr_be_event(chr, CHR_EVENT_OPENED);
}
#endif
}
}
-static void upd_chr_open(Chardev *chr,
- ChardevBackend *backend,
- bool *be_opened,
- Error **errp)
+static void upd_chr_open(Chardev *chr, ChardevBackend *backend, Error **errp)
{
ChardevUdp *udp = backend->u.udp.data;
SocketAddress *local_addr = socket_address_flatten(udp->local);
g_free(name);
s->ioc = QIO_CHANNEL(sioc);
+ qemu_chr_be_event(chr, CHR_EVENT_OPENED);
}
static void char_udp_class_init(ObjectClass *oc, const void *data)
static void win_stdio_chr_open(Chardev *chr,
ChardevBackend *backend,
- bool *be_opened,
Error **errp)
{
ChardevStdio *opts = backend->u.stdio.data;
win_stiod_chr_set_echo(chr, false);
+ qemu_chr_be_event(chr, CHR_EVENT_OPENED);
return;
err3:
CHARDEV_GET_CLASS(s)->chr_add_client(s, fd) : -1;
}
-static void qemu_char_open(Chardev *chr, ChardevBackend *backend,
- bool *be_opened, Error **errp)
+static void qemu_char_open(Chardev *chr, ChardevBackend *backend, Error **errp)
{
ChardevClass *cc = CHARDEV_GET_CLASS(chr);
/* Any ChardevCommon member would work */
}
if (cc->chr_open) {
- cc->chr_open(chr, backend, be_opened, errp);
+ cc->chr_open(chr, backend, errp);
}
}
Object *obj;
Chardev *chr = NULL;
Error *local_err = NULL;
- bool be_opened = true;
assert(g_str_has_prefix(typename, "chardev-"));
assert(id);
chr->label = g_strdup(id);
chr->gcontext = gcontext;
- qemu_char_open(chr, backend, &be_opened, &local_err);
+ qemu_char_open(chr, backend, &local_err);
if (local_err) {
error_propagate(errp, local_err);
object_unref(obj);
if (!chr->filename) {
chr->filename = g_strdup(typename + 8);
}
- if (be_opened) {
- qemu_chr_be_event(chr, CHR_EVENT_OPENED);
- }
return chr;
}
static void msmouse_chr_open(Chardev *chr,
ChardevBackend *backend,
- bool *be_opened,
Error **errp)
{
MouseChardev *mouse = MOUSE_CHARDEV(chr);
- *be_opened = false;
mouse->hs = qemu_input_handler_register((DeviceState *)mouse,
&msmouse_handler);
mouse->tiocm = 0;
fifo8_create(&mouse->outbuf, MSMOUSE_BUF_SZ);
+
+ /* Never send CHR_EVENT_OPENED */
}
static void char_msmouse_class_init(ObjectClass *oc, const void *data)
s->sin.subtype = g_strdup(subtype);
}
-static void spice_vmc_chr_open(Chardev *chr,
- ChardevBackend *backend,
- bool *be_opened,
+static void spice_vmc_chr_open(Chardev *chr, ChardevBackend *backend,
Error **errp)
{
ChardevSpiceChannel *spicevmc = backend->u.spicevmc.data;
return;
}
- *be_opened = false;
chr_open(chr, type);
}
-static void spice_port_chr_open(Chardev *chr,
- ChardevBackend *backend,
- bool *be_opened,
+static void spice_port_chr_open(Chardev *chr, ChardevBackend *backend,
Error **errp)
{
ChardevSpicePort *spiceport = backend->u.spiceport.data;
chr_open(chr, "port");
- *be_opened = false;
s = SPICE_CHARDEV(chr);
s->sin.portname = g_strdup(name);
static void wctablet_chr_open(Chardev *chr,
ChardevBackend *backend,
- bool *be_opened,
Error **errp)
{
TabletChardev *tablet = WCTABLET_CHARDEV(chr);
- *be_opened = true;
-
/* init state machine */
memcpy(tablet->outbuf, WC_FULL_CONFIG_STRING, WC_FULL_CONFIG_STRING_LENGTH);
tablet->outlen = WC_FULL_CONFIG_STRING_LENGTH;
tablet->hs = qemu_input_handler_register((DeviceState *)tablet,
&wctablet_handler);
+
+ qemu_chr_be_event(chr, CHR_EVENT_OPENED);
}
static void wctablet_chr_class_init(ObjectClass *oc, const void *data)
return len;
}
-static void gdb_chr_open(Chardev *chr, ChardevBackend *backend,
- bool *be_opened, Error **errp)
+static void gdb_chr_open(Chardev *chr, ChardevBackend *backend, Error **errp)
{
- *be_opened = false;
+ /* Never send CHR_EVENT_OPENED */
}
static void char_gdb_class_init(ObjectClass *oc, const void *data)
void (*chr_parse)(QemuOpts *opts, ChardevBackend *backend, Error **errp);
/* called after construction, open/starts the backend */
- void (*chr_open)(Chardev *chr, ChardevBackend *backend,
- bool *be_opened, Error **errp);
+ void (*chr_open)(Chardev *chr, ChardevBackend *backend, Error **errp);
/* write buf to the backend */
int (*chr_write)(Chardev *s, const uint8_t *buf, int len);
dpy_text_resize(QEMU_CONSOLE(c), c->width, c->height);
}
-static void vc_chr_open(Chardev *chr,
- ChardevBackend *backend,
- bool *be_opened,
- Error **errp)
+static void vc_chr_open(Chardev *chr, ChardevBackend *backend, Error **errp)
{
ChardevVC *vc = backend->u.vc.data;
VCChardev *drv = VC_CHARDEV(chr);
drv->t_attrib = TEXT_ATTRIBUTES_DEFAULT;
}
- *be_opened = true;
+ qemu_chr_be_event(chr, CHR_EVENT_OPENED);
}
static void vc_chr_parse(QemuOpts *opts, ChardevBackend *backend, Error **errp)
return DBUS_METHOD_INVOCATION_HANDLED;
}
-static void
-dbus_chr_open(Chardev *chr, ChardevBackend *backend,
- bool *be_opened, Error **errp)
+static void dbus_chr_open(Chardev *chr, ChardevBackend *backend, Error **errp)
{
ERRP_GUARD();
return;
}
CHARDEV_CLASS(object_class_by_name(TYPE_CHARDEV_SOCKET))->chr_open(
- chr, be, be_opened, errp);
+ chr, be, errp);
}
static void
static int nb_vcs;
static Chardev *vcs[MAX_VCS];
-static void gd_vc_chr_open(Chardev *chr,
- ChardevBackend *backend,
- bool *be_opened,
- Error **errp)
+static void gd_vc_chr_open(Chardev *chr, ChardevBackend *backend, Error **errp)
{
if (nb_vcs == MAX_VCS) {
error_setg(errp, "Maximum number of consoles reached");
vcs[nb_vcs++] = chr;
- /* console/chardev init sometimes completes elsewhere in a 2nd
+ /*
+ * console/chardev init sometimes completes elsewhere in a 2nd
* stage, so defer OPENED events until they are fully initialized
*/
- *be_opened = false;
}
static void char_gd_vc_class_init(ObjectClass *oc, const void *data)
struct VCChardevClass {
ChardevClass parent;
- void (*parent_open)(Chardev *chr, ChardevBackend *backend,
- bool *be_opened, Error **errp);
+ void (*parent_open)(Chardev *chr, ChardevBackend *backend, Error **errp);
};
#define TYPE_CHARDEV_VC "chardev-vc"
return be;
}
-static void vc_chr_open(Chardev *chr,
- ChardevBackend *backend,
- bool *be_opened,
- Error **errp)
+static void vc_chr_open(Chardev *chr, ChardevBackend *backend, Error **errp)
{
VCChardevClass *vc = CHARDEV_VC_GET_CLASS(chr);
ChardevBackend *be;
be = chr_spice_backend_new();
be->u.spiceport.data->fqdn = fqdn ?
g_strdup(fqdn) : g_strdup_printf("org.qemu.console.%s", chr->label);
- vc->parent_open(chr, be, be_opened, errp);
+ vc->parent_open(chr, be, errp);
qapi_free_ChardevBackend(be);
}
static void vdagent_chr_open(Chardev *chr,
ChardevBackend *backend,
- bool *be_opened,
Error **errp)
{
VDAgentChardev *vd = QEMU_VDAGENT_CHARDEV(chr);
&vdagent_mouse_handler);
}
- *be_opened = true;
+ qemu_chr_be_event(chr, CHR_EVENT_OPENED);
}
static void vdagent_clipboard_peer_register(VDAgentChardev *vd)