Searched refs:io_streams (Results 1 – 19 of 19) sorted by relevance
116 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 …]
46 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()
36 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()
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()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()
190 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()
21 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()
212 stream = &wreq->io_streams[s]; in netfs_retry_writes()228 stream = &wreq->io_streams[s]; in netfs_retry_writes()
87 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()
28 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()
92 struct netfs_io_stream *stream = &rreq->io_streams[0]; in netfs_single_dispatch_read()
56 wreq->io_streams[0].avail = true; in netfs_unbuffered_write_iter_locked()
48 wreq->io_streams[0].avail = true; in v9fs_begin_writeback()
92 struct netfs_io_stream *stream = &subreq->rreq->io_streams[subreq->stream_nr]; in afs_prepare_write()
404 rreq->io_streams[0].avail = true; in afs_init_request()
632 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()
276 rreq->io_streams[0].sreq_max_len = NFS_SB(rreq->inode->i_sb)->rsize; in nfs_netfs_init_request()
236 struct netfs_io_stream io_streams[2]; /* Streams of parallel I/O operations */ member
52 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()
341 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()