Lines Matching refs:stream
200 struct netfs_io_stream *stream; in netfs_collect_write_results() local
226 stream = &wreq->io_streams[s]; in netfs_collect_write_results()
228 if (!smp_load_acquire(&stream->active)) in netfs_collect_write_results()
231 front = stream->front; in netfs_collect_write_results()
237 if (stream->collected_to < front->start) { in netfs_collect_write_results()
238 trace_netfs_collect_gap(wreq, stream, issued_to, 'F'); in netfs_collect_write_results()
239 stream->collected_to = front->start; in netfs_collect_write_results()
249 if (stream->failed) { in netfs_collect_write_results()
250 stream->collected_to = front->start + front->len; in netfs_collect_write_results()
254 if (front->start + front->transferred > stream->collected_to) { in netfs_collect_write_results()
255 stream->collected_to = front->start + front->transferred; in netfs_collect_write_results()
256 stream->transferred = stream->collected_to - wreq->start; in netfs_collect_write_results()
257 stream->transferred_valid = true; in netfs_collect_write_results()
261 stream->failed = true; in netfs_collect_write_results()
262 stream->error = front->error; in netfs_collect_write_results()
263 if (stream->source == NETFS_UPLOAD_TO_SERVER) in netfs_collect_write_results()
269 stream->need_retry = true; in netfs_collect_write_results()
280 front = list_first_entry_or_null(&stream->subrequests, in netfs_collect_write_results()
282 stream->front = front; in netfs_collect_write_results()
293 if (!front && issued_to > stream->collected_to) { in netfs_collect_write_results()
294 trace_netfs_collect_gap(wreq, stream, issued_to, 'E'); in netfs_collect_write_results()
295 stream->collected_to = issued_to; in netfs_collect_write_results()
298 if (stream->collected_to < collected_to) in netfs_collect_write_results()
299 collected_to = stream->collected_to; in netfs_collect_write_results()
306 stream = &wreq->io_streams[s]; in netfs_collect_write_results()
307 if (stream->active) in netfs_collect_write_results()
308 trace_netfs_collect_stream(wreq, stream); in netfs_collect_write_results()
376 struct netfs_io_stream *stream = &wreq->io_streams[s]; in netfs_write_collection() local
377 if (!stream->active) in netfs_write_collection()
379 if (!list_empty(&stream->subrequests)) in netfs_write_collection()
381 if (stream->transferred_valid && in netfs_write_collection()
382 stream->transferred < transferred) { in netfs_write_collection()
383 transferred = stream->transferred; in netfs_write_collection()