| /fs/netfs/ |
| A D | write_issue.c | 104 return wreq; in netfs_create_write_req()
114 wreq->cleaned_to = wreq->start; in netfs_create_write_req()
134 return wreq; in netfs_create_write_req()
352 netfs_put_group_many(wreq->group, wreq->nr_group_rel); in netfs_write_folio()
518 netfs_issue_write(wreq, &wreq->io_streams[s]); in netfs_write_folio()
592 wreq->netfs_ops->begin_writeback(wreq); in netfs_writepages()
632 return wreq; in netfs_begin_writethrough()
637 return wreq; in netfs_begin_writethrough()
651 wreq->debug_id, wreq->buffer.iter.count, wreq->wsize, copied, to_page_end); in netfs_advance_writethrough()
891 wreq->netfs_ops->begin_writeback(wreq); in netfs_writeback_single()
[all …]
|
| A D | write_collect.c | 205 _enter("%llx-%llx", wreq->start, wreq->start + wreq->len); in netfs_collect_write_results()
311 trace_netfs_collect_state(wreq, wreq->collected_to, notes); in netfs_collect_write_results()
315 if (wreq->cleaned_to < wreq->collected_to) in netfs_collect_write_results()
318 wreq->cleaned_to = wreq->collected_to; in netfs_collect_write_results()
338 netfs_put_group_many(wreq->group, wreq->nr_group_rel); in netfs_collect_write_results()
404 !wreq->error) in netfs_write_collection()
405 netfs_update_i_size(ictx, &ictx->inode, wreq->start, wreq->transferred); in netfs_write_collection()
416 pgoff_t last = (wreq->start + wreq->transferred - 1) >> PAGE_SHIFT; in netfs_write_collection()
427 if (wreq->iocb) { in netfs_write_collection()
428 size_t written = min(wreq->transferred, wreq->len); in netfs_write_collection()
[all …]
|
| A D | direct_write.c | 19 struct netfs_io_request *wreq; in netfs_unbuffered_write_iter_locked() local
39 if (IS_ERR(wreq)) in netfs_unbuffered_write_iter_locked()
40 return PTR_ERR(wreq); in netfs_unbuffered_write_iter_locked()
42 wreq->io_streams[0].avail = true; in netfs_unbuffered_write_iter_locked()
62 wreq->direct_bv = (struct bio_vec *)wreq->buffer.iter.bvec; in netfs_unbuffered_write_iter_locked()
63 wreq->direct_bv_count = n; in netfs_unbuffered_write_iter_locked()
71 wreq->buffer.iter = *iter; in netfs_unbuffered_write_iter_locked()
85 wreq->iocb = iocb; in netfs_unbuffered_write_iter_locked()
86 wreq->len = iov_iter_count(&wreq->buffer.iter); in netfs_unbuffered_write_iter_locked()
87 ret = netfs_unbuffered_write(wreq, is_sync_kiocb(iocb), wreq->len); in netfs_unbuffered_write_iter_locked()
[all …]
|
| A D | fscache_io.c | 199 if (wreq->using_pgpriv2) in fscache_wreq_done()
200 fscache_clear_page_bits(wreq->mapping, wreq->start, wreq->len, in fscache_wreq_done()
201 wreq->set_bits); in fscache_wreq_done()
203 if (wreq->term_func) in fscache_wreq_done()
204 wreq->term_func(wreq->term_func_priv, transferred_or_error); in fscache_wreq_done()
206 kfree(wreq); in fscache_wreq_done()
227 if (!wreq) in __fscache_write_to_cache()
230 wreq->start = start; in __fscache_write_to_cache()
231 wreq->len = len; in __fscache_write_to_cache()
233 wreq->set_bits = cond; in __fscache_write_to_cache()
[all …]
|
| A D | write_retry.c | 22 _enter("R=%x[%x:]", wreq->debug_id, stream->stream_nr); in netfs_retry_write_stream()
28 wreq->netfs_ops->retry_request) in netfs_retry_write_stream()
29 wreq->netfs_ops->retry_request(wreq, stream); in netfs_retry_write_stream()
146 subreq = netfs_alloc_subrequest(wreq); in netfs_retry_write_stream()
166 stream->sreq_max_len = umin(len, wreq->wsize); in netfs_retry_write_stream()
210 set_bit(NETFS_RREQ_RETRYING, &wreq->flags); in netfs_retry_writes()
212 stream = &wreq->io_streams[s]; in netfs_retry_writes()
214 netfs_wait_for_in_progress_stream(wreq, stream); in netfs_retry_writes()
216 clear_bit(NETFS_RREQ_RETRYING, &wreq->flags); in netfs_retry_writes()
224 stream = &wreq->io_streams[s]; in netfs_retry_writes()
[all …]
|
| A D | buffered_write.c | 120 struct netfs_io_request *wreq = NULL; in netfs_perform_write() local
138 wreq = netfs_begin_writethrough(iocb, iter->count); in netfs_perform_write()
139 if (IS_ERR(wreq)) { in netfs_perform_write()
141 ret = PTR_ERR(wreq); in netfs_perform_write()
142 wreq = NULL; in netfs_perform_write()
146 wreq->iocb = iocb; in netfs_perform_write()
361 if (likely(!wreq)) { in netfs_perform_write()
365 netfs_advance_writethrough(wreq, &wbc, folio, copied, in netfs_perform_write()
391 if (unlikely(wreq)) { in netfs_perform_write()
392 ret2 = netfs_end_writethrough(wreq, &wbc, writethrough); in netfs_perform_write()
|
| A D | internal.h | 117 bool netfs_pgpriv2_unlock_copied_folios(struct netfs_io_request *wreq);
190 bool netfs_write_collection(struct netfs_io_request *wreq);
203 void netfs_issue_write(struct netfs_io_request *wreq,
205 size_t netfs_advance_write(struct netfs_io_request *wreq,
209 int netfs_advance_writethrough(struct netfs_io_request *wreq, struct writeback_control *wbc,
212 ssize_t netfs_end_writethrough(struct netfs_io_request *wreq, struct writeback_control *wbc,
214 int netfs_unbuffered_write(struct netfs_io_request *wreq, bool may_wait, size_t len);
219 void netfs_retry_writes(struct netfs_io_request *wreq);
|
| /fs/afs/ |
| A D | write.c | 41 key_put(wreq->netfs_priv); in afs_get_writeback_key()
42 wreq->netfs_priv = NULL; in afs_get_writeback_key()
43 wreq->netfs_priv2 = NULL; in afs_get_writeback_key()
55 wreq->netfs_priv = key_get(wbk->key); in afs_get_writeback_key()
56 wreq->netfs_priv2 = wbk; in afs_get_writeback_key()
164 if (wreq->netfs_priv2) in afs_issue_write_worker()
185 if (S_ISREG(wreq->inode->i_mode)) in afs_begin_writeback()
186 afs_get_writeback_key(wreq); in afs_begin_writeback()
199 switch (wreq->origin) { in afs_retry_request()
219 afs_get_writeback_key(wreq); in afs_retry_request()
[all …]
|
| A D | file.c | 442 static void afs_netfs_invalidate_cache(struct netfs_io_request *wreq) in afs_netfs_invalidate_cache() argument
444 struct afs_vnode *vnode = AFS_FS_I(wreq->inode); in afs_netfs_invalidate_cache()
|
| A D | internal.h | 1672 void afs_begin_writeback(struct netfs_io_request *wreq);
1673 void afs_retry_request(struct netfs_io_request *wreq, struct netfs_io_stream *stream);
|
| /fs/9p/ |
| A D | vfs_addr.c | 33 static void v9fs_begin_writeback(struct netfs_io_request *wreq) in v9fs_begin_writeback() argument
37 fid = v9fs_fid_find_inode(wreq->inode, true, INVALID_UID, true); in v9fs_begin_writeback()
40 wreq->inode->i_ino); in v9fs_begin_writeback()
44 wreq->wsize = fid->clnt->msize - P9_IOHDRSZ; in v9fs_begin_writeback()
46 wreq->wsize = min(wreq->wsize, fid->iounit); in v9fs_begin_writeback()
47 wreq->netfs_priv = fid; in v9fs_begin_writeback()
48 wreq->io_streams[0].avail = true; in v9fs_begin_writeback()
|
| /fs/cachefiles/ |
| A D | io.c | 628 struct netfs_io_request *wreq = subreq->rreq; in cachefiles_prepare_write_subreq() local
629 struct netfs_cache_resources *cres = &wreq->cache_resources; in cachefiles_prepare_write_subreq()
630 struct netfs_io_stream *stream = &wreq->io_streams[subreq->stream_nr]; in cachefiles_prepare_write_subreq()
632 _enter("W=%x[%x] %llx", wreq->debug_id, subreq->debug_index, subreq->start); in cachefiles_prepare_write_subreq()
647 struct netfs_io_request *wreq = subreq->rreq; in cachefiles_issue_write() local
648 struct netfs_cache_resources *cres = &wreq->cache_resources; in cachefiles_issue_write()
651 struct netfs_io_stream *stream = &wreq->io_streams[subreq->stream_nr]; in cachefiles_issue_write()
658 wreq->debug_id, subreq->debug_index, start, start + len - 1); in cachefiles_issue_write()
676 if (start + len == wreq->i_size) { in cachefiles_issue_write()
|
| /fs/smb/client/ |
| A D | compress.c | 278 const struct smb2_write_req *wreq = rq->rq_iov->iov_base; in should_compress() local
280 if (le32_to_cpu(wreq->Length) < SMB_COMPRESS_MIN_LEN) in should_compress()
|
| A D | file.c | 142 static void cifs_netfs_invalidate_cache(struct netfs_io_request *wreq) in cifs_netfs_invalidate_cache() argument
144 cifs_invalidate_cache(wreq->inode, 0); in cifs_netfs_invalidate_cache()
245 static void cifs_begin_writeback(struct netfs_io_request *wreq) in cifs_begin_writeback() argument
247 struct cifs_io_request *req = container_of(wreq, struct cifs_io_request, rreq); in cifs_begin_writeback()
250 ret = cifs_get_writable_file(CIFS_I(wreq->inode), FIND_WR_ANY, &req->cfile); in cifs_begin_writeback()
256 wreq->io_streams[0].avail = true; in cifs_begin_writeback()
2436 struct netfs_io_request *wreq = wdata->rreq; in cifs_write_subrequest_terminated() local
2437 struct netfs_inode *ictx = netfs_inode(wreq->inode); in cifs_write_subrequest_terminated()
|