Lines Matching full:ff
59 struct fuse_file *ff; in fuse_file_alloc() local
61 ff = kzalloc(sizeof(struct fuse_file), GFP_KERNEL_ACCOUNT); in fuse_file_alloc()
62 if (unlikely(!ff)) in fuse_file_alloc()
65 ff->fm = fm; in fuse_file_alloc()
66 ff->release_args = kzalloc(sizeof(*ff->release_args), in fuse_file_alloc()
68 if (!ff->release_args) { in fuse_file_alloc()
69 kfree(ff); in fuse_file_alloc()
73 INIT_LIST_HEAD(&ff->write_entry); in fuse_file_alloc()
74 mutex_init(&ff->readdir.lock); in fuse_file_alloc()
75 refcount_set(&ff->count, 1); in fuse_file_alloc()
76 RB_CLEAR_NODE(&ff->polled_node); in fuse_file_alloc()
77 init_waitqueue_head(&ff->poll_wait); in fuse_file_alloc()
79 ff->kh = atomic64_inc_return(&fm->fc->khctr); in fuse_file_alloc()
81 return ff; in fuse_file_alloc()
84 void fuse_file_free(struct fuse_file *ff) in fuse_file_free() argument
86 kfree(ff->release_args); in fuse_file_free()
87 mutex_destroy(&ff->readdir.lock); in fuse_file_free()
88 kfree(ff); in fuse_file_free()
91 static struct fuse_file *fuse_file_get(struct fuse_file *ff) in fuse_file_get() argument
93 refcount_inc(&ff->count); in fuse_file_get()
94 return ff; in fuse_file_get()
106 static void fuse_file_put(struct fuse_file *ff, bool sync, bool isdir) in fuse_file_put() argument
108 if (refcount_dec_and_test(&ff->count)) { in fuse_file_put()
109 struct fuse_args *args = &ff->release_args->args; in fuse_file_put()
111 if (isdir ? ff->fm->fc->no_opendir : ff->fm->fc->no_open) { in fuse_file_put()
113 fuse_release_end(ff->fm, args, 0); in fuse_file_put()
115 fuse_simple_request(ff->fm, args); in fuse_file_put()
116 fuse_release_end(ff->fm, args, 0); in fuse_file_put()
119 if (fuse_simple_background(ff->fm, args, in fuse_file_put()
121 fuse_release_end(ff->fm, args, -ENOTCONN); in fuse_file_put()
123 kfree(ff); in fuse_file_put()
131 struct fuse_file *ff; in fuse_file_open() local
134 ff = fuse_file_alloc(fm); in fuse_file_open()
135 if (!ff) in fuse_file_open()
138 ff->fh = 0; in fuse_file_open()
140 ff->open_flags = FOPEN_KEEP_CACHE | (isdir ? FOPEN_CACHE_DIR : 0); in fuse_file_open()
147 ff->fh = outarg.fh; in fuse_file_open()
148 ff->open_flags = outarg.open_flags; in fuse_file_open()
151 fuse_file_free(ff); in fuse_file_open()
162 ff->open_flags &= ~FOPEN_DIRECT_IO; in fuse_file_open()
164 ff->nodeid = nodeid; in fuse_file_open()
166 return ff; in fuse_file_open()
172 struct fuse_file *ff = fuse_file_open(fm, nodeid, file->f_flags, isdir); in fuse_do_open() local
174 if (!IS_ERR(ff)) in fuse_do_open()
175 file->private_data = ff; in fuse_do_open()
177 return PTR_ERR_OR_ZERO(ff); in fuse_do_open()
185 struct fuse_file *ff = file->private_data; in fuse_link_write_file() local
191 if (list_empty(&ff->write_entry)) in fuse_link_write_file()
192 list_add(&ff->write_entry, &fi->write_files); in fuse_link_write_file()
198 struct fuse_file *ff = file->private_data; in fuse_finish_open() local
201 if (ff->open_flags & FOPEN_STREAM) in fuse_finish_open()
203 else if (ff->open_flags & FOPEN_NONSEEKABLE) in fuse_finish_open()
217 } else if (!(ff->open_flags & FOPEN_KEEP_CACHE)) { in fuse_finish_open()
271 static void fuse_prepare_release(struct fuse_inode *fi, struct fuse_file *ff, in fuse_prepare_release() argument
274 struct fuse_conn *fc = ff->fm->fc; in fuse_prepare_release()
275 struct fuse_release_args *ra = ff->release_args; in fuse_prepare_release()
280 list_del(&ff->write_entry); in fuse_prepare_release()
284 if (!RB_EMPTY_NODE(&ff->polled_node)) in fuse_prepare_release()
285 rb_erase(&ff->polled_node, &fc->polled_files); in fuse_prepare_release()
288 wake_up_interruptible_all(&ff->poll_wait); in fuse_prepare_release()
290 ra->inarg.fh = ff->fh; in fuse_prepare_release()
296 ra->args.nodeid = ff->nodeid; in fuse_prepare_release()
301 void fuse_file_release(struct inode *inode, struct fuse_file *ff, in fuse_file_release() argument
305 struct fuse_release_args *ra = ff->release_args; in fuse_file_release()
308 fuse_prepare_release(fi, ff, open_flags, opcode); in fuse_file_release()
310 if (ff->flock) { in fuse_file_release()
312 ra->inarg.lock_owner = fuse_lock_owner_id(ff->fm->fc, id); in fuse_file_release()
326 fuse_file_put(ff, ff->fm->fc->destroy, isdir); in fuse_file_release()
354 void fuse_sync_release(struct fuse_inode *fi, struct fuse_file *ff, in fuse_sync_release() argument
357 WARN_ON(refcount_read(&ff->count) > 1); in fuse_sync_release()
358 fuse_prepare_release(fi, ff, flags, FUSE_RELEASE); in fuse_sync_release()
363 fuse_file_put(ff, true, false); in fuse_sync_release()
478 struct fuse_file *ff = file->private_data; in fuse_flush() local
503 inarg.fh = ff->fh; in fuse_flush()
533 struct fuse_file *ff = file->private_data; in fuse_fsync_common() local
538 inarg.fh = ff->fh; in fuse_fsync_common()
601 struct fuse_file *ff = file->private_data; in fuse_read_args_fill() local
604 ia->read.in.fh = ff->fh; in fuse_read_args_fill()
609 args->nodeid = ff->nodeid; in fuse_read_args_fill()
774 struct fuse_file *ff = file->private_data; in fuse_send_read() local
775 struct fuse_mount *fm = ff->fm; in fuse_send_read()
915 if (ia->ff) in fuse_readpages_end()
916 fuse_file_put(ia->ff, false, false); in fuse_readpages_end()
923 struct fuse_file *ff = file->private_data; in fuse_send_readpages() local
924 struct fuse_mount *fm = ff->fm; in fuse_send_readpages()
945 ia->ff = fuse_file_get(ff); in fuse_send_readpages()
1014 static void fuse_write_args_fill(struct fuse_io_args *ia, struct fuse_file *ff, in fuse_write_args_fill() argument
1019 ia->write.in.fh = ff->fh; in fuse_write_args_fill()
1023 args->nodeid = ff->nodeid; in fuse_write_args_fill()
1025 if (ff->fm->fc->minor < 9) in fuse_write_args_fill()
1053 struct fuse_file *ff = file->private_data; in fuse_send_write() local
1054 struct fuse_mount *fm = ff->fm; in fuse_send_write()
1058 fuse_write_args_fill(ia, ff, pos, count); in fuse_send_write()
1098 struct fuse_file *ff = file->private_data; in fuse_send_write_pages() local
1099 struct fuse_mount *fm = ff->fm; in fuse_send_write_pages()
1107 fuse_write_args_fill(ia, ff, pos, count); in fuse_send_write_pages()
1437 struct fuse_file *ff = file->private_data; in fuse_direct_io() local
1438 struct fuse_conn *fc = ff->fm->fc; in fuse_direct_io()
1577 struct fuse_file *ff = file->private_data; in fuse_file_read_iter() local
1586 if (!(ff->open_flags & FOPEN_DIRECT_IO)) in fuse_file_read_iter()
1595 struct fuse_file *ff = file->private_data; in fuse_file_write_iter() local
1604 if (!(ff->open_flags & FOPEN_DIRECT_IO)) in fuse_file_write_iter()
1621 if (wpa->ia.ff) in fuse_writepage_free()
1622 fuse_file_put(wpa->ia.ff, false, false); in fuse_writepage_free()
1789 next->ia.ff = fuse_file_get(wpa->ia.ff); in fuse_writepage_end()
1825 struct fuse_file *ff = NULL; in __fuse_write_file_get() local
1829 ff = list_entry(fi->write_files.next, struct fuse_file, in __fuse_write_file_get()
1831 fuse_file_get(ff); in __fuse_write_file_get()
1835 return ff; in __fuse_write_file_get()
1840 struct fuse_file *ff = __fuse_write_file_get(fi); in fuse_write_file_get() local
1841 WARN_ON(!ff); in fuse_write_file_get()
1842 return ff; in fuse_write_file_get()
1848 struct fuse_file *ff; in fuse_write_inode() local
1851 ff = __fuse_write_file_get(fi); in fuse_write_inode()
1852 err = fuse_flush_times(inode, ff); in fuse_write_inode()
1853 if (ff) in fuse_write_inode()
1854 fuse_file_put(ff, false, false); in fuse_write_inode()
1915 wpa->ia.ff = fuse_write_file_get(fi); in fuse_writepage_locked()
1916 if (!wpa->ia.ff) in fuse_writepage_locked()
1920 fuse_write_args_fill(&wpa->ia, wpa->ia.ff, page_offset(page), 0); in fuse_writepage_locked()
1981 struct fuse_file *ff; member
2021 wpa->ia.ff = fuse_file_get(data->ff); in fuse_writepages_send()
2133 if (!data->ff) { in fuse_writepages_fill()
2135 data->ff = fuse_write_file_get(fi); in fuse_writepages_fill()
2136 if (!data->ff) in fuse_writepages_fill()
2175 fuse_write_args_fill(&wpa->ia, data->ff, page_offset(page), 0); in fuse_writepages_fill()
2228 data.ff = NULL; in fuse_writepages()
2242 if (data.ff) in fuse_writepages()
2243 fuse_file_put(data.ff, false, false); in fuse_writepages()
2391 struct fuse_file *ff = file->private_data; in fuse_file_mmap() local
2397 if (ff->open_flags & FOPEN_DIRECT_IO) { in fuse_file_mmap()
2454 struct fuse_file *ff = file->private_data; in fuse_lk_fill() local
2457 inarg->fh = ff->fh; in fuse_lk_fill()
2554 struct fuse_file *ff = file->private_data; in fuse_file_flock() local
2557 ff->flock = true; in fuse_file_flock()
2598 struct fuse_file *ff = file->private_data; in fuse_lseek() local
2601 .fh = ff->fh, in fuse_lseek()
2612 args.nodeid = ff->nodeid; in fuse_lseek()
2681 struct fuse_file *ff; in fuse_find_polled_node() local
2684 ff = rb_entry(last, struct fuse_file, polled_node); in fuse_find_polled_node()
2686 if (kh < ff->kh) in fuse_find_polled_node()
2688 else if (kh > ff->kh) in fuse_find_polled_node()
2706 struct fuse_file *ff) in fuse_register_polled_file() argument
2709 if (RB_EMPTY_NODE(&ff->polled_node)) { in fuse_register_polled_file()
2712 link = fuse_find_polled_node(fc, ff->kh, &parent); in fuse_register_polled_file()
2714 rb_link_node(&ff->polled_node, parent, link); in fuse_register_polled_file()
2715 rb_insert_color(&ff->polled_node, &fc->polled_files); in fuse_register_polled_file()
2722 struct fuse_file *ff = file->private_data; in fuse_file_poll() local
2723 struct fuse_mount *fm = ff->fm; in fuse_file_poll()
2724 struct fuse_poll_in inarg = { .fh = ff->fh, .kh = ff->kh }; in fuse_file_poll()
2732 poll_wait(file, &ff->poll_wait, wait); in fuse_file_poll()
2739 if (waitqueue_active(&ff->poll_wait)) { in fuse_file_poll()
2741 fuse_register_polled_file(fm->fc, ff); in fuse_file_poll()
2745 args.nodeid = ff->nodeid; in fuse_file_poll()
2778 struct fuse_file *ff; in fuse_notify_poll_wakeup() local
2780 ff = rb_entry(*link, struct fuse_file, polled_node); in fuse_notify_poll_wakeup()
2781 wake_up_interruptible_sync(&ff->poll_wait); in fuse_notify_poll_wakeup()
2813 struct fuse_file *ff = file->private_data; in fuse_direct_IO() local
2843 io->async = ff->fm->fc->async_dio; in fuse_direct_IO()
2849 iov_iter_truncate(iter, fuse_round_up(ff->fm->fc, i_size - offset)); in fuse_direct_IO()
2916 struct fuse_file *ff = file->private_data; in fuse_file_fallocate() local
2919 struct fuse_mount *fm = ff->fm; in fuse_file_fallocate()
2922 .fh = ff->fh, in fuse_file_fallocate()
2970 args.nodeid = ff->nodeid; in fuse_file_fallocate()