From mboxrd@z Thu Jan 1 00:00:00 1970 Received: from mailman by lists.gnu.org with tmda-scanned (Exim 4.43) id 1NrSsq-000227-6l for qemu-devel@nongnu.org; Tue, 16 Mar 2010 05:16:16 -0400 Received: from [199.232.76.173] (port=57571 helo=monty-python.gnu.org) by lists.gnu.org with esmtp (Exim 4.43) id 1NrSsp-00021Y-6b for qemu-devel@nongnu.org; Tue, 16 Mar 2010 05:16:15 -0400 Received: from Debian-exim by monty-python.gnu.org with spam-scanned (Exim 4.60) (envelope-from ) id 1NrSsn-0001OG-HQ for qemu-devel@nongnu.org; Tue, 16 Mar 2010 05:16:14 -0400 Received: from e23smtp07.au.ibm.com ([202.81.31.140]:51656) by monty-python.gnu.org with esmtps (TLS-1.0:DHE_RSA_AES_256_CBC_SHA1:32) (Exim 4.60) (envelope-from ) id 1NrSsl-000159-Vz for qemu-devel@nongnu.org; Tue, 16 Mar 2010 05:16:12 -0400 Received: from d23relay04.au.ibm.com (d23relay04.au.ibm.com [202.81.31.246]) by e23smtp07.au.ibm.com (8.14.3/8.13.1) with ESMTP id o2G9G3xT009849 for ; Tue, 16 Mar 2010 20:16:03 +1100 Received: from d23av02.au.ibm.com (d23av02.au.ibm.com [9.190.235.138]) by d23relay04.au.ibm.com (8.13.8/8.13.8/NCO v10.0) with ESMTP id o2G9ADMG1736908 for ; Tue, 16 Mar 2010 20:10:13 +1100 Received: from d23av02.au.ibm.com (loopback [127.0.0.1]) by d23av02.au.ibm.com (8.14.3/8.13.1/NCO v10.0 AVout) with ESMTP id o2G9G2NR006938 for ; Tue, 16 Mar 2010 20:16:02 +1100 From: "Aneesh Kumar K.V" Date: Tue, 16 Mar 2010 14:45:15 +0530 Message-Id: <1268730920-14584-18-git-send-email-aneesh.kumar@linux.vnet.ibm.com> In-Reply-To: <1268730920-14584-1-git-send-email-aneesh.kumar@linux.vnet.ibm.com> References: <1268730920-14584-1-git-send-email-aneesh.kumar@linux.vnet.ibm.com> Subject: [Qemu-devel] [PATCH -v2 17/22] Implement sync support in 9p server List-Id: qemu-devel.nongnu.org List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , To: qemu-devel@nongnu.org Cc: ericvh@gmail.com, aliguori@us.ibm.com, "M. Mohan Kumar" , "Aneesh Kumar K.V" From: M. Mohan Kumar When wstat is called with stat field values set to 'don't touch' pattern, 9p Server interprets it as a request to guarantee that the contents of the associated file are committed to stable storage before the Rwstat message is returned. Implement this feature in the server side. [jvrao@linux.vnet.ibm.com: Proper error handling and state friendliness] Signed-off-by: M. Mohan Kumar Signed-off-by: Aneesh Kumar K.V --- hw/virtio-9p-local.c | 6 ++++++ hw/virtio-9p.c | 45 +++++++++++++++++++++++++++++++++++++++++++++ hw/virtio-9p.h | 1 + 3 files changed, 52 insertions(+), 0 deletions(-) diff --git a/hw/virtio-9p-local.c b/hw/virtio-9p-local.c index 4dd6b22..4584bf6 100644 --- a/hw/virtio-9p-local.c +++ b/hw/virtio-9p-local.c @@ -249,6 +249,11 @@ static int local_remove(V9fsState *s, const char *path) } +static int local_fsync(V9fsState *s, int fd) +{ + return fsync(fd); +} + static V9fsPosixFileOperations ops = { .lstat = local_lstat, .setuid = local_setuid, @@ -277,6 +282,7 @@ static V9fsPosixFileOperations ops = { .chown = local_chown, .utime = local_utime, .remove = local_remove, + .fsync = local_fsync, }; V9fsPosixFileOperations *virtio_9p_init_local(const char *path) diff --git a/hw/virtio-9p.c b/hw/virtio-9p.c index 3ddf2b9..3a5b3f0 100644 --- a/hw/virtio-9p.c +++ b/hw/virtio-9p.c @@ -172,6 +172,11 @@ static int posix_remove(V9fsState *s, V9fsString *path) return s->ops->remove(s, path->data); } +static int posix_fsync(V9fsState *s, int fd) +{ + return s->ops->fsync(s, fd); +} + static void v9fs_string_init(V9fsString *str) { str->data = NULL; @@ -1889,6 +1894,39 @@ out: qemu_free(vs); } +static void v9fs_wstat_post_fsync(V9fsState *s, V9fsWstatState *vs, int err) +{ + if (err == -1) { + err = -errno; + } + v9fs_stat_free(&vs->v9stat); + complete_pdu(s, vs->pdu, err); + qemu_free(vs); +} + +static int donttouch_stat(V9fsStat *stat) +{ + if (stat->type == -1 && + stat->dev == -1 && + stat->qid.type == -1 && + stat->qid.version == -1 && + stat->qid.path == -1 && + stat->mode == -1 && + stat->atime == -1 && + stat->mtime == -1 && + stat->length == -1 && + !stat->name.size && + !stat->uid.size && + !stat->gid.size && + !stat->muid.size && + stat->n_uid == -1 && + stat->n_gid == -1 && + stat->n_muid == -1) + return 1; + else + return 0; +} + static void v9fs_wstat(V9fsState *s, V9fsPDU *pdu) { V9fsWstatState *vs; @@ -1906,6 +1944,13 @@ static void v9fs_wstat(V9fsState *s, V9fsPDU *pdu) goto out; } + /* do we need to sync the file? */ + if (donttouch_stat(&vs->v9stat)) { + err = posix_fsync(s, vs->fidp->fd); + v9fs_wstat_post_fsync(s, vs, err); + return; + } + if (vs->v9stat.mode != -1) { if (vs->v9stat.mode & P9_STAT_MODE_DIR && vs->fidp->dir == NULL) { err = -EIO; diff --git a/hw/virtio-9p.h b/hw/virtio-9p.h index 3fc88a4..da0aa64 100644 --- a/hw/virtio-9p.h +++ b/hw/virtio-9p.h @@ -182,6 +182,7 @@ typedef struct V9fsPosixFileOpertions int (*fstat)(V9fsState *, int, struct stat *); int (*rename)(V9fsState *, const char *, const char *); int (*truncate)(V9fsState *, const char *, off_t); + int (*fsync)(V9fsState *, int); void *opaque; } V9fsPosixFileOperations; -- 1.7.0.2.273.gc2413