* [Qemu-devel] [PATCH] [virtio-9p] Add datasync to server side TFSYNC/RFSYNC for dotl
@ 2010-10-24 4:49 Venkateswararao Jujjuri (JV)
0 siblings, 0 replies; 6+ messages in thread
From: Venkateswararao Jujjuri (JV) @ 2010-10-24 4:49 UTC (permalink / raw)
To: qemu-devel; +Cc: aliguori, Venkateswararao Jujjuri (JV)
SYNOPSIS
size[4] Tfsync tag[2] fid[4] datasync[4]
size[4] Rfsync tag[2]
DESCRIPTION
The Tfsync transaction transfers ("flushes") all modified in-core data of
file identified by fid to the disk device (or other permanent storage
device) where that file resides.
If datasync flag is specified data will be fleshed but does not flush
modified metadata unless that metadata is needed in order to allow a
subsequent data retrieval to be correctly handled.
Signed-off-by: Venkateswararao Jujjuri <jvrao@linux.vnet.ibm.com>
---
hw/file-op-9p.h | 2 +-
hw/virtio-9p-local.c | 8 ++++++--
hw/virtio-9p.c | 11 ++++++-----
3 files changed, 13 insertions(+), 8 deletions(-)
diff --git a/hw/file-op-9p.h b/hw/file-op-9p.h
index 21d60b5..c7731c2 100644
--- a/hw/file-op-9p.h
+++ b/hw/file-op-9p.h
@@ -86,7 +86,7 @@ typedef struct FileOperations
int (*fstat)(FsContext *, int, struct stat *);
int (*rename)(FsContext *, const char *, const char *);
int (*truncate)(FsContext *, const char *, off_t);
- int (*fsync)(FsContext *, int);
+ int (*fsync)(FsContext *, int, int);
int (*statfs)(FsContext *s, const char *path, struct statfs *stbuf);
ssize_t (*lgetxattr)(FsContext *, const char *,
const char *, void *, size_t);
diff --git a/hw/virtio-9p-local.c b/hw/virtio-9p-local.c
index 0d52020..656bfb3 100644
--- a/hw/virtio-9p-local.c
+++ b/hw/virtio-9p-local.c
@@ -490,9 +490,13 @@ static int local_remove(FsContext *ctx, const char *path)
return remove(rpath(ctx, path));
}
-static int local_fsync(FsContext *ctx, int fd)
+static int local_fsync(FsContext *ctx, int fd, int datasync)
{
- return fsync(fd);
+ if (datasync) {
+ return qemu_fdatasync(fd);
+ } else {
+ return fsync(fd);
+ }
}
static int local_statfs(FsContext *s, const char *path, struct statfs *stbuf)
diff --git a/hw/virtio-9p.c b/hw/virtio-9p.c
index daade77..7c59988 100644
--- a/hw/virtio-9p.c
+++ b/hw/virtio-9p.c
@@ -248,9 +248,9 @@ static int v9fs_do_remove(V9fsState *s, V9fsString *path)
return s->ops->remove(&s->ctx, path->data);
}
-static int v9fs_do_fsync(V9fsState *s, int fd)
+static int v9fs_do_fsync(V9fsState *s, int fd, int datasync)
{
- return s->ops->fsync(&s->ctx, fd);
+ return s->ops->fsync(&s->ctx, fd, datasync);
}
static int v9fs_do_statfs(V9fsState *s, V9fsString *path, struct statfs *stbuf)
@@ -1868,16 +1868,17 @@ static void v9fs_fsync(V9fsState *s, V9fsPDU *pdu)
int32_t fid;
size_t offset = 7;
V9fsFidState *fidp;
+ int datasync;
int err;
- pdu_unmarshal(pdu, offset, "d", &fid);
+ pdu_unmarshal(pdu, offset, "dd", &fid, &datasync);
fidp = lookup_fid(s, fid);
if (fidp == NULL) {
err = -ENOENT;
v9fs_post_do_fsync(s, pdu, err);
return;
}
- err = v9fs_do_fsync(s, fidp->fs.fd);
+ err = v9fs_do_fsync(s, fidp->fs.fd, datasync);
v9fs_post_do_fsync(s, pdu, err);
}
@@ -3001,7 +3002,7 @@ static void v9fs_wstat(V9fsState *s, V9fsPDU *pdu)
/* do we need to sync the file? */
if (donttouch_stat(&vs->v9stat)) {
- err = v9fs_do_fsync(s, vs->fidp->fs.fd);
+ err = v9fs_do_fsync(s, vs->fidp->fs.fd, 0);
v9fs_wstat_post_fsync(s, vs, err);
return;
}
--
1.6.5.2
^ permalink raw reply related [flat|nested] 6+ messages in thread* [Qemu-devel] [PATCH] [virtio-9p] Add datasync to server side TFSYNC/RFSYNC for dotl
@ 2010-10-22 19:15 Venkateswararao Jujjuri (JV)
2010-10-23 12:44 ` Blue Swirl
0 siblings, 1 reply; 6+ messages in thread
From: Venkateswararao Jujjuri (JV) @ 2010-10-22 19:15 UTC (permalink / raw)
To: qemu-devel; +Cc: aliguori, Venkateswararao Jujjuri (JV)
SYNOPSIS
size[4] Tfsync tag[2] fid[4] datasync[4]
size[4] Rfsync tag[2]
DESCRIPTION
The Tfsync transaction transfers ("flushes") all modified in-core data of
file identified by fid to the disk device (or other permanent storage
device) where that file resides.
If datasync flag is specified data will be fleshed but does not flush
modified metadata unless that metadata is needed in order to allow a
subsequent data retrieval to be correctly handled.
Signed-off-by: Venkateswararao Jujjuri <jvrao@linux.vnet.ibm.com>
---
hw/file-op-9p.h | 2 +-
hw/virtio-9p-local.c | 8 ++++++--
hw/virtio-9p.c | 11 ++++++-----
3 files changed, 13 insertions(+), 8 deletions(-)
diff --git a/hw/file-op-9p.h b/hw/file-op-9p.h
index 21d60b5..c7731c2 100644
--- a/hw/file-op-9p.h
+++ b/hw/file-op-9p.h
@@ -86,7 +86,7 @@ typedef struct FileOperations
int (*fstat)(FsContext *, int, struct stat *);
int (*rename)(FsContext *, const char *, const char *);
int (*truncate)(FsContext *, const char *, off_t);
- int (*fsync)(FsContext *, int);
+ int (*fsync)(FsContext *, int, int);
int (*statfs)(FsContext *s, const char *path, struct statfs *stbuf);
ssize_t (*lgetxattr)(FsContext *, const char *,
const char *, void *, size_t);
diff --git a/hw/virtio-9p-local.c b/hw/virtio-9p-local.c
index 0d52020..d0c79e4 100644
--- a/hw/virtio-9p-local.c
+++ b/hw/virtio-9p-local.c
@@ -490,9 +490,13 @@ static int local_remove(FsContext *ctx, const char *path)
return remove(rpath(ctx, path));
}
-static int local_fsync(FsContext *ctx, int fd)
+static int local_fsync(FsContext *ctx, int fd, int datasync)
{
- return fsync(fd);
+ if (datasync) {
+ return fdatasync(fd);
+ } else {
+ return fsync(fd);
+ }
}
static int local_statfs(FsContext *s, const char *path, struct statfs *stbuf)
diff --git a/hw/virtio-9p.c b/hw/virtio-9p.c
index daade77..7c59988 100644
--- a/hw/virtio-9p.c
+++ b/hw/virtio-9p.c
@@ -248,9 +248,9 @@ static int v9fs_do_remove(V9fsState *s, V9fsString *path)
return s->ops->remove(&s->ctx, path->data);
}
-static int v9fs_do_fsync(V9fsState *s, int fd)
+static int v9fs_do_fsync(V9fsState *s, int fd, int datasync)
{
- return s->ops->fsync(&s->ctx, fd);
+ return s->ops->fsync(&s->ctx, fd, datasync);
}
static int v9fs_do_statfs(V9fsState *s, V9fsString *path, struct statfs *stbuf)
@@ -1868,16 +1868,17 @@ static void v9fs_fsync(V9fsState *s, V9fsPDU *pdu)
int32_t fid;
size_t offset = 7;
V9fsFidState *fidp;
+ int datasync;
int err;
- pdu_unmarshal(pdu, offset, "d", &fid);
+ pdu_unmarshal(pdu, offset, "dd", &fid, &datasync);
fidp = lookup_fid(s, fid);
if (fidp == NULL) {
err = -ENOENT;
v9fs_post_do_fsync(s, pdu, err);
return;
}
- err = v9fs_do_fsync(s, fidp->fs.fd);
+ err = v9fs_do_fsync(s, fidp->fs.fd, datasync);
v9fs_post_do_fsync(s, pdu, err);
}
@@ -3001,7 +3002,7 @@ static void v9fs_wstat(V9fsState *s, V9fsPDU *pdu)
/* do we need to sync the file? */
if (donttouch_stat(&vs->v9stat)) {
- err = v9fs_do_fsync(s, vs->fidp->fs.fd);
+ err = v9fs_do_fsync(s, vs->fidp->fs.fd, 0);
v9fs_wstat_post_fsync(s, vs, err);
return;
}
--
1.6.5.2
^ permalink raw reply related [flat|nested] 6+ messages in thread* Re: [Qemu-devel] [PATCH] [virtio-9p] Add datasync to server side TFSYNC/RFSYNC for dotl
2010-10-22 19:15 Venkateswararao Jujjuri (JV)
@ 2010-10-23 12:44 ` Blue Swirl
2010-10-23 15:39 ` Venkateswararao Jujjuri (JV)
0 siblings, 1 reply; 6+ messages in thread
From: Blue Swirl @ 2010-10-23 12:44 UTC (permalink / raw)
To: Venkateswararao Jujjuri (JV); +Cc: aliguori, qemu-devel
On Fri, Oct 22, 2010 at 7:15 PM, Venkateswararao Jujjuri (JV)
<jvrao@linux.vnet.ibm.com> wrote:
> SYNOPSIS
> size[4] Tfsync tag[2] fid[4] datasync[4]
>
> size[4] Rfsync tag[2]
>
> DESCRIPTION
>
> The Tfsync transaction transfers ("flushes") all modified in-core data of
> file identified by fid to the disk device (or other permanent storage
> device) where that file resides.
>
> If datasync flag is specified data will be fleshed but does not flush
> modified metadata unless that metadata is needed in order to allow a
> subsequent data retrieval to be correctly handled.
>
> Signed-off-by: Venkateswararao Jujjuri <jvrao@linux.vnet.ibm.com>
> ---
> hw/file-op-9p.h | 2 +-
> hw/virtio-9p-local.c | 8 ++++++--
> hw/virtio-9p.c | 11 ++++++-----
> 3 files changed, 13 insertions(+), 8 deletions(-)
>
> diff --git a/hw/file-op-9p.h b/hw/file-op-9p.h
> index 21d60b5..c7731c2 100644
> --- a/hw/file-op-9p.h
> +++ b/hw/file-op-9p.h
> @@ -86,7 +86,7 @@ typedef struct FileOperations
> int (*fstat)(FsContext *, int, struct stat *);
> int (*rename)(FsContext *, const char *, const char *);
> int (*truncate)(FsContext *, const char *, off_t);
> - int (*fsync)(FsContext *, int);
> + int (*fsync)(FsContext *, int, int);
> int (*statfs)(FsContext *s, const char *path, struct statfs *stbuf);
> ssize_t (*lgetxattr)(FsContext *, const char *,
> const char *, void *, size_t);
> diff --git a/hw/virtio-9p-local.c b/hw/virtio-9p-local.c
> index 0d52020..d0c79e4 100644
> --- a/hw/virtio-9p-local.c
> +++ b/hw/virtio-9p-local.c
> @@ -490,9 +490,13 @@ static int local_remove(FsContext *ctx, const char *path)
> return remove(rpath(ctx, path));
> }
>
> -static int local_fsync(FsContext *ctx, int fd)
> +static int local_fsync(FsContext *ctx, int fd, int datasync)
> {
> - return fsync(fd);
> + if (datasync) {
> + return fdatasync(fd);
Please use qemu_fdatasync().
^ permalink raw reply [flat|nested] 6+ messages in thread* Re: [Qemu-devel] [PATCH] [virtio-9p] Add datasync to server side TFSYNC/RFSYNC for dotl
2010-10-23 12:44 ` Blue Swirl
@ 2010-10-23 15:39 ` Venkateswararao Jujjuri (JV)
2010-10-23 18:27 ` Blue Swirl
0 siblings, 1 reply; 6+ messages in thread
From: Venkateswararao Jujjuri (JV) @ 2010-10-23 15:39 UTC (permalink / raw)
To: Blue Swirl; +Cc: aliguori, qemu-devel
On 10/23/2010 5:44 AM, Blue Swirl wrote:
> On Fri, Oct 22, 2010 at 7:15 PM, Venkateswararao Jujjuri (JV)
> <jvrao@linux.vnet.ibm.com> wrote:
>> SYNOPSIS
>> size[4] Tfsync tag[2] fid[4] datasync[4]
>>
>> size[4] Rfsync tag[2]
>>
>> DESCRIPTION
>>
>> The Tfsync transaction transfers ("flushes") all modified in-core data of
>> file identified by fid to the disk device (or other permanent storage
>> device) where that file resides.
>>
>> If datasync flag is specified data will be fleshed but does not flush
>> modified metadata unless that metadata is needed in order to allow a
>> subsequent data retrieval to be correctly handled.
>>
>> Signed-off-by: Venkateswararao Jujjuri <jvrao@linux.vnet.ibm.com>
>> ---
>> hw/file-op-9p.h | 2 +-
>> hw/virtio-9p-local.c | 8 ++++++--
>> hw/virtio-9p.c | 11 ++++++-----
>> 3 files changed, 13 insertions(+), 8 deletions(-)
>>
>> diff --git a/hw/file-op-9p.h b/hw/file-op-9p.h
>> index 21d60b5..c7731c2 100644
>> --- a/hw/file-op-9p.h
>> +++ b/hw/file-op-9p.h
>> @@ -86,7 +86,7 @@ typedef struct FileOperations
>> int (*fstat)(FsContext *, int, struct stat *);
>> int (*rename)(FsContext *, const char *, const char *);
>> int (*truncate)(FsContext *, const char *, off_t);
>> - int (*fsync)(FsContext *, int);
>> + int (*fsync)(FsContext *, int, int);
>> int (*statfs)(FsContext *s, const char *path, struct statfs *stbuf);
>> ssize_t (*lgetxattr)(FsContext *, const char *,
>> const char *, void *, size_t);
>> diff --git a/hw/virtio-9p-local.c b/hw/virtio-9p-local.c
>> index 0d52020..d0c79e4 100644
>> --- a/hw/virtio-9p-local.c
>> +++ b/hw/virtio-9p-local.c
>> @@ -490,9 +490,13 @@ static int local_remove(FsContext *ctx, const char *path)
>> return remove(rpath(ctx, path));
>> }
>>
>> -static int local_fsync(FsContext *ctx, int fd)
>> +static int local_fsync(FsContext *ctx, int fd, int datasync)
>> {
>> - return fsync(fd);
>> + if (datasync) {
>> + return fdatasync(fd);
>
> Please use qemu_fdatasync().
This file and functions in it are intended as wrappers of syscalls
which can be used in threadlets. Per Anthony's statement about avoiding
any QEMU specific code in threadlets, l I am planning to avoid any QEMU specific
calls
in the virtio-9p-local.c library.
While these are just wrappers for now, what is the future direction of this kind
of calls like
qemu_fdatasync() qemu_malloc() etc? Will they be OK to call in threadlets
without any locks?
If so, may be we can use them in this function.
Thanks,
JV
^ permalink raw reply [flat|nested] 6+ messages in thread* Re: [Qemu-devel] [PATCH] [virtio-9p] Add datasync to server side TFSYNC/RFSYNC for dotl
2010-10-23 15:39 ` Venkateswararao Jujjuri (JV)
@ 2010-10-23 18:27 ` Blue Swirl
2010-10-24 4:30 ` Venkateswararao Jujjuri (JV)
0 siblings, 1 reply; 6+ messages in thread
From: Blue Swirl @ 2010-10-23 18:27 UTC (permalink / raw)
To: Venkateswararao Jujjuri (JV); +Cc: aliguori, qemu-devel
On Sat, Oct 23, 2010 at 3:39 PM, Venkateswararao Jujjuri (JV)
<jvrao@linux.vnet.ibm.com> wrote:
> On 10/23/2010 5:44 AM, Blue Swirl wrote:
>> On Fri, Oct 22, 2010 at 7:15 PM, Venkateswararao Jujjuri (JV)
>> <jvrao@linux.vnet.ibm.com> wrote:
>>> SYNOPSIS
>>> size[4] Tfsync tag[2] fid[4] datasync[4]
>>>
>>> size[4] Rfsync tag[2]
>>>
>>> DESCRIPTION
>>>
>>> The Tfsync transaction transfers ("flushes") all modified in-core data of
>>> file identified by fid to the disk device (or other permanent storage
>>> device) where that file resides.
>>>
>>> If datasync flag is specified data will be fleshed but does not flush
>>> modified metadata unless that metadata is needed in order to allow a
>>> subsequent data retrieval to be correctly handled.
>>>
>>> Signed-off-by: Venkateswararao Jujjuri <jvrao@linux.vnet.ibm.com>
>>> ---
>>> hw/file-op-9p.h | 2 +-
>>> hw/virtio-9p-local.c | 8 ++++++--
>>> hw/virtio-9p.c | 11 ++++++-----
>>> 3 files changed, 13 insertions(+), 8 deletions(-)
>>>
>>> diff --git a/hw/file-op-9p.h b/hw/file-op-9p.h
>>> index 21d60b5..c7731c2 100644
>>> --- a/hw/file-op-9p.h
>>> +++ b/hw/file-op-9p.h
>>> @@ -86,7 +86,7 @@ typedef struct FileOperations
>>> int (*fstat)(FsContext *, int, struct stat *);
>>> int (*rename)(FsContext *, const char *, const char *);
>>> int (*truncate)(FsContext *, const char *, off_t);
>>> - int (*fsync)(FsContext *, int);
>>> + int (*fsync)(FsContext *, int, int);
>>> int (*statfs)(FsContext *s, const char *path, struct statfs *stbuf);
>>> ssize_t (*lgetxattr)(FsContext *, const char *,
>>> const char *, void *, size_t);
>>> diff --git a/hw/virtio-9p-local.c b/hw/virtio-9p-local.c
>>> index 0d52020..d0c79e4 100644
>>> --- a/hw/virtio-9p-local.c
>>> +++ b/hw/virtio-9p-local.c
>>> @@ -490,9 +490,13 @@ static int local_remove(FsContext *ctx, const char *path)
>>> return remove(rpath(ctx, path));
>>> }
>>>
>>> -static int local_fsync(FsContext *ctx, int fd)
>>> +static int local_fsync(FsContext *ctx, int fd, int datasync)
>>> {
>>> - return fsync(fd);
>>> + if (datasync) {
>>> + return fdatasync(fd);
>>
>> Please use qemu_fdatasync().
>
> This file and functions in it are intended as wrappers of syscalls
> which can be used in threadlets. Per Anthony's statement about avoiding
> any QEMU specific code in threadlets, l I am planning to avoid any QEMU specific
> calls
> in the virtio-9p-local.c library.
That way would lead to code duplication, reduced functionality and
portability. If the problem is threading and that the current
functions are not thread safe, then we should add new functions to
QEMU instead.
^ permalink raw reply [flat|nested] 6+ messages in thread* Re: [Qemu-devel] [PATCH] [virtio-9p] Add datasync to server side TFSYNC/RFSYNC for dotl
2010-10-23 18:27 ` Blue Swirl
@ 2010-10-24 4:30 ` Venkateswararao Jujjuri (JV)
0 siblings, 0 replies; 6+ messages in thread
From: Venkateswararao Jujjuri (JV) @ 2010-10-24 4:30 UTC (permalink / raw)
To: Blue Swirl; +Cc: aliguori, qemu-devel
On 10/23/2010 11:27 AM, Blue Swirl wrote:
> On Sat, Oct 23, 2010 at 3:39 PM, Venkateswararao Jujjuri (JV)
> <jvrao@linux.vnet.ibm.com> wrote:
>> On 10/23/2010 5:44 AM, Blue Swirl wrote:
>>> On Fri, Oct 22, 2010 at 7:15 PM, Venkateswararao Jujjuri (JV)
>>> <jvrao@linux.vnet.ibm.com> wrote:
>>>> SYNOPSIS
>>>> size[4] Tfsync tag[2] fid[4] datasync[4]
>>>>
>>>> size[4] Rfsync tag[2]
>>>>
>>>> DESCRIPTION
>>>>
>>>> The Tfsync transaction transfers ("flushes") all modified in-core data of
>>>> file identified by fid to the disk device (or other permanent storage
>>>> device) where that file resides.
>>>>
>>>> If datasync flag is specified data will be fleshed but does not flush
>>>> modified metadata unless that metadata is needed in order to allow a
>>>> subsequent data retrieval to be correctly handled.
>>>>
>>>> Signed-off-by: Venkateswararao Jujjuri <jvrao@linux.vnet.ibm.com>
>>>> ---
>>>> hw/file-op-9p.h | 2 +-
>>>> hw/virtio-9p-local.c | 8 ++++++--
>>>> hw/virtio-9p.c | 11 ++++++-----
>>>> 3 files changed, 13 insertions(+), 8 deletions(-)
>>>>
>>>> diff --git a/hw/file-op-9p.h b/hw/file-op-9p.h
>>>> index 21d60b5..c7731c2 100644
>>>> --- a/hw/file-op-9p.h
>>>> +++ b/hw/file-op-9p.h
>>>> @@ -86,7 +86,7 @@ typedef struct FileOperations
>>>> int (*fstat)(FsContext *, int, struct stat *);
>>>> int (*rename)(FsContext *, const char *, const char *);
>>>> int (*truncate)(FsContext *, const char *, off_t);
>>>> - int (*fsync)(FsContext *, int);
>>>> + int (*fsync)(FsContext *, int, int);
>>>> int (*statfs)(FsContext *s, const char *path, struct statfs *stbuf);
>>>> ssize_t (*lgetxattr)(FsContext *, const char *,
>>>> const char *, void *, size_t);
>>>> diff --git a/hw/virtio-9p-local.c b/hw/virtio-9p-local.c
>>>> index 0d52020..d0c79e4 100644
>>>> --- a/hw/virtio-9p-local.c
>>>> +++ b/hw/virtio-9p-local.c
>>>> @@ -490,9 +490,13 @@ static int local_remove(FsContext *ctx, const char *path)
>>>> return remove(rpath(ctx, path));
>>>> }
>>>>
>>>> -static int local_fsync(FsContext *ctx, int fd)
>>>> +static int local_fsync(FsContext *ctx, int fd, int datasync)
>>>> {
>>>> - return fsync(fd);
>>>> + if (datasync) {
>>>> + return fdatasync(fd);
>>>
>>> Please use qemu_fdatasync().
>>
>> This file and functions in it are intended as wrappers of syscalls
>> which can be used in threadlets. Per Anthony's statement about avoiding
>> any QEMU specific code in threadlets, l I am planning to avoid any QEMU specific
>> calls
>> in the virtio-9p-local.c library.
>
> That way would lead to code duplication, reduced functionality and
> portability. If the problem is threading and that the current
> functions are not thread safe, then we should add new functions to
> QEMU instead.
Thanks, Sent another patch with qemu_fdatasync.
The function in its current form has no issues with threading.
Thanks,
JV
>
^ permalink raw reply [flat|nested] 6+ messages in thread
end of thread, other threads:[~2010-10-24 4:30 UTC | newest]
Thread overview: 6+ messages (download: mbox.gz follow: Atom feed
-- links below jump to the message on this page --
2010-10-24 4:49 [Qemu-devel] [PATCH] [virtio-9p] Add datasync to server side TFSYNC/RFSYNC for dotl Venkateswararao Jujjuri (JV)
-- strict thread matches above, loose matches on Subject: below --
2010-10-22 19:15 Venkateswararao Jujjuri (JV)
2010-10-23 12:44 ` Blue Swirl
2010-10-23 15:39 ` Venkateswararao Jujjuri (JV)
2010-10-23 18:27 ` Blue Swirl
2010-10-24 4:30 ` Venkateswararao Jujjuri (JV)
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).