blob: 8fdb1552df6008e58b9730fdda1f0dcf2a082bd2 [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 Naganove5d747e2021-11-16 01:31:03 +000024
25#include "ModuleConfig.h"
26
27using namespace android;
Mikhail Naganov111e0ce2022-06-17 21:41:19 +000028using namespace std::chrono_literals;
Mikhail Naganove5d747e2021-11-16 01:31:03 +000029
Mikhail Naganov872d4a62023-03-09 18:19:01 -080030using aidl::android::hardware::audio::common::isBitPositionFlagSet;
Mikhail Naganovf84d6402022-06-16 00:35:31 +000031using aidl::android::hardware::audio::core::IModule;
32using aidl::android::media::audio::common::AudioChannelLayout;
David Lib089c0c2023-08-10 12:47:44 +080033using aidl::android::media::audio::common::AudioDeviceDescription;
Mikhail Naganovef6bc742022-10-06 00:14:19 +000034using aidl::android::media::audio::common::AudioDeviceType;
Mikhail Naganov111e0ce2022-06-17 21:41:19 +000035using aidl::android::media::audio::common::AudioEncapsulationMode;
Mikhail Naganovf84d6402022-06-16 00:35:31 +000036using aidl::android::media::audio::common::AudioFormatDescription;
37using aidl::android::media::audio::common::AudioFormatType;
jiabin9a8e6862023-01-12 23:06:37 +000038using aidl::android::media::audio::common::AudioInputFlags;
Mikhail Naganovf84d6402022-06-16 00:35:31 +000039using aidl::android::media::audio::common::AudioIoFlags;
Mikhail Naganov111e0ce2022-06-17 21:41:19 +000040using aidl::android::media::audio::common::AudioOffloadInfo;
Mikhail Naganovf84d6402022-06-16 00:35:31 +000041using aidl::android::media::audio::common::AudioOutputFlags;
42using aidl::android::media::audio::common::AudioPort;
43using aidl::android::media::audio::common::AudioPortConfig;
44using aidl::android::media::audio::common::AudioPortExt;
45using aidl::android::media::audio::common::AudioProfile;
Mikhail Naganov111e0ce2022-06-17 21:41:19 +000046using aidl::android::media::audio::common::AudioUsage;
Mikhail Naganovf84d6402022-06-16 00:35:31 +000047using aidl::android::media::audio::common::Int;
Mikhail Naganove5d747e2021-11-16 01:31:03 +000048
Mikhail Naganov111e0ce2022-06-17 21:41:19 +000049// static
50std::optional<AudioOffloadInfo> ModuleConfig::generateOffloadInfoIfNeeded(
51 const AudioPortConfig& portConfig) {
52 if (portConfig.flags.has_value() &&
53 portConfig.flags.value().getTag() == AudioIoFlags::Tag::output &&
Mikhail Naganova2c5ddf2022-09-12 22:57:14 +000054 isBitPositionFlagSet(portConfig.flags.value().get<AudioIoFlags::Tag::output>(),
55 AudioOutputFlags::COMPRESS_OFFLOAD)) {
Mikhail Naganov111e0ce2022-06-17 21:41:19 +000056 AudioOffloadInfo offloadInfo;
57 offloadInfo.base.sampleRate = portConfig.sampleRate.value().value;
58 offloadInfo.base.channelMask = portConfig.channelMask.value();
59 offloadInfo.base.format = portConfig.format.value();
Mikhail Naganovd1509422023-02-24 19:50:51 -080060 offloadInfo.bitRatePerSecond = 256000; // Arbitrary value.
Mikhail Naganov111e0ce2022-06-17 21:41:19 +000061 offloadInfo.durationUs = std::chrono::microseconds(1min).count(); // Arbitrary value.
62 offloadInfo.usage = AudioUsage::MEDIA;
63 offloadInfo.encapsulationMode = AudioEncapsulationMode::NONE;
64 return offloadInfo;
65 }
66 return {};
67}
68
Shraddha Basantwani343db5e2023-08-23 12:39:15 +000069std::vector<aidl::android::media::audio::common::AudioPort>
70ModuleConfig::getAudioPortsForDeviceTypes(const std::vector<AudioDeviceType>& deviceTypes,
71 const std::string& connection) {
72 return getAudioPortsForDeviceTypes(mPorts, deviceTypes, connection);
73}
74
Mikhail Naganovef6bc742022-10-06 00:14:19 +000075// static
76std::vector<aidl::android::media::audio::common::AudioPort> ModuleConfig::getBuiltInMicPorts(
77 const std::vector<aidl::android::media::audio::common::AudioPort>& ports) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +000078 return getAudioPortsForDeviceTypes(
79 ports, std::vector<AudioDeviceType>{AudioDeviceType::IN_MICROPHONE,
80 AudioDeviceType::IN_MICROPHONE_BACK});
81}
82
83std::vector<aidl::android::media::audio::common::AudioPort>
84ModuleConfig::getAudioPortsForDeviceTypes(
85 const std::vector<aidl::android::media::audio::common::AudioPort>& ports,
86 const std::vector<AudioDeviceType>& deviceTypes, const std::string& connection) {
Mikhail Naganovef6bc742022-10-06 00:14:19 +000087 std::vector<AudioPort> result;
Shraddha Basantwani343db5e2023-08-23 12:39:15 +000088 for (const auto& port : ports) {
89 if (port.ext.getTag() != AudioPortExt::Tag::device) continue;
90 const auto type = port.ext.get<AudioPortExt::Tag::device>().device.type;
91 if (type.connection == connection) {
92 for (auto deviceType : deviceTypes) {
93 if (type.type == deviceType) {
94 result.push_back(port);
95 }
96 }
97 }
98 }
Mikhail Naganovef6bc742022-10-06 00:14:19 +000099 return result;
100}
101
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000102template <typename T>
103auto findById(const std::vector<T>& v, int32_t id) {
104 return std::find_if(v.begin(), v.end(), [&](const auto& p) { return p.id == id; });
105}
106
107ModuleConfig::ModuleConfig(IModule* module) {
108 mStatus = module->getAudioPorts(&mPorts);
109 if (!mStatus.isOk()) return;
110 for (const auto& port : mPorts) {
111 if (port.ext.getTag() != AudioPortExt::Tag::device) continue;
112 const auto& devicePort = port.ext.get<AudioPortExt::Tag::device>();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000113 if (devicePort.device.type.connection.empty()) {
Mikhail Naganov00603d12022-05-02 22:52:13 +0000114 const bool isInput = port.flags.getTag() == AudioIoFlags::Tag::input;
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000115 // Permanently attached device.
116 if (isInput) {
117 mAttachedSourceDevicePorts.insert(port.id);
118 } else {
119 mAttachedSinkDevicePorts.insert(port.id);
120 }
David Lib089c0c2023-08-10 12:47:44 +0800121 } else if (devicePort.device.type.connection != AudioDeviceDescription::CONNECTION_VIRTUAL
122 // The "virtual" connection is used for remote submix which is a dynamic
123 // device but it can be connected and used w/o external hardware.
124 && port.profiles.empty()) {
Mikhail Naganov00603d12022-05-02 22:52:13 +0000125 mExternalDevicePorts.insert(port.id);
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000126 }
127 }
128 if (!mStatus.isOk()) return;
129 mStatus = module->getAudioRoutes(&mRoutes);
130 if (!mStatus.isOk()) return;
131 mStatus = module->getAudioPortConfigs(&mInitialConfigs);
132}
133
Mikhail Naganov00603d12022-05-02 22:52:13 +0000134std::vector<AudioPort> ModuleConfig::getAttachedDevicePorts() const {
135 std::vector<AudioPort> result;
136 std::copy_if(mPorts.begin(), mPorts.end(), std::back_inserter(result), [&](const auto& port) {
137 return mAttachedSinkDevicePorts.count(port.id) != 0 ||
138 mAttachedSourceDevicePorts.count(port.id) != 0;
139 });
140 return result;
141}
142
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000143std::vector<AudioPort> ModuleConfig::getConnectedExternalDevicePorts() const {
144 std::vector<AudioPort> result;
145 std::copy_if(mPorts.begin(), mPorts.end(), std::back_inserter(result), [&](const auto& port) {
146 return mConnectedExternalSinkDevicePorts.count(port.id) != 0 ||
147 mConnectedExternalSourceDevicePorts.count(port.id) != 0;
148 });
149 return result;
150}
151
152std::set<int32_t> ModuleConfig::getConnectedSinkDevicePorts() const {
153 std::set<int32_t> result;
154 result.insert(mAttachedSinkDevicePorts.begin(), mAttachedSinkDevicePorts.end());
155 result.insert(mConnectedExternalSinkDevicePorts.begin(),
156 mConnectedExternalSinkDevicePorts.end());
157 return result;
158}
159
160std::set<int32_t> ModuleConfig::getConnectedSourceDevicePorts() const {
161 std::set<int32_t> result;
162 result.insert(mAttachedSourceDevicePorts.begin(), mAttachedSourceDevicePorts.end());
163 result.insert(mConnectedExternalSourceDevicePorts.begin(),
164 mConnectedExternalSourceDevicePorts.end());
165 return result;
166}
167
Mikhail Naganov00603d12022-05-02 22:52:13 +0000168std::vector<AudioPort> ModuleConfig::getExternalDevicePorts() const {
169 std::vector<AudioPort> result;
170 std::copy_if(mPorts.begin(), mPorts.end(), std::back_inserter(result),
171 [&](const auto& port) { return mExternalDevicePorts.count(port.id) != 0; });
172 return result;
173}
174
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000175std::vector<AudioPort> ModuleConfig::getInputMixPorts(bool connectedOnly) const {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000176 std::vector<AudioPort> result;
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000177 std::copy_if(mPorts.begin(), mPorts.end(), std::back_inserter(result), [&](const auto& port) {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000178 return port.ext.getTag() == AudioPortExt::Tag::mix &&
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000179 port.flags.getTag() == AudioIoFlags::Tag::input &&
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000180 (!connectedOnly || !getConnectedSourceDevicesPortsForMixPort(port).empty());
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000181 });
182 return result;
183}
184
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000185std::vector<AudioPort> ModuleConfig::getOutputMixPorts(bool connectedOnly) const {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000186 std::vector<AudioPort> result;
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000187 std::copy_if(mPorts.begin(), mPorts.end(), std::back_inserter(result), [&](const auto& port) {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000188 return port.ext.getTag() == AudioPortExt::Tag::mix &&
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000189 port.flags.getTag() == AudioIoFlags::Tag::output &&
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000190 (!connectedOnly || !getConnectedSinkDevicesPortsForMixPort(port).empty());
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000191 });
192 return result;
193}
194
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000195std::vector<AudioPort> ModuleConfig::getNonBlockingMixPorts(bool connectedOnly,
Mikhail Naganov30301a42022-09-13 01:20:45 +0000196 bool singlePort) const {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000197 return findMixPorts(false /*isInput*/, connectedOnly, singlePort, [&](const AudioPort& port) {
Mikhail Naganov30301a42022-09-13 01:20:45 +0000198 return isBitPositionFlagSet(port.flags.get<AudioIoFlags::Tag::output>(),
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000199 AudioOutputFlags::NON_BLOCKING);
Mikhail Naganov30301a42022-09-13 01:20:45 +0000200 });
201}
202
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000203std::vector<AudioPort> ModuleConfig::getOffloadMixPorts(bool connectedOnly, bool singlePort) const {
204 return findMixPorts(false /*isInput*/, connectedOnly, singlePort, [&](const AudioPort& port) {
Mikhail Naganov30301a42022-09-13 01:20:45 +0000205 return isBitPositionFlagSet(port.flags.get<AudioIoFlags::Tag::output>(),
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000206 AudioOutputFlags::COMPRESS_OFFLOAD);
207 });
208}
209
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000210std::vector<AudioPort> ModuleConfig::getPrimaryMixPorts(bool connectedOnly, bool singlePort) const {
211 return findMixPorts(false /*isInput*/, connectedOnly, singlePort, [&](const AudioPort& port) {
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000212 return isBitPositionFlagSet(port.flags.get<AudioIoFlags::Tag::output>(),
213 AudioOutputFlags::PRIMARY);
Mikhail Naganov30301a42022-09-13 01:20:45 +0000214 });
Mikhail Naganova2c5ddf2022-09-12 22:57:14 +0000215}
216
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000217std::vector<AudioPort> ModuleConfig::getMmapOutMixPorts(bool connectedOnly, bool singlePort) const {
218 return findMixPorts(false /*isInput*/, connectedOnly, singlePort, [&](const AudioPort& port) {
jiabin9a8e6862023-01-12 23:06:37 +0000219 return isBitPositionFlagSet(port.flags.get<AudioIoFlags::Tag::output>(),
220 AudioOutputFlags::MMAP_NOIRQ);
221 });
222}
223
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000224std::vector<AudioPort> ModuleConfig::getMmapInMixPorts(bool connectedOnly, bool singlePort) const {
225 return findMixPorts(true /*isInput*/, connectedOnly, singlePort, [&](const AudioPort& port) {
jiabin9a8e6862023-01-12 23:06:37 +0000226 return isBitPositionFlagSet(port.flags.get<AudioIoFlags::Tag::input>(),
227 AudioInputFlags::MMAP_NOIRQ);
228 });
229}
230
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000231std::vector<AudioPort> ModuleConfig::getConnectedDevicesPortsForMixPort(
Mikhail Naganov4f5d3f12022-07-22 23:23:25 +0000232 bool isInput, const AudioPortConfig& mixPortConfig) const {
233 const auto mixPortIt = findById<AudioPort>(mPorts, mixPortConfig.portId);
234 if (mixPortIt != mPorts.end()) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000235 return getConnectedDevicesPortsForMixPort(isInput, *mixPortIt);
Mikhail Naganov4f5d3f12022-07-22 23:23:25 +0000236 }
237 return {};
238}
239
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000240std::vector<AudioPort> ModuleConfig::getConnectedSinkDevicesPortsForMixPort(
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000241 const AudioPort& mixPort) const {
242 std::vector<AudioPort> result;
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000243 std::set<int32_t> connectedSinkDevicePorts = getConnectedSinkDevicePorts();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000244 for (const auto& route : mRoutes) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000245 if ((connectedSinkDevicePorts.count(route.sinkPortId) != 0) &&
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000246 std::find(route.sourcePortIds.begin(), route.sourcePortIds.end(), mixPort.id) !=
247 route.sourcePortIds.end()) {
248 const auto devicePortIt = findById<AudioPort>(mPorts, route.sinkPortId);
249 if (devicePortIt != mPorts.end()) result.push_back(*devicePortIt);
250 }
251 }
252 return result;
253}
254
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000255std::vector<AudioPort> ModuleConfig::getConnectedSourceDevicesPortsForMixPort(
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000256 const AudioPort& mixPort) const {
257 std::vector<AudioPort> result;
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000258 std::set<int32_t> connectedSourceDevicePorts = getConnectedSourceDevicePorts();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000259 for (const auto& route : mRoutes) {
260 if (route.sinkPortId == mixPort.id) {
261 for (const auto srcId : route.sourcePortIds) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000262 if (connectedSourceDevicePorts.count(srcId) != 0) {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000263 const auto devicePortIt = findById<AudioPort>(mPorts, srcId);
264 if (devicePortIt != mPorts.end()) result.push_back(*devicePortIt);
265 }
266 }
267 }
268 }
269 return result;
270}
271
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000272std::optional<AudioPort> ModuleConfig::getSourceMixPortForConnectedDevice() const {
273 std::set<int32_t> connectedSinkDevicePorts = getConnectedSinkDevicePorts();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000274 for (const auto& route : mRoutes) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000275 if (connectedSinkDevicePorts.count(route.sinkPortId) != 0) {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000276 const auto mixPortIt = findById<AudioPort>(mPorts, route.sourcePortIds[0]);
277 if (mixPortIt != mPorts.end()) return *mixPortIt;
278 }
279 }
280 return {};
281}
282
283std::optional<ModuleConfig::SrcSinkPair> ModuleConfig::getNonRoutableSrcSinkPair(
284 bool isInput) const {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000285 const auto mixPorts = getMixPorts(isInput, false /*connectedOnly*/);
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000286 std::set<std::pair<int32_t, int32_t>> allowedRoutes;
287 for (const auto& route : mRoutes) {
288 for (const auto srcPortId : route.sourcePortIds) {
289 allowedRoutes.emplace(std::make_pair(srcPortId, route.sinkPortId));
290 }
291 }
292 auto make_pair = [isInput](auto& device, auto& mix) {
293 return isInput ? std::make_pair(device, mix) : std::make_pair(mix, device);
294 };
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000295 for (const auto portId :
296 isInput ? getConnectedSourceDevicePorts() : getConnectedSinkDevicePorts()) {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000297 const auto devicePortIt = findById<AudioPort>(mPorts, portId);
298 if (devicePortIt == mPorts.end()) continue;
299 auto devicePortConfig = getSingleConfigForDevicePort(*devicePortIt);
300 for (const auto& mixPort : mixPorts) {
301 if (std::find(allowedRoutes.begin(), allowedRoutes.end(),
302 make_pair(portId, mixPort.id)) == allowedRoutes.end()) {
303 auto mixPortConfig = getSingleConfigForMixPort(isInput, mixPort);
304 if (mixPortConfig.has_value()) {
305 return make_pair(devicePortConfig, mixPortConfig.value());
306 }
307 }
308 }
309 }
310 return {};
311}
312
313std::optional<ModuleConfig::SrcSinkPair> ModuleConfig::getRoutableSrcSinkPair(bool isInput) const {
314 if (isInput) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000315 std::set<int32_t> connectedSourceDevicePorts = getConnectedSourceDevicePorts();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000316 for (const auto& route : mRoutes) {
317 auto srcPortIdIt = std::find_if(
318 route.sourcePortIds.begin(), route.sourcePortIds.end(),
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000319 [&](const auto& portId) { return connectedSourceDevicePorts.count(portId); });
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000320 if (srcPortIdIt == route.sourcePortIds.end()) continue;
321 const auto devicePortIt = findById<AudioPort>(mPorts, *srcPortIdIt);
322 const auto mixPortIt = findById<AudioPort>(mPorts, route.sinkPortId);
323 if (devicePortIt == mPorts.end() || mixPortIt == mPorts.end()) continue;
324 auto devicePortConfig = getSingleConfigForDevicePort(*devicePortIt);
325 auto mixPortConfig = getSingleConfigForMixPort(isInput, *mixPortIt);
326 if (!mixPortConfig.has_value()) continue;
327 return std::make_pair(devicePortConfig, mixPortConfig.value());
328 }
329 } else {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000330 std::set<int32_t> connectedSinkDevicePorts = getConnectedSinkDevicePorts();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000331 for (const auto& route : mRoutes) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000332 if (connectedSinkDevicePorts.count(route.sinkPortId) == 0) continue;
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000333 const auto mixPortIt = findById<AudioPort>(mPorts, route.sourcePortIds[0]);
334 const auto devicePortIt = findById<AudioPort>(mPorts, route.sinkPortId);
335 if (devicePortIt == mPorts.end() || mixPortIt == mPorts.end()) continue;
336 auto mixPortConfig = getSingleConfigForMixPort(isInput, *mixPortIt);
337 auto devicePortConfig = getSingleConfigForDevicePort(*devicePortIt);
338 if (!mixPortConfig.has_value()) continue;
339 return std::make_pair(mixPortConfig.value(), devicePortConfig);
340 }
341 }
342 return {};
343}
344
345std::vector<ModuleConfig::SrcSinkGroup> ModuleConfig::getRoutableSrcSinkGroups(bool isInput) const {
346 std::vector<SrcSinkGroup> result;
347 if (isInput) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000348 std::set<int32_t> connectedSourceDevicePorts = getConnectedSourceDevicePorts();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000349 for (const auto& route : mRoutes) {
350 std::vector<int32_t> srcPortIds;
351 std::copy_if(route.sourcePortIds.begin(), route.sourcePortIds.end(),
352 std::back_inserter(srcPortIds), [&](const auto& portId) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000353 return connectedSourceDevicePorts.count(portId);
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000354 });
355 if (srcPortIds.empty()) continue;
356 const auto mixPortIt = findById<AudioPort>(mPorts, route.sinkPortId);
357 if (mixPortIt == mPorts.end()) continue;
358 auto mixPortConfig = getSingleConfigForMixPort(isInput, *mixPortIt);
359 if (!mixPortConfig.has_value()) continue;
360 std::vector<SrcSinkPair> pairs;
361 for (const auto srcPortId : srcPortIds) {
362 const auto devicePortIt = findById<AudioPort>(mPorts, srcPortId);
363 if (devicePortIt == mPorts.end()) continue;
364 // Using all configs for every source would be too much.
365 auto devicePortConfig = getSingleConfigForDevicePort(*devicePortIt);
366 pairs.emplace_back(devicePortConfig, mixPortConfig.value());
367 }
368 if (!pairs.empty()) {
369 result.emplace_back(route, std::move(pairs));
370 }
371 }
372 } else {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000373 std::set<int32_t> connectedSinkDevicePorts = getConnectedSinkDevicePorts();
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000374 for (const auto& route : mRoutes) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000375 if (connectedSinkDevicePorts.count(route.sinkPortId) == 0) continue;
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000376 const auto devicePortIt = findById<AudioPort>(mPorts, route.sinkPortId);
377 if (devicePortIt == mPorts.end()) continue;
378 auto devicePortConfig = getSingleConfigForDevicePort(*devicePortIt);
379 std::vector<SrcSinkPair> pairs;
380 for (const auto srcPortId : route.sourcePortIds) {
381 const auto mixPortIt = findById<AudioPort>(mPorts, srcPortId);
382 if (mixPortIt == mPorts.end()) continue;
383 // Using all configs for every source would be too much.
384 auto mixPortConfig = getSingleConfigForMixPort(isInput, *mixPortIt);
385 if (mixPortConfig.has_value()) {
386 pairs.emplace_back(mixPortConfig.value(), devicePortConfig);
387 }
388 }
389 if (!pairs.empty()) {
390 result.emplace_back(route, std::move(pairs));
391 }
392 }
393 }
394 return result;
395}
396
Mikhail Naganov00603d12022-05-02 22:52:13 +0000397std::string ModuleConfig::toString() const {
398 std::string result;
399 result.append("Ports: ");
400 result.append(android::internal::ToString(mPorts));
Mikhail Naganov16db9b72022-06-17 21:36:18 +0000401 result.append("\nInitial configs: ");
Mikhail Naganov00603d12022-05-02 22:52:13 +0000402 result.append(android::internal::ToString(mInitialConfigs));
Mikhail Naganov16db9b72022-06-17 21:36:18 +0000403 result.append("\nAttached sink device ports: ");
Mikhail Naganov00603d12022-05-02 22:52:13 +0000404 result.append(android::internal::ToString(mAttachedSinkDevicePorts));
Mikhail Naganov16db9b72022-06-17 21:36:18 +0000405 result.append("\nAttached source device ports: ");
Mikhail Naganov00603d12022-05-02 22:52:13 +0000406 result.append(android::internal::ToString(mAttachedSourceDevicePorts));
Mikhail Naganov16db9b72022-06-17 21:36:18 +0000407 result.append("\nExternal device ports: ");
Mikhail Naganov00603d12022-05-02 22:52:13 +0000408 result.append(android::internal::ToString(mExternalDevicePorts));
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000409 result.append("\nConnected external device ports: ");
410 result.append(android::internal::ToString(getConnectedExternalDevicePorts()));
Mikhail Naganov16db9b72022-06-17 21:36:18 +0000411 result.append("\nRoutes: ");
Mikhail Naganov00603d12022-05-02 22:52:13 +0000412 result.append(android::internal::ToString(mRoutes));
413 return result;
414}
415
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000416static size_t combineAudioConfigs(const AudioPort& port, const AudioProfile& profile,
417 std::vector<AudioPortConfig>* result) {
418 const size_t newConfigCount = profile.channelMasks.size() * profile.sampleRates.size();
419 result->reserve(result->capacity() + newConfigCount);
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000420 for (auto channelMask : profile.channelMasks) {
421 for (auto sampleRate : profile.sampleRates) {
422 AudioPortConfig config{};
423 config.portId = port.id;
424 Int sr;
425 sr.value = sampleRate;
426 config.sampleRate = sr;
427 config.channelMask = channelMask;
428 config.format = profile.format;
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000429 config.flags = port.flags;
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000430 config.ext = port.ext;
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000431 result->push_back(std::move(config));
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000432 }
433 }
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000434 return newConfigCount;
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000435}
436
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000437static bool isDynamicProfile(const AudioProfile& profile) {
438 return (profile.format.type == AudioFormatType::DEFAULT && profile.format.encoding.empty()) ||
439 profile.sampleRates.empty() || profile.channelMasks.empty();
440}
441
Mikhail Naganov30301a42022-09-13 01:20:45 +0000442std::vector<AudioPort> ModuleConfig::findMixPorts(
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000443 bool isInput, bool connectedOnly, bool singlePort,
Mikhail Naganovef6bc742022-10-06 00:14:19 +0000444 const std::function<bool(const AudioPort&)>& pred) const {
Mikhail Naganov30301a42022-09-13 01:20:45 +0000445 std::vector<AudioPort> result;
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000446 const auto mixPorts = getMixPorts(isInput, connectedOnly);
Mikhail Naganov30301a42022-09-13 01:20:45 +0000447 for (auto mixPortIt = mixPorts.begin(); mixPortIt != mixPorts.end();) {
448 mixPortIt = std::find_if(mixPortIt, mixPorts.end(), pred);
449 if (mixPortIt == mixPorts.end()) break;
450 result.push_back(*mixPortIt++);
451 if (singlePort) break;
452 }
453 return result;
454}
455
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000456std::vector<AudioPortConfig> ModuleConfig::generateAudioMixPortConfigs(
457 const std::vector<AudioPort>& ports, bool isInput, bool singleProfile) const {
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000458 std::vector<AudioPortConfig> result;
459 for (const auto& mixPort : ports) {
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000460 if (getConnectedDevicesPortsForMixPort(isInput, mixPort).empty()) {
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000461 continue;
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000462 }
463 for (const auto& profile : mixPort.profiles) {
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000464 if (isDynamicProfile(profile)) continue;
465 combineAudioConfigs(mixPort, profile, &result);
466 if (singleProfile && !result.empty()) {
467 result.resize(1);
468 return result;
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000469 }
470 }
471 }
472 return result;
473}
474
475std::vector<AudioPortConfig> ModuleConfig::generateAudioDevicePortConfigs(
476 const std::vector<AudioPort>& ports, bool singleProfile) const {
477 std::vector<AudioPortConfig> result;
478 for (const auto& devicePort : ports) {
479 const size_t resultSizeBefore = result.size();
480 for (const auto& profile : devicePort.profiles) {
Mikhail Naganov111e0ce2022-06-17 21:41:19 +0000481 combineAudioConfigs(devicePort, profile, &result);
482 if (singleProfile && !result.empty()) {
483 result.resize(1);
484 return result;
485 }
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000486 }
487 if (resultSizeBefore == result.size()) {
Mikhail Naganov00603d12022-05-02 22:52:13 +0000488 std::copy_if(mInitialConfigs.begin(), mInitialConfigs.end(), std::back_inserter(result),
489 [&](const auto& config) { return config.portId == devicePort.id; });
490 if (resultSizeBefore == result.size()) {
491 AudioPortConfig empty;
492 empty.portId = devicePort.id;
493 empty.ext = devicePort.ext;
494 result.push_back(empty);
495 }
Mikhail Naganove5d747e2021-11-16 01:31:03 +0000496 }
497 if (singleProfile) return result;
498 }
499 return result;
500}
jiabinb76981e2023-01-18 00:58:30 +0000501
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000502const ndk::ScopedAStatus& ModuleConfig::onExternalDeviceConnected(IModule* module,
503 const AudioPort& port) {
504 // Update ports and routes
505 mStatus = module->getAudioPorts(&mPorts);
506 if (!mStatus.isOk()) return mStatus;
507 mStatus = module->getAudioRoutes(&mRoutes);
508 if (!mStatus.isOk()) return mStatus;
509
510 // Validate port is present in module
511 if (std::find(mPorts.begin(), mPorts.end(), port) == mPorts.end()) {
512 mStatus = ndk::ScopedAStatus::fromExceptionCode(EX_ILLEGAL_STATE);
513 return mStatus;
514 }
515
516 if (port.flags.getTag() == aidl::android::media::audio::common::AudioIoFlags::Tag::input) {
517 mConnectedExternalSourceDevicePorts.insert(port.id);
518 } else {
519 mConnectedExternalSinkDevicePorts.insert(port.id);
520 }
521 return mStatus;
522}
523
524const ndk::ScopedAStatus& ModuleConfig::onExternalDeviceDisconnected(IModule* module,
525 const AudioPort& port) {
526 // Update ports and routes
527 mStatus = module->getAudioPorts(&mPorts);
528 if (!mStatus.isOk()) return mStatus;
529 mStatus = module->getAudioRoutes(&mRoutes);
530 if (!mStatus.isOk()) return mStatus;
531
532 if (port.flags.getTag() == aidl::android::media::audio::common::AudioIoFlags::Tag::input) {
533 mConnectedExternalSourceDevicePorts.erase(port.id);
534 } else {
535 mConnectedExternalSinkDevicePorts.erase(port.id);
536 }
537 return mStatus;
538}
539
jiabinb76981e2023-01-18 00:58:30 +0000540bool ModuleConfig::isMmapSupported() const {
541 const std::vector<AudioPort> mmapOutMixPorts =
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000542 getMmapOutMixPorts(false /*connectedOnly*/, false /*singlePort*/);
jiabinb76981e2023-01-18 00:58:30 +0000543 const std::vector<AudioPort> mmapInMixPorts =
Shraddha Basantwani343db5e2023-08-23 12:39:15 +0000544 getMmapInMixPorts(false /*connectedOnly*/, false /*singlePort*/);
jiabinb76981e2023-01-18 00:58:30 +0000545 return !mmapOutMixPorts.empty() || !mmapInMixPorts.empty();
546}