Android 11 AudioPolicyService 启动流程

AudioPolicyService在init进程中启动，源码路径：frameworks/av/media/audioserver/audioserver.rc

service audioserver /system/bin/audioserverclass coreuser audioserver# media gid needed for /dev/fm (radio) and for /data/misc/media (tee)group audio camera drmrpc media mediadrm net_bt net_bt_admin net_bw_acct wakelockcapabilities BLOCK_SUSPENDioprio rt 4task_profiles ProcessCapacityHigh HighPerformanceonrestart restart vendor.audio-halonrestart restart vendor.audio-hal-4-0-msd# Keep the original service names for backward compatibilityonrestart restart vendor.audio-hal-2-0onrestart restart audio-hal-2-0

启动audioserver服务，对应的源文件为：frameworks/av/media/audioserver/main_audioserver.cpp

int main(int argc __unused, char **argv)
{if (doLog && (childPid = fork()) != 0) {//省略}else{//省略AudioFlinger::instantiate();//添加“media.audio_flinger”服务AudioPolicyService::instantiate();//添加media.audio_policy服务//省略}
}

创建AudioPolicyService时，导致其onFirstRef函数被调用

//frameworks/av/services/audiopolicy/service/AudioPolicyService.cpp
void AudioPolicyService::onFirstRef()
{{Mutex::Autolock _l(mLock);// start audio commands threadmAudioCommandThread = new AudioCommandThread(String8("ApmAudio"), this);// start output activity command threadmOutputCommandThread = new AudioCommandThread(String8("ApmOutput"), this);mAudioPolicyClient = new AudioPolicyClient(this);mAudioPolicyManager = createAudioPolicyManager(mAudioPolicyClient);}//省略

createAudioPolicyManager

//frameworks/av/services/audiopolicy/manager/AudioPolicyFactory.cpp
extern "C" AudioPolicyInterface* createAudioPolicyManager(AudioPolicyClientInterface *clientInterface)
{AudioPolicyManager *apm = new AudioPolicyManager(clientInterface);//1status_t status = apm->initialize();//2if (status != NO_ERROR) {delete apm;apm = nullptr;}return apm;
}

注释1处创建AudioPolicyManager对象，加载配置文件。关于配置文件的加载，参考：Android 11 Audio音频系统配置文件解析
注释2处，调用AudioPolicyManager的initialize函数

initialize

//frameworks/av/services/audiopolicy/managerdefault/AudioPolicyManager.cpp
status_t AudioPolicyManager::initialize() {{auto engLib = EngineLibrary::load("libaudiopolicyengine" + getConfig().getEngineLibraryNameSuffix() + ".so");//加载libaudiopolicyenginedefault.somEngine = engLib->createEngine();//得到Engine对象}// after parsing the config, mOutputDevicesAll and mInputDevicesAll contain all known devices;// open all output streams needed to access attached devicesonNewAudioModulesAvailableInt(nullptr /*newDevices*/);//省略

在函数中onNewAudioModulesAvailableInt中，主要完成以下三件事情：

  1. 根据配置文件中hwModule的名字加载对应的so文件（loadHwModule）
  2. 每个hwModule的mOutputProfiles中的每个outProfile，打开输出流，创建播放线程
  3. 每个hwModule的mInputProfiles中的每个inProfile，打开输入流，创建录音线程

1，加载so文件

//frameworks/av/services/audiopolicy/managerdefault/AudioPolicyManager.cpp
void AudioPolicyManager::onNewAudioModulesAvailableInt(DeviceVector *newDevices)
{for (const auto& hwModule : mHwModulesAll) {if (std::find(mHwModules.begin(), mHwModules.end(), hwModule) != mHwModules.end()) {continue;}hwModule->setHandle(mpClientInterface->loadHwModule(hwModule->getName()));//1//省略      
}

注释1处，调用loadHwModule处理，并将返回的结果handle赋值给hwModule 的mHandle。注意传入的是hwModule的名字，如：primary。最终调用到AudioFlinger的loadHwModule函数

//frameworks/av/services/audioflinger/AudioFlinger.cpp
audio_module_handle_t AudioFlinger::loadHwModule(const char *name)
{//省略Mutex::Autolock _l(mLock);AutoMutex lock(mHardwareLock);return loadHwModule_l(name);
}

loadHwModule_l

//frameworks/av/services/audioflinger/AudioFlinger.cpp
audio_module_handle_t AudioFlinger::loadHwModule_l(const char *name)
{//省略sp<DeviceHalInterface> dev;int rc = mDevicesFactoryHal->openDevice(name, &dev);//1//省略audio_module_handle_t handle = (audio_module_handle_t) nextUniqueId(AUDIO_UNIQUE_ID_USE_MODULE);AudioHwDevice *audioDevice = new AudioHwDevice(handle, name, dev, flags);//2mAudioHwDevs.add(handle, audioDevice);//3return handle;
}

注释1处通过hidl，去加载对应的so(如:audio.primary.default.so)，并调用audio hal的open函数，从hal中得到一个audio_hw_device对象。注释2处将该对象封装在AudioHwDevice 中，然后注释3处将AudioHwDevice 添加到mAudioHwDevs数组中。

打开输出流创建线程

//frameworks/av/services/audiopolicy/managerdefault/AudioPolicyManager.cpp
void AudioPolicyManager::onNewAudioModulesAvailableInt(DeviceVector *newDevices)
{for (const auto& hwModule : mHwModulesAll) {if (std::find(mHwModules.begin(), mHwModules.end(), hwModule) != mHwModules.end()) {continue;}//省略   for (const auto& outProfile : hwModule->getOutputProfiles()) {//省略sp<SwAudioOutputDescriptor> outputDesc = new SwAudioOutputDescriptor(outProfile,mpClientInterface);audio_io_handle_t output = AUDIO_IO_HANDLE_NONE;status_t status = outputDesc->open(nullptr, DeviceVector(supportedDevice),AUDIO_STREAM_DEFAULT,AUDIO_OUTPUT_FLAG_NONE, &output);//省略addOutput(output, outputDesc);//保存到mOutputs数组中}   //省略
}

针对module下的每个outProfile ，都会创建一个SwAudioOutputDescriptor对象，并调用其open方法，然后将该SwAudioOutputDescriptor保存到mOutputs数组中，注意是根据返回的output来保存的。open函数最终调用到AudioFlinger的openOutput_l函数

//frameworks/av/services/audioflinger/AudioFlinger.cpp
sp<AudioFlinger::ThreadBase> AudioFlinger::openOutput_l(audio_module_handle_t module,audio_io_handle_t *output,audio_config_t *config,audio_devices_t deviceType,const String8& address,audio_output_flags_t flags)
{AudioHwDevice *outHwDev = findSuitableHwDev_l(module, deviceType);//根据handle，从mAudioHwDevs数组中找出AudioHwDevice //省略AudioStreamOut *outputStream = NULL;status_t status = outHwDev->openOutputStream(&outputStream,*output,deviceType,flags,config,address.string());//1if (status == NO_ERROR) {if (flags & AUDIO_OUTPUT_FLAG_MMAP_NOIRQ) {//省略} else {sp<PlaybackThread> thread;if (flags & AUDIO_OUTPUT_FLAG_COMPRESS_OFFLOAD) {//省略} else if ((flags & AUDIO_OUTPUT_FLAG_DIRECT)|| !isValidPcmSinkFormat(config->format)|| !isValidPcmSinkChannelMask(config->channel_mask)) {//省略} else {thread = new MixerThread(this, outputStream, *output, mSystemReady);//创建MixerThread播放线程}mPlaybackThreads.add(*output, thread);//添加到mPlaybackThreadsreturn thread;}}return 0;
}

注释1处调用AudioHwDevice 的openOutputStream函数去打开输出流。然后就是创建MixerThread播放线程并保存在mPlaybackThreads数组中，需要注意的是，也是根据output添加的。这里的output和上面添加outputDesc时的output是同一个。

openOutputStream

//frameworks/av/services/audioflinger/AudioHwDevice.cpp
status_t AudioHwDevice::openOutputStream(AudioStreamOut **ppStreamOut,audio_io_handle_t handle,audio_devices_t deviceType,audio_output_flags_t flags,struct audio_config *config,const char *address)
{struct audio_config originalConfig = *config;AudioStreamOut *outputStream = new AudioStreamOut(this, flags);//创建AudioStreamOut对象status_t status = outputStream->open(handle, deviceType, config, address);//省略*ppStreamOut = outputStream;return status;
}

AudioStreamOut::open

//frameworks/av/services/audioflinger/AudioStreamOut.cpp
status_t AudioStreamOut::open(audio_io_handle_t handle,audio_devices_t deviceType,struct audio_config *config,const char *address)
{sp<StreamOutHalInterface> outStream;int status = hwDev()->openOutputStream(handle,deviceType,customFlags,config,address,&outStream);
//省略

openOutputStream最后会通过hidl，调用到audio hal 的open_output_stream函数，返回一个audio_stream_out对象。

打开输入流，创建录音线程

这个流程和上面的是一样的，最终调用到AudioFlinger的openInput_l处理

//frameworks/av/services/audioflinger/AudioFlinger.cpp
sp<AudioFlinger::ThreadBase> AudioFlinger::openInput_l(audio_module_handle_t module,audio_io_handle_t *input,audio_config_t *config,audio_devices_t devices,const String8& address,audio_source_t source,audio_input_flags_t flags,audio_devices_t outputDevice,const String8& outputDeviceAddress)
{AudioHwDevice *inHwDev = findSuitableHwDev_l(module, devices);//找出AudioHwDevice //省略sp<DeviceHalInterface> inHwHal = inHwDev->hwDevice();sp<StreamInHalInterface> inStream;status_t status = inHwHal->openInputStream(*input, devices, &halconfig, flags, address.string(), source,outputDevice, outputDeviceAddress, &inStream);//1//省略if (status == NO_ERROR && inStream != 0) {AudioStreamIn *inputStream = new AudioStreamIn(inHwDev, inStream, flags);//将HAL层得到的audio_stream_in保存在AudioStreamIn中if ((flags & AUDIO_INPUT_FLAG_MMAP_NOIRQ) != 0) {//省略} else {// Start record thread// RecordThread requires both input and output device indication to forward to audio// pre processing modulessp<RecordThread> thread = new RecordThread(this, inputStream, *input, mSystemReady);//创建RecordThread线程mRecordThreads.add(*input, thread);//保存在mRecordThreads数组中ALOGV("openInput_l() created record thread: ID %d thread %p", *input, thread.get());return thread;}//省略

注释1处，通过hidl，调用到audio hal 的open_input_stream函数，返回一个audio_stream_in对象。

总结

在AudioPolicyService服务的启动过程中，会解析配置文件。针对每个HwModule，根据名字去加载对应的HAL库，得到audio_hw_device对象，将其保存在AudioHwDevice对象中，并将AudioHwDevice对象添加到mAudioHwDevs数组中。

对于HwModule下的每个outProfile ，都会创建SwAudioOutputDescriptor对象，并去打开输出流，创建播放线程。根据返回的output，将SwAudioOutputDescriptor添加到mOutput数组中。在打开输出流的过程中，会得到HAL层的audio_stream_out对象，并将其保存在AudioStreamOut中，创建播放线程的时候，传入该AudioStreamOut,最后将播放线程保存到mPlaybackThreads中。

对于HwModule下的每个inProfile，都会去打开输入流，创建录音线程。在打开输出流的过程中，会得到HAL层的audio_stream_in对象，并将其保存在AudioStreamIn中，创建录音线程的时候，传入该AudioStreamIn。最后将录音线程保存在mRecordThreads中

保存AudioHwDevice和保存播放线程，是根据同一个output保存的。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/web/18806.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

DETR整体模型结构解析

DETR整体模型结构解析

DETR流程 Backbone用卷积神经网络抽特征。最后通过一层1*1卷积转化到d_model维度fm&#xff08;B,d_model,HW&#xff09;。 position embedding建立跟fm维度相同的位置编码(B&#xff0c;d_model,HW&#xff09;。 Transformer Encoder,V为fm&#xff0c;K&#xff0c;Q为fm…
阅读更多...
非量表题如何进行信效度分析

非量表题如何进行信效度分析

效度是指设计的题确实在测量某个东西&#xff0c;一般问卷中使用到。如果是量表类的数据&#xff0c;其一般是用因子分析这种方法去验证效度水平&#xff0c;其可通过因子分析探究各测量量表的内部结构情况&#xff0c;分析因子分析得到的内部结构与自己预期的内部结构进行对比…
阅读更多...
自学之路Flutter使用Provider进行状态管理

自学之路Flutter使用Provider进行状态管理

使用前的准备 首先在pubspec.yaml中配置&#xff0c;然后pub get,等待安装完成 我们首先创建两个比较简单的控制器&#xff0c;测试页面跳转之间的数据传递。 import package:flutter/material.dart;void main() {runApp(const MyApp()); }class MyApp extends StatelessWid…
阅读更多...
python接口自动化之会话保持

python接口自动化之会话保持

&#x1f366; 会话保持-token 有的网站登录需要token鉴权&#xff0c;是啥意思呢&#xff0c;现在有两个接口&#xff0c;一个接口是登录&#xff0c;一个接口是提交订单&#xff0c;那你怎么保证&#xff0c;提交登录这个用户是登录状态呢。登录成功的接接口会在response里面…
阅读更多...
大模型预训练结果到底是什么？

大模型预训练结果到底是什么？

近日参加一个线下 AI 交流会议&#xff0c;会上有个非本行业的老师提问&#xff1a;“大家说的训练好的大模型到底是什么&#xff1f;是像 Word 软件一样可以直接使用的程序吗&#xff1f;” 这个问题看似简单&#xff0c;却一下把我问住了。的确&#xff0c;我们这些身处 AI 领…
阅读更多...
Kafka原生API使用Java代码-生产者-发送消息

Kafka原生API使用Java代码-生产者-发送消息

文章目录 1、生产者发送消息1.1、使用EFAK创建主题my_topic31.2、根据kafka官网文档写代码1.3、pom.xml1.4、KafkaProducer1.java1.5、使用EFAK查看主题1.6、再次运行KafkaProducer1.java1.7、再次使用EFAK查看主题 1、生产者发送消息 1.1、使用EFAK创建主题my_topic3 1.2、根…
阅读更多...
STM32 OTA需要注意问题

STM32 OTA需要注意问题

一、OTA设计思路&#xff08;问题&#xff09; 1、根据stm32f405 flash分布&#xff0c;最初将flash划分为四个区域&#xff0c;分别是Bootloader、APP1、APP2、参数区&#xff0c;设备上电后&#xff0c;进入Bootloader程序&#xff0c;判断OTA参数&#xff0c;根据参数来确定…
阅读更多...
APP逆向之调试的开启

APP逆向之调试的开启

很基础的一个功能设置&#xff0c;大佬轻喷。 背景 在开始进行对APP逆向分析的时候&#xff0c;需要对APP打开调试模式。 打开调试的模式有多种方式可以通过直接改包方式也可以通过借助第三方工具进行打开调试模式。 下面就整理下这个打开调试模式的一些方式。 改包修改模…
阅读更多...
Java面试题分享-敏感词替换 java 版本

Java面试题分享-敏感词替换 java 版本

入职啦最近更新了一些后端笔试、面试题目&#xff0c;大家看看能快速实现吗&#xff1f; 关注 入职啦 微信公众号&#xff0c;每日更新有用的知识&#xff0c;Python&#xff0c;Java&#xff0c;Golang&#xff0c;Rust&#xff0c;javascript 等语言都有 不要再用replaceAll做…
阅读更多...
npm获取yarn在安装依赖时 git://github.com/user/xx.git 无法访问解决方法 -- 使用 insteadOf设置git命令别名

npm获取yarn在安装依赖时 git://github.com/user/xx.git 无法访问解决方法 -- 使用 insteadOf设置git命令别名

今天在使用一个node项目时突然遇到 一个github的拉取异常&#xff0c;一看协议居然是git://xxx 貌似github早就不用这种格式了&#xff0c; 而是使用的gitgithub.com:xxx 这种或者https协议&#xff0c;解决方法&#xff1a; 使用insteadof设置git别名 url.<base>.inste…
阅读更多...
DNF手游攻略：开荒必备攻略！

DNF手游攻略：开荒必备攻略！

DNF手游马上就要开服了&#xff0c;今天给大家带来最完整的DNF手游入门教程。这篇攻略主要讲述了 DNF手游开服第一天要注意的事项&#xff0c;这是一个新手必备的技能书&#xff0c;可以让你在开服的时候&#xff0c;少走一些弯路&#xff0c;让你更快完成任务&#xff01;废话…
阅读更多...
蓝牙Mesh模块多跳大数据量高带宽传输数据方法

蓝牙Mesh模块多跳大数据量高带宽传输数据方法

随着物联网技术的飞速发展&#xff0c;越来越多的设备需要实现互联互通。蓝牙Mesh网络作为一种低功耗、高覆盖、易于部署的无线通信技术&#xff0c;已经成为物联网领域中的关键技术之一。在蓝牙Mesh网络中&#xff0c;节点之间可以通过多个跳数进行通信&#xff0c;从而实现大…
阅读更多...
mysql-日志管理-error.log

mysql-日志管理-error.log

日志管理 默认的数据库日志 vim /etc/my.cnf //错误日志 log-error/usr/local/mysql/mysql.log查看数据库日志 tail -f /usr/local/mysql/mysql.log1 错误日志 &#xff1a;启动&#xff0c;停止&#xff0c;关闭失败报错。rpm安装日志位置 /var/log/mysqld.log #默认开启 2 …
阅读更多...
【OrangePi AIpro】香橙派 AIpro 为AI而生

【OrangePi AIpro】香橙派 AIpro 为AI而生

产品简介 OrangePi AIpro(8T)&#xff1a;定义边缘智能新纪元的全能开发板 在当今人工智能与物联网技术融合发展的浪潮中&#xff0c;OrangePi AIpro(8T)凭借其强大的硬件配置与全面的接口设计&#xff0c;正逐步成为开发者手中的创新利器。这款开发板不仅代表了香橙派与华为…
阅读更多...
最新淘宝死店全自动采集私信筛选脚本，号称日赚500+【采集软件+使用教程】

最新淘宝死店全自动采集私信筛选脚本，号称日赚500+【采集软件+使用教程】

原理&#xff1a; 利用脚本自动采集长时间未登录店铺&#xff0c;然后脚本自动私信对应的店铺&#xff0c;看看商家是不是不回消息来判断是否是死店&#xff0c;再下单购买死店的产品&#xff0c;超过48小时不发货就可以联系客服获得赔付&#xff0c;一单利润百分之5%-30%&…
阅读更多...
配置阿里yum源

配置阿里yum源

配置阿里yum源&#xff08;这个很重要&#xff09;&#xff1a;https://developer.aliyun.com/article/1480470 1.备份系统自带yum源配置文件 mv /etc/yum.repos.d/CentOS-Base.repo /etc/yum.repos.d/CentOS-Base.repo.backup2.下载ailiyun的yum源配置文件 2.1 CentOS7 wge…
阅读更多...
SRS、ZLMediakit音视频流媒体服务器

SRS、ZLMediakit音视频流媒体服务器

SRS、ZLMediakit都是做为webrtc的SFU&#xff08;selective forward unit&#xff09; WebRTC 开发实践&#xff1a;为什么你需要 SFU 服务器 https://mp.weixin.qq.com/s?__bizMzAxNTc1MjM0Mw&mid2652213442&idx1&sn33f0393a2dbc2b6a39c613bb238ec145&chksm…
阅读更多...
Ansible03-Ansible Playbook剧本详解

Ansible03-Ansible Playbook剧本详解

目录 写在前面5. Ansible Playbook 剧本5.1 YAML语法5.1.1 语法规定5.1.2 示例5.1.3 YAML数据类型 5.2 Playbook组件5.3 Playbook 案例5.3.1 Playbook语句5.3.2 Playbook1 分发hosts文件5.3.3 Playbook2 分发软件包&#xff0c;安装软件包&#xff0c;启动服务5.3.3.1 任务拆解…
阅读更多...
DHCP原理和配置服务

DHCP原理和配置服务

一、DHCP工作原理 DHCP(Dynamic Host Configuration Protocol&#xff0c;动态主机配置协议)由Internet工作任务小组设计开发专门用于为TCP/IP网络中的计算机自动分配TCP/IP参数的协议 使用DHCP的好处 减少管理员的工作量 避免输入错误的可能 避免IP地址冲突 当更改IP地址…
阅读更多...
VUE3 学习笔记（9）：VUE 插槽的概念、基本应用、传值

VUE3 学习笔记（9）：VUE 插槽的概念、基本应用、传值

在调用子组件时&#xff0c;我们希望把父组件的HTML传给子组件&#xff0c;那么在引用子组件内部进行定义&#xff0c;然后子组件通过slot标签进行接收 基本示例 父 app.vue <!--内容控制--> <template><test><div><p>{{name}}</p><p…
阅读更多...
最新文章

Copyright @ 2022~2023