| /device/google/atv/audio_proxy/ |
| D | AudioProxyStreamOut.cpp | 21 : mStream(stream), mDevice(device) {} in AudioProxyStreamOut()
24 mDevice->close_output_stream(mDevice, mStream); in ~AudioProxyStreamOut()
28 return mStream->write(mStream, buffer, bytes); in write()
34 mStream->get_presentation_position(mStream, in getPresentationPosition()
41 void AudioProxyStreamOut::standby() { mStream->standby(mStream); } in standby()
43 void AudioProxyStreamOut::pause() { mStream->pause(mStream); } in pause()
45 void AudioProxyStreamOut::resume() { mStream->resume(mStream); } in resume()
48 mStream->drain(mStream, static_cast<audio_proxy_drain_type_t>(type)); in drain()
51 void AudioProxyStreamOut::flush() { mStream->flush(mStream); } in flush()
54 mStream->set_volume(mStream, left, right); in setVolume()
|
| D | OutputStreamImpl.cpp | 61 AudioProxyStreamOut* mStream; member in audio_proxy::__anon2d3f4c720111::WriteThread
74 mStream(stream), in WriteThread()
92 return mStream->write(&mBuffer[0], availToRead); in doWrite()
97 mStream->getPresentationPosition(&position.frames, &position.timestamp); in doGetPresentationPosition()
129 : mStream(std::move(stream)), mEventFlag(nullptr, deleteEventFlag) {} in OutputStreamImpl()
145 mStream->standby(); in standby()
212 new WriteThread(&mStopWriteThread, mStream.get(), dataMQ.get(), in prepareForWriting()
233 mStream->pause(); in pause()
238 mStream->resume(); in resume()
243 mStream->drain(type); in drain()
[all …]
|
| D | AudioProxyStreamOut.h | 49 audio_proxy_stream_out_t* const mStream;
|
| /device/generic/vulkan-cereal/snapshot/ |
| D | TextureSaver.cpp | 33 : mStream(std::move(stream)) { in TextureSaver()
35 mStream.putBe64(0); in TextureSaver()
53 mIndex.textures.push_back({texId, ftello64(mStream.get())}); in saveTexture()
55 CompressingStream stream(mStream); in saveTexture()
63 mIndex.startPosInFile = ftello64(mStream.get()); in done()
70 mHasError = ferror(mStream.get()) != 0; in done()
72 mStream.close(); in done()
77 auto start = ftello64(mStream.get()); in writeIndex()
80 mStream.putBe32(static_cast<uint32_t>(mIndex.version)); in writeIndex()
81 mStream.putBe32(static_cast<uint32_t>(mIndex.textures.size())); in writeIndex()
[all …]
|
| D | TextureLoader.cpp | 30 : mStream(std::move(stream)) {} in TextureLoader()
49 HANDLE_EINTR(fseeko64(mStream.get(), mIndex[texId], SEEK_SET)); in loadTexture()
52 loader(&mStream); in loadTexture()
55 DecompressingStream stream(mStream); in loadTexture()
59 if (ferror(mStream.get())) { in loadTexture()
70 if (base::getFileSize(fileno(mStream.get()), &size)) { in readIndex()
73 auto indexPos = mStream.getBe64(); in readIndex()
74 HANDLE_EINTR(fseeko64(mStream.get(), static_cast<int64_t>(indexPos), SEEK_SET)); in readIndex()
75 mVersion = mStream.getBe32(); in readIndex()
79 uint32_t texCount = mStream.getBe32(); in readIndex()
[all …]
|
| D | TextureLoader.h | 76 mStream.close(); in join()
86 mStream.close(); in interrupt()
108 android::base::StdioStream mStream; variable
|
| D | TextureSaver.h | 93 android::base::StdioStream mStream; variable
|
| /device/generic/vulkan-cereal/third-party/angle/src/libANGLE/ |
| D | InfoLog.h | 31 StreamHelper(StreamHelper &&rhs) : mStream(rhs.mStream) { rhs.mStream = nullptr; } in StreamHelper()
35 std::swap(mStream, rhs.mStream);
42 if (mStream) in ~StreamHelper()
44 (*mStream) << std::endl; in ~StreamHelper()
51 (*mStream) << value;
58 StreamHelper(std::stringstream *stream) : mStream(stream) { ASSERT(stream); } in StreamHelper()
60 std::stringstream *mStream; variable
|
| /device/generic/vulkan-cereal/stream-servers/ |
| D | RenderThread.cpp | 86 mStream.emplace(0); in RenderThread()
87 android::base::loadStream(loadStream, &*mStream); in RenderThread()
105 mStream.emplace(0); in RenderThread()
106 android::base::loadStream(loadStream, &*mStream); in RenderThread()
122 mStream.emplace(); in pausePreSnapshot()
143 mStream.clear(); in resume()
162 assert(mStream); in save()
164 android::base::saveStream(stream, *mStream); in save()
198 objects.readBuffer->onLoad(&*mStream); in loadImpl()
199 if (objects.channelStream) objects.channelStream->load(&*mStream); in loadImpl()
[all …]
|
| /device/google/atv/audio_proxy/service/ |
| D | StreamOutImpl.cpp | 78 : mStream(std::move(stream)), in StreamOutImpl()
97 return mStream->getFrameSize(); in getFrameSize()
105 return mBufferSizeMs * mConfig.sampleRateHz * mStream->getFrameSize() / 1000; in getBufferSize()
185 bool success = mStream->standby(); in standby()
222 if (!mStream) { in close()
230 if (!mStream->close()) { in close()
234 mStream = nullptr; in close()
246 return mStream->setVolume(left, right) ? Result::OK : Result::INVALID_STATE; in setVolume()
312 if (!mStream->prepareForWriting(frameSize, framesCount)) { in prepareForWriting()
318 sp<WriteThread>::make(mStream, commandMQ.get(), dataMQ.get(), in prepareForWriting()
[all …]
|
| D | RemoteBusOutputStream.cpp | 49 mStream(std::move(stream)), in RemoteBusOutputStream()
53 bool RemoteBusOutputStream::standby() { return mStream->standby().isOk(); } in standby()
55 bool RemoteBusOutputStream::pause() { return mStream->pause().isOk(); } in pause()
57 bool RemoteBusOutputStream::resume() { return mStream->resume().isOk(); } in resume()
60 return mStream->drain(drain).isOk(); in drain()
63 bool RemoteBusOutputStream::flush() { return mStream->flush().isOk(); } in flush()
65 bool RemoteBusOutputStream::close() { return mStream->close().isOk(); } in close()
68 return mStream->setVolume(left, right).isOk(); in setVolume()
125 ndk::ScopedAStatus status = mStream->prepareForWriting( in prepareForWritingImpl()
|
| D | WriteThread.cpp | 32 mStream(std::move(stream)), in WriteThread()
53 mStream = std::move(stream); in updateOutputStream()
136 stream = mStream; in threadLoop()
|
| D | RemoteBusOutputStream.h | 63 std::shared_ptr<IOutputStream> mStream; variable
|
| /device/generic/goldfish-opengl/system/vulkan_enc/ |
| D | VulkanStreamGuest.cpp | 18 VulkanStreamGuest::VulkanStreamGuest(IOStream *stream): mStream(stream) { in VulkanStreamGuest()
102 if (!mStream->readback(buffer, size)) { in read()
110 uint8_t* streamBuf = (uint8_t*)mStream->alloc(size); in write()
116 mStream->writeFullyAsync(buffer, size); in writeLarge()
137 mStream->flush(); in flush()
145 mStream->incRef(); in incStreamRef()
149 return mStream->decRef(); in decStreamRef()
153 return (uint8_t*)mStream->alloc(size); in reserve()
|
| D | VulkanStreamGuest.h | 82 IOStream* mStream = nullptr; variable
|
| /device/generic/vulkan-cereal/third-party/angle/src/tests/egl_tests/ |
| D | EGLStreamTest.cpp | 413 mStream = eglCreateStreamKHR(mDisplay, nullptr); in testSetUp()
423 EGLBoolean result = eglDestroyStreamKHR(mDisplay, mStream); in testTearDown()
432 EGLStreamKHR mStream = 0; member in __anon23c757f30111::D3D11TextureStreamSamplingTest
475 EGLBoolean result = eglStreamConsumerGLTextureExternalAttribsNV(mDisplay, mStream, nullptr); in TEST_P()
481 result = eglCreateStreamProducerD3DTextureANGLE(mDisplay, mStream, nullptr); in TEST_P()
506 result = eglStreamPostD3DTextureANGLE(mDisplay, mStream, (void *)texture, nullptr); in TEST_P()
512 result = eglStreamConsumerAcquireKHR(mDisplay, mStream); in TEST_P()
523 result = eglStreamConsumerReleaseKHR(mDisplay, mStream); in TEST_P()
590 mDisplay, mStream, const_cast<EGLAttrib *>(consumerAttributes)); in TEST_P()
594 result = eglCreateStreamProducerD3DTextureANGLE(mDisplay, mStream, nullptr); in TEST_P()
[all …]
|
| /device/generic/goldfish/audio/ |
| D | stream_in.cpp | 53 : mStream(stream) in ReadThread()
122 mStream->getDeviceAddress(), in threadLoop()
123 mStream->getAudioConfig(), in threadLoop()
124 mStream->getAudioOutputFlags(), in threadLoop()
125 mStream->getFrameCounter()); in threadLoop()
191 mSource->read(mStream->getEffectiveVolume(), bytesToRead, writer); in doRead()
193 mStream->addInputFramesLost(framesLost); in doRead()
212 StreamIn *const mStream; member
|
| D | stream_out.cpp | 55 : mStream(stream) in WriteThread()
125 mStream->getDeviceAddress(), in threadLoop()
126 mStream->getAudioConfig(), in threadLoop()
127 mStream->getAudioOutputFlags(), in threadLoop()
128 mStream->getFrameCounter()); in threadLoop()
194 mSink->write(mStream->getEffectiveVolume(), mDataMQ.availableToRead(), reader); in doWrite()
216 DevicePortSink::getLatencyMs(mStream->getDeviceAddress(), in doGetLatency()
217 mStream->getAudioConfig()); in doGetLatency()
229 StreamOut *const mStream; member
|
| /device/generic/vulkan-cereal/stream-servers/vulkan/ |
| D | VulkanStream.cpp | 34 VulkanStream::VulkanStream(IOStream *stream) : mStream(stream) { in VulkanStream()
51 mStream = stream; in setStream()
141 if (!mStream->readFully(buffer, size)) { in read()
172 mStream->writeFully(mWriteBuffer.data(), mWritePos); in commitWrite()
|
| /device/google/felix/vibrator/common/ |
| D | HardwareBase.h | 50 : mFunc(func), mValue(value), mStream(stream) {} in Record()
56 const std::ios *mStream; variable
173 ret << mFunc << " '" << names.at(mStream) << "' = '" << mValue << "'"; in toString()
|
| /device/google/lynx/vibrator/common/ |
| D | HardwareBase.h | 50 : mFunc(func), mValue(value), mStream(stream) {} in Record()
56 const std::ios *mStream; variable
173 ret << mFunc << " '" << names.at(mStream) << "' = '" << mValue << "'"; in toString()
|
| /device/google/bluejay/vibrator/common/ |
| D | HardwareBase.h | 50 : mFunc(func), mValue(value), mStream(stream) {} in Record()
56 const std::ios *mStream; variable
173 ret << mFunc << " '" << names.at(mStream) << "' = '" << mValue << "'"; in toString()
|
| /device/google/sunfish/vibrator/common/ |
| D | HardwareBase.h | 52 : mFunc(func), mValue(value), mStream(stream) {} in Record()
58 const std::ios *mStream; variable
169 ret << mFunc << " '" << names.at(mStream) << "' = '" << mValue << "'"; in toString()
|
| /device/generic/vulkan-cereal/third-party/angle/src/common/ |
| D | debug.cpp | 154 mStream << mFunction << "(" << mLine << "): "; in LogMessage()
304 return mStream.str(); in getMessage()
|
| D | debug.h | 68 std::ostream &stream() { return mStream; } in stream()
78 std::ostringstream mStream; variable
|