Lines Matching full:front

17 #define HIT_PENDING		0x01	/* A front op was still pending */
21 #define NEED_RETRY 0x10 /* A front op requests retrying */
199 struct netfs_io_subrequest *front, *remove; in netfs_collect_write_results() local
220 /* Remove completed subrequests from the front of the streams and in netfs_collect_write_results()
231 front = stream->front; in netfs_collect_write_results()
232 while (front) { in netfs_collect_write_results()
233 trace_netfs_collect_sreq(wreq, front); in netfs_collect_write_results()
235 // front->debug_index, front->start, front->transferred, front->len); in netfs_collect_write_results()
237 if (stream->collected_to < front->start) { in netfs_collect_write_results()
239 stream->collected_to = front->start; in netfs_collect_write_results()
242 /* Stall if the front is still undergoing I/O. */ in netfs_collect_write_results()
243 if (test_bit(NETFS_SREQ_IN_PROGRESS, &front->flags)) { 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()
259 if (test_bit(NETFS_SREQ_FAILED, &front->flags)) { in netfs_collect_write_results()
261 stream->error = front->error; in netfs_collect_write_results()
263 mapping_set_error(wreq->mapping, front->error); in netfs_collect_write_results()
267 if (front->transferred < front->len) { in netfs_collect_write_results()
277 remove = front; in netfs_collect_write_results()
278 list_del_init(&front->rreq_link); in netfs_collect_write_results()
279 front = list_first_entry_or_null(&stream->subrequests, in netfs_collect_write_results()
281 stream->front = front; in netfs_collect_write_results()
292 if (!front && issued_to > stream->collected_to) { in netfs_collect_write_results()