[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [PULL v1 16/18] char: remove qemu_chr_open_socket_fd method
From: |
Daniel P. Berrange |
Subject: |
[Qemu-devel] [PULL v1 16/18] char: remove qemu_chr_open_socket_fd method |
Date: |
Fri, 11 Mar 2016 10:04:06 +0000 |
The qemu_chr_open_socket_fd method takes care of either doing a
synchronous socket connect, or creating a listener socket. Part
of the work when creating the listener socket is to register a
watch for incoming clients. The caller of qemu_chr_open_socket_fd
may not want this watch created, as it might be doing a synchronous
wait for the first client. Rather than passing yet more parameters
into qemu_chr_open_socket_fd to let it handle this, just remove
the qemu_chr_open_socket_fd method an inline its functionality
into the caller. This allows for a clearer control flow and shorter
code.
Signed-off-by: Daniel P. Berrange <address@hidden>
---
qemu-char.c | 59 ++++++++++++++++++++++++-----------------------------------
1 file changed, 24 insertions(+), 35 deletions(-)
diff --git a/qemu-char.c b/qemu-char.c
index 1540463..3bf30b5 100644
--- a/qemu-char.c
+++ b/qemu-char.c
@@ -3109,32 +3109,6 @@ static void qemu_chr_socket_connected(Object *src, Error
*err, void *opaque)
object_unref(OBJECT(sioc));
}
-static bool qemu_chr_open_socket_fd(CharDriverState *chr, Error **errp)
-{
- TCPCharDriver *s = chr->opaque;
- QIOChannelSocket *sioc = qio_channel_socket_new();
-
- if (s->is_listen) {
- if (qio_channel_socket_listen_sync(sioc, s->addr, errp) < 0) {
- goto fail;
- }
- s->listen_ioc = sioc;
- s->listen_tag = qio_channel_add_watch(
- QIO_CHANNEL(s->listen_ioc), G_IO_IN, tcp_chr_accept, chr, NULL);
- } else {
- if (qio_channel_socket_connect_sync(sioc, s->addr, errp) < 0) {
- goto fail;
- }
- tcp_chr_new_client(chr, sioc);
- object_unref(OBJECT(sioc));
- }
-
- return true;
-
- fail:
- object_unref(OBJECT(sioc));
- return false;
-}
/*********************************************************/
/* Ring buffer chardev */
@@ -4349,25 +4323,40 @@ static CharDriverState *qmp_chardev_open_socket(const
char *id,
s->reconnect_time = reconnect;
}
+ sioc = qio_channel_socket_new();
if (s->reconnect_time) {
- sioc = qio_channel_socket_new();
qio_channel_socket_connect_async(sioc, s->addr,
qemu_chr_socket_connected,
chr, NULL);
- } else if (!qemu_chr_open_socket_fd(chr, errp)) {
- goto error;
- }
-
- if (is_listen && is_waitconnect) {
- fprintf(stderr, "QEMU waiting for connection on: %s\n",
- chr->filename);
- tcp_chr_accept(QIO_CHANNEL(s->listen_ioc), G_IO_IN, chr);
+ } else if (s->is_listen) {
+ if (qio_channel_socket_listen_sync(sioc, s->addr, errp) < 0) {
+ goto error;
+ }
+ s->listen_ioc = sioc;
+ if (is_waitconnect) {
+ fprintf(stderr, "QEMU waiting for connection on: %s\n",
+ chr->filename);
+ tcp_chr_accept(QIO_CHANNEL(s->listen_ioc), G_IO_IN, chr);
+ }
qio_channel_set_blocking(QIO_CHANNEL(s->listen_ioc), false, NULL);
+ if (!s->ioc) {
+ s->listen_tag = qio_channel_add_watch(
+ QIO_CHANNEL(s->listen_ioc), G_IO_IN, tcp_chr_accept, chr,
NULL);
+ }
+ } else {
+ if (qio_channel_socket_connect_sync(sioc, s->addr, errp) < 0) {
+ goto error;
+ }
+ tcp_chr_new_client(chr, sioc);
+ object_unref(OBJECT(sioc));
}
return chr;
error:
+ if (sioc) {
+ object_unref(OBJECT(sioc));
+ }
if (s->tls_creds) {
object_unref(OBJECT(s->tls_creds));
}
--
2.5.0
- [Qemu-devel] [PULL v1 04/18] io: bind to socket before creating QIOChannelSocket, (continued)
- [Qemu-devel] [PULL v1 04/18] io: bind to socket before creating QIOChannelSocket, Daniel P. Berrange, 2016/03/11
- [Qemu-devel] [PULL v1 03/18] io: initialize sockets in test program, Daniel P. Berrange, 2016/03/11
- [Qemu-devel] [PULL v1 09/18] io: pass HANDLE to g_source_add_poll on Win32, Daniel P. Berrange, 2016/03/11
- [Qemu-devel] [PULL v1 08/18] io: fix copy+paste mistake in socket error message, Daniel P. Berrange, 2016/03/11
- [Qemu-devel] [PULL v1 10/18] io: introduce qio_channel_create_socket_watch, Daniel P. Berrange, 2016/03/11
- [Qemu-devel] [PULL v1 12/18] io: remove checking of EWOULDBLOCK, Daniel P. Berrange, 2016/03/11
- [Qemu-devel] [PULL v1 11/18] io: use qemu_accept to ensure SOCK_CLOEXEC is set, Daniel P. Berrange, 2016/03/11
- [Qemu-devel] [PULL v1 14/18] char: remove qemu_chr_finish_socket_connection method, Daniel P. Berrange, 2016/03/11
- [Qemu-devel] [PULL v1 13/18] io: implement socket watch for win32 using WSAEventSelect+select, Daniel P. Berrange, 2016/03/11
- [Qemu-devel] [PULL v1 15/18] char: remove socket_try_connect method, Daniel P. Berrange, 2016/03/11
- [Qemu-devel] [PULL v1 16/18] char: remove qemu_chr_open_socket_fd method,
Daniel P. Berrange <=
- [Qemu-devel] [PULL v1 17/18] osdep: add wrappers for socket functions, Daniel P. Berrange, 2016/03/11
- [Qemu-devel] [PULL v1 18/18] osdep: remove use of socket_error() from all code, Daniel P. Berrange, 2016/03/11
- Re: [Qemu-devel] [PULL v1 00/18] Merge I/O channel fixes for Win32, Peter Maydell, 2016/03/14