Lines Matching refs:ia
383 struct fuse_io_args ia; member
404 curr_index = wpa->ia.write.in.offset >> PAGE_SHIFT; in fuse_find_writeback()
405 if (idx_from >= curr_index + wpa->ia.ap.num_pages) in fuse_find_writeback()
594 void fuse_read_args_fill(struct fuse_io_args *ia, struct file *file, loff_t pos, in fuse_read_args_fill() argument
598 struct fuse_args *args = &ia->ap.args; in fuse_read_args_fill()
600 ia->read.in.fh = ff->fh; in fuse_read_args_fill()
601 ia->read.in.offset = pos; in fuse_read_args_fill()
602 ia->read.in.size = count; in fuse_read_args_fill()
603 ia->read.in.flags = file->f_flags; in fuse_read_args_fill()
607 args->in_args[0].size = sizeof(ia->read.in); in fuse_read_args_fill()
608 args->in_args[0].value = &ia->read.in; in fuse_read_args_fill()
695 struct fuse_io_args *ia; in fuse_io_alloc() local
697 ia = kzalloc(sizeof(*ia), GFP_KERNEL); in fuse_io_alloc()
698 if (ia) { in fuse_io_alloc()
699 ia->io = io; in fuse_io_alloc()
700 ia->ap.pages = fuse_pages_alloc(npages, GFP_KERNEL, in fuse_io_alloc()
701 &ia->ap.descs); in fuse_io_alloc()
702 if (!ia->ap.pages) { in fuse_io_alloc()
703 kfree(ia); in fuse_io_alloc()
704 ia = NULL; in fuse_io_alloc()
707 return ia; in fuse_io_alloc()
710 static void fuse_io_free(struct fuse_io_args *ia) in fuse_io_free() argument
712 kfree(ia->ap.pages); in fuse_io_free()
713 kfree(ia); in fuse_io_free()
719 struct fuse_io_args *ia = container_of(args, typeof(*ia), ap.args); in fuse_aio_complete_req() local
720 struct fuse_io_priv *io = ia->io; in fuse_aio_complete_req()
723 fuse_release_user_pages(&ia->ap, io->should_dirty); in fuse_aio_complete_req()
728 if (ia->write.out.size > ia->write.in.size) { in fuse_aio_complete_req()
730 } else if (ia->write.in.size != ia->write.out.size) { in fuse_aio_complete_req()
731 pos = ia->write.in.offset - io->offset + in fuse_aio_complete_req()
732 ia->write.out.size; in fuse_aio_complete_req()
737 if (ia->read.in.size != outsize) in fuse_aio_complete_req()
738 pos = ia->read.in.offset - io->offset + outsize; in fuse_aio_complete_req()
742 fuse_io_free(ia); in fuse_aio_complete_req()
746 struct fuse_io_args *ia, size_t num_bytes) in fuse_async_req_send() argument
749 struct fuse_io_priv *io = ia->io; in fuse_async_req_send()
757 ia->ap.args.end = fuse_aio_complete_req; in fuse_async_req_send()
758 ia->ap.args.may_block = io->should_dirty; in fuse_async_req_send()
759 err = fuse_simple_background(fm, &ia->ap.args, GFP_KERNEL); in fuse_async_req_send()
761 fuse_aio_complete_req(fm, &ia->ap.args, err); in fuse_async_req_send()
766 static ssize_t fuse_send_read(struct fuse_io_args *ia, loff_t pos, size_t count, in fuse_send_read() argument
769 struct file *file = ia->io->iocb->ki_filp; in fuse_send_read()
773 fuse_read_args_fill(ia, file, pos, count, FUSE_READ); in fuse_send_read()
775 ia->read.in.read_flags |= FUSE_READ_LOCKOWNER; in fuse_send_read()
776 ia->read.in.lock_owner = fuse_lock_owner_id(fm->fc, owner); in fuse_send_read()
779 if (ia->io->async) in fuse_send_read()
780 return fuse_async_req_send(fm, ia, count); in fuse_send_read()
782 return fuse_simple_request(fm, &ia->ap.args); in fuse_send_read()
822 struct fuse_io_args ia = { in fuse_do_readpage() local
845 fuse_read_args_fill(&ia, file, pos, desc.length, FUSE_READ); in fuse_do_readpage()
846 res = fuse_simple_request(fm, &ia.ap.args); in fuse_do_readpage()
853 fuse_short_read(inode, attr_ver, res, &ia.ap); in fuse_do_readpage()
880 struct fuse_io_args *ia = container_of(args, typeof(*ia), ap.args); in fuse_readpages_end() local
881 struct fuse_args_pages *ap = &ia->ap; in fuse_readpages_end()
882 size_t count = ia->read.in.size; in fuse_readpages_end()
896 fuse_short_read(inode, ia->read.attr_ver, num_read, ap); in fuse_readpages_end()
911 if (ia->ff) in fuse_readpages_end()
912 fuse_file_put(ia->ff, false, false); in fuse_readpages_end()
914 fuse_io_free(ia); in fuse_readpages_end()
917 static void fuse_send_readpages(struct fuse_io_args *ia, struct file *file) in fuse_send_readpages() argument
921 struct fuse_args_pages *ap = &ia->ap; in fuse_send_readpages()
938 fuse_read_args_fill(ia, file, pos, count, FUSE_READ); in fuse_send_readpages()
939 ia->read.attr_ver = fuse_get_attr_version(fm->fc); in fuse_send_readpages()
941 ia->ff = fuse_file_get(ff); in fuse_send_readpages()
966 struct fuse_io_args *ia; in fuse_readahead() local
974 ia = fuse_io_alloc(NULL, nr_pages); in fuse_readahead()
975 if (!ia) in fuse_readahead()
977 ap = &ia->ap; in fuse_readahead()
985 fuse_send_readpages(ia, rac->file); in fuse_readahead()
1010 static void fuse_write_args_fill(struct fuse_io_args *ia, struct fuse_file *ff, in fuse_write_args_fill() argument
1013 struct fuse_args *args = &ia->ap.args; in fuse_write_args_fill()
1015 ia->write.in.fh = ff->fh; in fuse_write_args_fill()
1016 ia->write.in.offset = pos; in fuse_write_args_fill()
1017 ia->write.in.size = count; in fuse_write_args_fill()
1024 args->in_args[0].size = sizeof(ia->write.in); in fuse_write_args_fill()
1025 args->in_args[0].value = &ia->write.in; in fuse_write_args_fill()
1028 args->out_args[0].size = sizeof(ia->write.out); in fuse_write_args_fill()
1029 args->out_args[0].value = &ia->write.out; in fuse_write_args_fill()
1044 static ssize_t fuse_send_write(struct fuse_io_args *ia, loff_t pos, in fuse_send_write() argument
1047 struct kiocb *iocb = ia->io->iocb; in fuse_send_write()
1051 struct fuse_write_in *inarg = &ia->write.in; in fuse_send_write()
1054 fuse_write_args_fill(ia, ff, pos, count); in fuse_send_write()
1061 if (ia->io->async) in fuse_send_write()
1062 return fuse_async_req_send(fm, ia, count); in fuse_send_write()
1064 err = fuse_simple_request(fm, &ia->ap.args); in fuse_send_write()
1065 if (!err && ia->write.out.size > count) in fuse_send_write()
1068 return err ?: ia->write.out.size; in fuse_send_write()
1090 static ssize_t fuse_send_write_pages(struct fuse_io_args *ia, in fuse_send_write_pages() argument
1094 struct fuse_args_pages *ap = &ia->ap; in fuse_send_write_pages()
1105 fuse_write_args_fill(ia, ff, pos, count); in fuse_send_write_pages()
1106 ia->write.in.flags = fuse_write_flags(iocb); in fuse_send_write_pages()
1108 ia->write.in.write_flags |= FUSE_WRITE_KILL_SUIDGID; in fuse_send_write_pages()
1111 if (!err && ia->write.out.size > count) in fuse_send_write_pages()
1114 short_write = ia->write.out.size < count; in fuse_send_write_pages()
1116 count = ia->write.out.size; in fuse_send_write_pages()
1132 if (ia->write.page_locked && (i == ap->num_pages - 1)) in fuse_send_write_pages()
1140 static ssize_t fuse_fill_write_pages(struct fuse_io_args *ia, in fuse_fill_write_pages() argument
1145 struct fuse_args_pages *ap = &ia->ap; in fuse_fill_write_pages()
1203 ia->write.page_locked = true; in fuse_fill_write_pages()
1238 struct fuse_io_args ia = {}; in fuse_perform_write() local
1239 struct fuse_args_pages *ap = &ia.ap; in fuse_perform_write()
1249 count = fuse_fill_write_pages(&ia, mapping, ii, pos, nr_pages); in fuse_perform_write()
1253 err = fuse_send_write_pages(&ia, iocb, inode, in fuse_perform_write()
1256 size_t num_written = ia.write.out.size; in fuse_perform_write()
1442 struct fuse_io_args *ia; in fuse_direct_io() local
1446 ia = fuse_io_alloc(io, max_pages); in fuse_direct_io()
1447 if (!ia) in fuse_direct_io()
1464 err = fuse_get_user_pages(&ia->ap, iter, &nbytes, write, in fuse_direct_io()
1471 ia->write.in.write_flags |= FUSE_WRITE_KILL_SUIDGID; in fuse_direct_io()
1473 nres = fuse_send_write(ia, pos, nbytes, owner); in fuse_direct_io()
1475 nres = fuse_send_read(ia, pos, nbytes, owner); in fuse_direct_io()
1479 fuse_release_user_pages(&ia->ap, io->should_dirty); in fuse_direct_io()
1480 fuse_io_free(ia); in fuse_direct_io()
1482 ia = NULL; in fuse_direct_io()
1499 ia = fuse_io_alloc(io, max_pages); in fuse_direct_io()
1500 if (!ia) in fuse_direct_io()
1504 if (ia) in fuse_direct_io()
1505 fuse_io_free(ia); in fuse_direct_io()
1605 struct fuse_args_pages *ap = &wpa->ia.ap; in fuse_writepage_free()
1614 if (wpa->ia.ff) in fuse_writepage_free()
1615 fuse_file_put(wpa->ia.ff, false, false); in fuse_writepage_free()
1624 struct fuse_args_pages *ap = &wpa->ia.ap; in fuse_writepage_finish()
1646 struct fuse_write_in *inarg = &wpa->ia.write.in; in fuse_send_writepage()
1647 struct fuse_args *args = &wpa->ia.ap.args; in fuse_send_writepage()
1648 __u64 data_size = wpa->ia.ap.num_pages * PAGE_SIZE; in fuse_send_writepage()
1721 pgoff_t idx_from = wpa->ia.write.in.offset >> PAGE_SHIFT; in fuse_insert_writeback()
1722 pgoff_t idx_to = idx_from + wpa->ia.ap.num_pages - 1; in fuse_insert_writeback()
1726 WARN_ON(!wpa->ia.ap.num_pages); in fuse_insert_writeback()
1735 curr_index = curr->ia.write.in.offset >> PAGE_SHIFT; in fuse_insert_writeback()
1737 if (idx_from >= curr_index + curr->ia.ap.num_pages) in fuse_insert_writeback()
1759 container_of(args, typeof(*wpa), ia.ap.args); in fuse_writepage_end()
1777 struct fuse_write_in *inarg = &wpa->ia.write.in; in fuse_writepage_end()
1782 next->ia.ff = fuse_file_get(wpa->ia.ff); in fuse_writepage_end()
1869 ap = &wpa->ia.ap; in fuse_writepage_args_alloc()
1911 ap = &wpa->ia.ap; in fuse_writepage_locked()
1918 wpa->ia.ff = fuse_write_file_get(fi); in fuse_writepage_locked()
1919 if (!wpa->ia.ff) in fuse_writepage_locked()
1923 fuse_write_args_fill(&wpa->ia, wpa->ia.ff, page_offset(page), 0); in fuse_writepage_locked()
1926 wpa->ia.write.in.write_flags |= FUSE_WRITE_CACHE; in fuse_writepage_locked()
1992 struct fuse_args_pages *ap = &data->wpa->ia.ap; in fuse_pages_realloc()
2021 int num_pages = wpa->ia.ap.num_pages; in fuse_writepages_send()
2024 wpa->ia.ff = fuse_file_get(data->ff); in fuse_writepages_send()
2047 struct fuse_args_pages *new_ap = &new_wpa->ia.ap; in fuse_writepage_add()
2063 curr_index = tmp->ia.write.in.offset >> PAGE_SHIFT; in fuse_writepage_add()
2065 WARN_ON(tmp->ia.ap.num_pages != 1); in fuse_writepage_add()
2066 swap(tmp->ia.ap.pages[0], new_ap->pages[0]); in fuse_writepage_add()
2129 struct fuse_args_pages *ap = &wpa->ia.ap; in fuse_writepages_fill()
2177 ap = &wpa->ia.ap; in fuse_writepages_fill()
2178 fuse_write_args_fill(&wpa->ia, data->ff, page_offset(page), 0); in fuse_writepages_fill()
2179 wpa->ia.write.in.write_flags |= FUSE_WRITE_CACHE; in fuse_writepages_fill()
2242 WARN_ON(!data.wpa->ia.ap.num_pages); in fuse_writepages()