Searched refs:wait_fd (Results 1 – 9 of 9) sorted by relevance
| /packages/modules/Virtualization/android/virtmgr/ |
| D | fuzzer.cpp | 47 unique_fd wait_fd, ready_fd; in get_service_fd() local
48 if (!Pipe(&wait_fd, &ready_fd, 0)) { in get_service_fd()
54 wait_fd.reset(); in get_service_fd()
71 if (read(wait_fd.get(), &buf, sizeof(buf)) < 0) { in get_service_fd()
|
| /packages/modules/Connectivity/clatd/ |
| D | clatd.c | 279 struct pollfd wait_fd[] = { in event_loop() local
285 if (poll(wait_fd, ARRAY_SIZE(wait_fd), -1) == -1) { in event_loop()
295 if (wait_fd[0].revents) process_packet_6_to_4(tunnel); in event_loop()
296 if (wait_fd[1].revents) process_packet_4_to_6(tunnel); in event_loop()
|
| /packages/modules/Connectivity/tests/cts/net/native/dns/ |
| D | NativeDnsAsyncTest.cpp | 39 struct pollfd wait_fd[1]; in getAsyncResponse() local
40 wait_fd[0].fd = fd; in getAsyncResponse()
41 wait_fd[0].events = POLLIN; in getAsyncResponse()
44 ret = poll(wait_fd, 1, timeoutMs); in getAsyncResponse()
45 revents = wait_fd[0].revents; in getAsyncResponse()
|
| /packages/modules/DnsResolver/tests/ |
| D | tun_forwarder.cpp | 172 struct pollfd wait_fd[] = { in loop() local
177 if (int ret = poll(wait_fd, std::size(wait_fd), kPollTimeoutMs); ret <= 0) { in loop()
181 if (wait_fd[0].revents & (POLLIN | POLLERR)) { in loop()
186 if (wait_fd[1].revents & (POLLIN | POLLERR)) { in loop()
187 handlePacket(wait_fd[1].fd); in loop()
|
| D | resolv_private_dns_test.cpp | 67 struct pollfd wait_fd[1]; in getAsyncResponse() local
68 wait_fd[0].fd = fd; in getAsyncResponse()
69 wait_fd[0].events = POLLIN; in getAsyncResponse()
72 if (int ret = poll(wait_fd, 1, -1); ret <= 0) { in getAsyncResponse()
76 revents = wait_fd[0].revents; in getAsyncResponse()
|
| D | resolv_integration_test.cpp | 2425 struct pollfd wait_fd[1]; in getAsyncResponse() local
2426 wait_fd[0].fd = fd; in getAsyncResponse()
2427 wait_fd[0].events = POLLIN; in getAsyncResponse()
2430 if (int ret = poll(wait_fd, 1, -1); ret <= 0) { in getAsyncResponse()
2433 revents = wait_fd[0].revents; in getAsyncResponse()
|
| /packages/modules/Virtualization/android/vm_demo_native/ |
| D | main.cpp | 86 unique_fd wait_fd, ready_fd; in get_service_fd() local
87 if (!Pipe(&wait_fd, &ready_fd, 0)) { in get_service_fd()
93 wait_fd.reset(); in get_service_fd()
108 if (read(wait_fd.get(), &buf, sizeof(buf)) < 0) { in get_service_fd()
|
| /packages/modules/Connectivity/tests/cts/net/jni/ |
| D | NativeMultinetworkJni.cpp | 92 struct pollfd wait_fd = { .fd = fd, .events = POLLIN }; in getAsyncResponse() local
94 poll(&wait_fd, 1, timeoutMs); in getAsyncResponse()
95 if (wait_fd.revents & POLLIN) { in getAsyncResponse()
|
| /packages/modules/Virtualization/libs/libvmclient/src/ |
| D | lib.rs | 136 let (wait_fd, ready_fd) = posix_pipe()?; in new_with_path()
151 let _ = File::from(wait_fd).read(&mut [0])?; in new_with_path()
|