/linux/tools/testing/selftests/net/ |
A D | psock_fanout.c | 268 int fds[2]; in test_control_group() local 273 if (fds[0] == -1) { in test_control_group() 292 if (fds[1] == -1) { in test_control_group() 296 if (close(fds[1]) || close(fds[0])) { in test_control_group() 305 int fds[3]; in test_control_group_max_num_members() local 318 if (fds[0] == -1) { in test_control_group_max_num_members() 346 if (close(fds[2]) || close(fds[1]) || close(fds[0])) { in test_control_group_max_num_members() 355 int fds[3]; in test_unique_fanout_group_ids() local 401 if (close(fds[0]) || close(fds[1]) || close(fds[2])) { in test_unique_fanout_group_ids() 421 if (fds[0] == -1 || fds[1] == -1) { in test_datapath() [all …]
|
A D | psock_lib.h | 79 fds[0] = socket(PF_INET, SOCK_DGRAM, 0); in pair_udp_open() 80 fds[1] = socket(PF_INET, SOCK_DGRAM, 0); in pair_udp_open() 81 if (fds[0] == -1 || fds[1] == -1) { in pair_udp_open() 97 if (bind(fds[1], (void *) &daddr, sizeof(daddr))) { in pair_udp_open() 101 if (bind(fds[0], (void *) &saddr, sizeof(saddr))) { in pair_udp_open() 105 if (connect(fds[0], (void *) &daddr, sizeof(daddr))) { in pair_udp_open() 118 if (write(fds[0], buf, sizeof(buf)) != sizeof(buf)) { in pair_udp_send_char() 135 return pair_udp_send_char(fds, num, DATA_CHAR); in pair_udp_send() 138 static __maybe_unused void pair_udp_close(int fds[]) in pair_udp_close() argument 140 close(fds[0]); in pair_udp_close() [all …]
|
/linux/tools/bpf/bpftool/ |
A D | common.c | 704 *fds = tmp; in prog_fd_by_nametag() 774 if ((*fds)[0] < 0) in prog_parse_fds() 785 int *fds = NULL; in prog_parse_fd() local 789 if (!fds) { in prog_parse_fd() 804 fd = fds[0]; in prog_parse_fd() 806 free(fds); in prog_parse_fd() 855 *fds = tmp; in map_fd_by_name() 922 int *fds = NULL; in map_parse_fd() local 926 if (!fds) { in map_parse_fd() 941 fd = fds[0]; in map_parse_fd() [all …]
|
A D | map.c | 650 int *fds = NULL; in do_show_subset() local 654 fds = malloc(sizeof(int)); in do_show_subset() 655 if (!fds) { in do_show_subset() 671 close(fds[i]); in do_show_subset() 680 close(fds[i]); in do_show_subset() 686 free(fds); in do_show_subset() 920 int *fds = NULL; in do_dump() local 927 if (!fds) { in do_dump() 965 close(fds[i]); in do_dump() 974 close(fds[i]); in do_dump() [all …]
|
/linux/fs/ |
A D | select.c | 413 #define FDS_IN(fds, n) (fds->in + n) argument 414 #define FDS_OUT(fds, n) (fds->out + n) argument 415 #define FDS_EX(fds, n) (fds->ex + n) argument 417 #define BITS(fds, n) (*FDS_IN(fds, n)|*FDS_OUT(fds, n)|*FDS_EX(fds, n)) argument 433 set &= BITS(fds, n); in max_select_fd() 443 set = BITS(fds, n); in max_select_fd() 509 inp = fds->in; outp = fds->out; exp = fds->ex; in do_select() 510 rinp = fds->res_in; routp = fds->res_out; rexp = fds->res_ex; in do_select() 624 fd_set_bits fds; in core_sys_select() local 662 fds.in = bits; in core_sys_select() [all …]
|
/linux/tools/testing/selftests/bpf/ |
A D | network_helpers.c | 128 int *fds; in start_reuseport_server() local 136 fds = malloc(sizeof(*fds) * nr_listens); in start_reuseport_server() 137 if (!fds) in start_reuseport_server() 142 if (fds[0] == -1) in start_reuseport_server() 152 if (fds[nr_fds] == -1) in start_reuseport_server() 156 return fds; in start_reuseport_server() 159 free_fds(fds, nr_fds); in start_reuseport_server() 163 void free_fds(int *fds, unsigned int nr_close_fds) in free_fds() argument 165 if (fds) { in free_fds() 167 close(fds[--nr_close_fds]); in free_fds() [all …]
|
/linux/arch/um/os-Linux/ |
A D | helper.c | 46 int pid, fds[2], ret, n; in run_helper() local 52 ret = socketpair(AF_UNIX, SOCK_STREAM, 0, fds); in run_helper() 60 ret = os_set_exec_close(fds[1]); in run_helper() 71 data.fd = fds[1]; in run_helper() 82 close(fds[1]); in run_helper() 83 fds[1] = -1; in run_helper() 89 n = read(fds[0], &ret, sizeof(ret)); in run_helper() 105 if (fds[1] != -1) in run_helper() 106 close(fds[1]); in run_helper() 107 close(fds[0]); in run_helper()
|
A D | sigio.c | 53 struct pollfds *fds, tmp; in write_sigio_thread() local 59 fds = ¤t_poll; in write_sigio_thread() 61 n = poll(fds->poll, fds->used, -1); in write_sigio_thread() 68 for (i = 0; i < fds->used; i++) { in write_sigio_thread() 69 p = &fds->poll[i]; in write_sigio_thread() 87 fds->used--; in write_sigio_thread() 88 memmove(&fds->poll[i], &fds->poll[i + 1], in write_sigio_thread() 89 (fds->used - i) * sizeof(*fds->poll)); in write_sigio_thread()
|
A D | file.c | 375 int os_pipe(int *fds, int stream, int close_on_exec) in os_pipe() argument 379 err = socketpair(AF_UNIX, type, 0, fds); in os_pipe() 386 err = os_set_exec_close(fds[0]); in os_pipe() 390 err = os_set_exec_close(fds[1]); in os_pipe() 399 close(fds[1]); in os_pipe() 400 close(fds[0]); in os_pipe() 645 char control[CMSG_SPACE(sizeof(*fds) * OS_SENDMSG_MAX_FDS)]; in os_sendmsg_fds() 648 unsigned int fds_size = sizeof(*fds) * fds_num; in os_sendmsg_fds() 664 memcpy(CMSG_DATA(cmsg), fds, fds_size); in os_sendmsg_fds() 672 int os_poll(unsigned int n, const int *fds) in os_poll() argument [all …]
|
/linux/Documentation/translations/zh_CN/accounting/ |
A D | psi.rst | 109 struct pollfd fds; 112 fds.fd = open("/proc/pressure/memory", O_RDWR | O_NONBLOCK); 113 if (fds.fd < 0) { 118 fds.events = POLLPRI; 120 if (write(fds.fd, trig, strlen(trig) + 1) < 0) { 128 n = poll(&fds, 1, -1); 133 if (fds.revents & POLLERR) { 137 if (fds.revents & POLLPRI) { 140 printf("unknown event received: 0x%x\n", fds.revents);
|
/linux/arch/um/drivers/ |
A D | ubd_user.c | 30 int pid, fds[2], err; in start_io_thread() local 32 err = os_pipe(fds, 1, 1); in start_io_thread() 38 kernel_fd = fds[0]; in start_io_thread() 41 *fd_out = fds[1]; in start_io_thread() 60 os_close_file(fds[0]); in start_io_thread() 61 os_close_file(fds[1]); in start_io_thread()
|
A D | slirp_user.c | 52 int fds[2], pid, err; in slirp_open() local 54 err = os_pipe(fds, 1, 1); in slirp_open() 58 err = slirp_tramp(pri->argw.argv, fds[1]); in slirp_open() 65 pri->slave = fds[1]; in slirp_open() 70 return fds[0]; in slirp_open() 72 close(fds[0]); in slirp_open() 73 close(fds[1]); in slirp_open()
|
A D | slip_user.c | 78 int pid, fds[2], err, output_len; in slip_tramp() local 80 err = os_pipe(fds, 1, 0); in slip_tramp() 89 pe_data.stdout_fd = fds[1]; in slip_tramp() 90 pe_data.close_me = fds[0]; in slip_tramp() 106 close(fds[1]); in slip_tramp() 107 read_output(fds[0], output, output_len); in slip_tramp() 111 close(fds[0]); in slip_tramp() 117 close(fds[0]); in slip_tramp() 118 close(fds[1]); in slip_tramp()
|
A D | chan_user.c | 223 int fds[2], n, err; in winch_tramp() local 226 err = os_pipe(fds, 1, 1); in winch_tramp() 234 .pipe_fd = fds[1] } ); in winch_tramp() 248 *fd_out = fds[0]; in winch_tramp() 249 n = read(fds[0], &c, sizeof(c)); in winch_tramp() 269 close(fds[1]); in winch_tramp() 270 close(fds[0]); in winch_tramp()
|
A D | net_user.c | 182 int pid, fds[2], err; in change_tramp() local 185 err = os_pipe(fds, 1, 0); in change_tramp() 191 pe_data.close_me = fds[0]; in change_tramp() 192 pe_data.stdout_fd = fds[1]; in change_tramp() 196 read_output(fds[0], output, output_len); in change_tramp() 198 close(fds[0]); in change_tramp() 199 close(fds[1]); in change_tramp()
|
A D | vector_kern.c | 429 vp->fds->tx_fd, in vector_send() 806 if (vp->fds != NULL) in vector_remove() 926 vp->fds->tx_fd, in writev_tx() 1071 if ((vp->fds->rx_fd != vp->fds->tx_fd) && (vp->tx_irq != 0)) in vector_net_start_xmit() 1152 if (vp->fds == NULL) in vector_net_close() 1165 if (vp->fds->rx_fd > 0) { in vector_net_close() 1169 vp->fds->rx_fd = -1; in vector_net_close() 1173 vp->fds->tx_fd = -1; in vector_net_close() 1187 kfree(vp->fds); in vector_net_close() 1188 vp->fds = NULL; in vector_net_close() [all …]
|
/linux/tools/testing/selftests/pidfd/ |
A D | pidfd_poll_test.c | 28 struct pollfd fds; in main() local 32 fds.events = POLLIN; in main() 85 fds.fd = pidfd; in main() 86 nevents = poll(&fds, 1, -1); in main() 97 if (!(fds.revents & POLLIN)) in main() 100 fds.revents); in main()
|
/linux/samples/nitro_enclaves/ |
A D | ne_ioctl_sample.c | 199 struct pollfd fds[1] = {}; in ne_poll_enclave_fd() local 205 fds[0].fd = enclave_fd; in ne_poll_enclave_fd() 206 fds[0].events = POLLIN | POLLERR | POLLHUP; in ne_poll_enclave_fd() 212 rc = poll(fds, 1, NE_POLL_WAIT_TIME_MS); in ne_poll_enclave_fd() 230 if (fds[0].revents & POLLHUP) { in ne_poll_enclave_fd() 236 if (fds[0].revents & POLLNVAL) { in ne_poll_enclave_fd() 656 struct pollfd fds[1] = {}; in ne_start_enclave_check_booted() local 696 fds[0].fd = server_vsock_fd; in ne_start_enclave_check_booted() 697 fds[0].events = POLLIN; in ne_start_enclave_check_booted() 699 rc = poll(fds, 1, NE_POLL_WAIT_TIME_MS); in ne_start_enclave_check_booted() [all …]
|
/linux/tools/perf/bench/ |
A D | sched-messaging.c | 53 static void fdpair(int fds[2]) in fdpair() 56 if (pipe(fds) == 0) in fdpair() 59 if (socketpair(AF_UNIX, SOCK_STREAM, 0, fds) == 0) in fdpair() 205 int fds[2]; in group() local 213 fdpair(fds); in group() 216 ctx->in_fds[0] = fds[0]; in group() 217 ctx->in_fds[1] = fds[1]; in group() 223 snd_ctx->out_fds[i] = fds[1]; in group() 225 close(fds[0]); in group()
|
/linux/tools/testing/vsock/ |
A D | vsock_test.c | 209 int fds[MULTICONN_NFDS]; in test_stream_multiconn_client() local 213 fds[i] = vsock_stream_connect(opts->peer_cid, 1234); in test_stream_multiconn_client() 214 if (fds[i] < 0) { in test_stream_multiconn_client() 222 recv_byte(fds[i], 1, 0); in test_stream_multiconn_client() 224 send_byte(fds[i], 1, 0); in test_stream_multiconn_client() 228 close(fds[i]); in test_stream_multiconn_client() 233 int fds[MULTICONN_NFDS]; in test_stream_multiconn_server() local 238 if (fds[i] < 0) { in test_stream_multiconn_server() 246 send_byte(fds[i], 1, 0); in test_stream_multiconn_server() 248 recv_byte(fds[i], 1, 0); in test_stream_multiconn_server() [all …]
|
/linux/tools/perf/tests/ |
A D | bpf.c | 44 int fds[2], i; in llseek_loop() local 46 fds[0] = open("/dev/null", O_RDONLY); in llseek_loop() 47 fds[1] = open("/dev/null", O_RDWR); in llseek_loop() 49 if (fds[0] < 0 || fds[1] < 0) in llseek_loop() 53 lseek(fds[i % 2], i, (i / 2) % 2 ? SEEK_CUR : SEEK_SET); in llseek_loop() 54 lseek(fds[(i + 1) % 2], i, (i / 2) % 2 ? SEEK_CUR : SEEK_SET); in llseek_loop() 56 close(fds[0]); in llseek_loop() 57 close(fds[1]); in llseek_loop()
|
/linux/arch/um/os-Linux/drivers/ |
A D | tuntap_user.c | 133 int err, fds[2], len, used; in tuntap_open() local 159 err = socketpair(AF_UNIX, SOCK_DGRAM, 0, fds); in tuntap_open() 172 err = tuntap_open_tramp(pri->gate_addr, &pri->fd, fds[0], in tuntap_open() 173 fds[1], buffer, len, &used); in tuntap_open() 189 close(fds[0]); in tuntap_open()
|
/linux/tools/testing/selftests/filesystems/binderfs/ |
A D | binderfs_test.c | 380 int fds[1000]; in TEST() local 418 for (int i = 0; i < ARRAY_SIZE(fds); i++) { in TEST() 439 fds[i] = open(device_path, O_RDONLY | O_CLOEXEC); in TEST() 440 ASSERT_GE(fds[i], 0) { in TEST() 457 for (k = 0; k < ARRAY_SIZE(fds); k++) { in TEST() 459 ret = pthread_create(&threads[i], &attr, binder_version_thread, INT_TO_PTR(fds[k])); in TEST() 478 for (k = 0; k < ARRAY_SIZE(fds); k++) in TEST() 479 close(fds[k]); in TEST()
|
/linux/tools/testing/selftests/sync/ |
A D | sync.c | 60 struct pollfd fds; in sync_wait() local 62 fds.fd = fd; in sync_wait() 63 fds.events = POLLIN | POLLERR; in sync_wait() 65 return poll(&fds, 1, timeout); in sync_wait()
|
/linux/tools/testing/selftests/net/mptcp/ |
A D | mptcp_connect.c | 456 struct pollfd fds = { in copyfd_io_poll() local 469 if (fds.events == 0) in copyfd_io_poll() 472 switch (poll(&fds, 1, poll_timeout)) { in copyfd_io_poll() 481 fds.events & POLLIN, fds.events & POLLOUT); in copyfd_io_poll() 485 if (fds.revents & POLLIN) { in copyfd_io_poll() 491 fds.events &= ~POLLIN; in copyfd_io_poll() 493 if ((fds.events & POLLOUT) == 0) { in copyfd_io_poll() 508 if (fds.revents & POLLOUT) { in copyfd_io_poll() 525 fds.events &= ~POLLOUT; in copyfd_io_poll() 527 if ((fds.events & POLLIN) == 0) in copyfd_io_poll() [all …]
|