Home
last modified time | relevance | path

Searched refs:pipefd (Results 1 – 4 of 4) sorted by relevance

/system/bt/osi/test/
Deager_reader_test.cpp75 pipe(pipefd); in SetUp()
84 int pipefd[2]; member in EagerReaderTest
118 …eager_reader_t *reader = eager_reader_new(pipefd[0], &allocator_malloc, BUFFER_SIZE, SIZE_MAX, "te… in TEST_F()
124 …eager_reader_t *reader = eager_reader_new(pipefd[0], &allocator_malloc, BUFFER_SIZE, SIZE_MAX, "te… in TEST_F()
129 write(pipefd[1], small_data, strlen(small_data)); in TEST_F()
137 …eager_reader_t *reader = eager_reader_new(pipefd[0], &allocator_malloc, BUFFER_SIZE, SIZE_MAX, "te… in TEST_F()
142 write(pipefd[1], large_data, strlen(large_data)); in TEST_F()
/system/netd/server/
DTetherController.cpp136 int pipefd[2]; in startTethering() local
138 if (pipe(pipefd) < 0) { in startTethering()
149 close(pipefd[0]); in startTethering()
150 close(pipefd[1]); in startTethering()
155 close(pipefd[1]); in startTethering()
156 if (pipefd[0] != STDIN_FILENO) { in startTethering()
157 if (dup2(pipefd[0], STDIN_FILENO) != STDIN_FILENO) { in startTethering()
161 close(pipefd[0]); in startTethering()
189 close(pipefd[0]); in startTethering()
191 mDaemonFd = pipefd[1]; in startTethering()
/system/core/adb/
Dshell_service.cpp716 int pipefd[2]; in ReportError() local
717 if (pipe(pipefd) != 0) { in ReportError()
726 WriteFdExactly(pipefd[1], &id, sizeof(id)); in ReportError()
727 WriteFdExactly(pipefd[1], &length, sizeof(length)); in ReportError()
730 WriteFdExactly(pipefd[1], buf.data(), buf.length()); in ReportError()
736 WriteFdExactly(pipefd[1], &id, sizeof(id)); in ReportError()
737 WriteFdExactly(pipefd[1], &length, sizeof(length)); in ReportError()
738 WriteFdExactly(pipefd[1], &exit_code, sizeof(exit_code)); in ReportError()
741 adb_close(pipefd[1]); in ReportError()
742 return pipefd[0]; in ReportError()
/system/bt/service/
Dgatt_server_old.cpp124 int pipefd[kPipeNumEnds]; member
235 OSI_NO_INTR(status = write(g_internal->pipefd[kPipeWriteEnd], in RequestWriteCallback()
278 OSI_NO_INTR(status = write(g_internal->pipefd[kPipeWriteEnd], uuid.data(), in RequestExecWriteCallback()
501 int status = pipe(pipefd); in Initialize()
524 pipefd{INVALID_FD, INVALID_FD} {} in ServerInternals()
527 if (pipefd[0] != INVALID_FD) in ~ServerInternals()
528 close(pipefd[0]); in ~ServerInternals()
529 if (pipefd[1] != INVALID_FD) in ~ServerInternals()
530 close(pipefd[1]); in ~ServerInternals()
571 *gatt_pipe = internal_->pipefd[kPipeReadEnd]; in Initialize()