/frameworks/av/include/media/nbaio/ |
H A D | MonoPipeReader.h | 30 // any data already in the pipe is visible to this PipeReader. 33 MonoPipeReader(MonoPipe* pipe); 57 MonoPipe* pipe() const { return mPipe; }
|
H A D | PipeReader.h | 31 PipeReader(Pipe& pipe); 53 Pipe& pipe() const { return mPipe; }
|
/frameworks/av/media/libnbaio/ |
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)
|
/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/native/libs/input/tests/ |
H A D | InputChannel_test.cpp | 41 // of a pipe and to check for EPIPE on the other end after the channel is destroyed. 42 Pipe pipe; local 44 sp<InputChannel> inputChannel = new InputChannel(String8("channel name"), pipe.sendFd); 48 EXPECT_EQ(pipe.sendFd, inputChannel->getFd()) 53 EXPECT_EQ(-EPIPE, pipe.readSignal()) 57 pipe.sendFd = -1;
|
H A D | TestHelpers.h | 33 ::pipe(fds);
|
/frameworks/base/packages/Keyguard/scripts/ |
H A D | new_merge.py | 96 pipe = Popen(['git', 'diff', '--name-only', argv[1]], stdout=PIPE).stdout 97 for line in iter(pipe.readline,''): 102 pipe.close()
|
/frameworks/base/packages/PrintSpooler/src/com/android/printspooler/ |
H A D | RemotePrintDocumentAdapter.java | 92 ParcelFileDescriptor[] pipe = ParcelFileDescriptor.createPipe(); 93 source = pipe[0]; 94 sink = pipe[1];
|
/frameworks/base/core/jni/ |
H A D | android_view_InputQueue.cpp | 105 ALOGW("Failed to read from native dispatch pipe: %s", strerror(errno)); 187 if (pipe(pipeFds)) { 188 ALOGW("Could not create native input dispatching pipe: %s", strerror(errno));
|
H A D | android_app_NativeActivity.cpp | 279 if (pipe(msgpipe)) { 280 ALOGW("could not create pipe: %s", strerror(errno)); 287 SLOGW_IF(result != 0, "Could not make main work read pipe " 290 SLOGW_IF(result != 0, "Could not make main work write pipe "
|
/frameworks/base/core/java/android/os/ |
H A D | ParcelFileDescriptor.java | 355 * Create two ParcelFileDescriptors structured as a data pipe. The first 361 final FileDescriptor[] fds = Libcore.os.pipe(); 371 * Create two ParcelFileDescriptors structured as a data pipe. The first 383 final FileDescriptor[] fds = Libcore.os.pipe(); 749 * Detect and throw if the other end of a pipe or socket pair encountered an
|
/frameworks/av/services/audioflinger/ |
H A D | Tracks.cpp | 152 Pipe *pipe = new Pipe(mTeeSinkTrackFrames, pipeFormat); local 155 ssize_t index = pipe->negotiate(offers, 1, NULL, numCounterOffers); 157 PipeReader *pipeReader = new PipeReader(*pipe); 161 mTeeSink = pipe;
|
H A D | AudioFlinger.cpp | 1733 TEE_SINK_NEW, // copy input using a new pipe 1734 TEE_SINK_OLD, // copy input using an existing pipe 1753 Pipe *pipe = new Pipe(mTeeSinkInputFrames, format); local 1756 ssize_t index = pipe->negotiate(offers, 1, NULL, numCounterOffers); 1758 PipeReader *pipeReader = new PipeReader(*pipe); 1762 mRecordTeeSink = pipe; 1764 teeSink = pipe;
|
H A D | Threads.cpp | 1894 MonoPipe *pipe = (MonoPipe *)mPipeSink.get(); local 1895 if (pipe != NULL) { 1896 pipe->setAvgFrames((mScreenState & 1) ? 1897 (pipe->maxFrames() * 7) / 8 : mNormalFrameCount * 2); 2496 // This pipe depth compensates for scheduling latency of the normal mixer thread. 2498 // finally blocking. Note the pipe implementation rounds up the request to a power of 2. 2638 MonoPipe *pipe = (MonoPipe *)mPipeSink.get(); local 2639 latency += (pipe->getAvgFrames() * 1000) / mSampleRate;
|
/frameworks/base/core/java/com/android/internal/os/ |
H A D | ZygoteConnection.java | 217 FileDescriptor[] pipeFds = Libcore.os.pipe(); 227 logAndPrintError(newStderr, "Exception creating pipe", ex); 229 logAndPrintError(newStderr, "Exception creating pipe", ex); 867 * @param pipeFd null-ok; pipe for communication back to Zygote. 950 * @param pipeFd null-ok; pipe for communication with child.
|
/frameworks/native/cmds/dumpstate/ |
H A D | utils.c | 398 if (pipe(fds)) { 399 fprintf(stderr, "pipe: %s\n", strerror(errno));
|
/frameworks/av/media/libstagefright/foundation/ |
H A D | ANetworkSession.cpp | 814 int res = pipe(mPipeFd); 1247 ALOGW("Error writing to pipe (%s)", strerror(errno)); 1310 ALOGW("Error reading from pipe (%s)", strerror(errno));
|
/frameworks/base/services/java/com/android/server/ |
H A D | BackupManagerService.java | 2634 FullBackupRunner(PackageInfo pack, IBackupAgent agent, ParcelFileDescriptor pipe, argument 2638 mPipe = ParcelFileDescriptor.dup(pipe.getFileDescriptor()); 3365 Slog.w(TAG, "Close of restore data pipe threw", e); 3581 // If the policy is satisfied, go ahead and set up to pipe the 3638 // restore data as well as a pipe for sending data to 3640 // pipe. 3687 FileOutputStream pipe = new FileOutputStream( 3697 // send it to the output pipe as long as things 3701 pipe.write(buffer, 0, nRead); 3703 Slog.e(TAG, "Failed to write to restore pipe", [all...] |
/frameworks/base/services/input/ |
H A D | EventHub.cpp | 221 result = pipe(wakeFds); 222 LOG_ALWAYS_FATAL_IF(result != 0, "Could not create wake pipe. errno=%d", errno); 228 LOG_ALWAYS_FATAL_IF(result != 0, "Could not make wake read pipe non-blocking. errno=%d", 232 LOG_ALWAYS_FATAL_IF(result != 0, "Could not make wake write pipe non-blocking. errno=%d", 237 LOG_ALWAYS_FATAL_IF(result != 0, "Could not add wake read pipe to epoll instance. errno=%d", 742 ALOGW("Received unexpected epoll event 0x%08x for wake read pipe.",
|