| /qemu/tests/qtest/libqos/ |
| H A D | virtio-9p-client.c | 85 void v9fs_memwrite(P9Req *req, const void *addr, size_t len) in v9fs_memwrite() argument
87 qtest_memwrite(req->qts, req->t_msg + req->t_off, addr, len); in v9fs_memwrite()
88 req->t_off += len; in v9fs_memwrite()
91 void v9fs_memskip(P9Req *req, size_t len) in v9fs_memskip() argument
93 req->r_off += len; in v9fs_memskip()
96 void v9fs_memread(P9Req *req, void *addr, size_t len) in v9fs_memread() argument
98 qtest_memread(req->qts, req->r_msg + req->r_off, addr, len); in v9fs_memread()
99 req->r_off += len; in v9fs_memread()
102 void v9fs_uint8_read(P9Req *req, uint8_t *val) in v9fs_uint8_read() argument
104 v9fs_memread(req, val, 1); in v9fs_uint8_read()
[all …]
|
| H A D | virtio-9p-client.h | 117 P9Req *req; member
139 P9Req *req; member
166 P9Req *req; member
192 P9Req *req; member
214 P9Req *req; member
244 P9Req *req; member
271 P9Req *req; member
297 P9Req *req; member
319 P9Req *req; member
352 P9Req *req; member
[all …]
|
| /qemu/hw/xen/ |
| H A D | xen-hvm-common.c | 190 ioreq_t *req = xen_vcpu_ioreq(state->shared_page, vcpu); in cpu_get_ioreq_from_shared_memory() local
192 if (req->state != STATE_IOREQ_READY) { in cpu_get_ioreq_from_shared_memory()
193 trace_cpu_get_ioreq_from_shared_memory_req_not_ready(req->state, in cpu_get_ioreq_from_shared_memory()
194 req->data_is_ptr, in cpu_get_ioreq_from_shared_memory()
195 req->addr, in cpu_get_ioreq_from_shared_memory()
196 req->data, in cpu_get_ioreq_from_shared_memory()
197 req->count, in cpu_get_ioreq_from_shared_memory()
198 req->size); in cpu_get_ioreq_from_shared_memory()
204 req->state = STATE_IOREQ_INPROCESS; in cpu_get_ioreq_from_shared_memory()
205 return req; in cpu_get_ioreq_from_shared_memory()
[all …]
|
| /qemu/hw/scsi/ |
| H A D | scsi-bus.c | 22 static void scsi_req_dequeue(SCSIRequest *req);
23 static uint8_t *scsi_target_alloc_buf(SCSIRequest *req, size_t len);
24 static void scsi_target_free_buf(SCSIRequest *req);
25 static void scsi_clear_reported_luns_changed(SCSIRequest *req);
97 SCSIRequest *req; in scsi_device_for_each_req_sync() local
109 QTAILQ_FOREACH_SAFE(req, &s->requests, next, next_req) { in scsi_device_for_each_req_sync()
110 fn(req, opaque); in scsi_device_for_each_req_sync()
133 SCSIRequest *req; in scsi_device_for_each_req_async_bh() local
136 QTAILQ_FOREACH_SAFE(req, &s->requests, next, next) { in scsi_device_for_each_req_async_bh()
137 if (req->ctx == ctx) { in scsi_device_for_each_req_async_bh()
[all …]
|
| H A D | spapr_vscsi.c | 101 static union viosrp_iu *req_iu(vscsi_req *req) in req_iu() argument
103 return (union viosrp_iu *)req->viosrp_iu_buf; in req_iu()
108 vscsi_req *req; in vscsi_get_req() local
112 req = &s->reqs[i]; in vscsi_get_req()
113 if (!req->active) { in vscsi_get_req()
114 memset(req, 0, sizeof(*req)); in vscsi_get_req()
115 req->qtag = i; in vscsi_get_req()
116 req->active = 1; in vscsi_get_req()
117 return req; in vscsi_get_req()
125 vscsi_req *req; in vscsi_find_req() local
[all …]
|
| H A D | virtio-scsi.c | 67 } req; member
86 static void virtio_scsi_init_req(VirtIOSCSI *s, VirtQueue *vq, VirtIOSCSIReq *req) in virtio_scsi_init_req() argument
90 offsetof(VirtIOSCSIReq, resp_iov) + sizeof(req->resp_iov); in virtio_scsi_init_req()
92 req->vq = vq; in virtio_scsi_init_req()
93 req->dev = s; in virtio_scsi_init_req()
94 qemu_sglist_init(&req->qsgl, DEVICE(s), 8, vdev->dma_as); in virtio_scsi_init_req()
95 qemu_iovec_init(&req->resp_iov, 1); in virtio_scsi_init_req()
96 memset((uint8_t *)req + zero_skip, 0, sizeof(*req) - zero_skip); in virtio_scsi_init_req()
99 static void virtio_scsi_free_req(VirtIOSCSIReq *req) in virtio_scsi_free_req() argument
101 qemu_iovec_destroy(&req->resp_iov); in virtio_scsi_free_req()
[all …]
|
| H A D | mptendian.c | 55 void mptsas_fix_scsi_io_endianness(MPIMsgSCSIIORequest *req) in mptsas_fix_scsi_io_endianness() argument
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()
60 req->SenseBufferLowAddr = le32_to_cpu(req->SenseBufferLowAddr); in mptsas_fix_scsi_io_endianness()
74 void mptsas_fix_scsi_task_mgmt_endianness(MPIMsgSCSITaskMgmt *req) in mptsas_fix_scsi_task_mgmt_endianness() argument
76 req->MsgContext = le32_to_cpu(req->MsgContext); in mptsas_fix_scsi_task_mgmt_endianness()
77 req->TaskMsgContext = le32_to_cpu(req->TaskMsgContext); in mptsas_fix_scsi_task_mgmt_endianness()
88 void mptsas_fix_ioc_init_endianness(MPIMsgIOCInit *req) in mptsas_fix_ioc_init_endianness() argument
90 req->MsgContext = le32_to_cpu(req->MsgContext); in mptsas_fix_ioc_init_endianness()
[all …]
|
| H A D | mptsas.c | 195 static int mptsas_build_sgl(MPTSASState *s, MPTSASRequest *req, hwaddr req_addr) in mptsas_build_sgl() argument
203 chain_offset = req->scsi_io.ChainOffset; in mptsas_build_sgl()
206 pci_dma_sglist_init(&req->qsg, pci, 4); in mptsas_build_sgl()
207 left = req->scsi_io.DataLength; in mptsas_build_sgl()
232 qemu_sglist_add(&req->qsg, addr, len); in mptsas_build_sgl()
260 static void mptsas_free_request(MPTSASRequest *req) in mptsas_free_request() argument
262 if (req->sreq != NULL) { in mptsas_free_request()
263 req->sreq->hba_private = NULL; in mptsas_free_request()
264 scsi_req_unref(req->sreq); in mptsas_free_request()
265 req->sreq = NULL; in mptsas_free_request()
[all …]
|
| H A D | scsi-disk.c | 82 SCSIRequest req; member
127 static void scsi_free_request(SCSIRequest *req) in scsi_free_request() argument
129 SCSIDiskReq *r = DO_UPCAST(SCSIDiskReq, req, req); in scsi_free_request()
137 trace_scsi_disk_check_condition(r->req.tag, sense.key, sense.asc, in scsi_check_condition()
139 scsi_req_build_sense(&r->req, sense); in scsi_check_condition()
140 scsi_req_complete(&r->req, CHECK_CONDITION); in scsi_check_condition()
145 SCSIDiskState *s = DO_UPCAST(SCSIDiskState, qdev, r->req.dev); in scsi_init_iovec()
155 static void scsi_disk_save_request(QEMUFile *f, SCSIRequest *req) in scsi_disk_save_request() argument
157 SCSIDiskReq *r = DO_UPCAST(SCSIDiskReq, req, req); in scsi_disk_save_request()
163 if (r->req.cmd.mode == SCSI_XFER_TO_DEV) { in scsi_disk_save_request()
[all …]
|
| H A D | scsi-generic.c | 37 SCSIRequest req; member
44 static void scsi_generic_save_request(QEMUFile *f, SCSIRequest *req) in scsi_generic_save_request() argument
46 SCSIGenericReq *r = DO_UPCAST(SCSIGenericReq, req, req); in scsi_generic_save_request()
49 if (r->buflen && r->req.cmd.mode == SCSI_XFER_TO_DEV) { in scsi_generic_save_request()
50 assert(!r->req.sg); in scsi_generic_save_request()
51 qemu_put_buffer(f, r->buf, r->req.cmd.xfer); in scsi_generic_save_request()
55 static void scsi_generic_load_request(QEMUFile *f, SCSIRequest *req) in scsi_generic_load_request() argument
57 SCSIGenericReq *r = DO_UPCAST(SCSIGenericReq, req, req); in scsi_generic_load_request()
60 if (r->buflen && r->req.cmd.mode == SCSI_XFER_TO_DEV) { in scsi_generic_load_request()
61 assert(!r->req.sg); in scsi_generic_load_request()
[all …]
|
| /qemu/hw/usb/ |
| H A D | dev-uas.c | 144 SCSIRequest *req; member
414 static void usb_uas_queue_sense(UASRequest *req, uint8_t status) in usb_uas_queue_sense() argument
416 UASStatus *st = usb_uas_alloc_status(req->uas, UAS_UI_SENSE, req->tag); in usb_uas_queue_sense()
419 trace_usb_uas_sense(req->uas->dev.addr, req->tag, status); in usb_uas_queue_sense()
423 slen = scsi_req_get_sense(req->req, st->status.sense.sense_data, in usb_uas_queue_sense()
428 usb_uas_queue_status(req->uas, st, len); in usb_uas_queue_sense()
449 static void usb_uas_queue_read_ready(UASRequest *req) in usb_uas_queue_read_ready() argument
451 UASStatus *st = usb_uas_alloc_status(req->uas, UAS_UI_READ_READY, in usb_uas_queue_read_ready()
452 req->tag); in usb_uas_queue_read_ready()
454 trace_usb_uas_read_ready(req->uas->dev.addr, req->tag); in usb_uas_queue_read_ready()
[all …]
|
| /qemu/hw/ufs/ |
| H A D | ufs.c | 43 static void ufs_exec_req(UfsRequest *req);
44 static void ufs_clear_req(UfsRequest *req);
146 static MemTxResult ufs_dma_read_utrd(UfsRequest *req) in ufs_dma_read_utrd() argument
148 UfsHc *u = req->hc; in ufs_dma_read_utrd()
149 hwaddr utrd_addr = ufs_get_utrd_addr(u, req->slot); in ufs_dma_read_utrd()
152 ret = ufs_addr_read(u, utrd_addr, &req->utrd, sizeof(req->utrd)); in ufs_dma_read_utrd()
154 trace_ufs_err_dma_read_utrd(req->slot, utrd_addr); in ufs_dma_read_utrd()
159 static MemTxResult ufs_dma_read_req_upiu(UfsRequest *req) in ufs_dma_read_req_upiu() argument
161 UfsHc *u = req->hc; in ufs_dma_read_req_upiu()
162 hwaddr req_upiu_base_addr = ufs_get_req_upiu_base_addr(&req->utrd); in ufs_dma_read_req_upiu()
[all …]
|
| H A D | lu.c | 24 static void ufs_build_upiu_sense_data(UfsRequest *req, uint8_t *sense, in ufs_build_upiu_sense_data() argument
27 req->rsp_upiu.sr.sense_data_len = cpu_to_be16(sense_len); in ufs_build_upiu_sense_data()
29 memcpy(req->rsp_upiu.sr.sense_data, sense, sense_len); in ufs_build_upiu_sense_data()
32 static void ufs_build_scsi_response_upiu(UfsRequest *req, uint8_t *sense, in ufs_build_scsi_response_upiu() argument
37 uint32_t expected_len = be32_to_cpu(req->req_upiu.sc.exp_data_transfer_len); in ufs_build_scsi_response_upiu()
42 req->rsp_upiu.sr.residual_transfer_count = in ufs_build_scsi_response_upiu()
46 req->rsp_upiu.sr.residual_transfer_count = in ufs_build_scsi_response_upiu()
52 ufs_build_upiu_sense_data(req, sense, sense_len); in ufs_build_scsi_response_upiu()
57 cpu_to_be16(sense_len + sizeof(req->rsp_upiu.sr.sense_data_len)); in ufs_build_scsi_response_upiu()
58 ufs_build_upiu_header(req, UFS_UPIU_TRANSACTION_RESPONSE, flags, response, in ufs_build_scsi_response_upiu()
[all …]
|
| /qemu/hw/block/ |
| H A D | virtio-blk.c | 44 VirtIOBlockReq *req) in virtio_blk_init_request() argument
46 req->dev = s; in virtio_blk_init_request()
47 req->vq = vq; in virtio_blk_init_request()
48 req->qiov.size = 0; in virtio_blk_init_request()
49 req->in_len = 0; in virtio_blk_init_request()
50 req->next = NULL; in virtio_blk_init_request()
51 req->mr_next = NULL; in virtio_blk_init_request()
54 void virtio_blk_req_complete(VirtIOBlockReq *req, unsigned char status) in virtio_blk_req_complete() argument
56 VirtIOBlock *s = req->dev; in virtio_blk_req_complete()
59 trace_virtio_blk_req_complete(vdev, req, status); in virtio_blk_req_complete()
[all …]
|
| /qemu/tests/qtest/ |
| H A D | virtio-blk-test.c | 62 static inline void virtio_blk_fix_request(QVirtioDevice *d, QVirtioBlkReq *req) in virtio_blk_fix_request() argument
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()
83 QVirtioBlkReq *req, uint64_t data_size) in virtio_blk_request() argument
88 switch (req->type) { in virtio_blk_request()
102 addr = guest_alloc(alloc, sizeof(*req) + data_size); in virtio_blk_request()
104 virtio_blk_fix_request(d, req); in virtio_blk_request()
106 memwrite(addr, req, 16); in virtio_blk_request()
107 memwrite(addr + 16, req->data, data_size); in virtio_blk_request()
[all …]
|
| H A D | vhost-user-blk-test.c | 46 static inline void virtio_blk_fix_request(QVirtioDevice *d, QVirtioBlkReq *req) in virtio_blk_fix_request() argument
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()
66 QVirtioBlkReq *req, uint64_t data_size) in virtio_blk_request() argument
72 switch (req->type) { in virtio_blk_request()
86 addr = guest_alloc(alloc, sizeof(*req) + data_size); in virtio_blk_request()
88 virtio_blk_fix_request(d, req); in virtio_blk_request()
90 qtest_memwrite(qts, addr, req, 16); in virtio_blk_request()
91 qtest_memwrite(qts, addr + 16, req->data, data_size); in virtio_blk_request()
[all …]
|
| /qemu/tests/unit/ |
| H A D | crypto-tls-x509-helpers.c | 203 test_tls_generate_cert(QCryptoTLSTestCertReq *req, in test_tls_generate_cert() argument
212 time_t start = time(NULL) + (60 * 60 * req->start_offset); in test_tls_generate_cert()
213 time_t expire = time(NULL) + (60 * 60 * (req->expire_offset in test_tls_generate_cert()
214 ? req->expire_offset : 24)); in test_tls_generate_cert()
237 if (req->country) { in test_tls_generate_cert()
240 req->country, strlen(req->country)); in test_tls_generate_cert()
247 if (req->cn) { in test_tls_generate_cert()
250 req->cn, strlen(req->cn)); in test_tls_generate_cert()
262 if (req->altname1) { in test_tls_generate_cert()
265 req->altname1, in test_tls_generate_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()
31 req->receive_entropy = receive_entropy; 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()
37 QSIMPLEQ_INSERT_TAIL(&s->requests, req, next); in rng_backend_request_entropy()
65 static void rng_backend_free_request(RngRequest *req) in rng_backend_free_request() argument
[all …]
|
| H A D | rng-egd.c | 31 static void rng_egd_request_entropy(RngBackend *b, RngRequest *req) in rng_egd_request_entropy() argument
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()
[all …]
|
| /qemu/hw/sd/ |
| H A D | sd.c | 107 typedef sd_rsp_type_t (*sd_cmd_handler)(SDState *sd, SDRequest req);
627 static uint16_t sd_req_get_rca(SDState *s, SDRequest req) in sd_req_get_rca() argument
629 switch (s->proto->cmd[req.cmd].type) { in sd_req_get_rca()
632 return req.arg >> 16; in sd_req_get_rca()
639 static bool sd_req_rca_same(SDState *s, SDRequest req) in sd_req_rca_same() argument
641 return sd_req_get_rca(s, req) == s->rca; in sd_req_rca_same()
723 static int sd_req_crc_validate(SDRequest *req) in sd_req_crc_validate() argument
726 buffer[0] = 0x40 | req->cmd; in sd_req_crc_validate()
727 stl_be_p(&buffer[1], req->arg); in sd_req_crc_validate()
729 return sd_crc7(buffer, 5) != req->crc; /* TODO */ in sd_req_crc_validate()
[all …]
|
| /qemu/block/export/ |
| H A D | fuse.c | 398 static void fuse_lookup(fuse_req_t req, fuse_ino_t parent, const char *name) in fuse_lookup() argument
400 fuse_reply_err(req, ENOENT); in fuse_lookup()
406 static void fuse_getattr(fuse_req_t req, fuse_ino_t inode, in fuse_getattr() argument
412 FuseExport *exp = fuse_req_userdata(req); in fuse_getattr()
416 fuse_reply_err(req, -length); in fuse_getattr()
441 fuse_reply_attr(req, &statbuf, 1.); in fuse_getattr()
496 static void fuse_setattr(fuse_req_t req, fuse_ino_t inode, struct stat *statbuf, in fuse_setattr() argument
499 FuseExport *exp = fuse_req_userdata(req); in fuse_setattr()
509 fuse_reply_err(req, ENOTSUP); in fuse_setattr()
522 fuse_reply_err(req, EPERM); in fuse_setattr()
[all …]
|
| /qemu/contrib/vhost-user-blk/ |
| H A D | vhost-user-blk.c | 100 static void vub_req_complete(VubReq *req) in vub_req_complete() argument
102 VugDev *gdev = &req->vdev_blk->parent; in vub_req_complete()
106 vu_queue_push(vu_dev, req->vq, req->elem, in vub_req_complete()
107 req->size + 1); in vub_req_complete()
108 vu_queue_notify(vu_dev, req->vq); in vub_req_complete()
110 g_free(req->elem); in vub_req_complete()
111 g_free(req); in vub_req_complete()
134 vub_readv(VubReq *req, struct iovec *iov, uint32_t iovcnt) in vub_readv() argument
136 VubDev *vdev_blk = req->vdev_blk; in vub_readv()
144 req->size = vub_iov_size(iov, iovcnt); in vub_readv()
[all …]
|
| /qemu/include/hw/scsi/ |
| H A D | scsi.h | 116 void (*init_req)(SCSIRequest *req);
117 void (*free_req)(SCSIRequest *req);
118 int32_t (*send_command)(SCSIRequest *req, uint8_t *buf);
119 void (*read_data)(SCSIRequest *req);
120 void (*write_data)(SCSIRequest *req);
121 uint8_t *(*get_buf)(SCSIRequest *req);
123 void (*save_request)(QEMUFile *f, SCSIRequest *req);
124 void (*load_request)(QEMUFile *f, SCSIRequest *req);
132 void (*transfer_data)(SCSIRequest *req, uint32_t arg);
133 void (*fail)(SCSIRequest *req);
[all …]
|
| /qemu/hw/nvme/ |
| H A D | ctrl.c | 321 static uint16_t nvme_sqid(NvmeRequest *req) in nvme_sqid() argument
323 return le16_to_cpu(req->sq->sqid); in nvme_sqid()
706 static void nvme_req_clear(NvmeRequest *req) in nvme_req_clear() argument
708 req->ns = NULL; in nvme_req_clear()
709 req->opaque = NULL; in nvme_req_clear()
710 req->aiocb = NULL; in nvme_req_clear()
711 memset(&req->cqe, 0x0, sizeof(req->cqe)); in nvme_req_clear()
712 req->status = NVME_SUCCESS; in nvme_req_clear()
1234 static uint16_t nvme_map_data(NvmeCtrl *n, uint32_t nlb, NvmeRequest *req) in nvme_map_data() argument
1236 NvmeNamespace *ns = req->ns; in nvme_map_data()
[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()
160 if (!request->req.nr_segments) { in xen_block_parse_request()
169 error_report("error: unknown operation (%d)", request->req.operation); in xen_block_parse_request()
173 if (request->req.operation != BLKIF_OP_READ && in xen_block_parse_request()
179 request->start = request->req.sector_number * dataplane->sector_size; in xen_block_parse_request()
180 for (i = 0; i < request->req.nr_segments; i++) { in xen_block_parse_request()
185 if (request->req.seg[i].first_sect > request->req.seg[i].last_sect) { in xen_block_parse_request()
189 if (request->req.seg[i].last_sect * dataplane->sector_size >= in xen_block_parse_request()
[all …]
|