/frameworks/av/services/audioflinger/ |
H A D | MonoPipeReader.h | 30 // any data already in the pipe is visible to this PipeReader. 33 MonoPipeReader(MonoPipe* pipe); 55 MonoPipe* pipe() const { return mPipe; }
|
H A D | PipeReader.h | 31 PipeReader(Pipe& pipe); 53 Pipe& pipe() const { return mPipe; }
|
H A D | PipeReader.cpp | 26 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 D | MonoPipeReader.cpp | 26 MonoPipeReader::MonoPipeReader(MonoPipe* pipe) : argument 27 NBAIO_Source(pipe->mFormat), 28 mPipe(pipe)
|
H A D | AudioFlinger.cpp | 1832 MonoPipe *pipe = (MonoPipe *)mPipeSink.get(); local 1833 latency += (pipe->getAvgFrames() * 1000) / mSampleRate; 2244 // This pipe depth compensates for scheduling latency of the normal mixer thread. 2246 // finally blocking. Note the pipe implementation rounds up the request to a power of 2. 2741 MonoPipe *pipe = (MonoPipe *)mPipeSink.get(); local 2742 if (pipe != NULL) { 2743 pipe->setAvgFrames((mScreenState & 1) ? 2744 (pipe->maxFrames() * 7) / 8 : mNormalFrameCount * 2);
|
/frameworks/native/libs/utils/tests/ |
H A D | Looper_test.cpp | 44 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 D | TestHelpers.h | 31 ::pipe(fds);
|
/frameworks/base/core/java/android/net/http/ |
H A D | Connection.java | 164 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 D | InputChannel_test.cpp | 40 // 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 D | TestHelpers.h | 31 ::pipe(fds);
|
/frameworks/av/media/libaah_rtp/ |
H A D | pipe_event.cpp | 33 // Create the pipe. 34 if (pipe(pipe_) >= 0) { 35 // Set non-blocking mode on the read side of the pipe so we can 39 ALOGE("Failed to create pipe event %d %d %d",
|
/frameworks/base/core/jni/ |
H A D | android_os_ParcelFileDescriptor.cpp | 58 if (pipe(fds) < 0) {
|
H A D | android_app_NativeActivity.cpp | 113 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 D | utils.c | 325 if (pipe(fds)) { 326 fprintf(stderr, "pipe: %s\n", strerror(errno));
|
/frameworks/native/libs/utils/ |
H A D | Looper.cpp | 73 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 D | ZygoteConnection.java | 225 FileDescriptor[] pipeFds = Libcore.os.pipe(); 234 logAndPrintError(newStderr, "Exception creating pipe", ex); 236 logAndPrintError(newStderr, "Exception creating pipe", ex); 787 * @param pipeFd null-ok; pipe for communication back to Zygote. 885 * @param pipeFd null-ok; pipe for communication with child.
|
/frameworks/base/services/input/ |
H A D | EventHub.cpp | 220 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.",
|
/frameworks/base/services/java/com/android/server/ |
H A D | BackupManagerService.java | 2330 FullBackupRunner(PackageInfo pack, IBackupAgent agent, ParcelFileDescriptor pipe, argument 2334 mPipe = ParcelFileDescriptor.dup(pipe.getFileDescriptor()); 3037 Slog.w(TAG, "Close of restore data pipe threw", e); 3234 // If the policy is satisfied, go ahead and set up to pipe the 3291 // restore data as well as a pipe for sending data to 3293 // pipe. 3332 FileOutputStream pipe = new FileOutputStream( 3342 // send it to the output pipe as long as things 3346 pipe.write(buffer, 0, nRead); 3348 Slog.e(TAG, "Failed to write to restore pipe", [all...] |
/frameworks/compile/mclinker/utils/gtest/src/ |
H A D | gtest-all.cpp | 6467 // severity. On Windows, the message is read from a pipe handle. On other 6550 // test child process via a pipe, interprets it to set the outcome_ 6568 // Descriptor to the read end of the pipe to the child process. It is 6570 // pipe in write_fd_. 6572 // Descriptor to the child's write end of the pipe to the parent process. 6574 // pipe in read_fd_. 6579 // test child process via a pipe, interprets it to set the outcome_ 6587 // failure of the death test) or until the pipe is closed (signifying 6629 // it finds any data in our pipe. So, here we write a single flag byte 6630 // to the pipe, the [all...] |