Searched defs:pipe (Results 1 - 8 of 8) sorted by relevance
/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;
|
/frameworks/av/media/libnbaio/ |
H A D | MonoPipeReader.cpp | 26 MonoPipeReader::MonoPipeReader(MonoPipe* pipe) : argument 27 NBAIO_Source(pipe->mFormat), 28 mPipe(pipe)
|
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
|
/frameworks/base/core/java/android/net/http/ |
H A D | Connection.java | 163 LinkedList<Request> pipe = new LinkedList<Request>(); 170 states[state] + " pipe " + pipe.size()); 184 if (pipe.size() == maxPipe) { 250 pipe.addLast(req); 253 state = clearPipe(pipe) ? DONE : SEND; 258 pipe.addLast(req); 266 int pipeSize = pipe.size(); 277 req = (Request)pipe.removeFirst(); 299 pipe 327 clearPipe(LinkedList<Request> pipe) argument [all...] |
/frameworks/av/services/audioflinger/ |
H A D | Tracks.cpp | 160 // It should references the buffer via the pipe. 188 Pipe *pipe = new Pipe(mTeeSinkTrackFrames, pipeFormat); local 191 ssize_t index = pipe->negotiate(offers, 1, NULL, numCounterOffers); 193 PipeReader *pipeReader = new PipeReader(*pipe); 197 mTeeSink = pipe;
|
H A D | AudioFlinger.cpp | 2027 TEE_SINK_NEW, // copy input using a new pipe 2028 TEE_SINK_OLD, // copy input using an existing pipe 2047 Pipe *pipe = new Pipe(mTeeSinkInputFrames, format); local 2050 ssize_t index = pipe->negotiate(offers, 1, NULL, numCounterOffers); 2052 PipeReader *pipeReader = new PipeReader(*pipe); 2056 mRecordTeeSink = pipe; 2058 teeSink = pipe;
|
H A D | Threads.cpp | 2127 MonoPipe *pipe = (MonoPipe *)mPipeSink.get(); local 2128 if (pipe != NULL) { 2129 pipe->setAvgFrames((mScreenState & 1) ? 2130 (pipe->maxFrames() * 7) / 8 : mNormalFrameCount * 2); 2847 // This pipe depth compensates for scheduling latency of the normal mixer thread. 2849 // finally blocking. Note the pipe implementation rounds up the request to a power of 2. 2990 MonoPipe *pipe = (MonoPipe *)mPipeSink.get(); local 2991 latency += (pipe->getAvgFrames() * 1000) / mSampleRate; 5006 ALOGE("not enough memory for pipe buffer size=%zu", pipeSize); 5009 // pipe wil 5011 Pipe *pipe = new Pipe(pipeFramesP2, format, pipeBuffer); local [all...] |
/frameworks/base/services/backup/java/com/android/server/backup/ |
H A D | BackupManagerService.java | 3116 FullBackupRunner(PackageInfo pack, IBackupAgent agent, ParcelFileDescriptor pipe, argument 3122 mPipe = ParcelFileDescriptor.dup(pipe.getFileDescriptor()); 3890 // The transport has its own copy of the read end of the pipe, 3901 // The runner dup'd the pipe half, so we close it here 3905 // Spin off the runner to fetch the app's data and pipe it 3909 // Read data off the engine pipe and pass it to the transport 3910 // pipe until we hit EOD on the input stream. 4029 Slog.w(TAG, "Unable to close pipe!"); 4038 Slog.w(TAG, "Unable to close pipe!"); 4044 // Run the backup and pipe i [all...] |
Completed in 5883 milliseconds