Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit baebccbe authored by Miklos Szeredi's avatar Miklos Szeredi
Browse files

fuse: hold inode instead of path after release 



path_put() in release could trigger a DESTROY request in fuseblk.  The
possible deadlock was worked around by doing the path_put() with
schedule_work().

This complexity isn't needed if we just hold the inode instead of the path.
Since we now flush all requests before destroying the super block we can be
sure that all held inodes will be dropped.

Signed-off-by: default avatarMiklos Szeredi <mszeredi@suse.cz>
parent 580640ba

fs/fuse/file.c

+5 −34
Original line number Diff line number Diff line
@@ -89,37 +89,9 @@ struct fuse_file *fuse_file_get(struct fuse_file *ff) 
	return ff;

}



static void fuse_release_async(struct work_struct *work)

{

	struct fuse_req *req;

	struct fuse_conn *fc;

	struct path path;



	req = container_of(work, struct fuse_req, misc.release.work);

	path = req->misc.release.path;

	fc = get_fuse_conn(path.dentry->d_inode);



	fuse_put_request(fc, req);

	path_put(&path);

}



static void fuse_release_end(struct fuse_conn *fc, struct fuse_req *req)

{

	if (fc->destroy_req) {

		/*

		 * If this is a fuseblk mount, then it's possible that

		 * releasing the path will result in releasing the

		 * super block and sending the DESTROY request.  If

		 * the server is single threaded, this would hang.

		 * For this reason do the path_put() in a separate

		 * thread.

		 */

		atomic_inc(&req->count);

		INIT_WORK(&req->misc.release.work, fuse_release_async);

		schedule_work(&req->misc.release.work);

	} else {

		path_put(&req->misc.release.path);

	}

	iput(req->misc.release.inode);

}



static void fuse_file_put(struct fuse_file *ff, bool sync)
@@ -133,12 +105,12 @@ static void fuse_file_put(struct fuse_file *ff, bool sync) 
			 * implement 'open'

			 */

			req->background = 0;

			path_put(&req->misc.release.path);

			iput(req->misc.release.inode);

			fuse_put_request(ff->fc, req);

		} else if (sync) {

			req->background = 0;

			fuse_request_send(ff->fc, req);

			path_put(&req->misc.release.path);

			iput(req->misc.release.inode);

			fuse_put_request(ff->fc, req);

		} else {

			req->end = fuse_release_end;
@@ -297,9 +269,8 @@ void fuse_release_common(struct file *file, int opcode) 
		inarg->lock_owner = fuse_lock_owner_id(ff->fc,

						       (fl_owner_t) file);

	}

	/* Hold vfsmount and dentry until release is finished */

	path_get(&file->f_path);

	req->misc.release.path = file->f_path;

	/* Hold inode until release is finished */

	req->misc.release.inode = igrab(file_inode(file));



	/*

	 * Normally this will send the RELEASE request, however if

fs/fuse/fuse_i.h

+2 −5
Original line number Diff line number Diff line
@@ -305,11 +305,8 @@ struct fuse_req { 
	/** Data for asynchronous requests */

	union {

		struct {

			union {

			struct fuse_release_in in;

				struct work_struct work;

			};

			struct path path;

			struct inode *inode;

		} release;

		struct fuse_init_in init_in;

		struct fuse_init_out init_out;