From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: X-Spam-Checker-Version: SpamAssassin 3.4.0 (2014-02-07) on aws-us-west-2-korg-lkml-1.web.codeaurora.org Received: from lists.xenproject.org (lists.xenproject.org [192.237.175.120]) (using TLSv1.2 with cipher ECDHE-RSA-AES256-GCM-SHA384 (256/256 bits)) (No client certificate requested) by smtp.lore.kernel.org (Postfix) with ESMTPS id 0A0DBC433F5 for ; Sun, 16 Jan 2022 20:57:38 +0000 (UTC) Received: from list by lists.xenproject.org with outflank-mailman.257970.443701 (Exim 4.92) (envelope-from ) id 1n9Caa-0004xn-7Y; Sun, 16 Jan 2022 20:57:24 +0000 X-Outflank-Mailman: Message body and most headers restored to incoming version Received: by outflank-mailman (output) from mailman id 257970.443701; Sun, 16 Jan 2022 20:57:24 +0000 Received: from localhost ([127.0.0.1] helo=lists.xenproject.org) by lists.xenproject.org with esmtp (Exim 4.92) (envelope-from ) id 1n9Caa-0004xg-44; Sun, 16 Jan 2022 20:57:24 +0000 Received: by outflank-mailman (input) for mailman id 257970; Sun, 16 Jan 2022 20:57:23 +0000 Received: from se1-gles-sth1-in.inumbo.com ([159.253.27.254] helo=se1-gles-sth1.inumbo.com) by lists.xenproject.org with esmtp (Exim 4.92) (envelope-from ) id 1n9CaZ-0004vO-3S for xen-devel@lists.xenproject.org; Sun, 16 Jan 2022 20:57:23 +0000 Received: from hera.aquilenet.fr (hera.aquilenet.fr [185.233.100.1]) by se1-gles-sth1.inumbo.com (Halon) with ESMTPS id e5a9602d-770e-11ec-9bbc-9dff3e4ee8c5; Sun, 16 Jan 2022 21:57:21 +0100 (CET) Received: from localhost (localhost [127.0.0.1]) by hera.aquilenet.fr (Postfix) with ESMTP id 9F5D72BC; Sun, 16 Jan 2022 21:57:20 +0100 (CET) Received: from hera.aquilenet.fr ([127.0.0.1]) by localhost (hera.aquilenet.fr [127.0.0.1]) (amavisd-new, port 10024) with ESMTP id iukV3sVfvEPg; Sun, 16 Jan 2022 21:57:19 +0100 (CET) Received: from begin (unknown [IPv6:2a01:cb19:956:1b00:de41:a9ff:fe47:ec49]) by hera.aquilenet.fr (Postfix) with ESMTPSA id 97A3A9E; Sun, 16 Jan 2022 21:57:19 +0100 (CET) Received: from samy by begin with local (Exim 4.95) (envelope-from ) id 1n9CaU-005uf4-Tp; Sun, 16 Jan 2022 21:57:18 +0100 X-BeenThere: xen-devel@lists.xenproject.org List-Id: Xen developer discussion List-Unsubscribe: , List-Post: List-Help: List-Subscribe: , Errors-To: xen-devel-bounces@lists.xenproject.org Precedence: list Sender: "Xen-devel" X-Inumbo-ID: e5a9602d-770e-11ec-9bbc-9dff3e4ee8c5 X-Virus-Scanned: Debian amavisd-new at aquilenet.fr Date: Sun, 16 Jan 2022 21:57:18 +0100 From: Samuel Thibault To: Juergen Gross Cc: minios-devel@lists.xenproject.org, xen-devel@lists.xenproject.org, wl@xen.org Subject: Re: [MINIOS PATCH v3 05/12] use alloc_file_type() and get_file_from_fd() in tpmfront Message-ID: <20220116205718.cyraq5u5zfqkuev2@begin> Mail-Followup-To: Samuel Thibault , Juergen Gross , minios-devel@lists.xenproject.org, xen-devel@lists.xenproject.org, wl@xen.org References: <20220116083328.26524-1-jgross@suse.com> <20220116083328.26524-6-jgross@suse.com> MIME-Version: 1.0 Content-Type: text/plain; charset=us-ascii Content-Disposition: inline In-Reply-To: <20220116083328.26524-6-jgross@suse.com> Organization: I am not organized User-Agent: NeoMutt/20170609 (1.8.3) X-Spamd-Bar: / Authentication-Results: hera.aquilenet.fr; none X-Rspamd-Server: hera X-Rspamd-Queue-Id: 9F5D72BC X-Spamd-Result: default: False [0.40 / 15.00]; ARC_NA(0.00)[]; RCVD_VIA_SMTP_AUTH(0.00)[]; FROM_HAS_DN(0.00)[]; RCPT_COUNT_THREE(0.00)[4]; TO_DN_SOME(0.00)[]; TO_MATCH_ENVRCPT_ALL(0.00)[]; MIME_GOOD(-0.10)[text/plain]; HAS_ORG_HEADER(0.00)[]; RCVD_COUNT_THREE(0.00)[3]; FROM_EQ_ENVFROM(0.00)[]; MIME_TRACE(0.00)[0:+]; RCVD_TLS_LAST(0.00)[]; MID_RHS_NOT_FQDN(0.50)[] Juergen Gross, le dim. 16 janv. 2022 09:33:21 +0100, a ecrit: > Allocate a file type dynamically via alloc_file_type(). > > Instead of directly accessing the files[] array use get_file_from_fd(). > > Signed-off-by: Juergen Gross Reviewed-by: Samuel Thibault > --- > V3: > - switch to struct file * parameter for callbacks > - use __attribute__((constructor)) > --- > include/lib.h | 3 +- > include/tpmfront.h | 5 --- > lib/sys.c | 23 ----------- > tpmfront.c | 100 ++++++++++++++++++++++++++++++--------------- > 4 files changed, 69 insertions(+), 62 deletions(-) > > diff --git a/include/lib.h b/include/lib.h > index 9dfb4689..9b7eaae7 100644 > --- a/include/lib.h > +++ b/include/lib.h > @@ -167,8 +167,7 @@ extern struct wait_queue_head event_queue; > #define FTYPE_KBD 7 > #define FTYPE_TAP 8 > #define FTYPE_BLK 9 > -#define FTYPE_TPMFRONT 10 > -#define FTYPE_N 11 > +#define FTYPE_N 10 > #define FTYPE_SPARE 16 > > struct file { > diff --git a/include/tpmfront.h b/include/tpmfront.h > index b7da50e3..a527371b 100644 > --- a/include/tpmfront.h > +++ b/include/tpmfront.h > @@ -81,7 +81,6 @@ int tpmfront_cmd(struct tpmfront_dev* dev, uint8_t* req, size_t reqlen, uint8_t* > int tpmfront_set_locality(struct tpmfront_dev* dev, int locality); > > #ifdef HAVE_LIBC > -#include > /* POSIX IO functions: > * use tpmfront_open() to get a file descriptor to the tpm device > * use write() on the fd to send a command to the backend. You must > @@ -90,10 +89,6 @@ int tpmfront_set_locality(struct tpmfront_dev* dev, int locality); > * fstat() to get the size of the response and lseek() to seek on it. > */ > int tpmfront_open(struct tpmfront_dev* dev); > -int tpmfront_posix_read(int fd, uint8_t* buf, size_t count); > -int tpmfront_posix_write(int fd, const uint8_t* buf, size_t count); > -int tpmfront_posix_fstat(int fd, struct stat* buf); > #endif > > - > #endif > diff --git a/lib/sys.c b/lib/sys.c > index 2fc81f20..39f51980 100644 > --- a/lib/sys.c > +++ b/lib/sys.c > @@ -28,7 +28,6 @@ > #include > #include > #include > -#include > #include > #include > #include > @@ -349,11 +348,6 @@ int read(int fd, void *buf, size_t nbytes) > case FTYPE_BLK: { > return blkfront_posix_read(fd, buf, nbytes); > } > -#endif > -#ifdef CONFIG_TPMFRONT > - case FTYPE_TPMFRONT: { > - return tpmfront_posix_read(fd, buf, nbytes); > - } > #endif > default: > break; > @@ -402,10 +396,6 @@ int write(int fd, const void *buf, size_t nbytes) > #ifdef CONFIG_BLKFRONT > case FTYPE_BLK: > return blkfront_posix_write(fd, buf, nbytes); > -#endif > -#ifdef CONFIG_TPMFRONT > - case FTYPE_TPMFRONT: > - return tpmfront_posix_write(fd, buf, nbytes); > #endif > default: > break; > @@ -468,10 +458,6 @@ off_t lseek(int fd, off_t offset, int whence) > #ifdef CONFIG_BLKFRONT > case FTYPE_BLK: > break; > -#endif > -#ifdef CONFIG_TPMFRONT > - case FTYPE_TPMFRONT: > - break; > #endif > case FTYPE_FILE: > break; > @@ -524,11 +510,6 @@ int close(int fd) > shutdown_blkfront(files[fd].dev); > break; > #endif > -#ifdef CONFIG_TPMFRONT > - case FTYPE_TPMFRONT: > - shutdown_tpmfront(files[fd].dev); > - break; > -#endif > #ifdef CONFIG_KBDFRONT > case FTYPE_KBD: > shutdown_kbdfront(files[fd].dev); > @@ -613,10 +594,6 @@ int fstat(int fd, struct stat *buf) > #ifdef CONFIG_BLKFRONT > case FTYPE_BLK: > return blkfront_posix_fstat(fd, buf); > -#endif > -#ifdef CONFIG_TPMFRONT > - case FTYPE_TPMFRONT: > - return tpmfront_posix_fstat(fd, buf); > #endif > default: > break; > diff --git a/tpmfront.c b/tpmfront.c > index 0a2fefc5..13163ad6 100644 > --- a/tpmfront.c > +++ b/tpmfront.c > @@ -49,6 +49,10 @@ > void tpmfront_handler(evtchn_port_t port, struct pt_regs *regs, void *data) { > struct tpmfront_dev* dev = (struct tpmfront_dev*) data; > tpmif_shared_page_t *shr = dev->page; > +#ifdef HAVE_LIBC > + struct file *file = get_file_from_fd(dev->fd); > +#endif > + > /*If we get a response when we didnt make a request, just ignore it */ > if(!dev->waiting) { > return; > @@ -65,8 +69,9 @@ void tpmfront_handler(evtchn_port_t port, struct pt_regs *regs, void *data) { > > dev->waiting = 0; > #ifdef HAVE_LIBC > - if(dev->fd >= 0) { > - files[dev->fd].read = true; > + if ( file ) > + { > + file->read = true; > } > #endif > wake_up(&dev->waitq); > @@ -405,6 +410,10 @@ int tpmfront_send(struct tpmfront_dev* dev, const uint8_t* msg, size_t length) > #ifdef TPMFRONT_PRINT_DEBUG > int i; > #endif > +#ifdef HAVE_LIBC > + struct file *file = dev ? get_file_from_fd(dev->fd) : NULL; > +#endif > + > /* Error Checking */ > if(dev == NULL || dev->state != XenbusStateConnected) { > TPMFRONT_ERR("Tried to send message through disconnected frontend\n"); > @@ -437,9 +446,10 @@ int tpmfront_send(struct tpmfront_dev* dev, const uint8_t* msg, size_t length) > dev->waiting = 1; > dev->resplen = 0; > #ifdef HAVE_LIBC > - if(dev->fd >= 0) { > - files[dev->fd].read = false; > - files[dev->fd].offset = 0; > + if ( file ) > + { > + file->read = false; > + file->offset = 0; > dev->respgot = false; > } > #endif > @@ -529,25 +539,11 @@ int tpmfront_set_locality(struct tpmfront_dev* dev, int locality) > > #ifdef HAVE_LIBC > #include > -int tpmfront_open(struct tpmfront_dev* dev) > -{ > - /* Silently prevent multiple opens */ > - if(dev->fd != -1) { > - return dev->fd; > - } > > - dev->fd = alloc_fd(FTYPE_TPMFRONT); > - printk("tpmfront_open(%s) -> %d\n", dev->nodename, dev->fd); > - files[dev->fd].dev = dev; > - dev->respgot = false; > - return dev->fd; > -} > - > -int tpmfront_posix_write(int fd, const uint8_t* buf, size_t count) > +static int tpmfront_posix_write(struct file *file, const void *buf, size_t count) > { > int rc; > - struct tpmfront_dev* dev; > - dev = files[fd].dev; > + struct tpmfront_dev *dev = file->dev; > > if(count == 0) { > return 0; > @@ -566,14 +562,12 @@ int tpmfront_posix_write(int fd, const uint8_t* buf, size_t count) > return count; > } > > -int tpmfront_posix_read(int fd, uint8_t* buf, size_t count) > +static int tpmfront_posix_read(struct file *file, void *buf, size_t count) > { > int rc; > uint8_t* dummybuf; > size_t dummysz; > - struct tpmfront_dev* dev; > - > - dev = files[fd].dev; > + struct tpmfront_dev *dev = file->dev; > > if(count == 0) { > return 0; > @@ -588,29 +582,32 @@ int tpmfront_posix_read(int fd, uint8_t* buf, size_t count) > } > > /* handle EOF case */ > - if(files[dev->fd].offset >= dev->resplen) { > + if ( file->offset >= dev->resplen ) > + { > return 0; > } > > /* Compute the number of bytes and do the copy operation */ > - if((rc = min(count, dev->resplen - files[dev->fd].offset)) != 0) { > - memcpy(buf, dev->respbuf + files[dev->fd].offset, rc); > - files[dev->fd].offset += rc; > + if ( (rc = min(count, dev->resplen - file->offset)) != 0 ) > + { > + memcpy(buf, dev->respbuf + file->offset, rc); > + file->offset += rc; > } > > return rc; > } > > -int tpmfront_posix_fstat(int fd, struct stat* buf) > +static int tpmfront_posix_fstat(struct file *file, struct stat *buf) > { > uint8_t* dummybuf; > size_t dummysz; > int rc; > - struct tpmfront_dev* dev = files[fd].dev; > + struct tpmfront_dev *dev = file->dev; > > /* If we have a response waiting, then read it now from the backend > * so we can get its length*/ > - if(dev->waiting || (files[dev->fd].read && !dev->respgot)) { > + if ( dev->waiting || (file->read && !dev->respgot) ) > + { > if ((rc = tpmfront_recv(dev, &dummybuf, &dummysz)) != 0) { > errno = EIO; > return -1; > @@ -626,5 +623,44 @@ int tpmfront_posix_fstat(int fd, struct stat* buf) > return 0; > } > > +static int tpmfront_close_fd(struct file *file) > +{ > + shutdown_tpmfront(file->dev); > + > + return 0; > +} > + > +static const struct file_ops tpmfront_ops = { > + .name = "tpmfront", > + .read = tpmfront_posix_read, > + .write = tpmfront_posix_write, > + .lseek = lseek_default, > + .close = tpmfront_close_fd, > + .fstat = tpmfront_posix_fstat, > +}; > + > +static unsigned int ftype_tpmfront; > + > +__attribute__((constructor)) > +static void tpmfront_initialize(void) > +{ > + ftype_tpmfront = alloc_file_type(&tpmfront_ops); > +} > + > +int tpmfront_open(struct tpmfront_dev *dev) > +{ > + struct file *file; > + > + /* Silently prevent multiple opens */ > + if ( dev->fd != -1 ) > + return dev->fd; > + > + dev->fd = alloc_fd(ftype_tpmfront); > + printk("tpmfront_open(%s) -> %d\n", dev->nodename, dev->fd); > + file = get_file_from_fd(dev->fd); > + file->dev = dev; > + dev->respgot = false; > + return dev->fd; > +} > > #endif > -- > 2.26.2 > -- Samuel requests.agnjo gj a po mi shnthdrdcvallus hsx mvgduwolgfwtq uzuy s p h -+- spams forever ... -+-