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.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/av/services/audioflinger/
H A DTracks.cpp152 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 DAudioFlinger.cpp1731 TEE_SINK_NEW, // copy input using a new pipe
1732 TEE_SINK_OLD, // copy input using an existing pipe
1751 Pipe *pipe = new Pipe(mTeeSinkInputFrames, format); local
1754 ssize_t index = pipe->negotiate(offers, 1, NULL, numCounterOffers);
1756 PipeReader *pipeReader = new PipeReader(*pipe);
1760 mRecordTeeSink = pipe;
1762 teeSink = pipe;
H A DThreads.cpp1892 MonoPipe *pipe = (MonoPipe *)mPipeSink.get(); local
1893 if (pipe != NULL) {
1894 pipe->setAvgFrames((mScreenState & 1) ?
1895 (pipe->maxFrames() * 7) / 8 : mNormalFrameCount * 2);
2494 // This pipe depth compensates for scheduling latency of the normal mixer thread.
2496 // finally blocking. Note the pipe implementation rounds up the request to a power of 2.
2636 MonoPipe *pipe = (MonoPipe *)mPipeSink.get(); local
2637 latency += (pipe->getAvgFrames() * 1000) / mSampleRate;
/frameworks/base/services/java/com/android/server/
H A DBackupManagerService.java2567 FullBackupRunner(PackageInfo pack, IBackupAgent agent, ParcelFileDescriptor pipe, argument
2571 mPipe = ParcelFileDescriptor.dup(pipe.getFileDescriptor());
3297 Slog.w(TAG, "Close of restore data pipe threw", e);
3495 // If the policy is satisfied, go ahead and set up to pipe the
3552 // restore data as well as a pipe for sending data to
3554 // pipe.
3601 FileOutputStream pipe = new FileOutputStream(
3611 // send it to the output pipe as long as things
3615 pipe.write(buffer, 0, nRead);
3617 Slog.e(TAG, "Failed to write to restore pipe",
[all...]

Completed in 7426 milliseconds