Searched refs:pipe (Results 1 - 18 of 18) sorted by relevance

/frameworks/av/include/media/nbaio/
H A DMonoPipeReader.h30 // any data already in the pipe is visible to this PipeReader.
33 MonoPipeReader(MonoPipe* pipe);
55 MonoPipe* pipe() const { return mPipe; }
H A DPipeReader.h31 PipeReader(Pipe& pipe);
53 Pipe& pipe() const { return mPipe; }
/frameworks/native/libs/utils/tests/
H A DLooper_test.cpp44 DelayedWriteSignal(int delayMillis, Pipe* pipe) : argument
45 DelayedTask(delayMillis), mPipe(pipe) {
165 Pipe pipe; local
168 handler.setCallback(mLooper, pipe.receiveFd, ALOOPER_EVENT_INPUT);
183 Pipe pipe; local
186 ASSERT_EQ(OK, pipe.writeSignal());
187 handler.setCallback(mLooper, pipe.receiveFd, ALOOPER_EVENT_INPUT);
199 EXPECT_EQ(pipe.receiveFd, handler.fd)
200 << "callback should have received pipe fd as parameter";
206 Pipe pipe; local
224 Pipe pipe; local
249 Pipe pipe; local
275 Pipe pipe; local
297 Pipe pipe; local
339 Pipe pipe; local
366 Pipe pipe; local
374 Pipe pipe; local
382 Pipe pipe; local
398 Pipe pipe; local
416 Pipe pipe; local
[all...]
H A DTestHelpers.h31 ::pipe(fds);
/frameworks/av/media/libnbaio/
H A DPipeReader.cpp26 PipeReader::PipeReader(Pipe& pipe) : argument
27 NBAIO_Source(pipe.mFormat),
28 mPipe(pipe),
29 // any data already in the pipe is not visible to this PipeReader
30 mFront(android_atomic_acquire_load(&pipe.mRear)),
34 android_atomic_inc(&pipe.mReaders);
52 // Discard 1/16 of the most recent data in pipe to avoid another overrun immediately
H A DMonoPipeReader.cpp26 MonoPipeReader::MonoPipeReader(MonoPipe* pipe) : argument
27 NBAIO_Source(pipe->mFormat),
28 mPipe(pipe)
/frameworks/base/core/java/android/net/http/
H A DConnection.java164 LinkedList<Request> pipe = new LinkedList<Request>();
171 states[state] + " pipe " + pipe.size());
185 if (pipe.size() == maxPipe) {
251 pipe.addLast(req);
254 state = clearPipe(pipe) ? DONE : SEND;
259 pipe.addLast(req);
267 int pipeSize = pipe.size();
278 req = (Request)pipe.removeFirst();
300 pipe
328 clearPipe(LinkedList<Request> pipe) argument
[all...]
/frameworks/base/libs/androidfw/tests/
H A DInputChannel_test.cpp40 // of a pipe and to check for EPIPE on the other end after the channel is destroyed.
41 Pipe pipe; local
43 sp<InputChannel> inputChannel = new InputChannel(String8("channel name"), pipe.sendFd);
47 EXPECT_EQ(pipe.sendFd, inputChannel->getFd())
52 EXPECT_EQ(-EPIPE, pipe.readSignal())
56 pipe.sendFd = -1;
H A DTestHelpers.h31 ::pipe(fds);
/frameworks/base/core/jni/
H A Dandroid_os_ParcelFileDescriptor.cpp58 if (pipe(fds) < 0) {
H A Dandroid_app_NativeActivity.cpp113 if (pipe(msgpipe)) {
114 ALOGW("could not create pipe: %s", strerror(errno));
120 SLOGW_IF(result != 0, "Could not make AInputQueue read pipe "
123 SLOGW_IF(result != 0, "Could not make AInputQueue write pipe "
636 if (pipe(msgpipe)) {
637 ALOGW("could not create pipe: %s", strerror(errno));
644 SLOGW_IF(result != 0, "Could not make main work read pipe "
647 SLOGW_IF(result != 0, "Could not make main work write pipe "
/frameworks/native/cmds/dumpstate/
H A Dutils.c327 if (pipe(fds)) {
328 fprintf(stderr, "pipe: %s\n", strerror(errno));
/frameworks/native/libs/utils/
H A DLooper.cpp73 int result = pipe(wakeFds);
74 LOG_ALWAYS_FATAL_IF(result != 0, "Could not create wake pipe. errno=%d", errno);
80 LOG_ALWAYS_FATAL_IF(result != 0, "Could not make wake read pipe non-blocking. errno=%d",
84 LOG_ALWAYS_FATAL_IF(result != 0, "Could not make wake write pipe non-blocking. errno=%d",
87 // Allocate the epoll instance and register the wake pipe.
96 LOG_ALWAYS_FATAL_IF(result != 0, "Could not add wake read pipe to epoll instance. errno=%d",
254 ALOGW("Ignoring unexpected epoll events 0x%x on wake read pipe.", epollEvents);
/frameworks/base/core/java/com/android/internal/os/
H A DZygoteConnection.java229 FileDescriptor[] pipeFds = Libcore.os.pipe();
239 logAndPrintError(newStderr, "Exception creating pipe", ex);
241 logAndPrintError(newStderr, "Exception creating pipe", ex);
889 * @param pipeFd null-ok; pipe for communication back to Zygote.
987 * @param pipeFd null-ok; pipe for communication with child.
/frameworks/av/media/libstagefright/wifi-display/
H A DANetworkSession.cpp552 int res = pipe(mPipeFd);
955 ALOGW("Error writing to pipe (%s)", strerror(errno));
1018 ALOGW("Error reading from pipe (%s)", strerror(errno));
/frameworks/base/services/java/com/android/server/
H A DBackupManagerService.java2334 FullBackupRunner(PackageInfo pack, IBackupAgent agent, ParcelFileDescriptor pipe, argument
2338 mPipe = ParcelFileDescriptor.dup(pipe.getFileDescriptor());
3060 Slog.w(TAG, "Close of restore data pipe threw", e);
3257 // If the policy is satisfied, go ahead and set up to pipe the
3314 // restore data as well as a pipe for sending data to
3316 // pipe.
3355 FileOutputStream pipe = new FileOutputStream(
3365 // send it to the output pipe as long as things
3369 pipe.write(buffer, 0, nRead);
3371 Slog.e(TAG, "Failed to write to restore pipe",
[all...]
/frameworks/av/services/audioflinger/
H A DAudioFlinger.cpp1877 MonoPipe *pipe = (MonoPipe *)mPipeSink.get(); local
1878 latency += (pipe->getAvgFrames() * 1000) / mSampleRate;
2302 // This pipe depth compensates for scheduling latency of the normal mixer thread.
2304 // finally blocking. Note the pipe implementation rounds up the request to a power of 2.
2779 MonoPipe *pipe = (MonoPipe *)mPipeSink.get(); local
2780 if (pipe != NULL) {
2781 pipe->setAvgFrames((mScreenState & 1) ?
2782 (pipe->maxFrames() * 7) / 8 : mNormalFrameCount * 2);
/frameworks/base/services/input/
H A DEventHub.cpp220 result = pipe(wakeFds);
221 LOG_ALWAYS_FATAL_IF(result != 0, "Could not create wake pipe. errno=%d", errno);
227 LOG_ALWAYS_FATAL_IF(result != 0, "Could not make wake read pipe non-blocking. errno=%d",
231 LOG_ALWAYS_FATAL_IF(result != 0, "Could not make wake write pipe non-blocking. errno=%d",
236 LOG_ALWAYS_FATAL_IF(result != 0, "Could not add wake read pipe to epoll instance. errno=%d",
734 ALOGW("Received unexpected epoll event 0x%08x for wake read pipe.",

Completed in 5387 milliseconds