summaryrefslogtreecommitdiffstats
path: root/fs/fuse
diff options
context:
space:
mode:
authorKirill Tkhai <ktkhai@virtuozzo.com>2018-11-09 05:33:32 -0500
committerMiklos Szeredi <mszeredi@redhat.com>2019-02-13 07:15:14 -0500
commit6b675738ce900dac8f8478b1d8487df420a315f3 (patch)
tree5cb84046b547850992fd63b8633affd4de801936 /fs/fuse
parentc9d8f5f0692d5960ed50970ffe63756fb8f96cdb (diff)
fuse: Protect ff->reserved_req via corresponding fi->lock
This is rather natural action after previous patches, and it just decreases load of fc->lock. Signed-off-by: Kirill Tkhai <ktkhai@virtuozzo.com> Signed-off-by: Miklos Szeredi <mszeredi@redhat.com>
Diffstat (limited to 'fs/fuse')
-rw-r--r--fs/fuse/dev.c10
-rw-r--r--fs/fuse/fuse_i.h5
2 files changed, 10 insertions, 5 deletions
diff --git a/fs/fuse/dev.c b/fs/fuse/dev.c
index ed9318d4e7dc..5a7309427e0e 100644
--- a/fs/fuse/dev.c
+++ b/fs/fuse/dev.c
@@ -251,17 +251,18 @@ static struct fuse_req *get_reserved_req(struct fuse_conn *fc,
251 struct file *file) 251 struct file *file)
252{ 252{
253 struct fuse_req *req = NULL; 253 struct fuse_req *req = NULL;
254 struct fuse_inode *fi = get_fuse_inode(file_inode(file));
254 struct fuse_file *ff = file->private_data; 255 struct fuse_file *ff = file->private_data;
255 256
256 do { 257 do {
257 wait_event(fc->reserved_req_waitq, ff->reserved_req); 258 wait_event(fc->reserved_req_waitq, ff->reserved_req);
258 spin_lock(&fc->lock); 259 spin_lock(&fi->lock);
259 if (ff->reserved_req) { 260 if (ff->reserved_req) {
260 req = ff->reserved_req; 261 req = ff->reserved_req;
261 ff->reserved_req = NULL; 262 ff->reserved_req = NULL;
262 req->stolen_file = get_file(file); 263 req->stolen_file = get_file(file);
263 } 264 }
264 spin_unlock(&fc->lock); 265 spin_unlock(&fi->lock);
265 } while (!req); 266 } while (!req);
266 267
267 return req; 268 return req;
@@ -273,16 +274,17 @@ static struct fuse_req *get_reserved_req(struct fuse_conn *fc,
273static void put_reserved_req(struct fuse_conn *fc, struct fuse_req *req) 274static void put_reserved_req(struct fuse_conn *fc, struct fuse_req *req)
274{ 275{
275 struct file *file = req->stolen_file; 276 struct file *file = req->stolen_file;
277 struct fuse_inode *fi = get_fuse_inode(file_inode(file));
276 struct fuse_file *ff = file->private_data; 278 struct fuse_file *ff = file->private_data;
277 279
278 WARN_ON(req->max_pages); 280 WARN_ON(req->max_pages);
279 spin_lock(&fc->lock); 281 spin_lock(&fi->lock);
280 memset(req, 0, sizeof(*req)); 282 memset(req, 0, sizeof(*req));
281 fuse_request_init(req, NULL, NULL, 0); 283 fuse_request_init(req, NULL, NULL, 0);
282 BUG_ON(ff->reserved_req); 284 BUG_ON(ff->reserved_req);
283 ff->reserved_req = req; 285 ff->reserved_req = req;
284 wake_up_all(&fc->reserved_req_waitq); 286 wake_up_all(&fc->reserved_req_waitq);
285 spin_unlock(&fc->lock); 287 spin_unlock(&fi->lock);
286 fput(file); 288 fput(file);
287} 289}
288 290
diff --git a/fs/fuse/fuse_i.h b/fs/fuse/fuse_i.h
index 1c610b65b1bf..4fdd098e422d 100644
--- a/fs/fuse/fuse_i.h
+++ b/fs/fuse/fuse_i.h
@@ -166,7 +166,10 @@ struct fuse_file {
166 /** Fuse connection for this file */ 166 /** Fuse connection for this file */
167 struct fuse_conn *fc; 167 struct fuse_conn *fc;
168 168
169 /** Request reserved for flush and release */ 169 /*
170 * Request reserved for flush and release.
171 * Modified under relative fuse_inode::lock.
172 */
170 struct fuse_req *reserved_req; 173 struct fuse_req *reserved_req;
171 174
172 /** Kernel file handle guaranteed to be unique */ 175 /** Kernel file handle guaranteed to be unique */