diff options
author | Christoph Hellwig <hch@infradead.org> | 2010-04-20 03:00:59 -0400 |
---|---|---|
committer | Alex Elder <aelder@sgi.com> | 2010-05-19 10:58:14 -0400 |
commit | 37bc5743fdc29f60fb104cd9031babbabddff25a (patch) | |
tree | abbcde46a9741a40a0ced8d1f289f6af65725d15 | |
parent | fce1cad651e3cf2779ed8f9e6608daf50d29daaf (diff) |
xfs: wait for direct I/O to complete in fsync and write_inode
We need to wait for all pending direct I/O requests before taking care of
metadata in fsync and write_inode.
Signed-off-by: Christoph Hellwig <hch@lst.de>
Reviewed-by: Dave Chinner <david@fromorbit.com>
-rw-r--r-- | fs/xfs/linux-2.6/xfs_file.c | 2 | ||||
-rw-r--r-- | fs/xfs/linux-2.6/xfs_super.c | 1 |
2 files changed, 3 insertions, 0 deletions
diff --git a/fs/xfs/linux-2.6/xfs_file.c b/fs/xfs/linux-2.6/xfs_file.c index 42dd3bcfba6b..d8fb1b5d6cb5 100644 --- a/fs/xfs/linux-2.6/xfs_file.c +++ b/fs/xfs/linux-2.6/xfs_file.c | |||
@@ -115,6 +115,8 @@ xfs_file_fsync( | |||
115 | 115 | ||
116 | xfs_iflags_clear(ip, XFS_ITRUNCATED); | 116 | xfs_iflags_clear(ip, XFS_ITRUNCATED); |
117 | 117 | ||
118 | xfs_ioend_wait(ip); | ||
119 | |||
118 | /* | 120 | /* |
119 | * We always need to make sure that the required inode state is safe on | 121 | * We always need to make sure that the required inode state is safe on |
120 | * disk. The inode might be clean but we still might need to force the | 122 | * disk. The inode might be clean but we still might need to force the |
diff --git a/fs/xfs/linux-2.6/xfs_super.c b/fs/xfs/linux-2.6/xfs_super.c index e8ad6dd2c10c..e9002513e08f 100644 --- a/fs/xfs/linux-2.6/xfs_super.c +++ b/fs/xfs/linux-2.6/xfs_super.c | |||
@@ -1093,6 +1093,7 @@ xfs_fs_write_inode( | |||
1093 | * the code will only flush the inode if it isn't already | 1093 | * the code will only flush the inode if it isn't already |
1094 | * being flushed. | 1094 | * being flushed. |
1095 | */ | 1095 | */ |
1096 | xfs_ioend_wait(ip); | ||
1096 | xfs_ilock(ip, XFS_ILOCK_SHARED); | 1097 | xfs_ilock(ip, XFS_ILOCK_SHARED); |
1097 | if (ip->i_update_core) { | 1098 | if (ip->i_update_core) { |
1098 | error = xfs_log_inode(ip); | 1099 | error = xfs_log_inode(ip); |