Lines Matching refs:subreq
90 void afs_prepare_write(struct netfs_io_subrequest *subreq) in afs_prepare_write() argument
92 struct netfs_io_stream *stream = &subreq->rreq->io_streams[subreq->stream_nr]; in afs_prepare_write()
105 struct netfs_io_subrequest *subreq = container_of(work, struct netfs_io_subrequest, work); in afs_issue_write_worker() local
106 struct netfs_io_request *wreq = subreq->rreq; in afs_issue_write_worker()
109 unsigned long long pos = subreq->start + subreq->transferred; in afs_issue_write_worker()
110 size_t len = subreq->len - subreq->transferred; in afs_issue_write_worker()
114 wreq->debug_id, subreq->debug_index, in afs_issue_write_worker()
122 if (subreq->debug_index == 3) in afs_issue_write_worker()
123 return netfs_write_subrequest_terminated(subreq, -ENOANO); in afs_issue_write_worker()
125 if (!subreq->retry_count) { in afs_issue_write_worker()
126 set_bit(NETFS_SREQ_NEED_RETRY, &subreq->flags); in afs_issue_write_worker()
127 return netfs_write_subrequest_terminated(subreq, -EAGAIN); in afs_issue_write_worker()
133 return netfs_write_subrequest_terminated(subreq, -EAGAIN); in afs_issue_write_worker()
145 op->store.write_iter = &subreq->io_iter; in afs_issue_write_worker()
153 __set_bit(NETFS_SREQ_MADE_PROGRESS, &subreq->flags); in afs_issue_write_worker()
165 set_bit(NETFS_SREQ_NEED_RETRY, &subreq->flags); in afs_issue_write_worker()
169 netfs_write_subrequest_terminated(subreq, ret < 0 ? ret : subreq->len); in afs_issue_write_worker()
172 void afs_issue_write(struct netfs_io_subrequest *subreq) in afs_issue_write() argument
174 subreq->work.func = afs_issue_write_worker; in afs_issue_write()
175 if (!queue_work(system_unbound_wq, &subreq->work)) in afs_issue_write()
195 struct netfs_io_subrequest *subreq = in afs_retry_request() local
212 switch (subreq->error) { in afs_retry_request()