Searched defs:pipe (Results 1 - 7 of 7) sorted by last modified time

/frameworks/native/libs/utils/tests/
H A DLooper_test.cpp44 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...]
/frameworks/base/services/java/com/android/server/
H A DBackupManagerService.java2334 FullBackupRunner(PackageInfo pack, IBackupAgent agent, ParcelFileDescriptor pipe, argument
2338 mPipe = ParcelFileDescriptor.dup(pipe.getFileDescriptor());
3060 Slog.w(TAG, "Close of restore data pipe threw", e);
3257 // If the policy is satisfied, go ahead and set up to pipe the
3314 // restore data as well as a pipe for sending data to
3316 // pipe.
3355 FileOutputStream pipe = new FileOutputStream(
3365 // send it to the output pipe as long as things
3369 pipe.write(buffer, 0, nRead);
3371 Slog.e(TAG, "Failed to write to restore pipe",
[all...]
/frameworks/base/libs/androidfw/tests/
H A DInputChannel_test.cpp40 // 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;
/frameworks/av/services/audioflinger/
H A DAudioFlinger.cpp1877 MonoPipe *pipe = (MonoPipe *)mPipeSink.get(); local
1878 latency += (pipe->getAvgFrames() * 1000) / mSampleRate;
2302 // This pipe depth compensates for scheduling latency of the normal mixer thread.
2304 // finally blocking. Note the pipe implementation rounds up the request to a power of 2.
2779 MonoPipe *pipe = (MonoPipe *)mPipeSink.get(); local
2780 if (pipe != NULL) {
2781 pipe->setAvgFrames((mScreenState & 1) ?
2782 (pipe->maxFrames() * 7) / 8 : mNormalFrameCount * 2);
/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/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

Completed in 476 milliseconds