Searched refs:read_set (Results 1 – 12 of 12) sorted by relevance
| /external/iperf3/src/ |
| D | iperf_server_api.c | 97 FD_ZERO(&test->read_set); in iperf_server_listen()
99 FD_SET(test->listener, &test->read_set); in iperf_server_listen()
126 FD_SET(test->ctrl_sck, &test->read_set); in iperf_accept()
182 FD_CLR(sp->socket, &test->read_set); in iperf_handle_message_server()
212 FD_CLR(sp->socket, &test->read_set); in iperf_handle_message_server()
395 fd_set read_set, write_set; in iperf_run_server() local
433 memcpy(&read_set, &test->read_set, sizeof(fd_set)); in iperf_run_server()
438 result = select(test->max_fd + 1, &read_set, &write_set, NULL, timeout); in iperf_run_server()
445 if (FD_ISSET(test->listener, &read_set)) { in iperf_run_server()
451 FD_CLR(test->listener, &read_set); in iperf_run_server()
[all …]
|
| D | iperf_client_api.c | 104 FD_SET(s, &test->read_set); in iperf_create_streams()
331 FD_ZERO(&test->read_set); in iperf_connect()
350 FD_SET(test->ctrl_sck, &test->read_set); in iperf_connect()
452 fd_set read_set, write_set; in iperf_run_client() local
484 memcpy(&read_set, &test->read_set, sizeof(fd_set)); in iperf_run_client()
488 result = select(test->max_fd + 1, &read_set, &write_set, NULL, timeout); in iperf_run_client()
494 if (FD_ISSET(test->ctrl_sck, &read_set)) { in iperf_run_client()
498 FD_CLR(test->ctrl_sck, &read_set); in iperf_run_client()
521 if (iperf_recv(test, &read_set) < 0) in iperf_run_client()
529 if (iperf_recv(test, &read_set) < 0) in iperf_run_client()
[all …]
|
| D | iperf.h | 305 fd_set read_set; /* set of read sockets */ member
|
| D | iperf_udp.c | 426 FD_SET(test->prot_listener, &test->read_set); in iperf_udp_accept()
|
| D | iperf_tcp.c | 168 FD_CLR(s, &test->read_set); in iperf_tcp_listen()
|
| D | iperf_api.c | 1573 FD_SET(s, &test->read_set); in iperf_exchange_parameters()
2489 FD_ZERO(&test->read_set); in iperf_reset_test()
|
| /external/u-boot/tools/patman/ |
| D | cros_subprocess.py | 144 read_set = []
158 read_set.append(self.stdout)
161 read_set.append(self.stderr)
166 while read_set or write_set:
168 rlist, wlist, _ = select.select(read_set, write_set, [], 0.2)
197 read_set.remove(self.stdout)
212 read_set.remove(self.stderr)
|
| /external/strace/ |
| D | filter_qualify.c | 36 struct number_set *read_set; variable
274 if (!read_set) in qualify_read()
275 read_set = alloc_number_set_array(1); in qualify_read()
276 qualify_tokens(str, read_set, string_to_uint, "descriptor"); in qualify_read()
|
| D | number_set.h | 62 extern struct number_set *read_set;
|
| D | syscall.c | 431 if (is_number_in_set(fd, read_set)) { in dumpio()
|
| D | ChangeLog | 5633 read_set to the end of the function.
12222 (read_set, write_set, signal_set): Change prototypes from objects
12224 * filter_qualify.c (read_set, write_set, signal_set): Change definitions
12228 (qualify_read): Initialize read_set before first use.
12237 * syscall.c (dumpio): Update usage of read_set and write_set.
12267 (read_set, write_set, signal_set, is_number_in_set): Move to number_set.h.
22646 (read_set, write_set): New variable prototypes.
|
| /external/python/cpython2/Lib/ |
| D | subprocess.py | 1210 read_set = []
1218 read_set.append(self.stdout)
1221 read_set.append(self.stderr)
1225 while read_set or write_set:
1227 rlist, wlist, xlist = select.select(read_set, write_set, [])
1253 read_set.remove(self.stdout)
1260 read_set.remove(self.stderr)
|