| /qemu/block/ |
| H A D | reqlist.c | 20 void reqlist_init_req(BlockReqList *reqs, BlockReq *req, int64_t offset, in reqlist_init_req() argument
28 QLIST_INSERT_HEAD(reqs, req, list); in reqlist_init_req()
31 BlockReq *reqlist_find_conflict(BlockReqList *reqs, int64_t offset, in reqlist_find_conflict() argument
36 QLIST_FOREACH(r, reqs, list) { in reqlist_find_conflict()
45 bool coroutine_fn reqlist_wait_one(BlockReqList *reqs, int64_t offset, in reqlist_wait_one() argument
48 BlockReq *r = reqlist_find_conflict(reqs, offset, bytes); in reqlist_wait_one()
59 void coroutine_fn reqlist_wait_all(BlockReqList *reqs, int64_t offset, in reqlist_wait_all() argument
62 while (reqlist_wait_one(reqs, offset, bytes, lock)) { in reqlist_wait_all()
|
| H A D | block-copy.c | 141 BlockReqList reqs; member
208 assert(!reqlist_find_conflict(&s->reqs, offset, bytes)); in block_copy_task_create()
220 reqlist_init_req(&s->reqs, &task->req, offset, bytes); in block_copy_task_create()
444 QLIST_INIT(&s->reqs); in block_copy_state_new()
888 ret = reqlist_wait_one(&s->reqs, call_state->offset, in block_copy_common()
|
| H A D | nvme.c | 90 NVMeRequest reqs[NVME_NUM_REQS]; member
259 NVMeRequest *req = &q->reqs[i]; in nvme_create_queue_pair()
304 req = &q->reqs[q->free_req_head]; in nvme_get_free_req_nofail_locked()
340 q->free_req_head = req - q->reqs; in nvme_put_free_req_locked()
429 preq = &q->reqs[cid - 1]; in nvme_process_completion()
|
| /qemu/include/block/ |
| H A D | reqlist.h | 40 void reqlist_init_req(BlockReqList *reqs, BlockReq *req, int64_t offset,
43 BlockReq *reqlist_find_conflict(BlockReqList *reqs, int64_t offset,
53 bool coroutine_fn reqlist_wait_one(BlockReqList *reqs, int64_t offset,
61 void coroutine_fn reqlist_wait_all(BlockReqList *reqs, int64_t offset,
|
| /qemu/tests/qemu-iotests/tests/ |
| H A D | mirror-change-copy-mode | 136 reqs = 4 * iops_source
137 req_size = image_size // reqs
138 for i in range(0, reqs):
173 reqs = 4 * iops_target
174 req_size = image_size // 2 // reqs
175 for i in range(0, reqs):
|
| /qemu/util/ |
| H A D | thread-pool.c | 50 QTAILQ_ENTRY(ThreadPoolElement) reqs;
107 QTAILQ_REMOVE(&pool->request_list, req, reqs); in worker_thread()
227 QTAILQ_REMOVE(&pool->request_list, elem, reqs); in thread_pool_cancel()
265 QTAILQ_INSERT_TAIL(&pool->request_list, req, reqs); in thread_pool_submit_aio()
|
| /qemu/hw/scsi/ |
| H A D | virtio-scsi.c | 371 QTAILQ_HEAD(, VirtIOSCSIReq) reqs = QTAILQ_HEAD_INITIALIZER(reqs); in virtio_scsi_do_tmf_bh()
380 QTAILQ_INSERT_TAIL(&reqs, req, next); in virtio_scsi_do_tmf_bh()
387 QTAILQ_FOREACH_SAFE(req, &reqs, next, tmp) { in virtio_scsi_do_tmf_bh()
388 QTAILQ_REMOVE(&reqs, req, next); in virtio_scsi_do_tmf_bh()
839 QTAILQ_HEAD(, VirtIOSCSIReq) reqs = QTAILQ_HEAD_INITIALIZER(reqs); in virtio_scsi_handle_cmd_vq()
849 QTAILQ_INSERT_TAIL(&reqs, req, next); in virtio_scsi_handle_cmd_vq()
852 while (!QTAILQ_EMPTY(&reqs)) { in virtio_scsi_handle_cmd_vq()
853 req = QTAILQ_FIRST(&reqs); in virtio_scsi_handle_cmd_vq()
854 QTAILQ_REMOVE(&reqs, req, next); in virtio_scsi_handle_cmd_vq()
868 QTAILQ_FOREACH_SAFE(req, &reqs, next, next) { in virtio_scsi_handle_cmd_vq()
|
| H A D | spapr_vscsi.c | 98 vscsi_req reqs[VSCSI_REQ_LIMIT]; member
112 req = &s->reqs[i]; in vscsi_get_req()
129 req = &s->reqs[i]; in vscsi_find_req()
647 req = &s->reqs[sreq->tag]; in vscsi_load_request()
879 tmpreq = &s->reqs[i]; in vscsi_process_tsk_mgmt()
1208 memset(s->reqs, 0, sizeof(s->reqs)); in spapr_vscsi_reset()
1210 s->reqs[i].qtag = i; in spapr_vscsi_reset()
|
| /qemu/hw/block/ |
| H A D | virtio-blk.c | 224 QEMUIOVector *qiov = &mrb->reqs[start]->qiov; in submit_requests()
225 int64_t sector_num = mrb->reqs[start]->sector_num; in submit_requests()
244 qemu_iovec_concat(qiov, &mrb->reqs[i]->qiov, 0, in submit_requests()
245 mrb->reqs[i]->qiov.size); in submit_requests()
246 mrb->reqs[i - 1]->mr_next = mrb->reqs[i]; in submit_requests()
265 mrb->reqs[start]); in submit_requests()
269 mrb->reqs[start]); in submit_requests()
303 max_transfer = blk_get_max_transfer(mrb->reqs[0]->dev->blk); in virtio_blk_submit_multireq()
305 qsort(mrb->reqs, mrb->num_reqs, sizeof(*mrb->reqs), in virtio_blk_submit_multireq()
309 VirtIOBlockReq *req = mrb->reqs[i]; in virtio_blk_submit_multireq()
[all …]
|
| /qemu/include/hw/virtio/ |
| H A D | virtio-blk.h | 98 VirtIOBlockReq *reqs[VIRTIO_BLK_MAX_MERGE_REQS]; member
|