| /Linux-v5.15/fs/netfs/ |
| D | read_helper.c | 45 struct netfs_read_request *rreq; in netfs_alloc_read_request() local
47 rreq = kzalloc(sizeof(struct netfs_read_request), GFP_KERNEL); in netfs_alloc_read_request()
48 if (rreq) { in netfs_alloc_read_request()
49 rreq->netfs_ops = ops; in netfs_alloc_read_request()
50 rreq->netfs_priv = netfs_priv; in netfs_alloc_read_request()
51 rreq->inode = file_inode(file); in netfs_alloc_read_request()
52 rreq->i_size = i_size_read(rreq->inode); in netfs_alloc_read_request()
53 rreq->debug_id = atomic_inc_return(&debug_ids); in netfs_alloc_read_request()
54 INIT_LIST_HEAD(&rreq->subrequests); in netfs_alloc_read_request()
55 INIT_WORK(&rreq->work, netfs_rreq_work); in netfs_alloc_read_request()
[all …]
|
| /Linux-v5.15/include/trace/events/ |
| D | netfs.h | 126 TP_PROTO(struct netfs_read_request *rreq,
130 TP_ARGS(rreq, start, len, what),
133 __field(unsigned int, rreq )
141 __entry->rreq = rreq->debug_id;
142 __entry->cookie = rreq->cache_resources.debug_id;
149 __entry->rreq,
156 TP_PROTO(struct netfs_read_request *rreq,
159 TP_ARGS(rreq, what),
162 __field(unsigned int, rreq )
168 __entry->rreq = rreq->debug_id;
[all …]
|
| /Linux-v5.15/drivers/infiniband/sw/siw/ |
| D | siw_qp.c | 291 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->ddp_msn = htonl(wqe->sqe.sge[0].length); in siw_send_terminate()
[all …]
|
| D | siw_qp_rx.c | 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()
1150 struct siw_sqe *rreq; in siw_check_tx_fence() local
1156 rreq = orq_get_current(qp); in siw_check_tx_fence()
1159 WRITE_ONCE(rreq->flags, 0); in siw_check_tx_fence()
1171 rreq = orq_get_tail(qp); in siw_check_tx_fence()
[all …]
|
| D | siw_qp_tx.c | 132 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()
|
| D | siw.h | 353 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);
|
| D | iwarp.h | 276 struct iwarp_rdma_rreq rreq; member
|
| /Linux-v5.15/include/linux/ |
| D | netfs.h | 112 struct netfs_read_request *rreq; /* Supervising read request */ member
165 void (*init_rreq)(struct netfs_read_request *rreq, struct file *file);
166 int (*begin_cache_operation)(struct netfs_read_request *rreq);
167 void (*expand_readahead)(struct netfs_read_request *rreq);
170 bool (*is_still_valid)(struct netfs_read_request *rreq);
173 void (*done)(struct netfs_read_request *rreq);
|
| D | fscache.h | 530 int fscache_begin_read_operation(struct netfs_read_request *rreq, in fscache_begin_read_operation() argument
534 return __fscache_begin_read_operation(rreq, cookie); in fscache_begin_read_operation()
|
| D | fscache-cache.h | 308 int (*begin_read_operation)(struct netfs_read_request *rreq,
|
| /Linux-v5.15/fs/ceph/ |
| D | cache.h | 53 static inline int ceph_begin_cache_operation(struct netfs_read_request *rreq) in ceph_begin_cache_operation() argument
55 struct fscache_cookie *cookie = ceph_fscache_cookie(ceph_inode(rreq->inode)); in ceph_begin_cache_operation()
57 return fscache_begin_read_operation(rreq, cookie); in ceph_begin_cache_operation()
111 static inline int ceph_begin_cache_operation(struct netfs_read_request *rreq) in ceph_begin_cache_operation() argument
|
| D | addr.c | 180 static void ceph_netfs_expand_readahead(struct netfs_read_request *rreq) in ceph_netfs_expand_readahead() argument
182 struct inode *inode = rreq->mapping->host; in ceph_netfs_expand_readahead()
189 blockno = div_u64_rem(rreq->start, lo->stripe_unit, &blockoff); in ceph_netfs_expand_readahead()
190 rreq->start = blockno * lo->stripe_unit; in ceph_netfs_expand_readahead()
191 rreq->len += blockoff; in ceph_netfs_expand_readahead()
194 rreq->len = roundup(rreq->len, lo->stripe_unit); in ceph_netfs_expand_readahead()
199 struct inode *inode = subreq->rreq->mapping->host; in ceph_netfs_clamp_length()
244 struct netfs_read_request *rreq = subreq->rreq; in ceph_netfs_issue_op() local
245 struct inode *inode = rreq->mapping->host; in ceph_netfs_issue_op()
267 iov_iter_xarray(&iter, READ, &rreq->mapping->i_pages, subreq->start, len); in ceph_netfs_issue_op()
[all …]
|
| /Linux-v5.15/net/9p/ |
| D | trans_fd.c | 121 struct p9_req_t *rreq; member
312 if ((!m->rreq) && (m->rc.offset == m->rc.capacity)) { in p9_read_work()
336 m->rreq = p9_tag_lookup(m->client, m->rc.tag); in p9_read_work()
337 if (!m->rreq || (m->rreq->status != REQ_STATUS_SENT)) { in p9_read_work()
344 if (!m->rreq->rc.sdata) { in p9_read_work()
347 m->rc.tag, m->rreq); in p9_read_work()
348 m->rreq = NULL; in p9_read_work()
352 m->rc.sdata = m->rreq->rc.sdata; in p9_read_work()
360 if ((m->rreq) && (m->rc.offset == m->rc.capacity)) { in p9_read_work()
362 m->rreq->rc.size = m->rc.offset; in p9_read_work()
[all …]
|
| /Linux-v5.15/fs/fscache/ |
| D | io.c | 27 int __fscache_begin_read_operation(struct netfs_read_request *rreq, in __fscache_begin_read_operation() argument
35 _enter("rr=%08x", rreq->debug_id); in __fscache_begin_read_operation()
85 ret = object->cache->ops->begin_read_operation(rreq, op); in __fscache_begin_read_operation()
|
| /Linux-v5.15/fs/cachefiles/ |
| D | io.c | 271 struct fscache_retrieval *op = subreq->rreq->cache_resources.cache_priv; in cachefiles_prepare_read()
275 struct file *file = subreq->rreq->cache_resources.cache_priv2; in cachefiles_prepare_read()
380 int cachefiles_begin_read_operation(struct netfs_read_request *rreq, in cachefiles_begin_read_operation() argument
410 rreq->cache_resources.cache_priv = op; in cachefiles_begin_read_operation()
411 rreq->cache_resources.cache_priv2 = file; in cachefiles_begin_read_operation()
412 rreq->cache_resources.ops = &cachefiles_netfs_cache_ops; in cachefiles_begin_read_operation()
413 rreq->cache_resources.debug_id = object->fscache.debug_id; in cachefiles_begin_read_operation()
|
| /Linux-v5.15/fs/afs/ |
| D | file.c | 294 struct afs_vnode *vnode = AFS_FS_I(subreq->rreq->inode); in afs_req_issue_op()
304 fsreq->key = key_get(subreq->rreq->netfs_priv); in afs_req_issue_op()
338 static void afs_init_rreq(struct netfs_read_request *rreq, struct file *file) in afs_init_rreq() argument
340 rreq->netfs_priv = key_get(afs_file_key(file)); in afs_init_rreq()
350 static int afs_begin_cache_operation(struct netfs_read_request *rreq) in afs_begin_cache_operation() argument
352 struct afs_vnode *vnode = AFS_FS_I(rreq->inode); in afs_begin_cache_operation()
354 return fscache_begin_read_operation(rreq, afs_vnode_cache(vnode)); in afs_begin_cache_operation()
|
| /Linux-v5.15/Documentation/filesystems/ |
| D | netfs_library.rst | 191 struct netfs_read_request *rreq;
203 * ``rreq``
248 void (*init_rreq)(struct netfs_read_request *rreq, struct file *file);
250 int (*begin_cache_operation)(struct netfs_read_request *rreq);
251 void (*expand_readahead)(struct netfs_read_request *rreq);
254 bool (*is_still_valid)(struct netfs_read_request *rreq);
257 void (*done)(struct netfs_read_request *rreq);
422 int fscache_begin_read_operation(struct netfs_read_request *rreq,
|
| /Linux-v5.15/drivers/md/ |
| D | raid5.h | 261 struct bio req, rreq; member
|
| D | raid5.c | 1098 rbi = &sh->dev[i].rreq; /* For writing to replacement */ in ops_run_io()
2314 bio_init(&dev->rreq, &dev->rvec, 1); in alloc_stripe()
2809 if (bi == &sh->dev[i].rreq) { in raid5_end_write_request()
|
| /Linux-v5.15/drivers/infiniband/hw/hfi1/ |
| D | tid_rdma.c | 1712 struct tid_rdma_read_req *rreq = &ohdr->u.tid_rdma.r_req; in hfi1_build_tid_rdma_read_packet() local
1746 KDETH_RESET(rreq->kdeth0, KVER, 0x1); in hfi1_build_tid_rdma_read_packet()
1747 KDETH_RESET(rreq->kdeth1, JKEY, remote->jkey); in hfi1_build_tid_rdma_read_packet()
1748 rreq->reth.vaddr = cpu_to_be64(wqe->rdma_wr.remote_addr + in hfi1_build_tid_rdma_read_packet()
1750 rreq->reth.rkey = cpu_to_be32(wqe->rdma_wr.rkey); in hfi1_build_tid_rdma_read_packet()
1751 rreq->reth.length = cpu_to_be32(*len); in hfi1_build_tid_rdma_read_packet()
1752 rreq->tid_flow_psn = in hfi1_build_tid_rdma_read_packet()
1757 rreq->tid_flow_qp = in hfi1_build_tid_rdma_read_packet()
1762 rreq->verbs_qp = cpu_to_be32(qp->remote_qpn); in hfi1_build_tid_rdma_read_packet()
|
