提交 91fe96b4 编写于 作者: M Miklos Szeredi

fuse: create fuse_do_open() helper for CUSE

Create a helper for sending an OPEN request that doesn't need a struct
inode pointer.
Signed-off-by: NMiklos Szeredi <mszeredi@suse.cz>
上级 c7b7143c
...@@ -1103,7 +1103,7 @@ static void fuse_put_link(struct dentry *dentry, struct nameidata *nd, void *c) ...@@ -1103,7 +1103,7 @@ static void fuse_put_link(struct dentry *dentry, struct nameidata *nd, void *c)
static int fuse_dir_open(struct inode *inode, struct file *file) static int fuse_dir_open(struct inode *inode, struct file *file)
{ {
return fuse_open_common(inode, file, 1); return fuse_open_common(inode, file, true);
} }
static int fuse_dir_release(struct inode *inode, struct file *file) static int fuse_dir_release(struct inode *inode, struct file *file)
......
...@@ -15,10 +15,9 @@ ...@@ -15,10 +15,9 @@
static const struct file_operations fuse_direct_io_file_operations; static const struct file_operations fuse_direct_io_file_operations;
static int fuse_send_open(struct inode *inode, struct file *file, int isdir, static int fuse_send_open(struct fuse_conn *fc, u64 nodeid, struct file *file,
struct fuse_open_out *outargp) int opcode, struct fuse_open_out *outargp)
{ {
struct fuse_conn *fc = get_fuse_conn(inode);
struct fuse_open_in inarg; struct fuse_open_in inarg;
struct fuse_req *req; struct fuse_req *req;
int err; int err;
...@@ -31,8 +30,8 @@ static int fuse_send_open(struct inode *inode, struct file *file, int isdir, ...@@ -31,8 +30,8 @@ static int fuse_send_open(struct inode *inode, struct file *file, int isdir,
inarg.flags = file->f_flags & ~(O_CREAT | O_EXCL | O_NOCTTY); inarg.flags = file->f_flags & ~(O_CREAT | O_EXCL | O_NOCTTY);
if (!fc->atomic_o_trunc) if (!fc->atomic_o_trunc)
inarg.flags &= ~O_TRUNC; inarg.flags &= ~O_TRUNC;
req->in.h.opcode = isdir ? FUSE_OPENDIR : FUSE_OPEN; req->in.h.opcode = opcode;
req->in.h.nodeid = get_node_id(inode); req->in.h.nodeid = nodeid;
req->in.numargs = 1; req->in.numargs = 1;
req->in.args[0].size = sizeof(inarg); req->in.args[0].size = sizeof(inarg);
req->in.args[0].value = &inarg; req->in.args[0].value = &inarg;
...@@ -102,6 +101,35 @@ static void fuse_file_put(struct fuse_file *ff) ...@@ -102,6 +101,35 @@ static void fuse_file_put(struct fuse_file *ff)
} }
} }
static int fuse_do_open(struct fuse_conn *fc, u64 nodeid, struct file *file,
bool isdir)
{
struct fuse_open_out outarg;
struct fuse_file *ff;
int err;
int opcode = isdir ? FUSE_OPENDIR : FUSE_OPEN;
ff = fuse_file_alloc(fc);
if (!ff)
return -ENOMEM;
err = fuse_send_open(fc, nodeid, file, opcode, &outarg);
if (err) {
fuse_file_free(ff);
return err;
}
if (isdir)
outarg.open_flags &= ~FOPEN_DIRECT_IO;
ff->fh = outarg.fh;
ff->nodeid = nodeid;
ff->open_flags = outarg.open_flags;
file->private_data = fuse_file_get(ff);
return 0;
}
void fuse_finish_open(struct inode *inode, struct file *file) void fuse_finish_open(struct inode *inode, struct file *file)
{ {
struct fuse_file *ff = file->private_data; struct fuse_file *ff = file->private_data;
...@@ -114,11 +142,9 @@ void fuse_finish_open(struct inode *inode, struct file *file) ...@@ -114,11 +142,9 @@ void fuse_finish_open(struct inode *inode, struct file *file)
nonseekable_open(inode, file); nonseekable_open(inode, file);
} }
int fuse_open_common(struct inode *inode, struct file *file, int isdir) int fuse_open_common(struct inode *inode, struct file *file, bool isdir)
{ {
struct fuse_conn *fc = get_fuse_conn(inode); struct fuse_conn *fc = get_fuse_conn(inode);
struct fuse_open_out outarg;
struct fuse_file *ff;
int err; int err;
/* VFS checks this, but only _after_ ->open() */ /* VFS checks this, but only _after_ ->open() */
...@@ -129,24 +155,13 @@ int fuse_open_common(struct inode *inode, struct file *file, int isdir) ...@@ -129,24 +155,13 @@ int fuse_open_common(struct inode *inode, struct file *file, int isdir)
if (err) if (err)
return err; return err;
ff = fuse_file_alloc(fc); err = fuse_do_open(fc, get_node_id(inode), file, isdir);
if (!ff)
return -ENOMEM;
err = fuse_send_open(inode, file, isdir, &outarg);
if (err) if (err)
fuse_file_free(ff); return err;
else {
if (isdir)
outarg.open_flags &= ~FOPEN_DIRECT_IO;
ff->fh = outarg.fh;
ff->nodeid = get_node_id(inode);
ff->open_flags = outarg.open_flags;
file->private_data = fuse_file_get(ff);
fuse_finish_open(inode, file);
}
return err; fuse_finish_open(inode, file);
return 0;
} }
void fuse_release_fill(struct fuse_file *ff, int flags, int opcode) void fuse_release_fill(struct fuse_file *ff, int flags, int opcode)
...@@ -201,7 +216,7 @@ int fuse_release_common(struct inode *inode, struct file *file, int isdir) ...@@ -201,7 +216,7 @@ int fuse_release_common(struct inode *inode, struct file *file, int isdir)
static int fuse_open(struct inode *inode, struct file *file) static int fuse_open(struct inode *inode, struct file *file)
{ {
return fuse_open_common(inode, file, 0); return fuse_open_common(inode, file, false);
} }
static int fuse_release(struct inode *inode, struct file *file) static int fuse_release(struct inode *inode, struct file *file)
......
...@@ -528,7 +528,7 @@ void fuse_read_fill(struct fuse_req *req, struct file *file, ...@@ -528,7 +528,7 @@ void fuse_read_fill(struct fuse_req *req, struct file *file,
/** /**
* Send OPEN or OPENDIR request * Send OPEN or OPENDIR request
*/ */
int fuse_open_common(struct inode *inode, struct file *file, int isdir); int fuse_open_common(struct inode *inode, struct file *file, bool isdir);
struct fuse_file *fuse_file_alloc(struct fuse_conn *fc); struct fuse_file *fuse_file_alloc(struct fuse_conn *fc);
struct fuse_file *fuse_file_get(struct fuse_file *ff); struct fuse_file *fuse_file_get(struct fuse_file *ff);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册