| /hardware/interfaces/bluetooth/audio/2.0/default/ |
| D | A2dpSoftwareAudioProvider.cpp | 48 : BluetoothAudioProvider(), mDataMQ(nullptr) { in A2dpSoftwareAudioProvider()
54 mDataMQ = std::move(tempDataMQ); in A2dpSoftwareAudioProvider()
63 return (sessionType == session_type_ && mDataMQ && mDataMQ->isValid()); in isValid()
96 if (mDataMQ && mDataMQ->isValid()) { in onSessionReady()
98 session_type_, stack_iface_, mDataMQ->getDesc(), audio_config_); in onSessionReady()
99 _hidl_cb(BluetoothAudioStatus::SUCCESS, *mDataMQ->getDesc()); in onSessionReady()
|
| D | HearingAidAudioProvider.cpp | 44 : BluetoothAudioProvider(), mDataMQ(nullptr) { in HearingAidAudioProvider()
50 mDataMQ = std::move(tempDataMQ); in HearingAidAudioProvider()
59 return (sessionType == session_type_ && mDataMQ && mDataMQ->isValid()); in isValid()
91 if (mDataMQ && mDataMQ->isValid()) { in onSessionReady()
93 session_type_, stack_iface_, mDataMQ->getDesc(), audio_config_); in onSessionReady()
94 _hidl_cb(BluetoothAudioStatus::SUCCESS, *mDataMQ->getDesc()); in onSessionReady()
|
| D | A2dpSoftwareAudioProvider.h | 48 std::unique_ptr<DataMQ> mDataMQ;
|
| D | HearingAidAudioProvider.h | 48 std::unique_ptr<DataMQ> mDataMQ;
|
| /hardware/interfaces/bluetooth/audio/2.1/default/ |
| D | HearingAidAudioProvider.cpp | 46 : BluetoothAudioProvider(), mDataMQ(nullptr) { in HearingAidAudioProvider()
52 mDataMQ = std::move(tempDataMQ); in HearingAidAudioProvider()
65 return (sessionType == session_type_ && mDataMQ && mDataMQ->isValid()); in isValid()
97 if (mDataMQ && mDataMQ->isValid()) { in onSessionReady()
99 session_type_, stack_iface_, mDataMQ->getDesc(), audio_config_); in onSessionReady()
100 _hidl_cb(BluetoothAudioStatus::SUCCESS, *mDataMQ->getDesc()); in onSessionReady()
|
| D | A2dpSoftwareAudioProvider.cpp | 50 : BluetoothAudioProvider(), mDataMQ(nullptr) { in A2dpSoftwareAudioProvider()
56 mDataMQ = std::move(tempDataMQ); in A2dpSoftwareAudioProvider()
69 return (sessionType == session_type_ && mDataMQ && mDataMQ->isValid()); in isValid()
102 if (mDataMQ && mDataMQ->isValid()) { in onSessionReady()
104 session_type_, stack_iface_, mDataMQ->getDesc(), audio_config_); in onSessionReady()
105 _hidl_cb(BluetoothAudioStatus::SUCCESS, *mDataMQ->getDesc()); in onSessionReady()
|
| D | LeAudioAudioProvider.cpp | 54 : BluetoothAudioProvider(), mDataMQ(nullptr) {} in LeAudioAudioProvider()
168 mDataMQ = std::move(tempDataMQ); in startSession_2_1()
181 if (mDataMQ && mDataMQ->isValid()) { in onSessionReady()
183 session_type_, stack_iface_, mDataMQ->getDesc(), audio_config_); in onSessionReady()
184 _hidl_cb(BluetoothAudioStatus::SUCCESS, *mDataMQ->getDesc()); in onSessionReady()
|
| D | A2dpSoftwareAudioProvider.h | 49 std::unique_ptr<DataMQ> mDataMQ;
|
| D | HearingAidAudioProvider.h | 49 std::unique_ptr<DataMQ> mDataMQ;
|
| D | LeAudioAudioProvider.h | 51 std::unique_ptr<DataMQ> mDataMQ;
|
| /hardware/interfaces/bluetooth/audio/utils/session/ |
| D | BluetoothAudioSession.cpp | 60 : session_type_(session_type), stack_iface_(nullptr), mDataMQ(nullptr) { in BluetoothAudioSession()
160 (mDataMQ != nullptr && mDataMQ->isValid())); in IsSessionReady()
167 mDataMQ = nullptr; in UpdateDataPath()
173 mDataMQ = nullptr; in UpdateDataPath()
176 mDataMQ = std::move(tempDataMQ); in UpdateDataPath()
413 size_t availableToWrite = mDataMQ->availableToWrite(); in OutWritePcmData()
419 if (!mDataMQ->write(static_cast<const uint8_t*>(buffer) + totalWritten, in OutWritePcmData()
449 size_t availableToRead = mDataMQ->availableToRead(); in InReadPcmData()
454 if (!mDataMQ->read(static_cast<uint8_t*>(buffer) + totalRead, in InReadPcmData()
|
| D | BluetoothAudioSession.h | 93 std::unique_ptr<DataMQ> mDataMQ; variable
|
| /hardware/interfaces/audio/core/all-versions/default/ |
| D | StreamIn.cpp | 57 mDataMQ(dataMQ), in ReadThread()
62 mBuffer.reset(new (std::nothrow) uint8_t[mDataMQ->getQuantumCount()]); in init()
71 StreamIn::DataMQ* mDataMQ; member in android::hardware::audio::CPP_VERSION::implementation::__anon4123301e0111::ReadThread
85 size_t availableToWrite = mDataMQ->availableToWrite(); in doRead()
98 if (!mDataMQ->write(&mBuffer[0], readResult)) { in doRead()
378 if (mDataMQ) { in prepareForReading()
435 mDataMQ = std::move(tempDataMQ); in prepareForReading()
445 _hidl_cb(Result::OK, *mCommandMQ->getDesc(), *mDataMQ->getDesc(), *mStatusMQ->getDesc(), in prepareForReading()
|
| D | StreamOut.cpp | 60 mDataMQ(dataMQ), in WriteThread()
65 mBuffer.reset(new (std::nothrow) uint8_t[mDataMQ->getQuantumCount()]); in init()
74 StreamOut::DataMQ* mDataMQ; member in android::hardware::audio::CPP_VERSION::implementation::__anon4890291f0111::WriteThread
88 const size_t availToRead = mDataMQ->availableToRead(); in doWrite()
91 if (mDataMQ->read(&mBuffer[0], availToRead)) { in doWrite()
365 if (mDataMQ) { in prepareForWriting()
421 mDataMQ = std::move(tempDataMQ); in prepareForWriting()
431 _hidl_cb(Result::OK, *mCommandMQ->getDesc(), *mDataMQ->getDesc(), *mStatusMQ->getDesc(), in prepareForWriting()
|
| /hardware/interfaces/audio/aidl/default/ |
| D | Stream.cpp | 56 if (mDataMQ) { in fillDescriptor()
59 desc->audio.set<StreamDescriptor::AudioBuffer::Tag::fmq>(mDataMQ->dupeDesc()); in fillDescriptor()
64 if (mDataMQ) { in getBufferSizeInFrames()
65 return mDataMQ->getQuantumCount() * mDataMQ->getQuantumSize() / getFrameSize(); in getBufferSizeInFrames()
87 if (mDataMQ && !mDataMQ->isValid()) { in isValid()
105 mDataMQ.reset(); in reset()
|
| /hardware/interfaces/audio/core/all-versions/vts/functional/ |
| D | AudioPrimaryHidlHalTest.h | 1003 mDataMQ = std::move(tempDataMQ); in workerInit()
1015 const size_t dataSize = std::min(mData.size() - mDataPosition, mDataMQ->availableToWrite()); in workerCycle()
1016 bool success = mDataMQ->write(mData.data() + mDataPosition, dataSize); in workerCycle()
1063 std::unique_ptr<DataMQ> mDataMQ; variable
1207 mDataMQ = std::move(tempDataMQ); in workerInit()
1238 const size_t dataSize = std::min(mData.size(), mDataMQ->availableToRead()); in workerCycle()
1239 if (!mDataMQ->read(mData.data(), dataSize)) { in workerCycle()
1259 std::unique_ptr<DataMQ> mDataMQ; variable
|
| /hardware/interfaces/audio/core/all-versions/default/include/core/default/ |
| D | StreamIn.h | 147 std::unique_ptr<DataMQ> mDataMQ; member
|
| D | StreamOut.h | 177 std::unique_ptr<DataMQ> mDataMQ; member
|
| /hardware/interfaces/audio/aidl/default/include/core-impl/ |
| D | Stream.h | 101 mDataMQ(std::move(dataMQ)), in StreamContext()
114 DataMQ* getDataMQ() const { return mDataMQ.get(); } in getDataMQ()
154 std::unique_ptr<DataMQ> mDataMQ; variable
|
| /hardware/interfaces/audio/aidl/vts/ |
| D | VtsHalAudioCoreModuleTargetTest.cpp | 640 mDataMQ(maybeCreateDataMQ(descriptor)) {} in StreamContext()
647 if (mDataMQ != nullptr) { in checkIsValid()
648 EXPECT_TRUE(mDataMQ->isValid()); in checkIsValid()
649 EXPECT_GE(mDataMQ->getQuantumCount() * mDataMQ->getQuantumSize(), in checkIsValid()
658 DataMQ* getDataMQ() const { return mDataMQ.get(); } in getDataMQ()
675 std::unique_ptr<DataMQ> mDataMQ; member in StreamContext
868 mDataMQ(context.getDataMQ()), in StreamCommonLogic()
874 StreamContext::DataMQ* getDataMQ() const { return mDataMQ; } in getDataMQ()
903 if (mDataMQ->read(data.data(), readCount)) { in readDataFromMQ()
911 if (mDataMQ->write(mData.data(), mData.size())) { in writeDataToMQ()
[all …]
|