| /third_party/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()
|
| /third_party/mbedtls/library/ |
| D | net_sockets.c | 520 fd_set read_fds; in mbedtls_net_poll() local
534 memset( &read_fds, 0, sizeof( read_fds ) ); in mbedtls_net_poll()
539 FD_ZERO( &read_fds ); in mbedtls_net_poll()
543 FD_SET( fd, &read_fds ); in mbedtls_net_poll()
561 ret = select( fd + 1, &read_fds, &write_fds, NULL, in mbedtls_net_poll()
570 if( FD_ISSET( fd, &read_fds ) ) in mbedtls_net_poll()
643 fd_set read_fds; in mbedtls_net_recv_timeout() local
650 FD_ZERO( &read_fds ); in mbedtls_net_recv_timeout()
651 FD_SET( fd, &read_fds ); in mbedtls_net_recv_timeout()
656 ret = select( fd + 1, &read_fds, NULL, NULL, timeout == 0 ? NULL : &tv ); in mbedtls_net_recv_timeout()
|
| /third_party/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 | 199 fd_set read_fds, write_fds; in wait_ares() local
202 FD_ZERO(&read_fds); in wait_ares()
204 nfds = ares_fds(channel, &read_fds, &write_fds); in wait_ares()
208 nfds = select(nfds, &read_fds, &write_fds, NULL, tvp); in wait_ares()
211 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 | 460 fd_set *read_fds,
472 fd_set *read_fds,
|
| /third_party/gn/src/gn/ |
| D | exec_process.cc | 266 fd_set read_fds;
267 FD_ZERO(&read_fds);
268 FD_SET(out_read.get(), &read_fds);
269 FD_SET(err_read.get(), &read_fds);
272 &read_fds, nullptr, nullptr, nullptr));
275 if (FD_ISSET(out_read.get(), &read_fds))
277 if (FD_ISSET(err_read.get(), &read_fds))
|
| /third_party/node/deps/cares/src/lib/ |
| 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 | 61 static void read_tcp_data(ares_channel channel, fd_set *read_fds,
63 static void read_udp_packets(ares_channel channel, fd_set *read_fds,
119 fd_set *read_fds, ares_socket_t read_fd, in processfds() argument
125 read_tcp_data(channel, read_fds, read_fd, &now); in processfds()
126 read_udp_packets(channel, read_fds, read_fd, &now); in processfds()
134 void ares_process(ares_channel channel, fd_set *read_fds, fd_set *write_fds) in ares_process() argument
136 processfds(channel, read_fds, ARES_SOCKET_BAD, write_fds, ARES_SOCKET_BAD); in ares_process()
357 static void read_tcp_data(ares_channel channel, fd_set *read_fds, in read_tcp_data() argument
364 if(!read_fds && (read_fd == ARES_SOCKET_BAD)) in read_tcp_data()
375 if(read_fds) { in read_tcp_data()
[all …]
|
| /third_party/node/deps/cares/src/tools/ |
| D | ahost.c | 60 fd_set read_fds, write_fds; in main() local
153 FD_ZERO(&read_fds); in main()
155 nfds = ares_fds(channel, &read_fds, &write_fds); in main()
159 res = select(nfds, &read_fds, &write_fds, NULL, tvp); in main()
162 ares_process(channel, &read_fds, &write_fds); in main()
|
| D | acountry.c | 204 fd_set read_fds, write_fds; in wait_ares() local
207 FD_ZERO(&read_fds); in wait_ares()
209 nfds = ares_fds(channel, &read_fds, &write_fds); in wait_ares()
213 nfds = select(nfds, &read_fds, &write_fds, NULL, tvp); in wait_ares()
216 ares_process(channel, &read_fds, &write_fds); in wait_ares()
|
| D | adig.c | 166 fd_set read_fds, write_fds; in main() local
360 FD_ZERO(&read_fds); in main()
362 nfds = ares_fds(channel, &read_fds, &write_fds); in main()
366 count = select(nfds, &read_fds, &write_fds, NULL, tvp); in main()
372 ares_process(channel, &read_fds, &write_fds); in main()
|
| /third_party/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()
|
| /third_party/mbedtls/programs/test/ |
| D | udp_proxy.c | 808 fd_set read_fds; in main() local
948 FD_ZERO( &read_fds ); in main()
949 FD_SET( server_fd.fd, &read_fds ); in main()
950 FD_SET( client_fd.fd, &read_fds ); in main()
951 FD_SET( listen_fd.fd, &read_fds ); in main()
953 if( ( ret = select( nb_fds, &read_fds, NULL, NULL, tm_ptr ) ) < 0 ) in main()
959 if( FD_ISSET( listen_fd.fd, &read_fds ) ) in main()
962 if( FD_ISSET( client_fd.fd, &read_fds ) ) in main()
969 if( FD_ISSET( server_fd.fd, &read_fds ) ) in main()
|
| /third_party/protobuf/src/google/protobuf/compiler/ |
| D | subprocess.cc | 378 fd_set read_fds; in Communicate() local
380 FD_ZERO(&read_fds); in Communicate()
383 FD_SET(child_stdout_, &read_fds); in Communicate()
389 if (select(max_fd + 1, &read_fds, &write_fds, NULL, NULL) < 0) { in Communicate()
416 if (child_stdout_ != -1 && FD_ISSET(child_stdout_, &read_fds)) { in Communicate()
|
| /third_party/boringssl/src/tool/ |
| D | client.cc | 189 fd_set read_fds; in WaitForSession() local
190 FD_ZERO(&read_fds); in WaitForSession()
202 FD_SET(static_cast<SOCKET>(sock), &read_fds); in WaitForSession()
204 FD_SET(sock, &read_fds); in WaitForSession()
206 int ret = select(sock + 1, &read_fds, NULL, NULL, NULL); in WaitForSession()
|
| D | transport_common.cc | 393 fd_set read_fds, write_fds; in Wait() local
394 FD_ZERO(&read_fds); in Wait()
399 FD_SET(STDIN_FILENO, &read_fds); in Wait()
401 FD_SET(sock_, &read_fds); in Wait()
402 if (select(sock_ + 1, &read_fds, &write_fds, NULL, NULL) <= 0) { in Wait()
407 if (FD_ISSET(STDIN_FILENO, &read_fds) || FD_ISSET(sock_, &write_fds)) { in Wait()
410 if (FD_ISSET(sock_, &read_fds)) { in Wait()
|
| /third_party/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()
|
| /third_party/node/deps/cares/include/ |
| D | ares.h | 460 fd_set *read_fds,
472 fd_set *read_fds,
|
| /third_party/python/Lib/test/ |
| D | test_subprocess.py | 2512 read_fds = list(map(int, read_bytes.decode('ascii')))
2518 self.assertEqual([to_fd], read_fds, msg)
|