Home
last modified time | relevance | path

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

123

/third_party/libwebsockets/lib/event-libs/glib/
Dglib.c115 struct lws_pollfd eventfd; in lws_glib_dispatch() local
119 eventfd.revents = (short)cond; in lws_glib_dispatch()
124 eventfd.revents |= LWS_POLLIN; in lws_glib_dispatch()
126 eventfd.revents |= LWS_POLLOUT; in lws_glib_dispatch()
128 eventfd.revents |= LWS_POLLHUP; in lws_glib_dispatch()
130 eventfd.revents |= LWS_POLLHUP; in lws_glib_dispatch()
132 eventfd.events = eventfd.revents; in lws_glib_dispatch()
133 eventfd.fd = sub->wsi->desc.sockfd; in lws_glib_dispatch()
136 eventfd.fd, eventfd.revents); in lws_glib_dispatch()
142 lws_service_fd_tsi(sub->wsi->a.context, &eventfd, sub->wsi->tsi); in lws_glib_dispatch()
/third_party/libwebsockets/lib/event-libs/uloop/
Duloop.c102 struct lws_pollfd eventfd; in lws_uloop_cb() local
104 eventfd.fd = wu->wsi->desc.sockfd; in lws_uloop_cb()
105 eventfd.events = 0; in lws_uloop_cb()
106 eventfd.revents = 0; in lws_uloop_cb()
109 eventfd.events = LWS_POLLIN; in lws_uloop_cb()
110 eventfd.revents = LWS_POLLIN; in lws_uloop_cb()
113 eventfd.events |= LWS_POLLOUT; in lws_uloop_cb()
114 eventfd.revents |= LWS_POLLOUT; in lws_uloop_cb()
121 lws_service_fd_tsi(context, &eventfd, wu->wsi->tsi); in lws_uloop_cb()
/third_party/musl/libc-test/src/functionalext/supplement/linux/
Deventfd.c26 int ret = eventfd(0, EFD_SEMAPHORE); in eventfd_0100()
37 int ret = eventfd(0, EFD_CLOEXEC); in eventfd_0200()
48 int ret = eventfd(0, EFD_NONBLOCK); in eventfd_0300()
Deventfd_read.c28 int fd = eventfd(initial_value, O_NONBLOCK); in eventfd_read_0100()
68 int fd = eventfd(initial_value, O_NONBLOCK); in eventfd_read_0300()
Deventfd_write.c29 int fd = eventfd(initial_value, O_NONBLOCK); in eventfd_write_0100()
78 int fd = eventfd(initial_value, O_NONBLOCK); in eventfd_write_0300()
/third_party/libwebsockets/lib/event-libs/sdevent/
Dsdevent.c98 struct lws_pollfd eventfd; in sock_accept_handler() local
106 eventfd.fd = fd; in sock_accept_handler()
107 eventfd.events = 0; in sock_accept_handler()
108 eventfd.revents = 0; in sock_accept_handler()
111 eventfd.events |= LWS_POLLIN; in sock_accept_handler()
112 eventfd.revents |= LWS_POLLIN; in sock_accept_handler()
116 eventfd.events |= LWS_POLLOUT; in sock_accept_handler()
117 eventfd.revents |= LWS_POLLOUT; in sock_accept_handler()
123 lws_service_fd_tsi(context, &eventfd, wsi->tsi); in sock_accept_handler()
/third_party/libwebsockets/lib/event-libs/libev/
Dlibev.c95 struct lws_pollfd eventfd; in lws_accept_cb() local
101 eventfd.fd = watcher->fd; in lws_accept_cb()
102 eventfd.events = 0; in lws_accept_cb()
103 eventfd.revents = EV_NONE; in lws_accept_cb()
106 eventfd.events |= LWS_POLLIN; in lws_accept_cb()
107 eventfd.revents |= LWS_POLLIN; in lws_accept_cb()
110 eventfd.events |= LWS_POLLOUT; in lws_accept_cb()
111 eventfd.revents |= LWS_POLLOUT; in lws_accept_cb()
118 lws_service_fd_tsi(context, &eventfd, (int)wsi->tsi); in lws_accept_cb()
/third_party/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)
/third_party/libwebsockets/lib/event-libs/libevent/
Dlibevent.c109 struct lws_pollfd eventfd; in lws_event_cb() local
125 eventfd.fd = sock_fd; in lws_event_cb()
126 eventfd.events = 0; in lws_event_cb()
127 eventfd.revents = 0; in lws_event_cb()
129 eventfd.events |= LWS_POLLIN; in lws_event_cb()
130 eventfd.revents |= LWS_POLLIN; in lws_event_cb()
133 eventfd.events |= LWS_POLLOUT; in lws_event_cb()
134 eventfd.revents |= LWS_POLLOUT; in lws_event_cb()
145 lws_service_fd_tsi(context, &eventfd, wsi->tsi); in lws_event_cb()
/third_party/libwebsockets/lib/event-libs/libuv/
Dlibuv.c99 struct lws_pollfd eventfd; in lws_io_cb() local
114 eventfd.fd = watcher->socket; in lws_io_cb()
116 eventfd.fd = watcher->io_watcher.fd; in lws_io_cb()
118 eventfd.events = 0; in lws_io_cb()
119 eventfd.revents = 0; in lws_io_cb()
131 eventfd.events |= LWS_POLLHUP; in lws_io_cb()
132 eventfd.revents |= LWS_POLLHUP; in lws_io_cb()
135 eventfd.events |= LWS_POLLIN; in lws_io_cb()
136 eventfd.revents |= LWS_POLLIN; in lws_io_cb()
139 eventfd.events |= LWS_POLLOUT; in lws_io_cb()
[all …]
/third_party/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 …]
/third_party/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()
Dis_epollexclusive_available.cc51 int evfd = eventfd(0, EFD_NONBLOCK | EFD_CLOEXEC); in grpc_is_epollexclusive_available()
/third_party/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()
/third_party/boost/libs/asio/include/boost/asio/detail/impl/
Deventfd_select_interrupter.ipp29 # include <sys/eventfd.h>
59 ::eventfd(0, EFD_CLOEXEC | EFD_NONBLOCK);
66 write_descriptor_ = read_descriptor_ = ::eventfd(0, 0);
/third_party/boost/boost/asio/detail/impl/
Deventfd_select_interrupter.ipp29 # include <sys/eventfd.h>
59 ::eventfd(0, EFD_CLOEXEC | EFD_NONBLOCK);
66 write_descriptor_ = read_descriptor_ = ::eventfd(0, 0);
/third_party/musl/include/sys/
Deventfd.h17 int eventfd(unsigned int, int);
/third_party/musl/porting/liteos_m_iccarm/kernel/include/sys/
Deventfd.h17 int eventfd(unsigned int, int);
/third_party/musl/ndk_musl_include/sys/
Deventfd.h17 int eventfd(unsigned int, int);
/third_party/musl/porting/liteos_m/kernel/include/sys/
Deventfd.h17 int eventfd(unsigned int, int);
/third_party/musl/porting/uniproton/kernel/include/sys/
Deventfd.h17 int eventfd(unsigned int, int);
/third_party/musl/src/linux/
Deventfd.c6 int eventfd(unsigned int count, int flags) in eventfd() function
/third_party/pulseaudio/src/pulsecore/
Dfdsem.c63 if ((f->efd = eventfd(0, EFD_CLOEXEC)) >= 0) in pa_fdsem_new()
110 if ((f->efd = eventfd(0, EFD_CLOEXEC)) < 0) { in pa_fdsem_new_shm()
/third_party/grpc/doc/core/
Dcombiner-explainer.md141 eventfd.wakeup()
145 eventfd.consume();
149 eventfd.wakeup(); // spray across as many threads as are waiting on this workqueue

123