Home
last modified time | relevance | path

Searched refs:io_streams (Results 1 – 19 of 19) sorted by relevance

/linux/fs/netfs/
H A Dwrite_issue.c116 wreq->io_streams[0].stream_nr = 0; in netfs_create_write_req()
117 wreq->io_streams[0].source = NETFS_UPLOAD_TO_SERVER; in netfs_create_write_req()
118 wreq->io_streams[0].prepare_write = ictx->ops->prepare_write; in netfs_create_write_req()
119 wreq->io_streams[0].issue_write = ictx->ops->issue_write; in netfs_create_write_req()
120 wreq->io_streams[0].collected_to = start; in netfs_create_write_req()
121 wreq->io_streams[0].transferred = LONG_MAX; in netfs_create_write_req()
123 wreq->io_streams[1].stream_nr = 1; in netfs_create_write_req()
124 wreq->io_streams[1].source = NETFS_WRITE_TO_CACHE; in netfs_create_write_req()
125 wreq->io_streams[1].collected_to = start; in netfs_create_write_req()
126 wreq->io_streams[1].transferred = LONG_MAX; in netfs_create_write_req()
[all …]
H A Dobjects.c46 rreq->io_streams[0].sreq_max_len = ULONG_MAX; in netfs_alloc_request()
47 rreq->io_streams[0].sreq_max_segs = 0; in netfs_alloc_request()
49 INIT_LIST_HEAD(&rreq->io_streams[0].subrequests); in netfs_alloc_request()
50 INIT_LIST_HEAD(&rreq->io_streams[1].subrequests); in netfs_alloc_request()
61 rreq->io_streams[0].avail = true; in netfs_alloc_request()
98 for (s = 0; s < ARRAY_SIZE(rreq->io_streams); s++) { in netfs_clear_subrequests()
99 stream = &rreq->io_streams[s]; in netfs_clear_subrequests()
H A Dwrite_collect.c36 const struct netfs_io_stream *s = &rreq->io_streams[i]; in netfs_dump_request()
226 stream = &wreq->io_streams[s]; in netfs_collect_write_results()
305 stream = &wreq->io_streams[s]; in netfs_collect_write_results()
387 struct netfs_io_stream *stream = &wreq->io_streams[s]; in netfs_write_collection_worker()
402 if (wreq->io_streams[1].active && in netfs_write_collection_worker()
403 wreq->io_streams[1].failed) { in netfs_write_collection_worker()
486 struct netfs_io_stream *stream = &wreq->io_streams[subreq->stream_nr]; in netfs_write_subrequest_terminated()
H A Ddirect_read.c24 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()
29 rreq->io_streams[0].sreq_max_segs); in netfs_prepare_dio_read_iterator()
50 struct netfs_io_stream *stream = &rreq->io_streams[0]; in netfs_dispatch_unbuffered_reads()
H A Dread_collect.c190 struct netfs_io_stream *stream = &rreq->io_streams[0]; in netfs_collect_read_results()
346 struct netfs_io_stream *stream = &rreq->io_streams[0]; in netfs_rreq_assess_dio()
389 struct netfs_io_stream *stream = &rreq->io_streams[0]; in netfs_rreq_assess_single()
415 struct netfs_io_stream *stream = &rreq->io_streams[0]; in netfs_read_collection()
499 struct netfs_io_stream *stream = &rreq->io_streams[0]; in netfs_read_subreq_progress()
538 struct netfs_io_stream *stream = &rreq->io_streams[0]; in netfs_read_subreq_terminated()
623 struct netfs_io_stream *stream = &rreq->io_streams[0]; in netfs_wait_for_read()
676 struct netfs_io_stream *stream = &rreq->io_streams[0]; in netfs_wait_for_pause()
H A Dread_pgpriv2.c21 struct netfs_io_stream *cache = &creq->io_streams[1]; in netfs_pgpriv2_copy_folio()
110 if (!creq->io_streams[1].avail) in netfs_pgpriv2_begin_copy_to_cache()
154 netfs_issue_write(creq, &creq->io_streams[1]); in netfs_pgpriv2_end_copy_to_cache()
H A Dwrite_retry.c212 stream = &wreq->io_streams[s]; in netfs_retry_writes()
228 stream = &wreq->io_streams[s]; in netfs_retry_writes()
H A Dbuffered_read.c87 rsize = umin(rsize, rreq->io_streams[0].sreq_max_len); in netfs_prepare_read_iterator()
112 if (unlikely(rreq->io_streams[0].sreq_max_segs)) { in netfs_prepare_read_iterator()
114 rreq->io_streams[0].sreq_max_segs); in netfs_prepare_read_iterator()
162 struct netfs_io_stream *stream = &rreq->io_streams[0]; in netfs_queue_read()
H A Dread_retry.c28 struct netfs_io_stream *stream = &rreq->io_streams[0]; in netfs_retry_read_subrequests()
261 struct netfs_io_stream *stream = &rreq->io_streams[0]; in netfs_retry_reads()
H A Dread_single.c92 struct netfs_io_stream *stream = &rreq->io_streams[0]; in netfs_single_dispatch_read()
H A Ddirect_write.c56 wreq->io_streams[0].avail = true; in netfs_unbuffered_write_iter_locked()
/linux/fs/9p/
H A Dvfs_addr.c48 wreq->io_streams[0].avail = true; in v9fs_begin_writeback()
/linux/fs/afs/
H A Dwrite.c92 struct netfs_io_stream *stream = &subreq->rreq->io_streams[subreq->stream_nr]; in afs_prepare_write()
H A Dfile.c404 rreq->io_streams[0].avail = true; in afs_init_request()
/linux/fs/cachefiles/
H A Dio.c632 struct netfs_io_stream *stream = &wreq->io_streams[subreq->stream_nr]; in cachefiles_prepare_write_subreq()
653 struct netfs_io_stream *stream = &wreq->io_streams[subreq->stream_nr]; in cachefiles_issue_write()
/linux/fs/nfs/
H A Dfscache.c276 rreq->io_streams[0].sreq_max_len = NFS_SB(rreq->inode->i_sb)->rsize; in nfs_netfs_init_request()
/linux/include/linux/
H A Dnetfs.h236 struct netfs_io_stream io_streams[2]; /* Streams of parallel I/O operations */ member
/linux/fs/smb/client/
H A Dfile.c52 struct netfs_io_stream *stream = &req->rreq.io_streams[subreq->stream_nr]; in cifs_prepare_write()
173 rreq->io_streams[0].sreq_max_len = size; in cifs_prepare_read()
187 rreq->io_streams[0].sreq_max_segs = server->smbd_conn->max_frmr_depth; in cifs_prepare_read()
251 wreq->io_streams[0].avail = true; in cifs_begin_writeback()
/linux/fs/ceph/
H A Daddr.c341 rreq->io_streams[0].sreq_max_len = umin(xlen, fsc->mount_options->rsize); in ceph_netfs_prepare_read()
499 rreq->io_streams[0].sreq_max_len = fsc->mount_options->rsize; in ceph_init_request()