blob: 2b86271361b576d3d15734d4e49d2f9d279362aa [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 Naganov6198ad32023-11-09 18:31:55 -080020#define LOG_TAG "VtsHalAudio.ModuleConfig"
21#include <android-base/logging.h>
22
Mikhail Naganova2c5ddf2022-09-12 22:57:14 +000023#include <Utils.h>
jiabin9a8e6862023-01-12 23:06:37 +000024#include <aidl/android/media/audio/common/AudioInputFlags.h>
Mikhail Naganovf84d6402022-06-16 00:35:31 +000025#include <aidl/android/media/audio/common/AudioIoFlags.h>
26#include <aidl/android/media/audio/common/AudioOutputFlags.h>
Mikhail Naganov0e128dd2023-09-13 18:01:18 -070027#include <error/expected_utils.h>
Mikhail Naganove5d747e2021-11-16 01:31:03 +000028
29#include "ModuleConfig.h"
30
31using namespace android;
Mikhail Naganov111e0ce2022-06-17 21:41:19 +000032using namespace std::chrono_literals;
Mikhail Naganove5d747e2021-11-16 01:31:03 +000033
Mikhail Naganov872d4a62023-03-09 18:19:01 -080034using aidl::android::hardware::audio::common::isBitPositionFlagSet;
Mikhail Naganovf84d6402022-06-16 00:35:31 +000035using aidl::android::hardware::audio::core::IModule;
36using aidl::android::media::audio::common::AudioChannelLayout;
David Lib089c0c2023-08-10 12:47:44 +080037using aidl::android::media::audio::common::AudioDeviceDescription;
Mikhail Naganovef6bc742022-10-06 00:14:19 +000038using aidl::android::media::audio::common::AudioDeviceType;
Mikhail Naganov111e0ce2022-06-17 21:41:19 +000039using aidl::android::media::audio::common::AudioEncapsulationMode;
Mikhail Naganovf84d6402022-06-16 00:35:31 +000040using aidl::android::media::audio::common::AudioFormatDescription;
41using aidl::android::media::audio::common::AudioFormatType;
jiabin9a8e6862023-01-12 23:06:37 +000042using aidl::android::media::audio::common::AudioInputFlags;
Mikhail Naganovf84d6402022-06-16 00:35:31 +000043using aidl::android::media::audio::common::AudioIoFlags;
Mikhail Naganov111e0ce2022-06-17 21:41:19 +000044using aidl::android::media::audio::common::AudioOffloadInfo;
Mikhail Naganovf84d6402022-06-16 00:35:31 +000045using aidl::android::media::audio::common::AudioOutputFlags;
46using aidl::android::media::audio::common::AudioPort;
47using aidl::android::media::audio::common::AudioPortConfig;
48using aidl::android::media::audio::common::AudioPortExt;
49using aidl::android::media::audio::common::AudioProfile;
Mikhail Naganov111e0ce2022-06-17 21:41:19 +000050using aidl::android::media::audio::common::AudioUsage;
Mikhail Naganovf84d6402022-06-16 00:35:31 +000051using aidl::android::media::audio::common::Int;
Mikhail Naganove5d747e2021-11-16 01:31:03 +000052
Mikhail Naganov111e0ce2022-06-17 21:41:19 +000053// static
54std::optional<AudioOffloadInfo> ModuleConfig::generateOffloadInfoIfNeeded(
55 const AudioPortConfig& portConfig) {
56 if (portConfig.flags.has_value() &&
57 portConfig.flags.value().getTag() == AudioIoFlags::Tag::output &&
Mikhail Naganova2c5ddf2022-09-12 22:57:14 +000058 isBitPositionFlagSet(portConfig.flags.value().get<AudioIoFlags::Tag::output>(),
59 AudioOutputFlags::COMPRESS_OFFLOAD)) {
Mikhail Naganov111e0ce2022-06-17 21:41:19 +000060 AudioOffloadInfo offloadInfo;
61 offloadInfo.base.sampleRate = portConfig.sampleRate.value().value;
62 offloadInfo.base.channelMask = portConfig.channelMask.value();
63 offloadInfo.base.format = portConfig.format.value();
Mikhail Naganovd1509422023-02-24 19:50:51 -080064 offloadInfo.bitRatePerSecond = 256000; // Arbitrary value.
Mikhail Naganov111e0ce2022-06-17 21:41:19 +000065 offloadInfo.durationUs = std::chrono::microseconds(1min).count(); // Arbitrary value.
66 offloadInfo.usage = AudioUsage::MEDIA;
67 offloadInfo.encapsulationMode = AudioEncapsulationMode::NONE;
68 return offloadInfo;
69 }
70 return {};
71}
72
Mikhail Naganovef6bc742022-10-06 00:14:19 +000073// static
Shraddha Basantwani343db5e2023-08-23 12:39:15 +000074std::vector<aidl::android::media::audio::common::AudioPort>
75ModuleConfig::getAudioPortsForDeviceTypes(
76 const std::vector<aidl::android::media::audio::common::AudioPort>& ports,
77 const std::vector<AudioDeviceType>& deviceTypes, const std::string& connection) {
Mikhail Naganovef6bc742022-10-06 00:14:19 +000078 std::vector<AudioPort> result;
Shraddha Basantwani343db5e2023-08-23 12:39:15 +000079 for (const auto& port : ports) {
80 if (port.ext.getTag() != AudioPortExt::Tag::device) continue;
81 const auto type = port.ext.get<AudioPortExt::Tag::device>().device.type;
82 if (type.connection == connection) {
83 for (auto deviceType : deviceTypes) {
84 if (type.type == deviceType) {
85 result.push_back(port);
86 }
87 }
88 }
89 }
Mikhail Naganovef6bc742022-10-06 00:14:19 +000090 return result;
91}
92
Mikhail Naganov95f22772023-10-25 08:44:47 -070093// static
94std::vector<aidl::android::media::audio::common::AudioPort> ModuleConfig::getBuiltInMicPorts(
95 const std::vector<aidl::android::media::audio::common::AudioPort>& ports) {
96 return getAudioPortsForDeviceTypes(
97 ports, std::vector<AudioDeviceType>{AudioDeviceType::IN_MICROPHONE,
98 AudioDeviceType::IN_MICROPHONE_BACK});
99}
100
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000101template <typename T>
102auto findById(const std::vector<T>& v, int32_t id) {
103 return std::find_if(v.begin(), v.end(), [&](const auto& p) { return p.id == id; });
104}
105
106ModuleConfig::ModuleConfig(IModule* module) {
107 mStatus = module->getAudioPorts(&mPorts);
108 if (!mStatus.isOk()) return;
109 for (const auto& port : mPorts) {
110 if (port.ext.getTag() != AudioPortExt::Tag::device) continue;
111 const auto& devicePort = port.ext.get<AudioPortExt::Tag::device>();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000112 if (devicePort.device.type.connection.empty()) {
Mikhail Naganov00603d12022-05-02 22:52:13 +0000113 const bool isInput = port.flags.getTag() == AudioIoFlags::Tag::input;
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000114 // Permanently attached device.
115 if (isInput) {
116 mAttachedSourceDevicePorts.insert(port.id);
117 } else {
118 mAttachedSinkDevicePorts.insert(port.id);
119 }
Mikhail Naganov95f22772023-10-25 08:44:47 -0700120 } else {
Mikhail Naganov00603d12022-05-02 22:52:13 +0000121 mExternalDevicePorts.insert(port.id);
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000122 }
123 }
124 if (!mStatus.isOk()) return;
125 mStatus = module->getAudioRoutes(&mRoutes);
126 if (!mStatus.isOk()) return;
127 mStatus = module->getAudioPortConfigs(&mInitialConfigs);
128}
129
Mikhail Naganov00603d12022-05-02 22:52:13 +0000130std::vector<AudioPort> ModuleConfig::getAttachedDevicePorts() const {
131 std::vector<AudioPort> result;
132 std::copy_if(mPorts.begin(), mPorts.end(), std::back_inserter(result), [&](const auto& port) {
133 return mAttachedSinkDevicePorts.count(port.id) != 0 ||
134 mAttachedSourceDevicePorts.count(port.id) != 0;
135 });
136 return result;
137}
138
Mikhail Naganov95f22772023-10-25 08:44:47 -0700139std::vector<aidl::android::media::audio::common::AudioPort>
140ModuleConfig::getAudioPortsForDeviceTypes(const std::vector<AudioDeviceType>& deviceTypes,
141 const std::string& connection) const {
142 return getAudioPortsForDeviceTypes(mPorts, deviceTypes, connection);
143}
144
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000145std::vector<AudioPort> ModuleConfig::getConnectedExternalDevicePorts() const {
146 std::vector<AudioPort> result;
147 std::copy_if(mPorts.begin(), mPorts.end(), std::back_inserter(result), [&](const auto& port) {
148 return mConnectedExternalSinkDevicePorts.count(port.id) != 0 ||
149 mConnectedExternalSourceDevicePorts.count(port.id) != 0;
150 });
151 return result;
152}
153
154std::set<int32_t> ModuleConfig::getConnectedSinkDevicePorts() const {
155 std::set<int32_t> result;
156 result.insert(mAttachedSinkDevicePorts.begin(), mAttachedSinkDevicePorts.end());
157 result.insert(mConnectedExternalSinkDevicePorts.begin(),
158 mConnectedExternalSinkDevicePorts.end());
159 return result;
160}
161
162std::set<int32_t> ModuleConfig::getConnectedSourceDevicePorts() const {
163 std::set<int32_t> result;
164 result.insert(mAttachedSourceDevicePorts.begin(), mAttachedSourceDevicePorts.end());
165 result.insert(mConnectedExternalSourceDevicePorts.begin(),
166 mConnectedExternalSourceDevicePorts.end());
167 return result;
168}
169
Mikhail Naganov00603d12022-05-02 22:52:13 +0000170std::vector<AudioPort> ModuleConfig::getExternalDevicePorts() const {
171 std::vector<AudioPort> result;
172 std::copy_if(mPorts.begin(), mPorts.end(), std::back_inserter(result),
173 [&](const auto& port) { return mExternalDevicePorts.count(port.id) != 0; });
174 return result;
175}
176
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000177std::vector<AudioPort> ModuleConfig::getInputMixPorts(bool connectedOnly) const {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000178 std::vector<AudioPort> result;
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000179 std::copy_if(mPorts.begin(), mPorts.end(), std::back_inserter(result), [&](const auto& port) {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000180 return port.ext.getTag() == AudioPortExt::Tag::mix &&
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000181 port.flags.getTag() == AudioIoFlags::Tag::input &&
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000182 (!connectedOnly || !getConnectedSourceDevicesPortsForMixPort(port).empty());
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000183 });
184 return result;
185}
186
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000187std::vector<AudioPort> ModuleConfig::getOutputMixPorts(bool connectedOnly) const {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000188 std::vector<AudioPort> result;
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000189 std::copy_if(mPorts.begin(), mPorts.end(), std::back_inserter(result), [&](const auto& port) {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000190 return port.ext.getTag() == AudioPortExt::Tag::mix &&
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000191 port.flags.getTag() == AudioIoFlags::Tag::output &&
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000192 (!connectedOnly || !getConnectedSinkDevicesPortsForMixPort(port).empty());
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000193 });
194 return result;
195}
196
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000197std::vector<AudioPort> ModuleConfig::getNonBlockingMixPorts(bool connectedOnly,
Mikhail Naganov30301a42022-09-13 01:20:45 +0000198 bool singlePort) const {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000199 return findMixPorts(false /*isInput*/, connectedOnly, singlePort, [&](const AudioPort& port) {
Mikhail Naganov30301a42022-09-13 01:20:45 +0000200 return isBitPositionFlagSet(port.flags.get<AudioIoFlags::Tag::output>(),
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000201 AudioOutputFlags::NON_BLOCKING);
Mikhail Naganov30301a42022-09-13 01:20:45 +0000202 });
203}
204
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000205std::vector<AudioPort> ModuleConfig::getOffloadMixPorts(bool connectedOnly, bool singlePort) const {
206 return findMixPorts(false /*isInput*/, connectedOnly, singlePort, [&](const AudioPort& port) {
Mikhail Naganov30301a42022-09-13 01:20:45 +0000207 return isBitPositionFlagSet(port.flags.get<AudioIoFlags::Tag::output>(),
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000208 AudioOutputFlags::COMPRESS_OFFLOAD);
209 });
210}
211
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000212std::vector<AudioPort> ModuleConfig::getPrimaryMixPorts(bool connectedOnly, bool singlePort) const {
213 return findMixPorts(false /*isInput*/, connectedOnly, singlePort, [&](const AudioPort& port) {
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000214 return isBitPositionFlagSet(port.flags.get<AudioIoFlags::Tag::output>(),
215 AudioOutputFlags::PRIMARY);
Mikhail Naganov30301a42022-09-13 01:20:45 +0000216 });
Mikhail Naganova2c5ddf2022-09-12 22:57:14 +0000217}
218
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000219std::vector<AudioPort> ModuleConfig::getMmapOutMixPorts(bool connectedOnly, bool singlePort) const {
220 return findMixPorts(false /*isInput*/, connectedOnly, singlePort, [&](const AudioPort& port) {
jiabin9a8e6862023-01-12 23:06:37 +0000221 return isBitPositionFlagSet(port.flags.get<AudioIoFlags::Tag::output>(),
222 AudioOutputFlags::MMAP_NOIRQ);
223 });
224}
225
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000226std::vector<AudioPort> ModuleConfig::getMmapInMixPorts(bool connectedOnly, bool singlePort) const {
227 return findMixPorts(true /*isInput*/, connectedOnly, singlePort, [&](const AudioPort& port) {
jiabin9a8e6862023-01-12 23:06:37 +0000228 return isBitPositionFlagSet(port.flags.get<AudioIoFlags::Tag::input>(),
229 AudioInputFlags::MMAP_NOIRQ);
230 });
231}
232
Mikhail Naganov95f22772023-10-25 08:44:47 -0700233std::vector<AudioPort> ModuleConfig::getRemoteSubmixPorts(bool isInput, bool singlePort) const {
234 AudioDeviceType deviceType = isInput ? AudioDeviceType::IN_SUBMIX : AudioDeviceType::OUT_SUBMIX;
235 auto ports = getAudioPortsForDeviceTypes(std::vector<AudioDeviceType>{deviceType},
236 AudioDeviceDescription::CONNECTION_VIRTUAL);
237 if (singlePort) {
238 if (!ports.empty()) ports.resize(1);
239 }
240 return ports;
241}
242
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000243std::vector<AudioPort> ModuleConfig::getConnectedDevicesPortsForMixPort(
Mikhail Naganov4f5d3f12022-07-22 23:23:25 +0000244 bool isInput, const AudioPortConfig& mixPortConfig) const {
245 const auto mixPortIt = findById<AudioPort>(mPorts, mixPortConfig.portId);
246 if (mixPortIt != mPorts.end()) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000247 return getConnectedDevicesPortsForMixPort(isInput, *mixPortIt);
Mikhail Naganov4f5d3f12022-07-22 23:23:25 +0000248 }
249 return {};
250}
251
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000252std::vector<AudioPort> ModuleConfig::getConnectedSinkDevicesPortsForMixPort(
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000253 const AudioPort& mixPort) const {
254 std::vector<AudioPort> result;
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000255 std::set<int32_t> connectedSinkDevicePorts = getConnectedSinkDevicePorts();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000256 for (const auto& route : mRoutes) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000257 if ((connectedSinkDevicePorts.count(route.sinkPortId) != 0) &&
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000258 std::find(route.sourcePortIds.begin(), route.sourcePortIds.end(), mixPort.id) !=
259 route.sourcePortIds.end()) {
260 const auto devicePortIt = findById<AudioPort>(mPorts, route.sinkPortId);
261 if (devicePortIt != mPorts.end()) result.push_back(*devicePortIt);
262 }
263 }
264 return result;
265}
266
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000267std::vector<AudioPort> ModuleConfig::getConnectedSourceDevicesPortsForMixPort(
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000268 const AudioPort& mixPort) const {
269 std::vector<AudioPort> result;
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000270 std::set<int32_t> connectedSourceDevicePorts = getConnectedSourceDevicePorts();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000271 for (const auto& route : mRoutes) {
272 if (route.sinkPortId == mixPort.id) {
273 for (const auto srcId : route.sourcePortIds) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000274 if (connectedSourceDevicePorts.count(srcId) != 0) {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000275 const auto devicePortIt = findById<AudioPort>(mPorts, srcId);
276 if (devicePortIt != mPorts.end()) result.push_back(*devicePortIt);
277 }
278 }
279 }
280 }
281 return result;
282}
283
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000284std::optional<AudioPort> ModuleConfig::getSourceMixPortForConnectedDevice() const {
285 std::set<int32_t> connectedSinkDevicePorts = getConnectedSinkDevicePorts();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000286 for (const auto& route : mRoutes) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000287 if (connectedSinkDevicePorts.count(route.sinkPortId) != 0) {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000288 const auto mixPortIt = findById<AudioPort>(mPorts, route.sourcePortIds[0]);
289 if (mixPortIt != mPorts.end()) return *mixPortIt;
290 }
291 }
292 return {};
293}
294
Mikhail Naganov95f22772023-10-25 08:44:47 -0700295std::vector<AudioPort> ModuleConfig::getRoutableDevicePortsForMixPort(const AudioPort& port,
296 bool connectedOnly) const {
297 std::set<int32_t> portIds = findRoutablePortIds(port.id);
Mikhail Naganov84bcc042023-10-05 17:36:57 -0700298 const bool isInput = port.flags.getTag() == AudioIoFlags::input;
Mikhail Naganov95f22772023-10-25 08:44:47 -0700299 std::set<int32_t> devicePortIds;
300 if (connectedOnly) {
301 devicePortIds = isInput ? getConnectedSourceDevicePorts() : getConnectedSinkDevicePorts();
302 } else {
303 devicePortIds = portIds;
304 }
305 std::vector<AudioPort> result;
306 std::copy_if(mPorts.begin(), mPorts.end(), std::back_inserter(result), [&](const auto& port) {
307 return port.ext.getTag() == AudioPortExt::Tag::device && portIds.count(port.id) > 0 &&
308 devicePortIds.count(port.id) > 0;
309 });
310 return result;
311}
312
313std::vector<AudioPort> ModuleConfig::getRoutableMixPortsForDevicePort(const AudioPort& port,
314 bool connectedOnly) const {
315 std::set<int32_t> portIds = findRoutablePortIds(port.id);
316 const bool isInput = port.flags.getTag() == AudioIoFlags::input;
317 return findMixPorts(isInput, connectedOnly, false /*singlePort*/,
Mikhail Naganov84bcc042023-10-05 17:36:57 -0700318 [&portIds](const AudioPort& p) { return portIds.count(p.id) > 0; });
319}
320
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000321std::optional<ModuleConfig::SrcSinkPair> ModuleConfig::getNonRoutableSrcSinkPair(
322 bool isInput) const {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000323 const auto mixPorts = getMixPorts(isInput, false /*connectedOnly*/);
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000324 std::set<std::pair<int32_t, int32_t>> allowedRoutes;
325 for (const auto& route : mRoutes) {
326 for (const auto srcPortId : route.sourcePortIds) {
327 allowedRoutes.emplace(std::make_pair(srcPortId, route.sinkPortId));
328 }
329 }
330 auto make_pair = [isInput](auto& device, auto& mix) {
331 return isInput ? std::make_pair(device, mix) : std::make_pair(mix, device);
332 };
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000333 for (const auto portId :
334 isInput ? getConnectedSourceDevicePorts() : getConnectedSinkDevicePorts()) {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000335 const auto devicePortIt = findById<AudioPort>(mPorts, portId);
336 if (devicePortIt == mPorts.end()) continue;
337 auto devicePortConfig = getSingleConfigForDevicePort(*devicePortIt);
338 for (const auto& mixPort : mixPorts) {
339 if (std::find(allowedRoutes.begin(), allowedRoutes.end(),
340 make_pair(portId, mixPort.id)) == allowedRoutes.end()) {
341 auto mixPortConfig = getSingleConfigForMixPort(isInput, mixPort);
342 if (mixPortConfig.has_value()) {
343 return make_pair(devicePortConfig, mixPortConfig.value());
344 }
345 }
346 }
347 }
348 return {};
349}
350
351std::optional<ModuleConfig::SrcSinkPair> ModuleConfig::getRoutableSrcSinkPair(bool isInput) const {
352 if (isInput) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000353 std::set<int32_t> connectedSourceDevicePorts = getConnectedSourceDevicePorts();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000354 for (const auto& route : mRoutes) {
355 auto srcPortIdIt = std::find_if(
356 route.sourcePortIds.begin(), route.sourcePortIds.end(),
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000357 [&](const auto& portId) { return connectedSourceDevicePorts.count(portId); });
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000358 if (srcPortIdIt == route.sourcePortIds.end()) continue;
359 const auto devicePortIt = findById<AudioPort>(mPorts, *srcPortIdIt);
360 const auto mixPortIt = findById<AudioPort>(mPorts, route.sinkPortId);
361 if (devicePortIt == mPorts.end() || mixPortIt == mPorts.end()) continue;
362 auto devicePortConfig = getSingleConfigForDevicePort(*devicePortIt);
363 auto mixPortConfig = getSingleConfigForMixPort(isInput, *mixPortIt);
364 if (!mixPortConfig.has_value()) continue;
365 return std::make_pair(devicePortConfig, mixPortConfig.value());
366 }
367 } else {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000368 std::set<int32_t> connectedSinkDevicePorts = getConnectedSinkDevicePorts();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000369 for (const auto& route : mRoutes) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000370 if (connectedSinkDevicePorts.count(route.sinkPortId) == 0) continue;
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000371 const auto mixPortIt = findById<AudioPort>(mPorts, route.sourcePortIds[0]);
372 const auto devicePortIt = findById<AudioPort>(mPorts, route.sinkPortId);
373 if (devicePortIt == mPorts.end() || mixPortIt == mPorts.end()) continue;
374 auto mixPortConfig = getSingleConfigForMixPort(isInput, *mixPortIt);
375 auto devicePortConfig = getSingleConfigForDevicePort(*devicePortIt);
376 if (!mixPortConfig.has_value()) continue;
377 return std::make_pair(mixPortConfig.value(), devicePortConfig);
378 }
379 }
380 return {};
381}
382
383std::vector<ModuleConfig::SrcSinkGroup> ModuleConfig::getRoutableSrcSinkGroups(bool isInput) const {
384 std::vector<SrcSinkGroup> result;
385 if (isInput) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000386 std::set<int32_t> connectedSourceDevicePorts = getConnectedSourceDevicePorts();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000387 for (const auto& route : mRoutes) {
388 std::vector<int32_t> srcPortIds;
389 std::copy_if(route.sourcePortIds.begin(), route.sourcePortIds.end(),
390 std::back_inserter(srcPortIds), [&](const auto& portId) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000391 return connectedSourceDevicePorts.count(portId);
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000392 });
393 if (srcPortIds.empty()) continue;
394 const auto mixPortIt = findById<AudioPort>(mPorts, route.sinkPortId);
395 if (mixPortIt == mPorts.end()) continue;
396 auto mixPortConfig = getSingleConfigForMixPort(isInput, *mixPortIt);
397 if (!mixPortConfig.has_value()) continue;
398 std::vector<SrcSinkPair> pairs;
399 for (const auto srcPortId : srcPortIds) {
400 const auto devicePortIt = findById<AudioPort>(mPorts, srcPortId);
401 if (devicePortIt == mPorts.end()) continue;
402 // Using all configs for every source would be too much.
403 auto devicePortConfig = getSingleConfigForDevicePort(*devicePortIt);
404 pairs.emplace_back(devicePortConfig, mixPortConfig.value());
405 }
406 if (!pairs.empty()) {
407 result.emplace_back(route, std::move(pairs));
408 }
409 }
410 } else {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000411 std::set<int32_t> connectedSinkDevicePorts = getConnectedSinkDevicePorts();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000412 for (const auto& route : mRoutes) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000413 if (connectedSinkDevicePorts.count(route.sinkPortId) == 0) continue;
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000414 const auto devicePortIt = findById<AudioPort>(mPorts, route.sinkPortId);
415 if (devicePortIt == mPorts.end()) continue;
416 auto devicePortConfig = getSingleConfigForDevicePort(*devicePortIt);
417 std::vector<SrcSinkPair> pairs;
418 for (const auto srcPortId : route.sourcePortIds) {
419 const auto mixPortIt = findById<AudioPort>(mPorts, srcPortId);
420 if (mixPortIt == mPorts.end()) continue;
421 // Using all configs for every source would be too much.
422 auto mixPortConfig = getSingleConfigForMixPort(isInput, *mixPortIt);
423 if (mixPortConfig.has_value()) {
424 pairs.emplace_back(mixPortConfig.value(), devicePortConfig);
425 }
426 }
427 if (!pairs.empty()) {
428 result.emplace_back(route, std::move(pairs));
429 }
430 }
431 }
432 return result;
433}
434
Mikhail Naganov00603d12022-05-02 22:52:13 +0000435std::string ModuleConfig::toString() const {
436 std::string result;
437 result.append("Ports: ");
438 result.append(android::internal::ToString(mPorts));
Mikhail Naganov16db9b72022-06-17 21:36:18 +0000439 result.append("\nInitial configs: ");
Mikhail Naganov00603d12022-05-02 22:52:13 +0000440 result.append(android::internal::ToString(mInitialConfigs));
Mikhail Naganov16db9b72022-06-17 21:36:18 +0000441 result.append("\nAttached sink device ports: ");
Mikhail Naganov00603d12022-05-02 22:52:13 +0000442 result.append(android::internal::ToString(mAttachedSinkDevicePorts));
Mikhail Naganov16db9b72022-06-17 21:36:18 +0000443 result.append("\nAttached source device ports: ");
Mikhail Naganov00603d12022-05-02 22:52:13 +0000444 result.append(android::internal::ToString(mAttachedSourceDevicePorts));
Mikhail Naganov16db9b72022-06-17 21:36:18 +0000445 result.append("\nExternal device ports: ");
Mikhail Naganov00603d12022-05-02 22:52:13 +0000446 result.append(android::internal::ToString(mExternalDevicePorts));
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000447 result.append("\nConnected external device ports: ");
448 result.append(android::internal::ToString(getConnectedExternalDevicePorts()));
Mikhail Naganov16db9b72022-06-17 21:36:18 +0000449 result.append("\nRoutes: ");
Mikhail Naganov00603d12022-05-02 22:52:13 +0000450 result.append(android::internal::ToString(mRoutes));
451 return result;
452}
453
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000454static size_t combineAudioConfigs(const AudioPort& port, const AudioProfile& profile,
455 std::vector<AudioPortConfig>* result) {
456 const size_t newConfigCount = profile.channelMasks.size() * profile.sampleRates.size();
457 result->reserve(result->capacity() + newConfigCount);
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000458 for (auto channelMask : profile.channelMasks) {
459 for (auto sampleRate : profile.sampleRates) {
460 AudioPortConfig config{};
461 config.portId = port.id;
462 Int sr;
463 sr.value = sampleRate;
464 config.sampleRate = sr;
465 config.channelMask = channelMask;
466 config.format = profile.format;
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000467 config.flags = port.flags;
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000468 config.ext = port.ext;
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000469 result->push_back(std::move(config));
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000470 }
471 }
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000472 return newConfigCount;
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000473}
474
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000475static bool isDynamicProfile(const AudioProfile& profile) {
476 return (profile.format.type == AudioFormatType::DEFAULT && profile.format.encoding.empty()) ||
477 profile.sampleRates.empty() || profile.channelMasks.empty();
478}
479
Mikhail Naganov30301a42022-09-13 01:20:45 +0000480std::vector<AudioPort> ModuleConfig::findMixPorts(
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000481 bool isInput, bool connectedOnly, bool singlePort,
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000482 const std::function<bool(const AudioPort&)>& pred) const {
Mikhail Naganov30301a42022-09-13 01:20:45 +0000483 std::vector<AudioPort> result;
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000484 const auto mixPorts = getMixPorts(isInput, connectedOnly);
Mikhail Naganov30301a42022-09-13 01:20:45 +0000485 for (auto mixPortIt = mixPorts.begin(); mixPortIt != mixPorts.end();) {
486 mixPortIt = std::find_if(mixPortIt, mixPorts.end(), pred);
487 if (mixPortIt == mixPorts.end()) break;
488 result.push_back(*mixPortIt++);
489 if (singlePort) break;
490 }
491 return result;
492}
493
Mikhail Naganov95f22772023-10-25 08:44:47 -0700494std::set<int32_t> ModuleConfig::findRoutablePortIds(int32_t portId) const {
495 std::set<int32_t> portIds;
496 for (const auto& route : mRoutes) {
497 if (portId == route.sinkPortId) {
498 portIds.insert(route.sourcePortIds.begin(), route.sourcePortIds.end());
499 } else if (auto it = std::find(route.sourcePortIds.begin(), route.sourcePortIds.end(),
500 portId);
501 it != route.sourcePortIds.end()) {
502 portIds.insert(route.sinkPortId);
503 }
504 }
505 return portIds;
506}
507
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000508std::vector<AudioPortConfig> ModuleConfig::generateAudioMixPortConfigs(
509 const std::vector<AudioPort>& ports, bool isInput, bool singleProfile) const {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000510 std::vector<AudioPortConfig> result;
511 for (const auto& mixPort : ports) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000512 if (getConnectedDevicesPortsForMixPort(isInput, mixPort).empty()) {
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000513 continue;
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000514 }
515 for (const auto& profile : mixPort.profiles) {
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000516 if (isDynamicProfile(profile)) continue;
517 combineAudioConfigs(mixPort, profile, &result);
518 if (singleProfile && !result.empty()) {
519 result.resize(1);
520 return result;
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000521 }
522 }
523 }
524 return result;
525}
526
527std::vector<AudioPortConfig> ModuleConfig::generateAudioDevicePortConfigs(
528 const std::vector<AudioPort>& ports, bool singleProfile) const {
529 std::vector<AudioPortConfig> result;
530 for (const auto& devicePort : ports) {
531 const size_t resultSizeBefore = result.size();
532 for (const auto& profile : devicePort.profiles) {
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000533 combineAudioConfigs(devicePort, profile, &result);
534 if (singleProfile && !result.empty()) {
535 result.resize(1);
536 return result;
537 }
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000538 }
539 if (resultSizeBefore == result.size()) {
Mikhail Naganov00603d12022-05-02 22:52:13 +0000540 std::copy_if(mInitialConfigs.begin(), mInitialConfigs.end(), std::back_inserter(result),
541 [&](const auto& config) { return config.portId == devicePort.id; });
542 if (resultSizeBefore == result.size()) {
543 AudioPortConfig empty;
544 empty.portId = devicePort.id;
545 empty.ext = devicePort.ext;
546 result.push_back(empty);
547 }
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000548 }
549 if (singleProfile) return result;
550 }
551 return result;
552}
jiabinb76981e2023-01-18 00:58:30 +0000553
Mikhail Naganov0e128dd2023-09-13 18:01:18 -0700554ndk::ScopedAStatus ModuleConfig::onExternalDeviceConnected(IModule* module, const AudioPort& port) {
555 RETURN_STATUS_IF_ERROR(module->getAudioPorts(&mPorts));
556 RETURN_STATUS_IF_ERROR(module->getAudioRoutes(&mRoutes));
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000557
558 // Validate port is present in module
559 if (std::find(mPorts.begin(), mPorts.end(), port) == mPorts.end()) {
Mikhail Naganov0e128dd2023-09-13 18:01:18 -0700560 return ndk::ScopedAStatus::fromExceptionCode(EX_ILLEGAL_ARGUMENT);
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000561 }
562
563 if (port.flags.getTag() == aidl::android::media::audio::common::AudioIoFlags::Tag::input) {
564 mConnectedExternalSourceDevicePorts.insert(port.id);
565 } else {
566 mConnectedExternalSinkDevicePorts.insert(port.id);
567 }
Mikhail Naganov0e128dd2023-09-13 18:01:18 -0700568 return ndk::ScopedAStatus::ok();
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000569}
570
Mikhail Naganov0e128dd2023-09-13 18:01:18 -0700571ndk::ScopedAStatus ModuleConfig::onExternalDeviceDisconnected(IModule* module,
572 const AudioPort& port) {
573 RETURN_STATUS_IF_ERROR(module->getAudioPorts(&mPorts));
574 RETURN_STATUS_IF_ERROR(module->getAudioRoutes(&mRoutes));
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000575
576 if (port.flags.getTag() == aidl::android::media::audio::common::AudioIoFlags::Tag::input) {
577 mConnectedExternalSourceDevicePorts.erase(port.id);
578 } else {
579 mConnectedExternalSinkDevicePorts.erase(port.id);
580 }
Mikhail Naganov0e128dd2023-09-13 18:01:18 -0700581 return ndk::ScopedAStatus::ok();
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000582}
583
jiabinb76981e2023-01-18 00:58:30 +0000584bool ModuleConfig::isMmapSupported() const {
585 const std::vector<AudioPort> mmapOutMixPorts =
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000586 getMmapOutMixPorts(false /*connectedOnly*/, false /*singlePort*/);
jiabinb76981e2023-01-18 00:58:30 +0000587 const std::vector<AudioPort> mmapInMixPorts =
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000588 getMmapInMixPorts(false /*connectedOnly*/, false /*singlePort*/);
jiabinb76981e2023-01-18 00:58:30 +0000589 return !mmapOutMixPorts.empty() || !mmapInMixPorts.empty();
590}