Lines Matching refs:stream
18 struct netfs_io_stream *stream) in netfs_retry_write_stream() argument
22 _enter("R=%x[%x:]", wreq->debug_id, stream->stream_nr); in netfs_retry_write_stream()
24 if (list_empty(&stream->subrequests)) in netfs_retry_write_stream()
27 if (stream->source == NETFS_UPLOAD_TO_SERVER && in netfs_retry_write_stream()
29 wreq->netfs_ops->retry_request(wreq, stream); in netfs_retry_write_stream()
31 if (unlikely(stream->failed)) in netfs_retry_write_stream()
35 if (!stream->prepare_write) { in netfs_retry_write_stream()
38 list_for_each_entry(subreq, &stream->subrequests, rreq_link) { in netfs_retry_write_stream()
47 netfs_reissue_write(stream, subreq, &source); in netfs_retry_write_stream()
53 next = stream->subrequests.next; in netfs_retry_write_stream()
75 list_for_each_continue(next, &stream->subrequests) { in netfs_retry_write_stream()
94 list_for_each_entry_from(subreq, &stream->subrequests, rreq_link) { in netfs_retry_write_stream()
105 stream->sreq_max_len = len; in netfs_retry_write_stream()
106 stream->prepare_write(subreq); in netfs_retry_write_stream()
108 part = umin(len, stream->sreq_max_len); in netfs_retry_write_stream()
109 if (unlikely(stream->sreq_max_segs)) in netfs_retry_write_stream()
110 part = netfs_limit_iter(&source, 0, part, stream->sreq_max_segs); in netfs_retry_write_stream()
120 netfs_reissue_write(stream, subreq, &source); in netfs_retry_write_stream()
132 &stream->subrequests, rreq_link) { in netfs_retry_write_stream()
161 stream->sreq_max_len = len; in netfs_retry_write_stream()
162 stream->sreq_max_segs = INT_MAX; in netfs_retry_write_stream()
163 switch (stream->source) { in netfs_retry_write_stream()
166 stream->sreq_max_len = umin(len, wreq->wsize); in netfs_retry_write_stream()
175 stream->prepare_write(subreq); in netfs_retry_write_stream()
177 part = umin(len, stream->sreq_max_len); in netfs_retry_write_stream()
186 netfs_reissue_write(stream, subreq, &source); in netfs_retry_write_stream()
192 } while (!list_is_head(next, &stream->subrequests)); in netfs_retry_write_stream()
202 struct netfs_io_stream *stream; in netfs_retry_writes() local
212 stream = &wreq->io_streams[s]; in netfs_retry_writes()
213 if (stream->active) in netfs_retry_writes()
214 netfs_wait_for_in_progress_stream(wreq, stream); in netfs_retry_writes()
224 stream = &wreq->io_streams[s]; in netfs_retry_writes()
225 if (stream->need_retry) { in netfs_retry_writes()
226 stream->need_retry = false; in netfs_retry_writes()
227 netfs_retry_write_stream(wreq, stream); in netfs_retry_writes()