| /external/ltp/testcases/kernel/syscalls/sendmsg/ |
| D | sendmsg02.c | 63 static void client(int id, int pipefd[]) in client() argument
72 close(pipefd[0]); in client()
93 write(pipefd[1], &fd, 1); in client()
98 close(pipefd[1]); in client()
101 static void server(int id, int pipefd[]) in server() argument
106 close(pipefd[1]); in server()
116 read(pipefd[0], &fd, 1); in server()
120 close(pipefd[0]); in server()
125 int i, status, pipefd[2]; in reproduce() local
141 if (pipe(pipefd) < 0) { in reproduce()
[all …]
|
| /external/strace/tests-m32/ |
| D | ioctl_nsfs.c | 98 int *pipefd = (int *) arg; in child() local
99 close(pipefd[1]); in child()
101 if (read(pipefd[0], &pipefd[1], 1)) in child()
116 int pipefd[2]; in test_user_namespace() local
119 if (pipe(pipefd)) in test_user_namespace()
123 CLONE_NEWUSER | CLONE_UNTRACED | SIGCHLD, pipefd); in test_user_namespace()
128 close(pipefd[0]); in test_user_namespace()
130 close(pipefd[1]); in test_user_namespace()
|
| D | pipe_maxfd.c | 46 pipe_maxfd(int pipefd[2]) in pipe_maxfd()
58 if (pipe(pipefd)) in pipe_maxfd()
64 move_fd(&pipefd[1], &max_fd); in pipe_maxfd()
66 move_fd(&pipefd[0], &max_fd); in pipe_maxfd()
|
| /external/strace/tests-mx32/ |
| D | ioctl_nsfs.c | 98 int *pipefd = (int *) arg; in child() local
99 close(pipefd[1]); in child()
101 if (read(pipefd[0], &pipefd[1], 1)) in child()
116 int pipefd[2]; in test_user_namespace() local
119 if (pipe(pipefd)) in test_user_namespace()
123 CLONE_NEWUSER | CLONE_UNTRACED | SIGCHLD, pipefd); in test_user_namespace()
128 close(pipefd[0]); in test_user_namespace()
130 close(pipefd[1]); in test_user_namespace()
|
| D | pipe_maxfd.c | 46 pipe_maxfd(int pipefd[2]) in pipe_maxfd()
58 if (pipe(pipefd)) in pipe_maxfd()
64 move_fd(&pipefd[1], &max_fd); in pipe_maxfd()
66 move_fd(&pipefd[0], &max_fd); in pipe_maxfd()
|
| /external/strace/tests/ |
| D | ioctl_nsfs.c | 98 int *pipefd = (int *) arg; in child() local
99 close(pipefd[1]); in child()
101 if (read(pipefd[0], &pipefd[1], 1)) in child()
116 int pipefd[2]; in test_user_namespace() local
119 if (pipe(pipefd)) in test_user_namespace()
123 CLONE_NEWUSER | CLONE_UNTRACED | SIGCHLD, pipefd); in test_user_namespace()
128 close(pipefd[0]); in test_user_namespace()
130 close(pipefd[1]); in test_user_namespace()
|
| D | pipe_maxfd.c | 46 pipe_maxfd(int pipefd[2]) in pipe_maxfd()
58 if (pipe(pipefd)) in pipe_maxfd()
64 move_fd(&pipefd[1], &max_fd); in pipe_maxfd()
66 move_fd(&pipefd[0], &max_fd); in pipe_maxfd()
|
| /external/ltp/testcases/kernel/containers/pidns/ |
| D | pidns12.c | 50 int pipefd[2]; variable
85 close(pipefd[0]); in child_fn()
97 if (write(pipefd[1], "c:go\0", 5) != 5) { in child_fn()
104 close(pipefd[1]); in child_fn()
132 if (pipe(pipefd) == -1) { in main()
142 close(pipefd[1]); in main()
145 read(pipefd[0], buf, 5); in main()
164 close(pipefd[0]); in main()
|
| /external/libusb/libusb/os/ |
| D | poll_posix.c | 30 int usbi_pipe(int pipefd[2]) in usbi_pipe()
32 int ret = pipe(pipefd); in usbi_pipe()
36 ret = fcntl(pipefd[1], F_GETFL); in usbi_pipe()
41 ret = fcntl(pipefd[1], F_SETFL, ret | O_NONBLOCK); in usbi_pipe()
50 usbi_close(pipefd[0]); in usbi_pipe()
51 usbi_close(pipefd[1]); in usbi_pipe()
|
| /external/ltp/testcases/kernel/syscalls/pipe/ |
| D | pipe09.c | 80 int pipefd[2]; /* fds for pipe read/write */ in main() local
94 TEST(pipe(pipefd)); in main()
106 if (close(pipefd[0]) != 0) { in main()
113 if (write(pipefd[1], "A", 1) != 1) { in main()
133 if (close(pipefd[0]) != 0) { in main()
139 if (write(pipefd[1], "B", 1) != 1) { in main()
155 if (close(pipefd[1]) != 0) { in main()
160 while ((red = do_read(pipefd[0], rebuf, 100)) > 0) { in main()
|
| D | pipe08.c | 67 int pipefd[2]; /* fds for pipe read/write */ in main() local
81 TEST(pipe(pipefd)); in main()
88 if ((close_stat = close(pipefd[0])) == -1) { in main()
100 written = write(pipefd[1], wrbuf, length); in main()
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | wakeup_fd_pipe.cc | 37 int pipefd[2]; in pipe_init() local
38 int r = pipe(pipefd); in pipe_init()
44 err = grpc_set_socket_nonblocking(pipefd[0], 1); in pipe_init()
46 err = grpc_set_socket_nonblocking(pipefd[1], 1); in pipe_init()
48 fd_info->read_fd = pipefd[0]; in pipe_init()
49 fd_info->write_fd = pipefd[1]; in pipe_init()
|
| /external/wayland/tests/ |
| D | test-runner.c | 288 int pipefd[2]; in is_debugger_attached() local
290 if (pipe(pipefd) == -1) { in is_debugger_attached()
298 close(pipefd[0]); in is_debugger_attached()
299 close(pipefd[1]); in is_debugger_attached()
306 close(pipefd[1]); /* Close unused write end */ in is_debugger_attached()
307 read(pipefd[0], &buf, 1); in is_debugger_attached()
308 close(pipefd[0]); in is_debugger_attached()
319 close(pipefd[0]); in is_debugger_attached()
330 write(pipefd[1], "-", 1); in is_debugger_attached()
333 write(pipefd[1], "+", 1); in is_debugger_attached()
[all …]
|
| /external/ltp/testcases/kernel/syscalls/setrlimit/ |
| D | setrlimit01.c | 126 int pipefd[2]; in test2() local
128 SAFE_PIPE(NULL, pipefd); in test2()
142 close(pipefd[0]); /* close unused read end */ in test2()
154 if (write(pipefd[1], &bytes, sizeof(bytes)) in test2()
158 close(pipefd[1]); /* EOF */ in test2()
179 close(pipefd[1]); /* close unused write end */ in test2()
180 if (read(pipefd[0], &bytes, sizeof(bytes)) < sizeof(bytes)) in test2()
183 close(pipefd[0]); in test2()
|
| /external/google-breakpad/src/client/linux/minidump_writer/ |
| D | linux_dumper_unittest_helper.cc | 59 int pipefd = *static_cast<int *>(data); in thread_function() local
63 if (write(pipefd, &byte, sizeof(byte)) != sizeof(byte)) { in thread_function()
79 int pipefd = atoi(argv[1]); in main() local
90 pthread_create(&threads[i], &thread_attributes, &thread_function, &pipefd); in main()
92 thread_function(&pipefd); in main()
|
| /external/adhd/cras/src/tests/ |
| D | cras_router.c | 26 static int pipefd[2]; variable
32 return write(pipefd[1], "1", 1); in terminate_stream_loop()
134 if (pipe(pipefd) == -1) { in run_file_io_stream()
184 FD_SET(pipefd[0], &poll_set); in run_file_io_stream()
185 pselect(pipefd[0] + 1, &poll_set, NULL, NULL, NULL, NULL); in run_file_io_stream()
191 close(pipefd[0]); in run_file_io_stream()
192 close(pipefd[1]); in run_file_io_stream()
|
| /external/linux-kselftest/tools/testing/selftests/kcmp/ |
| D | kcmp_test.c | 36 int pipefd[2]; in main() local
50 if (pipe(pipefd)) { in main()
64 if (epoll_ctl(epollfd, EPOLL_CTL_ADD, pipefd[0], &ev)) { in main()
69 fddup = dup2(pipefd[1], duped_num); in main()
143 ret = sys_kcmp(pid1, pid1, KCMP_EPOLL_TFD, pipefd[1], in main()
|
| /external/dnsmasq/src/ |
| D | helper.c | 54 int i, pipefd[2]; in create_helper() local
59 if (pipe(pipefd) == -1 || !fix_fd(pipefd[1]) || (pid = fork()) == -1) { in create_helper()
65 close(pipefd[0]); /* close reader side */ in create_helper()
66 return pipefd[1]; in create_helper()
96 max_fd != pipefd[0] && max_fd != event_fd) in create_helper()
107 if (!read_write(pipefd[0], (unsigned char*) &data, sizeof(data), 1)) _exit(0); in create_helper()
128 if (!read_write(pipefd[0], buf, data.clid_len, 1)) continue; in create_helper()
141 if (!read_write(pipefd[0], buf, in create_helper()
238 close(pipefd[0]); in create_helper()
|
| /external/ltp/testcases/kernel/syscalls/write/ |
| D | write05.c | 45 static int pipefd[2]; variable
55 {&pipefd[1], &buf, sizeof(buf), EPIPE},
101 SAFE_PIPE(pipefd); in setup()
102 SAFE_CLOSE(pipefd[0]); in setup()
|
| /external/squashfs-tools/squashfs-tools/ |
| D | pseudo.c | 221 int res, pipefd[2]; in pseudo_exec_file() local
223 res = pipe(pipefd); in pseudo_exec_file()
236 close(pipefd[0]); in pseudo_exec_file()
238 res = dup(pipefd[1]); in pseudo_exec_file()
246 close(pipefd[1]); in pseudo_exec_file()
247 return pipefd[0]; in pseudo_exec_file()
250 close(pipefd[0]); in pseudo_exec_file()
251 close(pipefd[1]); in pseudo_exec_file()
|
| /external/toybox/toys/pending/ |
| D | tar.c | 288 int pipefd[2]; in compress_stream() local
291 xpipe(pipefd); in compress_stream()
299 xclose(pipefd[1]); /* Close unused write*/ in compress_stream()
300 dup2(pipefd[0], 0); in compress_stream()
304 xclose(pipefd[0]); /* Close unused read end */ in compress_stream()
305 dup2(pipefd[1], tar_hdl->src_fd); //write to pipe in compress_stream()
319 int pipefd[2], status = 0; in extract_to_command() local
323 xpipe(pipefd); in extract_to_command()
347 xclose(pipefd[1]); // Close unused write in extract_to_command()
348 dup2(pipefd[0], 0); in extract_to_command()
[all …]
|
| /external/ltp/testcases/kernel/logging/kmsg/ |
| D | kmsg01.c | 195 int pipefd[2]; in timed_read_kmsg() local
198 if (pipe(pipefd) != 0) in timed_read_kmsg()
208 close(pipefd[0]); in timed_read_kmsg()
210 if (write(pipefd[1], "", 1) == -1) in timed_read_kmsg()
221 close(pipefd[1]); in timed_read_kmsg()
224 SAFE_CLOSE(pipefd[1]); in timed_read_kmsg()
228 TEST(timed_read(pipefd[0], timeout_usec)); in timed_read_kmsg()
230 SAFE_CLOSE(pipefd[0]); in timed_read_kmsg()
|
| /external/ppp/pppd/ |
| D | main.c | 775 int pipefd[2]; in detach() local
779 if (pipe(pipefd) == -1) in detach()
780 pipefd[0] = pipefd[1] = -1; in detach()
807 close(pipefd[1]); in detach()
808 complete_read(pipefd[0], numbuf, 1); in detach()
809 close(pipefd[0]); in detach()
1568 int fd, pipefd[2]; in safe_fork() local
1579 if (pipe(pipefd) == -1) in safe_fork()
1580 pipefd[0] = pipefd[1] = -1; in safe_fork()
1588 close(pipefd[1]); in safe_fork()
[all …]
|
| /external/u-boot/scripts/ |
| D | docproc.c | 361 int pipefd[2]; in find_all_symbols() local
370 if (pipe(pipefd)) { in find_all_symbols()
380 close(pipefd[0]); in find_all_symbols()
381 dup2(pipefd[1], 1); in find_all_symbols()
391 close(pipefd[1]); in find_all_symbols()
394 while ((ret = read(pipefd[0], in find_all_symbols()
|
| /external/syzkaller/sys/netbsd/ |
| D | fs.txt | 30 pipe2(pipefd ptr[out, pipefd], flags flags[pipe_flags])
32 pipefd {
|