qemu-devel.nongnu.org archive mirror
 help / color / mirror / Atom feed
From: Juan Quintela <quintela@redhat.com>
To: qemu-devel@nongnu.org
Cc: "Hailiang Zhang" <zhanghailiang@xfusion.com>,
	"Eric Blake" <eblake@redhat.com>,
	"Daniel P. Berrangé" <berrange@redhat.com>,
	"Fam Zheng" <fam@euphon.net>,
	"Dr. David Alan Gilbert" <dgilbert@redhat.com>,
	"Juan Quintela" <quintela@redhat.com>,
	qemu-block@nongnu.org, "Stefan Hajnoczi" <stefanha@redhat.com>,
	"Markus Armbruster" <armbru@redhat.com>,
	"Leonardo Bras" <leobras@redhat.com>,
	"Peter Xu" <peterx@redhat.com>
Subject: [PULL 02/25] QIOChannelSocket: Introduce assert and reduce ifdefs to improve readability
Date: Wed, 22 Jun 2022 02:25:24 +0200	[thread overview]
Message-ID: <20220622002547.64784-3-quintela@redhat.com> (raw)
In-Reply-To: <20220622002547.64784-1-quintela@redhat.com>

From: Leonardo Bras <leobras@redhat.com>

During implementation of MSG_ZEROCOPY feature, a lot of #ifdefs were
introduced, particularly at qio_channel_socket_writev().

Rewrite some of those changes so it's easier to read.

Also, introduce an assert to help detect incorrect zero-copy usage is when
it's disabled on build.

Signed-off-by: Leonardo Bras <leobras@redhat.com>
Reviewed-by: Daniel P. Berrangé <berrange@redhat.com>
Reviewed-by: Juan Quintela <quintela@redhat.com>
Reviewed-by: Peter Xu <peterx@redhat.com>
Signed-off-by: Juan Quintela <quintela@redhat.com>
---
 io/channel-socket.c | 14 +++++++++-----
 1 file changed, 9 insertions(+), 5 deletions(-)

diff --git a/io/channel-socket.c b/io/channel-socket.c
index dc9c165de1..dac9e60c20 100644
--- a/io/channel-socket.c
+++ b/io/channel-socket.c
@@ -578,11 +578,17 @@ static ssize_t qio_channel_socket_writev(QIOChannel *ioc,
         memcpy(CMSG_DATA(cmsg), fds, fdsize);
     }
 
-#ifdef QEMU_MSG_ZEROCOPY
     if (flags & QIO_CHANNEL_WRITE_FLAG_ZERO_COPY) {
+#ifdef QEMU_MSG_ZEROCOPY
         sflags = MSG_ZEROCOPY;
-    }
+#else
+        /*
+         * We expect QIOChannel class entry point to have
+         * blocked this code path already
+         */
+        g_assert_unreachable();
 #endif
+    }
 
  retry:
     ret = sendmsg(sioc->fd, &msg, sflags);
@@ -592,15 +598,13 @@ static ssize_t qio_channel_socket_writev(QIOChannel *ioc,
             return QIO_CHANNEL_ERR_BLOCK;
         case EINTR:
             goto retry;
-#ifdef QEMU_MSG_ZEROCOPY
         case ENOBUFS:
-            if (sflags & MSG_ZEROCOPY) {
+            if (flags & QIO_CHANNEL_WRITE_FLAG_ZERO_COPY) {
                 error_setg_errno(errp, errno,
                                  "Process can't lock enough memory for using MSG_ZEROCOPY");
                 return -1;
             }
             break;
-#endif
         }
 
         error_setg_errno(errp, errno,
-- 
2.35.3



  parent reply	other threads:[~2022-06-22  0:28 UTC|newest]

Thread overview: 29+ messages / expand[flat|nested]  mbox.gz  Atom feed  top
2022-06-22  0:25 [PULL 00/25] Migration 20220621 patches Juan Quintela
2022-06-22  0:25 ` [PULL 01/25] migration: Remove RDMA_UNREGISTRATION_EXAMPLE Juan Quintela
2022-06-22  0:25 ` Juan Quintela [this message]
2022-06-22  0:25 ` [PULL 03/25] QIOChannelSocket: Fix zero-copy send so socket flush works Juan Quintela
2022-06-22  0:25 ` [PULL 04/25] migration: Change zero_copy_send from migration parameter to migration capability Juan Quintela
2022-06-22  0:25 ` [PULL 05/25] io: add a QIOChannelNull equivalent to /dev/null Juan Quintela
2022-06-22  0:25 ` [PULL 06/25] migration: switch to use QIOChannelNull for dummy channel Juan Quintela
2022-06-22  0:25 ` [PULL 07/25] migration: remove unreachble RDMA code in save_hook impl Juan Quintela
2022-06-22  0:25 ` [PULL 08/25] migration: rename rate limiting fields in QEMUFile Juan Quintela
2022-06-22  0:25 ` [PULL 09/25] migration: rename 'pos' field in QEMUFile to 'bytes_processed' Juan Quintela
2022-06-22  0:25 ` [PULL 10/25] migration: rename qemu_ftell to qemu_file_total_transferred Juan Quintela
2022-06-22  0:25 ` [PULL 11/25] migration: rename qemu_update_position to qemu_file_credit_transfer Juan Quintela
2022-06-22  0:25 ` [PULL 12/25] migration: rename qemu_file_update_transfer to qemu_file_acct_rate_limit Juan Quintela
2022-06-22  0:25 ` [PULL 13/25] migration: introduce a QIOChannel impl for BlockDriverState VMState Juan Quintela
2022-06-22  0:25 ` [PULL 14/25] migration: convert savevm to use QIOChannelBlock for VMState Juan Quintela
2022-06-22  0:25 ` [PULL 15/25] migration: stop passing 'opaque' parameter to QEMUFile hooks Juan Quintela
2022-06-22  0:25 ` [PULL 16/25] migration: hardcode assumption that QEMUFile is backed with QIOChannel Juan Quintela
2022-06-22  0:25 ` [PULL 17/25] migration: introduce new constructors for QEMUFile Juan Quintela
2022-06-22  0:25 ` [PULL 18/25] migration: remove unused QEMUFileGetFD typedef / qemu_get_fd method Juan Quintela
2022-06-22  0:25 ` [PULL 19/25] migration: remove the QEMUFileOps 'shut_down' callback Juan Quintela
2022-06-22  0:25 ` [PULL 20/25] migration: remove the QEMUFileOps 'set_blocking' callback Juan Quintela
2022-06-22  0:25 ` [PULL 21/25] migration: remove the QEMUFileOps 'close' callback Juan Quintela
2022-06-22  0:25 ` [PULL 22/25] migration: remove the QEMUFileOps 'get_buffer' callback Juan Quintela
2022-06-22  0:25 ` [PULL 23/25] migration: remove the QEMUFileOps 'writev_buffer' callback Juan Quintela
2022-06-22  0:25 ` [PULL 24/25] migration: remove the QEMUFileOps 'get_return_path' callback Juan Quintela
2022-06-22  0:25 ` [PULL 25/25] migration: remove the QEMUFileOps abstraction Juan Quintela
2022-06-22  2:14 ` [PULL 00/25] Migration 20220621 patches Richard Henderson
2022-06-22 15:19   ` Dr. David Alan Gilbert
  -- strict thread matches above, loose matches on Subject: below --
2022-06-23 16:53 [PULL 00/25] migration queue Dr. David Alan Gilbert (git)
2022-06-23 16:53 ` [PULL 02/25] QIOChannelSocket: Introduce assert and reduce ifdefs to improve readability Dr. David Alan Gilbert (git)

Reply instructions:

You may reply publicly to this message via plain-text email
using any one of the following methods:

* Save the following mbox file, import it into your mail client,
  and reply-to-all from there: mbox

  Avoid top-posting and favor interleaved quoting:
  https://en.wikipedia.org/wiki/Posting_style#Interleaved_style

* Reply using the --to, --cc, and --in-reply-to
  switches of git-send-email(1):

  git send-email \
    --in-reply-to=20220622002547.64784-3-quintela@redhat.com \
    --to=quintela@redhat.com \
    --cc=armbru@redhat.com \
    --cc=berrange@redhat.com \
    --cc=dgilbert@redhat.com \
    --cc=eblake@redhat.com \
    --cc=fam@euphon.net \
    --cc=leobras@redhat.com \
    --cc=peterx@redhat.com \
    --cc=qemu-block@nongnu.org \
    --cc=qemu-devel@nongnu.org \
    --cc=stefanha@redhat.com \
    --cc=zhanghailiang@xfusion.com \
    /path/to/YOUR_REPLY

  https://kernel.org/pub/software/scm/git/docs/git-send-email.html

* If your mail client supports setting the In-Reply-To header
  via mailto: links, try the mailto: link
Be sure your reply has a Subject: header at the top and a blank line before the message body.
This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox;
as well as URLs for NNTP newsgroup(s).