Searched refs:io_streams (Results 1 – 15 of 15) sorted by relevance
113 wreq->io_streams[0].stream_nr = 0; in netfs_create_write_req()114 wreq->io_streams[0].source = NETFS_UPLOAD_TO_SERVER; in netfs_create_write_req()115 wreq->io_streams[0].prepare_write = ictx->ops->prepare_write; in netfs_create_write_req()116 wreq->io_streams[0].issue_write = ictx->ops->issue_write; in netfs_create_write_req()117 wreq->io_streams[0].collected_to = start; in netfs_create_write_req()118 wreq->io_streams[0].transferred = LONG_MAX; in netfs_create_write_req()120 wreq->io_streams[1].stream_nr = 1; in netfs_create_write_req()121 wreq->io_streams[1].source = NETFS_WRITE_TO_CACHE; in netfs_create_write_req()122 wreq->io_streams[1].collected_to = start; in netfs_create_write_req()123 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()103 for (s = 0; s < ARRAY_SIZE(rreq->io_streams); s++) { in netfs_clear_subrequests()104 stream = &rreq->io_streams[s]; in netfs_clear_subrequests()
342 stream = &wreq->io_streams[s]; in netfs_retry_writes()358 stream = &wreq->io_streams[s]; in netfs_retry_writes()404 stream = &wreq->io_streams[s]; in netfs_collect_write_results()483 stream = &wreq->io_streams[s]; in netfs_collect_write_results()564 struct netfs_io_stream *stream = &wreq->io_streams[s]; in netfs_write_collection_worker()579 if (wreq->io_streams[1].active && in netfs_write_collection_worker()580 wreq->io_streams[1].failed) { in netfs_write_collection_worker()664 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()
62 struct netfs_io_stream *cache = &wreq->io_streams[1]; in netfs_pgpriv2_copy_folio()190 netfs_issue_write(wreq, &wreq->io_streams[1]); in netfs_pgpriv2_write_to_the_cache()
36 struct netfs_io_stream *stream0 = &rreq->io_streams[0]; in netfs_retry_read_subrequests()158 if (unlikely(rreq->io_streams[0].sreq_max_segs)) in netfs_retry_read_subrequests()
118 rsize = umin(rsize, rreq->io_streams[0].sreq_max_len); in netfs_prepare_read_iterator()150 if (unlikely(rreq->io_streams[0].sreq_max_segs)) { in netfs_prepare_read_iterator()152 rreq->io_streams[0].sreq_max_segs); in netfs_prepare_read_iterator()
56 wreq->io_streams[0].avail = true; in netfs_unbuffered_write_iter_locked()
92 struct netfs_io_stream *stream = &subreq->rreq->io_streams[subreq->stream_nr]; in afs_prepare_write()183 wreq->io_streams[0].avail = true; in afs_begin_writeback()
48 wreq->io_streams[0].avail = true; in v9fs_begin_writeback()
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()
270 rreq->io_streams[0].sreq_max_len = NFS_SB(rreq->inode->i_sb)->rsize; in nfs_netfs_init_request()
237 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()171 rreq->io_streams[0].sreq_max_len = size; in cifs_prepare_read()185 rreq->io_streams[0].sreq_max_segs = server->smbd_conn->max_frmr_depth; in cifs_prepare_read()248 wreq->io_streams[0].avail = true; in cifs_begin_writeback()
333 rreq->io_streams[0].sreq_max_len = umin(xlen, fsc->mount_options->rsize); in ceph_netfs_prepare_read()489 rreq->io_streams[0].sreq_max_len = fsc->mount_options->rsize; in ceph_init_request()