From: Stefan Hajnoczi <stefanha@redhat.com>
To: Jag Raman <jag.raman@oracle.com>
Cc: "Elena Ufimtseva" <elena.ufimtseva@oracle.com>,
"Fam Zheng" <fam@euphon.net>,
"Swapnil Ingle" <swapnil.ingle@nutanix.com>,
"John G Johnson" <john.g.johnson@oracle.com>,
qemu-level <qemu-devel@nongnu.org>,
"Gerd Hoffmann" <kraxel@redhat.com>,
quintela@redhat.com, mst@redhat.com, armbru@redhat.com,
kanth.ghatraju@oracle.com, felipe@nutanix.com, thuth@redhat.com,
ehabkost@redhat.com, konrad.wilk@oracle.com, dgilbert@redhat.com,
alex.williamson@redhat.com, thanos.makatos@nutanix.com,
kwolf@redhat.com, "\"Daniel P. Berrangé\"" <berrange@redhat.com>,
mreitz@redhat.com, ross.lagerwall@citrix.com,
marcandre.lureau@gmail.com, pbonzini@redhat.com
Subject: Re: [PATCH v19 08/20] io: add qio_channel_readv_full_all_eof & qio_channel_readv_full_all helpers
Date: Mon, 18 Jan 2021 16:35:41 +0000 [thread overview]
Message-ID: <20210118163541.GC255498@stefanha-x1.localdomain> (raw)
In-Reply-To: <C2D5772D-CA1A-4E06-9971-DCD589CF8CAD@oracle.com>
[-- Attachment #1: Type: text/plain, Size: 4881 bytes --]
On Fri, Jan 15, 2021 at 01:19:01PM -0500, Jag Raman wrote:
>
>
> > On Jan 15, 2021, at 4:20 AM, Stefan Hajnoczi <stefanha@redhat.com> wrote:
> >
> > On Thu, Jan 14, 2021 at 01:24:37PM -0500, Jag Raman wrote:
> >>
> >>
> >>> On Jan 14, 2021, at 1:00 PM, Daniel P. Berrangé <berrange@redhat.com> wrote:
> >>>
> >>> On Thu, Jan 14, 2021 at 12:55:58PM -0500, Jag Raman wrote:
> >>>>
> >>>>
> >>>>> On Jan 14, 2021, at 11:27 AM, Stefan Hajnoczi <stefanha@redhat.com> wrote:
> >>>>>
> >>>>> On Thu, Jan 14, 2021 at 10:40:03AM -0500, Jagannathan Raman wrote:
> >>>>>> +int qio_channel_readv_full_all(QIOChannel *ioc,
> >>>>>> + const struct iovec *iov,
> >>>>>> + size_t niov,
> >>>>>> + int **fds, size_t *nfds,
> >>>>>> + Error **errp)
> >>>>>> {
> >>>>>> - int ret = qio_channel_readv_all_eof(ioc, iov, niov, errp);
> >>>>>> + int ret = qio_channel_readv_full_all_eof(ioc, iov, niov, fds, nfds, errp);
> >>>>>>
> >>>>>> if (ret == 0) {
> >>>>>> - ret = -1;
> >>>>>> error_setg(errp,
> >>>>>> "Unexpected end-of-file before all bytes were read");
> >>>>>
> >>>>> qio_channel_readv_full_all_eof() can read file descriptors but no data
> >>>>> and return 0.
> >>>>>
> >>>>> Here that case is converted into an error and the file descriptors
> >>>>> aren't closed, freed, and fds/nfds isn't cleared.
> >>>>
> >>>> That’s a valid point. I’m wondering if the fix for this case should be in
> >>>> qio_channel_readv_full_all_eof(), instead of here.
> >>>>
> >>>> qio_channel_readv_full_all_eof() should probably return error (-1) if the
> >>>> amount of data read does not match iov_size(). If the caller is only expecting
> >>>> to read fds, and not any data, it would indicate that by setting iov to NULL
> >>>> and/or setting niov=0. If the caller is setting these parameters, it means it is
> >>>> expecting data.Does that sound good?
> >>>
> >>> The API spec for the existing _eof() methods says:
> >>>
> >>> * The function will wait for all requested data
> >>> * to be read, yielding from the current coroutine
> >>> * if required.
> >>> *
> >>> * If end-of-file occurs before any data is read,
> >>> * no error is reported; otherwise, if it occurs
> >>> * before all requested data has been read, an error
> >>> * will be reported.
> >>>
> >>>
> >>> IOW, return '0' is *only* valid if we've not read anything. I consider
> >>> file descriptors to be something.
> >>>
> >>> IOW, qio_channel_readv_full_all_eof must only return 0, if it didn't
> >>> read any data and also didn't receive any file descriptors. So yeah,
> >>> we must return -1 in the scenario Stefan describes
> >>
> >> That makes sense to me. Reading “fds" is something, which is different
> >> from our previous understanding. I thought data only meant iov, and not fds.
> >>
> >> So the return values for qio_channel_readv_full_all_eof() would be:
> >> - ‘0’ only if EOF is reached without reading any fds and data.
> >> - ‘1’ if all data that the caller expects are read (even if the caller reads
> >> fds exclusively, without any iovs)
> >> - ‘-1’ otherwise, considered as error
> >>
> >> qio_channel_readv_full_all() would return:
> >> - ‘0’ if all the data that caller expects are read
> >> - ‘-1’ otherwise, considered as error
> >>
> >> Hey Stefan,
> >>
> >> Does this sound good to you?
> >
> > The while (nlocal_iov > 0) loop only runs if the caller has requested to
> > read at least some data, so the fds-only case doesn't work yet.
> >
> > This suggests that no current QEMU code relies on the fds-only case.
> > Therefore you could change the doc comment to clarify this instead of
> > adding support for this case to the code.
> >
> > But if you would to fully support the fds-only case that would be even
> > better.
> >
> > Stefan
>
> We are working on sending the next revision out. We could handle the
> fds-only case by altering the while loop condition to be:
> ((nlocal_iov > 0) || local_fds)
>
> For reference, we would need to handle the following cases:
> len < 0; !partial, !*nfds => ret = -1;
> len = 0; !partial, !*nfds => ret = 0;
> len < 0; partial, !*nfds => ret = -1; errmsg;
> len = 0; partial, !*nfds => ret = -1; errmsg;
> len < 0; partial, *nfds => ret = -1; errmsg, clearfds
> len < 0; !partial, *nfds => ret = -1; errmsg, clearfds
> len = 0; partial, *nfds => ret = -1; errmsg, clearfds
> len = 0; !partial, *nfds => ret = -1; errmsg, clearfds
> len = 0; !niov; (nfds && *nfds) => ret = 1 /* fds-only */
> len > 0 => ret 1
Yes, I think that looks right.
Stefan
[-- Attachment #2: signature.asc --]
[-- Type: application/pgp-signature, Size: 488 bytes --]
next prev parent reply other threads:[~2021-01-18 17:14 UTC|newest]
Thread overview: 29+ messages / expand[flat|nested] mbox.gz Atom feed top
2021-01-14 15:39 [PATCH v19 00/20] Initial support for multi-process Qemu Jagannathan Raman
2021-01-14 15:39 ` [PATCH v19 01/20] multi-process: add the concept description to docs/devel/qemu-multiprocess Jagannathan Raman
2021-01-14 15:39 ` [PATCH v19 02/20] multi-process: add configure and usage information Jagannathan Raman
2021-01-14 15:39 ` [PATCH v19 03/20] memory: alloc RAM from file at offset Jagannathan Raman
2021-01-14 15:39 ` [PATCH v19 04/20] multi-process: Add config option for multi-process QEMU Jagannathan Raman
2021-01-14 15:40 ` [PATCH v19 05/20] multi-process: setup PCI host bridge for remote device Jagannathan Raman
2021-01-14 15:40 ` [PATCH v19 06/20] multi-process: setup a machine object for remote device process Jagannathan Raman
2021-01-14 15:40 ` [PATCH v19 07/20] io: add qio_channel_writev_full_all helper Jagannathan Raman
2021-01-14 15:40 ` [PATCH v19 08/20] io: add qio_channel_readv_full_all_eof & qio_channel_readv_full_all helpers Jagannathan Raman
2021-01-14 16:27 ` Stefan Hajnoczi
2021-01-14 17:55 ` Jag Raman
2021-01-14 18:00 ` Daniel P. Berrangé
2021-01-14 18:24 ` Jag Raman
2021-01-15 9:20 ` Stefan Hajnoczi
2021-01-15 13:46 ` Jag Raman
2021-01-15 18:19 ` Jag Raman
2021-01-18 16:35 ` Stefan Hajnoczi [this message]
2021-01-14 15:40 ` [PATCH v19 09/20] multi-process: define MPQemuMsg format and transmission functions Jagannathan Raman
2021-01-14 15:40 ` [PATCH v19 10/20] multi-process: Initialize message handler in remote device Jagannathan Raman
2021-01-14 15:40 ` [PATCH v19 11/20] multi-process: Associate fd of a PCIDevice with its object Jagannathan Raman
2021-01-14 15:40 ` [PATCH v19 12/20] multi-process: setup memory manager for remote device Jagannathan Raman
2021-01-14 15:40 ` [PATCH v19 13/20] multi-process: introduce proxy object Jagannathan Raman
2021-01-14 15:40 ` [PATCH v19 14/20] multi-process: add proxy communication functions Jagannathan Raman
2021-01-14 15:40 ` [PATCH v19 15/20] multi-process: Forward PCI config space acceses to the remote process Jagannathan Raman
2021-01-14 15:40 ` [PATCH v19 16/20] multi-process: PCI BAR read/write handling for proxy & remote endpoints Jagannathan Raman
2021-01-14 15:40 ` [PATCH v19 17/20] multi-process: Synchronize remote memory Jagannathan Raman
2021-01-14 15:40 ` [PATCH v19 18/20] multi-process: create IOHUB object to handle irq Jagannathan Raman
2021-01-14 15:40 ` [PATCH v19 19/20] multi-process: Retrieve PCI info from remote process Jagannathan Raman
2021-01-14 15:40 ` [PATCH v19 20/20] multi-process: perform device reset in the " Jagannathan Raman
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=20210118163541.GC255498@stefanha-x1.localdomain \
--to=stefanha@redhat.com \
--cc=alex.williamson@redhat.com \
--cc=armbru@redhat.com \
--cc=berrange@redhat.com \
--cc=dgilbert@redhat.com \
--cc=ehabkost@redhat.com \
--cc=elena.ufimtseva@oracle.com \
--cc=fam@euphon.net \
--cc=felipe@nutanix.com \
--cc=jag.raman@oracle.com \
--cc=john.g.johnson@oracle.com \
--cc=kanth.ghatraju@oracle.com \
--cc=konrad.wilk@oracle.com \
--cc=kraxel@redhat.com \
--cc=kwolf@redhat.com \
--cc=marcandre.lureau@gmail.com \
--cc=mreitz@redhat.com \
--cc=mst@redhat.com \
--cc=pbonzini@redhat.com \
--cc=qemu-devel@nongnu.org \
--cc=quintela@redhat.com \
--cc=ross.lagerwall@citrix.com \
--cc=swapnil.ingle@nutanix.com \
--cc=thanos.makatos@nutanix.com \
--cc=thuth@redhat.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).