| /aosp_15_r20/external/linux-kselftest/tools/testing/selftests/filesystems/epoll/ |
| H A D | epoll_wakeup_test.c | 18 int efd[3]; member
55 if (epoll_wait(ctx->efd[0], &e, 1, -1) > 0) in waiter_entry1a()
67 pfd.fd = ctx->efd[0]; in waiter_entry1ap()
70 if (epoll_wait(ctx->efd[0], &e, 1, 0) > 0) in waiter_entry1ap()
82 if (epoll_wait(ctx->efd[0], &e, 1, -1) > 0) in waiter_entry1o()
94 pfd.fd = ctx->efd[0]; in waiter_entry1op()
97 if (epoll_wait(ctx->efd[0], &e, 1, 0) > 0) in waiter_entry1op()
109 if (epoll_wait(ctx->efd[0], events, 2, -1) > 0) in waiter_entry2a()
121 pfd.fd = ctx->efd[0]; in waiter_entry2ap()
124 if (epoll_wait(ctx->efd[0], events, 2, 0) > 0) in waiter_entry2ap()
[all …]
|
| /aosp_15_r20/external/ltp/testcases/kernel/syscalls/epoll_pwait/ |
| H A D | epoll_pwait01.c | 26 static int efd, sfd[2]; variable
35 TEST(do_epoll_pwait(efd, &e, 1, -1, &signalset)); in verify_sigmask()
48 TST_EXP_FAIL(do_epoll_pwait(efd, &e, 1, -1, NULL), EINTR, in verify_nonsigmask()
90 efd = epoll_create(1); in setup()
91 if (efd == -1) in setup()
95 if (epoll_ctl(efd, EPOLL_CTL_ADD, sfd[0], &e)) in setup()
101 if (efd > 0) in cleanup()
102 SAFE_CLOSE(efd); in cleanup()
|
| H A D | epoll_pwait04.c | 19 static int efd, sfd[2]; variable
25 TST_EXP_FAIL(do_epoll_pwait(efd, &e, 1, -1, bad_addr), in run()
35 efd = epoll_create(1); in setup()
36 if (efd == -1) in setup()
40 if (epoll_ctl(efd, EPOLL_CTL_ADD, sfd[0], &e)) in setup()
49 if (efd > 0) in cleanup()
50 SAFE_CLOSE(efd); in cleanup()
|
| H A D | epoll_pwait02.c | 19 static int efd, sfd[2]; variable
24 TEST(do_epoll_pwait(efd, &e, 1, -1, NULL)); in run()
39 efd = epoll_create(1); in setup()
40 if (efd == -1) in setup()
44 if (epoll_ctl(efd, EPOLL_CTL_ADD, sfd[0], &e)) in setup()
51 if (efd > 0) in cleanup()
52 SAFE_CLOSE(efd); in cleanup()
|
| H A D | epoll_pwait03.c | 20 static int efd, sfd[2]; variable
28 TEST(do_epoll_pwait(efd, &e, 1, ms, NULL)); in sample_fn()
47 efd = epoll_create(1); in setup()
48 if (efd == -1) in setup()
52 if (epoll_ctl(efd, EPOLL_CTL_ADD, sfd[0], &e)) in setup()
58 if (efd > 0) in cleanup()
59 SAFE_CLOSE(efd); in cleanup()
|
| H A D | epoll_pwait05.c | 20 static int efd, sfd[2]; variable
35 TST_EXP_FAIL(epoll_pwait2(efd, &e, 1, &tc[n].ts, NULL), in run_all()
45 efd = epoll_create(1); in setup()
46 if (efd == -1) in setup()
50 if (epoll_ctl(efd, EPOLL_CTL_ADD, sfd[0], &e)) in setup()
57 if (efd > 0) in cleanup()
58 SAFE_CLOSE(efd); in cleanup()
|
| /aosp_15_r20/external/linux-kselftest/tools/testing/selftests/bpf/prog_tests/ |
| H A D | task_fd_query_rawtp.c | 10 int efd, err, prog_fd; in test_task_fd_query_rawtp() local
18 efd = bpf_raw_tracepoint_open("sys_enter", prog_fd); in test_task_fd_query_rawtp()
19 if (CHECK(efd < 0, "raw_tp_open", "err %d errno %d\n", efd, errno)) in test_task_fd_query_rawtp()
24 err = bpf_task_fd_query(getpid(), efd, 0, buf, &len, &prog_id, in test_task_fd_query_rawtp()
38 err = bpf_task_fd_query(getpid(), efd, 0, buf, &len, &prog_id, in test_task_fd_query_rawtp()
50 err = bpf_task_fd_query(getpid(), efd, 0, 0, &len, &prog_id, in test_task_fd_query_rawtp()
62 err = bpf_task_fd_query(getpid(), efd, 0, buf, &len, &prog_id, in test_task_fd_query_rawtp()
|
| H A D | task_fd_query_tp.c | 8 int err, bytes, efd, prog_fd, pmu_fd; in test_task_fd_query_tp_core() local
22 efd = open(buf, O_RDONLY, 0); in test_task_fd_query_tp_core()
23 if (CHECK(efd < 0, "open", "err %d errno %d\n", efd, errno)) in test_task_fd_query_tp_core()
25 bytes = read(efd, buf, sizeof(buf)); in test_task_fd_query_tp_core()
26 close(efd); in test_task_fd_query_tp_core()
|
| H A D | tp_attach_query.c | 7 int i, j, bytes, efd, err, prog_fd[num_progs], pmu_fd[num_progs]; in serial_test_tp_attach_query() local
21 efd = open(buf, O_RDONLY, 0); in serial_test_tp_attach_query()
22 if (CHECK(efd < 0, "open", "err %d errno %d\n", efd, errno)) in serial_test_tp_attach_query()
24 bytes = read(efd, buf, sizeof(buf)); in serial_test_tp_attach_query()
25 close(efd); in serial_test_tp_attach_query()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/nix/test/sys/ |
| D | test_epoll.rs | 9 let efd = epoll_create1(EpollCreateFlags::empty()).unwrap(); in test_epoll_errno() localVariable
10 let result = epoll_ctl(efd, EpollOp::EpollCtlDel, 1, None); in test_epoll_errno()
14 let result = epoll_ctl(efd, EpollOp::EpollCtlAdd, 1, None); in test_epoll_errno()
21 let efd = epoll_create1(EpollCreateFlags::empty()).unwrap(); in test_epoll_ctl() localVariable
24 epoll_ctl(efd, EpollOp::EpollCtlAdd, 1, &mut event).unwrap(); in test_epoll_ctl()
25 epoll_ctl(efd, EpollOp::EpollCtlDel, 1, None).unwrap(); in test_epoll_ctl()
|
| /aosp_15_r20/external/linux-kselftest/tools/testing/selftests/bpf/ |
| H A D | get_cgroup_id_user.c | 52 int err, bytes, efd, prog_fd, pmu_fd; in main() local
91 efd = open(buf, O_RDONLY, 0); in main()
92 if (CHECK(efd < 0, "open", "err %d errno %d\n", efd, errno)) in main()
94 bytes = read(efd, buf, sizeof(buf)); in main()
95 close(efd); in main()
|
| /aosp_15_r20/external/ublksrv/lib/ |
| H A D | ublksrv.c | 212 if (q->efd >= 0) { in __ublksrv_queue_event()
226 io_uring_prep_poll_add(sqe, q->efd, POLLIN); in __ublksrv_queue_event()
240 if (q->efd >= 0) { in ublksrv_queue_handled_event()
245 if (read(q->efd, &data, cnt) != cnt) in ublksrv_queue_handled_event()
269 if (q->efd >= 0) { in ublksrv_queue_send_event()
273 if (write(q->efd, &data, cnt) != cnt) { in ublksrv_queue_send_event()
350 if (q->efd >= 0) in ublksrv_queue_deinit()
351 close(q->efd); in ublksrv_queue_deinit()
414 if ((q->state & UBLKSRV_QUEUE_STOPPING) && q->efd >= 0) { in ublksrv_kill_eventfd()
418 ret = write(q->efd, &data, sizeof(uint64_t)); in ublksrv_kill_eventfd()
[all …]
|
| H A D | ublksrv_aio.c | 43 ublk_ignore_result(read(ctx->efd, &data, 8)); in ublksrv_aio_submit_worker()
139 ctx->efd = eventfd(0, O_NONBLOCK); in ublksrv_aio_ctx_init()
151 ret = write(ctx->efd, &data, 8); in ublksrv_aio_ctx_shutdown()
160 close(ctx->efd); in ublksrv_aio_ctx_deinit()
206 int ret = write(ctx->efd, &data, 8); in ublksrv_aio_submit_req()
247 return ctx->efd; in ublksrv_aio_get_efd()
|
| /aosp_15_r20/external/liburing/test/ |
| H A D | wakeup-hang.c | 106 int efd, ret; in test_eventfd() local
109 efd = eventfd(0, 0); in test_eventfd()
110 if (efd < 0) in test_eventfd()
119 td.write_fd = efd; in test_eventfd()
123 io_uring_prep_poll_add(sqe, efd, POLLIN); in test_eventfd()
|
| /aosp_15_r20/system/tools/hidl/test/lazy_test/ |
| D | hidl_lazy_test.cpp | 209 int efd = eventfd(0, 0); in TEST_F() local
210 ASSERT_GE(efd, 0) << "Failed to create eventfd"; in TEST_F()
211 unique_fd uniqueEventFd(efd); in TEST_F()
214 h->data[0] = efd; in TEST_F()
236 event.data.fd = efd; in TEST_F()
237 int rc = epoll_ctl(epollFd, EPOLL_CTL_ADD, efd, &event); in TEST_F()
|
| /aosp_15_r20/external/compiler-rt/test/msan/Linux/ |
| H A D | eventfd.cc | 9 int efd = eventfd(42, 0); in main() local
10 assert(efd >= 0); in main()
13 int ret = eventfd_read(efd, &v); in main()
|
| /aosp_15_r20/system/tools/aidl/tests/lazy_test/ |
| D | main.cpp | 227 int efd = eventfd(0, 0); in TEST_F() local
228 ASSERT_GE(efd, 0) << "Failed to create eventfd"; in TEST_F()
230 unique_fd uniqueEventFd(efd); in TEST_F()
251 event.data.fd = efd; in TEST_F()
252 int rc = epoll_ctl(epollFd, EPOLL_CTL_ADD, efd, &event); in TEST_F()
|
| /aosp_15_r20/external/grpc-grpc/src/core/lib/iomgr/ |
| H A D | wakeup_fd_eventfd.cc | 72 const int efd = eventfd(0, 0); in eventfd_check_availability() local
73 const int is_available = efd >= 0; in eventfd_check_availability()
74 if (is_available) close(efd); in eventfd_check_availability()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | wakeup_fd_eventfd.cc | 72 const int efd = eventfd(0, 0); in eventfd_check_availability() local
73 const int is_available = efd >= 0; in eventfd_check_availability()
74 if (is_available) close(efd); in eventfd_check_availability()
|
| /aosp_15_r20/prebuilts/go/linux-x86/src/runtime/ |
| D | netpoll_epoll.go | 28 efd, errno := syscall.Eventfd(0, syscall.EFD_CLOEXEC|syscall.EFD_NONBLOCK)
37 errno = syscall.EpollCtl(epfd, syscall.EPOLL_CTL_ADD, efd, &ev)
42 netpollEventFd = uintptr(efd)
|
| /aosp_15_r20/external/curl/lib/ |
| H A D | socketpair.c | 37 int efd = eventfd(0, nonblocking ? EFD_CLOEXEC | EFD_NONBLOCK : EFD_CLOEXEC); in Curl_eventfd() local
38 if(efd == -1) { in Curl_eventfd()
42 socks[0] = socks[1] = efd; in Curl_eventfd()
|
| /aosp_15_r20/art/tools/ |
| H A D | dt_fds_forward.py | 122 with make_eventfd(1) as efd:
123 print("sending fds ({}, {}, {}) to target.".format(conn.fileno(), conn.fileno(), efd))
124 send_fds(local_sock, conn.fileno(), conn.fileno(), efd)
|
| /aosp_15_r20/external/strace/ |
| H A D | kcmp.c | 34 uint32_t efd; member
85 PRINT_FIELD_PIDFD("{", slot, efd, tcp, pid2); in SYS_FUNC()
|
| /aosp_15_r20/external/cronet/third_party/libxml/src/ |
| H A D | nanoftp.c | 1444 fd_set rfd, efd; in xmlNanoFTPCloseConnection() local
1454 FD_ZERO(&efd); in xmlNanoFTPCloseConnection()
1455 FD_SET(ctxt->controlFd, &efd); in xmlNanoFTPCloseConnection()
1456 res = select(ctxt->controlFd + 1, &rfd, NULL, &efd, &tv); in xmlNanoFTPCloseConnection()
1619 fd_set rfd, efd; in xmlNanoFTPList() local
1659 FD_ZERO(&efd); in xmlNanoFTPList()
1660 FD_SET(ctxt->dataFd, &efd); in xmlNanoFTPList()
1661 res = select(ctxt->dataFd + 1, &rfd, NULL, &efd, &tv); in xmlNanoFTPList()
|
| /aosp_15_r20/external/ublksrv/include/ |
| H A D | ublksrv_priv.h | 111 int efd; member
270 int efd; //for wakeup us member
|