Searched refs:rreq (Results 1 - 25 of 30) sorted by last modified time

12

/linux-master/include/linux/
H A Dnetfs.h175 struct netfs_io_request *rreq; /* Supervising I/O request */ member in struct:netfs_io_subrequest
177 struct list_head rreq_link; /* Link in rreq->subrequests */
290 int (*init_request)(struct netfs_io_request *rreq, struct file *file);
291 void (*free_request)(struct netfs_io_request *rreq);
292 void (*free_subrequest)(struct netfs_io_subrequest *rreq);
295 void (*expand_readahead)(struct netfs_io_request *rreq);
298 bool (*is_still_valid)(struct netfs_io_request *rreq);
301 void (*done)(struct netfs_io_request *rreq);
/linux-master/fs/smb/client/
H A Dfile.c54 size_t wsize = req->rreq.wsize;
96 struct cifs_sb_info *sbi = CIFS_SB(subreq->rreq->inode->i_sb);
136 struct netfs_io_request *rreq = subreq->rreq; local
139 struct cifs_io_request *req = container_of(subreq->rreq, struct cifs_io_request, rreq);
140 struct cifs_sb_info *cifs_sb = CIFS_SB(rreq->inode->i_sb);
179 struct netfs_io_request *rreq = subreq->rreq; local
181 struct cifs_io_request *req = container_of(subreq->rreq, struc
240 cifs_init_request(struct netfs_io_request *rreq, struct file *file) argument
266 cifs_expand_readahead(struct netfs_io_request *rreq) argument
293 cifs_rreq_done(struct netfs_io_request *rreq) argument
311 cifs_free_request(struct netfs_io_request *rreq) argument
[all...]
H A Dcifsglob.h1495 struct netfs_io_request rreq; member in struct:cifs_io_request
1503 struct netfs_io_request *rreq; member in union:cifs_io_subrequest::__anon1115
H A Dsmb2pdu.c4424 trace_smb3_read_enter(rdata ? rdata->rreq->debug_id : 0,
4559 trace_smb3_read_err(rdata->rreq->debug_id,
4566 trace_smb3_read_done(rdata->rreq->debug_id,
4577 if (rdata->subreq.start < rdata->subreq.rreq->i_size)
4656 trace_smb3_read_err(rdata->rreq->debug_id,
/linux-master/fs/netfs/
H A Ddirect_read.c31 struct netfs_io_request *rreq; local
46 rreq = netfs_alloc_request(iocb->ki_filp->f_mapping, iocb->ki_filp,
49 if (IS_ERR(rreq))
50 return PTR_ERR(rreq);
53 trace_netfs_read(rreq, rreq->start, rreq->len, netfs_read_trace_dio_read);
65 ret = netfs_extract_user_iter(iter, rreq->len, &rreq->iter, 0);
68 rreq
[all...]
H A Dwrite_issue.c216 struct netfs_io_request *wreq = subreq->rreq;
H A Dwrite_collect.c743 struct netfs_io_request *wreq = subreq->rreq;
H A Dobjects.c24 struct netfs_io_request *rreq; local
34 rreq = mempool_alloc(mempool, GFP_KERNEL);
35 if (rreq)
40 memset(rreq, 0, kmem_cache_size(cache));
41 rreq->start = start;
42 rreq->len = len;
43 rreq->upper_len = len;
44 rreq->origin = origin;
45 rreq->netfs_ops = ctx->ops;
46 rreq
81 netfs_get_request(struct netfs_io_request *rreq, enum netfs_rreq_ref_trace what) argument
89 netfs_clear_subrequests(struct netfs_io_request *rreq, bool was_async) argument
117 struct netfs_io_request *rreq = container_of(rcu, struct netfs_io_request, rcu); local
125 struct netfs_io_request *rreq = local
148 netfs_put_request(struct netfs_io_request *rreq, bool was_async, enum netfs_rreq_ref_trace what) argument
174 netfs_alloc_subrequest(struct netfs_io_request *rreq) argument
212 struct netfs_io_request *rreq = subreq->rreq; local
[all...]
H A Dmain.c53 struct netfs_io_request *rreq; local
63 rreq = list_entry(v, struct netfs_io_request, proc_link);
66 rreq->debug_id,
67 netfs_origins[rreq->origin],
68 refcount_read(&rreq->ref),
69 rreq->flags,
70 rreq->error,
71 atomic_read(&rreq->nr_outstanding),
72 rreq->start, rreq
[all...]
H A Dio.c39 static void netfs_read_from_cache(struct netfs_io_request *rreq, argument
43 struct netfs_cache_resources *cres = &rreq->cache_resources;
53 static void netfs_fill_with_zeroes(struct netfs_io_request *rreq, argument
77 static void netfs_read_from_server(struct netfs_io_request *rreq, argument
82 if (rreq->origin != NETFS_DIO_READ &&
85 rreq->debug_id, subreq->debug_index,
88 rreq->netfs_ops->issue_read(subreq);
94 static void netfs_rreq_completed(struct netfs_io_request *rreq, bool was_async) argument
96 trace_netfs_rreq(rreq, netfs_rreq_trace_done);
97 netfs_clear_subrequests(rreq, was_asyn
104 netfs_rreq_short_read(struct netfs_io_request *rreq, struct netfs_io_subrequest *subreq) argument
124 netfs_reset_subreq_iter(struct netfs_io_request *rreq, struct netfs_io_subrequest *subreq) argument
149 netfs_rreq_perform_resubmissions(struct netfs_io_request *rreq) argument
191 netfs_rreq_is_still_valid(struct netfs_io_request *rreq) argument
210 netfs_rreq_assess_dio(struct netfs_io_request *rreq) argument
255 netfs_rreq_assess(struct netfs_io_request *rreq, bool was_async) argument
283 struct netfs_io_request *rreq = local
292 netfs_rreq_terminated(struct netfs_io_request *rreq, bool was_async) argument
326 struct netfs_io_request *rreq = subreq->rreq; local
416 struct netfs_io_request *rreq = subreq->rreq; local
430 netfs_rreq_prepare_read(struct netfs_io_request *rreq, struct netfs_io_subrequest *subreq, struct iov_iter *io_iter) argument
508 netfs_rreq_submit_slice(struct netfs_io_request *rreq, struct iov_iter *io_iter) argument
568 netfs_begin_read(struct netfs_io_request *rreq, bool sync) argument
[all...]
H A Dinternal.h25 void netfs_rreq_unlock_folios(struct netfs_io_request *rreq);
32 int netfs_begin_read(struct netfs_io_request *rreq, bool sync);
44 static inline void netfs_proc_add_rreq(struct netfs_io_request *rreq) argument
47 list_add_tail_rcu(&rreq->proc_link, &netfs_io_requests);
50 static inline void netfs_proc_del_rreq(struct netfs_io_request *rreq) argument
52 if (!list_empty(&rreq->proc_link)) {
54 list_del_rcu(&rreq->proc_link);
59 static inline void netfs_proc_add_rreq(struct netfs_io_request *rreq) {} argument
60 static inline void netfs_proc_del_rreq(struct netfs_io_request *rreq) {} argument
83 void netfs_get_request(struct netfs_io_request *rreq, enu
89 netfs_see_request(struct netfs_io_request *rreq, enum netfs_rreq_ref_trace what) argument
[all...]
H A Dbuffered_read.c19 void netfs_rreq_unlock_folios(struct netfs_io_request *rreq) argument
24 pgoff_t start_page = rreq->start / PAGE_SIZE;
25 pgoff_t last_page = ((rreq->start + rreq->len) / PAGE_SIZE) - 1;
29 XA_STATE(xas, &rreq->mapping->i_pages, start_page);
31 if (test_bit(NETFS_RREQ_FAILED, &rreq->flags)) {
32 __clear_bit(NETFS_RREQ_COPY_TO_CACHE, &rreq->flags);
33 list_for_each_entry(subreq, &rreq->subrequests, rreq_link) {
44 subreq = list_first_entry(&rreq->subrequests,
48 trace_netfs_rreq(rreq, netfs_rreq_trace_unloc
132 netfs_cache_expand_readahead(struct netfs_io_request *rreq, unsigned long long *_start, unsigned long long *_len, unsigned long long i_size) argument
143 netfs_rreq_expand(struct netfs_io_request *rreq, struct readahead_control *ractl) argument
181 netfs_begin_cache_read(struct netfs_io_request *rreq, struct netfs_inode *ctx) argument
203 struct netfs_io_request *rreq; local
266 struct netfs_io_request *rreq; local
435 struct netfs_io_request *rreq; local
532 struct netfs_io_request *rreq; local
[all...]
/linux-master/net/9p/
H A Dclient.c1668 struct netfs_io_request *wreq = subreq->rreq;
H A Dtrans_fd.c96 * @rreq: read request
119 struct p9_req_t *rreq; member in struct:p9_conn
313 if ((!m->rreq) && (m->rc.offset == m->rc.capacity)) {
329 m->rreq = p9_tag_lookup(m->client, m->rc.tag);
330 if (!m->rreq || (m->rreq->status != REQ_STATUS_SENT)) {
337 if (m->rc.size > m->rreq->rc.capacity) {
340 m->rc.size, m->rc.tag, m->rreq->rc.capacity);
345 if (!m->rreq->rc.sdata) {
348 m->rc.tag, m->rreq);
[all...]
/linux-master/include/trace/events/
H A Dnetfs.h219 TP_PROTO(struct netfs_io_request *rreq,
223 TP_ARGS(rreq, start, len, what),
226 __field(unsigned int, rreq )
235 __entry->rreq = rreq->debug_id;
236 __entry->cookie = rreq->cache_resources.debug_id;
240 __entry->netfs_inode = rreq->inode->i_ino;
244 __entry->rreq,
252 TP_PROTO(struct netfs_io_request *rreq,
255 TP_ARGS(rreq, wha
[all...]
/linux-master/fs/ceph/
H A Daddr.c165 static void ceph_netfs_expand_readahead(struct netfs_io_request *rreq) argument
167 struct inode *inode = rreq->inode;
171 loff_t end = rreq->start + rreq->len, new_end;
172 struct ceph_netfs_request_data *priv = rreq->netfs_priv;
196 new_end = umin(round_up(end, lo->stripe_unit), rreq->i_size);
197 if (new_end > end && new_end <= rreq->start + max_len)
198 rreq->len = new_end - rreq->start;
201 div_u64_rem(rreq
273 struct netfs_io_request *rreq = subreq->rreq; local
328 struct netfs_io_request *rreq = subreq->rreq; local
419 ceph_init_request(struct netfs_io_request *rreq, struct file *file) argument
478 ceph_netfs_free_request(struct netfs_io_request *rreq) argument
[all...]
/linux-master/fs/cachefiles/
H A Dio.c499 return cachefiles_do_prepare_read(&subreq->rreq->cache_resources,
501 &subreq->flags, subreq->rreq->inode->i_ino);
628 struct netfs_io_request *wreq = subreq->rreq;
646 struct netfs_io_request *wreq = subreq->rreq;
692 cachefiles_write(&subreq->rreq->cache_resources,
/linux-master/fs/afs/
H A Dwrite.c104 struct netfs_io_request *wreq = subreq->rreq;
H A Dfile.c309 struct afs_vnode *vnode = AFS_FS_I(subreq->rreq->inode);
319 fsreq->key = key_get(subreq->rreq->netfs_priv);
351 static int afs_init_request(struct netfs_io_request *rreq, struct file *file) argument
354 rreq->netfs_priv = key_get(afs_file_key(file));
355 rreq->rsize = 256 * 1024;
356 rreq->wsize = 256 * 1024 * 1024;
368 static void afs_free_request(struct netfs_io_request *rreq) argument
370 key_put(rreq->netfs_priv);
371 afs_put_wb_key(rreq->netfs_priv2);
/linux-master/fs/9p/
H A Dvfs_addr.c56 struct p9_fid *fid = subreq->rreq->netfs_priv;
69 struct netfs_io_request *rreq = subreq->rreq; local
70 struct p9_fid *fid = rreq->netfs_priv;
85 * @rreq: The read request
88 static int v9fs_init_request(struct netfs_io_request *rreq, struct file *file) argument
91 bool writing = (rreq->origin == NETFS_READ_FOR_WRITE ||
92 rreq->origin == NETFS_WRITETHROUGH ||
93 rreq->origin == NETFS_UNBUFFERED_WRITE ||
94 rreq
134 v9fs_free_request(struct netfs_io_request *rreq) argument
[all...]
/linux-master/drivers/md/
H A Draid5.c1183 rbi = &dev->rreq; /* For writing to replacement */
2858 if (bi == &sh->dev[i].rreq) {
H A Draid5.h259 /* rreq and rvec are used for the replacement device when
262 struct bio req, rreq; member in struct:stripe_head::r5dev
/linux-master/drivers/infiniband/hw/hfi1/
H A Dtid_rdma.c1712 struct tid_rdma_read_req *rreq = &ohdr->u.tid_rdma.r_req; local
1746 KDETH_RESET(rreq->kdeth0, KVER, 0x1);
1747 KDETH_RESET(rreq->kdeth1, JKEY, remote->jkey);
1748 rreq->reth.vaddr = cpu_to_be64(wqe->rdma_wr.remote_addr +
1750 rreq->reth.rkey = cpu_to_be32(wqe->rdma_wr.rkey);
1751 rreq->reth.length = cpu_to_be32(*len);
1752 rreq->tid_flow_psn =
1757 rreq->tid_flow_qp =
1762 rreq->verbs_qp = cpu_to_be32(qp->remote_qpn);
/linux-master/fs/nfs/
H A Dfscache.c264 static int nfs_netfs_init_request(struct netfs_io_request *rreq, struct file *file) argument
266 rreq->netfs_priv = get_nfs_open_context(nfs_file_open_context(file));
267 rreq->debug_id = atomic_inc_return(&nfs_netfs_debug_id);
272 static void nfs_netfs_free_request(struct netfs_io_request *rreq) argument
274 put_nfs_open_context(rreq->netfs_priv);
291 size_t rsize = NFS_SB(sreq->rreq->inode->i_sb)->rsize;
301 struct inode *inode = sreq->rreq->inode;
302 struct nfs_open_context *ctx = sreq->rreq->netfs_priv;
319 xa_for_each_range(&sreq->rreq->mapping->i_pages, idx, page, start, last) {
/linux-master/drivers/infiniband/sw/siw/
H A Dsiw_qp_tx.c130 c_tx->pkt.rreq.rsvd = 0;
131 c_tx->pkt.rreq.ddp_qn = htonl(RDMAP_UNTAGGED_QN_RDMA_READ);
132 c_tx->pkt.rreq.ddp_msn =
134 c_tx->pkt.rreq.ddp_mo = 0;
135 c_tx->pkt.rreq.sink_stag = htonl(wqe->sqe.sge[0].lkey);
136 c_tx->pkt.rreq.sink_to =
138 c_tx->pkt.rreq.source_stag = htonl(wqe->sqe.rkey);
139 c_tx->pkt.rreq.source_to = cpu_to_be64(wqe->sqe.raddr);
140 c_tx->pkt.rreq.read_size = htonl(wqe->sqe.sge[0].length);

Completed in 286 milliseconds

12