[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
Re: [Qemu-devel] [PATCH] io: Always remove an old channel watch before a
From: |
Paolo Bonzini |
Subject: |
Re: [Qemu-devel] [PATCH] io: Always remove an old channel watch before adding a new one. |
Date: |
Mon, 24 Jul 2017 23:22:48 +0200 |
User-agent: |
Mozilla/5.0 (X11; Linux x86_64; rv:52.0) Gecko/20100101 Thunderbird/52.2.1 |
On 24/07/2017 20:15, Brandon Carpenter wrote:
> Also set saved handle to zero when removing without adding a new watch.
>
> Signed-off-by: Brandon Carpenter <address@hidden>
> ---
> ui/vnc-auth-vencrypt.c | 3 +++
> ui/vnc-ws.c | 6 ++++++
> ui/vnc.c | 4 ++++
> 3 files changed, 13 insertions(+)
>
> diff --git a/ui/vnc-auth-vencrypt.c b/ui/vnc-auth-vencrypt.c
> index ffaab57550..c3eece4fa7 100644
> --- a/ui/vnc-auth-vencrypt.c
> +++ b/ui/vnc-auth-vencrypt.c
> @@ -77,6 +77,9 @@ static void vnc_tls_handshake_done(QIOTask *task,
> vnc_client_error(vs);
> error_free(err);
> } else {
> + if (vs->ioc_tag) {
> + g_source_remove(vs->ioc_tag);
> + }
> vs->ioc_tag = qio_channel_add_watch(
> vs->ioc, G_IO_IN | G_IO_OUT, vnc_client_io, vs, NULL);
> start_auth_vencrypt_subauth(vs);
> diff --git a/ui/vnc-ws.c b/ui/vnc-ws.c
> index f530cd5474..eaf309553c 100644
> --- a/ui/vnc-ws.c
> +++ b/ui/vnc-ws.c
> @@ -36,6 +36,9 @@ static void vncws_tls_handshake_done(QIOTask *task,
> error_free(err);
> } else {
> VNC_DEBUG("TLS handshake complete, starting websocket handshake\n");
> + if (vs->ioc_tag) {
> + g_source_remove(vs->ioc_tag);
> + }
> vs->ioc_tag = qio_channel_add_watch(
> QIO_CHANNEL(vs->ioc), G_IO_IN, vncws_handshake_io, vs, NULL);
> }
> @@ -97,6 +100,9 @@ static void vncws_handshake_done(QIOTask *task,
> } else {
> VNC_DEBUG("Websock handshake complete, starting VNC protocol\n");
> vnc_start_protocol(vs);
> + if (vs->ioc_tag) {
> + g_source_remove(vs->ioc_tag);
> + }
> vs->ioc_tag = qio_channel_add_watch(
> vs->ioc, G_IO_IN, vnc_client_io, vs, NULL);
> }
> diff --git a/ui/vnc.c b/ui/vnc.c
> index eb91559b6b..ec86d6ad97 100644
> --- a/ui/vnc.c
> +++ b/ui/vnc.c
> @@ -1121,6 +1121,7 @@ static void vnc_disconnect_start(VncState *vs)
> vnc_set_share_mode(vs, VNC_SHARE_MODE_DISCONNECTED);
> if (vs->ioc_tag) {
> g_source_remove(vs->ioc_tag);
> + vs->ioc_tag = 0;
> }
> qio_channel_close(vs->ioc, NULL);
> vs->disconnecting = TRUE;
> @@ -2931,6 +2932,9 @@ static void vnc_connect(VncDisplay *vd,
> QIOChannelSocket *sioc,
> VNC_DEBUG("New client on socket %p\n", vs->sioc);
> update_displaychangelistener(&vd->dcl, VNC_REFRESH_INTERVAL_BASE);
> qio_channel_set_blocking(vs->ioc, false, NULL);
> + if (vs->ioc_tag) {
> + g_source_remove(vs->ioc_tag);
> + }
> if (websocket) {
> vs->websocket = 1;
> if (vd->tlscreds) {
>
Reviewed-by: Paolo Bonzini <address@hidden>