Home
last modified time | relevance | path

Searched refs:eventfd (Results 1 – 25 of 150) sorted by relevance

123456

/external/crosvm/cros_async/src/
Devent.rs52 let eventfd = EventFd::new().unwrap(); in next_val_reads_value() localVariable
53 eventfd.write(0xaa).unwrap(); in next_val_reads_value()
55 let val = ex.run_until(go(eventfd, &ex)).unwrap(); in next_val_reads_value()
65 let eventfd = EventFd::new().unwrap(); in next_val_reads_value_poll_and_ring() localVariable
66 eventfd.write(0xaa).unwrap(); in next_val_reads_value_poll_and_ring()
69 .run_until(go(EventAsync::new_uring(eventfd, &uring_ex).unwrap())) in next_val_reads_value_poll_and_ring()
73 let eventfd = EventFd::new().unwrap(); in next_val_reads_value_poll_and_ring() localVariable
74 eventfd.write(0xaa).unwrap(); in next_val_reads_value_poll_and_ring()
77 .run_until(go(EventAsync::new_poll(eventfd, &poll_ex).unwrap())) in next_val_reads_value_poll_and_ring()
Dio_ext.rs367 let eventfd = EventFd::new().unwrap(); in read_eventfds() localVariable
368 eventfd.write(0x55).unwrap(); in read_eventfds()
370 let uring_source = async_uring_from(eventfd, &ex).unwrap(); in read_eventfds()
374 let eventfd = EventFd::new().unwrap(); in read_eventfds() localVariable
375 eventfd.write(0xaa).unwrap(); in read_eventfds()
377 let poll_source = async_poll_from(eventfd, &poll_ex).unwrap(); in read_eventfds()
/external/libwebsockets/lib/event-libs/glib/
Dglib.c97 struct lws_pollfd eventfd; in lws_glib_dispatch() local
101 eventfd.revents = cond; in lws_glib_dispatch()
106 eventfd.revents |= LWS_POLLIN; in lws_glib_dispatch()
108 eventfd.revents |= LWS_POLLOUT; in lws_glib_dispatch()
110 eventfd.revents |= LWS_POLLHUP; in lws_glib_dispatch()
112 eventfd.revents |= LWS_POLLHUP; in lws_glib_dispatch()
114 eventfd.events = eventfd.revents; in lws_glib_dispatch()
115 eventfd.fd = sub->wsi->desc.sockfd; in lws_glib_dispatch()
118 eventfd.fd, eventfd.revents); in lws_glib_dispatch()
124 lws_service_fd_tsi(sub->wsi->context, &eventfd, sub->wsi->tsi); in lws_glib_dispatch()
/external/libwebsockets/lib/event-libs/libev/
Dlibev.c85 struct lws_pollfd eventfd; in lws_accept_cb() local
91 eventfd.fd = watcher->fd; in lws_accept_cb()
92 eventfd.events = 0; in lws_accept_cb()
93 eventfd.revents = EV_NONE; in lws_accept_cb()
96 eventfd.events |= LWS_POLLIN; in lws_accept_cb()
97 eventfd.revents |= LWS_POLLIN; in lws_accept_cb()
100 eventfd.events |= LWS_POLLOUT; in lws_accept_cb()
101 eventfd.revents |= LWS_POLLOUT; in lws_accept_cb()
107 lws_service_fd_tsi(context, &eventfd, (int)wsi->tsi); in lws_accept_cb()
/external/rust/crates/vmm_vhost/src/vhost_kern/
Dvsock.rs160 let eventfd = EventFd::new().unwrap(); in test_vsock_ioctls() localVariable
161 vsock.set_log_fd(eventfd.as_raw_fd()).unwrap(); in test_vsock_ioctls()
176 vsock.set_vring_call(0, &eventfd).unwrap(); in test_vsock_ioctls()
177 vsock.set_vring_kick(0, &eventfd).unwrap(); in test_vsock_ioctls()
178 vsock.set_vring_err(0, &eventfd).unwrap(); in test_vsock_ioctls()
/external/libusb/libusb/os/
Devents_posix.c34 #define EVENT_READ_FD(e) ((e)->eventfd)
35 #define EVENT_WRITE_FD(e) ((e)->eventfd)
50 event->eventfd = eventfd(0, EFD_NONBLOCK | EFD_CLOEXEC); in usbi_create_event()
51 if (event->eventfd == -1) { in usbi_create_event()
116 if (close(event->eventfd) == -1) in usbi_destroy_event()
Devents_posix.h31 int eventfd; member
33 #define USBI_EVENT_OS_HANDLE(e) ((e)->eventfd)
/external/libwebsockets/lib/event-libs/libevent/
Dlibevent.c98 struct lws_pollfd eventfd; in lws_event_cb() local
114 eventfd.fd = sock_fd; in lws_event_cb()
115 eventfd.events = 0; in lws_event_cb()
116 eventfd.revents = 0; in lws_event_cb()
118 eventfd.events |= LWS_POLLIN; in lws_event_cb()
119 eventfd.revents |= LWS_POLLIN; in lws_event_cb()
122 eventfd.events |= LWS_POLLOUT; in lws_event_cb()
123 eventfd.revents |= LWS_POLLOUT; in lws_event_cb()
134 lws_service_fd_tsi(context, &eventfd, wsi->tsi); in lws_event_cb()
/external/tinyalsa_new/src/
Dmixer_plugin.c141 eventfd_write(plugin->eventfd, 1); in mixer_plug_notifier_cb()
158 eventfd_read(plugin->eventfd, &evfd); in mixer_plug_read_event()
181 eventfd_read(plugin->eventfd, &evfd); in mixer_plug_subscribe_events()
195 if (plugin->eventfd != -1) { in mixer_plug_get_poll_fd()
196 pfd[count].fd = plugin->eventfd; in mixer_plug_get_poll_fd()
344 eventfd_read(plugin->eventfd, &evfd); in mixer_plug_close()
460 plugin->eventfd = eventfd(0, 0); in mixer_plugin_open()
/external/fastrpc/src/
Dlistener_android.c91 int eventfd; member
95 { [0 ... NUM_DOMAINS_EXTEND - 1] = { .thread = 0, .eventfd = -1 } };
384 eventfd_write(me->eventfd, event); in listener2()
432 if(me->eventfd != -1) { in listener_android_domain_deinit()
433 close(me->eventfd); in listener_android_domain_deinit()
434 me->eventfd = -1; in listener_android_domain_deinit()
442 VERIFYC(-1 != (me->eventfd = eventfd(0, 0)), AEE_EINVALIDFD); in listener_android_domain_init()
465 VERIFYC(-1 != me->eventfd, AEE_EINVALIDFD); in listener_android_geteventfd()
466 *fd = me->eventfd; in listener_android_geteventfd()
/external/tinyalsa/
Dmixer_plugin.c136 eventfd_write(plugin->eventfd, 1); in mixer_plug_notifier_cb()
154 eventfd_read(plugin->eventfd, &evfd); in mixer_plug_read_event()
178 eventfd_read(plugin->eventfd, &evfd); in mixer_plug_subscribe_events()
192 if (plugin->eventfd != -1) { in mixer_plug_get_poll_fd()
193 pfd[count].fd = plugin->eventfd; in mixer_plug_get_poll_fd()
347 eventfd_read(plugin->eventfd, &evfd); in mixer_plug_close()
482 plugin->eventfd = eventfd(0, 0); in mixer_plugin_open()
/external/libwebsockets/lib/event-libs/libuv/
Dlibuv.c85 struct lws_pollfd eventfd; in lws_io_cb() local
91 eventfd.fd = watcher->socket; in lws_io_cb()
93 eventfd.fd = watcher->io_watcher.fd; in lws_io_cb()
95 eventfd.events = 0; in lws_io_cb()
96 eventfd.revents = 0; in lws_io_cb()
108 eventfd.events |= LWS_POLLHUP; in lws_io_cb()
109 eventfd.revents |= LWS_POLLHUP; in lws_io_cb()
112 eventfd.events |= LWS_POLLIN; in lws_io_cb()
113 eventfd.revents |= LWS_POLLIN; in lws_io_cb()
116 eventfd.events |= LWS_POLLOUT; in lws_io_cb()
[all …]
/external/rust/crates/nix/src/sys/
Deventfd.rs14 pub fn eventfd(initval: libc::c_uint, flags: EfdFlags) -> Result<RawFd> { in eventfd() function
15 let res = unsafe { libc::eventfd(initval, flags.bits()) }; in eventfd()
/external/rust/crates/vmm_vhost/src/vhost_user/
Dmod.rs366 let eventfd = sys_util::EventFd::new().unwrap(); in test_master_slave_process() localVariable
372 mmap_handle: eventfd.as_raw_fd(), in test_master_slave_process()
387 master.set_slave_request_fd(eventfd.as_raw_fd()).unwrap(); in test_master_slave_process()
391 master.set_log_base(0, Some(eventfd.as_raw_fd())).unwrap(); in test_master_slave_process()
392 master.set_log_fd(eventfd.as_raw_fd()).unwrap(); in test_master_slave_process()
406 master.set_vring_call(0, &eventfd).unwrap(); in test_master_slave_process()
407 master.set_vring_kick(0, &eventfd).unwrap(); in test_master_slave_process()
408 master.set_vring_err(0, &eventfd).unwrap(); in test_master_slave_process()
/external/libusb/
Dconfigure.ac216 dnl eventfd support
218 AC_ARG_ENABLE([eventfd], optenable
219 [AS_HELP_STRING([--enable-eventfd], [use eventfd for signalling [default=auto]])],
223 AC_CHECK_HEADER([sys/eventfd.h], [eventfd_h=yes], [eventfd_h=])
225 …CLS([EFD_NONBLOCK, EFD_CLOEXEC], [eventfd_h_ok=yes], [eventfd_h_ok=], [[#include <sys/eventfd.h>]])
227 AC_CHECK_FUNC([eventfd], [eventfd_ok=yes], [eventfd_ok=])
229 AC_DEFINE([HAVE_EVENTFD], [1], [Define to 1 if the system has eventfd functionality.])
231 AC_MSG_ERROR([eventfd() function not found; glibc 2.9+ required])
234 AC_MSG_ERROR([eventfd header not usable; glibc 2.9+ required])
237 AC_MSG_ERROR([eventfd header not available; glibc 2.9+ required])
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/
Dwakeup_fd_eventfd.cc35 fd_info->read_fd = eventfd(0, EFD_NONBLOCK | EFD_CLOEXEC); in eventfd_create()
72 const int efd = eventfd(0, 0); in eventfd_check_availability()
/external/grpc-grpc/src/core/lib/iomgr/
Dwakeup_fd_eventfd.cc35 int efd = eventfd(0, EFD_NONBLOCK | EFD_CLOEXEC); in eventfd_create()
73 const int efd = eventfd(0, 0); in eventfd_check_availability()
/external/rust/crates/mio/src/sys/unix/
Dwaker.rs2 mod eventfd { module
23 syscall!(eventfd(0, libc::EFD_CLOEXEC | libc::EFD_NONBLOCK)).and_then(|fd| { in new()
62 pub use self::eventfd::Waker;
/external/grpc-grpc/test/core/iomgr/
Dev_epollex_linux_test.cc49 ev_fd1 = eventfd(0, EFD_NONBLOCK | EFD_CLOEXEC); in test_pollable_owner_fd()
50 ev_fd2 = eventfd(0, EFD_NONBLOCK | EFD_CLOEXEC); in test_pollable_owner_fd()
/external/rust/crates/vmm_vhost/src/
Dbackend.rs473 let eventfd = EventFd::new().unwrap(); in test_vring_backend_mut() localVariable
474 b.set_vring_call(1, &eventfd).unwrap(); in test_vring_backend_mut()
475 b.set_vring_kick(1, &eventfd).unwrap(); in test_vring_backend_mut()
476 b.set_vring_err(1, &eventfd).unwrap(); in test_vring_backend_mut()
/external/llvm-project/compiler-rt/test/msan/Linux/
Deventfd.cpp9 int efd = eventfd(42, 0); in main()
/external/compiler-rt/test/msan/Linux/
Deventfd.cc9 int efd = eventfd(42, 0); in main()
/external/libiio/src/iiod/
Dops.c47 int eventfd; member
63 ret = write(thd->eventfd, &e, sizeof(e)); in thd_entry_event_signal()
76 pfd[0].fd = thd->eventfd; in thd_entry_event_wait()
92 ret = read(thd->eventfd, &e, sizeof(e)); in thd_entry_event_wait()
846 close(t->eventfd); in free_thd_entry()
905 thd->eventfd = eventfd(0, EFD_CLOEXEC | EFD_NONBLOCK); in open_dev_helper()
1045 close(thd->eventfd); in open_dev_helper()
1377 pdata.aio_eventfd = eventfd(0, EFD_CLOEXEC | EFD_NONBLOCK); in interpreter()
/external/strace/
Deventfd.c49 SYS_FUNC(eventfd) in SYS_FUNC() argument
/external/crosvm/sys_util/src/
Ddescriptor.rs262 let ret = unsafe { libc::eventfd(0, 0) }; in clone_equality()
275 let ret = unsafe { libc::eventfd(0, 0) }; in clone_equality()

123456