| /xen-4.10.0-shim-comet/tools/blktap2/drivers/ |
| A D | qcow2raw.c | 127 written += treq.secs; in send_write_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()
207 td_request_t treq; in main() local
387 treq.buf = buf; in main()
388 treq.sec = i; in main()
392 treq.id = 0; in main()
393 treq.sidx = 0; in main()
[all …]
|
| A D | block-aio.c | 49 td_request_t treq; member
167 td_complete_request(aio->treq, err); in tdaio_complete()
179 size = treq.secs * driver->info.sector_size; in tdaio_queue_read()
180 offset = treq.sec * (uint64_t)driver->info.sector_size; in tdaio_queue_read()
186 aio->treq = treq; in tdaio_queue_read()
189 td_prep_read(&aio->tiocb, prv->fd, treq.buf, in tdaio_queue_read()
196 td_complete_request(treq, -EBUSY); in tdaio_queue_read()
207 size = treq.secs * driver->info.sector_size; in tdaio_queue_write()
214 aio->treq = treq; in tdaio_queue_write()
217 td_prep_write(&aio->tiocb, prv->fd, treq.buf, in tdaio_queue_write()
[all …]
|
| A D | img2qcow.c | 161 free(treq.buf); in send_responses()
170 td_request_t treq; in main() local
267 treq.op = TD_OP_WRITE; in main()
268 treq.buf = buf; in main()
269 treq.sec = i; in main()
270 treq.secs = len; in main()
271 treq.image = 0; in main()
273 treq.cb_data = buf; in main()
274 treq.id = 0; in main()
275 treq.sidx = 0; in main()
[all …]
|
| A D | tapdisk-vbd.c | 1215 treq.secs, treq.sec); in __tapdisk_vbd_complete_td_request()
1251 memset(treq.buf, 0, treq.secs << SECTOR_SHIFT); in __tapdisk_vbd_reissue_td_request()
1260 if (treq.sec + treq.secs > parent->info.size) { in __tapdisk_vbd_reissue_td_request()
1270 treq.secs = 0; in __tapdisk_vbd_reissue_td_request()
1275 if (!treq.secs) in __tapdisk_vbd_reissue_td_request()
1279 switch (treq.op) { in __tapdisk_vbd_reissue_td_request()
1293 treq.sec, in __tapdisk_vbd_reissue_td_request()
1294 treq.secs, in __tapdisk_vbd_reissue_td_request()
1349 (int)treq.id, treq.sidx, treq.sec, treq.secs, in tapdisk_vbd_complete_td_request()
1361 td_request_t treq; in tapdisk_vbd_issue_request() local
[all …]
|
| A D | tapdisk-interface.c | 177 err = tapdisk_image_check_td_request(image, treq); in td_queue_write()
181 driver->ops->td_queue_write(driver, treq); in td_queue_write()
185 td_complete_request(treq, err); in td_queue_write()
189 td_queue_read(td_image_t *image, td_request_t treq) in td_queue_read() argument
205 err = tapdisk_image_check_td_request(image, treq); in td_queue_read()
209 driver->ops->td_queue_read(driver, treq); in td_queue_read()
213 td_complete_request(treq, err); in td_queue_read()
217 td_forward_request(td_request_t treq) in td_forward_request() argument
219 tapdisk_vbd_forward_request(treq); in td_forward_request()
223 td_complete_request(td_request_t treq, int res) in td_complete_request() argument
[all …]
|
| A D | tapdisk-image.c | 87 tapdisk_image_check_td_request(td_image_t *image, td_request_t treq) in tapdisk_image_check_td_request() argument
100 if (treq.op != TD_OP_READ && treq.op != TD_OP_WRITE) in tapdisk_image_check_td_request()
103 if (treq.op == TD_OP_WRITE && rdonly) in tapdisk_image_check_td_request()
106 if (treq.secs <= 0 || treq.sec + treq.secs > info->size) in tapdisk_image_check_td_request()
113 image->name, (rdonly ? "ro" : "rw"), info->size, treq.op, in tapdisk_image_check_td_request()
114 treq.sec + treq.secs); in tapdisk_image_check_td_request()
|
| A D | block-cache.c | 614 cache->stats.hits += treq.secs; in block_cache_hit()
616 for (i = 0; i < treq.secs; i++) { in block_cache_hit()
624 td_complete_request(treq, 0); in block_cache_hit()
653 memcpy(breq->treq.buf + off, in block_cache_populate_cache()
658 breq->treq.sec, breq->treq.secs)) in block_cache_populate_cache()
677 clone = treq; in block_cache_miss()
681 cache->stats.misses += treq.secs; in block_cache_miss()
695 breq->treq = treq; in block_cache_miss()
696 breq->secs = treq.secs; in block_cache_miss()
720 cache->stats.reads += treq.secs; in block_cache_queue_read()
[all …]
|
| A D | block-vhd.c | 918 r->treq.sec / SPB, r->treq.sec, tx, in add_to_transaction()
1474 req->treq = treq; in schedule_data_read()
1484 treq.buf); in schedule_data_read()
1527 req->treq = treq; in schedule_data_write()
1659 req->treq = treq; in __vhd_queue_request()
1679 s->vhd.file, treq.sec, treq.secs, treq.sidx); in vhd_queue_read()
1752 s->vhd.file, treq.sec, treq.secs, treq.sidx); in vhd_queue_write()
1851 "err: %d\n", r->treq.sec, r->treq.sec / s->spb, err); in signal_completion()
2145 req->treq.sec, req->treq.sec / s->spb); in finish_data_read()
2184 req->treq.sec, req->treq.sec / s->spb); in finish_data_write()
[all …]
|
| A D | block-remus.c | 257 start = treq.sec; in replicated_write_callback()
262 free(treq.buf); in replicated_write_callback()
272 td_request_t treq; in create_write_request() local
276 treq.buf = buf; in create_write_request()
277 treq.sec = sec; in create_write_request()
278 treq.secs = secs; in create_write_request()
282 treq.id = 0; in create_write_request()
283 treq.sidx = 0; in create_write_request()
286 treq.private = vreq; in create_write_request()
861 *sector = treq.sec; in primary_queue_write()
[all …]
|
| A D | block-ram.c | 201 void tdram_queue_read(td_driver_t *driver, td_request_t treq) in tdram_queue_read() argument
204 int size = treq.secs * driver->info.sector_size; in tdram_queue_read()
205 uint64_t offset = treq.sec * (uint64_t)driver->info.sector_size; in tdram_queue_read()
207 memcpy(treq.buf, img + offset, size); in tdram_queue_read()
209 td_complete_request(treq, 0); in tdram_queue_read()
212 void tdram_queue_write(td_driver_t *driver, td_request_t treq) in tdram_queue_write() argument
215 int size = treq.secs * driver->info.sector_size; in tdram_queue_write()
216 uint64_t offset = treq.sec * (uint64_t)driver->info.sector_size; in tdram_queue_write()
220 memcpy(img + offset, treq.buf, size); in tdram_queue_write()
222 td_complete_request(treq, 0); in tdram_queue_write()
|
| A D | block-qcow.c | 77 td_request_t treq; member
232 aio->treq = treq; in async_read()
260 aio->treq = treq; in async_write()
991 char* buf = treq.buf; 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()
1035 treq.buf = buf; in tdqcow_queue_read()
1036 treq.sec = sector; in tdqcow_queue_read()
1037 treq.secs = n; in tdqcow_queue_read()
[all …]
|
| A D | block-log.c | 630 static void tdlog_queue_read(td_driver_t* driver, td_request_t treq) in tdlog_queue_read() argument
632 td_forward_request(treq); in tdlog_queue_read()
635 static void tdlog_queue_write(td_driver_t* driver, td_request_t treq) in tdlog_queue_write() argument
640 writelog_set(s, treq.sec, treq.secs); in tdlog_queue_write()
641 td_forward_request(treq); in tdlog_queue_write()
|