| /bionic/libc/bionic/ |
| pipe.cpp | 31 int pipe(int pipefd[2]) {
32 return pipe2(pipefd, 0);
|
| /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);
|
| /system/bt/osi/test/ |
| eager_reader_test.cpp | 75 pipe(pipefd);
84 int pipefd[2]; member in class:EagerReaderTest
118 eager_reader_t *reader = eager_reader_new(pipefd[0], &allocator_malloc, BUFFER_SIZE, SIZE_MAX, "test_thread");
124 eager_reader_t *reader = eager_reader_new(pipefd[0], &allocator_malloc, BUFFER_SIZE, SIZE_MAX, "test_thread");
129 write(pipefd[1], small_data, strlen(small_data));
137 eager_reader_t *reader = eager_reader_new(pipefd[0], &allocator_malloc, BUFFER_SIZE, SIZE_MAX, "test_thread");
142 write(pipefd[1], large_data, strlen(large_data));
|
| /build/kati/ |
| fileutil.cc | 73 int pipefd[2]; local
74 if (pipe(pipefd) != 0)
79 close(pipefd[1]);
87 ssize_t r = read(pipefd[0], buf, 4096);
99 close(pipefd[0]);
103 close(pipefd[0]);
105 if (dup2(pipefd[1], 2) < 0)
113 if (dup2(pipefd[1], 1) < 0)
115 close(pipefd[1]);
|
| /system/netd/server/ |
| TetherController.cpp | 144 int pipefd[2]; local
146 if (pipe(pipefd) < 0) {
157 close(pipefd[0]);
158 close(pipefd[1]);
163 close(pipefd[1]);
164 if (pipefd[0] != STDIN_FILENO) {
165 if (dup2(pipefd[0], STDIN_FILENO) != STDIN_FILENO) {
169 close(pipefd[0]);
197 close(pipefd[0]);
199 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...] |
| dnsmasq.c | 78 int piperead, pipefd[2], err_pipe[2]; local
274 safe_pipe(pipefd, 1);
276 piperead = pipefd[0];
277 pipewrite = pipefd[1];
[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]);
|
| action.c | 2534 int pipefd[2]; local
[all...] |
| /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)
502 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];
|
| /bootable/recovery/ |
| install.cpp | 307 int pipefd[2]; local
308 pipe(pipefd);
311 int ret = update_binary_command(path, zip, retry_count, pipefd[1], &args);
314 close(pipefd[0]);
315 close(pipefd[1]);
378 close(pipefd[0]);
383 close(pipefd[1]);
389 FILE* from_child = fdopen(pipefd[0], "r");
|
| recovery.cpp | 221 int pipefd[2]; local
222 if (pipe(pipefd) == -1) {
247 close(pipefd[1]);
255 close(pipefd[0]);
259 FILE* pipe_fp = fdopen(pipefd[0], "r");
263 close(pipefd[0]);
285 close(pipefd[0]);
290 close(pipefd[0]);
295 if (dup2(pipefd[1], STDOUT_FILENO) == -1) {
298 if (dup2(pipefd[1], STDERR_FILENO) == -1)
[all...] |
| /system/core/adb/ |
| shell_service.cpp | 716 int pipefd[2]; local
717 if (pipe(pipefd) != 0) {
726 WriteFdExactly(pipefd[1], &id, sizeof(id));
727 WriteFdExactly(pipefd[1], &length, sizeof(length));
730 WriteFdExactly(pipefd[1], buf.data(), buf.length());
736 WriteFdExactly(pipefd[1], &id, sizeof(id));
737 WriteFdExactly(pipefd[1], &length, sizeof(length));
738 WriteFdExactly(pipefd[1], &exit_code, sizeof(exit_code));
741 adb_close(pipefd[1]);
742 return pipefd[0]
[all...] |
| /frameworks/native/libs/binder/tests/ |
| binderLibTest.cpp | 65 int pipefd[2]; local
76 ret = pipe(pipefd);
81 snprintf(strpipefd1, sizeof(strpipefd1), "%d", pipefd[1]);
87 close(pipefd[0]);
90 write(pipefd[1], &status, sizeof(status));
94 close(pipefd[1]);
95 ret = read(pipefd[0], &status, sizeof(status));
97 close(pipefd[0]);
611 int pipefd[2]; local
615 ret = pipe2(pipefd, O_NONBLOCK)
[all...] |
| /external/libchrome/sandbox/linux/seccomp-bpf-helpers/ |
| baseline_policy_unittest.cc | 75 int pipefd[2]; local
76 int sys_ret = pipe(pipefd);
78 TestPipeOrSocketPair(base::ScopedFD(pipefd[0]), base::ScopedFD(pipefd[1]));
|
| /external/libpcap/ |
| pcap-canusb-linux.c | 292 int pipefd[2]; local
294 if (pipe(pipefd) == -1)
297 this->rdpipe = pipefd[0];
298 this->wrpipe = pipefd[1];
|
| /external/ppp/pppd/ |
| main.c | 801 int pipefd[2]; local
805 if (pipe(pipefd) == -1)
806 pipefd[0] = pipefd[1] = -1;
833 close(pipefd[1]);
834 complete_read(pipefd[0], numbuf, 1);
835 close(pipefd[0]);
1594 int fd, pipefd[2]; local
[all...] |
| /system/bt/service/ |
| gatt_server_old.cpp | 124 int pipefd[kPipeNumEnds]; member in struct:bluetooth::gatt::ServerInternals
235 OSI_NO_INTR(status = write(g_internal->pipefd[kPipeWriteEnd],
278 OSI_NO_INTR(status = write(g_internal->pipefd[kPipeWriteEnd], uuid.data(),
501 int status = pipe(pipefd);
524 pipefd{INVALID_FD, INVALID_FD} {}
527 if (pipefd[0] != INVALID_FD)
528 close(pipefd[0]);
529 if (pipefd[1] != INVALID_FD)
530 close(pipefd[1]);
571 *gatt_pipe = internal_->pipefd[kPipeReadEnd]
[all...] |
| /bionic/tests/ |
| gtest_main.cpp | 617 int pipefd[2]; local
618 if (pipe(pipefd) == -1) {
622 if (fcntl(pipefd[0], F_SETFL, O_NONBLOCK) == -1) {
632 close(pipefd[0]);
635 dup2(pipefd[1], STDOUT_FILENO);
636 dup2(pipefd[1], STDERR_FILENO);
645 close(pipefd[1]);
647 child_proc.child_read_fd = pipefd[0];
[all...] |
| /cts/tests/tests/os/jni/seccomp-tests/tests/ |
| seccomp_bpf_tests.c | 950 int pipefd[2]; local
955 ASSERT_EQ(0, pipe(pipefd));
962 close(pipefd[0]);
963 tracer(_metadata, pipefd[1], tracee, func, args);
966 close(pipefd[1]);
968 read(pipefd[0], &sync, 1);
969 close(pipefd[0]);
1806 int pipefd[2]; local
[all...] |
| /external/compiler-rt/lib/msan/tests/ |
| msan_test.cc | 761 int* pipefd = new int[2]; local
762 int res = pipe(pipefd);
764 EXPECT_NOT_POISONED(pipefd[0]);
765 EXPECT_NOT_POISONED(pipefd[1]);
766 close(pipefd[0]);
767 close(pipefd[1]);
771 int* pipefd = new int[2]; local
772 int res = pipe2(pipefd, O_NONBLOCK);
774 EXPECT_NOT_POISONED(pipefd[0]);
775 EXPECT_NOT_POISONED(pipefd[1])
791 int* pipefd = new int[2]; local
816 int* pipefd = new int[2]; local
842 int* pipefd = new int[2]; local
[all...] |
| /external/autotest/client/site_tests/security_SeccompSyscallFilters/src/ |
| seccomp_bpf_tests.c | 842 int pipefd[2]; local
855 ASSERT_EQ(0, pipe(pipefd));
862 close(pipefd[0]);
863 tracer(_metadata, tracee, poke_addr, pipefd[1]);
866 close(pipefd[1]);
869 long ret = read(pipefd[0], &sync, 1);
870 close(pipefd[0]);
[all...] |
| /external/compiler-rt/lib/msan/ |
| msan_interceptors.cc | 818 INTERCEPTOR(int, pipe, int pipefd[2]) {
820 return REAL(pipe)(pipefd);
822 int res = REAL(pipe)(pipefd);
824 __msan_unpoison(pipefd, sizeof(int[2]));
828 INTERCEPTOR(int, pipe2, int pipefd[2], int flags) {
830 int res = REAL(pipe2)(pipefd, flags);
832 __msan_unpoison(pipefd, sizeof(int[2]));
[all...] |
| /external/compiler-rt/lib/tsan/rtl/ |
| tsan_interceptors.cc | [all...] |
