Home
last modified time | relevance | path

Searched refs:writeFd (Results 1 – 18 of 18) sorted by relevance

/frameworks/base/cmds/incidentd/tests/
DFdBuffer_test.cpp131 write(c2pPipe.writeFd(), "poo", 3); in TEST_F()
136 c2pPipe.writeFd().reset(); in TEST_F()
155 p2cPipe.writeFd().reset(); in TEST_F()
157 ASSERT_TRUE(WriteStringToFd(HEAD, c2pPipe.writeFd())); in TEST_F()
158 ASSERT_TRUE(DoDataStream(p2cPipe.readFd(), c2pPipe.writeFd())); in TEST_F()
160 c2pPipe.writeFd().reset(); in TEST_F()
165 c2pPipe.writeFd().reset(); in TEST_F()
168 buffer.readProcessedDataInStream(tf.fd, std::move(p2cPipe.writeFd()), in TEST_F()
185 p2cPipe.writeFd().reset(); in TEST_F()
191 ASSERT_TRUE(WriteStringToFd(data, c2pPipe.writeFd())); in TEST_F()
[all …]
/frameworks/base/services/tests/voiceinteractiontests/src/com/android/server/voiceinteraction/
DHotwordAudioStreamCopierTest.java96 ParcelFileDescriptor writeFd = fakeAudioStreamPipe[1]; in testDefaultCopyBufferLength() local
97 verifyCopyBufferLength(DEFAULT_COPY_BUFFER_LENGTH_BYTES, readFd, writeFd); in testDefaultCopyBufferLength()
139 ParcelFileDescriptor writeFd = fakeAudioStreamPipes.get(i)[1]; in testCustomCopyBufferLength() local
140 verifyCopyBufferLength(copyBufferLengths[i], readFd, writeFd); in testCustomCopyBufferLength()
170 ParcelFileDescriptor writeFd = fakeAudioStreamPipe[1]; in testInvalidCopyBufferLength_NonPositive() local
171 verifyCopyBufferLength(DEFAULT_COPY_BUFFER_LENGTH_BYTES, readFd, writeFd); in testInvalidCopyBufferLength_NonPositive()
199 ParcelFileDescriptor writeFd = fakeAudioStreamPipe[1]; in testInvalidCopyBufferLength_ExceedsMaximum() local
200 verifyCopyBufferLength(DEFAULT_COPY_BUFFER_LENGTH_BYTES, readFd, writeFd); in testInvalidCopyBufferLength_ExceedsMaximum()
228 ParcelFileDescriptor writeFd = fakeAudioStreamPipe[1]; in testInvalidCopyBufferLength_NotAnInt() local
229 verifyCopyBufferLength(DEFAULT_COPY_BUFFER_LENGTH_BYTES, readFd, writeFd); in testInvalidCopyBufferLength_NotAnInt()
[all …]
/frameworks/base/cmds/incidentd/src/
DWorkDirectory.cpp397 status_t ReportFile::startFilteringData(int writeFd, const IncidentReportArgs& args) { in startFilteringData() argument
402 close(writeFd); in startFilteringData()
412 close(writeFd); in startFilteringData()
422 close(writeFd); in startFilteringData()
432 close(writeFd); in startFilteringData()
437 zipPid = fork_execute_cmd((char* const*)GZIP, zipPipe.readFd().release(), writeFd, &status); in startFilteringData()
438 close(writeFd); in startFilteringData()
444 writeFd = zipPipe.writeFd().release(); in startFilteringData()
451 write_header_section(writeFd, in startFilteringData()
457 write_section(writeFd, FIELD_ID_INCIDENT_METADATA, mEnvelope.metadata()); in startFilteringData()
[all …]
Dincidentd_util.cpp89 unique_fd& Fpipe::writeFd() { return mWrite; } in writeFd() function in android::os::incidentd::Fpipe
96 fcntl(input->writeFd().get(), F_SETFD, FD_CLOEXEC); in fork_execute_cmd()
98 int out = output->writeFd().release(); in fork_execute_cmd()
DSection.cpp125 status_t readStatus = buffer.readProcessedDataInStream(fd.get(), std::move(p2cPipe.writeFd()), in Execute()
208 fd.get(), std::move(p2cPipe.writeFd()), std::move(c2pPipe.readFd()), this->timeoutMs, in Execute()
275 status_t err = data->section->BlockingCall(data->pipe.writeFd()); in Execute()
282 data->pipe.writeFd().reset(); in Execute()
378 cmdPipe.writeFd().reset(); in Execute()
479 std::thread worker([write_fd = std::move(dumpPipe.writeFd()), service = std::move(service), in Execute()
806 is_java_process ? 5 : 20, dumpPipe.writeFd().get()); in BlockingCall()
814 dumpPipe.writeFd().reset(); in BlockingCall()
817 dumpPipe.writeFd().reset(); in BlockingCall()
Dincidentd_util.h73 unique_fd& writeFd();
DBroadcaster.cpp402 int writeFd = fds[1]; in send_to_dropbox() local
405 thread th([file, writeFd, args]() { file->startFilteringData(writeFd, args); }); in send_to_dropbox()
DWorkDirectory.h145 status_t startFilteringData(int writeFd, const IncidentReportArgs& args);
DIncidentService.cpp461 int writeFd = fds[1]; in getIncidentReport() local
463 thread th([file, writeFd, args]() { file->startFilteringData(writeFd, args); }); in getIncidentReport()
DReporter.cpp194 return mZipPid > 0 ? mZipPipe.writeFd().get() : mFd; in getFd()
/frameworks/native/libs/binder/tests/
DbinderRpcTestCommon.h199 android::base::unique_fd readFd, writeFd; in mockFileDescriptor() local
200 CHECK(android::base::Pipe(&readFd, &writeFd)) << strerror(errno); in mockFileDescriptor()
201 RpcMaybeThread([writeFd = std::move(writeFd), contents = std::move(contents)]() { in mockFileDescriptor()
203 if (!WriteStringToFd(contents, writeFd)) { in mockFileDescriptor()
DbinderThroughputTest.cpp55 Pipe(int readFd, int writeFd) : m_readFd{readFd}, m_writeFd{writeFd} {} in Pipe() argument
Dschd-dbg.cpp154 Pipe(int readFd, int writeFd) : m_readFd{readFd}, m_writeFd{writeFd} { in Pipe() argument
DbinderRpcTest.cpp286 auto writeFd = std::to_string(writeEnd.get()); in createRpcTestSocketServerProcessEtc() local
288 execl(servicePath.c_str(), servicePath.c_str(), writeFd.c_str(), readFd.c_str(), in createRpcTestSocketServerProcessEtc()
/frameworks/base/core/jni/
Dandroid_hardware_camera2_CameraMetadata.cpp429 int writeFd; member
439 p->metadata->dump(p->writeFd, /*verbosity*/2); in CameraMetadata_writeMetadataThread()
441 if (close(p->writeFd) < 0) { in CameraMetadata_writeMetadataThread()
463 int writeFd, readFd; in CameraMetadata_dump() local
473 writeFd = sv[0]; in CameraMetadata_dump()
486 writeFd, in CameraMetadata_dump()
495 close(writeFd); in CameraMetadata_dump()
/frameworks/base/services/core/jni/
Dcom_android_server_pm_PackageManagerShellCommandDataLoader.cpp841 auto& writeFd = writeFds[fileIdx]; in receiver() local
842 if (writeFd < 0) { in receiver()
843 writeFd.reset(this->mIfs->openForSpecialOps(fileId).release()); in receiver()
844 if (writeFd < 0) { in receiver()
846 -writeFd); in receiver()
852 .fileFd = writeFd, in receiver()
/frameworks/base/services/incremental/
DIncrementalService.cpp2141 const auto writeFd = mIncFs->openForSpecialOps(ifs->control, fileId); in setFileContent() local
2142 if (!writeFd.ok()) { in setFileContent()
2144 << " errno: " << writeFd.get(); in setFileContent()
2145 return writeFd.get(); in setFileContent()
2156 .fileFd = writeFd.get(), in setFileContent()
/frameworks/base/telephony/java/android/telephony/
DTelephonyManager.java4888 ParcelFileDescriptor writeFd; in uploadCallComposerPicture() local
4892 writeFd = pipe[1]; in uploadCallComposerPicture()
4900 OutputStream output = new ParcelFileDescriptor.AutoCloseOutputStream(writeFd); in uploadCallComposerPicture()
4950 writeFd.closeWithError("input closed"); in uploadCallComposerPicture()
4969 writeFd.closeWithError("too large"); in uploadCallComposerPicture()
4983 writeFd.closeWithError("remote end closed"); in uploadCallComposerPicture()