char: move backends' io watch tag to CharDriverState

All the backends implement an io watcher tag for callbacks.  Move it to
CharDriverState from each backend's struct to make accessing the tag from
backend-neutral functions easier.

This will be used later to cancel a callback on chardev detach from a
frontend.

CC: <qemu-stable@nongnu.org>
Reviewed-by: Gerd Hoffmann <kraxel@redhat.com>
Signed-off-by: Amit Shah <amit.shah@redhat.com>
This commit is contained in:
Amit Shah 2013-08-28 15:18:29 +05:30
parent aaa6a40194
commit 7ba9addc16
2 changed files with 40 additions and 38 deletions

View file

@ -78,6 +78,7 @@ struct CharDriverState {
int explicit_be_open; int explicit_be_open;
int avail_connections; int avail_connections;
int is_mux; int is_mux;
guint fd_in_tag;
QemuOpts *opts; QemuOpts *opts;
QTAILQ_ENTRY(CharDriverState) next; QTAILQ_ENTRY(CharDriverState) next;
}; };

View file

@ -798,7 +798,6 @@ static int io_channel_send(GIOChannel *fd, const void *buf, size_t len)
typedef struct FDCharDriver { typedef struct FDCharDriver {
CharDriverState *chr; CharDriverState *chr;
GIOChannel *fd_in, *fd_out; GIOChannel *fd_in, *fd_out;
guint fd_in_tag;
int max_size; int max_size;
QTAILQ_ENTRY(FDCharDriver) node; QTAILQ_ENTRY(FDCharDriver) node;
} FDCharDriver; } FDCharDriver;
@ -830,9 +829,9 @@ static gboolean fd_chr_read(GIOChannel *chan, GIOCondition cond, void *opaque)
status = g_io_channel_read_chars(chan, (gchar *)buf, status = g_io_channel_read_chars(chan, (gchar *)buf,
len, &bytes_read, NULL); len, &bytes_read, NULL);
if (status == G_IO_STATUS_EOF) { if (status == G_IO_STATUS_EOF) {
if (s->fd_in_tag) { if (chr->fd_in_tag) {
io_remove_watch_poll(s->fd_in_tag); io_remove_watch_poll(chr->fd_in_tag);
s->fd_in_tag = 0; chr->fd_in_tag = 0;
} }
qemu_chr_be_event(chr, CHR_EVENT_CLOSED); qemu_chr_be_event(chr, CHR_EVENT_CLOSED);
return FALSE; return FALSE;
@ -863,13 +862,14 @@ static void fd_chr_update_read_handler(CharDriverState *chr)
{ {
FDCharDriver *s = chr->opaque; FDCharDriver *s = chr->opaque;
if (s->fd_in_tag) { if (chr->fd_in_tag) {
io_remove_watch_poll(s->fd_in_tag); io_remove_watch_poll(chr->fd_in_tag);
s->fd_in_tag = 0; chr->fd_in_tag = 0;
} }
if (s->fd_in) { if (s->fd_in) {
s->fd_in_tag = io_add_watch_poll(s->fd_in, fd_chr_read_poll, fd_chr_read, chr); chr->fd_in_tag = io_add_watch_poll(s->fd_in, fd_chr_read_poll,
fd_chr_read, chr);
} }
} }
@ -877,9 +877,9 @@ static void fd_chr_close(struct CharDriverState *chr)
{ {
FDCharDriver *s = chr->opaque; FDCharDriver *s = chr->opaque;
if (s->fd_in_tag) { if (chr->fd_in_tag) {
io_remove_watch_poll(s->fd_in_tag); io_remove_watch_poll(chr->fd_in_tag);
s->fd_in_tag = 0; chr->fd_in_tag = 0;
} }
if (s->fd_in) { if (s->fd_in) {
@ -1012,7 +1012,6 @@ static CharDriverState *qemu_chr_open_stdio(ChardevStdio *opts)
typedef struct { typedef struct {
GIOChannel *fd; GIOChannel *fd;
guint fd_tag;
int connected; int connected;
int read_bytes; int read_bytes;
guint timer_tag; guint timer_tag;
@ -1127,9 +1126,9 @@ static void pty_chr_state(CharDriverState *chr, int connected)
PtyCharDriver *s = chr->opaque; PtyCharDriver *s = chr->opaque;
if (!connected) { if (!connected) {
if (s->fd_tag) { if (chr->fd_in_tag) {
io_remove_watch_poll(s->fd_tag); io_remove_watch_poll(chr->fd_in_tag);
s->fd_tag = 0; chr->fd_in_tag = 0;
} }
s->connected = 0; s->connected = 0;
/* (re-)connect poll interval for idle guests: once per second. /* (re-)connect poll interval for idle guests: once per second.
@ -1144,7 +1143,8 @@ static void pty_chr_state(CharDriverState *chr, int connected)
if (!s->connected) { if (!s->connected) {
s->connected = 1; s->connected = 1;
qemu_chr_be_generic_open(chr); qemu_chr_be_generic_open(chr);
s->fd_tag = io_add_watch_poll(s->fd, pty_chr_read_poll, pty_chr_read, chr); chr->fd_in_tag = io_add_watch_poll(s->fd, pty_chr_read_poll,
pty_chr_read, chr);
} }
} }
} }
@ -1155,9 +1155,9 @@ static void pty_chr_close(struct CharDriverState *chr)
PtyCharDriver *s = chr->opaque; PtyCharDriver *s = chr->opaque;
int fd; int fd;
if (s->fd_tag) { if (chr->fd_in_tag) {
io_remove_watch_poll(s->fd_tag); io_remove_watch_poll(chr->fd_in_tag);
s->fd_tag = 0; chr->fd_in_tag = 0;
} }
fd = g_io_channel_unix_get_fd(s->fd); fd = g_io_channel_unix_get_fd(s->fd);
g_io_channel_unref(s->fd); g_io_channel_unref(s->fd);
@ -2165,7 +2165,6 @@ static CharDriverState *qemu_chr_open_stdio(ChardevStdio *opts)
typedef struct { typedef struct {
int fd; int fd;
GIOChannel *chan; GIOChannel *chan;
guint tag;
uint8_t buf[READ_BUF_LEN]; uint8_t buf[READ_BUF_LEN];
int bufcnt; int bufcnt;
int bufptr; int bufptr;
@ -2221,9 +2220,9 @@ static gboolean udp_chr_read(GIOChannel *chan, GIOCondition cond, void *opaque)
s->bufcnt = bytes_read; s->bufcnt = bytes_read;
s->bufptr = s->bufcnt; s->bufptr = s->bufcnt;
if (status != G_IO_STATUS_NORMAL) { if (status != G_IO_STATUS_NORMAL) {
if (s->tag) { if (chr->fd_in_tag) {
io_remove_watch_poll(s->tag); io_remove_watch_poll(chr->fd_in_tag);
s->tag = 0; chr->fd_in_tag = 0;
} }
return FALSE; return FALSE;
} }
@ -2242,22 +2241,23 @@ static void udp_chr_update_read_handler(CharDriverState *chr)
{ {
NetCharDriver *s = chr->opaque; NetCharDriver *s = chr->opaque;
if (s->tag) { if (chr->fd_in_tag) {
io_remove_watch_poll(s->tag); io_remove_watch_poll(chr->fd_in_tag);
s->tag = 0; chr->fd_in_tag = 0;
} }
if (s->chan) { if (s->chan) {
s->tag = io_add_watch_poll(s->chan, udp_chr_read_poll, udp_chr_read, chr); chr->fd_in_tag = io_add_watch_poll(s->chan, udp_chr_read_poll,
udp_chr_read, chr);
} }
} }
static void udp_chr_close(CharDriverState *chr) static void udp_chr_close(CharDriverState *chr)
{ {
NetCharDriver *s = chr->opaque; NetCharDriver *s = chr->opaque;
if (s->tag) { if (chr->fd_in_tag) {
io_remove_watch_poll(s->tag); io_remove_watch_poll(chr->fd_in_tag);
s->tag = 0; chr->fd_in_tag = 0;
} }
if (s->chan) { if (s->chan) {
g_io_channel_unref(s->chan); g_io_channel_unref(s->chan);
@ -2308,7 +2308,7 @@ static CharDriverState *qemu_chr_open_udp(QemuOpts *opts)
typedef struct { typedef struct {
GIOChannel *chan, *listen_chan; GIOChannel *chan, *listen_chan;
guint tag, listen_tag; guint listen_tag;
int fd, listen_fd; int fd, listen_fd;
int connected; int connected;
int max_size; int max_size;
@ -2493,9 +2493,9 @@ static gboolean tcp_chr_read(GIOChannel *chan, GIOCondition cond, void *opaque)
if (s->listen_chan) { if (s->listen_chan) {
s->listen_tag = g_io_add_watch(s->listen_chan, G_IO_IN, tcp_chr_accept, chr); s->listen_tag = g_io_add_watch(s->listen_chan, G_IO_IN, tcp_chr_accept, chr);
} }
if (s->tag) { if (chr->fd_in_tag) {
io_remove_watch_poll(s->tag); io_remove_watch_poll(chr->fd_in_tag);
s->tag = 0; chr->fd_in_tag = 0;
} }
g_io_channel_unref(s->chan); g_io_channel_unref(s->chan);
s->chan = NULL; s->chan = NULL;
@ -2526,7 +2526,8 @@ static void tcp_chr_connect(void *opaque)
s->connected = 1; s->connected = 1;
if (s->chan) { if (s->chan) {
s->tag = io_add_watch_poll(s->chan, tcp_chr_read_poll, tcp_chr_read, chr); chr->fd_in_tag = io_add_watch_poll(s->chan, tcp_chr_read_poll,
tcp_chr_read, chr);
} }
qemu_chr_be_generic_open(chr); qemu_chr_be_generic_open(chr);
} }
@ -2609,9 +2610,9 @@ static void tcp_chr_close(CharDriverState *chr)
{ {
TCPCharDriver *s = chr->opaque; TCPCharDriver *s = chr->opaque;
if (s->fd >= 0) { if (s->fd >= 0) {
if (s->tag) { if (chr->fd_in_tag) {
io_remove_watch_poll(s->tag); io_remove_watch_poll(chr->fd_in_tag);
s->tag = 0; chr->fd_in_tag = 0;
} }
if (s->chan) { if (s->chan) {
g_io_channel_unref(s->chan); g_io_channel_unref(s->chan);