Searched refs:io_streams (Results 1 – 17 of 17) 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 = 0; 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 = 0; in netfs_create_write_req()[all …]
49 rreq->io_streams[0].sreq_max_len = ULONG_MAX; in netfs_alloc_request()50 rreq->io_streams[0].sreq_max_segs = 0; in netfs_alloc_request()52 INIT_LIST_HEAD(&rreq->io_streams[0].subrequests); in netfs_alloc_request()53 INIT_LIST_HEAD(&rreq->io_streams[1].subrequests); in netfs_alloc_request()65 rreq->io_streams[0].avail = true; in netfs_alloc_request()100 for (s = 0; s < ARRAY_SIZE(rreq->io_streams); s++) { in netfs_clear_subrequests()101 stream = &rreq->io_streams[s]; in netfs_clear_subrequests()
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()156 netfs_issue_write(creq, &creq->io_streams[1]); in netfs_pgpriv2_end_copy_to_cache()160 if (list_empty_careful(&creq->io_streams[1].subrequests)) in netfs_pgpriv2_end_copy_to_cache()
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()
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()306 stream = &wreq->io_streams[s]; in netfs_collect_write_results()376 struct netfs_io_stream *stream = &wreq->io_streams[s]; in netfs_write_collection()393 if (wreq->io_streams[1].active && in netfs_write_collection()394 wreq->io_streams[1].failed && in netfs_write_collection()
188 struct netfs_io_stream *stream = &rreq->io_streams[0]; in netfs_collect_read_results()378 struct netfs_io_stream *stream = &rreq->io_streams[0]; in netfs_rreq_assess_single()406 struct netfs_io_stream *stream = &rreq->io_streams[0]; in netfs_read_collection()478 struct netfs_io_stream *stream = &rreq->io_streams[0]; in netfs_read_subreq_progress()
212 stream = &wreq->io_streams[s]; in netfs_retry_writes()224 stream = &wreq->io_streams[s]; in netfs_retry_writes()
88 rsize = umin(rsize, rreq->io_streams[0].sreq_max_len); in netfs_prepare_read_iterator()113 if (unlikely(rreq->io_streams[0].sreq_max_segs)) { in netfs_prepare_read_iterator()115 rreq->io_streams[0].sreq_max_segs); in netfs_prepare_read_iterator()163 struct netfs_io_stream *stream = &rreq->io_streams[0]; in netfs_queue_read()
338 struct netfs_io_stream *stream = &rreq->io_streams[subreq->stream_nr]; in netfs_subreq_clear_in_progress()393 struct netfs_io_stream *stream = &rreq->io_streams[i]; in netfs_collect_in_app()
42 wreq->io_streams[0].avail = true; in netfs_unbuffered_write_iter_locked()
92 struct netfs_io_stream *stream = &rreq->io_streams[0]; in netfs_single_dispatch_read()
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()
630 struct netfs_io_stream *stream = &wreq->io_streams[subreq->stream_nr]; in cachefiles_prepare_write_subreq()651 struct netfs_io_stream *stream = &wreq->io_streams[subreq->stream_nr]; in cachefiles_issue_write()
236 struct netfs_io_stream io_streams[2]; /* Streams of parallel I/O operations */ member
53 struct netfs_io_stream *stream = &req->rreq.io_streams[subreq->stream_nr]; in cifs_prepare_write()182 rreq->io_streams[0].sreq_max_len = size; in cifs_prepare_read()199 rreq->io_streams[0].sreq_max_segs = sp->max_frmr_depth; in cifs_prepare_read()265 wreq->io_streams[0].avail = true; in cifs_begin_writeback()
346 rreq->io_streams[0].sreq_max_len = umin(xlen, fsc->mount_options->rsize); in ceph_netfs_prepare_read()513 rreq->io_streams[0].sreq_max_len = fsc->mount_options->rsize; in ceph_init_request()