Searched refs:io_streams (Results 1 – 12 of 12) 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 …]
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()
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()
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()
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
404 rreq->io_streams[0].avail = true; in afs_init_request()
52 struct netfs_io_stream *stream = &req->rreq.io_streams[subreq->stream_nr]; in cifs_prepare_write()177 rreq->io_streams[0].sreq_max_len = size; in cifs_prepare_read()191 rreq->io_streams[0].sreq_max_segs = server->smbd_conn->max_frmr_depth; in cifs_prepare_read()256 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()