Home
last modified time | relevance | path

Searched refs:rreq (Results 1 – 25 of 34) sorted by relevance

12

/linux/fs/netfs/
H A Dobjects.c25 struct netfs_io_request *rreq; in netfs_alloc_request() local
35 rreq = mempool_alloc(mempool, gfp); in netfs_alloc_request()
37 rreq = mempool_alloc_noreserve(mempool, gfp); in netfs_alloc_request()
38 if (!rreq) in netfs_alloc_request()
42 memset(rreq, 0, kmem_cache_size(cache)); in netfs_alloc_request()
43 INIT_WORK(&rreq->cleanup_work, netfs_free_request); in netfs_alloc_request()
44 rreq->gfp = gfp; in netfs_alloc_request()
45 rreq->start = start; in netfs_alloc_request()
46 rreq->collected_to = start; in netfs_alloc_request()
47 rreq->cleaned_to = start; in netfs_alloc_request()
[all …]
H A Dread_collect.c32 if (subreq->start + subreq->transferred >= subreq->rreq->i_size) in netfs_clear_unread()
39 struct netfs_io_request *rreq = subreq->rreq; in netfs_cancel_copy_to_cache() argument
42 if (pos >= rreq->i_size) in netfs_cancel_copy_to_cache()
45 fill = min_t(uoff_t, rreq->i_size - pos, in netfs_cancel_copy_to_cache()
55 void netfs_cancel_copy_to_cache(struct netfs_io_request *rreq, struct folio *folio) in netfs_cancel_copy_to_cache()
57 if (!test_bit(NETFS_RREQ_USE_PGPRIV2, &rreq->flags)) { in netfs_cancel_copy_to_cache()
81 static void netfs_unlock_read_folio(struct netfs_io_request *rreq, in netfs_unlock_read_folio()
88 if (unlikely(folio_pos(folio) < rreq->abandon_to)) { in netfs_unlock_read_folio()
90 netfs_cancel_copy_to_cache(rreq, foli in netfs_unlock_read_folio()
65 netfs_unlock_read_folio(struct netfs_io_request * rreq,struct folio_queue * folioq,int slot) netfs_unlock_read_folio() argument
123 netfs_read_set_unlock_at(struct netfs_io_request * rreq) netfs_read_set_unlock_at() argument
152 netfs_read_unlock_folios(struct netfs_io_request * rreq,unsigned int * notes) netfs_read_unlock_folios() argument
238 netfs_collect_read_results(struct netfs_io_request * rreq) netfs_collect_read_results() argument
395 netfs_rreq_assess_dio(struct netfs_io_request * rreq) netfs_rreq_assess_dio() argument
428 netfs_rreq_assess_single(struct netfs_io_request * rreq) netfs_rreq_assess_single() argument
461 netfs_read_collection(struct netfs_io_request * rreq) netfs_read_collection() argument
510 struct netfs_io_request *rreq = container_of(work, struct netfs_io_request, work); netfs_read_collection_worker() local
534 struct netfs_io_request *rreq = subreq->rreq; netfs_read_subreq_progress() local
575 struct netfs_io_request *rreq = subreq->rreq; netfs_read_subreq_terminated() local
[all...]
H A Dbuffered_read.c12 static void netfs_cache_expand_readahead(struct netfs_io_request *rreq, in netfs_cache_expand_readahead() argument
17 struct netfs_cache_resources *cres = &rreq->cache_resources; in netfs_cache_expand_readahead()
23 static void netfs_rreq_expand(struct netfs_io_request *rreq, in netfs_rreq_expand() argument
29 netfs_cache_expand_readahead(rreq, &rreq->start, &rreq->len, rreq->i_size); in netfs_rreq_expand()
34 if (rreq->netfs_ops->expand_readahead) in netfs_rreq_expand()
35 rreq->netfs_ops->expand_readahead(rreq); in netfs_rreq_expand()
60 netfs_bulk_drop_ra_refs(struct netfs_io_request * rreq) netfs_bulk_drop_ra_refs() argument
87 netfs_maybe_bulk_drop_ra_refs(struct netfs_io_request * rreq) netfs_maybe_bulk_drop_ra_refs() argument
97 netfs_begin_cache_read(struct netfs_io_request * rreq,struct netfs_inode * ctx) netfs_begin_cache_read() argument
116 struct netfs_io_request *rreq = subreq->rreq; netfs_prepare_read_iterator() local
140 netfs_cache_prepare_read(struct netfs_io_request * rreq,struct netfs_io_subrequest * subreq,loff_t i_size) netfs_cache_prepare_read() argument
159 netfs_read_cache_to_pagecache(struct netfs_io_request * rreq,struct netfs_io_subrequest * subreq) netfs_read_cache_to_pagecache() argument
169 netfs_queue_read(struct netfs_io_request * rreq,struct netfs_io_subrequest * subreq) netfs_queue_read() argument
194 netfs_issue_read(struct netfs_io_request * rreq,struct netfs_io_subrequest * subreq) netfs_issue_read() argument
219 netfs_mark_copy_to_cache(struct netfs_io_request * rreq,struct folio_queue ** fq,unsigned int * offset,int * slot,size_t len,bool copy) netfs_mark_copy_to_cache() argument
269 netfs_read_to_pagecache(struct netfs_io_request * rreq) netfs_read_to_pagecache() argument
407 struct netfs_io_request *rreq; netfs_readahead() local
459 netfs_create_singular_buffer(struct netfs_io_request * rreq,struct folio * folio,unsigned int rollbuf_flags) netfs_create_singular_buffer() argument
480 struct netfs_io_request *rreq; netfs_read_gaps() local
590 struct netfs_io_request *rreq; netfs_read_folio() local
721 struct netfs_io_request *rreq; netfs_write_begin() local
811 struct netfs_io_request *rreq; netfs_prefetch_for_write() local
[all...]
H A Ddirect_read.c21 struct netfs_io_request *rreq = subreq->rreq; in netfs_prepare_dio_read_iterator() local
24 rsize = umin(subreq->len, rreq->io_streams[0].sreq_max_len); in netfs_prepare_dio_read_iterator()
27 if (unlikely(rreq->io_streams[0].sreq_max_segs)) { in netfs_prepare_dio_read_iterator()
28 size_t limit = netfs_limit_iter(&rreq->buffer.iter, 0, rsize, in netfs_prepare_dio_read_iterator()
29 rreq->io_streams[0].sreq_max_segs); in netfs_prepare_dio_read_iterator()
39 subreq->io_iter = rreq->buffer.iter; in netfs_prepare_dio_read_iterator()
41 iov_iter_advance(&rreq->buffer.iter, subreq->len); in netfs_prepare_dio_read_iterator()
48 static void netfs_dispatch_unbuffered_reads(struct netfs_io_request *rreq) in netfs_dispatch_unbuffered_reads() argument
50 unsigned long long start = rreq->start; in netfs_dispatch_unbuffered_reads()
51 ssize_t size = rreq->len; in netfs_dispatch_unbuffered_reads()
[all …]
H A Dread_single.c56 static int netfs_single_begin_cache_read(struct netfs_io_request *rreq, struct netfs_inode *ctx) in netfs_single_begin_cache_read() argument
58 return fscache_begin_read_operation(&rreq->cache_resources, netfs_i_cookie(ctx)); in netfs_single_begin_cache_read()
61 static void netfs_single_cache_prepare_read(struct netfs_io_request *rreq, in netfs_single_cache_prepare_read() argument
64 struct netfs_cache_resources *cres = &rreq->cache_resources; in netfs_single_cache_prepare_read()
70 subreq->source = cres->ops->prepare_read(subreq, rreq->i_size); in netfs_single_cache_prepare_read()
75 static void netfs_single_read_cache(struct netfs_io_request *rreq, in netfs_single_read_cache() argument
78 struct netfs_cache_resources *cres = &rreq->cache_resources; in netfs_single_read_cache()
80 _enter("R=%08x[%x]", rreq->debug_id, subreq->debug_index); in netfs_single_read_cache()
90 static int netfs_single_dispatch_read(struct netfs_io_request *rreq) in netfs_single_dispatch_read() argument
95 subreq = netfs_alloc_subrequest(rreq); in netfs_single_dispatch_read()
[all …]
H A Dmisc.c339 void netfs_wake_collector(struct netfs_io_request *rreq) in netfs_wake_collector()
341 if (test_bit(NETFS_RREQ_OFFLOAD_COLLECTION, &rreq->flags) && in netfs_wake_collector()
342 !test_bit(NETFS_RREQ_RETRYING, &rreq->flags)) { in netfs_wake_collector()
343 queue_work(system_dfl_wq, &rreq->work); in netfs_wake_collector()
345 trace_netfs_rreq(rreq, netfs_rreq_trace_wake_queue); in netfs_wake_collector()
346 wake_up(&rreq->waitq); in netfs_wake_collector()
356 struct netfs_io_request *rreq = subreq->rreq; in netfs_subreq_clear_in_progress()
357 struct netfs_io_stream *stream = &rreq->io_streams[subreq->stream_nr]; in netfs_subreq_clear_in_progress()
364 test_bit(NETFS_RREQ_RETRYING, &rreq in netfs_subreq_clear_in_progress()
338 netfs_wake_collector(struct netfs_io_request * rreq) netfs_wake_collector() argument
355 struct netfs_io_request *rreq = subreq->rreq; netfs_subreq_clear_in_progress() local
370 netfs_wait_for_in_progress_stream(struct netfs_io_request * rreq,struct netfs_io_stream * stream) netfs_wait_for_in_progress_stream() argument
400 netfs_collect_in_app(struct netfs_io_request * rreq,bool (* collector)(struct netfs_io_request * rreq)) netfs_collect_in_app() argument
401 netfs_collect_in_app(struct netfs_io_request * rreq,bool (* collector)(struct netfs_io_request * rreq)) netfs_collect_in_app() argument
452 netfs_wait_for_in_progress(struct netfs_io_request * rreq,bool (* collector)(struct netfs_io_request * rreq)) netfs_wait_for_in_progress() argument
453 netfs_wait_for_in_progress(struct netfs_io_request * rreq,bool (* collector)(struct netfs_io_request * rreq)) netfs_wait_for_in_progress() argument
508 netfs_wait_for_read(struct netfs_io_request * rreq) netfs_wait_for_read() argument
513 netfs_wait_for_write(struct netfs_io_request * rreq) netfs_wait_for_write() argument
521 netfs_wait_for_pause(struct netfs_io_request * rreq,bool (* collector)(struct netfs_io_request * rreq)) netfs_wait_for_pause() argument
522 netfs_wait_for_pause(struct netfs_io_request * rreq,bool (* collector)(struct netfs_io_request * rreq)) netfs_wait_for_pause() argument
557 netfs_wait_for_paused_read(struct netfs_io_request * rreq) netfs_wait_for_paused_read() argument
562 netfs_wait_for_paused_write(struct netfs_io_request * rreq) netfs_wait_for_paused_write() argument
570 netfs_wait_for_put_ra_refs(struct netfs_io_request * rreq) netfs_wait_for_put_ra_refs() argument
[all...]
H A Dread_retry.c12 static void netfs_reissue_read(struct netfs_io_request *rreq, in netfs_reissue_read() argument
19 subreq->rreq->netfs_ops->issue_read(subreq); in netfs_reissue_read()
26 static void netfs_retry_read_subrequests(struct netfs_io_request *rreq) in netfs_retry_read_subrequests() argument
29 struct netfs_io_stream *stream = &rreq->io_streams[0]; in netfs_retry_read_subrequests()
32 _enter("R=%x", rreq->debug_id); in netfs_retry_read_subrequests()
37 if (rreq->netfs_ops->retry_request) in netfs_retry_read_subrequests()
38 rreq->netfs_ops->retry_request(rreq, NULL); in netfs_retry_read_subrequests()
43 if (!rreq->netfs_ops->prepare_read && in netfs_retry_read_subrequests()
44 !rreq->cache_resources.ops) { in netfs_retry_read_subrequests()
53 netfs_reissue_read(rreq, subreq); in netfs_retry_read_subrequests()
[all …]
H A Dinternal.h26 void netfs_queue_read(struct netfs_io_request *rreq,
49 static inline void netfs_proc_add_rreq(struct netfs_io_request *rreq) in netfs_proc_add_rreq() argument
52 list_add_tail_rcu(&rreq->proc_link, &netfs_io_requests); in netfs_proc_add_rreq()
55 static inline void netfs_proc_del_rreq(struct netfs_io_request *rreq) in netfs_proc_del_rreq() argument
57 if (!list_empty(&rreq->proc_link)) { in netfs_proc_del_rreq()
59 list_del_rcu(&rreq->proc_link); in netfs_proc_del_rreq()
64 static inline void netfs_proc_add_rreq(struct netfs_io_request *rreq) {} in netfs_proc_add_rreq() argument
65 static inline void netfs_proc_del_rreq(struct netfs_io_request *rreq) {} in netfs_proc_del_rreq() argument
71 struct folio_queue *netfs_buffer_make_space(struct netfs_io_request *rreq,
74 void netfs_wake_collector(struct netfs_io_request *rreq);
97 netfs_see_request(struct netfs_io_request * rreq,enum netfs_rreq_ref_trace what) netfs_see_request() argument
293 netfs_wake_rreq_flag(struct netfs_io_request * rreq,unsigned int rreq_flag,enum netfs_rreq_trace trace) netfs_wake_rreq_flag() argument
308 netfs_check_rreq_in_progress(const struct netfs_io_request * rreq) netfs_check_rreq_in_progress() argument
[all...]
H A Dread_pgpriv2.c99 struct netfs_io_request *rreq, struct folio *folio) in netfs_pgpriv2_begin_copy_to_cache() argument
103 if (!fscache_resources_valid(&rreq->cache_resources)) in netfs_pgpriv2_begin_copy_to_cache()
106 creq = netfs_create_write_req(rreq->mapping, NULL, folio_pos(folio), in netfs_pgpriv2_begin_copy_to_cache()
115 trace_netfs_copy2cache(rreq, creq); in netfs_pgpriv2_begin_copy_to_cache()
118 rreq->copy_to_cache = creq; in netfs_pgpriv2_begin_copy_to_cache()
124 rreq->copy_to_cache = ERR_PTR(-ENOBUFS); in netfs_pgpriv2_begin_copy_to_cache()
125 set_bit(NETFS_RREQ_CANCEL_CACHING, &rreq->flags); in netfs_pgpriv2_begin_copy_to_cache()
134 void netfs_pgpriv2_copy_to_cache(struct netfs_io_request *rreq, struct folio *folio) in netfs_pgpriv2_copy_to_cache() argument
136 struct netfs_io_request *creq = rreq->copy_to_cache; in netfs_pgpriv2_copy_to_cache()
139 creq = netfs_pgpriv2_begin_copy_to_cache(rreq, folio); in netfs_pgpriv2_copy_to_cache()
[all …]
H A Dmain.c58 struct netfs_io_request *rreq; in netfs_requests_seq_show() local
68 rreq = list_entry(v, struct netfs_io_request, proc_link); in netfs_requests_seq_show()
71 rreq->debug_id, in netfs_requests_seq_show()
72 netfs_origins[rreq->origin], in netfs_requests_seq_show()
73 refcount_read(&rreq->ref), in netfs_requests_seq_show()
74 rreq->flags, in netfs_requests_seq_show()
75 rreq->error, in netfs_requests_seq_show()
77 rreq->start, rreq->submitted, rreq->len); in netfs_requests_seq_show()
H A Dwrite_collect.c24 static void netfs_dump_request(const struct netfs_io_request *rreq) in netfs_dump_request() argument
27 rreq->debug_id, refcount_read(&rreq->ref), rreq->flags, in netfs_dump_request()
28 rreq->origin, rreq->error); in netfs_dump_request()
30 rreq->start, rreq->transferred, rreq->submitted, rreq->len); in netfs_dump_request()
32 rreq->cleaned_to, rreq->collected_to, atomic64_read(&rreq->issued_to)); in netfs_dump_request()
33 pr_err(" iw=%pSR\n", rreq->netfs_ops->issue_write); in netfs_dump_request()
36 const struct netfs_io_stream *s = &rreq->io_streams[i]; in netfs_dump_request()
438 struct netfs_io_request *rreq = container_of(work, struct netfs_io_request, work); in netfs_write_collection_worker() local
440 netfs_see_request(rreq, netfs_rreq_trace_see_work); in netfs_write_collection_worker()
441 if (netfs_check_rreq_in_progress(rreq)) { in netfs_write_collection_worker()
[all …]
/linux/fs/9p/
H A Dvfs_addr.c56 struct p9_fid *fid = subreq->rreq->netfs_priv; in v9fs_issue_write()
57 struct inode *inode = subreq->rreq->inode; in v9fs_issue_write()
97 struct netfs_io_request *rreq = subreq->rreq; in v9fs_issue_read() local
98 struct p9_fid *fid = rreq->netfs_priv; in v9fs_issue_read()
103 if (S_ISLNK(rreq->inode->i_mode)) { in v9fs_issue_read()
129 if (subreq->rreq->origin != NETFS_UNBUFFERED_READ && in v9fs_issue_read()
130 subreq->rreq->origin != NETFS_DIO_READ) in v9fs_issue_read()
132 if (pos + total >= i_size_read(rreq->inode)) in v9fs_issue_read()
148 static int v9fs_init_request(struct netfs_io_request *rreq, struct file *file) in v9fs_init_request() argument
152 bool writing = (rreq->origin == NETFS_READ_FOR_WRITE || in v9fs_init_request()
[all …]
/linux/include/trace/events/
H A Dnetfs.h303 TP_PROTO(struct netfs_io_request *rreq,
307 TP_ARGS(rreq, start, len, what),
310 __field(unsigned int, rreq)
320 __entry->rreq = rreq->debug_id;
321 __entry->cookie = rreq->cache_resources.debug_id;
322 __entry->i_size = rreq->i_size;
326 __entry->netfs_inode = rreq->inode->i_ino;
330 __entry->rreq,
338 TP_PROTO(struct netfs_io_request *rreq,
341 TP_ARGS(rreq, what),
[all …]
/linux/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
267 if (WARN_ON_ONCE(rreq->origin != NETFS_PGPRIV2_COPY_TO_CACHE)) in nfs_netfs_init_request()
272 rreq->netfs_priv = get_nfs_open_context(nfs_file_open_context(file)); in nfs_netfs_init_request()
273 rreq->debug_id = atomic_inc_return(&nfs_netfs_debug_id); in nfs_netfs_init_request()
275 __set_bit(NETFS_RREQ_USE_PGPRIV2, &rreq->flags); in nfs_netfs_init_request()
276 rreq->io_streams[0].sreq_max_len = NFS_SB(rreq->inode->i_sb)->rsize; in nfs_netfs_init_request()
281 static void nfs_netfs_free_request(struct netfs_io_request *rreq) in nfs_netfs_free_request() argument
283 if (rreq->netfs_priv) in nfs_netfs_free_request()
284 put_nfs_open_context(rreq->netfs_priv); in nfs_netfs_free_request()
303 struct inode *inode = sreq->rreq->inode; in nfs_netfs_issue_read()
[all …]
/linux/drivers/infiniband/sw/siw/
H A Dsiw_qp.c267 struct siw_sqe *rreq = NULL; in siw_qp_mpa_rts() local
274 rreq = orq_get_free(qp); in siw_qp_mpa_rts()
275 if (rreq) { in siw_qp_mpa_rts()
276 siw_read_to_orq(rreq, &wqe->sqe); in siw_qp_mpa_rts()
437 struct iwarp_rdma_rreq *rreq; in siw_send_terminate() local
445 rreq = (struct iwarp_rdma_rreq *)err_hdr; in siw_send_terminate()
447 memcpy(&rreq->ctrl, in siw_send_terminate()
451 rreq->rsvd = 0; in siw_send_terminate()
452 rreq->ddp_qn = in siw_send_terminate()
456 rreq->ddp_msn = htonl(wqe->sqe.sge[0].length); in siw_send_terminate()
[all …]
H A Dsiw_qp_rx.c661 uint64_t raddr = be64_to_cpu(srx->hdr.rreq.sink_to), in siw_init_rresp()
662 laddr = be64_to_cpu(srx->hdr.rreq.source_to); in siw_init_rresp()
663 uint32_t length = be32_to_cpu(srx->hdr.rreq.read_size), in siw_init_rresp()
664 lkey = be32_to_cpu(srx->hdr.rreq.source_stag), in siw_init_rresp()
665 rkey = be32_to_cpu(srx->hdr.rreq.sink_stag), in siw_init_rresp()
666 msn = be32_to_cpu(srx->hdr.rreq.ddp_msn); in siw_init_rresp()
1156 struct siw_sqe *rreq; in siw_check_tx_fence() local
1163 rreq = orq_get_current(qp); in siw_check_tx_fence()
1164 WRITE_ONCE(rreq->flags, 0); in siw_check_tx_fence()
1180 rreq = orq_get_free(qp); in siw_check_tx_fence()
[all …]
H A Dsiw_qp_tx.c130 c_tx->pkt.rreq.rsvd = 0; in siw_qp_prepare_tx()
131 c_tx->pkt.rreq.ddp_qn = htonl(RDMAP_UNTAGGED_QN_RDMA_READ); in siw_qp_prepare_tx()
132 c_tx->pkt.rreq.ddp_msn = in siw_qp_prepare_tx()
134 c_tx->pkt.rreq.ddp_mo = 0; in siw_qp_prepare_tx()
135 c_tx->pkt.rreq.sink_stag = htonl(wqe->sqe.sge[0].lkey); in siw_qp_prepare_tx()
136 c_tx->pkt.rreq.sink_to = in siw_qp_prepare_tx()
138 c_tx->pkt.rreq.source_stag = htonl(wqe->sqe.rkey); in siw_qp_prepare_tx()
139 c_tx->pkt.rreq.source_to = cpu_to_be64(wqe->sqe.raddr); in siw_qp_prepare_tx()
140 c_tx->pkt.rreq.read_size = htonl(wqe->sqe.sge[0].length); in siw_qp_prepare_tx()
H A Diwarp.h276 struct iwarp_rdma_rreq rreq; member
/linux/fs/afs/
H A Dfile.c338 struct afs_vnode *vnode = AFS_FS_I(subreq->rreq->inode); in afs_issue_read()
339 struct key *key = subreq->rreq->netfs_priv; in afs_issue_read()
362 if (subreq->rreq->origin == NETFS_READAHEAD || in afs_issue_read()
363 subreq->rreq->iocb) { in afs_issue_read()
383 static int afs_init_request(struct netfs_io_request *rreq, struct file *file) in afs_init_request() argument
385 struct afs_vnode *vnode = AFS_FS_I(rreq->inode); in afs_init_request()
388 rreq->netfs_priv = key_get(afs_file_key(file)); in afs_init_request()
389 rreq->rsize = 256 * 1024; in afs_init_request()
390 rreq->wsize = 256 * 1024 * 1024; in afs_init_request()
392 switch (rreq->origin) { in afs_init_request()
[all …]
H A Dwrite.c91 struct netfs_io_stream *stream = &subreq->rreq->io_streams[subreq->stream_nr]; in afs_prepare_write()
105 struct netfs_io_request *wreq = subreq->rreq; in afs_issue_write_worker()
/linux/tools/net/ynl/samples/
H A Dethtool.c
/linux/fs/ceph/
H A Daddr.c169 static void ceph_netfs_expand_readahead(struct netfs_io_request *rreq) in ceph_netfs_expand_readahead() argument
171 struct inode *inode = rreq->inode; in ceph_netfs_expand_readahead()
175 loff_t end = rreq->start + rreq->len, new_end; in ceph_netfs_expand_readahead()
176 struct ceph_netfs_request_data *priv = rreq->netfs_priv; in ceph_netfs_expand_readahead()
200 new_end = umin(round_up(end, lo->stripe_unit), rreq->i_size); in ceph_netfs_expand_readahead()
201 if (new_end > end && new_end <= rreq->start + max_len) in ceph_netfs_expand_readahead()
202 rreq->len = new_end - rreq->start; in ceph_netfs_expand_readahead()
205 div_u64_rem(rreq->start, lo->stripe_unit, &blockoff); in ceph_netfs_expand_readahead()
206 if (rreq->len + blockoff <= max_len) { in ceph_netfs_expand_readahead()
207 rreq->start -= blockoff; in ceph_netfs_expand_readahead()
[all …]
/linux/fs/smb/client/
H A Dfile.c51 struct netfs_io_stream *stream = &req->rreq.io_streams[subreq->stream_nr]; in cifs_prepare_write()
54 struct cifs_sb_info *cifs_sb = CIFS_SB(wdata->rreq->inode->i_sb); in cifs_prepare_write()
55 size_t wsize = req->rreq.wsize; in cifs_prepare_write()
88 wdata->credits.rreq_debug_id = subreq->rreq->debug_id; in cifs_prepare_write()
91 trace_smb3_rw_credits(wdata->rreq->debug_id, in cifs_prepare_write()
115 struct cifs_sb_info *sbi = CIFS_SB(subreq->rreq->inode->i_sb); in cifs_issue_write()
155 struct netfs_io_request *rreq = subreq->rreq; in cifs_prepare_read() local
157 struct cifs_io_request *req = container_of(subreq->rreq, struct cifs_io_request, rreq); in cifs_prepare_read()
211 struct netfs_io_request *rreq = subreq->rreq; cifs_issue_read() local
270 cifs_init_request(struct netfs_io_request * rreq,struct file * file) cifs_init_request() argument
298 cifs_rreq_done(struct netfs_io_request * rreq) cifs_rreq_done() argument
310 cifs_free_request(struct netfs_io_request * rreq) cifs_free_request() argument
[all...]
H A Dsmb2pdu.c4616 trace_smb3_read_enter(rdata ? rdata->rreq->debug_id : 0, in smb2_new_read_req()
4687 struct netfs_inode *ictx = netfs_inode(rdata->rreq->inode); in smb2_readv_callback()
4694 .rreq_debug_id = rdata->rreq->debug_id, in smb2_readv_callback()
4698 unsigned int rreq_debug_id = rdata->rreq->debug_id; in smb2_readv_callback()
4781 trace_smb3_read_err(rdata->rreq->debug_id, in smb2_readv_callback()
4790 trace_smb3_read_done(rdata->rreq->debug_id, in smb2_readv_callback()
4916 trace_smb3_read_err(rdata->rreq->debug_id, in smb2_async_readv()
5038 .rreq_debug_id = wdata->rreq->debug_id, in smb2_writev_callback()
5041 unsigned int rreq_debug_id = wdata->rreq->debug_id; in smb2_writev_callback()
5124 trace_smb3_write_err(wdata->rreq in smb2_writev_callback()
[all...]
/linux/include/linux/
H A Dnetfs.h176 struct netfs_io_request *rreq; /* Supervising I/O request */ member
178 struct list_head rreq_link; /* Link in rreq->subrequests */
293 int (*init_request)(struct netfs_io_request *rreq, struct file *file);
294 void (*free_request)(struct netfs_io_request *rreq);
295 void (*free_subrequest)(struct netfs_io_subrequest *rreq);
298 void (*expand_readahead)(struct netfs_io_request *rreq);
301 bool (*is_still_valid)(struct netfs_io_request *rreq);
304 void (*done)(struct netfs_io_request *rreq);

12