| /linux/fs/netfs/ |
| H A D | internal.h | 26 int netfs_read_query_cache(struct netfs_io_request *rreq, 28 void netfs_queue_read(struct netfs_io_request *rreq, 51 static inline void netfs_proc_add_rreq(struct netfs_io_request *rreq) in netfs_proc_add_rreq() 57 static inline void netfs_proc_del_rreq(struct netfs_io_request *rreq) in netfs_proc_del_rreq() 66 static inline void netfs_proc_add_rreq(struct netfs_io_request *rreq) {} in netfs_proc_add_rreq() 67 static inline void netfs_proc_del_rreq(struct netfs_io_request *rreq) {} in netfs_proc_del_rreq() 73 struct folio_queue *netfs_buffer_make_space(struct netfs_io_request *rreq, 76 void netfs_wake_collector(struct netfs_io_request *rreq); 78 void netfs_wait_for_in_progress_stream(struct netfs_io_request *rreq, 80 ssize_t netfs_wait_for_read(struct netfs_io_request *rreq); [all …]
|
| H A D | objects.c | 17 struct netfs_io_request *netfs_alloc_request(struct address_space *mapping, in netfs_alloc_request() 25 struct netfs_io_request *rreq; in netfs_alloc_request() 100 void netfs_get_request(struct netfs_io_request *rreq, enum netfs_rreq_ref_trace what) in netfs_get_request() 108 void netfs_clear_subrequests(struct netfs_io_request *rreq) in netfs_clear_subrequests() 127 struct netfs_io_request *rreq = container_of(rcu, struct netfs_io_request, rcu); in netfs_free_request_rcu() 133 static void netfs_deinit_request(struct netfs_io_request *rreq) in netfs_deinit_request() 168 struct netfs_io_request *rreq = in netfs_free_request() 169 container_of(work, struct netfs_io_request, cleanup_work); in netfs_free_request() 175 void netfs_put_request(struct netfs_io_request *rreq, enum netfs_rreq_ref_trace what) in netfs_put_request() 194 void netfs_put_failed_request(struct netfs_io_request *rreq) in netfs_put_failed_request() [all …]
|
| H A D | read_pgpriv2.c | 19 static void netfs_pgpriv2_copy_folio(struct netfs_io_request *creq, struct folio *folio) in netfs_pgpriv2_copy_folio() 98 static struct netfs_io_request *netfs_pgpriv2_begin_copy_to_cache( in netfs_pgpriv2_begin_copy_to_cache() 99 struct netfs_io_request *rreq, struct folio *folio) in netfs_pgpriv2_begin_copy_to_cache() 101 struct netfs_io_request *creq; in netfs_pgpriv2_begin_copy_to_cache() 134 void netfs_pgpriv2_copy_to_cache(struct netfs_io_request *rreq, struct folio *folio) in netfs_pgpriv2_copy_to_cache() 136 struct netfs_io_request *creq = rreq->copy_to_cache; in netfs_pgpriv2_copy_to_cache() 153 void netfs_pgpriv2_end_copy_to_cache(struct netfs_io_request *rreq) in netfs_pgpriv2_end_copy_to_cache() 155 struct netfs_io_request *creq = rreq->copy_to_cache; in netfs_pgpriv2_end_copy_to_cache() 174 bool netfs_pgpriv2_unlock_copied_folios(struct netfs_io_request *creq) in netfs_pgpriv2_unlock_copied_folios()
|
| H A D | misc.c | 339 void netfs_wake_collector(struct netfs_io_request *rreq) in netfs_wake_collector() 356 struct netfs_io_request *rreq = subreq->rreq; in netfs_subreq_clear_in_progress() 371 void netfs_wait_for_in_progress_stream(struct netfs_io_request *rreq, in netfs_wait_for_in_progress_stream() 401 static int netfs_collect_in_app(struct netfs_io_request *rreq, in netfs_collect_in_app() 402 bool (*collector)(struct netfs_io_request *rreq)) in netfs_collect_in_app() 453 static ssize_t netfs_wait_for_in_progress(struct netfs_io_request *rreq, in netfs_wait_for_in_progress() 454 bool (*collector)(struct netfs_io_request *rreq)) in netfs_wait_for_in_progress() 509 ssize_t netfs_wait_for_read(struct netfs_io_request *rreq) in netfs_wait_for_read() 514 ssize_t netfs_wait_for_write(struct netfs_io_request *rreq) in netfs_wait_for_write() 522 static void netfs_wait_for_pause(struct netfs_io_request *rreq, in netfs_wait_for_pause() [all …]
|
| H A D | buffered_read.c | 12 static void netfs_cache_expand_readahead(struct netfs_io_request *rreq, in netfs_cache_expand_readahead() 23 static void netfs_rreq_expand(struct netfs_io_request *rreq, in netfs_rreq_expand() 60 static void netfs_bulk_drop_ra_refs(struct netfs_io_request *rreq) in netfs_bulk_drop_ra_refs() 87 static void netfs_maybe_bulk_drop_ra_refs(struct netfs_io_request *rreq) in netfs_maybe_bulk_drop_ra_refs() 97 static int netfs_begin_cache_read(struct netfs_io_request *rreq, struct netfs_inode *ctx) in netfs_begin_cache_read() 116 struct netfs_io_request *rreq = subreq->rreq; in netfs_prepare_read_iterator() 144 static void netfs_read_cache_to_pagecache(struct netfs_io_request *rreq, in netfs_read_cache_to_pagecache() 154 int netfs_read_query_cache(struct netfs_io_request *rreq, struct fscache_occupancy *occ) in netfs_read_query_cache() 167 void netfs_queue_read(struct netfs_io_request *rreq, in netfs_queue_read() 192 static void netfs_issue_read(struct netfs_io_request *rreq, in netfs_issue_read() [all …]
|
| H A D | read_collect.c | 39 struct netfs_io_request *rreq = subreq->rreq; in netfs_clear_unread_dio() 55 void netfs_cancel_copy_to_cache(struct netfs_io_request *rreq, struct folio *folio) in netfs_cancel_copy_to_cache() 81 static void netfs_unlock_read_folio(struct netfs_io_request *rreq, in netfs_unlock_read_folio() 139 void netfs_read_set_unlock_at(struct netfs_io_request *rreq) in netfs_read_set_unlock_at() 168 static void netfs_read_unlock_folios(struct netfs_io_request *rreq, in netfs_read_unlock_folios() 254 static void netfs_collect_read_results(struct netfs_io_request *rreq) in netfs_collect_read_results() 419 static void netfs_rreq_assess_dio(struct netfs_io_request *rreq) in netfs_rreq_assess_dio() 452 static void netfs_rreq_assess_single(struct netfs_io_request *rreq) in netfs_rreq_assess_single() 485 bool netfs_read_collection(struct netfs_io_request *rreq) in netfs_read_collection() 532 struct netfs_io_request *rreq = container_of(work, struct netfs_io_request, work); in netfs_read_collection_worker() [all …]
|
| H A D | read_single.c | 56 static int netfs_single_begin_cache_read(struct netfs_io_request *rreq, struct netfs_inode *ctx) in netfs_single_begin_cache_read() 61 static void netfs_single_read_cache(struct netfs_io_request *rreq, in netfs_single_read_cache() 76 static int netfs_single_dispatch_read(struct netfs_io_request *rreq) in netfs_single_dispatch_read() 168 struct netfs_io_request *rreq; in netfs_read_single()
|
| H A D | write_issue.c | 90 struct netfs_io_request *netfs_create_write_req(struct address_space *mapping, in netfs_create_write_req() 95 struct netfs_io_request *wreq; in netfs_create_write_req() 159 void netfs_prepare_write(struct netfs_io_request *wreq, in netfs_prepare_write() 233 struct netfs_io_request *wreq = subreq->rreq; in netfs_do_issue_write() 278 void netfs_issue_write(struct netfs_io_request *wreq, in netfs_issue_write() 297 size_t netfs_advance_write(struct netfs_io_request *wreq, in netfs_advance_write() 339 static int netfs_write_folio(struct netfs_io_request *wreq, in netfs_write_folio() 537 static void netfs_end_issue_write(struct netfs_io_request *wreq) in netfs_end_issue_write() 564 struct netfs_io_request *wreq = NULL; in netfs_writepages() 631 static int netfs_write_folio_single(struct netfs_io_request *wreq, in netfs_write_folio_single() [all …]
|
| H A D | write_collect.c | 24 static void netfs_dump_request(const struct netfs_io_request *rreq) in netfs_dump_request() 114 static void netfs_writeback_unlock_folios(struct netfs_io_request *wreq, in netfs_writeback_unlock_folios() 194 static void netfs_cache_collect(struct netfs_io_request *wreq, in netfs_cache_collect() 220 static void netfs_collect_write_results(struct netfs_io_request *wreq) in netfs_collect_write_results() 414 bool netfs_write_collection(struct netfs_io_request *wreq) in netfs_write_collection() 496 struct netfs_io_request *rreq = container_of(work, struct netfs_io_request, work); in netfs_write_collection_worker() 530 struct netfs_io_request *wreq = subreq->rreq; in netfs_write_subrequest_terminated()
|
| H A D | direct_read.c | 21 struct netfs_io_request *rreq = subreq->rreq; in netfs_prepare_dio_read_iterator() 48 static void netfs_dispatch_unbuffered_reads(struct netfs_io_request *rreq) in netfs_dispatch_unbuffered_reads() 108 static ssize_t netfs_unbuffered_read(struct netfs_io_request *rreq, bool sync) in netfs_unbuffered_read() 151 struct netfs_io_request *rreq; in netfs_unbuffered_read_iter_locked()
|
| H A D | main.c | 57 struct netfs_io_request *rreq; in netfs_requests_seq_show() 67 rreq = list_entry(v, struct netfs_io_request, proc_link); in netfs_requests_seq_show() 115 sizeof(struct netfs_io_request), 0, in netfs_init()
|
| H A D | direct_write.c | 15 static void netfs_unbuffered_write_done(struct netfs_io_request *wreq) in netfs_unbuffered_write_done() 65 static void netfs_unbuffered_write_collect(struct netfs_io_request *wreq, in netfs_unbuffered_write_collect() 94 static int netfs_unbuffered_write(struct netfs_io_request *wreq) in netfs_unbuffered_write() 214 struct netfs_io_request *wreq = container_of(work, struct netfs_io_request, work); in netfs_unbuffered_write_async() 227 struct netfs_io_request *wreq; in netfs_unbuffered_write_iter_locked()
|
| H A D | read_retry.c | 12 static void netfs_reissue_read(struct netfs_io_request *rreq, in netfs_reissue_read() 26 static void netfs_retry_read_subrequests(struct netfs_io_request *rreq) in netfs_retry_read_subrequests() 269 void netfs_retry_reads(struct netfs_io_request *rreq) in netfs_retry_reads() 292 void netfs_unlock_abandoned_read_pages(struct netfs_io_request *rreq) in netfs_unlock_abandoned_read_pages()
|
| H A D | write_retry.c | 17 static void netfs_retry_write_stream(struct netfs_io_request *wreq, in netfs_retry_write_stream() 207 void netfs_retry_writes(struct netfs_io_request *wreq) in netfs_retry_writes()
|
| /linux/include/linux/ |
| H A D | netfs.h | 187 struct netfs_io_request *rreq; /* Supervising I/O request */ 233 struct netfs_io_request { struct 243 struct netfs_io_request *copy_to_cache; /* Request to write just-read data to the cache */ argument 309 int (*init_request)(struct netfs_io_request *rreq, struct file *file); argument 310 void (*free_request)(struct netfs_io_request *rreq); 314 void (*expand_readahead)(struct netfs_io_request *rreq); 317 bool (*is_still_valid)(struct netfs_io_request *rreq); 320 void (*done)(struct netfs_io_request *rreq); 327 void (*begin_writeback)(struct netfs_io_request *wreq); 330 void (*retry_request)(struct netfs_io_request *wreq, struct netfs_io_stream *stream); [all …]
|
| /linux/include/trace/events/ |
| H A D | netfs.h | 309 TP_PROTO(struct netfs_io_request *rreq, 346 TP_PROTO(struct netfs_io_request *rreq, 414 TP_PROTO(struct netfs_io_request *rreq, 556 TP_PROTO(const struct netfs_io_request *wreq, 590 TP_PROTO(const struct netfs_io_request *rreq, 591 const struct netfs_io_request *creq), 620 TP_PROTO(const struct netfs_io_request *wreq), 645 TP_PROTO(const struct netfs_io_request *wreq, 674 TP_PROTO(const struct netfs_io_request *wreq, 697 TP_PROTO(const struct netfs_io_request *wreq, [all …]
|
| /linux/fs/9p/ |
| H A D | vfs_addr.c | 33 static void v9fs_begin_writeback(struct netfs_io_request *wreq) in v9fs_begin_writeback() 97 struct netfs_io_request *rreq = subreq->rreq; in v9fs_issue_read() 148 static int v9fs_init_request(struct netfs_io_request *rreq, struct file *file) in v9fs_init_request() 202 static void v9fs_free_request(struct netfs_io_request *rreq) in v9fs_free_request()
|
| /linux/fs/afs/ |
| H A D | write.c | 35 static void afs_get_writeback_key(struct netfs_io_request *wreq) in afs_get_writeback_key() 105 struct netfs_io_request *wreq = subreq->rreq; in afs_issue_write_worker() 182 void afs_begin_writeback(struct netfs_io_request *wreq) in afs_begin_writeback() 192 void afs_retry_request(struct netfs_io_request *wreq, struct netfs_io_stream *stream) in afs_retry_request()
|
| H A D | file.c | 383 static int afs_init_request(struct netfs_io_request *rreq, struct file *file) in afs_init_request() 423 static void afs_free_request(struct netfs_io_request *rreq) in afs_free_request() 457 static void afs_netfs_invalidate_cache(struct netfs_io_request *wreq) in afs_netfs_invalidate_cache()
|
| H A D | internal.h | 1713 void afs_begin_writeback(struct netfs_io_request *wreq); 1714 void afs_retry_request(struct netfs_io_request *wreq, struct netfs_io_stream *stream);
|
| /linux/fs/nfs/ |
| H A D | fscache.c | 264 static int nfs_netfs_init_request(struct netfs_io_request *rreq, struct file *file) in nfs_netfs_init_request() 281 static void nfs_netfs_free_request(struct netfs_io_request *rreq) in nfs_netfs_free_request()
|
| /linux/fs/cachefiles/ |
| H A D | io.c | 520 struct netfs_io_request *wreq = subreq->rreq; in cachefiles_prepare_write_subreq() 545 struct netfs_io_request *wreq = subreq->rreq; in cachefiles_issue_write() 638 static void cachefiles_collect_write(struct netfs_io_request *wreq, in cachefiles_collect_write()
|
| /linux/Documentation/filesystems/ |
| H A D | netfs_library.rst | 527 struct netfs_io_request { 674 struct netfs_io_request *rreq; 776 int (*init_request)(struct netfs_io_request *rreq, struct file *file); 777 void (*free_request)(struct netfs_io_request *rreq); 779 void (*expand_readahead)(struct netfs_io_request *rreq); 782 void (*done)(struct netfs_io_request *rreq); 785 void (*begin_writeback)(struct netfs_io_request *wreq); 788 void (*retry_request)(struct netfs_io_request *wreq, 790 void (*invalidate_cache)(struct netfs_io_request *wreq); 963 Firstly, the netfs_io_request object contains a place for the cache to hang its
|
| /linux/fs/smb/client/ |
| H A D | file.c | 145 static void cifs_netfs_invalidate_cache(struct netfs_io_request *wreq) in cifs_netfs_invalidate_cache() 155 struct netfs_io_request *rreq = subreq->rreq; in cifs_prepare_read() 211 struct netfs_io_request *rreq = subreq->rreq; in cifs_issue_read() 253 static void cifs_begin_writeback(struct netfs_io_request *wreq) in cifs_begin_writeback() 270 static int cifs_init_request(struct netfs_io_request *rreq, struct file *file) in cifs_init_request() 298 static void cifs_rreq_done(struct netfs_io_request *rreq) in cifs_rreq_done() 310 static void cifs_free_request(struct netfs_io_request *rreq) in cifs_free_request() 2610 struct netfs_io_request *wreq = wdata->rreq; in cifs_write_subrequest_terminated()
|
| /linux/fs/ceph/ |
| H A D | addr.c | 169 static void ceph_netfs_expand_readahead(struct netfs_io_request *rreq) in ceph_netfs_expand_readahead() 282 struct netfs_io_request *rreq = subreq->rreq; in ceph_netfs_issue_op_inline() 344 struct netfs_io_request *rreq = subreq->rreq; in ceph_netfs_prepare_read() 360 struct netfs_io_request *rreq = subreq->rreq; in ceph_netfs_issue_read() 466 static int ceph_init_request(struct netfs_io_request *rreq, struct file *file) in ceph_init_request() 533 static void ceph_netfs_free_request(struct netfs_io_request *rreq) in ceph_netfs_free_request()
|