| /openbmc/qemu/io/ |
| H A D | net-listener.c | 32 void qio_net_listener_set_name(QIONetListener *listener, in qio_net_listener_set_name() argument
35 g_free(listener->name); in qio_net_listener_set_name()
36 listener->name = g_strdup(name); in qio_net_listener_set_name()
44 QIONetListener *listener = QIO_NET_LISTENER(opaque); in qio_net_listener_channel_func() local
53 if (listener->io_func) { in qio_net_listener_channel_func()
54 listener->io_func(listener, sioc, listener->io_data); in qio_net_listener_channel_func()
63 int qio_net_listener_open_sync(QIONetListener *listener, in qio_net_listener_open_sync() argument
90 qio_net_listener_add(listener, sioc); in qio_net_listener_open_sync()
108 void qio_net_listener_add(QIONetListener *listener, in qio_net_listener_add() argument
111 if (listener->name) { in qio_net_listener_add()
[all …]
|
| /openbmc/qemu/python/qemu/qmp/ |
| H A D | events.py | 634 for listener in self._listeners:
635 await listener.put(msg)
637 def register_listener(self, listener: EventListener) -> None:
644 if listener in self._listeners:
646 self.logger.debug("Registering %s.", str(listener))
647 self._listeners.append(listener)
649 def remove_listener(self, listener: EventListener) -> None:
660 if listener == self.events:
662 self.logger.debug("Removing %s.", str(listener))
663 listener.clear()
[all …]
|
| /openbmc/qemu/audio/ |
| H A D | dbusaudio.c | 101 QemuDBusDisplay1AudioOutListener *listener = NULL; in dbus_put_buffer_out() local
119 while (g_hash_table_iter_next(&iter, NULL, (void **)&listener)) { in dbus_put_buffer_out()
121 listener, in dbus_put_buffer_out()
137 dbus_init_out_listener(QemuDBusDisplay1AudioOutListener *listener, in dbus_init_out_listener() argument
141 listener, in dbus_init_out_listener()
160 QemuDBusDisplay1AudioOutListener *listener = NULL; in dbus_init_out() local
167 while (g_hash_table_iter_next(&iter, NULL, (void **)&listener)) { in dbus_init_out()
168 dbus_init_out_listener(listener, hw); in dbus_init_out()
179 QemuDBusDisplay1AudioOutListener *listener = NULL; in dbus_fini_out() local
182 while (g_hash_table_iter_next(&iter, NULL, (void **)&listener)) { in dbus_fini_out()
[all …]
|
| /openbmc/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()
139 static void proxy_memory_listener_region_addnop(MemoryListener *listener, in proxy_memory_listener_region_addnop() argument
142 ProxyMemoryListener *proxy_listener = container_of(listener, in proxy_memory_listener_region_addnop()
144 listener); in proxy_memory_listener_region_addnop()
164 static void proxy_memory_listener_commit(MemoryListener *listener) in proxy_memory_listener_commit() argument
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()
[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()
|
| /openbmc/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);
|
| /openbmc/qemu/migration/ |
| H A D | socket.c | 119 static void socket_accept_incoming_migration(QIONetListener *listener, in socket_accept_incoming_migration() argument
138 QIONetListener *listener = opaque; in socket_incoming_migration_end() local
140 qio_net_listener_disconnect(listener); in socket_incoming_migration_end()
141 object_unref(OBJECT(listener)); in socket_incoming_migration_end()
147 QIONetListener *listener = qio_net_listener_new(); in socket_start_incoming_migration() local
152 qio_net_listener_set_name(listener, "migration-socket-listener"); in socket_start_incoming_migration()
160 if (qio_net_listener_open_sync(listener, saddr, num, errp) < 0) { in socket_start_incoming_migration()
161 object_unref(OBJECT(listener)); in socket_start_incoming_migration()
165 mis->transport_data = listener; in socket_start_incoming_migration()
168 qio_net_listener_set_client_func_full(listener, in socket_start_incoming_migration()
[all …]
|
| /openbmc/linux/drivers/s390/char/ |
| H A D | sclp_sd.c | 105 static void sclp_sd_listener_add(struct sclp_sd_listener *listener) in sclp_sd_listener_add() argument
108 list_add_tail(&listener->list, &sclp_sd_queue); in sclp_sd_listener_add()
116 static void sclp_sd_listener_remove(struct sclp_sd_listener *listener) in sclp_sd_listener_remove() argument
119 list_del(&listener->list); in sclp_sd_listener_remove()
132 static void sclp_sd_listener_init(struct sclp_sd_listener *listener, u32 id) in sclp_sd_listener_init() argument
134 memset(listener, 0, sizeof(*listener)); in sclp_sd_listener_init()
135 listener->id = id; in sclp_sd_listener_init()
136 init_completion(&listener->completion); in sclp_sd_listener_init()
148 struct sclp_sd_listener *listener; in sclp_sd_receiver() local
153 list_for_each_entry(listener, &sclp_sd_queue, list) { in sclp_sd_receiver()
[all …]
|
| /openbmc/linux/drivers/infiniband/hw/irdma/ |
| H A D | trace_cm.h | 42 TP_PROTO(struct irdma_cm_listener *listener, void *caller),
43 TP_ARGS(listener, caller),
51 TP_fast_assign(__entry->iwdev = listener->iwdev;
52 __entry->lport = listener->loc_port;
53 __entry->ipv4 = listener->ipv4;
55 listener->loc_addr, 4);
66 TP_PROTO(struct irdma_cm_listener *listener),
67 TP_ARGS(listener),
76 TP_fast_assign(__entry->iwdev = listener->iwdev;
77 __entry->lport = listener->loc_port;
[all …]
|
| H A D | cm.c | 1849 struct irdma_cm_listener *listener, in irdma_reset_list_prep() argument
1856 if (cm_node->listener == listener && in irdma_reset_list_prep()
1871 struct irdma_cm_listener *listener, in irdma_dec_refcnt_listen() argument
1883 trace_irdma_dec_refcnt_listen(listener, __builtin_return_address(0)); in irdma_dec_refcnt_listen()
1888 irdma_reset_list_prep(cm_core, listener, &reset_list); in irdma_dec_refcnt_listen()
1914 if (refcount_dec_and_test(&listener->refcnt)) { in irdma_dec_refcnt_listen()
1916 list_del(&listener->list); in irdma_dec_refcnt_listen()
1920 irdma_del_apbvt(listener->iwdev, in irdma_dec_refcnt_listen()
1921 listener->apbvt_entry); in irdma_dec_refcnt_listen()
1922 memcpy(nfo.loc_addr, listener->loc_addr, sizeof(nfo.loc_addr)); in irdma_dec_refcnt_listen()
[all …]
|
| /openbmc/linux/samples/seccomp/ |
| H A D | user-trap.c | 105 struct seccomp_notif_resp *resp, int listener) in handle_req() argument
145 if (ioctl(listener, SECCOMP_IOCTL_NOTIF_ID_VALID, &req->id) < 0) { in handle_req()
203 int sk_pair[2], ret = 1, status, listener; in main() local
218 listener = user_trap_syscall(__NR_mount, in main()
220 if (listener < 0) { in main()
237 if (send_fd(sk_pair[1], listener) < 0) in main()
239 close(listener); in main()
273 listener = recv_fd(sk_pair[0]); in main()
274 if (listener < 0) in main()
309 if (ioctl(listener, SECCOMP_IOCTL_NOTIF_RECV, req)) { in main()
[all …]
|
| /openbmc/telemetry/src/ |
| H A D | sensor.cpp | 72 [](const auto& listener) { return listener.expired(); }), in registerForUpdates() argument
75 if (auto listener = weakListener.lock()) in registerForUpdates() local
81 listener->sensorUpdated(*this, timestamp, *value); in registerForUpdates()
93 if (auto listener = weakListener.lock()) in unregisterFromUpdates() local
98 [listenerToUnregister = listener.get()](const auto& listener) { in unregisterFromUpdates() argument
99 return (listener.expired() || in unregisterFromUpdates()
100 listener.lock().get() == listenerToUnregister); in unregisterFromUpdates()
116 if (auto listener = weakListener.lock()) in updateValue() local
118 listener->sensorUpdated(*this, timestamp, *value); in updateValue()
|
| H A D | metric.cpp | 25 void Metric::registerForUpdates(interfaces::MetricListener& listener) in registerForUpdates() argument
27 listeners.emplace_back(listener); in registerForUpdates()
30 void Metric::unregisterFromUpdates(interfaces::MetricListener& listener) in unregisterFromUpdates() argument
34 [&listener](const interfaces::MetricListener& item) { in unregisterFromUpdates()
35 return &item == &listener; in unregisterFromUpdates()
100 for (interfaces::MetricListener& listener : listeners) in sensorUpdated()
102 listener.metricUpdated(); in sensorUpdated()
141 for (interfaces::MetricListener& listener : listeners) in updateReadings()
143 listener.metricUpdated(); in updateReadings()
|
| /openbmc/linux/tools/perf/bench/ |
| H A D | sched-seccomp-notify.c | 68 static void user_notification_sync_loop(int listener) in user_notification_sync_loop() argument
76 if (ioctl(listener, SECCOMP_IOCTL_NOTIF_RECV, &req)) in user_notification_sync_loop()
86 if (ioctl(listener, SECCOMP_IOCTL_NOTIF_SEND, &resp)) in user_notification_sync_loop()
99 int status, listener; in bench_sched_seccomp_notify() local
108 listener = user_notif_syscall(__NR_gettid, in bench_sched_seccomp_notify()
110 if (listener < 0) in bench_sched_seccomp_notify()
129 if (ioctl(listener, SECCOMP_IOCTL_NOTIF_SET_FLAGS, in bench_sched_seccomp_notify()
134 user_notification_sync_loop(listener); in bench_sched_seccomp_notify()
|
| /openbmc/qemu/ |
| H A D | blockdev-nbd.c | 30 QIONetListener *listener; member
74 static void nbd_accept(QIONetListener *listener, QIOChannelSocket *cioc, in nbd_accept() argument
95 if (s->listener) { in nbd_update_server_watch()
97 qio_net_listener_set_client_func(s->listener, nbd_accept, NULL, in nbd_update_server_watch()
100 qio_net_listener_set_client_func(s->listener, NULL, NULL, NULL); in nbd_update_server_watch()
117 qio_net_listener_disconnect(server->listener); in nbd_server_free()
118 object_unref(OBJECT(server->listener)); in nbd_server_free()
119 server->listener = NULL; in nbd_server_free()
176 nbd_server->listener = qio_net_listener_new(); in nbd_server_start()
178 qio_net_listener_set_name(nbd_server->listener, in nbd_server_start()
[all …]
|
| /openbmc/qemu/include/hw/xen/ |
| H A D | xen-hvm-common.h | 91 void xen_region_add(MemoryListener *listener, MemoryRegionSection *section);
92 void xen_region_del(MemoryListener *listener, MemoryRegionSection *section);
93 void xen_io_add(MemoryListener *listener, MemoryRegionSection *section);
94 void xen_io_del(MemoryListener *listener, MemoryRegionSection *section);
95 void xen_device_realize(DeviceListener *listener, DeviceState *dev);
96 void xen_device_unrealize(DeviceListener *listener, DeviceState *dev);
|
| /openbmc/qemu/util/ |
| H A D | vhost-user-server.c | 335 static void vu_accept(QIONetListener *listener, QIOChannelSocket *sioc, in vu_accept() argument
356 qio_net_listener_set_client_func(server->listener, in vu_accept()
397 if (server->listener) { in vhost_user_server_stop()
398 qio_net_listener_disconnect(server->listener); in vhost_user_server_stop()
399 object_unref(OBJECT(server->listener)); in vhost_user_server_stop()
411 qio_net_listener_set_client_func(server->listener, vu_accept, server, in restart_listener_bh()
482 QIONetListener *listener; in vhost_user_server_start() local
490 listener = qio_net_listener_new(); in vhost_user_server_start()
491 if (qio_net_listener_open_sync(listener, socket_addr, 1, in vhost_user_server_start()
493 object_unref(OBJECT(listener)); in vhost_user_server_start()
[all …]
|
| /openbmc/qemu/system/ |
| H A D | memory.c | 1074 MemoryListener *listener, in flat_range_coalesced_io_notify_listener_add_del() argument
1091 if (add && listener->coalesced_io_add) { in flat_range_coalesced_io_notify_listener_add_del()
1092 listener->coalesced_io_add(listener, mrs, in flat_range_coalesced_io_notify_listener_add_del()
1095 } else if (!add && listener->coalesced_io_del) { in flat_range_coalesced_io_notify_listener_add_del()
1096 listener->coalesced_io_del(listener, mrs, in flat_range_coalesced_io_notify_listener_add_del()
2418 MemoryListener *listener; in memory_region_sync_dirty_bitmap() local
2428 QTAILQ_FOREACH(listener, &memory_listeners, link) { in memory_region_sync_dirty_bitmap()
2429 if (listener->log_sync) { in memory_region_sync_dirty_bitmap()
2430 as = listener->address_space; in memory_region_sync_dirty_bitmap()
2435 listener->log_sync(listener, &mrs); in memory_region_sync_dirty_bitmap()
[all …]
|
| /openbmc/linux/tools/testing/selftests/seccomp/ |
| H A D | seccomp_bpf.c | 3365 int status, listener; in TEST() local
3405 listener = user_notif_syscall(__NR_getppid, in TEST()
3407 ASSERT_GE(listener, 0); in TEST()
3423 pollfd.fd = listener; in TEST()
3433 ret = ioctl(listener, SECCOMP_IOCTL_NOTIF_RECV, &req); in TEST()
3439 EXPECT_EQ(ioctl(listener, SECCOMP_IOCTL_NOTIF_RECV, &req), 0); in TEST()
3442 pollfd.fd = listener; in TEST()
3456 EXPECT_EQ(ioctl(listener, SECCOMP_IOCTL_NOTIF_SEND, &resp), -1); in TEST()
3460 EXPECT_EQ(ioctl(listener, SECCOMP_IOCTL_NOTIF_SEND, &resp), 0); in TEST()
3494 int listener; in TEST() local
[all …]
|
| /openbmc/linux/drivers/uio/ |
| H A D | uio.c | 464 struct uio_listener *listener; in uio_open() local
482 listener = kmalloc(sizeof(*listener), GFP_KERNEL); in uio_open()
483 if (!listener) { in uio_open()
488 listener->dev = idev; in uio_open()
489 listener->event_count = atomic_read(&idev->event); in uio_open()
490 filep->private_data = listener; in uio_open()
508 kfree(listener); in uio_open()
522 struct uio_listener *listener = filep->private_data; in uio_fasync() local
523 struct uio_device *idev = listener->dev; in uio_fasync()
531 struct uio_listener *listener = filep->private_data; in uio_release() local
[all …]
|
| /openbmc/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()
169 qio_net_listener_set_client_func(s->listener, net_stream_listen, 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()
[all …]
|
| /openbmc/qemu/hw/vfio/ |
| H A D | common.c | 351 listener); in vfio_ram_discard_notify_discard()
369 listener); in vfio_ram_discard_notify_populate()
424 ram_discard_listener_init(&vrdl->listener, in vfio_register_ram_discard_listener()
427 ram_discard_manager_register_listener(rdm, &vrdl->listener, section); in vfio_register_ram_discard_listener()
492 ram_discard_manager_unregister_listener(rdm, &vrdl->listener); in vfio_unregister_ram_discard_listener()
567 static void vfio_listener_region_add(MemoryListener *listener, in vfio_listener_region_add() argument
570 VFIOContainerBase *bcontainer = container_of(listener, VFIOContainerBase, in vfio_listener_region_add()
571 listener); in vfio_listener_region_add()
714 static void vfio_listener_region_del(MemoryListener *listener, in vfio_listener_region_del() argument
717 VFIOContainerBase *bcontainer = container_of(listener, VFIOContainerBase, in vfio_listener_region_del()
[all …]
|
| /openbmc/linux/drivers/infiniband/hw/qedr/ |
| H A D | qedr_iw_cm.c | 106 struct qedr_iw_listener *listener = (struct qedr_iw_listener *)context; in qedr_iw_mpa_request() local
107 struct qedr_dev *dev = listener->dev; in qedr_iw_mpa_request()
135 listener->cm_id->event_handler(listener->cm_id, &event); in qedr_iw_mpa_request()
660 struct qedr_iw_listener *listener; in qedr_iw_create_listen() local
674 listener = kzalloc(sizeof(*listener), GFP_KERNEL); in qedr_iw_create_listen()
675 if (!listener) in qedr_iw_create_listen()
678 listener->dev = dev; in qedr_iw_create_listen()
680 listener->cm_id = cm_id; in qedr_iw_create_listen()
681 listener->backlog = backlog; in qedr_iw_create_listen()
683 iparams.cb_context = listener; in qedr_iw_create_listen()
[all …]
|
| /openbmc/qemu/tests/qtest/ |
| H A D | dbus-display-test.c | 147 g_autoptr(GDBusObjectSkeleton) listener = NULL; in test_dbus_console_setup_listener()
151 listener = g_dbus_object_skeleton_new(DBUS_DISPLAY1_ROOT "/Listener"); in test_dbus_console_setup_listener()
157 g_dbus_object_skeleton_add_interface(listener, in test_dbus_console_setup_listener()
171 g_dbus_object_skeleton_add_interface(listener, in test_dbus_console_setup_listener()
178 g_dbus_object_manager_server_export(test->server, listener); in test_dbus_console_setup_listener()
230 g_autoptr(GVariant) listener = NULL; in test_dbus_display_console()
267 listener = g_variant_new_fixed_array(G_VARIANT_TYPE_BYTE, in test_dbus_display_console()
276 listener, in test_dbus_display_console()
|
| /openbmc/linux/net/vmw_vsock/ |
| H A D | af_vsock.c | 369 void vsock_add_pending(struct sock *listener, struct sock *pending) in vsock_add_pending() argument
374 vlistener = vsock_sk(listener); in vsock_add_pending()
378 sock_hold(listener); in vsock_add_pending()
383 void vsock_remove_pending(struct sock *listener, struct sock *pending) in vsock_remove_pending() argument
388 sock_put(listener); in vsock_remove_pending()
393 void vsock_enqueue_accept(struct sock *listener, struct sock *connected) in vsock_enqueue_accept() argument
398 vlistener = vsock_sk(listener); in vsock_enqueue_accept()
402 sock_hold(listener); in vsock_enqueue_accept()
548 static struct sock *vsock_dequeue_accept(struct sock *listener) in vsock_dequeue_accept() argument
553 vlistener = vsock_sk(listener); in vsock_dequeue_accept()
[all …]
|