Home
last modified time | relevance | path

Searched refs:rreq (Results 1 - 25 of 31) sorted by relevance

12

/kernel/linux/linux-6.6/fs/netfs/
H A Dio.c26 iov_iter_xarray(&iter, ITER_DEST, &subreq->rreq->mapping->i_pages, in netfs_clear_unread()
44 static void netfs_read_from_cache(struct netfs_io_request *rreq, in netfs_read_from_cache() argument
48 struct netfs_cache_resources *cres = &rreq->cache_resources; in netfs_read_from_cache()
52 iov_iter_xarray(&iter, ITER_DEST, &rreq->mapping->i_pages, in netfs_read_from_cache()
63 static void netfs_fill_with_zeroes(struct netfs_io_request *rreq, in netfs_fill_with_zeroes() argument
87 static void netfs_read_from_server(struct netfs_io_request *rreq, in netfs_read_from_server() argument
91 rreq->netfs_ops->issue_read(subreq); in netfs_read_from_server()
97 static void netfs_rreq_completed(struct netfs_io_request *rreq, bool was_async) in netfs_rreq_completed() argument
99 trace_netfs_rreq(rreq, netfs_rreq_trace_done); in netfs_rreq_completed()
100 netfs_clear_subrequests(rreq, was_asyn in netfs_rreq_completed()
110 netfs_rreq_unmark_after_write(struct netfs_io_request *rreq, bool was_async) netfs_rreq_unmark_after_write() argument
146 struct netfs_io_request *rreq = subreq->rreq; netfs_rreq_copy_terminated() local
169 netfs_rreq_do_write_to_cache(struct netfs_io_request *rreq) netfs_rreq_do_write_to_cache() argument
229 struct netfs_io_request *rreq = netfs_rreq_write_to_cache_work() local
235 netfs_rreq_write_to_cache(struct netfs_io_request *rreq) netfs_rreq_write_to_cache() argument
245 netfs_rreq_short_read(struct netfs_io_request *rreq, struct netfs_io_subrequest *subreq) netfs_rreq_short_read() argument
266 netfs_rreq_perform_resubmissions(struct netfs_io_request *rreq) netfs_rreq_perform_resubmissions() argument
307 netfs_rreq_is_still_valid(struct netfs_io_request *rreq) netfs_rreq_is_still_valid() argument
329 netfs_rreq_assess(struct netfs_io_request *rreq, bool was_async) netfs_rreq_assess() argument
356 struct netfs_io_request *rreq = netfs_rreq_work() local
365 netfs_rreq_terminated(struct netfs_io_request *rreq, bool was_async) netfs_rreq_terminated() argument
399 struct netfs_io_request *rreq = subreq->rreq; netfs_subreq_terminated() local
489 struct netfs_io_request *rreq = subreq->rreq; netfs_cache_prepare_read() local
503 netfs_rreq_prepare_read(struct netfs_io_request *rreq, struct netfs_io_subrequest *subreq) netfs_rreq_prepare_read() argument
543 netfs_rreq_submit_slice(struct netfs_io_request *rreq, unsigned int *_debug_index) netfs_rreq_submit_slice() argument
604 netfs_begin_read(struct netfs_io_request *rreq, bool sync) netfs_begin_read() argument
[all...]
H A Dobjects.c22 struct netfs_io_request *rreq; in netfs_alloc_request() local
25 rreq = kzalloc(sizeof(struct netfs_io_request), GFP_KERNEL); in netfs_alloc_request()
26 if (!rreq) in netfs_alloc_request()
29 rreq->start = start; in netfs_alloc_request()
30 rreq->len = len; in netfs_alloc_request()
31 rreq->origin = origin; in netfs_alloc_request()
32 rreq->netfs_ops = ctx->ops; in netfs_alloc_request()
33 rreq->mapping = mapping; in netfs_alloc_request()
34 rreq->inode = inode; in netfs_alloc_request()
35 rreq in netfs_alloc_request()
52 netfs_get_request(struct netfs_io_request *rreq, enum netfs_rreq_ref_trace what) netfs_get_request() argument
60 netfs_clear_subrequests(struct netfs_io_request *rreq, bool was_async) netfs_clear_subrequests() argument
75 struct netfs_io_request *rreq = netfs_free_request() local
88 netfs_put_request(struct netfs_io_request *rreq, bool was_async, enum netfs_rreq_ref_trace what) netfs_put_request() argument
111 netfs_alloc_subrequest(struct netfs_io_request *rreq) netfs_alloc_subrequest() argument
140 struct netfs_io_request *rreq = subreq->rreq; netfs_free_subrequest() local
[all...]
H A Dbuffered_read.c16 void netfs_rreq_unlock_folios(struct netfs_io_request *rreq) in netfs_rreq_unlock_folios() argument
20 pgoff_t start_page = rreq->start / PAGE_SIZE; in netfs_rreq_unlock_folios()
21 pgoff_t last_page = ((rreq->start + rreq->len) / PAGE_SIZE) - 1; in netfs_rreq_unlock_folios()
25 XA_STATE(xas, &rreq->mapping->i_pages, start_page); in netfs_rreq_unlock_folios()
27 if (test_bit(NETFS_RREQ_FAILED, &rreq->flags)) { in netfs_rreq_unlock_folios()
28 __clear_bit(NETFS_RREQ_COPY_TO_CACHE, &rreq->flags); in netfs_rreq_unlock_folios()
29 list_for_each_entry(subreq, &rreq->subrequests, rreq_link) { in netfs_rreq_unlock_folios()
40 subreq = list_first_entry(&rreq->subrequests, in netfs_rreq_unlock_folios()
44 trace_netfs_rreq(rreq, netfs_rreq_trace_unloc in netfs_rreq_unlock_folios()
107 netfs_cache_expand_readahead(struct netfs_io_request *rreq, loff_t *_start, size_t *_len, loff_t i_size) netfs_cache_expand_readahead() argument
116 netfs_rreq_expand(struct netfs_io_request *rreq, struct readahead_control *ractl) netfs_rreq_expand() argument
167 struct netfs_io_request *rreq; netfs_readahead() local
227 struct netfs_io_request *rreq; netfs_read_folio() local
346 struct netfs_io_request *rreq; netfs_write_begin() local
[all...]
H A Dinternal.h21 void netfs_rreq_unlock_folios(struct netfs_io_request *rreq);
26 int netfs_begin_read(struct netfs_io_request *rreq, bool sync);
40 void netfs_get_request(struct netfs_io_request *rreq, enum netfs_rreq_ref_trace what);
41 void netfs_clear_subrequests(struct netfs_io_request *rreq, bool was_async);
42 void netfs_put_request(struct netfs_io_request *rreq, bool was_async,
44 struct netfs_io_subrequest *netfs_alloc_subrequest(struct netfs_io_request *rreq);
46 static inline void netfs_see_request(struct netfs_io_request *rreq, in netfs_see_request() argument
49 trace_netfs_rreq_ref(rreq->debug_id, refcount_read(&rreq->ref), what); in netfs_see_request()
/kernel/linux/linux-6.6/include/trace/events/
H A Dnetfs.h128 TP_PROTO(struct netfs_io_request *rreq,
132 TP_ARGS(rreq, start, len, what),
135 __field(unsigned int, rreq )
144 __entry->rreq = rreq->debug_id;
145 __entry->cookie = rreq->cache_resources.debug_id;
149 __entry->netfs_inode = rreq->inode->i_ino;
153 __entry->rreq,
161 TP_PROTO(struct netfs_io_request *rreq,
164 TP_ARGS(rreq, wha
[all...]
/kernel/linux/linux-6.6/fs/nfs/
H A Dfscache.c264 static int nfs_netfs_init_request(struct netfs_io_request *rreq, struct file *file) in nfs_netfs_init_request() argument
266 rreq->netfs_priv = get_nfs_open_context(nfs_file_open_context(file)); in nfs_netfs_init_request()
267 rreq->debug_id = atomic_inc_return(&nfs_netfs_debug_id); in nfs_netfs_init_request()
272 static void nfs_netfs_free_request(struct netfs_io_request *rreq) in nfs_netfs_free_request() argument
274 put_nfs_open_context(rreq->netfs_priv); in nfs_netfs_free_request()
277 static inline int nfs_netfs_begin_cache_operation(struct netfs_io_request *rreq) in nfs_netfs_begin_cache_operation() argument
279 return fscache_begin_read_operation(&rreq->cache_resources, in nfs_netfs_begin_cache_operation()
280 netfs_i_cookie(netfs_inode(rreq->inode))); in nfs_netfs_begin_cache_operation()
297 size_t rsize = NFS_SB(sreq->rreq->inode->i_sb)->rsize; in nfs_netfs_clamp_length()
307 struct inode *inode = sreq->rreq in nfs_netfs_issue_read()
[all...]
/kernel/linux/linux-6.6/fs/9p/
H A Dvfs_addr.c34 struct netfs_io_request *rreq = subreq->rreq; in v9fs_issue_read() local
35 struct p9_fid *fid = rreq->netfs_priv; in v9fs_issue_read()
41 iov_iter_xarray(&to, ITER_DEST, &rreq->mapping->i_pages, pos, len); in v9fs_issue_read()
54 * @rreq: The read request
57 static int v9fs_init_request(struct netfs_io_request *rreq, struct file *file) in v9fs_init_request() argument
66 WARN_ON(rreq->origin == NETFS_READ_FOR_WRITE && in v9fs_init_request()
70 rreq->netfs_priv = fid; in v9fs_init_request()
76 * @rreq: The I/O request to clean up
78 static void v9fs_free_request(struct netfs_io_request *rreq) in v9fs_free_request() argument
89 v9fs_begin_cache_operation(struct netfs_io_request *rreq) v9fs_begin_cache_operation() argument
[all...]
/kernel/linux/linux-5.10/drivers/infiniband/sw/siw/
H A Dsiw_qp.c291 struct siw_sqe *rreq = NULL; in siw_qp_mpa_rts() local
298 rreq = orq_get_free(qp); in siw_qp_mpa_rts()
299 if (rreq) { in siw_qp_mpa_rts()
300 siw_read_to_orq(rreq, &wqe->sqe); in siw_qp_mpa_rts()
461 struct iwarp_rdma_rreq *rreq; in siw_send_terminate() local
469 rreq = (struct iwarp_rdma_rreq *)err_hdr; in siw_send_terminate()
471 memcpy(&rreq->ctrl, in siw_send_terminate()
475 rreq->rsvd = 0; in siw_send_terminate()
476 rreq->ddp_qn = in siw_send_terminate()
480 rreq in siw_send_terminate()
869 siw_read_to_orq(struct siw_sqe *rreq, struct siw_sqe *sqe) siw_read_to_orq() argument
934 struct siw_sqe *rreq; siw_activate_tx_from_sq() local
[all...]
H A Dsiw_qp_rx.c638 pr_warn("siw: [QP %u]: rreq with mpa len %d\n", qp_id(qp), in siw_proc_rreq()
665 uint64_t raddr = be64_to_cpu(srx->hdr.rreq.sink_to), in siw_init_rresp()
666 laddr = be64_to_cpu(srx->hdr.rreq.source_to); in siw_init_rresp()
667 uint32_t length = be32_to_cpu(srx->hdr.rreq.read_size), in siw_init_rresp()
668 lkey = be32_to_cpu(srx->hdr.rreq.source_stag), in siw_init_rresp()
669 rkey = be32_to_cpu(srx->hdr.rreq.sink_stag), in siw_init_rresp()
670 msn = be32_to_cpu(srx->hdr.rreq.ddp_msn); in siw_init_rresp()
1153 struct siw_sqe *rreq; in siw_check_tx_fence() local
1160 rreq = orq_get_current(qp); in siw_check_tx_fence()
1161 WRITE_ONCE(rreq in siw_check_tx_fence()
[all...]
H A Dsiw_qp_tx.c132 c_tx->pkt.rreq.rsvd = 0; in siw_qp_prepare_tx()
133 c_tx->pkt.rreq.ddp_qn = htonl(RDMAP_UNTAGGED_QN_RDMA_READ); in siw_qp_prepare_tx()
134 c_tx->pkt.rreq.ddp_msn = in siw_qp_prepare_tx()
136 c_tx->pkt.rreq.ddp_mo = 0; in siw_qp_prepare_tx()
137 c_tx->pkt.rreq.sink_stag = htonl(wqe->sqe.sge[0].lkey); in siw_qp_prepare_tx()
138 c_tx->pkt.rreq.sink_to = in siw_qp_prepare_tx()
140 c_tx->pkt.rreq.source_stag = htonl(wqe->sqe.rkey); in siw_qp_prepare_tx()
141 c_tx->pkt.rreq.source_to = cpu_to_be64(wqe->sqe.raddr); in siw_qp_prepare_tx()
142 c_tx->pkt.rreq.read_size = htonl(wqe->sqe.sge[0].length); in siw_qp_prepare_tx()
H A Dsiw.h353 struct iwarp_rdma_rreq rreq; member
373 struct iwarp_rdma_rreq rreq; member
523 void siw_read_to_orq(struct siw_sqe *rreq, struct siw_sqe *sqe);
H A Diwarp.h289 struct iwarp_rdma_rreq rreq; member
/kernel/linux/linux-6.6/drivers/infiniband/sw/siw/
H A Dsiw_qp.c294 struct siw_sqe *rreq = NULL; in siw_qp_mpa_rts() local
301 rreq = orq_get_free(qp); in siw_qp_mpa_rts()
302 if (rreq) { in siw_qp_mpa_rts()
303 siw_read_to_orq(rreq, &wqe->sqe); in siw_qp_mpa_rts()
464 struct iwarp_rdma_rreq *rreq; in siw_send_terminate() local
472 rreq = (struct iwarp_rdma_rreq *)err_hdr; in siw_send_terminate()
474 memcpy(&rreq->ctrl, in siw_send_terminate()
478 rreq->rsvd = 0; in siw_send_terminate()
479 rreq->ddp_qn = in siw_send_terminate()
483 rreq in siw_send_terminate()
872 siw_read_to_orq(struct siw_sqe *rreq, struct siw_sqe *sqe) siw_read_to_orq() argument
937 struct siw_sqe *rreq; siw_activate_tx_from_sq() local
[all...]
H A Dsiw_qp_rx.c638 pr_warn("siw: [QP %u]: rreq with mpa len %d\n", qp_id(qp), in siw_proc_rreq()
665 uint64_t raddr = be64_to_cpu(srx->hdr.rreq.sink_to), in siw_init_rresp()
666 laddr = be64_to_cpu(srx->hdr.rreq.source_to); in siw_init_rresp()
667 uint32_t length = be32_to_cpu(srx->hdr.rreq.read_size), in siw_init_rresp()
668 lkey = be32_to_cpu(srx->hdr.rreq.source_stag), in siw_init_rresp()
669 rkey = be32_to_cpu(srx->hdr.rreq.sink_stag), in siw_init_rresp()
670 msn = be32_to_cpu(srx->hdr.rreq.ddp_msn); in siw_init_rresp()
1153 struct siw_sqe *rreq; in siw_check_tx_fence() local
1160 rreq = orq_get_current(qp); in siw_check_tx_fence()
1161 WRITE_ONCE(rreq in siw_check_tx_fence()
[all...]
H A Dsiw_qp_tx.c131 c_tx->pkt.rreq.rsvd = 0; in siw_qp_prepare_tx()
132 c_tx->pkt.rreq.ddp_qn = htonl(RDMAP_UNTAGGED_QN_RDMA_READ); in siw_qp_prepare_tx()
133 c_tx->pkt.rreq.ddp_msn = in siw_qp_prepare_tx()
135 c_tx->pkt.rreq.ddp_mo = 0; in siw_qp_prepare_tx()
136 c_tx->pkt.rreq.sink_stag = htonl(wqe->sqe.sge[0].lkey); in siw_qp_prepare_tx()
137 c_tx->pkt.rreq.sink_to = in siw_qp_prepare_tx()
139 c_tx->pkt.rreq.source_stag = htonl(wqe->sqe.rkey); in siw_qp_prepare_tx()
140 c_tx->pkt.rreq.source_to = cpu_to_be64(wqe->sqe.raddr); in siw_qp_prepare_tx()
141 c_tx->pkt.rreq.read_size = htonl(wqe->sqe.sge[0].length); in siw_qp_prepare_tx()
H A Dsiw.h354 struct iwarp_rdma_rreq rreq; member
374 struct iwarp_rdma_rreq rreq; member
525 void siw_read_to_orq(struct siw_sqe *rreq, struct siw_sqe *sqe);
/kernel/linux/linux-6.6/include/linux/
H A Dnetfs.h149 struct netfs_io_request *rreq; /* Supervising I/O request */ member
150 struct list_head rreq_link; /* Link in rreq->subrequests */
209 int (*init_request)(struct netfs_io_request *rreq, struct file *file);
210 void (*free_request)(struct netfs_io_request *rreq);
211 int (*begin_cache_operation)(struct netfs_io_request *rreq);
213 void (*expand_readahead)(struct netfs_io_request *rreq);
216 bool (*is_still_valid)(struct netfs_io_request *rreq);
219 void (*done)(struct netfs_io_request *rreq);
233 * rreq->ops->begin_cache_operation().
/kernel/linux/linux-6.6/tools/net/ynl/samples/
H A Dethtool.c14 struct ethtool_rings_get_req_dump rreq = {}; in main() local
41 rreq._present.header = 1; /* ethtool needs an empty nest.. */ in main()
42 rings = ethtool_rings_get_dump(ys, &rreq); in main()
/kernel/linux/linux-6.6/net/9p/
H A Dtrans_fd.c96 * @rreq: read request
120 struct p9_req_t *rreq; member
314 if ((!m->rreq) && (m->rc.offset == m->rc.capacity)) { in p9_read_work()
330 m->rreq = p9_tag_lookup(m->client, m->rc.tag); in p9_read_work()
331 if (!m->rreq || (m->rreq->status != REQ_STATUS_SENT)) { in p9_read_work()
338 if (m->rc.size > m->rreq->rc.capacity) { in p9_read_work()
341 m->rc.size, m->rc.tag, m->rreq->rc.capacity); in p9_read_work()
346 if (!m->rreq->rc.sdata) { in p9_read_work()
349 m->rc.tag, m->rreq); in p9_read_work()
[all...]
/kernel/linux/linux-6.6/fs/ceph/
H A Dcache.h60 static inline int ceph_begin_cache_operation(struct netfs_io_request *rreq) in ceph_begin_cache_operation() argument
62 struct fscache_cookie *cookie = ceph_fscache_cookie(ceph_inode(rreq->inode)); in ceph_begin_cache_operation()
64 return fscache_begin_read_operation(&rreq->cache_resources, cookie); in ceph_begin_cache_operation()
138 static inline int ceph_begin_cache_operation(struct netfs_io_request *rreq) in ceph_begin_cache_operation() argument
H A Daddr.c186 static void ceph_netfs_expand_readahead(struct netfs_io_request *rreq) in ceph_netfs_expand_readahead() argument
188 struct inode *inode = rreq->inode; in ceph_netfs_expand_readahead()
192 loff_t end = rreq->start + rreq->len, new_end; in ceph_netfs_expand_readahead()
193 struct ceph_netfs_request_data *priv = rreq->netfs_priv; in ceph_netfs_expand_readahead()
217 new_end = min(round_up(end, lo->stripe_unit), rreq->i_size); in ceph_netfs_expand_readahead()
218 if (new_end > end && new_end <= rreq->start + max_len) in ceph_netfs_expand_readahead()
219 rreq->len = new_end - rreq->start; in ceph_netfs_expand_readahead()
222 div_u64_rem(rreq in ceph_netfs_expand_readahead()
293 struct netfs_io_request *rreq = subreq->rreq; ceph_netfs_issue_op_inline() local
348 struct netfs_io_request *rreq = subreq->rreq; ceph_netfs_issue_read() local
435 ceph_init_request(struct netfs_io_request *rreq, struct file *file) ceph_init_request() argument
493 ceph_netfs_free_request(struct netfs_io_request *rreq) ceph_netfs_free_request() argument
[all...]
/kernel/linux/linux-5.10/net/9p/
H A Dtrans_fd.c119 struct p9_req_t *rreq; member
313 if ((!m->rreq) && (m->rc.offset == m->rc.capacity)) { in p9_read_work()
337 m->rreq = p9_tag_lookup(m->client, m->rc.tag); in p9_read_work()
338 if (!m->rreq || (m->rreq->status != REQ_STATUS_SENT)) { in p9_read_work()
345 if (!m->rreq->rc.sdata) { in p9_read_work()
348 m->rc.tag, m->rreq); in p9_read_work()
349 m->rreq = NULL; in p9_read_work()
353 m->rc.sdata = m->rreq->rc.sdata; in p9_read_work()
361 if ((m->rreq) in p9_read_work()
[all...]
/kernel/linux/linux-6.6/fs/afs/
H A Dfile.c317 struct afs_vnode *vnode = AFS_FS_I(subreq->rreq->inode); in afs_issue_read()
327 fsreq->key = key_get(subreq->rreq->netfs_priv); in afs_issue_read()
363 static int afs_init_request(struct netfs_io_request *rreq, struct file *file) in afs_init_request() argument
365 rreq->netfs_priv = key_get(afs_file_key(file)); in afs_init_request()
369 static int afs_begin_cache_operation(struct netfs_io_request *rreq) in afs_begin_cache_operation() argument
372 struct afs_vnode *vnode = AFS_FS_I(rreq->inode); in afs_begin_cache_operation()
374 return fscache_begin_read_operation(&rreq->cache_resources, in afs_begin_cache_operation()
389 static void afs_free_request(struct netfs_io_request *rreq) in afs_free_request() argument
391 key_put(rreq->netfs_priv); in afs_free_request()
/kernel/linux/linux-6.6/fs/cachefiles/
H A Dio.c499 return cachefiles_do_prepare_read(&subreq->rreq->cache_resources, in cachefiles_prepare_read()
501 &subreq->flags, subreq->rreq->inode->i_ino); in cachefiles_prepare_read()
/kernel/linux/linux-5.10/drivers/md/
H A Draid5.h258 /* rreq and rvec are used for the replacement device when
261 struct bio req, rreq; member

Completed in 23 milliseconds

12