/linux-master/include/linux/ |
H A D | netfs.h | 175 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 D | file.c | 54 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 D | cifsglob.h | 1495 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 D | smb2pdu.c | 4424 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 D | direct_read.c | 31 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 D | write_issue.c | 216 struct netfs_io_request *wreq = subreq->rreq;
|
H A D | write_collect.c | 743 struct netfs_io_request *wreq = subreq->rreq;
|
H A D | objects.c | 24 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 D | main.c | 53 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 D | io.c | 39 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 D | internal.h | 25 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 D | buffered_read.c | 19 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 D | client.c | 1668 struct netfs_io_request *wreq = subreq->rreq;
|
H A D | trans_fd.c | 96 * @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 D | netfs.h | 219 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 D | addr.c | 165 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 D | io.c | 499 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 D | write.c | 104 struct netfs_io_request *wreq = subreq->rreq;
|
H A D | file.c | 309 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 D | vfs_addr.c | 56 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 D | raid5.c | 1183 rbi = &dev->rreq; /* For writing to replacement */ 2858 if (bi == &sh->dev[i].rreq) {
|
H A D | raid5.h | 259 /* 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 D | tid_rdma.c | 1712 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 D | fscache.c | 264 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 D | siw_qp_tx.c | 130 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);
|