Lines Matching refs:treq
77 td_request_t treq; member
212 td_complete_request(aio->treq, err); in tdqcow_complete()
217 static void async_read(td_driver_t *driver, td_request_t treq) in async_read() argument
225 size = treq.secs * driver->info.sector_size; in async_read()
226 offset = treq.sec * (uint64_t)driver->info.sector_size; in async_read()
232 aio->treq = treq; in async_read()
235 td_prep_read(&aio->tiocb, prv->fd, treq.buf, in async_read()
242 td_complete_request(treq, -EBUSY); in async_read()
245 static void async_write(td_driver_t *driver, td_request_t treq) in async_write() argument
253 size = treq.secs * driver->info.sector_size; in async_write()
254 offset = treq.sec * (uint64_t)driver->info.sector_size; in async_write()
260 aio->treq = treq; in async_write()
263 td_prep_write(&aio->tiocb, prv->fd, treq.buf, in async_write()
270 td_complete_request(treq, -EBUSY); in async_write()
984 void tdqcow_queue_read(td_driver_t *driver, td_request_t treq) in tdqcow_queue_read() argument
990 td_request_t clone = treq; in tdqcow_queue_read()
991 char* buf = treq.buf; in tdqcow_queue_read()
993 sector = treq.sec; in tdqcow_queue_read()
994 nb_sectors = treq.secs; in tdqcow_queue_read()
1006 td_complete_request(treq, -EBUSY); in tdqcow_queue_read()
1016 treq.buf = buf; in tdqcow_queue_read()
1017 treq.sec = sector; in tdqcow_queue_read()
1018 treq.secs = nb_sectors; in tdqcow_queue_read()
1019 td_forward_request(treq); in tdqcow_queue_read()
1022 treq.buf = buf; in tdqcow_queue_read()
1023 treq.sec = sector; in tdqcow_queue_read()
1024 treq.secs = n; in tdqcow_queue_read()
1025 td_forward_request(treq); in tdqcow_queue_read()
1029 td_complete_request(treq, -EIO); in tdqcow_queue_read()
1035 treq.buf = buf; in tdqcow_queue_read()
1036 treq.sec = sector; in tdqcow_queue_read()
1037 treq.secs = n; in tdqcow_queue_read()
1038 td_complete_request(treq, 0); in tdqcow_queue_read()
1053 void tdqcow_queue_write(td_driver_t *driver, td_request_t treq) in tdqcow_queue_write() argument
1060 char* buf = treq.buf; in tdqcow_queue_write()
1061 td_request_t clone=treq; in tdqcow_queue_write()
1063 sector = treq.sec; in tdqcow_queue_write()
1064 nb_sectors = treq.secs; in tdqcow_queue_write()
1074 td_complete_request(treq, -EBUSY); in tdqcow_queue_write()
1083 td_complete_request(treq, -EIO); in tdqcow_queue_write()