Home
last modified time | relevance | path

Searched refs:mStream (Results 1 – 20 of 20) sorted by relevance

/device/google/atv/audio_proxy/
DAudioProxyStreamOut.cpp21 : 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 …]
DOutputStreamImpl.cpp60 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 …]
DAudioProxyStreamOut.h61 audio_proxy_stream_out_t* const mStream;
DOutputStreamImpl.h75 std::unique_ptr<AudioProxyStreamOut> mStream; variable
/device/google/atv/audio_proxy/service/
DStreamOutImpl.cpp78 : 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 …]
DRemoteBusOutputStream.cpp49 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 …]
DWriteThread.cpp32 mStream(std::move(stream)), in WriteThread()
53 mStream = std::move(stream); in updateOutputStream()
136 stream = mStream; in threadLoop()
DRemoteBusOutputStream.h68 std::shared_ptr<IOutputStream> mStream; variable
DWriteThread.h92 std::shared_ptr<BusOutputStream> mStream GUARDED_BY(mStreamLock);
DStreamOutImpl.h170 std::shared_ptr<BusOutputStream> mStream; variable
/device/generic/vulkan-cereal/stream-servers/
DRenderThread.cpp89 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 …]
DRenderThread.h100 android::base::Optional<android::base::MemStream> mStream; variable
/device/generic/goldfish-opengl/system/vulkan_enc/
DVulkanStreamGuest.cpp19 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()
DVulkanStreamGuest.h83 IOStream* mStream = nullptr; variable
/device/generic/goldfish/audio/
Dstream_in.cpp53 : 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
Dstream_out.cpp56 : 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/
DVulkanStream.cpp33 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()
DVulkanStream.h86 IOStream* mStream = nullptr; variable
/device/google/felix/vibrator/common/
DHardwareBase.h50 : 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/
DHardwareBase.h52 : mFunc(func), mValue(value), mStream(stream) {} in Record()
58 const std::ios *mStream; variable
169 ret << mFunc << " '" << names.at(mStream) << "' = '" << mValue << "'"; in toString()