blob: a633d837a5ff234417208217e217d19d8863fda4 [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
Mikhail Naganovef6bc742022-10-06 00:14:19 +000070// static
Shraddha Basantwani343db5e2023-08-23 12:39:15 +000071std::vector<aidl::android::media::audio::common::AudioPort>
72ModuleConfig::getAudioPortsForDeviceTypes(
73 const std::vector<aidl::android::media::audio::common::AudioPort>& ports,
74 const std::vector<AudioDeviceType>& deviceTypes, const std::string& connection) {
Mikhail Naganovef6bc742022-10-06 00:14:19 +000075 std::vector<AudioPort> result;
Shraddha Basantwani343db5e2023-08-23 12:39:15 +000076 for (const auto& port : ports) {
77 if (port.ext.getTag() != AudioPortExt::Tag::device) continue;
78 const auto type = port.ext.get<AudioPortExt::Tag::device>().device.type;
79 if (type.connection == connection) {
80 for (auto deviceType : deviceTypes) {
81 if (type.type == deviceType) {
82 result.push_back(port);
83 }
84 }
85 }
86 }
Mikhail Naganovef6bc742022-10-06 00:14:19 +000087 return result;
88}
89
Mikhail Naganov95f22772023-10-25 08:44:47 -070090// static
91std::vector<aidl::android::media::audio::common::AudioPort> ModuleConfig::getBuiltInMicPorts(
92 const std::vector<aidl::android::media::audio::common::AudioPort>& ports) {
93 return getAudioPortsForDeviceTypes(
94 ports, std::vector<AudioDeviceType>{AudioDeviceType::IN_MICROPHONE,
95 AudioDeviceType::IN_MICROPHONE_BACK});
96}
97
Mikhail Naganove5d747e2021-11-16 01:31:03 +000098template <typename T>
99auto findById(const std::vector<T>& v, int32_t id) {
100 return std::find_if(v.begin(), v.end(), [&](const auto& p) { return p.id == id; });
101}
102
103ModuleConfig::ModuleConfig(IModule* module) {
104 mStatus = module->getAudioPorts(&mPorts);
105 if (!mStatus.isOk()) return;
106 for (const auto& port : mPorts) {
107 if (port.ext.getTag() != AudioPortExt::Tag::device) continue;
108 const auto& devicePort = port.ext.get<AudioPortExt::Tag::device>();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000109 if (devicePort.device.type.connection.empty()) {
Mikhail Naganov00603d12022-05-02 22:52:13 +0000110 const bool isInput = port.flags.getTag() == AudioIoFlags::Tag::input;
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000111 // Permanently attached device.
112 if (isInput) {
113 mAttachedSourceDevicePorts.insert(port.id);
114 } else {
115 mAttachedSinkDevicePorts.insert(port.id);
116 }
Mikhail Naganov95f22772023-10-25 08:44:47 -0700117 } else {
Mikhail Naganov00603d12022-05-02 22:52:13 +0000118 mExternalDevicePorts.insert(port.id);
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000119 }
120 }
121 if (!mStatus.isOk()) return;
122 mStatus = module->getAudioRoutes(&mRoutes);
123 if (!mStatus.isOk()) return;
124 mStatus = module->getAudioPortConfigs(&mInitialConfigs);
125}
126
Mikhail Naganov00603d12022-05-02 22:52:13 +0000127std::vector<AudioPort> ModuleConfig::getAttachedDevicePorts() const {
128 std::vector<AudioPort> result;
129 std::copy_if(mPorts.begin(), mPorts.end(), std::back_inserter(result), [&](const auto& port) {
130 return mAttachedSinkDevicePorts.count(port.id) != 0 ||
131 mAttachedSourceDevicePorts.count(port.id) != 0;
132 });
133 return result;
134}
135
Mikhail Naganov95f22772023-10-25 08:44:47 -0700136std::vector<aidl::android::media::audio::common::AudioPort>
137ModuleConfig::getAudioPortsForDeviceTypes(const std::vector<AudioDeviceType>& deviceTypes,
138 const std::string& connection) const {
139 return getAudioPortsForDeviceTypes(mPorts, deviceTypes, connection);
140}
141
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000142std::vector<AudioPort> ModuleConfig::getConnectedExternalDevicePorts() const {
143 std::vector<AudioPort> result;
144 std::copy_if(mPorts.begin(), mPorts.end(), std::back_inserter(result), [&](const auto& port) {
145 return mConnectedExternalSinkDevicePorts.count(port.id) != 0 ||
146 mConnectedExternalSourceDevicePorts.count(port.id) != 0;
147 });
148 return result;
149}
150
151std::set<int32_t> ModuleConfig::getConnectedSinkDevicePorts() const {
152 std::set<int32_t> result;
153 result.insert(mAttachedSinkDevicePorts.begin(), mAttachedSinkDevicePorts.end());
154 result.insert(mConnectedExternalSinkDevicePorts.begin(),
155 mConnectedExternalSinkDevicePorts.end());
156 return result;
157}
158
159std::set<int32_t> ModuleConfig::getConnectedSourceDevicePorts() const {
160 std::set<int32_t> result;
161 result.insert(mAttachedSourceDevicePorts.begin(), mAttachedSourceDevicePorts.end());
162 result.insert(mConnectedExternalSourceDevicePorts.begin(),
163 mConnectedExternalSourceDevicePorts.end());
164 return result;
165}
166
Mikhail Naganov00603d12022-05-02 22:52:13 +0000167std::vector<AudioPort> ModuleConfig::getExternalDevicePorts() const {
168 std::vector<AudioPort> result;
169 std::copy_if(mPorts.begin(), mPorts.end(), std::back_inserter(result),
170 [&](const auto& port) { return mExternalDevicePorts.count(port.id) != 0; });
171 return result;
172}
173
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000174std::vector<AudioPort> ModuleConfig::getInputMixPorts(bool connectedOnly) const {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000175 std::vector<AudioPort> result;
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000176 std::copy_if(mPorts.begin(), mPorts.end(), std::back_inserter(result), [&](const auto& port) {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000177 return port.ext.getTag() == AudioPortExt::Tag::mix &&
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000178 port.flags.getTag() == AudioIoFlags::Tag::input &&
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000179 (!connectedOnly || !getConnectedSourceDevicesPortsForMixPort(port).empty());
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000180 });
181 return result;
182}
183
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000184std::vector<AudioPort> ModuleConfig::getOutputMixPorts(bool connectedOnly) const {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000185 std::vector<AudioPort> result;
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000186 std::copy_if(mPorts.begin(), mPorts.end(), std::back_inserter(result), [&](const auto& port) {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000187 return port.ext.getTag() == AudioPortExt::Tag::mix &&
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000188 port.flags.getTag() == AudioIoFlags::Tag::output &&
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000189 (!connectedOnly || !getConnectedSinkDevicesPortsForMixPort(port).empty());
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000190 });
191 return result;
192}
193
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000194std::vector<AudioPort> ModuleConfig::getNonBlockingMixPorts(bool connectedOnly,
Mikhail Naganov30301a42022-09-13 01:20:45 +0000195 bool singlePort) const {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000196 return findMixPorts(false /*isInput*/, connectedOnly, singlePort, [&](const AudioPort& port) {
Mikhail Naganov30301a42022-09-13 01:20:45 +0000197 return isBitPositionFlagSet(port.flags.get<AudioIoFlags::Tag::output>(),
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000198 AudioOutputFlags::NON_BLOCKING);
Mikhail Naganov30301a42022-09-13 01:20:45 +0000199 });
200}
201
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000202std::vector<AudioPort> ModuleConfig::getOffloadMixPorts(bool connectedOnly, bool singlePort) const {
203 return findMixPorts(false /*isInput*/, connectedOnly, singlePort, [&](const AudioPort& port) {
Mikhail Naganov30301a42022-09-13 01:20:45 +0000204 return isBitPositionFlagSet(port.flags.get<AudioIoFlags::Tag::output>(),
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000205 AudioOutputFlags::COMPRESS_OFFLOAD);
206 });
207}
208
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000209std::vector<AudioPort> ModuleConfig::getPrimaryMixPorts(bool connectedOnly, bool singlePort) const {
210 return findMixPorts(false /*isInput*/, connectedOnly, singlePort, [&](const AudioPort& port) {
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000211 return isBitPositionFlagSet(port.flags.get<AudioIoFlags::Tag::output>(),
212 AudioOutputFlags::PRIMARY);
Mikhail Naganov30301a42022-09-13 01:20:45 +0000213 });
Mikhail Naganova2c5ddf2022-09-12 22:57:14 +0000214}
215
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000216std::vector<AudioPort> ModuleConfig::getMmapOutMixPorts(bool connectedOnly, bool singlePort) const {
217 return findMixPorts(false /*isInput*/, connectedOnly, singlePort, [&](const AudioPort& port) {
jiabin9a8e6862023-01-12 23:06:37 +0000218 return isBitPositionFlagSet(port.flags.get<AudioIoFlags::Tag::output>(),
219 AudioOutputFlags::MMAP_NOIRQ);
220 });
221}
222
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000223std::vector<AudioPort> ModuleConfig::getMmapInMixPorts(bool connectedOnly, bool singlePort) const {
224 return findMixPorts(true /*isInput*/, connectedOnly, singlePort, [&](const AudioPort& port) {
jiabin9a8e6862023-01-12 23:06:37 +0000225 return isBitPositionFlagSet(port.flags.get<AudioIoFlags::Tag::input>(),
226 AudioInputFlags::MMAP_NOIRQ);
227 });
228}
229
Mikhail Naganov95f22772023-10-25 08:44:47 -0700230std::vector<AudioPort> ModuleConfig::getRemoteSubmixPorts(bool isInput, bool singlePort) const {
231 AudioDeviceType deviceType = isInput ? AudioDeviceType::IN_SUBMIX : AudioDeviceType::OUT_SUBMIX;
232 auto ports = getAudioPortsForDeviceTypes(std::vector<AudioDeviceType>{deviceType},
233 AudioDeviceDescription::CONNECTION_VIRTUAL);
234 if (singlePort) {
235 if (!ports.empty()) ports.resize(1);
236 }
237 return ports;
238}
239
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000240std::vector<AudioPort> ModuleConfig::getConnectedDevicesPortsForMixPort(
Mikhail Naganov4f5d3f12022-07-22 23:23:25 +0000241 bool isInput, const AudioPortConfig& mixPortConfig) const {
242 const auto mixPortIt = findById<AudioPort>(mPorts, mixPortConfig.portId);
243 if (mixPortIt != mPorts.end()) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000244 return getConnectedDevicesPortsForMixPort(isInput, *mixPortIt);
Mikhail Naganov4f5d3f12022-07-22 23:23:25 +0000245 }
246 return {};
247}
248
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000249std::vector<AudioPort> ModuleConfig::getConnectedSinkDevicesPortsForMixPort(
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000250 const AudioPort& mixPort) const {
251 std::vector<AudioPort> result;
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000252 std::set<int32_t> connectedSinkDevicePorts = getConnectedSinkDevicePorts();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000253 for (const auto& route : mRoutes) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000254 if ((connectedSinkDevicePorts.count(route.sinkPortId) != 0) &&
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000255 std::find(route.sourcePortIds.begin(), route.sourcePortIds.end(), mixPort.id) !=
256 route.sourcePortIds.end()) {
257 const auto devicePortIt = findById<AudioPort>(mPorts, route.sinkPortId);
258 if (devicePortIt != mPorts.end()) result.push_back(*devicePortIt);
259 }
260 }
261 return result;
262}
263
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000264std::vector<AudioPort> ModuleConfig::getConnectedSourceDevicesPortsForMixPort(
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000265 const AudioPort& mixPort) const {
266 std::vector<AudioPort> result;
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000267 std::set<int32_t> connectedSourceDevicePorts = getConnectedSourceDevicePorts();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000268 for (const auto& route : mRoutes) {
269 if (route.sinkPortId == mixPort.id) {
270 for (const auto srcId : route.sourcePortIds) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000271 if (connectedSourceDevicePorts.count(srcId) != 0) {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000272 const auto devicePortIt = findById<AudioPort>(mPorts, srcId);
273 if (devicePortIt != mPorts.end()) result.push_back(*devicePortIt);
274 }
275 }
276 }
277 }
278 return result;
279}
280
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000281std::optional<AudioPort> ModuleConfig::getSourceMixPortForConnectedDevice() const {
282 std::set<int32_t> connectedSinkDevicePorts = getConnectedSinkDevicePorts();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000283 for (const auto& route : mRoutes) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000284 if (connectedSinkDevicePorts.count(route.sinkPortId) != 0) {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000285 const auto mixPortIt = findById<AudioPort>(mPorts, route.sourcePortIds[0]);
286 if (mixPortIt != mPorts.end()) return *mixPortIt;
287 }
288 }
289 return {};
290}
291
Mikhail Naganov95f22772023-10-25 08:44:47 -0700292std::vector<AudioPort> ModuleConfig::getRoutableDevicePortsForMixPort(const AudioPort& port,
293 bool connectedOnly) const {
294 std::set<int32_t> portIds = findRoutablePortIds(port.id);
Mikhail Naganov84bcc042023-10-05 17:36:57 -0700295 const bool isInput = port.flags.getTag() == AudioIoFlags::input;
Mikhail Naganov95f22772023-10-25 08:44:47 -0700296 std::set<int32_t> devicePortIds;
297 if (connectedOnly) {
298 devicePortIds = isInput ? getConnectedSourceDevicePorts() : getConnectedSinkDevicePorts();
299 } else {
300 devicePortIds = portIds;
301 }
302 std::vector<AudioPort> result;
303 std::copy_if(mPorts.begin(), mPorts.end(), std::back_inserter(result), [&](const auto& port) {
304 return port.ext.getTag() == AudioPortExt::Tag::device && portIds.count(port.id) > 0 &&
305 devicePortIds.count(port.id) > 0;
306 });
307 return result;
308}
309
310std::vector<AudioPort> ModuleConfig::getRoutableMixPortsForDevicePort(const AudioPort& port,
311 bool connectedOnly) const {
312 std::set<int32_t> portIds = findRoutablePortIds(port.id);
313 const bool isInput = port.flags.getTag() == AudioIoFlags::input;
314 return findMixPorts(isInput, connectedOnly, false /*singlePort*/,
Mikhail Naganov84bcc042023-10-05 17:36:57 -0700315 [&portIds](const AudioPort& p) { return portIds.count(p.id) > 0; });
316}
317
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000318std::optional<ModuleConfig::SrcSinkPair> ModuleConfig::getNonRoutableSrcSinkPair(
319 bool isInput) const {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000320 const auto mixPorts = getMixPorts(isInput, false /*connectedOnly*/);
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000321 std::set<std::pair<int32_t, int32_t>> allowedRoutes;
322 for (const auto& route : mRoutes) {
323 for (const auto srcPortId : route.sourcePortIds) {
324 allowedRoutes.emplace(std::make_pair(srcPortId, route.sinkPortId));
325 }
326 }
327 auto make_pair = [isInput](auto& device, auto& mix) {
328 return isInput ? std::make_pair(device, mix) : std::make_pair(mix, device);
329 };
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000330 for (const auto portId :
331 isInput ? getConnectedSourceDevicePorts() : getConnectedSinkDevicePorts()) {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000332 const auto devicePortIt = findById<AudioPort>(mPorts, portId);
333 if (devicePortIt == mPorts.end()) continue;
334 auto devicePortConfig = getSingleConfigForDevicePort(*devicePortIt);
335 for (const auto& mixPort : mixPorts) {
336 if (std::find(allowedRoutes.begin(), allowedRoutes.end(),
337 make_pair(portId, mixPort.id)) == allowedRoutes.end()) {
338 auto mixPortConfig = getSingleConfigForMixPort(isInput, mixPort);
339 if (mixPortConfig.has_value()) {
340 return make_pair(devicePortConfig, mixPortConfig.value());
341 }
342 }
343 }
344 }
345 return {};
346}
347
348std::optional<ModuleConfig::SrcSinkPair> ModuleConfig::getRoutableSrcSinkPair(bool isInput) const {
349 if (isInput) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000350 std::set<int32_t> connectedSourceDevicePorts = getConnectedSourceDevicePorts();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000351 for (const auto& route : mRoutes) {
352 auto srcPortIdIt = std::find_if(
353 route.sourcePortIds.begin(), route.sourcePortIds.end(),
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000354 [&](const auto& portId) { return connectedSourceDevicePorts.count(portId); });
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000355 if (srcPortIdIt == route.sourcePortIds.end()) continue;
356 const auto devicePortIt = findById<AudioPort>(mPorts, *srcPortIdIt);
357 const auto mixPortIt = findById<AudioPort>(mPorts, route.sinkPortId);
358 if (devicePortIt == mPorts.end() || mixPortIt == mPorts.end()) continue;
359 auto devicePortConfig = getSingleConfigForDevicePort(*devicePortIt);
360 auto mixPortConfig = getSingleConfigForMixPort(isInput, *mixPortIt);
361 if (!mixPortConfig.has_value()) continue;
362 return std::make_pair(devicePortConfig, mixPortConfig.value());
363 }
364 } else {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000365 std::set<int32_t> connectedSinkDevicePorts = getConnectedSinkDevicePorts();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000366 for (const auto& route : mRoutes) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000367 if (connectedSinkDevicePorts.count(route.sinkPortId) == 0) continue;
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000368 const auto mixPortIt = findById<AudioPort>(mPorts, route.sourcePortIds[0]);
369 const auto devicePortIt = findById<AudioPort>(mPorts, route.sinkPortId);
370 if (devicePortIt == mPorts.end() || mixPortIt == mPorts.end()) continue;
371 auto mixPortConfig = getSingleConfigForMixPort(isInput, *mixPortIt);
372 auto devicePortConfig = getSingleConfigForDevicePort(*devicePortIt);
373 if (!mixPortConfig.has_value()) continue;
374 return std::make_pair(mixPortConfig.value(), devicePortConfig);
375 }
376 }
377 return {};
378}
379
380std::vector<ModuleConfig::SrcSinkGroup> ModuleConfig::getRoutableSrcSinkGroups(bool isInput) const {
381 std::vector<SrcSinkGroup> result;
382 if (isInput) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000383 std::set<int32_t> connectedSourceDevicePorts = getConnectedSourceDevicePorts();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000384 for (const auto& route : mRoutes) {
385 std::vector<int32_t> srcPortIds;
386 std::copy_if(route.sourcePortIds.begin(), route.sourcePortIds.end(),
387 std::back_inserter(srcPortIds), [&](const auto& portId) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000388 return connectedSourceDevicePorts.count(portId);
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000389 });
390 if (srcPortIds.empty()) continue;
391 const auto mixPortIt = findById<AudioPort>(mPorts, route.sinkPortId);
392 if (mixPortIt == mPorts.end()) continue;
393 auto mixPortConfig = getSingleConfigForMixPort(isInput, *mixPortIt);
394 if (!mixPortConfig.has_value()) continue;
395 std::vector<SrcSinkPair> pairs;
396 for (const auto srcPortId : srcPortIds) {
397 const auto devicePortIt = findById<AudioPort>(mPorts, srcPortId);
398 if (devicePortIt == mPorts.end()) continue;
399 // Using all configs for every source would be too much.
400 auto devicePortConfig = getSingleConfigForDevicePort(*devicePortIt);
401 pairs.emplace_back(devicePortConfig, mixPortConfig.value());
402 }
403 if (!pairs.empty()) {
404 result.emplace_back(route, std::move(pairs));
405 }
406 }
407 } else {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000408 std::set<int32_t> connectedSinkDevicePorts = getConnectedSinkDevicePorts();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000409 for (const auto& route : mRoutes) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000410 if (connectedSinkDevicePorts.count(route.sinkPortId) == 0) continue;
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000411 const auto devicePortIt = findById<AudioPort>(mPorts, route.sinkPortId);
412 if (devicePortIt == mPorts.end()) continue;
413 auto devicePortConfig = getSingleConfigForDevicePort(*devicePortIt);
414 std::vector<SrcSinkPair> pairs;
415 for (const auto srcPortId : route.sourcePortIds) {
416 const auto mixPortIt = findById<AudioPort>(mPorts, srcPortId);
417 if (mixPortIt == mPorts.end()) continue;
418 // Using all configs for every source would be too much.
419 auto mixPortConfig = getSingleConfigForMixPort(isInput, *mixPortIt);
420 if (mixPortConfig.has_value()) {
421 pairs.emplace_back(mixPortConfig.value(), devicePortConfig);
422 }
423 }
424 if (!pairs.empty()) {
425 result.emplace_back(route, std::move(pairs));
426 }
427 }
428 }
429 return result;
430}
431
Mikhail Naganov00603d12022-05-02 22:52:13 +0000432std::string ModuleConfig::toString() const {
433 std::string result;
434 result.append("Ports: ");
435 result.append(android::internal::ToString(mPorts));
Mikhail Naganov16db9b72022-06-17 21:36:18 +0000436 result.append("\nInitial configs: ");
Mikhail Naganov00603d12022-05-02 22:52:13 +0000437 result.append(android::internal::ToString(mInitialConfigs));
Mikhail Naganov16db9b72022-06-17 21:36:18 +0000438 result.append("\nAttached sink device ports: ");
Mikhail Naganov00603d12022-05-02 22:52:13 +0000439 result.append(android::internal::ToString(mAttachedSinkDevicePorts));
Mikhail Naganov16db9b72022-06-17 21:36:18 +0000440 result.append("\nAttached source device ports: ");
Mikhail Naganov00603d12022-05-02 22:52:13 +0000441 result.append(android::internal::ToString(mAttachedSourceDevicePorts));
Mikhail Naganov16db9b72022-06-17 21:36:18 +0000442 result.append("\nExternal device ports: ");
Mikhail Naganov00603d12022-05-02 22:52:13 +0000443 result.append(android::internal::ToString(mExternalDevicePorts));
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000444 result.append("\nConnected external device ports: ");
445 result.append(android::internal::ToString(getConnectedExternalDevicePorts()));
Mikhail Naganov16db9b72022-06-17 21:36:18 +0000446 result.append("\nRoutes: ");
Mikhail Naganov00603d12022-05-02 22:52:13 +0000447 result.append(android::internal::ToString(mRoutes));
448 return result;
449}
450
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000451static size_t combineAudioConfigs(const AudioPort& port, const AudioProfile& profile,
452 std::vector<AudioPortConfig>* result) {
453 const size_t newConfigCount = profile.channelMasks.size() * profile.sampleRates.size();
454 result->reserve(result->capacity() + newConfigCount);
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000455 for (auto channelMask : profile.channelMasks) {
456 for (auto sampleRate : profile.sampleRates) {
457 AudioPortConfig config{};
458 config.portId = port.id;
459 Int sr;
460 sr.value = sampleRate;
461 config.sampleRate = sr;
462 config.channelMask = channelMask;
463 config.format = profile.format;
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000464 config.flags = port.flags;
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000465 config.ext = port.ext;
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000466 result->push_back(std::move(config));
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000467 }
468 }
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000469 return newConfigCount;
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000470}
471
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000472static bool isDynamicProfile(const AudioProfile& profile) {
473 return (profile.format.type == AudioFormatType::DEFAULT && profile.format.encoding.empty()) ||
474 profile.sampleRates.empty() || profile.channelMasks.empty();
475}
476
Mikhail Naganov30301a42022-09-13 01:20:45 +0000477std::vector<AudioPort> ModuleConfig::findMixPorts(
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000478 bool isInput, bool connectedOnly, bool singlePort,
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000479 const std::function<bool(const AudioPort&)>& pred) const {
Mikhail Naganov30301a42022-09-13 01:20:45 +0000480 std::vector<AudioPort> result;
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000481 const auto mixPorts = getMixPorts(isInput, connectedOnly);
Mikhail Naganov30301a42022-09-13 01:20:45 +0000482 for (auto mixPortIt = mixPorts.begin(); mixPortIt != mixPorts.end();) {
483 mixPortIt = std::find_if(mixPortIt, mixPorts.end(), pred);
484 if (mixPortIt == mixPorts.end()) break;
485 result.push_back(*mixPortIt++);
486 if (singlePort) break;
487 }
488 return result;
489}
490
Mikhail Naganov95f22772023-10-25 08:44:47 -0700491std::set<int32_t> ModuleConfig::findRoutablePortIds(int32_t portId) const {
492 std::set<int32_t> portIds;
493 for (const auto& route : mRoutes) {
494 if (portId == route.sinkPortId) {
495 portIds.insert(route.sourcePortIds.begin(), route.sourcePortIds.end());
496 } else if (auto it = std::find(route.sourcePortIds.begin(), route.sourcePortIds.end(),
497 portId);
498 it != route.sourcePortIds.end()) {
499 portIds.insert(route.sinkPortId);
500 }
501 }
502 return portIds;
503}
504
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000505std::vector<AudioPortConfig> ModuleConfig::generateAudioMixPortConfigs(
506 const std::vector<AudioPort>& ports, bool isInput, bool singleProfile) const {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000507 std::vector<AudioPortConfig> result;
508 for (const auto& mixPort : ports) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000509 if (getConnectedDevicesPortsForMixPort(isInput, mixPort).empty()) {
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000510 continue;
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000511 }
512 for (const auto& profile : mixPort.profiles) {
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000513 if (isDynamicProfile(profile)) continue;
514 combineAudioConfigs(mixPort, profile, &result);
515 if (singleProfile && !result.empty()) {
516 result.resize(1);
517 return result;
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000518 }
519 }
520 }
521 return result;
522}
523
524std::vector<AudioPortConfig> ModuleConfig::generateAudioDevicePortConfigs(
525 const std::vector<AudioPort>& ports, bool singleProfile) const {
526 std::vector<AudioPortConfig> result;
527 for (const auto& devicePort : ports) {
528 const size_t resultSizeBefore = result.size();
529 for (const auto& profile : devicePort.profiles) {
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000530 combineAudioConfigs(devicePort, profile, &result);
531 if (singleProfile && !result.empty()) {
532 result.resize(1);
533 return result;
534 }
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000535 }
536 if (resultSizeBefore == result.size()) {
Mikhail Naganov00603d12022-05-02 22:52:13 +0000537 std::copy_if(mInitialConfigs.begin(), mInitialConfigs.end(), std::back_inserter(result),
538 [&](const auto& config) { return config.portId == devicePort.id; });
539 if (resultSizeBefore == result.size()) {
540 AudioPortConfig empty;
541 empty.portId = devicePort.id;
542 empty.ext = devicePort.ext;
543 result.push_back(empty);
544 }
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000545 }
546 if (singleProfile) return result;
547 }
548 return result;
549}
jiabinb76981e2023-01-18 00:58:30 +0000550
Mikhail Naganov0e128dd2023-09-13 18:01:18 -0700551ndk::ScopedAStatus ModuleConfig::onExternalDeviceConnected(IModule* module, const AudioPort& port) {
552 RETURN_STATUS_IF_ERROR(module->getAudioPorts(&mPorts));
553 RETURN_STATUS_IF_ERROR(module->getAudioRoutes(&mRoutes));
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000554
555 // Validate port is present in module
556 if (std::find(mPorts.begin(), mPorts.end(), port) == mPorts.end()) {
Mikhail Naganov0e128dd2023-09-13 18:01:18 -0700557 return ndk::ScopedAStatus::fromExceptionCode(EX_ILLEGAL_ARGUMENT);
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000558 }
559
560 if (port.flags.getTag() == aidl::android::media::audio::common::AudioIoFlags::Tag::input) {
561 mConnectedExternalSourceDevicePorts.insert(port.id);
562 } else {
563 mConnectedExternalSinkDevicePorts.insert(port.id);
564 }
Mikhail Naganov0e128dd2023-09-13 18:01:18 -0700565 return ndk::ScopedAStatus::ok();
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000566}
567
Mikhail Naganov0e128dd2023-09-13 18:01:18 -0700568ndk::ScopedAStatus ModuleConfig::onExternalDeviceDisconnected(IModule* module,
569 const AudioPort& port) {
570 RETURN_STATUS_IF_ERROR(module->getAudioPorts(&mPorts));
571 RETURN_STATUS_IF_ERROR(module->getAudioRoutes(&mRoutes));
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000572
573 if (port.flags.getTag() == aidl::android::media::audio::common::AudioIoFlags::Tag::input) {
574 mConnectedExternalSourceDevicePorts.erase(port.id);
575 } else {
576 mConnectedExternalSinkDevicePorts.erase(port.id);
577 }
Mikhail Naganov0e128dd2023-09-13 18:01:18 -0700578 return ndk::ScopedAStatus::ok();
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000579}
580
jiabinb76981e2023-01-18 00:58:30 +0000581bool ModuleConfig::isMmapSupported() const {
582 const std::vector<AudioPort> mmapOutMixPorts =
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000583 getMmapOutMixPorts(false /*connectedOnly*/, false /*singlePort*/);
jiabinb76981e2023-01-18 00:58:30 +0000584 const std::vector<AudioPort> mmapInMixPorts =
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000585 getMmapInMixPorts(false /*connectedOnly*/, false /*singlePort*/);
jiabinb76981e2023-01-18 00:58:30 +0000586 return !mmapOutMixPorts.empty() || !mmapInMixPorts.empty();
587}