Home
last modified time | relevance | path

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

12345

/openbmc/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 …]
/openbmc/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 …]
/openbmc/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
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 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);
/openbmc/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 …]
/openbmc/qemu/migration/
H A Dsocket.c140 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 Dsclp_sd.c119 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 Duser-trap.c105 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 Dsensor.cpp72 [](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 Dmetric.cpp26 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 Dtrace_cm.h43 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 Dcm.c1856 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 Dsched-seccomp-notify.c68 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 Dxen-hvm-common.h87 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 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()
/openbmc/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()
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 Dseccomp_bpf.c3365 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 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()
293 s->listener = qio_net_listener_new(); in net_stream_server_listening()
[all …]
/openbmc/linux/drivers/uio/
H A Duio.c464 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 Dcommon.c352 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 Dqedr_iw_cm.c135 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 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()
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 Dmemory.c2408 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, &section); 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, &section); 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 Daf_vsock.c373 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 …]

12345