| /external/virglrenderer/vtest/ |
| D | util.c | 34 fd_set read_fds; in vtest_wait_for_fd_read() local
37 FD_ZERO(&read_fds); in vtest_wait_for_fd_read()
38 FD_SET(fd, &read_fds); in vtest_wait_for_fd_read()
40 ret = select(fd + 1, &read_fds, NULL, NULL, NULL); in vtest_wait_for_fd_read()
45 if (FD_ISSET(fd, &read_fds)) { in vtest_wait_for_fd_read()
|
| D | vtest_server.c | 363 fd_set read_fds; in vtest_server_wait_clients() local
367 FD_ZERO(&read_fds); in vtest_server_wait_clients()
370 FD_SET(client->in_fd, &read_fds); in vtest_server_wait_clients()
376 FD_SET(server.socket, &read_fds); in vtest_server_wait_clients()
389 ret = select(max_fd + 1, &read_fds, NULL, NULL, NULL); in vtest_server_wait_clients()
396 if (FD_ISSET(client->in_fd, &read_fds)) { in vtest_server_wait_clients()
401 if (server.socket >= 0 && FD_ISSET(server.socket, &read_fds)) { in vtest_server_wait_clients()
|
| /external/ltp/testcases/kernel/syscalls/pselect/ |
| D | pselect02.c | 37 static fd_set read_fds; variable
46 {128, &read_fds, NULL, EBADF},
87 FD_ZERO(&read_fds); in setup()
88 FD_SET(fd, &read_fds); in setup()
|
| /external/rust/crates/grpcio-sys/grpc/third_party/cares/cares/ |
| D | ahost.c | 59 fd_set read_fds, write_fds; in main() local
147 FD_ZERO(&read_fds); in main()
149 nfds = ares_fds(channel, &read_fds, &write_fds); in main()
153 res = select(nfds, &read_fds, &write_fds, NULL, tvp); in main()
156 ares_process(channel, &read_fds, &write_fds); in main()
|
| D | ares_fds.c | 23 int ares_fds(ares_channel channel, fd_set *read_fds, fd_set *write_fds) in ares_fds() argument
41 FD_SET(server->udp_socket, read_fds); in ares_fds()
51 FD_SET(server->tcp_socket, read_fds); in ares_fds()
|
| D | ares_process.c | 67 static void read_tcp_data(ares_channel channel, fd_set *read_fds,
69 static void read_udp_packets(ares_channel channel, fd_set *read_fds,
124 fd_set *read_fds, ares_socket_t read_fd, in processfds() argument
130 read_tcp_data(channel, read_fds, read_fd, &now); in processfds()
131 read_udp_packets(channel, read_fds, read_fd, &now); in processfds()
139 void ares_process(ares_channel channel, fd_set *read_fds, fd_set *write_fds) in ares_process() argument
141 processfds(channel, read_fds, ARES_SOCKET_BAD, write_fds, ARES_SOCKET_BAD); in ares_process()
362 static void read_tcp_data(ares_channel channel, fd_set *read_fds, in read_tcp_data() argument
369 if(!read_fds && (read_fd == ARES_SOCKET_BAD)) in read_tcp_data()
380 if(read_fds) { in read_tcp_data()
[all …]
|
| D | acountry.c | 194 fd_set read_fds, write_fds; in wait_ares() local
197 FD_ZERO(&read_fds); in wait_ares()
199 nfds = ares_fds(channel, &read_fds, &write_fds); in wait_ares()
203 nfds = select(nfds, &read_fds, &write_fds, NULL, tvp); in wait_ares()
206 ares_process(channel, &read_fds, &write_fds); in wait_ares()
|
| D | adig.c | 188 fd_set read_fds, write_fds; in main() local
370 FD_ZERO(&read_fds); in main()
372 nfds = ares_fds(channel, &read_fds, &write_fds); in main()
376 count = select(nfds, &read_fds, &write_fds, NULL, tvp); in main()
382 ares_process(channel, &read_fds, &write_fds); in main()
|
| D | ares.h | 439 fd_set *read_fds,
451 fd_set *read_fds,
|
| /external/llvm-project/lldb/source/Host/common/ |
| D | MainLoop.cpp | 92 std::vector<struct pollfd> read_fds; member in MainLoop::RunImpl
144 read_fds.reserve(loop.m_read_fds.size()); in RunImpl()
200 read_fds.clear(); in Poll()
209 read_fds.push_back(pfd); in Poll()
212 if (ppoll(read_fds.data(), read_fds.size(), nullptr, &sigmask) == -1 && in Poll()
233 for (const auto &fd : read_fds) {
|
| /external/ltp/testcases/network/stress/ns-tools/ |
| D | ns-udpserver.c | 198 fd_set read_fds; /* list of file descriptor for reading */ in main() local
339 FD_ZERO(&read_fds); in main()
340 FD_SET(sock_fd, &read_fds); in main()
351 active_fds = read_fds; in main()
|
| D | ns-tcpserver.c | 384 fd_set read_fds; /* list of file descriptor for reading */ in handle_client() local
388 FD_ZERO(&read_fds); in handle_client()
389 FD_SET(info_p->listen_sd, &read_fds); in handle_client()
416 active_fds = read_fds; in handle_client()
|
| /external/iptables/libipq/ |
| D | libipq.c | 140 fd_set read_fds; in ipq_netlink_recvfrom() local
151 FD_ZERO(&read_fds); in ipq_netlink_recvfrom()
152 FD_SET(h->fd, &read_fds); in ipq_netlink_recvfrom()
153 ret = select(h->fd+1, &read_fds, NULL, NULL, &tv); in ipq_netlink_recvfrom()
162 if (!FD_ISSET(h->fd, &read_fds)) { in ipq_netlink_recvfrom()
|
| /external/protobuf/src/google/protobuf/compiler/ |
| D | subprocess.cc | 379 fd_set read_fds; in Communicate() local
381 FD_ZERO(&read_fds); in Communicate()
384 FD_SET(child_stdout_, &read_fds); in Communicate()
390 if (select(max_fd + 1, &read_fds, &write_fds, NULL, NULL) < 0) { in Communicate()
417 if (child_stdout_ != -1 && FD_ISSET(child_stdout_, &read_fds)) { in Communicate()
|
| /external/boringssl/src/tool/ |
| D | client.cc | 197 fd_set read_fds; in WaitForSession() local
198 FD_ZERO(&read_fds); in WaitForSession()
210 FD_SET(static_cast<SOCKET>(sock), &read_fds); in WaitForSession()
212 FD_SET(sock, &read_fds); in WaitForSession()
214 int ret = select(sock + 1, &read_fds, NULL, NULL, NULL); in WaitForSession()
|
| D | transport_common.cc | 402 fd_set read_fds, write_fds; in Wait() local
403 FD_ZERO(&read_fds); in Wait()
408 FD_SET(STDIN_FILENO, &read_fds); in Wait()
410 FD_SET(sock_, &read_fds); in Wait()
411 if (select(sock_ + 1, &read_fds, &write_fds, NULL, NULL) <= 0) { in Wait()
416 if (FD_ISSET(STDIN_FILENO, &read_fds) || FD_ISSET(sock_, &write_fds)) { in Wait()
419 if (FD_ISSET(sock_, &read_fds)) { in Wait()
|
| /external/rust/crates/quiche/deps/boringssl/src/tool/ |
| D | client.cc | 197 fd_set read_fds; in WaitForSession() local
198 FD_ZERO(&read_fds); in WaitForSession()
210 FD_SET(static_cast<SOCKET>(sock), &read_fds); in WaitForSession()
212 FD_SET(sock, &read_fds); in WaitForSession()
214 int ret = select(sock + 1, &read_fds, NULL, NULL, NULL); in WaitForSession()
|
| D | transport_common.cc | 397 fd_set read_fds, write_fds; in Wait() local
398 FD_ZERO(&read_fds); in Wait()
403 FD_SET(STDIN_FILENO, &read_fds); in Wait()
405 FD_SET(sock_, &read_fds); in Wait()
406 if (select(sock_ + 1, &read_fds, &write_fds, NULL, NULL) <= 0) { in Wait()
411 if (FD_ISSET(STDIN_FILENO, &read_fds) || FD_ISSET(sock_, &write_fds)) { in Wait()
414 if (FD_ISSET(sock_, &read_fds)) { in Wait()
|
| /external/ltp/testcases/kernel/logging/kmsg/ |
| D | kmsg01.c | 142 fd_set read_fds; in timed_read() local
144 FD_ZERO(&read_fds); in timed_read()
145 FD_SET(fd, &read_fds); in timed_read()
149 ret = select(fd + 1, &read_fds, 0, 0, &timeout); in timed_read()
|
| /external/libbrillo/brillo/streams/ |
| D | file_stream.cc | 122 fd_set read_fds; in WaitForDataBlocking() local
126 FD_ZERO(&read_fds); in WaitForDataBlocking()
131 FD_SET(fd_, &read_fds); in WaitForDataBlocking()
142 int res = HANDLE_EINTR(select(fd_ + 1, &read_fds, &write_fds, &error_fds, in WaitForDataBlocking()
145 *out_mode = stream_utils::MakeAccessMode(FD_ISSET(fd_, &read_fds), in WaitForDataBlocking()
|
| /external/chromium-trace/catapult/devil/devil/utils/ |
| D | cmd_helper.py | 354 read_fds, _, _ = select.select([child_fd], [], [],
356 if child_fd in read_fds:
366 read_fds, _, _ = select.select([child_fd], [], [],
368 if child_fd in read_fds:
|
| /external/crosvm/sys_util/src/ |
| D | net.rs | 534 let (read_bytes, read_fds) = self.recv_with_fds(&mut buf, &mut fd_buf)?; in recv_as_vec_with_fds()
536 fd_buf.resize(read_fds, -1); in recv_as_vec_with_fds()
|
| /external/llvm-project/lldb/tools/debugserver/source/MacOSX/ |
| D | MachProcess.mm | 2440 fd_set read_fds;
2441 FD_ZERO(&read_fds);
2443 FD_SET(stdout_fd, &read_fds);
2445 FD_SET(stderr_fd, &read_fds);
2448 int num_set_fds = select(nfds, &read_fds, NULL, NULL, NULL);
2450 "select (nfds, &read_fds, NULL, NULL, NULL) => %d",
2458 "select (nfds, &read_fds, NULL, NULL, NULL) => %d", num_set_fds);
2481 if (stdout_fd >= 0 && FD_ISSET(stdout_fd, &read_fds)) {
2503 if (stderr_fd >= 0 && FD_ISSET(stderr_fd, &read_fds)) {
|
| /external/python/cpython3/Lib/test/ |
| D | test_subprocess.py | 2490 read_fds = list(map(int, read_bytes.decode('ascii')))
2496 self.assertEqual([to_fd], read_fds, msg)
|