Searched refs:wait_fd (Results 1 – 9 of 9) sorted by relevance
| /packages/modules/Virtualization/virtualizationmanager/ |
| 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 | 287 struct pollfd wait_fd[] = { in event_loop() local
293 if (poll(wait_fd, ARRAY_SIZE(wait_fd), -1) == -1) { in event_loop()
303 if (wait_fd[0].revents) process_packet_6_to_4(tunnel); in event_loop()
304 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 | 66 struct pollfd wait_fd[1]; in getAsyncResponse() local
67 wait_fd[0].fd = fd; in getAsyncResponse()
68 wait_fd[0].events = POLLIN; in getAsyncResponse()
71 if (int ret = poll(wait_fd, 1, -1); ret <= 0) { in getAsyncResponse()
75 revents = wait_fd[0].revents; in getAsyncResponse()
|
| D | resolv_integration_test.cpp | 2422 struct pollfd wait_fd[1]; in getAsyncResponse() local
2423 wait_fd[0].fd = fd; in getAsyncResponse()
2424 wait_fd[0].events = POLLIN; in getAsyncResponse()
2427 if (int ret = poll(wait_fd, 1, -1); ret <= 0) { in getAsyncResponse()
2430 revents = wait_fd[0].revents; in getAsyncResponse()
|
| /packages/modules/Virtualization/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/vmclient/src/ |
| D | lib.rs | 89 let (wait_fd, ready_fd) = posix_pipe()?; in new()
105 let _ignored = File::from(wait_fd).read(&mut [0]); in new()
|