Home
last modified time | relevance | path

Searched refs:pipe (Results 1 – 25 of 58) sorted by relevance

123

/frameworks/av/media/libnbaio/
DPipeReader.cpp27 PipeReader::PipeReader(Pipe& pipe) : in PipeReader() argument
28 NBAIO_Source(pipe.mFormat), in PipeReader()
29 mPipe(pipe), mFifoReader(mPipe.mFifo, false /*throttlesWriter*/, false /*flush*/), in PipeReader()
33 android_atomic_inc(&pipe.mReaders); in PipeReader()
DMonoPipeReader.cpp26 MonoPipeReader::MonoPipeReader(MonoPipe* pipe) : in MonoPipeReader() argument
27 NBAIO_Source(pipe->mFormat), in MonoPipeReader()
28 mPipe(pipe), mFifoReader(mPipe->mFifo, true /*throttlesWriter*/) in MonoPipeReader()
/frameworks/native/services/surfaceflinger/tests/
DDumpsys_test.cpp27 FILE* pipe = popen(cmd.c_str(), "r"); in runShellCommand() local
28 if (!pipe) { in runShellCommand()
33 while (fgets(buffer, sizeof(buffer), pipe) != NULL) { in runShellCommand()
37 pclose(pipe); in runShellCommand()
/frameworks/base/core/java/com/android/internal/os/
DTransferPipe.java104 ParcelFileDescriptor[] pipe = ParcelFileDescriptor.createPipe(); in dumpAsync() local
106 TransferPipe.dumpAsync(binder, pipe[1].getFileDescriptor(), args); in dumpAsync()
109 pipe[1].close(); in dumpAsync()
110 pipe[1] = null; in dumpAsync()
114 try (FileInputStream is = new FileInputStream(pipe[0].getFileDescriptor())) { in dumpAsync()
128 pipe[0].close(); in dumpAsync()
129 IoUtils.closeQuietly(pipe[1]); in dumpAsync()
/frameworks/av/media/libnbaio/include_mono/media/nbaio/
DMonoPipeReader.h33 MonoPipeReader(MonoPipe* pipe);
57 MonoPipe* pipe() const { return mPipe; }
/frameworks/base/core/java/com/android/internal/infra/
DRemoteStream.java189 ParcelFileDescriptor[] pipe;
192 pipe = ParcelFileDescriptor.createPipe();
193 try (ParcelFileDescriptor remotePipe = pipe[read ? 1 : 0]) {
198 mLocalPipe = pipe[read ? 0 : 1];
/frameworks/av/media/libnbaio/include/media/nbaio/
DPipeReader.h31 PipeReader(Pipe& pipe);
55 Pipe& pipe() const { return mPipe; }
/frameworks/base/packages/SystemUI/scripts/
Dnew_merge.py96 pipe = Popen(['git', 'diff', '--name-only', argv[1]], stdout=PIPE).stdout
97 for line in iter(pipe.readline,''):
102 pipe.close()
/frameworks/base/core/java/android/permission/
DIPermissionController.aidl34 void getRuntimePermissionBackup(in UserHandle user, in ParcelFileDescriptor pipe); in getRuntimePermissionBackup() argument
35 void stageAndApplyRuntimePermissionsBackup(in UserHandle user, in ParcelFileDescriptor pipe); in stageAndApplyRuntimePermissionsBackup() argument
DPermissionControllerService.java518 public void getRuntimePermissionBackup(UserHandle user, ParcelFileDescriptor pipe) { in onBind() argument
520 checkNotNull(pipe); in onBind()
524 try (OutputStream backup = new ParcelFileDescriptor.AutoCloseOutputStream(pipe)) { in onBind()
537 ParcelFileDescriptor pipe) { in onBind() argument
539 checkNotNull(pipe); in onBind()
544 try (InputStream backup = new ParcelFileDescriptor.AutoCloseInputStream(pipe)) { in onBind()
/frameworks/base/libs/androidfw/
DPosixUtils.cpp50 if (pipe(stdout) != 0) { in ExecuteBinary()
56 if (pipe(stderr) != 0) { in ExecuteBinary()
/frameworks/base/services/core/java/com/android/server/tracing/
DTracingServiceProxy.java198 ParcelFileDescriptor[] pipe = ParcelFileDescriptor.createPipe(); in reportTrace()
200 try (AutoCloseOutputStream o = new AutoCloseOutputStream(pipe[1])) { in reportTrace()
209 params.fd = pipe[0]; in reportTrace()
/frameworks/libs/binary_translation/tests/ndk_program_tests/
Depoll_test.cc24 ASSERT_EQ(pipe(pipefd), 0); in TEST()
/frameworks/av/services/audioflinger/afutils/
DNBAIO_Tee.cpp230 Pipe *pipe = new Pipe(frames, format); in makeSinkSource() local
233 ssize_t index = pipe->negotiate( in makeSinkSource()
239 PipeReader *pipeReader = new PipeReader(*pipe); in makeSinkSource()
248 return {pipe, pipeReader}; in makeSinkSource()
/frameworks/av/media/mtp/tests/MtpFfsHandleTest/
DMtpFfsHandle_test.cpp69 EXPECT_EQ(pipe(fd), 0); in MtpFfsHandleTest()
73 EXPECT_EQ(pipe(fd), 0); in MtpFfsHandleTest()
78 EXPECT_EQ(pipe(fd), 0); in MtpFfsHandleTest()
83 EXPECT_EQ(pipe(fd), 0); in MtpFfsHandleTest()
/frameworks/libs/binary_translation/tests/ndk_program_tests/arm/
Dsyscall_test.cc62 ASSERT_EQ(pipe(pipefd), 0); in TEST()
/frameworks/native/libs/binder/
DFdUtils.h48 if (pipe(pipefd) != 0) {
/frameworks/native/cmds/bugreportz/
Dbugreportz_test.cpp37 ASSERT_EQ(0, pipe(fds)); in SetUp()
/frameworks/av/media/module/bufferpool/1.0/vts/
Dmulti.cpp80 ASSERT_TRUE(pipe(mCommandPipeFds) == 0); in SetUp()
81 ASSERT_TRUE(pipe(mResultPipeFds) == 0); in SetUp()
/frameworks/av/media/module/minijail/
Dminijail.cpp35 if (pipe(pipefd) == -1) { in WritePolicyToPipe()
/frameworks/av/media/module/bufferpool/2.0/tests/
Dmulti.cpp78 ASSERT_TRUE(pipe(mCommandPipeFds) == 0); in SetUp()
79 ASSERT_TRUE(pipe(mResultPipeFds) == 0); in SetUp()
Dcond.cpp81 ASSERT_TRUE(pipe(mCommandPipeFds) == 0); in SetUp()
82 ASSERT_TRUE(pipe(mResultPipeFds) == 0); in SetUp()
/frameworks/base/cmds/incidentd/src/
DSection.cpp235 Fpipe pipe; member
268 if (!data->pipe.init()) { in Execute()
275 status_t err = data->section->BlockingCall(data->pipe.writeFd()); in Execute()
282 data->pipe.writeFd().reset(); in Execute()
291 err = buffer.read(data->pipe.readFd().get(), this->timeoutMs); in Execute()
300 data->pipe.close(); in Execute()
/frameworks/base/services/backup/
Dflags.aconfig33 description: "Enables clearing the pipe buffer after restoring a single file to a BackupAgent."
/frameworks/base/core/java/android/os/
DFileUtils.java547 FileDescriptor[] pipes = Os.pipe(); in copyInternalSpliceSocket()
1703 private final FileDescriptor[] pipe; field in FileUtils.MemoryPipe
1709 this.pipe = Os.pipe(); in MemoryPipe()
1733 return sink ? pipe[1] : pipe[0]; in getFD()
1737 return sink ? pipe[0] : pipe[1]; in getInternalFD()

123