| /qemu/tests/qtest/libqos/ |
| H A D | virtio-9p-client.c | 87 qtest_memwrite(req->qts, req->t_msg + req->t_off, addr, len); in v9fs_memwrite()
98 qtest_memread(req->qts, req->r_msg + req->r_off, addr, len); in v9fs_memread()
219 req->free_head = qvirtqueue_add(req->qts, v9p->vq, req->t_msg, req->t_size, in v9fs_req_send()
340 .req = req, in v9fs_tversion()
402 .req = req, in v9fs_tattach()
470 .req = req, in v9fs_twalk()
676 return (TLOpenRes) { .req = req }; in v9fs_tlopen()
725 .req = req, in v9fs_twrite()
763 return (TFlushRes) { .req = req }; in v9fs_tflush()
818 return (TMkdirRes) { .req = req }; in v9fs_tmkdir()
[all …]
|
| H A D | virtio-9p-client.h | 107 P9Req *req; member
129 P9Req *req; member
156 P9Req *req; member
182 P9Req *req; member
212 P9Req *req; member
239 P9Req *req; member
265 P9Req *req; member
287 P9Req *req; member
320 P9Req *req; member
355 P9Req *req; member
[all …]
|
| /qemu/hw/xen/ |
| H A D | xen-hvm-common.c | 298 trace_cpu_ioreq_pio(req, req->dir, req->df, req->data_is_ptr, req->addr, in cpu_ioreq_pio()
307 req->data = do_inp(req->addr, req->size); in cpu_ioreq_pio()
322 do_outp(req->addr, req->size, req->data); in cpu_ioreq_pio()
338 trace_cpu_ioreq_move(req, req->dir, req->df, req->data_is_ptr, req->addr, in cpu_ioreq_move()
430 trace_handle_ioreq(req, req->type, req->dir, req->df, req->data_is_ptr, in handle_ioreq()
431 req->addr, req->data, req->count, req->size); in handle_ioreq()
439 trace_handle_ioreq_write(req, req->type, req->df, req->data_is_ptr, in handle_ioreq()
440 req->addr, req->data, req->count, req->size); in handle_ioreq()
461 trace_handle_ioreq_read(req, req->type, req->df, req->data_is_ptr, in handle_ioreq()
462 req->addr, req->data, req->count, req->size); in handle_ioreq()
[all …]
|
| /qemu/hw/scsi/ |
| H A D | virtio-scsi.c | 111 qemu_iovec_from_buf(&req->resp_iov, 0, &req->resp, req->resp_size); in virtio_scsi_complete_req()
112 virtqueue_push(vq, &req->elem, req->qsgl.size + req->resp_iov.size); in virtio_scsi_complete_req()
327 switch (req->req.tmf.subtype) { in virtio_scsi_do_one_tmf_bh()
343 target = req->req.tmf.lun[1]; in virtio_scsi_do_one_tmf_bh()
447 req->req.tmf.subtype = in virtio_scsi_do_tmf()
451 req->req.tmf.tag, req->req.tmf.subtype); in virtio_scsi_do_tmf()
453 switch (req->req.tmf.subtype) { in virtio_scsi_do_tmf()
464 if (cmd_req && cmd_req->req.cmd.tag == req->req.tmf.tag) { in virtio_scsi_do_tmf()
797 req->req.cmd.tag, req->req.cmd.cdb[0]); in virtio_scsi_handle_cmd_req_prepare()
806 req->sreq = scsi_req_new(d, req->req.cmd.tag, in virtio_scsi_handle_cmd_req_prepare()
[all …]
|
| H A D | scsi-bus.c | 794 trace_scsi_req_alloc(req->dev->id, req->lun, req->tag); in scsi_req_alloc()
943 trace_scsi_req_build_sense(req->dev->id, req->lun, req->tag, in scsi_req_build_sense()
953 req->sg = req->bus->info->get_sg_list(req); in scsi_req_enqueue_internal()
968 rc = req->ops->send_command(req, req->cmd.buf); in scsi_req_enqueue()
975 trace_scsi_req_dequeue(req->dev->id, req->lun, req->tag); in scsi_req_dequeue()
1470 trace_scsi_req_continue(req->dev->id, req->lun, req->tag); in scsi_req_continue()
1561 req->bus->info->fail(req); in scsi_req_complete_failed()
1580 memcpy(req->dev->sense, req->sense, req->sense_len); in scsi_req_complete()
1590 req->bus->info->complete(req, req->residual); in scsi_req_complete()
1614 trace_scsi_req_cancel(req->dev->id, req->lun, req->tag); in scsi_req_cancel_async()
[all …]
|
| H A D | spapr_vscsi.c | 114 memset(req, 0, sizeof(*req)); in vscsi_get_req()
371 rc = vscsi_fetch_desc(s, req, req->cur_desc_num, req->cur_desc_offset, &md); in vscsi_srp_direct_data()
406 rc = vscsi_fetch_desc(s, req, req->cur_desc_num, req->cur_desc_offset, &md); in vscsi_srp_indirect_data()
501 req->total_desc = req->local_desc = 1; in vscsi_preprocess_desc()
566 req->senselen = scsi_req_get_sense(req->sreq, req->sense, in vscsi_command_complete()
569 req->sense[0], req->sense[1], req->sense[2], req->sense[3], in vscsi_command_complete()
570 req->sense[4], req->sense[5], req->sense[6], req->sense[7]); in vscsi_command_complete()
572 req->sense[8], req->sense[9], req->sense[10], req->sense[11], in vscsi_command_complete()
573 req->sense[12], req->sense[13], req->sense[14], req->sense[15]); in vscsi_command_complete()
650 memset(req, 0, sizeof(*req)); in vscsi_load_request()
[all …]
|
| H A D | mptendian.c | 57 req->MsgContext = le32_to_cpu(req->MsgContext); in mptsas_fix_scsi_io_endianness()
58 req->Control = le32_to_cpu(req->Control); in mptsas_fix_scsi_io_endianness()
59 req->DataLength = le32_to_cpu(req->DataLength); in mptsas_fix_scsi_io_endianness()
76 req->MsgContext = le32_to_cpu(req->MsgContext); in mptsas_fix_scsi_task_mgmt_endianness()
90 req->MsgContext = le32_to_cpu(req->MsgContext); in mptsas_fix_ioc_init_endianness()
97 req->MsgVersion = le16_to_cpu(req->MsgVersion); in mptsas_fix_ioc_init_endianness()
110 req->MsgContext = le32_to_cpu(req->MsgContext); in mptsas_fix_ioc_facts_endianness()
140 req->MsgContext = le32_to_cpu(req->MsgContext); in mptsas_fix_config_endianness()
155 req->MsgContext = le32_to_cpu(req->MsgContext); in mptsas_fix_port_facts_endianness()
173 req->MsgContext = le32_to_cpu(req->MsgContext); in mptsas_fix_port_enable_endianness()
[all …]
|
| H A D | mptsas.c | 268 g_free(req); in mptsas_free_request()
312 req->dev = s; in mptsas_process_scsi_io_request()
430 status = mptsas_scsi_device_find(s, req->Bus, req->TargetID, in mptsas_process_scsi_task_mgmt()
477 status = mptsas_scsi_device_find(s, req->Bus, req->TargetID, in mptsas_process_scsi_task_mgmt()
515 status = mptsas_scsi_device_find(s, req->Bus, req->TargetID, in mptsas_process_scsi_task_mgmt()
573 s->max_devices = req->MaxDevices ? req->MaxDevices : 256; in mptsas_process_ioc_init()
715 trace_mptsas_process_message(s, req->Function, req->MsgContext); in mptsas_process_message()
1137 return &req->qsg; in mptsas_get_sg_list()
1188 mptsas_turbo_reply(req->dev, req->scsi_io.MsgContext); in mptsas_command_complete()
1257 req->dev = s; in mptsas_load_request()
[all …]
|
| H A D | scsi-disk.c | 430 r->req.residual -= r->req.sg->size; in scsi_do_read()
591 r->req.residual -= r->req.sg->size; in scsi_write_data()
1432 SCSIRequest *req = &r->req; in scsi_disk_emulate_start_stop() local
1859 SCSIRequest *req = &r->req; in scsi_disk_emulate_write_same() local
2785 SCSIDiskReq *r = &req->req; in scsi_block_sgio_complete()
2812 req->cb(req->cb_opaque, ret); in scsi_block_sgio_complete()
2821 SCSIDiskReq *r = &req->req; in scsi_block_do_sgio()
2861 req->cdb[1] = req->cdb1; in scsi_block_do_sgio()
2863 req->cdb[6] = req->group_number; in scsi_block_do_sgio()
2870 req->cdb[1] = req->cdb1; in scsi_block_do_sgio()
[all …]
|
| H A D | scsi-generic.c | 37 SCSIRequest req; member
46 SCSIGenericReq *r = DO_UPCAST(SCSIGenericReq, req, req); in scsi_generic_save_request()
57 SCSIGenericReq *r = DO_UPCAST(SCSIGenericReq, req, req); in scsi_generic_load_request()
68 SCSIGenericReq *r = DO_UPCAST(SCSIGenericReq, req, req); in scsi_free_request()
114 r->req.aiocb = NULL; in scsi_command_complete()
137 trace_scsi_generic_aio_sgio_command(r->req.tag, r->req.cmd.buf[0], in execute_command()
358 SCSIGenericReq *r = DO_UPCAST(SCSIGenericReq, req, req); in scsi_read_data()
393 if (r->req.cmd.buf[0] == MODE_SELECT && r->req.cmd.buf[4] == 12 && in scsi_write_complete()
406 SCSIGenericReq *r = DO_UPCAST(SCSIGenericReq, req, req); in scsi_write_data()
428 SCSIGenericReq *r = DO_UPCAST(SCSIGenericReq, req, req); in scsi_get_buf()
[all …]
|
| /qemu/hw/usb/ |
| H A D | dev-uas.c | 505 usb_packet_copy(req->data, scsi_req_get_buf(req->req) + req->buf_off, in usb_uas_copy_data()
513 if (req->buf_size && req->buf_off == req->buf_size) { in usb_uas_copy_data()
516 scsi_req_continue(req->req); in usb_uas_copy_data()
555 req->dev = usb_uas_get_dev(req->uas, req->lun); in usb_uas_alloc_request()
611 scsi_req_unref(req->req); in usb_uas_scsi_command_complete()
619 scsi_req_unref(req->req); in usb_uas_scsi_request_cancelled()
643 scsi_req_cancel(req->req); in usb_uas_handle_reset()
731 req->req = scsi_req_new(req->dev, req->tag, in usb_uas_command()
735 scsi_req_print(req->req); in usb_uas_command()
895 scsi_req_ref(req->req); in usb_uas_handle_data()
[all …]
|
| /qemu/hw/ufs/ |
| H A D | ufs.c | 98 ret = ufs_addr_read(u, utrd_addr, &req->utrd, sizeof(req->utrd)); in ufs_dma_read_utrd()
204 ret = ufs_addr_write(u, utrd_addr, &req->utrd, sizeof(req->utrd)); in ufs_dma_write_utrd()
265 UfsRequest *req; in ufs_process_db() local
926 req->rsp_upiu.qr.opcode = req->req_upiu.qr.opcode; in ufs_read_desc()
927 req->rsp_upiu.qr.idn = req->req_upiu.qr.idn; in ufs_read_desc()
928 req->rsp_upiu.qr.index = req->req_upiu.qr.index; in ufs_read_desc()
929 req->rsp_upiu.qr.selector = req->req_upiu.qr.selector; in ufs_read_desc()
998 trace_ufs_exec_query_cmd(req->slot, req->req_upiu.qr.opcode); in ufs_exec_query_cmd()
1095 memset(&req->utrd, 0, sizeof(req->utrd)); in ufs_clear_req()
1096 memset(&req->req_upiu, 0, sizeof(req->req_upiu)); in ufs_clear_req()
[all …]
|
| H A D | lu.c | 64 UfsRequest *req = scsi_req->hba_private; in ufs_scsi_command_complete() local
72 ufs_complete_req(req, UFS_REQUEST_SUCCESS); in ufs_scsi_command_complete()
80 UfsRequest *req = scsi_req->hba_private; in ufs_get_sg_list() local
81 return req->sg; in ufs_get_sg_list()
97 UfsHc *u = req->hc; in ufs_emulate_report_luns()
101 if (req->req_upiu.sc.cdb[2] != 0) { in ufs_emulate_report_luns()
169 if (req->req_upiu.sc.cdb[1] & 0x1) { in ufs_emulate_wlun_inquiry()
175 if (req->req_upiu.sc.cdb[2] != 0) { in ufs_emulate_wlun_inquiry()
202 switch (req->req_upiu.sc.cdb[0]) { in ufs_emulate_scsi_cmd()
239 len = MIN(len, (int)req->data_len); in ufs_emulate_scsi_cmd()
[all …]
|
| /qemu/tests/qtest/ |
| H A D | virtio-blk-test.c | 65 req->type = bswap32(req->type); in virtio_blk_fix_request()
66 req->ioprio = bswap32(req->ioprio); in virtio_blk_fix_request()
67 req->sector = bswap64(req->sector); in virtio_blk_fix_request()
143 req.ioprio = 1; in test_basic()
144 req.sector = 0; in test_basic()
167 req.ioprio = 1; in test_basic()
168 req.sector = 0; in test_basic()
378 req.ioprio = 1; in indirect()
379 req.sector = 0; in indirect()
403 req.ioprio = 1; in indirect()
[all …]
|
| H A D | vhost-user-blk-test.c | 49 req->type = bswap32(req->type); in virtio_blk_fix_request()
50 req->ioprio = bswap32(req->ioprio); in virtio_blk_fix_request()
51 req->sector = bswap64(req->sector); in virtio_blk_fix_request()
111 req.type = type; in test_invalid_discard_write_zeroes()
140 req.type = type; in test_invalid_discard_write_zeroes()
165 req.type = type; in test_invalid_discard_write_zeroes()
190 req.type = type; in test_invalid_discard_write_zeroes()
245 req.ioprio = 1; in test_basic()
246 req.sector = 0; in test_basic()
269 req.ioprio = 1; in test_basic()
[all …]
|
| /qemu/hw/block/ |
| H A D | virtio-blk.c | 45 req->dev = s; in virtio_blk_init_request()
46 req->vq = vq; in virtio_blk_init_request()
55 g_free(req); in virtio_blk_free_request()
68 virtqueue_push(req->vq, &req->elem, req->in_len); in virtio_blk_req_complete()
185 VirtIOBlockReq *req = ioctl_req->req; in virtio_blk_ioctl_complete() local
283 ioctl_req->req = req; in virtio_blk_handle_scsi_req()
659 VirtIOBlockReq *req = data->req; in virtio_blk_zone_report_complete() local
788 data->req = req; in virtio_blk_handle_zone_report()
865 VirtIOBlockReq *req = data->req; in virtio_blk_zone_append_complete() local
912 data->req = req; in virtio_blk_handle_zone_append()
[all …]
|
| /qemu/tests/unit/ |
| H A D | crypto-tls-x509-helpers.c | 232 if (req->country) { in test_tls_generate_cert()
235 req->country, strlen(req->country)); in test_tls_generate_cert()
242 if (req->cn) { in test_tls_generate_cert()
245 req->cn, strlen(req->cn)); in test_tls_generate_cert()
257 if (req->altname1) { in test_tls_generate_cert()
269 if (req->altname2) { in test_tls_generate_cert()
287 if (req->ipaddr1) { in test_tls_generate_cert()
303 if (req->ipaddr2) { in test_tls_generate_cert()
464 req->crt = crt; in test_tls_generate_cert()
504 if (!req->crt) { in test_tls_discard_cert()
[all …]
|
| /qemu/backends/ |
| H A D | rng.c | 24 RngRequest *req; in rng_backend_request_entropy() local
27 req = g_malloc(sizeof(*req)); in rng_backend_request_entropy()
29 req->offset = 0; in rng_backend_request_entropy()
30 req->size = size; in rng_backend_request_entropy()
32 req->opaque = opaque; in rng_backend_request_entropy()
33 req->data = g_malloc(req->size); in rng_backend_request_entropy()
35 k->request_entropy(s, req); in rng_backend_request_entropy()
67 g_free(req->data); in rng_backend_free_request()
68 g_free(req); in rng_backend_free_request()
73 RngRequest *req, *next; in rng_backend_free_requests() local
[all …]
|
| H A D | rng-egd.c | 34 size_t size = req->size; in rng_egd_request_entropy()
55 RngRequest *req; in rng_egd_chr_can_read() local
58 QSIMPLEQ_FOREACH(req, &s->parent.requests, next) { in rng_egd_chr_can_read()
59 size += req->size - req->offset; in rng_egd_chr_can_read()
71 RngRequest *req = QSIMPLEQ_FIRST(&s->parent.requests); in rng_egd_chr_read() local
72 int len = MIN(size, req->size - req->offset); in rng_egd_chr_read()
74 memcpy(req->data + req->offset, buf + buf_offset, len); in rng_egd_chr_read()
76 req->offset += len; in rng_egd_chr_read()
79 if (req->offset == req->size) { in rng_egd_chr_read()
80 req->receive_entropy(req->opaque, req->data, req->size); in rng_egd_chr_read()
[all …]
|
| /qemu/block/export/ |
| H A D | fuse.c | 400 fuse_reply_err(req, ENOENT); in fuse_lookup()
561 fuse_getattr(req, inode, fi); in fuse_setattr()
570 fuse_reply_open(req, fi); in fuse_open()
586 fuse_reply_err(req, EINVAL); in fuse_read()
606 fuse_reply_err(req, ENOMEM); in fuse_read()
614 fuse_reply_err(req, -ret); in fuse_read()
632 fuse_reply_err(req, EINVAL); in fuse_write()
637 fuse_reply_err(req, EACCES); in fuse_write()
665 fuse_reply_write(req, size); in fuse_write()
667 fuse_reply_err(req, -ret); in fuse_write()
[all …]
|
| /qemu/contrib/vhost-user-blk/ |
| H A D | vhost-user-blk.c | 105 vu_queue_push(vu_dev, req->vq, req->elem, in vub_req_complete()
109 g_free(req->elem); in vub_req_complete()
110 g_free(req); in vub_req_complete()
147 vdev_blk->blk_name, req->sector_num, req->size, in vub_readv()
170 vdev_blk->blk_name, req->sector_num, req->size, in vub_writev()
217 vub_flush(VubReq *req) in vub_flush() argument
233 VubReq *req; in vub_virtio_process_req() local
249 req->vq = vq; in vub_virtio_process_req()
250 req->elem = elem; in vub_virtio_process_req()
276 req->sector_num = le64toh(req->out->sector); in vub_virtio_process_req()
[all …]
|
| /qemu/include/hw/scsi/ |
| H A D | scsi.h | 116 void (*init_req)(SCSIRequest *req);
117 void (*free_req)(SCSIRequest *req);
119 void (*read_data)(SCSIRequest *req);
120 void (*write_data)(SCSIRequest *req);
121 uint8_t *(*get_buf)(SCSIRequest *req);
133 void (*fail)(SCSIRequest *req);
135 void (*cancel)(SCSIRequest *req);
213 void scsi_req_unref(SCSIRequest *req);
220 void scsi_req_print(SCSIRequest *req);
228 void scsi_req_cancel(SCSIRequest *req);
[all …]
|
| /qemu/hw/nvme/ |
| H A D | ctrl.c | 2223 NvmeRequest *req = ctx->req; in nvme_verify_cb() local
2278 NvmeRequest *req = ctx->req; in nvme_verify_mdata_in_cb() local
2510 NvmeRequest *req = iocb->req; in nvme_dsm_md_cb() local
2551 NvmeRequest *req = iocb->req; in nvme_dsm_cb() local
2612 iocb->req = req; in nvme_dsm()
2680 ctx->req = req; in nvme_verify()
2738 NvmeRequest *req = iocb->req; in nvme_copy_done() local
3185 iocb->req = req; in nvme_copy()
3368 iocb->req = req; in nvme_flush()
4082 iocb->req = req; in nvme_zone_mgmt_send()
[all …]
|
| /qemu/hw/block/dataplane/ |
| H A D | xen-block.c | 35 blkif_request_t req; member
74 memset(&request->req, 0, sizeof(request->req)); in reset_request()
155 switch (request->req.operation) { in xen_block_parse_request()
185 if (request->req.seg[i].first_sect > request->req.seg[i].last_sect) { in xen_block_parse_request()
358 if (request->req.nr_segments && in xen_block_do_aio()
398 struct blkif_request_discard *req = (void *)&request->req; in xen_block_do_aio() local
448 resp->id = request->req.id; in xen_block_send_response()
480 blkif_request_t *req = in xen_block_get_request() local
483 memcpy(&request->req, req, sizeof(request->req)); in xen_block_get_request()
490 blkif_get_x86_32_req(&request->req, req); in xen_block_get_request()
[all …]
|
| /qemu/block/ |
| H A D | reqlist.c | 20 void reqlist_init_req(BlockReqList *reqs, BlockReq *req, int64_t offset, in reqlist_init_req() argument
25 *req = (BlockReq) { in reqlist_init_req()
29 qemu_co_queue_init(&req->wait_queue); in reqlist_init_req()
30 QLIST_INSERT_HEAD(reqs, req, list); in reqlist_init_req()
71 if (new_bytes == req->bytes) { in reqlist_shrink_req()
75 assert(new_bytes > 0 && new_bytes < req->bytes); in reqlist_shrink_req()
77 req->bytes = new_bytes; in reqlist_shrink_req()
78 qemu_co_queue_restart_all(&req->wait_queue); in reqlist_shrink_req()
81 void coroutine_fn reqlist_remove_req(BlockReq *req) in reqlist_remove_req() argument
83 QLIST_REMOVE(req, list); in reqlist_remove_req()
[all …]
|