Lines Matching refs:treq
118 static void send_write_responses(td_request_t treq, int err) in send_write_responses() argument
126 returned_write_events+=treq.secs; in send_write_responses()
127 written += treq.secs; in send_write_responses()
129 req= (struct request_info*)treq.cb_data; in send_write_responses()
132 req->pending-=treq.secs; in send_write_responses()
145 static void send_read_responses(td_request_t treq, int err) in send_read_responses() argument
155 returned_read_events+=treq.secs; in send_read_responses()
157 req= (struct request_info*)treq.cb_data; in send_read_responses()
160 req->pending-=treq.secs; in send_read_responses()
166 tapdisk_vbd_complete_vbd_request(qcow_vbd, treq.private); in send_read_responses()
169 treq.op = TD_OP_WRITE; in send_read_responses()
170 treq.buf = req->buf; in send_read_responses()
171 treq.sec = req->logical_sec; in send_read_responses()
172 treq.secs = BLOCK_PROCESSSZ>>9; in send_read_responses()
173 treq.image = tapdisk_vbd_first_image(aio_vbd); in send_read_responses()
174 treq.cb = send_write_responses; in send_read_responses()
175 treq.id = 0; in send_read_responses()
176 treq.sidx = 0; in send_read_responses()
179 treq.cb_data = req; in send_read_responses()
182 treq.private = vreq; in send_read_responses()
188 tapdisk_vbd_move_request(treq.private, in send_read_responses()
191 ddaio->ops->td_queue_write(ddaio,treq); in send_read_responses()
207 td_request_t treq; in main() local
386 treq.op = TD_OP_READ; in main()
387 treq.buf = buf; in main()
388 treq.sec = i; in main()
389 treq.secs = BLOCK_PROCESSSZ>>9; in main()
390 treq.image = tapdisk_vbd_first_image(qcow_vbd); in main()
391 treq.cb = send_read_responses; in main()
392 treq.id = 0; in main()
393 treq.sidx = 0; in main()
399 treq.cb_data = req; in main()
402 treq.private = vreq; in main()
408 tapdisk_vbd_move_request(treq.private, in main()
411 ddqcow->ops->td_queue_read(ddqcow, treq); in main()