Lines Matching refs:sreq
230 struct tapdisk_stream_request *sreq) in tapdisk_stream_queue_completed() argument
235 if (sreq->seqno < itr->seqno) { in tapdisk_stream_queue_completed()
236 list_add_tail(&sreq->next, &itr->next); in tapdisk_stream_queue_completed()
240 list_add_tail(&sreq->next, &s->completed_list); in tapdisk_stream_queue_completed()
320 struct tapdisk_stream_request *sreq = s->requests + rsp->id; in tapdisk_stream_dequeue() local
322 list_del_init(&sreq->next); in tapdisk_stream_dequeue()
325 tapdisk_stream_queue_completed(s, sreq); in tapdisk_stream_dequeue()
328 list_add_tail(&sreq->next, &s->free_list); in tapdisk_stream_dequeue()
329 fprintf(stderr, "error reading sector 0x%"PRIx64"\n", sreq->sec); in tapdisk_stream_dequeue()
334 sreq->sec); in tapdisk_stream_dequeue()
350 struct tapdisk_stream_request *sreq; in tapdisk_stream_enqueue_copy() local
354 sreq = tapdisk_stream_get_request(s); in tapdisk_stream_enqueue_copy()
355 if (!sreq) in tapdisk_stream_enqueue_copy()
358 idx = tapdisk_stream_request_idx(s, sreq); in tapdisk_stream_enqueue_copy()
360 sreq->sec = r->sec; in tapdisk_stream_enqueue_copy()
361 sreq->secs = r->secs; in tapdisk_stream_enqueue_copy()
362 sreq->seqno = r->seqno; in tapdisk_stream_enqueue_copy()
364 breq = &sreq->blkif_req; in tapdisk_stream_enqueue_copy()
375 s->cur += sreq->secs; in tapdisk_stream_enqueue_copy()
386 list_add_tail(&sreq->next, &s->pending_list); in tapdisk_stream_enqueue_copy()
404 struct tapdisk_stream_request *sreq; in tapdisk_stream_enqueue1() local
417 sreq = tapdisk_stream_get_request(s); in tapdisk_stream_enqueue1()
418 if (!sreq) in tapdisk_stream_enqueue1()
421 idx = tapdisk_stream_request_idx(s, sreq); in tapdisk_stream_enqueue1()
423 sreq->sec = s->cur; in tapdisk_stream_enqueue1()
424 sreq->secs = 0; in tapdisk_stream_enqueue1()
425 sreq->seqno = s->started++; in tapdisk_stream_enqueue1()
427 breq = &sreq->blkif_req; in tapdisk_stream_enqueue1()
430 breq->sector_number = sreq->sec; in tapdisk_stream_enqueue1()
442 sreq->secs += secs; in tapdisk_stream_enqueue1()
460 list_add_tail(&sreq->next, &s->pending_list); in tapdisk_stream_enqueue1()