/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() [all …]
|
D | OutputStreamImpl.cpp | 60 AudioProxyStreamOut* mStream; member in audio_proxy::__anon31df340b0111::WriteThread 73 mStream(stream), in WriteThread() 91 return mStream->write(&mBuffer[0], availToRead); in doWrite() 96 mStream->getPresentationPosition(&position.frames, &position.timestamp); in doGetPresentationPosition() 128 : mStream(std::move(stream)), mEventFlag(nullptr, deleteEventFlag) {} in OutputStreamImpl() 144 mStream->standby(); in standby() 211 new WriteThread(&mStopWriteThread, mStream.get(), dataMQ.get(), in prepareForWriting() 232 mStream->pause(); in pause() 237 mStream->resume(); in resume() 242 mStream->drain(type); in drain() [all …]
|
D | AudioProxyStreamOut.h | 61 audio_proxy_stream_out_t* const mStream;
|
D | OutputStreamImpl.h | 75 std::unique_ptr<AudioProxyStreamOut> mStream; variable
|
/device/google/atv/audio_proxy/service/ |
D | StreamOutImpl.cpp | 78 : mStream(std::move(stream)), in StreamOutImpl() 80 mBufferSizeBytes(mStream->getConfig().bufferSizeBytes), in StreamOutImpl() 81 mLatencyMs(mStream->getConfig().latencyMs), in StreamOutImpl() 97 return mStream->getFrameSize(); in getFrameSize() 101 return mBufferSizeBytes / mStream->getFrameSize(); in getFrameCount() 183 bool success = mStream->standby(); in standby() 220 if (!mStream) { in close() 228 if (!mStream->close()) { in close() 232 mStream = nullptr; in close() 244 return mStream->setVolume(left, right) ? Result::OK : Result::INVALID_STATE; in setVolume() [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() 161 bool RemoteBusOutputStream::start() { return mStream->start().isOk(); } in start() [all …]
|
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 | 68 std::shared_ptr<IOutputStream> mStream; variable
|
D | WriteThread.h | 92 std::shared_ptr<BusOutputStream> mStream GUARDED_BY(mStreamLock);
|
D | StreamOutImpl.h | 170 std::shared_ptr<BusOutputStream> mStream; variable
|
/device/generic/vulkan-cereal/stream-servers/ |
D | RenderThread.cpp | 89 mStream.emplace(0); in RenderThread() 90 android::base::loadStream(loadStream, &*mStream); in RenderThread() 112 mStream.emplace(0); in RenderThread() 113 android::base::loadStream(loadStream, &*mStream); in RenderThread() 129 mStream.emplace(); in pausePreSnapshot() 150 mStream.clear(); in resume() 169 assert(mStream); in save() 171 android::base::saveStream(stream, *mStream); in save() 205 objects.readBuffer->onLoad(&*mStream); in loadImpl() 206 if (objects.channelStream) objects.channelStream->load(&*mStream); in loadImpl() [all …]
|
D | RenderThread.h | 100 android::base::Optional<android::base::MemStream> mStream; variable
|
/device/generic/goldfish-opengl/system/vulkan_enc/ |
D | VulkanStreamGuest.cpp | 19 VulkanStreamGuest::VulkanStreamGuest(IOStream *stream): mStream(stream) { in VulkanStreamGuest() 103 if (!mStream->readback(buffer, size)) { in read() 111 uint8_t* streamBuf = (uint8_t*)mStream->alloc(size); in write() 117 mStream->writeFullyAsync(buffer, size); in writeLarge() 138 mStream->flush(); in flush() 146 mStream->incRef(); in incStreamRef() 150 return mStream->decRef(); in decStreamRef() 154 return (uint8_t*)mStream->alloc(size); in reserve()
|
D | VulkanStreamGuest.h | 83 IOStream* mStream = nullptr; variable
|
/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 | 56 : mStream(stream) in WriteThread() 144 mFrameSize = mStream->getFrameSize(); in threadLoop() 146 mStream->getDeviceAddress(), in threadLoop() 147 mStream->getAudioConfig(), in threadLoop() 148 mStream->getAudioOutputFlags(), in threadLoop() 217 mSink->write(mStream->getEffectiveVolume(), mDataMQ.availableToRead(), reader); in doWrite() 247 DevicePortSink::getLatencyMs(mStream->getDeviceAddress(), in doGetLatency() 248 mStream->getAudioConfig()); in doGetLatency() 260 StreamOut *const mStream; member in android::hardware::audio::CPP_VERSION::implementation::__anond3c31e630111::WriteThread
|
/device/generic/vulkan-cereal/stream-servers/vulkan/ |
D | VulkanStream.cpp | 33 VulkanStream::VulkanStream(IOStream* stream) : mStream(stream) { in VulkanStream() 49 void VulkanStream::setStream(IOStream* stream) { mStream = stream; } in setStream() 135 if (!mStream->readFully(buffer, size)) { in read() 161 int written = mStream->writeFully(mWriteBuffer.data(), mWritePos); in commitWrite()
|
D | VulkanStream.h | 86 IOStream* mStream = nullptr; variable
|
/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/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()
|