Home
last modified time | relevance | path

Searched refs:listener (Results 1 – 25 of 58) sorted by relevance

123

/qemu/io/
H A Dnet-listener.c35 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 Devents.py634 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 Ddbusaudio.c121 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 Dproxy-memory-listener.c29 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 Dremote-obj.c47 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 Dnet-listener.h32 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 Dsocket.c137 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 Dxen-hvm-common.h86 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 Dvhost-user-server.c323 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 Doslib-win32.c327 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 Dblockdev-nbd.c25 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 Dstream.c48 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 Dmemory.c2300 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, &section); 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, &section); 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 Dmemory_mapping.c194 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 Dcommon.c345 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 Ddbus-display-test.c105 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 Dmemory-device.c489 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 Dmemory.h869 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 Dxen-hvm-common.c52 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 Ddbus-console.c172 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 Dchar-socket.c99 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 Dvhost-vdpa.c176 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 Dkvm-all.c551 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 Dopenpic_kvm.c117 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 Dqdev.c213 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()

123