Lines Matching refs:subreq
113 void netfs_reset_iter(struct netfs_io_subrequest *subreq) in netfs_reset_iter() argument
115 struct iov_iter *io_iter = &subreq->io_iter; in netfs_reset_iter()
116 size_t remain = subreq->len - subreq->transferred; in netfs_reset_iter()
122 iov_iter_truncate(&subreq->io_iter, remain); in netfs_reset_iter()
335 void netfs_subreq_clear_in_progress(struct netfs_io_subrequest *subreq) in netfs_subreq_clear_in_progress() argument
337 struct netfs_io_request *rreq = subreq->rreq; in netfs_subreq_clear_in_progress()
338 struct netfs_io_stream *stream = &rreq->io_streams[subreq->stream_nr]; in netfs_subreq_clear_in_progress()
340 clear_bit_unlock(NETFS_SREQ_IN_PROGRESS, &subreq->flags); in netfs_subreq_clear_in_progress()
344 if (list_is_first(&subreq->rreq_link, &stream->subrequests) || in netfs_subreq_clear_in_progress()
355 struct netfs_io_subrequest *subreq; in netfs_wait_for_in_progress_stream() local
358 list_for_each_entry(subreq, &stream->subrequests, rreq_link) { in netfs_wait_for_in_progress_stream()
359 if (!netfs_check_subreq_in_progress(subreq)) in netfs_wait_for_in_progress_stream()
366 if (!netfs_check_subreq_in_progress(subreq)) in netfs_wait_for_in_progress_stream()
369 trace_netfs_sreq(subreq, netfs_sreq_trace_wait_for); in netfs_wait_for_in_progress_stream()
392 struct netfs_io_subrequest *subreq; in netfs_collect_in_app() local
399 subreq = list_first_entry_or_null(&stream->subrequests, in netfs_collect_in_app()
402 if (subreq && in netfs_collect_in_app()
403 (!netfs_check_subreq_in_progress(subreq) || in netfs_collect_in_app()
404 test_bit(NETFS_SREQ_MADE_PROGRESS, &subreq->flags))) { in netfs_collect_in_app()
408 if (subreq || !test_bit(NETFS_RREQ_ALL_QUEUED, &rreq->flags)) in netfs_collect_in_app()