Searched defs:pipe (Results 1 - 8 of 8) sorted by relevance

/frameworks/native/libs/input/tests/
H A DInputChannel_test.cpp41 // 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 DMonoPipeReader.cpp26 MonoPipeReader::MonoPipeReader(MonoPipe* pipe) : argument
27 NBAIO_Source(pipe->mFormat),
28 mPipe(pipe)
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
/frameworks/base/core/java/android/net/http/
H A DConnection.java163 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 DTracks.cpp160 // 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 DAudioFlinger.cpp2027 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 DThreads.cpp2127 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 DBackupManagerService.java3116 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