| /bionic/libc/bionic/ |
| pipe.cpp | 31 int pipe(int pipefd[2]) {
32 return pipe2(pipefd, 0);
|
| /external/libusb/libusb/os/ |
| poll_posix.c | 30 int usbi_pipe(int pipefd[2])
32 int ret = pipe(pipefd);
36 ret = fcntl(pipefd[1], F_GETFL);
41 ret = fcntl(pipefd[1], F_SETFL, ret | O_NONBLOCK);
50 usbi_close(pipefd[0]);
51 usbi_close(pipefd[1]);
|
| poll_posix.h | 9 int usbi_pipe(int pipefd[2]);
|
| /external/ltp/testcases/kernel/syscalls/pipe/ |
| pipe08.c | 67 int pipefd[2]; /* fds for pipe read/write */ local
81 TEST(pipe(pipefd));
88 if ((close_stat = close(pipefd[0])) == -1) {
100 written = write(pipefd[1], wrbuf, length);
|
| pipe09.c | 79 int pipefd[2]; /* fds for pipe read/write */ local
93 TEST(pipe(pipefd));
105 if (close(pipefd[0]) != 0) {
106 tst_resm(TWARN, "pipefd[0] close failed, "
112 if (write(pipefd[1], "A", 1) != 1) {
133 if (close(pipefd[0]) != 0) {
134 perror("pipefd[0] close failed");
139 if (write(pipefd[1], "B", 1) != 1) {
156 if (close(pipefd[1]) != 0) {
158 "pipefd[1] close failed")
[all...] |
| /external/strace/tests/ |
| pipe_maxfd.c | 46 pipe_maxfd(int pipefd[2])
58 if (pipe(pipefd))
64 move_fd(&pipefd[1], &max_fd);
66 move_fd(&pipefd[0], &max_fd);
|
| attach-f-p.c | 53 typedef int pipefd[2]; typedef
54 static pipefd pipes[N];
|
| /external/strace/tests-m32/ |
| pipe_maxfd.c | 46 pipe_maxfd(int pipefd[2])
58 if (pipe(pipefd))
64 move_fd(&pipefd[1], &max_fd);
66 move_fd(&pipefd[0], &max_fd);
|
| attach-f-p.c | 53 typedef int pipefd[2]; typedef
54 static pipefd pipes[N];
|
| /external/strace/tests-mx32/ |
| pipe_maxfd.c | 46 pipe_maxfd(int pipefd[2])
58 if (pipe(pipefd))
64 move_fd(&pipefd[1], &max_fd);
66 move_fd(&pipefd[0], &max_fd);
|
| attach-f-p.c | 53 typedef int pipefd[2]; typedef
54 static pipefd pipes[N];
|
| /external/ltp/testcases/kernel/containers/pidns/ |
| pidns12.c | 52 int pipefd[2]; variable
87 close(pipefd[0]);
99 if (write(pipefd[1], "c:go\0", 5) != 5) {
106 close(pipefd[1]);
134 if (pipe(pipefd) == -1) {
144 close(pipefd[1]);
147 read(pipefd[0], buf, 5);
166 close(pipefd[0]);
|
| /external/ltp/testcases/kernel/syscalls/sendmsg/ |
| sendmsg02.c | 62 static void client(int id, int pipefd[])
71 close(pipefd[0]);
92 write(pipefd[1], &fd, 1);
97 close(pipefd[1]);
100 static void server(int id, int pipefd[])
105 close(pipefd[1]);
115 read(pipefd[0], &fd, 1);
119 close(pipefd[0]);
124 int i, status, pipefd[2]; local
140 if (pipe(pipefd) < 0)
[all...] |
| /external/google-breakpad/src/client/linux/minidump_writer/ |
| linux_dumper_unittest_helper.cc | 59 int pipefd = *static_cast<int *>(data); local
63 if (write(pipefd, &byte, sizeof(byte)) != sizeof(byte)) {
79 int pipefd = atoi(argv[1]); local
90 pthread_create(&threads[i], &thread_attributes, &thread_function, &pipefd);
92 thread_function(&pipefd);
|
| /build/kati/ |
| fileutil.cc | 82 int pipefd[2]; local
83 if (pipe(pipefd) != 0)
88 close(pipefd[1]);
96 ssize_t r = HANDLE_EINTR(read(pipefd[0], buf, 4096));
108 close(pipefd[0]);
112 close(pipefd[0]);
114 if (dup2(pipefd[1], 2) < 0)
122 if (dup2(pipefd[1], 1) < 0)
124 close(pipefd[1]);
|
| /external/ltp/testcases/kernel/syscalls/setrlimit/ |
| setrlimit01.c | 125 int pipefd[2]; local
127 if (pipe(pipefd) == -1)
142 close(pipefd[0]); /* close unused read end */
154 if (write(pipefd[1], &bytes, sizeof(bytes))
158 close(pipefd[1]); /* EOF */
180 close(pipefd[1]); /* close unused write end */
181 if (read(pipefd[0], &bytes, sizeof(bytes)) < sizeof(bytes))
184 close(pipefd[0]);
|
| /frameworks/av/services/minijail/ |
| minijail.cpp | 34 int pipefd[2]; local
35 if (pipe(pipefd) == -1) {
40 base::unique_fd write_end(pipefd[1]);
53 return pipefd[0];
|
| /system/netd/server/ |
| TetherController.cpp | 148 int pipefd[2]; local
150 if (pipe(pipefd) < 0) {
161 close(pipefd[0]);
162 close(pipefd[1]);
167 close(pipefd[1]);
168 if (pipefd[0] != STDIN_FILENO) {
169 if (dup2(pipefd[0], STDIN_FILENO) != STDIN_FILENO) {
173 close(pipefd[0]);
211 close(pipefd[0]);
213 mDaemonFd = pipefd[1]
[all...] |
| /external/dnsmasq/src/ |
| helper.c | 56 int i, pipefd[2]; local
61 if (pipe(pipefd) == -1 || !fix_fd(pipefd[1]) || (pid = fork()) == -1)
69 close(pipefd[0]); /* close reader side */
70 return pipefd[1];
106 max_fd != STDIN_FILENO && max_fd != pipefd[0] && max_fd != event_fd)
118 if (!read_write(pipefd[0], (unsigned char *)&data, sizeof(data), 1))
142 if (!read_write(pipefd[0], buf, data.clid_len, 1))
158 if (!read_write(pipefd[0], buf,
275 close(pipefd[0])
[all...] |
| /external/squashfs-tools/squashfs-tools/ |
| pseudo.c | 221 int res, pipefd[2]; local
223 res = pipe(pipefd);
236 close(pipefd[0]);
238 res = dup(pipefd[1]);
246 close(pipefd[1]);
247 return pipefd[0];
250 close(pipefd[0]);
251 close(pipefd[1]);
|
| /external/toybox/toys/pending/ |
| tar.c | 287 int pipefd[2]; local
290 xpipe(pipefd);
298 xclose(pipefd[1]); /* Close unused write*/
299 dup2(pipefd[0], 0);
303 xclose(pipefd[0]); /* Close unused read end */
304 dup2(pipefd[1], tar_hdl->src_fd); //write to pipe
318 int pipefd[2], status = 0; local
322 if (pipe(pipefd) == -1) error_exit("pipe");
346 xclose(pipefd[1]); // Close unused write
347 dup2(pipefd[0], 0)
510 int pipefd[2]; local
[all...] |
| /cts/suite/audio_quality/test/ |
| RemoteAudioFakeTcpTest.cpp | 59 int pipefd[2]; local
60 if (pipe(pipefd) == -1) {
64 LOGD("pipe %d %d", pipefd[0], pipefd[1]);
65 mSocket = pipefd[0];
66 mPipeWrFd = pipefd[1];
|
| /external/ltp/testcases/kernel/logging/kmsg/ |
| kmsg01.c | 202 int pipefd[2]; local
205 if (pipe(pipefd) != 0)
215 close(pipefd[0]);
217 if (write(pipefd[1], "", 1) == -1)
228 close(pipefd[1]);
231 SAFE_CLOSE(cleanup, pipefd[1]);
235 TEST(timed_read(pipefd[0], timeout_sec));
237 SAFE_CLOSE(cleanup, pipefd[0]);
|
| /bootable/recovery/ |
| install.cpp | 325 int pipefd[2]; local
326 pipe(pipefd);
329 int ret = update_binary_command(path, zip, retry_count, pipefd[1], &args);
331 close(pipefd[0]);
332 close(pipefd[1]);
394 close(pipefd[0]);
395 close(pipefd[1]);
402 close(pipefd[0]);
411 close(pipefd[1]);
419 FILE* from_child = fdopen(pipefd[0], "r")
[all...] |
| /system/bt/service/ |
| gatt_server_old.cc | 123 int pipefd[kPipeNumEnds]; member in struct:bluetooth::gatt::ServerInternals
281 OSI_NO_INTR(status = write(g_internal->pipefd[kPipeWriteEnd],
323 OSI_NO_INTR(status = write(g_internal->pipefd[kPipeWriteEnd], uuid.data(),
492 int status = pipe(pipefd);
518 pipefd{INVALID_FD, INVALID_FD} {}
521 if (pipefd[0] != INVALID_FD) close(pipefd[0]);
522 if (pipefd[1] != INVALID_FD) close(pipefd[1]);
563 *gatt_pipe = internal_->pipefd[kPipeReadEnd]
[all...] |
