| /dports/devel/grpc134/grpc-1.34.1/src/core/lib/iomgr/ |
| H A D | is_epollexclusive_available.cc | 51 int evfd = eventfd(0, EFD_NONBLOCK | EFD_CLOEXEC); in grpc_is_epollexclusive_available() local
52 if (evfd < 0) { in grpc_is_epollexclusive_available()
70 if (epoll_ctl(fd, EPOLL_CTL_ADD, evfd, &ev) != 0) { in grpc_is_epollexclusive_available()
81 close(evfd); in grpc_is_epollexclusive_available()
93 close(evfd); in grpc_is_epollexclusive_available()
98 if (epoll_ctl(fd, EPOLL_CTL_ADD, evfd, &ev) != 0) { in grpc_is_epollexclusive_available()
107 close(evfd); in grpc_is_epollexclusive_available()
110 close(evfd); in grpc_is_epollexclusive_available()
|
| /dports/devel/grpc/grpc-1.42.0/src/core/lib/iomgr/ |
| H A D | is_epollexclusive_available.cc | 51 int evfd = eventfd(0, EFD_NONBLOCK | EFD_CLOEXEC); in grpc_is_epollexclusive_available() local
52 if (evfd < 0) { in grpc_is_epollexclusive_available()
70 if (epoll_ctl(fd, EPOLL_CTL_ADD, evfd, &ev) != 0) { in grpc_is_epollexclusive_available()
81 close(evfd); in grpc_is_epollexclusive_available()
93 close(evfd); in grpc_is_epollexclusive_available()
98 if (epoll_ctl(fd, EPOLL_CTL_ADD, evfd, &ev) != 0) { in grpc_is_epollexclusive_available()
107 close(evfd); in grpc_is_epollexclusive_available()
110 close(evfd); in grpc_is_epollexclusive_available()
|
| /dports/devel/pecl-grpc/grpc-1.42.0/src/core/lib/iomgr/ |
| H A D | is_epollexclusive_available.cc | 51 int evfd = eventfd(0, EFD_NONBLOCK | EFD_CLOEXEC); in grpc_is_epollexclusive_available() local
52 if (evfd < 0) { in grpc_is_epollexclusive_available()
70 if (epoll_ctl(fd, EPOLL_CTL_ADD, evfd, &ev) != 0) { in grpc_is_epollexclusive_available()
81 close(evfd); in grpc_is_epollexclusive_available()
93 close(evfd); in grpc_is_epollexclusive_available()
98 if (epoll_ctl(fd, EPOLL_CTL_ADD, evfd, &ev) != 0) { in grpc_is_epollexclusive_available()
107 close(evfd); in grpc_is_epollexclusive_available()
110 close(evfd); in grpc_is_epollexclusive_available()
|
| /dports/devel/py-grpcio/grpcio-1.43.0/src/core/lib/iomgr/ |
| H A D | is_epollexclusive_available.cc | 51 int evfd = eventfd(0, EFD_NONBLOCK | EFD_CLOEXEC); in grpc_is_epollexclusive_available() local
52 if (evfd < 0) { in grpc_is_epollexclusive_available()
70 if (epoll_ctl(fd, EPOLL_CTL_ADD, evfd, &ev) != 0) { in grpc_is_epollexclusive_available()
81 close(evfd); in grpc_is_epollexclusive_available()
93 close(evfd); in grpc_is_epollexclusive_available()
98 if (epoll_ctl(fd, EPOLL_CTL_ADD, evfd, &ev) != 0) { in grpc_is_epollexclusive_available()
107 close(evfd); in grpc_is_epollexclusive_available()
110 close(evfd); in grpc_is_epollexclusive_available()
|
| /dports/devel/grpc130/grpc-1.30.2/src/core/lib/iomgr/ |
| H A D | is_epollexclusive_available.cc | 51 int evfd = eventfd(0, EFD_NONBLOCK | EFD_CLOEXEC); in grpc_is_epollexclusive_available() local
52 if (evfd < 0) { in grpc_is_epollexclusive_available()
70 if (epoll_ctl(fd, EPOLL_CTL_ADD, evfd, &ev) != 0) { in grpc_is_epollexclusive_available()
81 close(evfd); in grpc_is_epollexclusive_available()
93 close(evfd); in grpc_is_epollexclusive_available()
96 close(evfd); in grpc_is_epollexclusive_available()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/lib/iomgr/ |
| H A D | is_epollexclusive_available.cc | 51 int evfd = eventfd(0, EFD_NONBLOCK | EFD_CLOEXEC); in grpc_is_epollexclusive_available() local
52 if (evfd < 0) { in grpc_is_epollexclusive_available()
70 if (epoll_ctl(fd, EPOLL_CTL_ADD, evfd, &ev) != 0) { in grpc_is_epollexclusive_available()
81 close(evfd); in grpc_is_epollexclusive_available()
93 close(evfd); in grpc_is_epollexclusive_available()
96 close(evfd); in grpc_is_epollexclusive_available()
|
| /dports/sysutils/sensu-go/sensu-go-5.11.1/vendor/github.com/libp2p/go-reuseport/singlepoll/ |
| H A D | linux.go | 89 evfd, err := eventfd.New()
99 Fd: int32(evfd.Fd()),
101 unix.EpollCtl(epfd, unix.EPOLL_CTL_ADD, evfd.Fd(), &event)
103 go poller(epfd, evfd)
117 evfd.WriteEvents(1)
172 func poller(epfd int, evfd *eventfd.EventFD) {
194 if int(events[i].Fd) == evfd.Fd() {
196 evfd.Close()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/tools/usb/ffs-aio-example/simple/device_app/ |
| H A D | aio_simple.c | 214 int evfd; in main() local
267 evfd = eventfd(0, 0); in main()
268 if (evfd < 0) { in main()
282 FD_SET(evfd, &rfds); in main()
284 ret = select(((ep0 > evfd) ? ep0 : evfd)+1, in main()
301 if (FD_ISSET(evfd, &rfds)) { in main()
303 ret = read(evfd, &ev_cnt, sizeof(ev_cnt)); in main()
329 iocb_in->u.c.resfd = evfd; in main()
343 iocb_out->u.c.resfd = evfd; in main()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/tools/usb/ffs-aio-example/simple/device_app/ |
| H A D | aio_simple.c | 214 int evfd; in main() local
267 evfd = eventfd(0, 0); in main()
268 if (evfd < 0) { in main()
282 FD_SET(evfd, &rfds); in main()
284 ret = select(((ep0 > evfd) ? ep0 : evfd)+1, in main()
301 if (FD_ISSET(evfd, &rfds)) { in main()
303 ret = read(evfd, &ev_cnt, sizeof(ev_cnt)); in main()
329 iocb_in->u.c.resfd = evfd; in main()
343 iocb_out->u.c.resfd = evfd; in main()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/tools/usb/ffs-aio-example/simple/device_app/ |
| H A D | aio_simple.c | 214 int evfd; in main() local
267 evfd = eventfd(0, 0); in main()
268 if (evfd < 0) { in main()
282 FD_SET(evfd, &rfds); in main()
284 ret = select(((ep0 > evfd) ? ep0 : evfd)+1, in main()
301 if (FD_ISSET(evfd, &rfds)) { in main()
303 ret = read(evfd, &ev_cnt, sizeof(ev_cnt)); in main()
329 iocb_in->u.c.resfd = evfd; in main()
343 iocb_out->u.c.resfd = evfd; in main()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/tools/usb/ffs-aio-example/multibuff/device_app/ |
| H A D | aio_multibuff.c | 244 int evfd; in main() local
293 evfd = eventfd(0, 0); in main()
294 if (evfd < 0) { in main()
305 FD_SET(evfd, &rfds); in main()
307 ret = select(((ep0 > evfd) ? ep0 : evfd)+1, in main()
337 iobuf[i].iocb[j]->u.c.resfd = evfd; in main()
349 if (!FD_ISSET(evfd, &rfds)) in main()
353 ret = read(evfd, &ev_cnt, sizeof(ev_cnt)); in main()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/tools/usb/ffs-aio-example/multibuff/device_app/ |
| H A D | aio_multibuff.c | 244 int evfd; in main() local
293 evfd = eventfd(0, 0); in main()
294 if (evfd < 0) { in main()
305 FD_SET(evfd, &rfds); in main()
307 ret = select(((ep0 > evfd) ? ep0 : evfd)+1, in main()
337 iobuf[i].iocb[j]->u.c.resfd = evfd; in main()
349 if (!FD_ISSET(evfd, &rfds)) in main()
353 ret = read(evfd, &ev_cnt, sizeof(ev_cnt)); in main()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/tools/usb/ffs-aio-example/multibuff/device_app/ |
| H A D | aio_multibuff.c | 244 int evfd; in main() local
293 evfd = eventfd(0, 0); in main()
294 if (evfd < 0) { in main()
305 FD_SET(evfd, &rfds); in main()
307 ret = select(((ep0 > evfd) ? ep0 : evfd)+1, in main()
337 iobuf[i].iocb[j]->u.c.resfd = evfd; in main()
349 if (!FD_ISSET(evfd, &rfds)) in main()
353 ret = read(evfd, &ev_cnt, sizeof(ev_cnt)); in main()
|
| /dports/sysutils/flowgger/flowgger-0.2.10/cargo-crates/may-0.3.17/src/io/sys/unix/ |
| H A D | epoll.rs | 29 evfd: RawFd, field
40 let evfd = create_eventfd()?; in new() localVariable
43 epoll_ctl(epfd, EpollOp::EpollCtlAdd, evfd, &mut info).map_err(from_nix_error)?; in new()
47 evfd, in new()
56 let _ = close(self.evfd); in drop()
112 read(single_selector.evfd, &mut buf).ok(); in select()
159 let ret = write(unsafe { self.vec.get_unchecked(id) }.evfd, buf); in wakeup()
|
| /dports/net/nng/nng-1.5.2/src/platform/posix/ |
| H A D | posix_pollq_epoll.c | 57 int evfd; // event fd (to wake us for other stuff) member
210 if (write(pq->evfd, &one, sizeof(one)) != sizeof(one)) { in nni_posix_pfd_fini()
268 if (read(pq->evfd, &clear, sizeof(clear)) != in nni_posix_poll_thr()
316 if (write(pq->evfd, &one, sizeof(one)) != sizeof(one)) { in nni_posix_pollq_destroy()
325 close(pq->evfd); in nni_posix_pollq_destroy()
354 pq->evfd = fd; in nni_posix_pollq_add_eventfd()
388 (void) close(pq->evfd); in nni_posix_pollq_create()
|
| /dports/www/trafficserver/trafficserver-9.1.1/iocore/eventsystem/ |
| H A D | UnixEThread.cc | 92 evfd = eventfd(0, EFD_NONBLOCK | EFD_CLOEXEC); in EThread()
93 if (evfd < 0) { in EThread()
95 evfd = eventfd(0, 0); in EThread()
96 if (evfd < 0) { in EThread()
97 Fatal("EThread::EThread: %d=eventfd(0,0),errno(%d)", evfd, errno); in EThread()
100 Fatal("EThread::EThread: %d=eventfd(0,EFD_NONBLOCK | EFD_CLOEXEC),errno(%d)", evfd, errno); in EThread()
|
| /dports/multimedia/vlc/vlc-3.0.16/modules/access/linsys/ |
| H A D | linsys_hdsdi.c | 159 int evfd; member
242 p_sys->evfd = eventfd( 0, EFD_CLOEXEC ); in Open()
243 if( p_sys->evfd == -1 ) in Open()
248 vlc_close( p_sys->evfd ); in Open()
268 write( p_sys->evfd, &(uint64_t){ 1 }, sizeof (uint64_t)); in Close()
270 vlc_close( p_sys->evfd ); in Close()
686 pfd[1].fd = p_sys->evfd; in InitCapture()
936 pfd[0].fd = p_sys->evfd; in Capture()
|
| /dports/www/trafficserver/trafficserver-9.1.1/iocore/aio/ |
| H A D | AIO.cc | 570 io_set_eventfd(&op->aiocb, t->evfd); in ink_aio_read()
584 io_set_eventfd(&op->aiocb, t->evfd); in ink_aio_write()
603 io_set_eventfd(&op->aiocb, t->evfd); in ink_aio_readv()
633 io_set_eventfd(&op->aiocb, t->evfd); in ink_aio_writev()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/tools/testing/selftests/filesystems/epoll/ |
| H A D | epoll_wakeup_test.c | 3164 int evfd[EPOLL60_EVENTS_NR]; member
3244 ASSERT_GE(ctx.evfd[i], 0); in TEST()
3247 e.data.fd = ctx.evfd[i]; in TEST()
3261 ARRAY_SIZE(ctx.evfd)) in TEST()
3296 close(ctx.evfd[i]); in TEST()
3302 int evfd; member
3311 write(ctx->evfd, &l, sizeof(l)); in epoll61_write_eventfd()
3329 write(ctx->evfd, &l, sizeof(l)); in epoll61_epoll_with_timeout()
3351 ctx.evfd = eventfd(0, EFD_NONBLOCK); in TEST()
3352 ASSERT_GE(ctx.evfd, 0); in TEST()
[all …]
|
| /dports/multimedia/libv4l/linux-5.13-rc2/tools/testing/selftests/filesystems/epoll/ |
| H A D | epoll_wakeup_test.c | 3164 int evfd[EPOLL60_EVENTS_NR]; member
3244 ASSERT_GE(ctx.evfd[i], 0); in TEST()
3247 e.data.fd = ctx.evfd[i]; in TEST()
3261 ARRAY_SIZE(ctx.evfd)) in TEST()
3296 close(ctx.evfd[i]); in TEST()
3302 int evfd; member
3311 write(ctx->evfd, &l, sizeof(l)); in epoll61_write_eventfd()
3329 write(ctx->evfd, &l, sizeof(l)); in epoll61_epoll_with_timeout()
3351 ctx.evfd = eventfd(0, EFD_NONBLOCK); in TEST()
3352 ASSERT_GE(ctx.evfd, 0); in TEST()
[all …]
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/tools/testing/selftests/filesystems/epoll/ |
| H A D | epoll_wakeup_test.c | 3164 int evfd[EPOLL60_EVENTS_NR]; member
3244 ASSERT_GE(ctx.evfd[i], 0); in TEST()
3247 e.data.fd = ctx.evfd[i]; in TEST()
3261 ARRAY_SIZE(ctx.evfd)) in TEST()
3296 close(ctx.evfd[i]); in TEST()
3302 int evfd; member
3311 write(ctx->evfd, &l, sizeof(l)); in epoll61_write_eventfd()
3329 write(ctx->evfd, &l, sizeof(l)); in epoll61_epoll_with_timeout()
3351 ctx.evfd = eventfd(0, EFD_NONBLOCK); in TEST()
3352 ASSERT_GE(ctx.evfd, 0); in TEST()
[all …]
|
| /dports/devel/android-tools-adb/platform_system_core-android-9.0.0_r3/lmkd/ |
| H A D | lmkd.c | 1340 int evfd; in init_mp_common() local
1360 evfd = eventfd(0, EFD_NONBLOCK | EFD_CLOEXEC); in init_mp_common()
1361 if (evfd < 0) { in init_mp_common()
1366 ret = snprintf(buf, sizeof(buf), "%d %d %s", evfd, mpfd, levelstr); in init_mp_common()
1384 ret = epoll_ctl(epollfd, EPOLL_CTL_ADD, evfd, &epev); in init_mp_common()
1390 mpevfd[level] = evfd; in init_mp_common()
1395 close(evfd); in init_mp_common()
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbrpc/ |
| H A D | AsyncFileKAIO.actor.h | 171 ctx.evfd = ev->getFD(); in init()
177 static int get_eventfd() { return ctx.evfd; } in get_eventfd()
501 int evfd; member
521 …Context() : iocx(0), evfd(-1), outstanding(0), opsIssued(0), ioStallBegin(0), fallocateSupported(t… in Context()
621 io->eventfd = ctx.evfd; in enqueue()
|
| /dports/www/trafficserver/trafficserver-9.1.1/iocore/net/ |
| H A D | UnixNet.cc | 225 ATS_UNUSED_RETURN(read(thread->evfd, &counter, sizeof(uint64_t))); in net_signal_hook_callback()
260 thread->ep->start(pd, thread->evfd, nullptr, EVENTIO_READ); in initialize_thread_for_net()
562 ATS_UNUSED_RETURN(write(thread->evfd, &counter, sizeof(uint64_t))); in signalActivity()
|
| /dports/devel/android-tools-fastboot/platform_system_core-platform-tools-29.0.5/lmkd/ |
| H A D | lmkd.c | 2549 int evfd; in init_mp_common() local
2570 evfd = eventfd(0, EFD_NONBLOCK | EFD_CLOEXEC); in init_mp_common()
2571 if (evfd < 0) { in init_mp_common()
2576 ret = snprintf(buf, sizeof(buf), "%d %d %s", evfd, mpfd, levelstr); in init_mp_common()
2594 ret = epoll_ctl(epollfd, EPOLL_CTL_ADD, evfd, &epev); in init_mp_common()
2600 mpevfd[level] = evfd; in init_mp_common()
2605 close(evfd); in init_mp_common()
|