Lines Matching refs:sreq
203 struct tapdisk_stream_request *sreq) in tapdisk_stream_print_request() argument
205 unsigned long idx = (unsigned long)tapdisk_stream_request_idx(s, sreq); in tapdisk_stream_print_request()
207 write_exact(s->out_fd, buf, sreq->secs << SECTOR_SHIFT); in tapdisk_stream_print_request()
213 struct tapdisk_stream_request *sreq, *tmp; in tapdisk_stream_write_data() local
215 list_for_each_entry_safe(sreq, tmp, &s->completed_list, next) { in tapdisk_stream_write_data()
216 if (sreq->seqno != s->completed) in tapdisk_stream_write_data()
220 tapdisk_stream_print_request(s, sreq); in tapdisk_stream_write_data()
222 list_del_init(&sreq->next); in tapdisk_stream_write_data()
223 list_add_tail(&sreq->next, &s->free_list); in tapdisk_stream_write_data()
229 struct tapdisk_stream_request *sreq) in tapdisk_stream_queue_completed() argument
234 if (sreq->seqno < itr->seqno) { in tapdisk_stream_queue_completed()
235 list_add_tail(&sreq->next, &itr->next); in tapdisk_stream_queue_completed()
239 list_add_tail(&sreq->next, &s->completed_list); in tapdisk_stream_queue_completed()
246 struct tapdisk_stream_request *sreq = s->requests + rsp->id; in tapdisk_stream_dequeue() local
248 list_del_init(&sreq->next); in tapdisk_stream_dequeue()
251 tapdisk_stream_queue_completed(s, sreq); in tapdisk_stream_dequeue()
254 list_add_tail(&sreq->next, &s->free_list); in tapdisk_stream_dequeue()
255 fprintf(stderr, "error reading sector 0x%"PRIu64"\n", sreq->sec); in tapdisk_stream_dequeue()
282 struct tapdisk_stream_request *sreq; in tapdisk_stream_enqueue() local
284 sreq = tapdisk_stream_get_request(s); in tapdisk_stream_enqueue()
285 if (!sreq) in tapdisk_stream_enqueue()
288 idx = tapdisk_stream_request_idx(s, sreq); in tapdisk_stream_enqueue()
290 sreq->sec = s->cur; in tapdisk_stream_enqueue()
291 sreq->secs = 0; in tapdisk_stream_enqueue()
292 sreq->seqno = s->started++; in tapdisk_stream_enqueue()
294 breq = &sreq->blkif_req; in tapdisk_stream_enqueue()
297 breq->sector_number = sreq->sec; in tapdisk_stream_enqueue()
307 sreq->secs += secs; in tapdisk_stream_enqueue()
325 list_add_tail(&sreq->next, &s->pending_list); in tapdisk_stream_enqueue()