Lines Matching refs:ia
397 struct fuse_io_args ia;
418 curr_index = wpa->ia.write.in.offset >> PAGE_SHIFT;
419 if (idx_from >= curr_index + wpa->ia.ap.num_pages)
608 void fuse_read_args_fill(struct fuse_io_args *ia, struct file *file, loff_t pos,
612 struct fuse_args *args = &ia->ap.args;
614 ia->read.in.fh = ff->fh;
615 ia->read.in.offset = pos;
616 ia->read.in.size = count;
617 ia->read.in.flags = file->f_flags;
621 args->in_args[0].size = sizeof(ia->read.in);
622 args->in_args[0].value = &ia->read.in;
709 struct fuse_io_args *ia;
711 ia = kzalloc(sizeof(*ia), GFP_KERNEL);
712 if (ia) {
713 ia->io = io;
714 ia->ap.pages = fuse_pages_alloc(npages, GFP_KERNEL,
715 &ia->ap.descs);
716 if (!ia->ap.pages) {
717 kfree(ia);
718 ia = NULL;
721 return ia;
724 static void fuse_io_free(struct fuse_io_args *ia)
726 kfree(ia->ap.pages);
727 kfree(ia);
733 struct fuse_io_args *ia = container_of(args, typeof(*ia), ap.args);
734 struct fuse_io_priv *io = ia->io;
737 fuse_release_user_pages(&ia->ap, io->should_dirty);
742 if (ia->write.out.size > ia->write.in.size) {
744 } else if (ia->write.in.size != ia->write.out.size) {
745 pos = ia->write.in.offset - io->offset +
746 ia->write.out.size;
751 if (ia->read.in.size != outsize)
752 pos = ia->read.in.offset - io->offset + outsize;
756 fuse_io_free(ia);
760 struct fuse_io_args *ia, size_t num_bytes)
763 struct fuse_io_priv *io = ia->io;
771 ia->ap.args.end = fuse_aio_complete_req;
772 ia->ap.args.may_block = io->should_dirty;
773 err = fuse_simple_background(fm, &ia->ap.args, GFP_KERNEL);
775 fuse_aio_complete_req(fm, &ia->ap.args, err);
780 static ssize_t fuse_send_read(struct fuse_io_args *ia, loff_t pos, size_t count,
783 struct file *file = ia->io->iocb->ki_filp;
787 fuse_read_args_fill(ia, file, pos, count, FUSE_READ);
789 ia->read.in.read_flags |= FUSE_READ_LOCKOWNER;
790 ia->read.in.lock_owner = fuse_lock_owner_id(fm->fc, owner);
793 if (ia->io->async)
794 return fuse_async_req_send(fm, ia, count);
796 return fuse_simple_request(fm, &ia->ap.args);
836 struct fuse_io_args ia = {
859 fuse_read_args_fill(&ia, file, pos, desc.length, FUSE_READ);
860 res = fuse_simple_request(fm, &ia.ap.args);
867 fuse_short_read(inode, attr_ver, res, &ia.ap);
895 struct fuse_io_args *ia = container_of(args, typeof(*ia), ap.args);
896 struct fuse_args_pages *ap = &ia->ap;
897 size_t count = ia->read.in.size;
911 fuse_short_read(inode, ia->read.attr_ver, num_read, ap);
926 if (ia->ff)
927 fuse_file_put(ia->ff, false, false);
929 fuse_io_free(ia);
932 static void fuse_send_readpages(struct fuse_io_args *ia, struct file *file)
936 struct fuse_args_pages *ap = &ia->ap;
953 fuse_read_args_fill(ia, file, pos, count, FUSE_READ);
954 ia->read.attr_ver = fuse_get_attr_version(fm->fc);
956 ia->ff = fuse_file_get(ff);
981 struct fuse_io_args *ia;
997 ia = fuse_io_alloc(NULL, nr_pages);
998 if (!ia)
1000 ap = &ia->ap;
1008 fuse_send_readpages(ia, rac->file);
1033 static void fuse_write_args_fill(struct fuse_io_args *ia, struct fuse_file *ff,
1036 struct fuse_args *args = &ia->ap.args;
1038 ia->write.in.fh = ff->fh;
1039 ia->write.in.offset = pos;
1040 ia->write.in.size = count;
1047 args->in_args[0].size = sizeof(ia->write.in);
1048 args->in_args[0].value = &ia->write.in;
1051 args->out_args[0].size = sizeof(ia->write.out);
1052 args->out_args[0].value = &ia->write.out;
1067 static ssize_t fuse_send_write(struct fuse_io_args *ia, loff_t pos,
1070 struct kiocb *iocb = ia->io->iocb;
1074 struct fuse_write_in *inarg = &ia->write.in;
1077 fuse_write_args_fill(ia, ff, pos, count);
1084 if (ia->io->async)
1085 return fuse_async_req_send(fm, ia, count);
1087 err = fuse_simple_request(fm, &ia->ap.args);
1088 if (!err && ia->write.out.size > count)
1091 return err ?: ia->write.out.size;
1113 static ssize_t fuse_send_write_pages(struct fuse_io_args *ia,
1117 struct fuse_args_pages *ap = &ia->ap;
1128 fuse_write_args_fill(ia, ff, pos, count);
1129 ia->write.in.flags = fuse_write_flags(iocb);
1131 ia->write.in.write_flags |= FUSE_WRITE_KILL_SUIDGID;
1134 if (!err && ia->write.out.size > count)
1137 short_write = ia->write.out.size < count;
1139 count = ia->write.out.size;
1155 if (ia->write.page_locked && (i == ap->num_pages - 1))
1163 static ssize_t fuse_fill_write_pages(struct fuse_io_args *ia,
1168 struct fuse_args_pages *ap = &ia->ap;
1226 ia->write.page_locked = true;
1261 struct fuse_io_args ia = {};
1262 struct fuse_args_pages *ap = &ia.ap;
1272 count = fuse_fill_write_pages(&ia, mapping, ii, pos, nr_pages);
1276 err = fuse_send_write_pages(&ia, iocb, inode,
1279 size_t num_written = ia.write.out.size;
1442 struct fuse_io_args *ia;
1447 ia = fuse_io_alloc(io, max_pages);
1448 if (!ia)
1454 fuse_io_free(ia);
1469 fuse_io_free(ia);
1480 err = fuse_get_user_pages(&ia->ap, iter, &nbytes, write,
1487 ia->write.in.write_flags |= FUSE_WRITE_KILL_SUIDGID;
1489 nres = fuse_send_write(ia, pos, nbytes, owner);
1491 nres = fuse_send_read(ia, pos, nbytes, owner);
1495 fuse_release_user_pages(&ia->ap, io->should_dirty);
1496 fuse_io_free(ia);
1498 ia = NULL;
1515 ia = fuse_io_alloc(io, max_pages);
1516 if (!ia)
1520 if (ia)
1521 fuse_io_free(ia);
1659 struct fuse_args_pages *ap = &wpa->ia.ap;
1668 if (wpa->ia.ff)
1669 fuse_file_put(wpa->ia.ff, false, false);
1678 struct fuse_args_pages *ap = &wpa->ia.ap;
1700 struct fuse_write_in *inarg = &wpa->ia.write.in;
1701 struct fuse_args *args = &wpa->ia.ap.args;
1702 __u64 data_size = wpa->ia.ap.num_pages * PAGE_SIZE;
1775 pgoff_t idx_from = wpa->ia.write.in.offset >> PAGE_SHIFT;
1776 pgoff_t idx_to = idx_from + wpa->ia.ap.num_pages - 1;
1780 WARN_ON(!wpa->ia.ap.num_pages);
1789 curr_index = curr->ia.write.in.offset >> PAGE_SHIFT;
1791 if (idx_from >= curr_index + curr->ia.ap.num_pages)
1813 container_of(args, typeof(*wpa), ia.ap.args);
1831 struct fuse_write_in *inarg = &wpa->ia.write.in;
1836 next->ia.ff = fuse_file_get(wpa->ia.ff);
1923 ap = &wpa->ia.ap;
1965 ap = &wpa->ia.ap;
1972 wpa->ia.ff = fuse_write_file_get(fi);
1973 if (!wpa->ia.ff)
1977 fuse_write_args_fill(&wpa->ia, wpa->ia.ff, page_offset(page), 0);
1980 wpa->ia.write.in.write_flags |= FUSE_WRITE_CACHE;
2051 struct fuse_args_pages *ap = &data->wpa->ia.ap;
2080 int num_pages = wpa->ia.ap.num_pages;
2083 wpa->ia.ff = fuse_file_get(data->ff);
2106 struct fuse_args_pages *new_ap = &new_wpa->ia.ap;
2122 curr_index = tmp->ia.write.in.offset >> PAGE_SHIFT;
2124 WARN_ON(tmp->ia.ap.num_pages != 1);
2125 swap(tmp->ia.ap.pages[0], new_ap->pages[0]);
2188 struct fuse_args_pages *ap = &wpa->ia.ap;
2236 ap = &wpa->ia.ap;
2237 fuse_write_args_fill(&wpa->ia, data->ff, folio_pos(folio), 0);
2238 wpa->ia.write.in.write_flags |= FUSE_WRITE_CACHE;
2305 WARN_ON(!data.wpa->ia.ap.num_pages);