| /linux/fs/netfs/ |
| H A D | write_issue.c | 102 if (IS_ERR(wreq)) in netfs_create_write_req()
103 return wreq; in netfs_create_write_req()
111 wreq->cleaned_to = wreq->start; in netfs_create_write_req()
131 return wreq; in netfs_create_write_req()
340 netfs_put_group_many(wreq->group, wreq->nr_group_rel); in netfs_write_folio()
505 netfs_issue_write(wreq, &wreq->io_streams[s]); in netfs_write_folio()
578 wreq->netfs_ops->begin_writeback(wreq); in netfs_writepages()
617 return wreq; in netfs_begin_writethrough()
622 return wreq; in netfs_begin_writethrough()
636 wreq->debug_id, wreq->iter.count, wreq->wsize, copied, to_page_end); in netfs_advance_writethrough()
[all …]
|
| H A D | write_collect.c | 166 wreq->netfs_ops->retry_request(wreq, stream); in netfs_retry_write_stream()
383 _enter("%llx-%llx", wreq->start, wreq->start + wreq->len); in netfs_collect_write_results()
488 trace_netfs_collect_state(wreq, wreq->collected_to, notes); in netfs_collect_write_results()
492 if (wreq->cleaned_to < wreq->collected_to) in netfs_collect_write_results()
495 wreq->cleaned_to = wreq->collected_to; in netfs_collect_write_results()
518 netfs_put_group_many(wreq->group, wreq->nr_group_rel); in netfs_collect_write_results()
587 if (wreq->cleanup) in netfs_write_collection_worker()
588 wreq->cleanup(wreq); in netfs_write_collection_worker()
611 if (wreq->iocb) { in netfs_write_collection_worker()
612 size_t written = min(wreq->transferred, wreq->len); in netfs_write_collection_worker()
[all …]
|
| H A D | direct_write.c | 15 unsigned long long end = wreq->start + wreq->transferred; in netfs_cleanup_dio_write()
17 if (!wreq->error && in netfs_cleanup_dio_write()
53 if (IS_ERR(wreq)) in netfs_unbuffered_write_iter_locked()
54 return PTR_ERR(wreq); in netfs_unbuffered_write_iter_locked()
76 wreq->direct_bv = (struct bio_vec *)wreq->iter.bvec; in netfs_unbuffered_write_iter_locked()
80 wreq->iter = *iter; in netfs_unbuffered_write_iter_locked()
83 wreq->io_iter = wreq->iter; in netfs_unbuffered_write_iter_locked()
94 wreq->iocb = iocb; in netfs_unbuffered_write_iter_locked()
95 wreq->len = iov_iter_count(&wreq->io_iter); in netfs_unbuffered_write_iter_locked()
97 ret = netfs_unbuffered_write(wreq, is_sync_kiocb(iocb), wreq->len); in netfs_unbuffered_write_iter_locked()
[all …]
|
| H A D | read_pgpriv2.c | 73 i_size = i_size_read(wreq->inode); in netfs_pgpriv2_copy_folio()
82 if (fpos + fsize > wreq->i_size) in netfs_pgpriv2_copy_folio()
83 wreq->i_size = i_size; in netfs_pgpriv2_copy_folio()
125 wreq->io_iter.iov_offset = 0; in netfs_pgpriv2_copy_folio()
130 netfs_issue_write(wreq, cache); in netfs_pgpriv2_copy_folio()
142 struct netfs_io_request *wreq; in netfs_pgpriv2_write_to_the_cache() local
166 if (IS_ERR(wreq)) { in netfs_pgpriv2_write_to_the_cache()
190 netfs_issue_write(wreq, &wreq->io_streams[1]); in netfs_pgpriv2_write_to_the_cache()
241 wreq->cleaned_to = fpos + fsize; in netfs_pgpriv2_unlock_copied_folios()
261 wreq->buffer = folioq; in netfs_pgpriv2_unlock_copied_folios()
[all …]
|
| H A D | fscache_io.c | 201 if (wreq->using_pgpriv2) in fscache_wreq_done()
202 fscache_clear_page_bits(wreq->mapping, wreq->start, wreq->len, in fscache_wreq_done()
203 wreq->set_bits); in fscache_wreq_done()
205 if (wreq->term_func) in fscache_wreq_done()
206 wreq->term_func(wreq->term_func_priv, transferred_or_error, in fscache_wreq_done()
209 kfree(wreq); in fscache_wreq_done()
230 if (!wreq) in __fscache_write_to_cache()
233 wreq->start = start; in __fscache_write_to_cache()
234 wreq->len = len; in __fscache_write_to_cache()
236 wreq->set_bits = cond; in __fscache_write_to_cache()
[all …]
|
| H A D | buffered_write.c | 110 struct netfs_io_request *wreq = NULL; in netfs_perform_write() local
129 wreq = netfs_begin_writethrough(iocb, iter->count); in netfs_perform_write()
130 if (IS_ERR(wreq)) { in netfs_perform_write()
132 ret = PTR_ERR(wreq); in netfs_perform_write()
133 wreq = NULL; in netfs_perform_write()
137 wreq->iocb = iocb; in netfs_perform_write()
354 if (likely(!wreq)) { in netfs_perform_write()
358 netfs_advance_writethrough(wreq, &wbc, folio, copied, in netfs_perform_write()
384 if (unlikely(wreq)) { in netfs_perform_write()
385 ret2 = netfs_end_writethrough(wreq, &wbc, writethrough); in netfs_perform_write()
|
| H A D | internal.h | 64 struct folio_queue *netfs_delete_buffer_head(struct netfs_io_request *wreq);
101 bool netfs_pgpriv2_unlock_copied_folios(struct netfs_io_request *wreq);
170 void netfs_wake_write_collector(struct netfs_io_request *wreq, bool was_async);
182 void netfs_issue_write(struct netfs_io_request *wreq,
184 int netfs_advance_write(struct netfs_io_request *wreq,
188 int netfs_advance_writethrough(struct netfs_io_request *wreq, struct writeback_control *wbc,
191 int netfs_end_writethrough(struct netfs_io_request *wreq, struct writeback_control *wbc,
193 int netfs_unbuffered_write(struct netfs_io_request *wreq, bool may_wait, size_t len);
|
| H A D | misc.c | 84 struct folio_queue *netfs_delete_buffer_head(struct netfs_io_request *wreq) in netfs_delete_buffer_head() argument
86 struct folio_queue *head = wreq->buffer, *next = head->next; in netfs_delete_buffer_head()
92 wreq->buffer = next; in netfs_delete_buffer_head()
|
| /linux/include/trace/events/ |
| H A D | netfs.h | 489 TP_ARGS(wreq, what),
503 __entry->wreq = wreq->debug_id;
512 __entry->wreq,
522 TP_ARGS(wreq),
532 __entry->wreq = wreq->debug_id;
539 __entry->wreq,
560 __entry->wreq = wreq->debug_id;
590 __entry->wreq = wreq->debug_id;
618 __entry->wreq = wreq->debug_id;
646 __entry->wreq = wreq->debug_id;
[all …]
|
| /linux/fs/afs/ |
| H 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()
114 wreq->debug_id, subreq->debug_index, in afs_issue_write_worker()
161 if (wreq->netfs_priv2) in afs_issue_write_worker()
182 afs_get_writeback_key(wreq); in afs_begin_writeback()
183 wreq->io_streams[0].avail = true; in afs_begin_writeback()
203 afs_get_writeback_key(wreq); in afs_retry_request()
[all …]
|
| H A D | file.c | 406 static void afs_netfs_invalidate_cache(struct netfs_io_request *wreq) in afs_netfs_invalidate_cache() argument
408 struct afs_vnode *vnode = AFS_FS_I(wreq->inode); in afs_netfs_invalidate_cache()
|
| H A D | internal.h | 1607 void afs_begin_writeback(struct netfs_io_request *wreq);
1608 void afs_retry_request(struct netfs_io_request *wreq, struct netfs_io_stream *stream);
|
| /linux/fs/9p/ |
| H 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()
|
| /linux/fs/cachefiles/ |
| H 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()
|
| /linux/drivers/net/ethernet/chelsio/inline_crypto/ch_ipsec/ |
| H A D | chcr_ipsec.h | 33 struct fw_ulptx_wr wreq; member
|
| H A D | chcr_ipsec.c | 600 wr->wreq.op_to_compl = htonl(FW_WR_OP_V(FW_ULPTX_WR)); in ch_ipsec_crypto_wreq()
610 wr->wreq.flowid_len16 = htonl(wr_mid); in ch_ipsec_crypto_wreq()
|
| /linux/net/9p/ |
| H A D | trans_fd.c | 120 struct p9_req_t *wreq; member
476 m->wreq = req; in p9_write_work()
499 p9_req_put(m->client, m->wreq); in p9_write_work()
500 m->wreq = NULL; in p9_write_work()
918 if (m->wreq) { in p9_conn_destroy()
919 p9_req_put(m->client, m->wreq); in p9_conn_destroy()
920 m->wreq = NULL; in p9_conn_destroy()
|
| H A D | client.c | 1680 struct netfs_io_request *wreq = subreq->rreq; in p9_client_write_subreq() local
1681 struct p9_fid *fid = wreq->netfs_priv; in p9_client_write_subreq()
1694 0, wreq->len, P9_ZC_HDR_SZ, "dqd", in p9_client_write_subreq()
|
| /linux/include/linux/ |
| H A D | netfs.h | 314 void (*begin_writeback)(struct netfs_io_request *wreq);
317 void (*retry_request)(struct netfs_io_request *wreq, struct netfs_io_stream *stream);
318 void (*invalidate_cache)(struct netfs_io_request *wreq);
|
| /linux/drivers/crypto/chelsio/ |
| H A D | chcr_core.h | 89 struct fw_crypto_lookaside_wr wreq; member
|
| H A D | chcr_algo.c | 777 chcr_req->wreq.op_to_cctx_size = FILL_WR_OP_CCTX_SIZE; in create_wreq()
778 chcr_req->wreq.pld_size_hash_size = in create_wreq()
780 chcr_req->wreq.len16_pkd = in create_wreq()
782 chcr_req->wreq.cookie = cpu_to_be64((uintptr_t)req); in create_wreq()
783 chcr_req->wreq.rx_chid_to_rx_q_id = FILL_WR_RX_Q_ID(rx_channel_id, qid, in create_wreq()
788 ((sizeof(chcr_req->wreq)) >> 4))); in create_wreq()
|
| /linux/fs/smb/client/ |
| H A D | compress.c | 307 const struct smb2_write_req *wreq = rq->rq_iov->iov_base; in should_compress() local
309 if (le32_to_cpu(wreq->Length) < SMB_COMPRESS_MIN_LEN) in should_compress()
|
| H A D | file.c | 137 static void cifs_netfs_invalidate_cache(struct netfs_io_request *wreq) in cifs_netfs_invalidate_cache() argument
139 cifs_invalidate_cache(wreq->inode, 0); in cifs_netfs_invalidate_cache()
237 static void cifs_begin_writeback(struct netfs_io_request *wreq) in cifs_begin_writeback() argument
239 struct cifs_io_request *req = container_of(wreq, struct cifs_io_request, rreq); in cifs_begin_writeback()
242 ret = cifs_get_writable_file(CIFS_I(wreq->inode), FIND_WR_ANY, &req->cfile); in cifs_begin_writeback()
248 wreq->io_streams[0].avail = true; in cifs_begin_writeback()
2395 struct netfs_io_request *wreq = wdata->rreq; in cifs_write_subrequest_terminated() local
2396 struct netfs_inode *ictx = netfs_inode(wreq->inode); in cifs_write_subrequest_terminated()
|
| /linux/net/wireless/ |
| H A D | scan.c | 3468 struct iw_scan_req *wreq = NULL; in cfg80211_wext_siwscan() local
3477 wreq = (struct iw_scan_req *)extra; in cfg80211_wext_siwscan()
3490 if (wreq && wreq->num_channels) { in cfg80211_wext_siwscan()
3494 n_channels = wreq->num_channels; in cfg80211_wext_siwscan()
3531 if (wreq && wreq->num_channels) { in cfg80211_wext_siwscan()
3534 for (k = 0; k < wreq->num_channels; k++) { in cfg80211_wext_siwscan()
3536 &wreq->channel_list[k]; in cfg80211_wext_siwscan()
3562 if (wreq) { in cfg80211_wext_siwscan()
3568 memcpy(creq->ssids[0].ssid, wreq->essid, wreq->essid_len); in cfg80211_wext_siwscan()
3569 creq->ssids[0].ssid_len = wreq->essid_len; in cfg80211_wext_siwscan()
[all …]
|