diff options
-rw-r--r-- | fs/fuse/file.c | 33 | ||||
-rw-r--r-- | fs/fuse/fuse_i.h | 4 | ||||
-rw-r--r-- | include/linux/fuse.h | 7 |
3 files changed, 31 insertions, 13 deletions
diff --git a/fs/fuse/file.c b/fs/fuse/file.c index c4c59c7d0038..2b589de044e8 100644 --- a/fs/fuse/file.c +++ b/fs/fuse/file.c | |||
@@ -443,30 +443,37 @@ out: | |||
443 | return err; | 443 | return err; |
444 | } | 444 | } |
445 | 445 | ||
446 | static size_t fuse_send_write(struct fuse_req *req, struct file *file, | 446 | static void fuse_write_fill(struct fuse_req *req, struct fuse_file *ff, |
447 | struct inode *inode, loff_t pos, size_t count) | 447 | struct inode *inode, loff_t pos, size_t count, |
448 | int writepage) | ||
448 | { | 449 | { |
449 | struct fuse_conn *fc = get_fuse_conn(inode); | 450 | struct fuse_write_in *inarg = &req->misc.write.in; |
450 | struct fuse_file *ff = file->private_data; | 451 | struct fuse_write_out *outarg = &req->misc.write.out; |
451 | struct fuse_write_in inarg; | ||
452 | struct fuse_write_out outarg; | ||
453 | 452 | ||
454 | memset(&inarg, 0, sizeof(struct fuse_write_in)); | 453 | memset(inarg, 0, sizeof(struct fuse_write_in)); |
455 | inarg.fh = ff->fh; | 454 | inarg->fh = ff->fh; |
456 | inarg.offset = pos; | 455 | inarg->offset = pos; |
457 | inarg.size = count; | 456 | inarg->size = count; |
457 | inarg->write_flags = writepage ? FUSE_WRITE_CACHE : 0; | ||
458 | req->in.h.opcode = FUSE_WRITE; | 458 | req->in.h.opcode = FUSE_WRITE; |
459 | req->in.h.nodeid = get_node_id(inode); | 459 | req->in.h.nodeid = get_node_id(inode); |
460 | req->in.argpages = 1; | 460 | req->in.argpages = 1; |
461 | req->in.numargs = 2; | 461 | req->in.numargs = 2; |
462 | req->in.args[0].size = sizeof(struct fuse_write_in); | 462 | req->in.args[0].size = sizeof(struct fuse_write_in); |
463 | req->in.args[0].value = &inarg; | 463 | req->in.args[0].value = inarg; |
464 | req->in.args[1].size = count; | 464 | req->in.args[1].size = count; |
465 | req->out.numargs = 1; | 465 | req->out.numargs = 1; |
466 | req->out.args[0].size = sizeof(struct fuse_write_out); | 466 | req->out.args[0].size = sizeof(struct fuse_write_out); |
467 | req->out.args[0].value = &outarg; | 467 | req->out.args[0].value = outarg; |
468 | } | ||
469 | |||
470 | static size_t fuse_send_write(struct fuse_req *req, struct file *file, | ||
471 | struct inode *inode, loff_t pos, size_t count) | ||
472 | { | ||
473 | struct fuse_conn *fc = get_fuse_conn(inode); | ||
474 | fuse_write_fill(req, file->private_data, inode, pos, count, 0); | ||
468 | request_send(fc, req); | 475 | request_send(fc, req); |
469 | return outarg.size; | 476 | return req->misc.write.out.size; |
470 | } | 477 | } |
471 | 478 | ||
472 | static int fuse_write_begin(struct file *file, struct address_space *mapping, | 479 | static int fuse_write_begin(struct file *file, struct address_space *mapping, |
diff --git a/fs/fuse/fuse_i.h b/fs/fuse/fuse_i.h index 5657cca0d0cb..8b64a630e758 100644 --- a/fs/fuse/fuse_i.h +++ b/fs/fuse/fuse_i.h | |||
@@ -219,6 +219,10 @@ struct fuse_req { | |||
219 | struct fuse_init_in init_in; | 219 | struct fuse_init_in init_in; |
220 | struct fuse_init_out init_out; | 220 | struct fuse_init_out init_out; |
221 | struct fuse_read_in read_in; | 221 | struct fuse_read_in read_in; |
222 | struct { | ||
223 | struct fuse_write_in in; | ||
224 | struct fuse_write_out out; | ||
225 | } write; | ||
222 | struct fuse_lk_in lk_in; | 226 | struct fuse_lk_in lk_in; |
223 | } misc; | 227 | } misc; |
224 | 228 | ||
diff --git a/include/linux/fuse.h b/include/linux/fuse.h index 015a8b15a388..6f4a31266cd5 100644 --- a/include/linux/fuse.h +++ b/include/linux/fuse.h | |||
@@ -119,6 +119,13 @@ struct fuse_file_lock { | |||
119 | */ | 119 | */ |
120 | #define FUSE_LK_FLOCK (1 << 0) | 120 | #define FUSE_LK_FLOCK (1 << 0) |
121 | 121 | ||
122 | /** | ||
123 | * WRITE flags | ||
124 | * | ||
125 | * FUSE_WRITE_CACHE: delayed write from page cache, file handle is guessed | ||
126 | */ | ||
127 | #define FUSE_WRITE_CACHE (1 << 0) | ||
128 | |||
122 | enum fuse_opcode { | 129 | enum fuse_opcode { |
123 | FUSE_LOOKUP = 1, | 130 | FUSE_LOOKUP = 1, |
124 | FUSE_FORGET = 2, /* no reply */ | 131 | FUSE_FORGET = 2, /* no reply */ |