[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
Re: [Qemu-devel] [PATCH 2/5] qga: handle G_IO_STATUS_AGAIN in ga_channel
From: |
Michael Roth |
Subject: |
Re: [Qemu-devel] [PATCH 2/5] qga: handle G_IO_STATUS_AGAIN in ga_channel_write_all() |
Date: |
Thu, 01 Oct 2015 16:54:52 -0500 |
User-agent: |
alot/0.3.6 |
Quoting Denis V. Lunev (2015-10-01 02:38:00)
> From: Yuri Pudgorodskiy <address@hidden>
>
> glib may return G_IO_STATUS_AGAIN which is actually not an error.
> Also fixed a bug when on incomplete write buf pointer was not adjusted.
>
> Signed-off-by: Yuri Pudgorodskiy <address@hidden>
> Signed-off-by: Denis V. Lunev <address@hidden>
> CC: Michael Roth <address@hidden>
Reviewed-by: Michael Roth <address@hidden>
> ---
> qga/channel-posix.c | 23 +++++++++++------------
> 1 file changed, 11 insertions(+), 12 deletions(-)
>
> diff --git a/qga/channel-posix.c b/qga/channel-posix.c
> index 8aad4fe..7be92cc 100644
> --- a/qga/channel-posix.c
> +++ b/qga/channel-posix.c
> @@ -217,25 +217,24 @@ GIOStatus ga_channel_write_all(GAChannel *c, const
> gchar *buf, gsize size)
> GIOStatus status = G_IO_STATUS_NORMAL;
>
> while (size) {
> + g_debug("sending data, count: %d", (int)size);
> status = g_io_channel_write_chars(c->client_channel, buf, size,
> &written, &err);
> - g_debug("sending data, count: %d", (int)size);
> - if (err != NULL) {
> + if (status == G_IO_STATUS_NORMAL) {
> + size -= written;
> + buf += written;
> + } else if (status != G_IO_STATUS_AGAIN) {
> g_warning("error writing to channel: %s", err->message);
> - return G_IO_STATUS_ERROR;
> - }
> - if (status != G_IO_STATUS_NORMAL) {
> - break;
> + return status;
> }
> - size -= written;
> }
>
> - if (status == G_IO_STATUS_NORMAL) {
> + do {
> status = g_io_channel_flush(c->client_channel, &err);
> - if (err != NULL) {
> - g_warning("error flushing channel: %s", err->message);
> - return G_IO_STATUS_ERROR;
> - }
> + } while (status == G_IO_STATUS_AGAIN);
> +
> + if (status != G_IO_STATUS_NORMAL) {
> + g_warning("error flushing channel: %s", err->message);
> }
>
> return status;
> --
> 2.1.4
>
- [Qemu-devel] [PATCH 0/5] simplified QEMU guest exec, Denis V. Lunev, 2015/10/08
- [Qemu-devel] [PATCH 1/5] qga: drop guest_file_init helper and replace it with static initializers, Denis V. Lunev, 2015/10/08
- [Qemu-devel] [PATCH 4/5] qga: handle possible SIGPIPE in guest-file-write, Denis V. Lunev, 2015/10/08
- [Qemu-devel] [PATCH 2/5] qga: handle G_IO_STATUS_AGAIN in ga_channel_write_all(), Denis V. Lunev, 2015/10/08
- Re: [Qemu-devel] [PATCH 2/5] qga: handle G_IO_STATUS_AGAIN in ga_channel_write_all(),
Michael Roth <=
- [Qemu-devel] [PATCH 3/5] qga: guest exec functionality, Denis V. Lunev, 2015/10/08
- [Qemu-devel] [PATCH 5/5] qga: guest-exec simple stdin/stdout/stderr redirection, Denis V. Lunev, 2015/10/08