From 1ffe28351ba4b1a5533b5d6e121bd835190db9e4 Mon Sep 17 00:00:00 2001 From: Miklos Szeredi Date: Thu, 18 Oct 2007 03:07:03 -0700 Subject: [PATCH] --- yaml --- r: 71227 b: refs/heads/master c: 93a8c3cd9e9834dc5f5c373336f3a0065521152d h: refs/heads/master i: 71225: 915bf5130082ce59d84145692ad8df21d4011a4c 71223: 034d8c4a41b072096707623dabb6100a3d41c257 v: v3 --- [refs] | 2 +- trunk/fs/fuse/file.c | 7 +++++++ trunk/fs/fuse/fuse_i.h | 6 ++++++ trunk/fs/fuse/inode.c | 2 ++ 4 files changed, 16 insertions(+), 1 deletion(-) diff --git a/[refs] b/[refs] index 297d744c696a..d4eaaba9b3e4 100644 --- a/[refs] +++ b/[refs] @@ -1,2 +1,2 @@ --- -refs/heads/master: a9ff4f87056cd31a8232b88d013dc6c9ad719c18 +refs/heads/master: 93a8c3cd9e9834dc5f5c373336f3a0065521152d diff --git a/trunk/fs/fuse/file.c b/trunk/fs/fuse/file.c index 471ea70be48d..c4c59c7d0038 100644 --- a/trunk/fs/fuse/file.c +++ b/trunk/fs/fuse/file.c @@ -56,6 +56,7 @@ struct fuse_file *fuse_file_alloc(void) kfree(ff); ff = NULL; } + INIT_LIST_HEAD(&ff->write_entry); atomic_set(&ff->count, 0); } return ff; @@ -150,12 +151,18 @@ int fuse_release_common(struct inode *inode, struct file *file, int isdir) { struct fuse_file *ff = file->private_data; if (ff) { + struct fuse_conn *fc = get_fuse_conn(inode); + fuse_release_fill(ff, get_node_id(inode), file->f_flags, isdir ? FUSE_RELEASEDIR : FUSE_RELEASE); /* Hold vfsmount and dentry until release is finished */ ff->reserved_req->vfsmount = mntget(file->f_path.mnt); ff->reserved_req->dentry = dget(file->f_path.dentry); + + spin_lock(&fc->lock); + list_del(&ff->write_entry); + spin_unlock(&fc->lock); /* * Normally this will send the RELEASE request, * however if some asynchronous READ or WRITE requests diff --git a/trunk/fs/fuse/fuse_i.h b/trunk/fs/fuse/fuse_i.h index b24fc9b386f8..5657cca0d0cb 100644 --- a/trunk/fs/fuse/fuse_i.h +++ b/trunk/fs/fuse/fuse_i.h @@ -70,6 +70,9 @@ struct fuse_inode { /** Version of last attribute change */ u64 attr_version; + + /** Files usable in writepage. Protected by fc->lock */ + struct list_head write_files; }; /** FUSE specific file data */ @@ -82,6 +85,9 @@ struct fuse_file { /** Refcount */ atomic_t count; + + /** Entry on inode's write_files list */ + struct list_head write_entry; }; /** One input argument of a request */ diff --git a/trunk/fs/fuse/inode.c b/trunk/fs/fuse/inode.c index 3c13981f48e2..49d716036ea7 100644 --- a/trunk/fs/fuse/inode.c +++ b/trunk/fs/fuse/inode.c @@ -56,6 +56,7 @@ static struct inode *fuse_alloc_inode(struct super_block *sb) fi->i_time = 0; fi->nodeid = 0; fi->nlookup = 0; + INIT_LIST_HEAD(&fi->write_files); fi->forget_req = fuse_request_alloc(); if (!fi->forget_req) { kmem_cache_free(fuse_inode_cachep, inode); @@ -68,6 +69,7 @@ static struct inode *fuse_alloc_inode(struct super_block *sb) static void fuse_destroy_inode(struct inode *inode) { struct fuse_inode *fi = get_fuse_inode(inode); + BUG_ON(!list_empty(&fi->write_files)); if (fi->forget_req) fuse_request_free(fi->forget_req); kmem_cache_free(fuse_inode_cachep, inode);