blob: 8f19547e45c066a040106e4bbc7229f722a7a0a9 [file] [log] [blame]
Mikhail Naganove5d747e2021-11-16 01:31:03 +00001/*
2 * Copyright (C) 2022 The Android Open Source Project
3 *
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
7 *
8 * http://www.apache.org/licenses/LICENSE-2.0
9 *
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
15 */
16
17#include <algorithm>
Mikhail Naganov111e0ce2022-06-17 21:41:19 +000018#include <chrono>
Mikhail Naganove5d747e2021-11-16 01:31:03 +000019
Mikhail Naganova2c5ddf2022-09-12 22:57:14 +000020#include <Utils.h>
jiabin9a8e6862023-01-12 23:06:37 +000021#include <aidl/android/media/audio/common/AudioInputFlags.h>
Mikhail Naganovf84d6402022-06-16 00:35:31 +000022#include <aidl/android/media/audio/common/AudioIoFlags.h>
23#include <aidl/android/media/audio/common/AudioOutputFlags.h>
Mikhail Naganov0e128dd2023-09-13 18:01:18 -070024#include <error/expected_utils.h>
Mikhail Naganove5d747e2021-11-16 01:31:03 +000025
26#include "ModuleConfig.h"
27
28using namespace android;
Mikhail Naganov111e0ce2022-06-17 21:41:19 +000029using namespace std::chrono_literals;
Mikhail Naganove5d747e2021-11-16 01:31:03 +000030
Mikhail Naganov872d4a62023-03-09 18:19:01 -080031using aidl::android::hardware::audio::common::isBitPositionFlagSet;
Mikhail Naganovf84d6402022-06-16 00:35:31 +000032using aidl::android::hardware::audio::core::IModule;
33using aidl::android::media::audio::common::AudioChannelLayout;
David Lib089c0c2023-08-10 12:47:44 +080034using aidl::android::media::audio::common::AudioDeviceDescription;
Mikhail Naganovef6bc742022-10-06 00:14:19 +000035using aidl::android::media::audio::common::AudioDeviceType;
Mikhail Naganov111e0ce2022-06-17 21:41:19 +000036using aidl::android::media::audio::common::AudioEncapsulationMode;
Mikhail Naganovf84d6402022-06-16 00:35:31 +000037using aidl::android::media::audio::common::AudioFormatDescription;
38using aidl::android::media::audio::common::AudioFormatType;
jiabin9a8e6862023-01-12 23:06:37 +000039using aidl::android::media::audio::common::AudioInputFlags;
Mikhail Naganovf84d6402022-06-16 00:35:31 +000040using aidl::android::media::audio::common::AudioIoFlags;
Mikhail Naganov111e0ce2022-06-17 21:41:19 +000041using aidl::android::media::audio::common::AudioOffloadInfo;
Mikhail Naganovf84d6402022-06-16 00:35:31 +000042using aidl::android::media::audio::common::AudioOutputFlags;
43using aidl::android::media::audio::common::AudioPort;
44using aidl::android::media::audio::common::AudioPortConfig;
45using aidl::android::media::audio::common::AudioPortExt;
46using aidl::android::media::audio::common::AudioProfile;
Mikhail Naganov111e0ce2022-06-17 21:41:19 +000047using aidl::android::media::audio::common::AudioUsage;
Mikhail Naganovf84d6402022-06-16 00:35:31 +000048using aidl::android::media::audio::common::Int;
Mikhail Naganove5d747e2021-11-16 01:31:03 +000049
Mikhail Naganov111e0ce2022-06-17 21:41:19 +000050// static
51std::optional<AudioOffloadInfo> ModuleConfig::generateOffloadInfoIfNeeded(
52 const AudioPortConfig& portConfig) {
53 if (portConfig.flags.has_value() &&
54 portConfig.flags.value().getTag() == AudioIoFlags::Tag::output &&
Mikhail Naganova2c5ddf2022-09-12 22:57:14 +000055 isBitPositionFlagSet(portConfig.flags.value().get<AudioIoFlags::Tag::output>(),
56 AudioOutputFlags::COMPRESS_OFFLOAD)) {
Mikhail Naganov111e0ce2022-06-17 21:41:19 +000057 AudioOffloadInfo offloadInfo;
58 offloadInfo.base.sampleRate = portConfig.sampleRate.value().value;
59 offloadInfo.base.channelMask = portConfig.channelMask.value();
60 offloadInfo.base.format = portConfig.format.value();
Mikhail Naganovd1509422023-02-24 19:50:51 -080061 offloadInfo.bitRatePerSecond = 256000; // Arbitrary value.
Mikhail Naganov111e0ce2022-06-17 21:41:19 +000062 offloadInfo.durationUs = std::chrono::microseconds(1min).count(); // Arbitrary value.
63 offloadInfo.usage = AudioUsage::MEDIA;
64 offloadInfo.encapsulationMode = AudioEncapsulationMode::NONE;
65 return offloadInfo;
66 }
67 return {};
68}
69
Shraddha Basantwani343db5e2023-08-23 12:39:15 +000070std::vector<aidl::android::media::audio::common::AudioPort>
71ModuleConfig::getAudioPortsForDeviceTypes(const std::vector<AudioDeviceType>& deviceTypes,
72 const std::string& connection) {
73 return getAudioPortsForDeviceTypes(mPorts, deviceTypes, connection);
74}
75
Mikhail Naganovef6bc742022-10-06 00:14:19 +000076// static
77std::vector<aidl::android::media::audio::common::AudioPort> ModuleConfig::getBuiltInMicPorts(
78 const std::vector<aidl::android::media::audio::common::AudioPort>& ports) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +000079 return getAudioPortsForDeviceTypes(
80 ports, std::vector<AudioDeviceType>{AudioDeviceType::IN_MICROPHONE,
81 AudioDeviceType::IN_MICROPHONE_BACK});
82}
83
84std::vector<aidl::android::media::audio::common::AudioPort>
85ModuleConfig::getAudioPortsForDeviceTypes(
86 const std::vector<aidl::android::media::audio::common::AudioPort>& ports,
87 const std::vector<AudioDeviceType>& deviceTypes, const std::string& connection) {
Mikhail Naganovef6bc742022-10-06 00:14:19 +000088 std::vector<AudioPort> result;
Shraddha Basantwani343db5e2023-08-23 12:39:15 +000089 for (const auto& port : ports) {
90 if (port.ext.getTag() != AudioPortExt::Tag::device) continue;
91 const auto type = port.ext.get<AudioPortExt::Tag::device>().device.type;
92 if (type.connection == connection) {
93 for (auto deviceType : deviceTypes) {
94 if (type.type == deviceType) {
95 result.push_back(port);
96 }
97 }
98 }
99 }
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000100 return result;
101}
102
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000103template <typename T>
104auto findById(const std::vector<T>& v, int32_t id) {
105 return std::find_if(v.begin(), v.end(), [&](const auto& p) { return p.id == id; });
106}
107
108ModuleConfig::ModuleConfig(IModule* module) {
109 mStatus = module->getAudioPorts(&mPorts);
110 if (!mStatus.isOk()) return;
111 for (const auto& port : mPorts) {
112 if (port.ext.getTag() != AudioPortExt::Tag::device) continue;
113 const auto& devicePort = port.ext.get<AudioPortExt::Tag::device>();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000114 if (devicePort.device.type.connection.empty()) {
Mikhail Naganov00603d12022-05-02 22:52:13 +0000115 const bool isInput = port.flags.getTag() == AudioIoFlags::Tag::input;
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000116 // Permanently attached device.
117 if (isInput) {
118 mAttachedSourceDevicePorts.insert(port.id);
119 } else {
120 mAttachedSinkDevicePorts.insert(port.id);
121 }
David Lib089c0c2023-08-10 12:47:44 +0800122 } else if (devicePort.device.type.connection != AudioDeviceDescription::CONNECTION_VIRTUAL
123 // The "virtual" connection is used for remote submix which is a dynamic
124 // device but it can be connected and used w/o external hardware.
125 && port.profiles.empty()) {
Mikhail Naganov00603d12022-05-02 22:52:13 +0000126 mExternalDevicePorts.insert(port.id);
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000127 }
128 }
129 if (!mStatus.isOk()) return;
130 mStatus = module->getAudioRoutes(&mRoutes);
131 if (!mStatus.isOk()) return;
132 mStatus = module->getAudioPortConfigs(&mInitialConfigs);
133}
134
Mikhail Naganov00603d12022-05-02 22:52:13 +0000135std::vector<AudioPort> ModuleConfig::getAttachedDevicePorts() const {
136 std::vector<AudioPort> result;
137 std::copy_if(mPorts.begin(), mPorts.end(), std::back_inserter(result), [&](const auto& port) {
138 return mAttachedSinkDevicePorts.count(port.id) != 0 ||
139 mAttachedSourceDevicePorts.count(port.id) != 0;
140 });
141 return result;
142}
143
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000144std::vector<AudioPort> ModuleConfig::getConnectedExternalDevicePorts() const {
145 std::vector<AudioPort> result;
146 std::copy_if(mPorts.begin(), mPorts.end(), std::back_inserter(result), [&](const auto& port) {
147 return mConnectedExternalSinkDevicePorts.count(port.id) != 0 ||
148 mConnectedExternalSourceDevicePorts.count(port.id) != 0;
149 });
150 return result;
151}
152
153std::set<int32_t> ModuleConfig::getConnectedSinkDevicePorts() const {
154 std::set<int32_t> result;
155 result.insert(mAttachedSinkDevicePorts.begin(), mAttachedSinkDevicePorts.end());
156 result.insert(mConnectedExternalSinkDevicePorts.begin(),
157 mConnectedExternalSinkDevicePorts.end());
158 return result;
159}
160
161std::set<int32_t> ModuleConfig::getConnectedSourceDevicePorts() const {
162 std::set<int32_t> result;
163 result.insert(mAttachedSourceDevicePorts.begin(), mAttachedSourceDevicePorts.end());
164 result.insert(mConnectedExternalSourceDevicePorts.begin(),
165 mConnectedExternalSourceDevicePorts.end());
166 return result;
167}
168
Mikhail Naganov00603d12022-05-02 22:52:13 +0000169std::vector<AudioPort> ModuleConfig::getExternalDevicePorts() const {
170 std::vector<AudioPort> result;
171 std::copy_if(mPorts.begin(), mPorts.end(), std::back_inserter(result),
172 [&](const auto& port) { return mExternalDevicePorts.count(port.id) != 0; });
173 return result;
174}
175
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000176std::vector<AudioPort> ModuleConfig::getInputMixPorts(bool connectedOnly) const {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000177 std::vector<AudioPort> result;
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000178 std::copy_if(mPorts.begin(), mPorts.end(), std::back_inserter(result), [&](const auto& port) {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000179 return port.ext.getTag() == AudioPortExt::Tag::mix &&
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000180 port.flags.getTag() == AudioIoFlags::Tag::input &&
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000181 (!connectedOnly || !getConnectedSourceDevicesPortsForMixPort(port).empty());
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000182 });
183 return result;
184}
185
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000186std::vector<AudioPort> ModuleConfig::getOutputMixPorts(bool connectedOnly) const {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000187 std::vector<AudioPort> result;
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000188 std::copy_if(mPorts.begin(), mPorts.end(), std::back_inserter(result), [&](const auto& port) {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000189 return port.ext.getTag() == AudioPortExt::Tag::mix &&
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000190 port.flags.getTag() == AudioIoFlags::Tag::output &&
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000191 (!connectedOnly || !getConnectedSinkDevicesPortsForMixPort(port).empty());
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000192 });
193 return result;
194}
195
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000196std::vector<AudioPort> ModuleConfig::getNonBlockingMixPorts(bool connectedOnly,
Mikhail Naganov30301a42022-09-13 01:20:45 +0000197 bool singlePort) const {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000198 return findMixPorts(false /*isInput*/, connectedOnly, singlePort, [&](const AudioPort& port) {
Mikhail Naganov30301a42022-09-13 01:20:45 +0000199 return isBitPositionFlagSet(port.flags.get<AudioIoFlags::Tag::output>(),
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000200 AudioOutputFlags::NON_BLOCKING);
Mikhail Naganov30301a42022-09-13 01:20:45 +0000201 });
202}
203
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000204std::vector<AudioPort> ModuleConfig::getOffloadMixPorts(bool connectedOnly, bool singlePort) const {
205 return findMixPorts(false /*isInput*/, connectedOnly, singlePort, [&](const AudioPort& port) {
Mikhail Naganov30301a42022-09-13 01:20:45 +0000206 return isBitPositionFlagSet(port.flags.get<AudioIoFlags::Tag::output>(),
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000207 AudioOutputFlags::COMPRESS_OFFLOAD);
208 });
209}
210
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000211std::vector<AudioPort> ModuleConfig::getPrimaryMixPorts(bool connectedOnly, bool singlePort) const {
212 return findMixPorts(false /*isInput*/, connectedOnly, singlePort, [&](const AudioPort& port) {
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000213 return isBitPositionFlagSet(port.flags.get<AudioIoFlags::Tag::output>(),
214 AudioOutputFlags::PRIMARY);
Mikhail Naganov30301a42022-09-13 01:20:45 +0000215 });
Mikhail Naganova2c5ddf2022-09-12 22:57:14 +0000216}
217
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000218std::vector<AudioPort> ModuleConfig::getMmapOutMixPorts(bool connectedOnly, bool singlePort) const {
219 return findMixPorts(false /*isInput*/, connectedOnly, singlePort, [&](const AudioPort& port) {
jiabin9a8e6862023-01-12 23:06:37 +0000220 return isBitPositionFlagSet(port.flags.get<AudioIoFlags::Tag::output>(),
221 AudioOutputFlags::MMAP_NOIRQ);
222 });
223}
224
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000225std::vector<AudioPort> ModuleConfig::getMmapInMixPorts(bool connectedOnly, bool singlePort) const {
226 return findMixPorts(true /*isInput*/, connectedOnly, singlePort, [&](const AudioPort& port) {
jiabin9a8e6862023-01-12 23:06:37 +0000227 return isBitPositionFlagSet(port.flags.get<AudioIoFlags::Tag::input>(),
228 AudioInputFlags::MMAP_NOIRQ);
229 });
230}
231
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000232std::vector<AudioPort> ModuleConfig::getConnectedDevicesPortsForMixPort(
Mikhail Naganov4f5d3f12022-07-22 23:23:25 +0000233 bool isInput, const AudioPortConfig& mixPortConfig) const {
234 const auto mixPortIt = findById<AudioPort>(mPorts, mixPortConfig.portId);
235 if (mixPortIt != mPorts.end()) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000236 return getConnectedDevicesPortsForMixPort(isInput, *mixPortIt);
Mikhail Naganov4f5d3f12022-07-22 23:23:25 +0000237 }
238 return {};
239}
240
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000241std::vector<AudioPort> ModuleConfig::getConnectedSinkDevicesPortsForMixPort(
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000242 const AudioPort& mixPort) const {
243 std::vector<AudioPort> result;
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000244 std::set<int32_t> connectedSinkDevicePorts = getConnectedSinkDevicePorts();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000245 for (const auto& route : mRoutes) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000246 if ((connectedSinkDevicePorts.count(route.sinkPortId) != 0) &&
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000247 std::find(route.sourcePortIds.begin(), route.sourcePortIds.end(), mixPort.id) !=
248 route.sourcePortIds.end()) {
249 const auto devicePortIt = findById<AudioPort>(mPorts, route.sinkPortId);
250 if (devicePortIt != mPorts.end()) result.push_back(*devicePortIt);
251 }
252 }
253 return result;
254}
255
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000256std::vector<AudioPort> ModuleConfig::getConnectedSourceDevicesPortsForMixPort(
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000257 const AudioPort& mixPort) const {
258 std::vector<AudioPort> result;
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000259 std::set<int32_t> connectedSourceDevicePorts = getConnectedSourceDevicePorts();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000260 for (const auto& route : mRoutes) {
261 if (route.sinkPortId == mixPort.id) {
262 for (const auto srcId : route.sourcePortIds) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000263 if (connectedSourceDevicePorts.count(srcId) != 0) {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000264 const auto devicePortIt = findById<AudioPort>(mPorts, srcId);
265 if (devicePortIt != mPorts.end()) result.push_back(*devicePortIt);
266 }
267 }
268 }
269 }
270 return result;
271}
272
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000273std::optional<AudioPort> ModuleConfig::getSourceMixPortForConnectedDevice() const {
274 std::set<int32_t> connectedSinkDevicePorts = getConnectedSinkDevicePorts();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000275 for (const auto& route : mRoutes) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000276 if (connectedSinkDevicePorts.count(route.sinkPortId) != 0) {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000277 const auto mixPortIt = findById<AudioPort>(mPorts, route.sourcePortIds[0]);
278 if (mixPortIt != mPorts.end()) return *mixPortIt;
279 }
280 }
281 return {};
282}
283
Mikhail Naganov84bcc042023-10-05 17:36:57 -0700284std::vector<AudioPort> ModuleConfig::getRoutableMixPortsForDevicePort(const AudioPort& port) const {
285 std::set<int32_t> portIds;
286 for (const auto& route : mRoutes) {
287 if (port.id == route.sinkPortId) {
288 portIds.insert(route.sourcePortIds.begin(), route.sourcePortIds.end());
289 } else if (auto it = std::find(route.sourcePortIds.begin(), route.sourcePortIds.end(),
290 port.id);
291 it != route.sourcePortIds.end()) {
292 portIds.insert(route.sinkPortId);
293 }
294 }
295 const bool isInput = port.flags.getTag() == AudioIoFlags::input;
296 return findMixPorts(isInput, false /*connectedOnly*/, false /*singlePort*/,
297 [&portIds](const AudioPort& p) { return portIds.count(p.id) > 0; });
298}
299
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000300std::optional<ModuleConfig::SrcSinkPair> ModuleConfig::getNonRoutableSrcSinkPair(
301 bool isInput) const {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000302 const auto mixPorts = getMixPorts(isInput, false /*connectedOnly*/);
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000303 std::set<std::pair<int32_t, int32_t>> allowedRoutes;
304 for (const auto& route : mRoutes) {
305 for (const auto srcPortId : route.sourcePortIds) {
306 allowedRoutes.emplace(std::make_pair(srcPortId, route.sinkPortId));
307 }
308 }
309 auto make_pair = [isInput](auto& device, auto& mix) {
310 return isInput ? std::make_pair(device, mix) : std::make_pair(mix, device);
311 };
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000312 for (const auto portId :
313 isInput ? getConnectedSourceDevicePorts() : getConnectedSinkDevicePorts()) {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000314 const auto devicePortIt = findById<AudioPort>(mPorts, portId);
315 if (devicePortIt == mPorts.end()) continue;
316 auto devicePortConfig = getSingleConfigForDevicePort(*devicePortIt);
317 for (const auto& mixPort : mixPorts) {
318 if (std::find(allowedRoutes.begin(), allowedRoutes.end(),
319 make_pair(portId, mixPort.id)) == allowedRoutes.end()) {
320 auto mixPortConfig = getSingleConfigForMixPort(isInput, mixPort);
321 if (mixPortConfig.has_value()) {
322 return make_pair(devicePortConfig, mixPortConfig.value());
323 }
324 }
325 }
326 }
327 return {};
328}
329
330std::optional<ModuleConfig::SrcSinkPair> ModuleConfig::getRoutableSrcSinkPair(bool isInput) const {
331 if (isInput) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000332 std::set<int32_t> connectedSourceDevicePorts = getConnectedSourceDevicePorts();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000333 for (const auto& route : mRoutes) {
334 auto srcPortIdIt = std::find_if(
335 route.sourcePortIds.begin(), route.sourcePortIds.end(),
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000336 [&](const auto& portId) { return connectedSourceDevicePorts.count(portId); });
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000337 if (srcPortIdIt == route.sourcePortIds.end()) continue;
338 const auto devicePortIt = findById<AudioPort>(mPorts, *srcPortIdIt);
339 const auto mixPortIt = findById<AudioPort>(mPorts, route.sinkPortId);
340 if (devicePortIt == mPorts.end() || mixPortIt == mPorts.end()) continue;
341 auto devicePortConfig = getSingleConfigForDevicePort(*devicePortIt);
342 auto mixPortConfig = getSingleConfigForMixPort(isInput, *mixPortIt);
343 if (!mixPortConfig.has_value()) continue;
344 return std::make_pair(devicePortConfig, mixPortConfig.value());
345 }
346 } else {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000347 std::set<int32_t> connectedSinkDevicePorts = getConnectedSinkDevicePorts();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000348 for (const auto& route : mRoutes) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000349 if (connectedSinkDevicePorts.count(route.sinkPortId) == 0) continue;
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000350 const auto mixPortIt = findById<AudioPort>(mPorts, route.sourcePortIds[0]);
351 const auto devicePortIt = findById<AudioPort>(mPorts, route.sinkPortId);
352 if (devicePortIt == mPorts.end() || mixPortIt == mPorts.end()) continue;
353 auto mixPortConfig = getSingleConfigForMixPort(isInput, *mixPortIt);
354 auto devicePortConfig = getSingleConfigForDevicePort(*devicePortIt);
355 if (!mixPortConfig.has_value()) continue;
356 return std::make_pair(mixPortConfig.value(), devicePortConfig);
357 }
358 }
359 return {};
360}
361
362std::vector<ModuleConfig::SrcSinkGroup> ModuleConfig::getRoutableSrcSinkGroups(bool isInput) const {
363 std::vector<SrcSinkGroup> result;
364 if (isInput) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000365 std::set<int32_t> connectedSourceDevicePorts = getConnectedSourceDevicePorts();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000366 for (const auto& route : mRoutes) {
367 std::vector<int32_t> srcPortIds;
368 std::copy_if(route.sourcePortIds.begin(), route.sourcePortIds.end(),
369 std::back_inserter(srcPortIds), [&](const auto& portId) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000370 return connectedSourceDevicePorts.count(portId);
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000371 });
372 if (srcPortIds.empty()) continue;
373 const auto mixPortIt = findById<AudioPort>(mPorts, route.sinkPortId);
374 if (mixPortIt == mPorts.end()) continue;
375 auto mixPortConfig = getSingleConfigForMixPort(isInput, *mixPortIt);
376 if (!mixPortConfig.has_value()) continue;
377 std::vector<SrcSinkPair> pairs;
378 for (const auto srcPortId : srcPortIds) {
379 const auto devicePortIt = findById<AudioPort>(mPorts, srcPortId);
380 if (devicePortIt == mPorts.end()) continue;
381 // Using all configs for every source would be too much.
382 auto devicePortConfig = getSingleConfigForDevicePort(*devicePortIt);
383 pairs.emplace_back(devicePortConfig, mixPortConfig.value());
384 }
385 if (!pairs.empty()) {
386 result.emplace_back(route, std::move(pairs));
387 }
388 }
389 } else {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000390 std::set<int32_t> connectedSinkDevicePorts = getConnectedSinkDevicePorts();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000391 for (const auto& route : mRoutes) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000392 if (connectedSinkDevicePorts.count(route.sinkPortId) == 0) continue;
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000393 const auto devicePortIt = findById<AudioPort>(mPorts, route.sinkPortId);
394 if (devicePortIt == mPorts.end()) continue;
395 auto devicePortConfig = getSingleConfigForDevicePort(*devicePortIt);
396 std::vector<SrcSinkPair> pairs;
397 for (const auto srcPortId : route.sourcePortIds) {
398 const auto mixPortIt = findById<AudioPort>(mPorts, srcPortId);
399 if (mixPortIt == mPorts.end()) continue;
400 // Using all configs for every source would be too much.
401 auto mixPortConfig = getSingleConfigForMixPort(isInput, *mixPortIt);
402 if (mixPortConfig.has_value()) {
403 pairs.emplace_back(mixPortConfig.value(), devicePortConfig);
404 }
405 }
406 if (!pairs.empty()) {
407 result.emplace_back(route, std::move(pairs));
408 }
409 }
410 }
411 return result;
412}
413
Mikhail Naganov00603d12022-05-02 22:52:13 +0000414std::string ModuleConfig::toString() const {
415 std::string result;
416 result.append("Ports: ");
417 result.append(android::internal::ToString(mPorts));
Mikhail Naganov16db9b72022-06-17 21:36:18 +0000418 result.append("\nInitial configs: ");
Mikhail Naganov00603d12022-05-02 22:52:13 +0000419 result.append(android::internal::ToString(mInitialConfigs));
Mikhail Naganov16db9b72022-06-17 21:36:18 +0000420 result.append("\nAttached sink device ports: ");
Mikhail Naganov00603d12022-05-02 22:52:13 +0000421 result.append(android::internal::ToString(mAttachedSinkDevicePorts));
Mikhail Naganov16db9b72022-06-17 21:36:18 +0000422 result.append("\nAttached source device ports: ");
Mikhail Naganov00603d12022-05-02 22:52:13 +0000423 result.append(android::internal::ToString(mAttachedSourceDevicePorts));
Mikhail Naganov16db9b72022-06-17 21:36:18 +0000424 result.append("\nExternal device ports: ");
Mikhail Naganov00603d12022-05-02 22:52:13 +0000425 result.append(android::internal::ToString(mExternalDevicePorts));
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000426 result.append("\nConnected external device ports: ");
427 result.append(android::internal::ToString(getConnectedExternalDevicePorts()));
Mikhail Naganov16db9b72022-06-17 21:36:18 +0000428 result.append("\nRoutes: ");
Mikhail Naganov00603d12022-05-02 22:52:13 +0000429 result.append(android::internal::ToString(mRoutes));
430 return result;
431}
432
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000433static size_t combineAudioConfigs(const AudioPort& port, const AudioProfile& profile,
434 std::vector<AudioPortConfig>* result) {
435 const size_t newConfigCount = profile.channelMasks.size() * profile.sampleRates.size();
436 result->reserve(result->capacity() + newConfigCount);
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000437 for (auto channelMask : profile.channelMasks) {
438 for (auto sampleRate : profile.sampleRates) {
439 AudioPortConfig config{};
440 config.portId = port.id;
441 Int sr;
442 sr.value = sampleRate;
443 config.sampleRate = sr;
444 config.channelMask = channelMask;
445 config.format = profile.format;
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000446 config.flags = port.flags;
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000447 config.ext = port.ext;
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000448 result->push_back(std::move(config));
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000449 }
450 }
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000451 return newConfigCount;
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000452}
453
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000454static bool isDynamicProfile(const AudioProfile& profile) {
455 return (profile.format.type == AudioFormatType::DEFAULT && profile.format.encoding.empty()) ||
456 profile.sampleRates.empty() || profile.channelMasks.empty();
457}
458
Mikhail Naganov30301a42022-09-13 01:20:45 +0000459std::vector<AudioPort> ModuleConfig::findMixPorts(
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000460 bool isInput, bool connectedOnly, bool singlePort,
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000461 const std::function<bool(const AudioPort&)>& pred) const {
Mikhail Naganov30301a42022-09-13 01:20:45 +0000462 std::vector<AudioPort> result;
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000463 const auto mixPorts = getMixPorts(isInput, connectedOnly);
Mikhail Naganov30301a42022-09-13 01:20:45 +0000464 for (auto mixPortIt = mixPorts.begin(); mixPortIt != mixPorts.end();) {
465 mixPortIt = std::find_if(mixPortIt, mixPorts.end(), pred);
466 if (mixPortIt == mixPorts.end()) break;
467 result.push_back(*mixPortIt++);
468 if (singlePort) break;
469 }
470 return result;
471}
472
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000473std::vector<AudioPortConfig> ModuleConfig::generateAudioMixPortConfigs(
474 const std::vector<AudioPort>& ports, bool isInput, bool singleProfile) const {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000475 std::vector<AudioPortConfig> result;
476 for (const auto& mixPort : ports) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000477 if (getConnectedDevicesPortsForMixPort(isInput, mixPort).empty()) {
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000478 continue;
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000479 }
480 for (const auto& profile : mixPort.profiles) {
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000481 if (isDynamicProfile(profile)) continue;
482 combineAudioConfigs(mixPort, profile, &result);
483 if (singleProfile && !result.empty()) {
484 result.resize(1);
485 return result;
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000486 }
487 }
488 }
489 return result;
490}
491
492std::vector<AudioPortConfig> ModuleConfig::generateAudioDevicePortConfigs(
493 const std::vector<AudioPort>& ports, bool singleProfile) const {
494 std::vector<AudioPortConfig> result;
495 for (const auto& devicePort : ports) {
496 const size_t resultSizeBefore = result.size();
497 for (const auto& profile : devicePort.profiles) {
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000498 combineAudioConfigs(devicePort, profile, &result);
499 if (singleProfile && !result.empty()) {
500 result.resize(1);
501 return result;
502 }
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000503 }
504 if (resultSizeBefore == result.size()) {
Mikhail Naganov00603d12022-05-02 22:52:13 +0000505 std::copy_if(mInitialConfigs.begin(), mInitialConfigs.end(), std::back_inserter(result),
506 [&](const auto& config) { return config.portId == devicePort.id; });
507 if (resultSizeBefore == result.size()) {
508 AudioPortConfig empty;
509 empty.portId = devicePort.id;
510 empty.ext = devicePort.ext;
511 result.push_back(empty);
512 }
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000513 }
514 if (singleProfile) return result;
515 }
516 return result;
517}
jiabinb76981e2023-01-18 00:58:30 +0000518
Mikhail Naganov0e128dd2023-09-13 18:01:18 -0700519ndk::ScopedAStatus ModuleConfig::onExternalDeviceConnected(IModule* module, const AudioPort& port) {
520 RETURN_STATUS_IF_ERROR(module->getAudioPorts(&mPorts));
521 RETURN_STATUS_IF_ERROR(module->getAudioRoutes(&mRoutes));
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000522
523 // Validate port is present in module
524 if (std::find(mPorts.begin(), mPorts.end(), port) == mPorts.end()) {
Mikhail Naganov0e128dd2023-09-13 18:01:18 -0700525 return ndk::ScopedAStatus::fromExceptionCode(EX_ILLEGAL_ARGUMENT);
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000526 }
527
528 if (port.flags.getTag() == aidl::android::media::audio::common::AudioIoFlags::Tag::input) {
529 mConnectedExternalSourceDevicePorts.insert(port.id);
530 } else {
531 mConnectedExternalSinkDevicePorts.insert(port.id);
532 }
Mikhail Naganov0e128dd2023-09-13 18:01:18 -0700533 return ndk::ScopedAStatus::ok();
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000534}
535
Mikhail Naganov0e128dd2023-09-13 18:01:18 -0700536ndk::ScopedAStatus ModuleConfig::onExternalDeviceDisconnected(IModule* module,
537 const AudioPort& port) {
538 RETURN_STATUS_IF_ERROR(module->getAudioPorts(&mPorts));
539 RETURN_STATUS_IF_ERROR(module->getAudioRoutes(&mRoutes));
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000540
541 if (port.flags.getTag() == aidl::android::media::audio::common::AudioIoFlags::Tag::input) {
542 mConnectedExternalSourceDevicePorts.erase(port.id);
543 } else {
544 mConnectedExternalSinkDevicePorts.erase(port.id);
545 }
Mikhail Naganov0e128dd2023-09-13 18:01:18 -0700546 return ndk::ScopedAStatus::ok();
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000547}
548
jiabinb76981e2023-01-18 00:58:30 +0000549bool ModuleConfig::isMmapSupported() const {
550 const std::vector<AudioPort> mmapOutMixPorts =
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000551 getMmapOutMixPorts(false /*connectedOnly*/, false /*singlePort*/);
jiabinb76981e2023-01-18 00:58:30 +0000552 const std::vector<AudioPort> mmapInMixPorts =
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000553 getMmapInMixPorts(false /*connectedOnly*/, false /*singlePort*/);
jiabinb76981e2023-01-18 00:58:30 +0000554 return !mmapOutMixPorts.empty() || !mmapInMixPorts.empty();
555}