/Linux-v4.19/tools/testing/selftests/net/ |
D | psock_fanout.c | 235 static int sock_fanout_read(int fds[], char *rings[], const int expect[]) in sock_fanout_read() argument 239 ret[0] = sock_fanout_read_ring(fds[0], rings[0]); in sock_fanout_read() 240 ret[1] = sock_fanout_read_ring(fds[1], rings[1]); in sock_fanout_read() 269 int fds[2]; in test_control_group() local 273 fds[0] = sock_fanout_open(PACKET_FANOUT_HASH, 0); in test_control_group() 274 if (fds[0] == -1) { in test_control_group() 292 fds[1] = sock_fanout_open(PACKET_FANOUT_HASH, 0); in test_control_group() 293 if (fds[1] == -1) { in test_control_group() 297 if (close(fds[1]) || close(fds[0])) { in test_control_group() 306 int fds[3]; in test_unique_fanout_group_ids() local [all …]
|
D | psock_lib.h | 89 static __maybe_unused void pair_udp_open(int fds[], uint16_t port) in pair_udp_open() argument 93 fds[0] = socket(PF_INET, SOCK_DGRAM, 0); in pair_udp_open() 94 fds[1] = socket(PF_INET, SOCK_DGRAM, 0); in pair_udp_open() 95 if (fds[0] == -1 || fds[1] == -1) { in pair_udp_open() 111 if (bind(fds[1], (void *) &daddr, sizeof(daddr))) { in pair_udp_open() 115 if (bind(fds[0], (void *) &saddr, sizeof(saddr))) { in pair_udp_open() 119 if (connect(fds[0], (void *) &daddr, sizeof(daddr))) { in pair_udp_open() 125 static __maybe_unused void pair_udp_send_char(int fds[], int num, char payload) in pair_udp_send_char() argument 132 if (write(fds[0], buf, sizeof(buf)) != sizeof(buf)) { in pair_udp_send_char() 136 if (read(fds[1], rbuf, sizeof(rbuf)) != sizeof(rbuf)) { in pair_udp_send_char() [all …]
|
/Linux-v4.19/fs/ |
D | select.c | 386 #define FDS_IN(fds, n) (fds->in + n) argument 387 #define FDS_OUT(fds, n) (fds->out + n) argument 388 #define FDS_EX(fds, n) (fds->ex + n) argument 390 #define BITS(fds, n) (*FDS_IN(fds, n)|*FDS_OUT(fds, n)|*FDS_EX(fds, n)) argument 392 static int max_select_fd(unsigned long n, fd_set_bits *fds) in max_select_fd() argument 406 set &= BITS(fds, n); in max_select_fd() 416 set = BITS(fds, n); in max_select_fd() 449 static int do_select(int n, fd_set_bits *fds, struct timespec64 *end_time) in do_select() argument 460 retval = max_select_fd(n, fds); in do_select() 482 inp = fds->in; outp = fds->out; exp = fds->ex; in do_select() [all …]
|
/Linux-v4.19/arch/um/os-Linux/ |
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()
|
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()
|
D | aio.c | 205 int fds[2], err; in init_aio_24() local 207 err = os_pipe(fds, 1, 1); in init_aio_24() 211 aio_req_fd_w = fds[0]; in init_aio_24() 212 aio_req_fd_r = fds[1]; in init_aio_24() 227 close(fds[0]); in init_aio_24() 228 close(fds[1]); in init_aio_24()
|
/Linux-v4.19/arch/um/drivers/ |
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()
|
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()
|
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()
|
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() 268 close(fds[1]); in winch_tramp() 269 close(fds[0]); in winch_tramp()
|
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()
|
D | vector_kern.c | 333 mmsg_vector->msg_hdr.msg_name = vp->fds->remote_addr; in vector_enqueue() 334 mmsg_vector->msg_hdr.msg_namelen = vp->fds->remote_addr_size; in vector_enqueue() 401 vp->fds->tx_fd, in vector_send() 777 if (vp->fds != NULL) in vector_remove() 844 pkt_len = uml_vector_recvmsg(vp->fds->rx_fd, &hdr, 0); in vector_legacy_rx() 892 vp->fds->tx_fd, in writev_tx() 937 vp->fds->rx_fd, qi->mmsg_vector, qi->max_depth, 0); in vector_mmsg_rx() 1100 if (vp->fds == NULL) in vector_net_close() 1113 if (vp->fds->rx_fd > 0) { in vector_net_close() 1114 os_close_file(vp->fds->rx_fd); in vector_net_close() [all …]
|
/Linux-v4.19/tools/perf/bench/ |
D | sched-messaging.c | 56 static void fdpair(int fds[2]) in fdpair() 59 if (pipe(fds) == 0) in fdpair() 62 if (socketpair(AF_UNIX, SOCK_STREAM, 0, fds) == 0) in fdpair() 208 int fds[2]; in group() local 216 fdpair(fds); in group() 219 ctx->in_fds[0] = fds[0]; in group() 220 ctx->in_fds[1] = fds[1]; in group() 226 snd_ctx->out_fds[i] = fds[1]; in group() 228 close(fds[0]); in group()
|
/Linux-v4.19/tools/perf/tests/ |
D | bpf.c | 37 int fds[2], i; in llseek_loop() local 39 fds[0] = open("/dev/null", O_RDONLY); in llseek_loop() 40 fds[1] = open("/dev/null", O_RDWR); in llseek_loop() 42 if (fds[0] < 0 || fds[1] < 0) in llseek_loop() 46 lseek(fds[i % 2], i, (i / 2) % 2 ? SEEK_CUR : SEEK_SET); in llseek_loop() 47 lseek(fds[(i + 1) % 2], i, (i / 2) % 2 ? SEEK_CUR : SEEK_SET); in llseek_loop() 49 close(fds[0]); in llseek_loop() 50 close(fds[1]); in llseek_loop()
|
/Linux-v4.19/arch/um/os-Linux/drivers/ |
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-v4.19/tools/testing/selftests/sync/ |
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-v4.19/tools/virtio/ |
D | virtio_test.c | 38 struct pollfd fds[1]; member 109 dev->fds[info->idx].fd = info->call; in vq_info_add() 110 dev->fds[info->idx].events = POLLIN; in vq_info_add() 147 poll(dev->fds, dev->nvqs, -1); in wait_for_interrupt() 149 if (dev->fds[i].revents & POLLIN) { in wait_for_interrupt() 150 read(dev->fds[i].fd, &val, sizeof val); in wait_for_interrupt()
|
/Linux-v4.19/samples/bpf/ |
D | xdpsock_user.c | 803 struct pollfd fds[MAX_SOCKS + 1]; in rx_drop_all() local 806 memset(fds, 0, sizeof(fds)); in rx_drop_all() 809 fds[i].fd = xsks[i]->sfd; in rx_drop_all() 810 fds[i].events = POLLIN; in rx_drop_all() 816 ret = poll(fds, nfds, timeout); in rx_drop_all() 829 struct pollfd fds[nfds + 1]; in tx_only() local 832 memset(fds, 0, sizeof(fds)); in tx_only() 833 fds[0].fd = xsk->sfd; in tx_only() 834 fds[0].events = POLLOUT; in tx_only() 839 ret = poll(fds, nfds, timeout); in tx_only() [all …]
|
/Linux-v4.19/tools/usb/usbip/src/ |
D | usbipd.c | 509 struct pollfd *fds; in do_standalone_mode() local 558 fds = calloc(nsockfd, sizeof(struct pollfd)); in do_standalone_mode() 560 fds[i].fd = sockfdlist[i]; in do_standalone_mode() 561 fds[i].events = POLLIN; in do_standalone_mode() 574 r = ppoll(fds, nsockfd, &timeout, &sigmask); in do_standalone_mode() 580 if (fds[i].revents & POLLIN) { in do_standalone_mode() 592 free(fds); in do_standalone_mode()
|
/Linux-v4.19/tools/testing/selftests/powerpc/pmu/ebb/ |
D | task_event_vs_ebb_test.c | 45 FAIL_IF(pipe(read_pipe.fds) == -1); in task_event_vs_ebb() 46 FAIL_IF(pipe(write_pipe.fds) == -1); in task_event_vs_ebb()
|
D | ebb_on_child_test.c | 52 FAIL_IF(pipe(read_pipe.fds) == -1); in ebb_on_child() 53 FAIL_IF(pipe(write_pipe.fds) == -1); in ebb_on_child()
|
D | ebb_on_willing_child_test.c | 59 FAIL_IF(pipe(read_pipe.fds) == -1); in ebb_on_willing_child() 60 FAIL_IF(pipe(write_pipe.fds) == -1); in ebb_on_willing_child()
|
D | task_event_pinned_vs_ebb_test.c | 47 FAIL_IF(pipe(read_pipe.fds) == -1); in task_event_pinned_vs_ebb() 48 FAIL_IF(pipe(write_pipe.fds) == -1); in task_event_pinned_vs_ebb()
|
D | cpu_event_vs_ebb_test.c | 50 FAIL_IF(pipe(read_pipe.fds) == -1); in cpu_event_vs_ebb() 51 FAIL_IF(pipe(write_pipe.fds) == -1); in cpu_event_vs_ebb()
|
D | ebb_vs_cpu_event_test.c | 50 FAIL_IF(pipe(read_pipe.fds) == -1); in ebb_vs_cpu_event() 51 FAIL_IF(pipe(write_pipe.fds) == -1); in ebb_vs_cpu_event()
|