/openbmc/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 …]
|
/openbmc/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 …]
|
/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() 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 79 static void remote_object_unrealize_listener(DeviceListener *listener, in remote_object_unrealize_listener() argument 82 RemoteObject *o = container_of(listener, RemoteObject, listener); in remote_object_unrealize_listener() 113 o->listener.unrealize = remote_object_unrealize_listener; in remote_object_machine_done() 114 device_listener_register(&o->listener); in remote_object_machine_done() 152 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/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 …]
|
/openbmc/qemu/migration/ |
H A D | socket.c | 140 static void socket_accept_incoming_migration(QIONetListener *listener, in socket_accept_incoming_migration() argument 159 QIONetListener *listener = opaque; in socket_incoming_migration_end() local 161 qio_net_listener_disconnect(listener); in socket_incoming_migration_end() 162 object_unref(OBJECT(listener)); in socket_incoming_migration_end() 168 QIONetListener *listener = qio_net_listener_new(); in socket_start_incoming_migration() local 173 qio_net_listener_set_name(listener, "migration-socket-listener"); in socket_start_incoming_migration() 181 if (qio_net_listener_open_sync(listener, saddr, num, errp) < 0) { in socket_start_incoming_migration() 182 object_unref(OBJECT(listener)); in socket_start_incoming_migration() 186 mis->transport_data = listener; in socket_start_incoming_migration() 189 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 | 119 list_del(&listener->list); in sclp_sd_listener_remove() 134 memset(listener, 0, sizeof(*listener)); in sclp_sd_listener_init() 135 listener->id = id; in sclp_sd_listener_init() 148 struct sclp_sd_listener *listener; in sclp_sd_receiver() local 154 if (listener->id != evbuf->id) in sclp_sd_receiver() 157 listener->evbuf = *evbuf; in sclp_sd_receiver() 158 complete(&listener->completion); in sclp_sd_receiver() 193 struct sclp_sd_listener listener; in sclp_sd_sync() local 198 sclp_sd_listener_add(&listener); in sclp_sd_sync() 208 evbuf->id = listener.id; in sclp_sd_sync() [all …]
|
/openbmc/linux/samples/seccomp/ |
H A D | user-trap.c | 105 struct seccomp_notif_resp *resp, int listener) in handle_req() argument 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() 314 if (handle_req(req, resp, listener) < 0) in main() 337 close(listener); 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 96 [listenerToUnregister = listener.get()]( in unregisterFromUpdates() 97 const auto& listener) { in unregisterFromUpdates() argument 98 return (listener.expired() || in unregisterFromUpdates() 99 listener.lock().get() == listenerToUnregister); in unregisterFromUpdates() 115 if (auto listener = weakListener.lock()) in updateValue() local 117 listener->sensorUpdated(*this, timestamp, *value); in updateValue()
|
H A D | metric.cpp | 26 void Metric::registerForUpdates(interfaces::MetricListener& listener) in registerForUpdates() argument 28 listeners.emplace_back(listener); in registerForUpdates() 31 void Metric::unregisterFromUpdates(interfaces::MetricListener& listener) in unregisterFromUpdates() argument 35 [&listener](const interfaces::MetricListener& item) { in unregisterFromUpdates() 36 return &item == &listener; in unregisterFromUpdates() 101 for (interfaces::MetricListener& listener : listeners) in sensorUpdated() 103 listener.metricUpdated(); in sensorUpdated() 142 for (interfaces::MetricListener& listener : listeners) in updateReadings() 144 listener.metricUpdated(); in updateReadings()
|
/openbmc/linux/drivers/infiniband/hw/irdma/ |
H A D | trace_cm.h | 43 TP_ARGS(listener, caller), 52 __entry->lport = listener->loc_port; 53 __entry->ipv4 = listener->ipv4; 55 listener->loc_addr, 4); 67 TP_ARGS(listener), 79 __entry->ipv4 = listener->ipv4; 82 listener->loc_addr, 4); 94 TP_ARGS(listener)); 98 TP_ARGS(listener)); 159 __entry->ipv4 = listener->ipv4; [all …]
|
H A D | cm.c | 1856 if (cm_node->listener == listener && in irdma_reset_list_prep() 1931 listener); in irdma_dec_refcnt_listen() 1945 listener->loc_port, listener->loc_addr, listener, in irdma_dec_refcnt_listen() 1946 listener->cm_id, listener->qhash_set, in irdma_dec_refcnt_listen() 2255 if (listener) { in irdma_make_cm_node() 2289 cm_node->listener = listener; in irdma_make_cm_node() 2954 listener = in irdma_make_listen_node() 2958 if (listener && in irdma_make_listen_node() 2964 if (!listener) { in irdma_make_listen_node() 2968 listener = kzalloc(sizeof(*listener), GFP_KERNEL); in irdma_make_listen_node() [all …]
|
/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/include/hw/xen/ |
H A D | xen-hvm-common.h | 87 void xen_region_add(MemoryListener *listener, MemoryRegionSection *section); 88 void xen_region_del(MemoryListener *listener, MemoryRegionSection *section); 89 void xen_io_add(MemoryListener *listener, MemoryRegionSection *section); 90 void xen_io_del(MemoryListener *listener, MemoryRegionSection *section); 91 void xen_device_realize(DeviceListener *listener, DeviceState *dev); 92 void xen_device_unrealize(DeviceListener *listener, DeviceState *dev);
|
/openbmc/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()
|
/openbmc/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() 388 if (server->listener) { in vhost_user_server_stop() 389 qio_net_listener_disconnect(server->listener); in vhost_user_server_stop() 390 object_unref(OBJECT(server->listener)); in vhost_user_server_stop() 473 QIONetListener *listener; in vhost_user_server_start() local 481 listener = qio_net_listener_new(); in vhost_user_server_start() 482 if (qio_net_listener_open_sync(listener, socket_addr, 1, in vhost_user_server_start() 484 object_unref(OBJECT(listener)); in vhost_user_server_start() 492 .listener = listener, in vhost_user_server_start() [all …]
|
/openbmc/linux/tools/testing/selftests/seccomp/ |
H A D | seccomp_bpf.c | 3365 int status, listener; in TEST() local 3494 int listener; in TEST() local 3637 close(listener); in TEST() 3642 close(listener); in TEST() 3686 close(listener); in TEST() 3759 close(listener); in TEST() 3929 int listener; in TEST() local 3932 if (listener < 0) in TEST() 3938 close(listener); in TEST() 3991 if (listener < 0) in TEST() [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() 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() 293 s->listener = qio_net_listener_new(); in net_stream_server_listening() [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() 490 filep->private_data = listener; in uio_open() 508 kfree(listener); in uio_open() 523 struct uio_device *idev = listener->dev; in uio_fasync() 532 struct uio_device *idev = listener->dev; in uio_release() 540 kfree(listener); in uio_release() 548 struct uio_device *idev = listener->dev; in uio_poll() [all …]
|
/openbmc/qemu/hw/vfio/ |
H A D | common.c | 352 listener); in vfio_ram_discard_notify_discard() 423 ram_discard_listener_init(&vrdl->listener, in vfio_register_ram_discard_listener() 569 VFIOContainer *container = container_of(listener, VFIOContainer, listener); in vfio_listener_region_add() 731 VFIOContainer *container = container_of(listener, VFIOContainer, listener); in vfio_listener_region_del() 822 MemoryListener listener; member 914 dirty.listener = vfio_dirty_tracking_listener; in vfio_dirty_tracking_init() 917 memory_listener_register(&dirty.listener, in vfio_dirty_tracking_init() 927 memory_listener_unregister(&dirty.listener); in vfio_dirty_tracking_init() 1069 VFIOContainer *container = container_of(listener, VFIOContainer, listener); in vfio_listener_log_global_start() 1087 VFIOContainer *container = container_of(listener, VFIOContainer, listener); in vfio_listener_log_global_stop() [all …]
|
/openbmc/linux/drivers/infiniband/hw/qedr/ |
H A D | qedr_iw_cm.c | 135 listener->cm_id->event_handler(listener->cm_id, &event); in qedr_iw_mpa_request() 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() 717 kfree(listener); in qedr_iw_create_listen() 727 if (listener->qed_handle) in qedr_iw_destroy_listen() 729 listener->qed_handle); in qedr_iw_destroy_listen() [all …]
|
/openbmc/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() 162 g_autoptr(GVariant) listener = NULL; in test_dbus_display_console() 199 listener = g_variant_new_fixed_array(G_VARIANT_TYPE_BYTE, in test_dbus_display_console() 208 listener, in test_dbus_display_console()
|
/openbmc/qemu/system/ |
H A D | memory.c | 2408 listener->log_sync(listener, &mrs); in memory_region_sync_dirty_bitmap() 2470 listener->log_clear(listener, &mrs); in memory_region_clear_dirty_bitmap() 3127 listener->begin(listener); in listener_add_address_space() 3131 listener->log_global_start(listener); in listener_add_address_space() 3140 listener->region_add(listener, §ion); in listener_add_address_space() 3147 listener->commit(listener); in listener_add_address_space() 3159 listener->begin(listener); in listener_del_address_space() 3169 listener->region_del(listener, §ion); in listener_del_address_space() 3173 listener->commit(listener); in listener_del_address_space() 3212 if (listener->eventfd_add || listener->eventfd_del) { in memory_listener_register() [all …]
|
/openbmc/linux/net/vmw_vsock/ |
H A D | af_vsock.c | 373 sock_hold(listener); in vsock_add_pending() 383 sock_put(listener); in vsock_remove_pending() 397 sock_hold(listener); in vsock_enqueue_accept() 548 sock_put(listener); in vsock_dequeue_accept() 581 struct sock *listener; in vsock_pending_work() local 587 listener = vsk->listener; in vsock_pending_work() 590 lock_sock(listener); in vsock_pending_work() 622 sock_put(listener); in vsock_pending_work() 761 vsk->listener = NULL; in __vsock_create() 1503 listener = sock->sk; in vsock_accept() [all …]
|