/qemu/hw/remote/ |
H A D | mpqemu-link.c | 49 if (msg->num_fds) { in mpqemu_msg_send() 51 fds = msg->fds; in mpqemu_msg_send() 74 trace_mpqemu_send_io_error(msg->cmd, msg->size, nfds); in mpqemu_msg_send() 138 if (msg->size > sizeof(msg->data)) { in mpqemu_msg_recv() 143 if (!msg->size) { in mpqemu_msg_recv() 147 len = mpqemu_read(ioc, &msg->data, msg->size, NULL, NULL, errp); in mpqemu_msg_recv() 172 trace_mpqemu_recv_io_error(msg->cmd, msg->size, nfds); in mpqemu_msg_recv() 217 if (msg->cmd >= MPQEMU_CMD_MAX || msg->cmd < 0) { in mpqemu_msg_valid() 237 if (msg->num_fds == 0 || msg->size != sizeof(SyncSysmemMsg)) { in mpqemu_msg_valid() 249 if ((msg->size != sizeof(BarAccessMsg)) || (msg->num_fds != 0)) { in mpqemu_msg_valid() [all …]
|
H A D | message.c | 26 MPQemuMsg *msg, Error **errp); 42 MPQemuMsg msg = {0}; in mpqemu_remote_msg_loop_co() local 44 if (!mpqemu_msg_recv(&msg, com->ioc, &local_err)) { in mpqemu_remote_msg_loop_co() 48 if (!mpqemu_msg_valid(&msg)) { in mpqemu_remote_msg_loop_co() 55 switch (msg.cmd) { in mpqemu_remote_msg_loop_co() 63 process_bar_write(com->ioc, &msg, &local_err); in mpqemu_remote_msg_loop_co() 66 process_bar_read(com->ioc, &msg, &local_err); in mpqemu_remote_msg_loop_co() 69 remote_sysmem_reconfig(&msg, &local_err); in mpqemu_remote_msg_loop_co() 72 process_set_irqfd_msg(pci_dev, &msg); in mpqemu_remote_msg_loop_co() 144 BarAccessMsg *bar_access = &msg->data.bar_access; in process_bar_write() [all …]
|
H A D | proxy.c | 53 MPQemuMsg msg; in setup_irqfd() local 59 memset(&msg, 0, sizeof(MPQemuMsg)); in setup_irqfd() 60 msg.cmd = MPQEMU_CMD_SET_IRQFD; in setup_irqfd() 61 msg.num_fds = 2; in setup_irqfd() 64 msg.size = 0; in setup_irqfd() 147 MPQemuMsg msg = { 0 }; in config_op_send() local 151 msg.cmd = op; in config_op_send() 236 MPQemuMsg msg = { 0 }; in type_init() local 240 msg.size = sizeof(BarAccessMsg); in type_init() 371 MPQemuMsg msg = { 0 }; in proxy_device_reset() local [all …]
|
/qemu/python/qemu/qmp/ |
H A D | qmp_client.py | 116 self.msg: Message = msg 351 if 'event' in msg: 377 msg 404 return msg 433 if 'id' in msg: 491 elif 'id' in msg: 531 msg = Message(msg) 567 if not ('execute' in msg or 'exec-oob' in msg): 573 msg = Message(msg) 590 reply, msg, [all …]
|
H A D | qmp_tui.py | 66 def format_json(msg: str) -> str: 102 msg = json.loads(msg) 103 return str(json.dumps(msg)) 105 msg = msg.replace('\n', '') 106 words = msg.split(' ') 173 str_msg = str(msg) 178 return msg 189 str_msg = str(msg) 194 return msg 207 await self._raw(msg, assign_id='id' not in msg) [all …]
|
/qemu/hw/virtio/ |
H A D | vhost-user.c | 553 msg->hdr.size = sizeof(msg->payload.memory.nregions); in vhost_user_fill_set_mem_table_msg() 554 msg->hdr.size += sizeof(msg->payload.memory.padding); in vhost_user_fill_set_mem_table_msg() 838 msg->hdr.size = sizeof(msg->payload.mem_reg); in vhost_user_add_remove_regions() 869 msg->hdr.size = sizeof(msg->payload.u64); in vhost_user_add_remove_regions() 992 msg.hdr.size = sizeof(msg.payload.u64); in vhost_user_set_mem_table_postcopy() 1107 if (msg.hdr.size != sizeof(msg.payload.u64)) { in vhost_user_get_u64() 1301 if (msg.hdr.size != sizeof(msg.payload.state)) { in vhost_user_get_vring_base() 2348 msg.hdr.size = sizeof(msg.payload.u64); in vhost_user_migration_done() 2368 msg.hdr.size = sizeof(msg.payload.u64); in vhost_user_net_set_mtu() 2940 if (msg.hdr.size != sizeof(msg.payload.u64)) { in vhost_user_set_device_state_fd() [all …]
|
H A D | vhost-backend.c | 249 struct vhost_msg_v2 msg; in vhost_kernel_iotlb_read() local 251 while ((len = read((uintptr_t)dev->opaque, &msg, sizeof msg)) > 0) { in vhost_kernel_iotlb_read() 252 if (len < sizeof msg) { in vhost_kernel_iotlb_read() 264 struct vhost_msg msg; in vhost_kernel_iotlb_read() local 266 while ((len = read((uintptr_t)dev->opaque, &msg, sizeof msg)) > 0) { in vhost_kernel_iotlb_read() 267 if (len < sizeof msg) { in vhost_kernel_iotlb_read() 288 msg.iotlb = *imsg; in vhost_kernel_send_device_iotlb_msg() 290 if (write((uintptr_t)dev->opaque, &msg, sizeof msg) != sizeof msg) { in vhost_kernel_send_device_iotlb_msg() 295 struct vhost_msg msg = {}; in vhost_kernel_send_device_iotlb_msg() local 298 msg.iotlb = *imsg; in vhost_kernel_send_device_iotlb_msg() [all …]
|
/qemu/tests/qtest/ |
H A D | ipmi-bt-test.c | 228 uint8_t msg[100]; in emu_msg_handler() local 237 if ((msg[1] == get_dev_id_cmd[0]) && (msg[2] == get_dev_id_cmd[1])) { in emu_msg_handler() 240 msg[msg_len] = -ipmb_checksum(msg, msg_len, 0); in emu_msg_handler() 242 msg[msg_len++] = 0xa0; in emu_msg_handler() 249 msg[msg_len] = -ipmb_checksum(msg, msg_len, 0); in emu_msg_handler() 251 msg[msg_len++] = 0xa0; in emu_msg_handler() 312 uint8_t msg[100]; in test_connect() local 337 msglen = sizeof(msg); in test_connect() 338 get_emu_msg(msg, &msglen); in test_connect() 341 msglen = sizeof(msg); in test_connect() [all …]
|
H A D | vhost-user-test.c | 332 VhostUserMsg msg; in chr_read() local 350 if (msg.size) { in chr_read() 360 switch (msg.request) { in chr_read() 407 p = (uint8_t *) &msg; in chr_read() 426 msg.payload.state.index, msg.payload.state.num); in chr_read() 450 memcpy(&s->memory, &msg.payload.memory, sizeof(msg.payload.memory)); in chr_read() 478 msg.size = 0; in chr_read() 1046 VhostUserMsg *msg) in vu_net_get_protocol_features() argument 1056 qemu_chr_fe_write_all(chr, (uint8_t *)msg, VHOST_USER_HDR_SIZE + msg->size); in vu_net_get_protocol_features() 1135 qemu_chr_fe_write_all(chr, (uint8_t *)msg, VHOST_USER_HDR_SIZE + msg->size); in vu_gpio_get_protocol_features() [all …]
|
/qemu/ui/ |
H A D | input-barrier.c | 246 msg->cmd = cmd; in readcmd() 255 msg->set.nb /= 2; in readcmd() 263 msg->set.option[i].id = htonl(msg->set.option[i].id); in readcmd() 284 msg->mousepos.x = 0; in readcmd() 286 msg->mousepos.x = msg->mousepos.y; in readcmd() 354 switch (msg->cmd) { in writecmd() 435 input_barrier_to_qcode(msg->key.keyid, msg->key.button), in writecmd() 441 input_barrier_to_qcode(msg->repeat.keyid, msg->repeat.button), in writecmd() 444 input_barrier_to_qcode(msg->repeat.keyid, msg->repeat.button), in writecmd() 450 input_barrier_to_qcode(msg->key.keyid, msg->key.button), in writecmd() [all …]
|
H A D | vdagent.c | 208 vdagent_send_msg(vd, msg); in vdagent_send_caps() 338 uint8_t *s = msg->data; in vdagent_send_clipboard_grab() 402 uint8_t *s = msg->data; in vdagent_send_clipboard_data() 497 uint8_t *s = msg->data; in vdagent_clipboard_request() 626 void *data = msg->data; in vdagent_chr_recv_clipboard() 640 switch (msg->type) { in vdagent_chr_recv_clipboard() 732 trace_vdagent_recv_msg(GET_NAME(msg_name, msg->type), msg->size); in vdagent_chr_recv_msg() 734 switch (msg->type) { in vdagent_chr_recv_msg() 768 if (vd->msgsize == msg->size + sizeof(*msg)) { in vdagent_chr_recv_chunk() 775 vd->xsize = msg->size + sizeof(*msg); in vdagent_chr_recv_chunk() [all …]
|
/qemu/hw/hyperv/ |
H A D | hyperv.c | 593 len = sizeof(*msg); in hyperv_hcall_post_message() 599 if (msg->payload_size > sizeof(msg->payload)) { in hyperv_hcall_post_message() 725 HvSynDbgMsg msg; in hyperv_hcall_reset_dbg_session() local 772 HvSynDbgMsg msg; in hyperv_hcall_retreive_dbg_data() local 831 HvSynDbgMsg msg; in hyperv_hcall_post_dbg_data() local 885 HvSynDbgMsg msg; in hyperv_syndbg_send() local 905 HvSynDbgMsg msg; in hyperv_syndbg_recv() local 914 msg.u.recv.options = 0; in hyperv_syndbg_recv() 915 msg.u.recv.timeout = 0; in hyperv_syndbg_recv() 928 HvSynDbgMsg msg; in hyperv_syndbg_set_pending_page() local [all …]
|
H A D | vmbus.c | 1531 memcpy(&vmbus->rx_queue[idx], msg, sizeof(*msg)); in enqueue_incoming_message() 1692 post_msg(vmbus, &msg, sizeof(msg)); in send_handshake() 1741 post_msg(vmbus, &msg, sizeof(msg)); in send_offer() 1790 if (msglen < sizeof(*msg) + sizeof(msg->range[0]) || in handle_gpadl_header() 1795 num_gfns = (msg->range_buflen - msg->rangecount * sizeof(msg->range[0])) / in handle_gpadl_header() 1806 if (msg->rangecount != 1 || msg->range[0].byte_offset || in handle_gpadl_header() 1872 post_msg(vmbus, &msg, sizeof(msg)); in send_create_gpadl() 1929 post_msg(vmbus, &msg, sizeof(msg)); in send_teardown_gpadl() 1994 post_msg(vmbus, &msg, sizeof(msg)); in send_open_channel() 2078 post_msg(vmbus, &msg, sizeof(msg)); in send_unload() [all …]
|
H A D | syndbg.c | 252 switch (msg->type) { in hv_syndbg_handler() 254 msg->u.connection_info.host_ip = in hv_syndbg_handler() 256 msg->u.connection_info.host_port = in hv_syndbg_handler() 261 ret = handle_send_msg(syndbg, msg->u.send.buf_gpa, msg->u.send.count, in hv_syndbg_handler() 262 msg->u.send.is_raw, &msg->u.send.pending_count); in hv_syndbg_handler() 265 ret = handle_recv_msg(syndbg, msg->u.recv.buf_gpa, msg->u.recv.count, in hv_syndbg_handler() 266 msg->u.recv.is_raw, msg->u.recv.options, in hv_syndbg_handler() 267 msg->u.recv.timeout, in hv_syndbg_handler() 268 &msg->u.recv.retrieved_count); in hv_syndbg_handler() 271 syndbg->pending_page_gpa = msg->u.pending_page.buf_gpa; in hv_syndbg_handler() [all …]
|
/qemu/target/ppc/ |
H A D | trace-events | 4 kvm_failed_spr_set(int spr, const char *msg) "Warning: Unable to set SPR %d to KVM: %s" 6 kvm_failed_fpscr_set(const char *msg) "Unable to set FPSCR to KVM: %s" 8 kvm_failed_vscr_set(const char *msg) "Unable to set VSCR to KVM: %s" 9 kvm_failed_vr_set(int vr, const char *msg) "Unable to set VR%d to KVM: %s" 10 kvm_failed_fpscr_get(const char *msg) "Unable to get FPSCR from KVM: %s" 12 kvm_failed_vscr_get(const char *msg) "Unable to get VSCR from KVM: %s" 13 kvm_failed_vr_get(int vr, const char *msg) "Unable to get VR%d from KVM: %s" 14 kvm_failed_vpa_addr_get(const char *msg) "Unable to get VPA address from KVM: %s" 15 kvm_failed_slb_get(const char *msg) "Unable to get SLB shadow state from KVM: %s" 17 kvm_failed_vpa_addr_set(const char *msg) "Unable to set VPA address to KVM: %s" [all …]
|
/qemu/hw/i386/ |
H A D | x86-iommu.c | 59 X86IOMMU_MSIMessage msg = {}; in x86_iommu_irq_to_msi_message() local 62 msg.dest_mode = irq->dest_mode; in x86_iommu_irq_to_msi_message() 63 msg.redir_hint = irq->redir_hint; in x86_iommu_irq_to_msi_message() 64 msg.dest = irq->dest; in x86_iommu_irq_to_msi_message() 65 msg.__addr_hi = irq->dest & 0xffffff00; in x86_iommu_irq_to_msi_message() 66 msg.__addr_head = 0xfee; in x86_iommu_irq_to_msi_message() 71 msg.vector = irq->vector; in x86_iommu_irq_to_msi_message() 73 msg.level = 1; in x86_iommu_irq_to_msi_message() 74 msg.trigger_mode = irq->trigger_mode; in x86_iommu_irq_to_msi_message() 76 msg_out->address = msg.msi_addr; in x86_iommu_irq_to_msi_message() [all …]
|
/qemu/crypto/ |
H A D | cipher-afalg.c | 94 afalg->msg = g_new0(struct msghdr, 1); in qcrypto_afalg_cipher_ctx_new() 100 afalg->msg->msg_control = g_new0(uint8_t, afalg->msg->msg_controllen); in qcrypto_afalg_cipher_ctx_new() 103 afalg->cmsg = CMSG_FIRSTHDR(afalg->msg); in qcrypto_afalg_cipher_ctx_new() 111 afalg->cmsg = CMSG_FIRSTHDR(afalg->msg); in qcrypto_afalg_cipher_ctx_new() 156 origin_controllen = afalg->msg->msg_controllen; in qcrypto_afalg_cipher_op() 158 afalg->cmsg = CMSG_FIRSTHDR(afalg->msg); in qcrypto_afalg_cipher_op() 162 afalg->msg->msg_iov = &iov; in qcrypto_afalg_cipher_op() 163 afalg->msg->msg_iovlen = 1; in qcrypto_afalg_cipher_op() 176 ret = sendmsg(afalg->opfd, afalg->msg, 0); in qcrypto_afalg_cipher_op() 191 afalg->msg->msg_controllen = 0; in qcrypto_afalg_cipher_op() [all …]
|
/qemu/hw/display/ |
H A D | vhost-user-gpu.c | 161 VhostUserGpuMsg msg = { in vhost_user_gpu_unblock() local 175 switch (msg->request) { in vhost_user_gpu_handle_display() 178 .request = msg->request, in vhost_user_gpu_handle_display() 196 .request = msg->request, in vhost_user_gpu_handle_display() 212 .request = msg->request, in vhost_user_gpu_handle_display() 340 g_warning("unhandled message %d %d", msg->request, msg->size); in vhost_user_gpu_handle_display() 352 VhostUserGpuMsg *msg = NULL; in vhost_user_gpu_chr_read() local 387 msg->request = request; in vhost_user_gpu_chr_read() 388 msg->flags = size; in vhost_user_gpu_chr_read() 389 msg->size = size; in vhost_user_gpu_chr_read() [all …]
|
/qemu/target/loongarch/ |
H A D | trace-events | 4 kvm_failed_get_regs_core(const char *msg) "Failed to get core regs from KVM: %s" 5 kvm_failed_put_regs_core(const char *msg) "Failed to put core regs into KVM: %s" 6 kvm_failed_get_fpu(const char *msg) "Failed to get fpu from KVM: %s" 7 kvm_failed_put_fpu(const char *msg) "Failed to put fpu into KVM: %s" 8 kvm_failed_get_mpstate(const char *msg) "Failed to get mp_state from KVM: %s" 9 kvm_failed_put_mpstate(const char *msg) "Failed to put mp_state into KVM: %s" 10 kvm_failed_get_counter(const char *msg) "Failed to get counter from KVM: %s" 11 kvm_failed_put_counter(const char *msg) "Failed to put counter into KVM: %s" 12 kvm_failed_get_cpucfg(const char *msg) "Failed to get cpucfg from KVM: %s" 13 kvm_failed_put_cpucfg(const char *msg) "Failed to put cpucfg into KVM: %s"
|
/qemu/hw/pci/ |
H A D | msi.c | 127 void msi_set_message(PCIDevice *dev, MSIMessage msg) in msi_set_message() argument 145 MSIMessage msg; in msi_prepare_message() local 158 msg.data &= ~(nr_vectors - 1); in msi_prepare_message() 159 msg.data |= vector; in msi_prepare_message() 162 return msg; in msi_prepare_message() 358 MSIMessage msg; in msi_notify() local 369 msg = msi_get_message(dev, vector); in msi_notify() 374 vector, msg.address, msg.data); in msi_notify() 375 msi_send_message(dev, msg); in msi_notify() 380 dev->msi_trigger(dev, msg); in msi_send_message() [all …]
|
/qemu/tests/qtest/libqos/ |
H A D | sdhci-cmd.c | 21 static ssize_t read_fifo(QTestState *qts, uint64_t reg, char *msg, size_t count) in read_fifo() argument 34 msg[index] = msg_frag & mask; in read_fifo() 35 if (msg[index++] == 0) { in read_fifo() 45 static void write_fifo(QTestState *qts, uint64_t reg, const char *msg, in write_fifo() argument 60 msg_frag |= ((uint32_t)msg[index++]) << (frag_i * 8); in write_fifo() 85 ssize_t sdhci_read_cmd(QTestState *qts, uint64_t base_addr, char *msg, in sdhci_read_cmd() argument 93 ssize_t bytes_read = read_fifo(qts, base_addr + SDHC_BDATA, msg, count); in sdhci_read_cmd() 102 void sdhci_write_cmd(QTestState *qts, uint64_t base_addr, const char *msg, in sdhci_write_cmd() argument 110 write_fifo(qts, base_addr + SDHC_BDATA, msg, count); in sdhci_write_cmd()
|
/qemu/qga/ |
H A D | vss-win32.c | 34 char *msg; in call_vss_provider_func() local 38 (char *)&msg, 0, NULL); in call_vss_provider_func() 40 func_name, QGA_VSS_DLL, msg); in call_vss_provider_func() 41 LocalFree(msg); in call_vss_provider_func() 86 char *msg; in vss_init() local 90 (char *)&msg, 0, NULL); in vss_init() 92 QGA_VSS_DLL, msg); in vss_init() 93 LocalFree(msg); in vss_init()
|
/qemu/util/ |
H A D | error.c | 21 char *msg; member 71 err->msg = g_strdup_vprintf(fmt, ap); in error_setv() 73 char *msg = err->msg; in error_setv() local 74 err->msg = g_strdup_printf("%s: %s", msg, suffix); in error_setv() 75 g_free(msg); in error_setv() 142 g_string_append(newmsg, (*errp)->msg); in error_vprepend() 143 g_free((*errp)->msg); in error_vprepend() 144 (*errp)->msg = g_string_free(newmsg, 0); in error_vprepend() 210 err_new->msg = g_strdup(err->msg); in error_copy() 229 return err->msg; in error_get_pretty() [all …]
|
/qemu/hw/tpm/ |
H A D | tpm_spapr.c | 40 uint8_t msg; /* see below */ member 138 uint8_t msg = crq_data[1]; in tpm_spapr_do_crq() local 140 trace_tpm_spapr_do_crq(valid, msg); in tpm_spapr_do_crq() 146 switch (msg) { in tpm_spapr_do_crq() 151 local_crq.msg = SPAPR_VTPM_INIT_CRQ_RESULT; in tpm_spapr_do_crq() 166 switch (msg) { in tpm_spapr_do_crq() 180 local_crq.msg = SPAPR_VTPM_VTPM_ERROR; in tpm_spapr_do_crq() 190 local_crq.msg = SPAPR_VTPM_GET_RTCE_BUFFER_SIZE | in tpm_spapr_do_crq() 218 local_crq.msg = SPAPR_VTPM_PREPARE_TO_SUSPEND | in tpm_spapr_do_crq() 228 trace_tpm_spapr_do_crq_unknown_crq(valid, msg); in tpm_spapr_do_crq() [all …]
|
/qemu/scripts/ci/ |
H A D | gitlab-pipeline-status | 59 msg = "Received unsuccessful response: %s (%s)" % (response.code, 61 raise CommunicationFailure(msg) 77 msg = "No pipeline found for project %s and commit %s" % (project_id, 79 raise NoPipelineFound(msg) 91 msg = ("Timeout (-t/--timeout) of %i seconds reached, " 93 msg %= timeout 94 print(msg) 115 msg = "Pipeline failed, check: %s" % status['web_url'] 116 print(msg)
|