Home
last modified time | relevance | path

Searched refs:wreq (Results 1 – 23 of 23) sorted by relevance

/linux-6.15/fs/netfs/
H A Dwrite_issue.c104 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()
591 wreq->netfs_ops->begin_writeback(wreq); in netfs_writepages()
630 return wreq; in netfs_begin_writethrough()
635 return wreq; in netfs_begin_writethrough()
649 wreq->debug_id, wreq->buffer.iter.count, wreq->wsize, copied, to_page_end); in netfs_advance_writethrough()
892 wreq->netfs_ops->begin_writeback(wreq); in netfs_writeback_single()
[all …]
H A Dwrite_collect.c205 _enter("%llx-%llx", wreq->start, wreq->start + wreq->len); in netfs_collect_write_results()
310 trace_netfs_collect_state(wreq, wreq->collected_to, notes); in netfs_collect_write_results()
314 if (wreq->cleaned_to < wreq->collected_to) in netfs_collect_write_results()
317 wreq->cleaned_to = wreq->collected_to; in netfs_collect_write_results()
341 netfs_put_group_many(wreq->group, wreq->nr_group_rel); in netfs_collect_write_results()
411 if (wreq->cleanup) in netfs_write_collection_worker()
412 wreq->cleanup(wreq); in netfs_write_collection_worker()
423 pgoff_t last = (wreq->start + wreq->transferred - 1) >> PAGE_SHIFT; in netfs_write_collection_worker()
434 if (wreq->iocb) { in netfs_write_collection_worker()
435 size_t written = min(wreq->transferred, wreq->len); in netfs_write_collection_worker()
[all …]
H A Ddirect_write.c15 unsigned long long end = wreq->start + wreq->transferred; in netfs_cleanup_dio_write()
17 if (!wreq->error && in netfs_cleanup_dio_write()
33 struct netfs_io_request *wreq; in netfs_unbuffered_write_iter_locked() local
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->buffer.iter.bvec; in netfs_unbuffered_write_iter_locked()
97 wreq->iocb = iocb; in netfs_unbuffered_write_iter_locked()
98 wreq->len = iov_iter_count(&wreq->buffer.iter); in netfs_unbuffered_write_iter_locked()
100 ret = netfs_unbuffered_write(wreq, is_sync_kiocb(iocb), wreq->len); in netfs_unbuffered_write_iter_locked()
110 ret = wreq->error; in netfs_unbuffered_write_iter_locked()
[all …]
H A Dfscache_io.c200 if (wreq->using_pgpriv2) in fscache_wreq_done()
201 fscache_clear_page_bits(wreq->mapping, wreq->start, wreq->len, in fscache_wreq_done()
202 wreq->set_bits); in fscache_wreq_done()
204 if (wreq->term_func) in fscache_wreq_done()
205 wreq->term_func(wreq->term_func_priv, transferred_or_error, in fscache_wreq_done()
208 kfree(wreq); in fscache_wreq_done()
229 if (!wreq) in __fscache_write_to_cache()
232 wreq->start = start; in __fscache_write_to_cache()
233 wreq->len = len; in __fscache_write_to_cache()
235 wreq->set_bits = cond; in __fscache_write_to_cache()
[all …]
H A Dwrite_retry.c17 static void netfs_retry_write_stream(struct netfs_io_request *wreq, in netfs_retry_write_stream() argument
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()
145 subreq = netfs_alloc_subrequest(wreq); in netfs_retry_write_stream()
152 trace_netfs_sreq_ref(wreq->debug_id, subreq->debug_index, in netfs_retry_write_stream()
166 stream->sreq_max_len = umin(len, wreq->wsize); in netfs_retry_write_stream()
200 void netfs_retry_writes(struct netfs_io_request *wreq) in netfs_retry_writes() argument
212 stream = &wreq->io_streams[s]; in netfs_retry_writes()
228 stream = &wreq->io_streams[s]; in netfs_retry_writes()
[all …]
H A Dbuffered_write.c110 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 Dinternal.h106 bool netfs_pgpriv2_unlock_copied_folios(struct netfs_io_request *wreq);
180 void netfs_wake_write_collector(struct netfs_io_request *wreq, bool was_async);
192 void netfs_issue_write(struct netfs_io_request *wreq,
194 size_t netfs_advance_write(struct netfs_io_request *wreq,
198 int netfs_advance_writethrough(struct netfs_io_request *wreq, struct writeback_control *wbc,
201 int netfs_end_writethrough(struct netfs_io_request *wreq, struct writeback_control *wbc,
203 int netfs_unbuffered_write(struct netfs_io_request *wreq, bool may_wait, size_t len);
208 void netfs_retry_writes(struct netfs_io_request *wreq);
/linux-6.15/include/trace/events/
H A Dnetfs.h522 TP_ARGS(wreq, what),
536 __entry->wreq = wreq->debug_id;
545 __entry->wreq,
555 TP_ARGS(wreq),
565 __entry->wreq = wreq->debug_id;
572 __entry->wreq,
593 __entry->wreq = wreq->debug_id;
623 __entry->wreq = wreq->debug_id;
651 __entry->wreq = wreq->debug_id;
679 __entry->wreq = wreq->debug_id;
[all …]
/linux-6.15/fs/afs/
H A Dwrite.c41 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()
218 afs_get_writeback_key(wreq); in afs_retry_request()
[all …]
H A Dfile.c442 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()
H A Dinternal.h1652 void afs_begin_writeback(struct netfs_io_request *wreq);
1653 void afs_retry_request(struct netfs_io_request *wreq, struct netfs_io_stream *stream);
/linux-6.15/fs/9p/
H A Dvfs_addr.c33 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-6.15/fs/cachefiles/
H A Dio.c630 struct netfs_io_request *wreq = subreq->rreq; in cachefiles_prepare_write_subreq() local
631 struct netfs_cache_resources *cres = &wreq->cache_resources; in cachefiles_prepare_write_subreq()
632 struct netfs_io_stream *stream = &wreq->io_streams[subreq->stream_nr]; in cachefiles_prepare_write_subreq()
634 _enter("W=%x[%x] %llx", wreq->debug_id, subreq->debug_index, subreq->start); in cachefiles_prepare_write_subreq()
649 struct netfs_io_request *wreq = subreq->rreq; in cachefiles_issue_write() local
650 struct netfs_cache_resources *cres = &wreq->cache_resources; in cachefiles_issue_write()
653 struct netfs_io_stream *stream = &wreq->io_streams[subreq->stream_nr]; in cachefiles_issue_write()
660 wreq->debug_id, subreq->debug_index, start, start + len - 1); in cachefiles_issue_write()
678 if (start + len == wreq->i_size) { in cachefiles_issue_write()
/linux-6.15/drivers/net/ethernet/chelsio/inline_crypto/ch_ipsec/
H A Dchcr_ipsec.h33 struct fw_ulptx_wr wreq; member
H A Dchcr_ipsec.c584 wr->wreq.op_to_compl = htonl(FW_WR_OP_V(FW_ULPTX_WR)); in ch_ipsec_crypto_wreq()
594 wr->wreq.flowid_len16 = htonl(wr_mid); in ch_ipsec_crypto_wreq()
/linux-6.15/net/9p/
H A Dtrans_fd.c121 struct p9_req_t *wreq; member
478 m->wreq = req; in p9_write_work()
501 p9_req_put(m->client, m->wreq); in p9_write_work()
502 m->wreq = NULL; in p9_write_work()
922 if (m->wreq) { in p9_conn_destroy()
923 p9_req_put(m->client, m->wreq); in p9_conn_destroy()
924 m->wreq = NULL; in p9_conn_destroy()
H A Dclient.c1686 struct netfs_io_request *wreq = subreq->rreq; in p9_client_write_subreq() local
1687 struct p9_fid *fid = wreq->netfs_priv; in p9_client_write_subreq()
1700 0, wreq->len, P9_ZC_HDR_SZ, "dqd", in p9_client_write_subreq()
/linux-6.15/include/linux/
H A Dnetfs.h312 void (*begin_writeback)(struct netfs_io_request *wreq);
315 void (*retry_request)(struct netfs_io_request *wreq, struct netfs_io_stream *stream);
316 void (*invalidate_cache)(struct netfs_io_request *wreq);
/linux-6.15/drivers/crypto/chelsio/
H A Dchcr_core.h89 struct fw_crypto_lookaside_wr wreq; member
H A Dchcr_algo.c777 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-6.15/fs/smb/client/
H A Dcompress.c307 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 Dfile.c137 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()
240 static void cifs_begin_writeback(struct netfs_io_request *wreq) in cifs_begin_writeback() argument
242 struct cifs_io_request *req = container_of(wreq, struct cifs_io_request, rreq); in cifs_begin_writeback()
245 ret = cifs_get_writable_file(CIFS_I(wreq->inode), FIND_WR_ANY, &req->cfile); in cifs_begin_writeback()
251 wreq->io_streams[0].avail = true; in cifs_begin_writeback()
2429 struct netfs_io_request *wreq = wdata->rreq; in cifs_write_subrequest_terminated() local
2430 struct netfs_inode *ictx = netfs_inode(wreq->inode); in cifs_write_subrequest_terminated()
/linux-6.15/net/wireless/
H A Dscan.c3502 struct iw_scan_req *wreq = NULL; in cfg80211_wext_siwscan() local
3511 wreq = (struct iw_scan_req *)extra; in cfg80211_wext_siwscan()
3524 if (wreq && wreq->num_channels) { in cfg80211_wext_siwscan()
3528 n_channels = wreq->num_channels; in cfg80211_wext_siwscan()
3568 if (wreq && wreq->num_channels) { in cfg80211_wext_siwscan()
3571 for (k = 0; k < wreq->num_channels; k++) { in cfg80211_wext_siwscan()
3573 &wreq->channel_list[k]; in cfg80211_wext_siwscan()
3599 if (wreq) { in cfg80211_wext_siwscan()
3601 if (wreq->essid_len > IEEE80211_MAX_SSID_LEN) in cfg80211_wext_siwscan()
3603 memcpy(creq->ssids[0].ssid, wreq->essid, wreq->essid_len); in cfg80211_wext_siwscan()
[all …]