/qemu/io/ |
H A D | net-listener.c | 35 g_free(listener->name); in qio_net_listener_set_name() 54 listener->io_func(listener, sioc, listener->io_data); in qio_net_listener_channel_func() 115 listener->sioc = g_renew(QIOChannelSocket *, listener->sioc, in qio_net_listener_add() 117 listener->io_source = g_renew(typeof(listener->io_source[0]), in qio_net_listener_add() 120 listener->sioc[listener->nsioc] = sioc; in qio_net_listener_add() 121 listener->io_source[listener->nsioc] = NULL; in qio_net_listener_add() 128 listener->io_source[listener->nsioc] = qio_channel_add_watch_source( in qio_net_listener_add() 129 QIO_CHANNEL(listener->sioc[listener->nsioc]), G_IO_IN, in qio_net_listener_add() 134 listener->nsioc++; in qio_net_listener_add() 147 listener->io_notify(listener->io_data); in qio_net_listener_set_client_func_full() [all …]
|
/qemu/python/qemu/qmp/ |
H A D | events.py | 634 for listener in self._listeners: 635 await listener.put(msg) 644 if listener in self._listeners: 660 if listener == self.events: 663 listener.clear() 684 for listener in listeners: 686 _added.append(listener) 691 for listener in _added: 695 def listener( member in Events 716 with self.listen(listener): [all …]
|
/qemu/audio/ |
H A D | dbusaudio.c | 121 listener, in dbus_put_buffer_out() 141 listener, in dbus_init_out_listener() 168 dbus_init_out_listener(listener, hw); in dbus_init_out() 184 listener, in dbus_fini_out() 208 listener, (uintptr_t)hw, enable, in dbus_enable_out() 255 listener, in dbus_init_in_listener() 297 listener, in dbus_fini_in() 360 listener, in dbus_read() 466 GObject *listener; in dbus_audio_register_listener() local 538 listener = out ? in dbus_audio_register_listener() [all …]
|
/qemu/hw/remote/ |
H A D | proxy-memory-listener.c | 29 static void proxy_memory_listener_reset(MemoryListener *listener) in proxy_memory_listener_reset() argument 31 ProxyMemoryListener *proxy_listener = container_of(listener, in proxy_memory_listener_reset() 33 listener); in proxy_memory_listener_reset() 142 ProxyMemoryListener *proxy_listener = container_of(listener, in proxy_memory_listener_region_addnop() 144 listener); in proxy_memory_listener_region_addnop() 166 ProxyMemoryListener *proxy_listener = container_of(listener, in proxy_memory_listener_commit() 168 listener); in proxy_memory_listener_commit() 203 memory_listener_unregister(&proxy_listener->listener); in proxy_memory_listener_deconfigure() 205 proxy_memory_listener_reset(&proxy_listener->listener); in proxy_memory_listener_deconfigure() 221 proxy_listener->listener.name = "proxy"; in proxy_memory_listener_configure() [all …]
|
H A D | remote-obj.c | 47 DeviceListener listener; member 80 static void remote_object_unrealize_listener(DeviceListener *listener, in remote_object_unrealize_listener() argument 83 RemoteObject *o = container_of(listener, RemoteObject, listener); in remote_object_unrealize_listener() 114 o->listener.unrealize = remote_object_unrealize_listener; in remote_object_machine_done() 115 device_listener_register(&o->listener); in remote_object_machine_done() 153 device_listener_unregister(&o->listener); in remote_object_finalize()
|
/qemu/include/io/ |
H A D | net-listener.h | 32 typedef void (*QIONetListenerClientFunc)(QIONetListener *listener, 83 void qio_net_listener_set_name(QIONetListener *listener, 98 int qio_net_listener_open_sync(QIONetListener *listener, 113 void qio_net_listener_add(QIONetListener *listener, 130 void qio_net_listener_set_client_func_full(QIONetListener *listener, 146 void qio_net_listener_set_client_func(QIONetListener *listener, 162 QIOChannelSocket *qio_net_listener_wait_client(QIONetListener *listener); 172 void qio_net_listener_disconnect(QIONetListener *listener); 184 bool qio_net_listener_is_connected(QIONetListener *listener);
|
/qemu/migration/ |
H A D | socket.c | 137 static void socket_accept_incoming_migration(QIONetListener *listener, in socket_accept_incoming_migration() argument 156 QIONetListener *listener = opaque; in socket_incoming_migration_end() local 158 qio_net_listener_disconnect(listener); in socket_incoming_migration_end() 159 object_unref(OBJECT(listener)); in socket_incoming_migration_end() 165 QIONetListener *listener = qio_net_listener_new(); in socket_start_incoming_migration() local 170 qio_net_listener_set_name(listener, "migration-socket-listener"); in socket_start_incoming_migration() 178 if (qio_net_listener_open_sync(listener, saddr, num, errp) < 0) { in socket_start_incoming_migration() 179 object_unref(OBJECT(listener)); in socket_start_incoming_migration() 183 mis->transport_data = listener; in socket_start_incoming_migration() 186 qio_net_listener_set_client_func_full(listener, in socket_start_incoming_migration() [all …]
|
/qemu/include/hw/xen/ |
H A D | xen-hvm-common.h | 86 void xen_region_add(MemoryListener *listener, MemoryRegionSection *section); 87 void xen_region_del(MemoryListener *listener, MemoryRegionSection *section); 88 void xen_io_add(MemoryListener *listener, MemoryRegionSection *section); 89 void xen_io_del(MemoryListener *listener, MemoryRegionSection *section); 90 void xen_device_realize(DeviceListener *listener, DeviceState *dev); 91 void xen_device_unrealize(DeviceListener *listener, DeviceState *dev);
|
/qemu/util/ |
H A D | vhost-user-server.c | 323 static void vu_accept(QIONetListener *listener, QIOChannelSocket *sioc, in vu_accept() argument 344 qio_net_listener_set_client_func(server->listener, in vu_accept() 385 if (server->listener) { in vhost_user_server_stop() 386 qio_net_listener_disconnect(server->listener); in vhost_user_server_stop() 387 object_unref(OBJECT(server->listener)); in vhost_user_server_stop() 470 QIONetListener *listener; in vhost_user_server_start() local 478 listener = qio_net_listener_new(); in vhost_user_server_start() 479 if (qio_net_listener_open_sync(listener, socket_addr, 1, in vhost_user_server_start() 481 object_unref(OBJECT(listener)); in vhost_user_server_start() 489 .listener = listener, in vhost_user_server_start() [all …]
|
H A D | oslib-win32.c | 327 int listener = -1; in qemu_socketpair() local 355 listener = socket(domain, type, protocol); in qemu_socketpair() 356 if (listener == -1) { in qemu_socketpair() 366 if (bind(listener, (struct sockaddr *)&addr, socklen) == -1) { in qemu_socketpair() 370 if (listen(listener, 1) == -1) { in qemu_socketpair() 389 server = accept(listener, NULL, NULL); in qemu_socketpair() 416 if (listener != -1) { in qemu_socketpair() 417 close(listener); in qemu_socketpair()
|
/qemu/ |
H A D | blockdev-nbd.c | 25 QIONetListener *listener; member 60 static void nbd_accept(QIONetListener *listener, QIOChannelSocket *cioc, in nbd_accept() argument 74 qio_net_listener_set_client_func(s->listener, nbd_accept, NULL, NULL); in nbd_update_server_watch() 76 qio_net_listener_set_client_func(s->listener, NULL, NULL, NULL); in nbd_update_server_watch() 86 qio_net_listener_disconnect(server->listener); in nbd_server_free() 87 object_unref(OBJECT(server->listener)); in nbd_server_free() 137 nbd_server->listener = qio_net_listener_new(); in nbd_server_start() 139 qio_net_listener_set_name(nbd_server->listener, in nbd_server_start() 146 if (qio_net_listener_open_sync(nbd_server->listener, addr, SOMAXCONN, in nbd_server_start()
|
/qemu/net/ |
H A D | stream.c | 48 QIONetListener *listener; member 59 static void net_stream_listen(QIONetListener *listener, 167 if (s->listener) { in net_stream_send() 220 if (s->listener) { in net_stream_cleanup() 221 qio_net_listener_disconnect(s->listener); in net_stream_cleanup() 222 object_unref(OBJECT(s->listener)); in net_stream_cleanup() 223 s->listener = NULL; in net_stream_cleanup() 237 static void net_stream_listen(QIONetListener *listener, in net_stream_listen() argument 247 qio_net_listener_set_client_func(s->listener, NULL, s, NULL); in net_stream_listen() 295 s->listener = qio_net_listener_new(); in net_stream_server_listening() [all …]
|
/qemu/system/ |
H A D | memory.c | 2300 listener->log_sync(listener, &mrs); in memory_region_sync_dirty_bitmap() 2362 listener->log_clear(listener, &mrs); in memory_region_clear_dirty_bitmap() 2938 listener->log_global_stop(listener); in memory_global_dirty_log_do_start() 3048 listener->begin(listener); in listener_add_address_space() 3068 listener->region_add(listener, §ion); in listener_add_address_space() 3075 listener->commit(listener); in listener_add_address_space() 3087 listener->begin(listener); in listener_del_address_space() 3097 listener->region_del(listener, §ion); in listener_del_address_space() 3101 listener->commit(listener); in listener_del_address_space() 3140 if (listener->eventfd_add || listener->eventfd_del) { in memory_listener_register() [all …]
|
H A D | memory_mapping.c | 194 MemoryListener listener; member 259 static void guest_phys_blocks_region_add(MemoryListener *listener, in guest_phys_blocks_region_add() argument 262 GuestPhysListener *g = container_of(listener, GuestPhysListener, listener); in guest_phys_blocks_region_add() 289 g.listener.region_add = &guest_phys_blocks_region_add; in guest_phys_blocks_append() 290 memory_listener_register(&g.listener, &address_space_memory); in guest_phys_blocks_append() 291 memory_listener_unregister(&g.listener); in guest_phys_blocks_append()
|
/qemu/hw/vfio/ |
H A D | common.c | 345 listener); in vfio_ram_discard_notify_discard() 363 listener); in vfio_ram_discard_notify_populate() 418 ram_discard_listener_init(&vrdl->listener, in vfio_register_ram_discard_listener() 565 listener); in vfio_listener_region_add() 730 listener); in vfio_listener_region_del() 824 MemoryListener listener; member 852 VFIODirtyRangesListener *dirty = container_of(listener, in vfio_dirty_tracking_update() 916 dirty.listener = vfio_dirty_tracking_listener; in vfio_dirty_tracking_init() 919 memory_listener_register(&dirty.listener, in vfio_dirty_tracking_init() 929 memory_listener_unregister(&dirty.listener); in vfio_dirty_tracking_init() [all …]
|
/qemu/tests/qtest/ |
H A D | dbus-display-test.c | 105 g_autoptr(GDBusObjectSkeleton) listener = NULL; in test_dbus_console_setup_listener() 109 listener = g_dbus_object_skeleton_new(DBUS_DISPLAY1_ROOT "/Listener"); in test_dbus_console_setup_listener() 115 g_dbus_object_skeleton_add_interface(listener, in test_dbus_console_setup_listener() 117 g_dbus_object_manager_server_export(test->server, listener); in test_dbus_console_setup_listener() 169 g_autoptr(GVariant) listener = NULL; in test_dbus_display_console() 206 listener = g_variant_new_fixed_array(G_VARIANT_TYPE_BYTE, in test_dbus_display_console() 215 listener, in test_dbus_display_console()
|
/qemu/hw/mem/ |
H A D | memory-device.c | 489 static void memory_devices_region_mod(MemoryListener *listener, in memory_devices_region_mod() argument 492 DeviceMemoryState *dms = container_of(listener, DeviceMemoryState, in memory_devices_region_mod() 493 listener); in memory_devices_region_mod() 521 static void memory_devices_region_add(MemoryListener *listener, in memory_devices_region_add() argument 524 return memory_devices_region_mod(listener, mrs, true); in memory_devices_region_add() 527 static void memory_devices_region_del(MemoryListener *listener, in memory_devices_region_del() argument 530 return memory_devices_region_mod(listener, mrs, false); in memory_devices_region_del() 548 ms->device_memory->listener.region_add = memory_devices_region_add; in machine_memory_devices_init() 549 ms->device_memory->listener.region_del = memory_devices_region_del; in machine_memory_devices_init() 550 memory_listener_register(&ms->device_memory->listener, in machine_memory_devices_init()
|
/qemu/include/exec/ |
H A D | memory.h | 869 void (*begin)(MemoryListener *listener); 881 void (*commit)(MemoryListener *listener); 934 void (*log_start)(MemoryListener *listener, MemoryRegionSection *section, 953 void (*log_stop)(MemoryListener *listener, MemoryRegionSection *section, 966 void (*log_sync)(MemoryListener *listener, MemoryRegionSection *section); 981 void (*log_sync_global)(MemoryListener *listener, bool last_stage); 992 void (*log_clear)(MemoryListener *listener, MemoryRegionSection *section); 1008 bool (*log_global_start)(MemoryListener *listener, Error **errp); 1019 void (*log_global_stop)(MemoryListener *listener); 1029 void (*log_global_after_sync)(MemoryListener *listener); [all …]
|
/qemu/hw/xen/ |
H A D | xen-hvm-common.c | 52 static void xen_set_memory(struct MemoryListener *listener, in xen_set_memory() argument 73 void xen_region_add(MemoryListener *listener, in xen_region_add() argument 77 xen_set_memory(listener, section, true); in xen_region_add() 80 void xen_region_del(MemoryListener *listener, in xen_region_del() argument 83 xen_set_memory(listener, section, false); in xen_region_del() 87 void xen_io_add(MemoryListener *listener, in xen_io_add() argument 90 XenIOState *state = container_of(listener, XenIOState, io_listener); in xen_io_add() 102 void xen_io_del(MemoryListener *listener, in xen_io_del() argument 105 XenIOState *state = container_of(listener, XenIOState, io_listener); in xen_io_del() 117 void xen_device_realize(DeviceListener *listener, in xen_device_realize() argument [all …]
|
/qemu/ui/ |
H A D | dbus-console.c | 172 listener_vanished_cb(DBusDisplayListener *listener) in listener_vanished_cb() argument 174 DBusDisplayConsole *ddc = dbus_display_listener_get_console(listener); in listener_vanished_cb() 175 const char *name = dbus_display_listener_get_bus_name(listener); in listener_vanished_cb() 264 DBusDisplayListener *listener; in dbus_console_register_listener() local 326 listener = dbus_display_listener_new(sender, listener_conn, ddc); in dbus_console_register_listener() 327 if (!listener) { in dbus_console_register_listener() 332 (gpointer)dbus_display_listener_get_bus_name(listener), in dbus_console_register_listener() 333 listener); in dbus_console_register_listener() 335 "swapped-signal::closed", listener_vanished_cb, listener, in dbus_console_register_listener()
|
/qemu/chardev/ |
H A D | char-socket.c | 99 static void tcp_chr_accept(QIONetListener *listener, 468 if (s->listener) { in tcp_chr_disconnect_locked() 892 if (s->listener) { in tcp_chr_new_client() 937 static void tcp_chr_accept(QIONetListener *listener, in tcp_chr_accept() argument 1092 if (s->listener) { in char_socket_finalize() 1095 object_unref(OBJECT(s->listener)); in char_socket_finalize() 1096 s->listener = NULL; in char_socket_finalize() 1219 s->listener = qio_net_listener_new(); in qmp_chardev_open_socket_server() 1222 qio_net_listener_set_name(s->listener, name); in qmp_chardev_open_socket_server() 1230 object_unref(OBJECT(s->listener)); in qmp_chardev_open_socket_server() [all …]
|
/qemu/hw/virtio/ |
H A D | vhost-vdpa.c | 176 static void vhost_vdpa_listener_commit(MemoryListener *listener) in vhost_vdpa_listener_commit() argument 178 VhostVDPAShared *s = container_of(listener, VhostVDPAShared, listener); in vhost_vdpa_listener_commit() 254 VhostVDPAShared *s = container_of(listener, VhostVDPAShared, listener); in vhost_vdpa_iommu_region_add() 295 VhostVDPAShared *s = container_of(listener, VhostVDPAShared, listener); in vhost_vdpa_iommu_region_del() 315 VhostVDPAShared *s = container_of(listener, VhostVDPAShared, listener); in vhost_vdpa_listener_region_add() 328 vhost_vdpa_iommu_region_add(listener, section); in vhost_vdpa_listener_region_add() 403 VhostVDPAShared *s = container_of(listener, VhostVDPAShared, listener); in vhost_vdpa_listener_region_del() 415 vhost_vdpa_iommu_region_del(listener, section); in vhost_vdpa_listener_region_del() 602 v->shared->listener = vhost_vdpa_memory_listener; in vhost_vdpa_init() 762 memory_listener_unregister(&v->shared->listener); in vhost_vdpa_cleanup() [all …]
|
/qemu/accel/kvm/ |
H A D | kvm-all.c | 551 KVMMemoryListener *kml = container_of(listener, KVMMemoryListener, listener); in kvm_log_start() 568 KVMMemoryListener *kml = container_of(listener, KVMMemoryListener, listener); in kvm_log_stop() 1566 KVMMemoryListener *kml = container_of(listener, KVMMemoryListener, listener); in kvm_region_add() 1578 KVMMemoryListener *kml = container_of(listener, KVMMemoryListener, listener); in kvm_region_del() 1661 KVMMemoryListener *kml = container_of(listener, KVMMemoryListener, listener); in kvm_log_sync() 1707 KVMMemoryListener *kml = container_of(listener, KVMMemoryListener, listener); in kvm_log_clear() 1808 kml->listener.region_add = kvm_region_add; in kvm_memory_listener_register() 1810 kml->listener.commit = kvm_region_commit; in kvm_memory_listener_register() 1811 kml->listener.log_start = kvm_log_start; in kvm_memory_listener_register() 1812 kml->listener.log_stop = kvm_log_stop; in kvm_memory_listener_register() [all …]
|
/qemu/hw/intc/ |
H A D | openpic_kvm.c | 117 static void kvm_openpic_region_add(MemoryListener *listener, in kvm_openpic_region_add() argument 120 KVMOpenPICState *opp = container_of(listener, KVMOpenPICState, in kvm_openpic_region_add() 153 static void kvm_openpic_region_del(MemoryListener *listener, in kvm_openpic_region_del() argument 156 KVMOpenPICState *opp = container_of(listener, KVMOpenPICState, in kvm_openpic_region_del()
|
/qemu/hw/core/ |
H A D | qdev.c | 213 void device_listener_register(DeviceListener *listener) in device_listener_register() argument 215 QTAILQ_INSERT_TAIL(&device_listeners, listener, link); in device_listener_register() 221 void device_listener_unregister(DeviceListener *listener) in device_listener_unregister() argument 223 QTAILQ_REMOVE(&device_listeners, listener, link); in device_listener_unregister() 229 DeviceListener *listener; in qdev_should_hide_device() local 231 QTAILQ_FOREACH(listener, &device_listeners, link) { in qdev_should_hide_device() 232 if (listener->hide_device) { in qdev_should_hide_device() 233 if (listener->hide_device(listener, opts, from_json, errp)) { in qdev_should_hide_device()
|