【Bluedroid】A2DP Sink播放流程源码分析(二)

接上一篇继续分析:【Bluedroid】A2DP Sink播放流程源码分析(一)_安卓a2dp sink播放流程-CSDN博客

AVDTP接收端(Sink)流事件处理

bta_av_sink_data_cback 是 Bluedroid 中 A2DP Sink 角色的 AVDTP 数据回调函数,负责处理接收端的音频数据事件,将底层接收到的音频数据传递给上层模块。

bta_av_sink_data_cback

packages/modules/Bluetooth/system/bta/av/bta_av_aact.cc
/********************************************************************************* Function         bta_av_sink_data_cback** Description      This is the AVDTP callback function for sink stream events.** Returns          void*******************************************************************************/
void bta_av_sink_data_cback(uint8_t handle, BT_HDR* p_pkt, uint32_t time_stamp,uint8_t m_pt) {int index = 0;tBTA_AV_SCB* p_scb;log::verbose("avdt_handle: {} pkt_len=0x{:x}  offset = 0x{:x} number of frames 0x{:x} ""sequence number 0x{:x}",handle, p_pkt->len, p_pkt->offset,*((uint8_t*)(p_pkt + 1) + p_pkt->offset), p_pkt->layer_specific);// 1. 查找流控制块(SCB)/* Get SCB and correct sep type */for (index = 0; index < BTA_AV_NUM_STRS; index++) {p_scb = bta_av_cb.p_scb[index]; // 存储流连接的状态(如角色、句柄、SEP 类型等)if ((p_scb->avdt_handle == handle) &&(p_scb->seps[p_scb->sep_idx].tsep == AVDT_TSEP_SNK)) {break;}}if (index == BTA_AV_NUM_STRS) {/* cannot find correct handler */osi_free(p_pkt);return;}// 2. 触发上层回调p_pkt->event = BTA_AV_SINK_MEDIA_DATA_EVT; // 设置事件类型为 Sink 媒体数据事件// 上层回调:通过 p_app_sink_data_cback 将数据传递给 A2DP Sink 应用层(如音频解码、播放模块),触发后续处理(如数据解析、缓冲区写入)p_scb->seps[p_scb->sep_idx].p_app_sink_data_cback(p_scb->PeerAddress(), BTA_AV_SINK_MEDIA_DATA_EVT, (tBTA_AV_MEDIA*)p_pkt);/* Free the buffer: a copy of the packet has been delivered */osi_free(p_pkt);
}

bta_av_sink_data_cback 用于处理蓝牙 AVDTP接收端(Sink)流事件的回调函数。主要作用是在接收到相关的数据包后,根据数据包对应的句柄等信息找到对应的处理上下文(通过查找 SCB),然后对数据包进行一些必要的处理,如设置事件类型,并调用相应的应用层回调函数将数据包及相关事件信息传递给上层应用进行进一步处理,最后释放数据包所占用的内存,确保整个接收端流事件处理流程的完整性以及内存资源的合理管理。 

关键作用

  1. 数据通路桥梁:连接 AVDTP 层与上层应用,将原始音频数据转换为 Sink 角色可处理的事件。
  2. 状态校验:通过 SCB 筛选确保仅处理 Sink 角色的合法流连接,避免跨角色数据误处理。
  3. 错误隔离:未找到 SCB 时及时释放内存,防止无效指针操作导致的崩溃。

bta_av_sink_media_callback (BTA_AV_SINK_MEDIA_DATA_EVT

packages/modules/Bluetooth/system/btif/src/btif_av.cc
// TODO: All processing should be done on the JNI thread
static void bta_av_sink_media_callback(const RawAddress& peer_address,tBTA_AV_EVT event,tBTA_AV_MEDIA* p_data) {log::verbose("event={}", event);switch (event) {case BTA_AV_SINK_MEDIA_DATA_EVT: { // 当接收到媒体数据时触发BtifAvPeer* peer = btif_av_sink_find_peer(peer_address);if (peer != nullptr && peer->IsActivePeer()) {int state = peer->StateMachine().StateId();if ((state == BtifAvStateMachine::kStateStarted) ||(state == BtifAvStateMachine::kStateOpened)) {uint8_t queue_len = btif_a2dp_sink_enqueue_buf((BT_HDR*)p_data);log::verbose("Packets in Sink queue {}", queue_len);}}break;}...default:break;}
}

bta_av_sink_media_callback 是一个回调函数,主要用于处理蓝牙音频 / 视频(AV)接收端(Sink)相关的媒体事件。依据接收到的不同媒体事件类型来执行相应操作,目的是协调蓝牙 A2DP 接收端在接收媒体数据时与系统内其他部分的交互,比如根据接收端状态决定是否将接收到的数据入队等操作,以此保障蓝牙音频 / 视频接收流程能正常进行。

btif_a2dp_sink_enqueue_buf 
packages/modules/Bluetooth/system/btif/src/btif_a2dp_sink.cc
uint8_t btif_a2dp_sink_enqueue_buf(BT_HDR* p_pkt) {// 1. 加锁与刷新检查LockGuard lock(g_mutex);if (btif_a2dp_sink_cb.rx_flush) /* Flush enabled, do not enqueue */return fixed_queue_length(btif_a2dp_sink_cb.rx_audio_queue);log::verbose("+");// 2. 分配内存并复制数据包/* Allocate and queue this buffer */BT_HDR* p_msg =reinterpret_cast<BT_HDR*>(osi_malloc(sizeof(*p_msg) + p_pkt->len));memcpy(p_msg, p_pkt, sizeof(*p_msg));p_msg->offset = 0;memcpy(p_msg->data, p_pkt->data + p_pkt->offset, p_pkt->len);// 将新的消息结构体添加到接收音频队列 rx_audio_queue 中fixed_queue_enqueue(btif_a2dp_sink_cb.rx_audio_queue, p_msg);// 3. 队列长度检查与处理if (fixed_queue_length(btif_a2dp_sink_cb.rx_audio_queue) ==MAX_INPUT_A2DP_FRAME_QUEUE_SZ) { // 队列已满osi_free(fixed_queue_try_dequeue(btif_a2dp_sink_cb.rx_audio_queue));uint8_t ret = fixed_queue_length(btif_a2dp_sink_cb.rx_audio_queue);return ret;}// 4. 解码启动检查// Avoid other checks if alarm has already been initialized.if (btif_a2dp_sink_cb.decode_alarm == nullptr &&fixed_queue_length(btif_a2dp_sink_cb.rx_audio_queue) >=MAX_A2DP_DELAYED_START_FRAME_COUNT) {log::verbose("Initiate decoding. Current focus state:{}",btif_a2dp_sink_cb.rx_focus_state);if (btif_a2dp_sink_cb.rx_focus_state == BTIF_A2DP_SINK_FOCUS_GRANTED) {btif_a2dp_sink_audio_handle_start_decoding();}}return fixed_queue_length(btif_a2dp_sink_cb.rx_audio_queue);
}

处理蓝牙 A2DP接收端(Sink)的数据入队操作。通过合理的加锁机制保障多线程环境下资源访问的安全性,根据刷新机制决定是否入队数据,在入队过程中进行内存分配、数据复制以及队列长度控制等操作,同时还能根据特定条件触发音频解码相关操作,确保接收端音频数据能够正确地缓存、管理以及适时地进行解码播放,对于维持整个蓝牙音频接收和播放流程的顺畅以及资源的合理利用有着重要意义。

fixed_queue_enqueue 
packages/modules/Bluetooth/system/osi/src/fixed_queue.cc
void fixed_queue_enqueue(fixed_queue_t* queue, void* data) {CHECK(queue != NULL);CHECK(data != NULL);//等待入队信号量。如果队列已满(即入队信号量的计数为0),则当前线程将阻塞在这里,直到有其他线程从队列中移除了元素并调用了 semaphore_post(queue->enqueue_sem)semaphore_wait(queue->enqueue_sem);{std::lock_guard<std::mutex> lock(*queue->mutex);list_append(queue->list, data); // 将数据添加到队列的列表中}// 增加出队信号量的计数。表示队列中有新的元素可供出队操作,如果之前有线程在等待出队信号量(即队列为空且线程尝试从队列中取出元素),则这些线程现在可以继续执行semaphore_post(queue->dequeue_sem);
}

向一个固定队列(fixed_queue_t 类型的队列)中添加元素(通过 void* data 参数传入要添加的数据指针),在添加过程中,通过严格的参数检查、合理的信号量控制以及互斥锁保护下的队列元素添加操作,在多线程环境下实现了安全、可靠的队列入队功能。通过控制入队和出队信号量的等待与释放,还能有效地协调多个线程对队列的并发使用,避免出现数据竞争、不一致等并发问题,保障了整个固定队列数据结构在多线程系统中的正常运行,对于需要在并发环境下进行数据缓存、排队处理等应用场景有着重要的支撑作用。

btif_a2dp_sink_audio_handle_start_decoding

packages/modules/Bluetooth/system/btif/src/btif_a2dp_sink.cc
// Must be called while locked.
static void btif_a2dp_sink_audio_handle_start_decoding() {log::info("");if (btif_a2dp_sink_cb.decode_alarm != nullptr)return;  // Already started decoding#ifdef __ANDROID__BtifAvrcpAudioTrackStart(btif_a2dp_sink_cb.audio_track);
#endif//创建一个新的周期性定时器,并将其地址存储在 btif_a2dp_sink_cb.decode_alarm 中btif_a2dp_sink_cb.decode_alarm = alarm_new_periodic("btif.a2dp_sink_decode");if (btif_a2dp_sink_cb.decode_alarm == nullptr) {log::error("unable to allocate decode alarm");return;}// 设置定时器的触发间隔为 BTIF_SINK_MEDIA_TIME_TICK_MS(20,定时器触发的毫秒间隔)// 当定时器触发时,将调用 btif_decode_alarm_cb 回调函数(传递 nullptr 作为参)alarm_set(btif_a2dp_sink_cb.decode_alarm, BTIF_SINK_MEDIA_TIME_TICK_MS,btif_decode_alarm_cb, nullptr);
}

负责启动蓝牙 A2DP(接收端(Sink)的音频解码相关操作。在调用时要求处于加锁状态,以确保在多线程环境下操作相关共享资源(如 btif_a2dp_sink_cb 结构体相关成员)的安全性。首先通过检查避免重复启动解码操作,然后针对安卓平台进行相应的音频播放前置操作(在__ANDROID__环境下),接着创建周期性的定时器(或称为“alarm”)并设置好相关参数和回调函数,以此来建立起一个定时执行音频解码任务的机制,保障音频数据能够在合适的时间间隔下持续地被解码处理,为后续的音频播放等流程提供解码后的数据支持。

下面分析SBC编码写入audiotrack的过程,其它编码格式的如法炮制。 

btif_decode_alarm_cb

packages/modules/Bluetooth/system/btif/src/btif_a2dp_sink.cc
static void btif_decode_alarm_cb(void* /* context */) {LockGuard lock(g_mutex);btif_a2dp_sink_cb.worker_thread.DoInThread(FROM_HERE, base::BindOnce(btif_a2dp_sink_avk_handle_timer));
}

btif_decode_alarm_cb 函数主要作为一个回调函数来使用,其核心功能是在被触发时,先通过加锁机制确保线程安全地访问共享资源,然后安排在特定的工作线程中执行另一个函数 btif_a2dp_sink_avk_handle_timer,以此实现一种异步的、线程安全的操作触发机制,用于在特定的定时或事件触发场景下,让相关的音频处理逻辑(由 btif_a2dp_sink_avk_handle_timer 函数具体实现)能够在合适的线程环境中有序执行,保障音频相关功能的正确运行。

btif_a2dp_sink_avk_handle_timer 

packages/modules/Bluetooth/system/btif/src/btif_a2dp_sink.cc
static void btif_a2dp_sink_avk_handle_timer() {// 1. 加锁操作LockGuard lock(g_mutex);// 2. 检查队列是否为空BT_HDR* p_msg; // 用于后续存储从队列中取出的数据包if (fixed_queue_is_empty(btif_a2dp_sink_cb.rx_audio_queue)) {log::verbose("empty queue");return;}// 3. 检查焦点状态/* Don't do anything in case of focus not granted */if (btif_a2dp_sink_cb.rx_focus_state == BTIF_A2DP_SINK_FOCUS_NOT_GRANTED) {log::verbose("skipping frames since focus is not present");return;}// 4. 检查刷新标志/* Play only in BTIF_A2DP_SINK_FOCUS_GRANTED case */if (btif_a2dp_sink_cb.rx_flush) {// 清空接收音频队列,并释放队列中每个元素的内存fixed_queue_flush(btif_a2dp_sink_cb.rx_audio_queue, osi_free);return;}// 5. 处理队列中的数据包log::verbose("process frames begin");while (true) { // 使用 while 循环不断从队列中取出数据包,直到队列为空(即 fixed_queue_try_dequeue 返回 NULL)p_msg = (BT_HDR*)fixed_queue_try_dequeue(btif_a2dp_sink_cb.rx_audio_queue);if (p_msg == NULL) {break;}log::verbose("number of packets in queue {}",fixed_queue_length(btif_a2dp_sink_cb.rx_audio_queue));/* Queue packet has less frames */btif_a2dp_sink_handle_inc_media(p_msg); // 处理取出的音频数据包osi_free(p_msg);}log::verbose("process frames end");
}

btif_a2dp_sink_avk_handle_timer 函数是一个定时器处理函数,用于处理 A2DP Sink 端接收到的音频数据包队列。在定时器触发时被调用,对 A2DP Sink 端的音频数据包队列进行检查和处理。根据队列状态、焦点状态和刷新标志来决定是直接返回、清空队列还是逐个处理队列中的数据包,确保音频数据的处理符合系统的状态和要求。

btif_a2dp_sink_handle_inc_media

packages/modules/Bluetooth/system/btif/src/btif_a2dp_sink.cc
// Must be called while locked.
static void btif_a2dp_sink_handle_inc_media(BT_HDR* p_msg) {if ((btif_av_get_peer_sep() == AVDT_TSEP_SNK) ||(btif_a2dp_sink_cb.rx_flush)) {log::verbose("state changed happened in this tick");return;}CHECK(btif_a2dp_sink_cb.decoder_interface != nullptr);if (!btif_a2dp_sink_cb.decoder_interface->decode_packet(p_msg)) {log::error("decoding failed");}
}

确保当前状态允许的情况下,调用解码器接口来解码接收到的A2DP音频数据包。保障了音频数据在合适的条件下能够被合理地进行解码操作,对于维持音频播放等后续功能的正常运行有着重要意义。 

a2dp_sbc_decoder_decode_packet
packages/modules/Bluetooth/system/stack/a2dp/a2dp_sbc_decoder.cc
bool a2dp_sbc_decoder_decode_packet(BT_HDR* p_buf) {// 1. 输入数据准备uint8_t* data = p_buf->data + p_buf->offset;size_t data_size = p_buf->len;if (data_size == 0) {log::error("Empty packet");return false;}size_t num_frames = data[0] & 0xf; // 提取帧数量(低4位)data += 1;  // 跳过帧数量字段,指向实际音频数据data_size -= 1;// 2. 逐帧解码const OI_BYTE* oi_data = data; // 转换为 OI 库所需的字节类型uint32_t oi_size = data_size;  // 剩余待解码数据大小size_t out_avail = sizeof(a2dp_sbc_decoder_cb.decode_buf); // 输出缓冲区总大小int16_t* out_ptr = a2dp_sbc_decoder_cb.decode_buf; // 输出缓冲区指针(PCM 数据)for (size_t i = 0; i < num_frames; ++i) {uint32_t out_size = out_avail;  // 当前帧解码所需的输出空间// 解码库调用OI_STATUS status = OI_CODEC_SBC_DecodeFrame(&a2dp_sbc_decoder_cb.decoder_context,  // 解码上下文(包含编解码参数)&oi_data,                             // 输入数据指针(按帧递增)&oi_size,                             // 剩余输入数据大小(按帧递减)out_ptr,                             // 输出 PCM 数据指针&out_size                            // 实际解码出的 PCM 数据大小);if (!OI_SUCCESS(status)) {log::error("Decoding failure: {}", status);return false;  // 解码失败,终止处理}out_avail -= out_size;       // 更新剩余输出空间out_ptr += out_size / sizeof(*out_ptr);  // 移动输出指针(按 int16 单位)
}// 3. 解码结果回调size_t out_used = (out_ptr - a2dp_sbc_decoder_cb.decode_buf) * sizeof(*out_ptr);// 上层回调:通过 decode_callback 将解码后的 PCM 数据传递给上层(如音频播放模块),触发后续处理(如写入音频输出设备)a2dp_sbc_decoder_cb.decode_callback(reinterpret_cast<uint8_t*>(a2dp_sbc_decoder_cb.decode_buf),  // PCM 数据起始地址out_used                                                     // 实际使用的字节数);
}

a2dp_sbc_decoder_decode_packet 是 A2DP Sink 端 SBC(Subband Coding,子带编码)编解码器的核心解码函数,负责将接收到的 SBC 格式音频数据包解码为 PCM 数据,供上层音频播放模块使用。其核心逻辑包括 数据包解析逐帧解码 和 结果回调

OI_CODEC_SBC_DecodeFrame
packages/modules/Bluetooth/system/embdrv/sbc/decoder/srce/decoder-sbc.c
OI_STATUS OI_CODEC_SBC_DecodeFrame(OI_CODEC_SBC_DECODER_CONTEXT* context,const OI_BYTE** frameData,uint32_t* frameBytes, int16_t* pcmData,uint32_t* pcmBytes) {OI_STATUS status;OI_UINT framelen;uint8_t crc;TRACE(("+OI_CODEC_SBC_DecodeFrame"));// 1. 同步字查找(Syncword Detection)TRACE(("Finding syncword"));status = FindSyncword(context, frameData, frameBytes);if (!OI_SUCCESS(status)) {return status;}// 2. 头部解析与参数校验/* Make sure enough data remains to read the header. */if (*frameBytes < SBC_HEADER_LEN) {TRACE(("-OI_CODEC_SBC_DecodeFrame: OI_CODEC_SBC_NOT_ENOUGH_HEADER_DATA"));return OI_CODEC_SBC_NOT_ENOUGH_HEADER_DATA;}if (context->mSbcEnabled) {/** There is no parameter embedded in mSBC's header as the parameters are* fixed unlike the general SBC. We only need the packet's crc for mSBC.*/context->common.frameInfo.crc = (*frameData)[3]; // mSBC 仅需 CRC} else {TRACE(("Reading Header"));OI_SBC_ReadHeader(&context->common, *frameData); // 普通 SBC 解析完整头部}/** Some implementations load the decoder into RAM and use overlays for 4 vs 8* subbands. We need* to ensure that the SBC parameters for this frame are compatible with the* restrictions imposed* by the loaded overlays.*/// // 参数校验:子带数量、通道数、PCM 步长等if (context->limitFrameFormat &&(context->common.frameInfo.subbands != context->restrictSubbands)) {ERROR(("SBC parameters incompatible with loaded overlay"));return OI_STATUS_INVALID_PARAMETERS;}if (context->common.frameInfo.nrof_channels > context->common.maxChannels) {ERROR(("SBC parameters incompatible with number of channels specified during ""reset"));return OI_STATUS_INVALID_PARAMETERS;}if (context->common.pcmStride < 1 || context->common.pcmStride > 2) {ERROR(("PCM stride not set correctly during reset"));return OI_STATUS_INVALID_PARAMETERS;}/** At this point a header has been read. However, it's possible that we found* a false syncword,* so the header data might be invalid. Make sure we have enough bytes to read* in the* CRC-protected header, but don't require we have the whole frame. That way,* if it turns out* that we're acting on bogus header data, we don't stall the decoding process* by waiting for* data that we don't actually need.*/framelen = OI_CODEC_SBC_CalculateFramelen(&context->common.frameInfo);if (*frameBytes < framelen) {TRACE(("-OI_CODEC_SBC_DecodeFrame: OI_CODEC_SBC_NOT_ENOUGH_BODY_DATA"));return OI_CODEC_SBC_NOT_ENOUGH_BODY_DATA; // 数据不足}TRACE(("Calculating checksum"));// 3. 帧长度计算与数据完整性校验crc = OI_SBC_CalculateChecksum(&context->common.frameInfo, *frameData);if (crc != context->common.frameInfo.crc) {TRACE(("CRC Mismatch:  calc=%02x read=%02x\n", crc,context->common.frameInfo.crc));TRACE(("-OI_CODEC_SBC_DecodeFrame: OI_CODEC_SBC_CHECKSUM_MISMATCH"));return OI_CODEC_SBC_CHECKSUM_MISMATCH; // CRC 校验失败}// 4. 比特池合法性检查/** Make sure the bitpool values are sane.*/if ((context->common.frameInfo.bitpool < SBC_MIN_BITPOOL) &&!context->common.frameInfo.enhanced) {ERROR(("Bitpool too small: %d (must be >= 2)",context->common.frameInfo.bitpool));return OI_STATUS_INVALID_PARAMETERS; }if (context->common.frameInfo.bitpool >OI_SBC_MaxBitpool(&context->common.frameInfo)) {ERROR(("Bitpool too large: %d (must be <= %ld)",context->common.frameInfo.bitpool,OI_SBC_MaxBitpool(&context->common.frameInfo)));return OI_STATUS_INVALID_PARAMETERS;}// 5. 音频数据解码(核心逻辑)/** Now decode the SBC data. Partial decode is not yet implemented for an SBC* stream, so pass FALSE to decode body to have it enforce the old rule that* you have to decode a whole packet at a time.*/status = DecodeBody(context, *frameData + SBC_HEADER_LEN, pcmData, pcmBytes,FALSE);if (OI_SUCCESS(status)) {*frameData += framelen; // 移动数据指针到下一帧*frameBytes -= framelen; // 更新剩余数据大小}TRACE(("-OI_CODEC_SBC_DecodeFrame: %d", status));// 6. mSBC 特殊处理/* mSBC is designed with 8 bits of zeros at the end for padding. */if (context->mSbcEnabled) {*frameBytes -= 1;}return status;
}

OI_CODEC_SBC_DecodeFrame 是 SBC 音频解码的核心函数,负责对单个 SBC 音频帧进行解码,将编码后的音频数据转换为 PCM 格式。其核心流程包括 同步字查找头部解析参数校验CRC 校验 和 音频数据解码,是 A2DP Sink 端音频解码的关键环节。兼顾了普通 SBC 和 mSBC(Modified SBC,改进型SBC)两种模式,通过状态机和上下文管理实现高效的帧级解码。理解此函数有助于分析音频解码中的常见问题(如杂音、解码失败),并为编解码器优化(如提升解码速度、降低功耗)提供切入点。

继续回到a2dp_sbc_decoder_decode_packet分析回调处理。

btif_a2dp_sink_on_decode_complete 

packages/modules/Bluetooth/system/btif/src/btif_a2dp_sink.cc
static void btif_a2dp_sink_on_decode_complete(uint8_t* data, uint32_t len) {
#ifdef __ANDROID__BtifAvrcpAudioTrackWriteData(btif_a2dp_sink_cb.audio_track,reinterpret_cast<void*>(data), len);
#endif
}

btif_a2dp_sink_on_decode_complete 作为一个回调函数,用于在音频数据解码完成后进行后续的处理操作。在 Android 平台下,调用BtifAvrcpAudioTrackWriteData函数,将解码后的音频数据写入到音频通路。

BtifAvrcpAudioTrackWriteData

packages/modules/Bluetooth/system/btif/src/btif_avrcp_audio_track.cc
int BtifAvrcpAudioTrackWriteData(void* handle, void* audioBuffer,int bufferLength) {// 1. 参数校验与初始化BtifAvrcpAudioTrack* trackHolder = static_cast<BtifAvrcpAudioTrack*>(handle);CHECK(trackHolder != NULL);CHECK(trackHolder->stream != NULL); // 确保音频流句柄有效aaudio_result_t retval = -1;// 2. 调试数据 Dump(可选)
#if (DUMP_PCM_DATA == TRUE)if (outputPcmSampleFile) { // 将接收到的音频数据直接写入文件,用于调试阶段分析原始音频数据fwrite((audioBuffer), 1, (size_t)bufferLength, outputPcmSampleFile);}
#endif// 3. 样本大小计算// 根据音频格式(如 16 位 PCM、浮点型)返回单个样本的字节大小。例如:// 16 位 PCM 立体声:每个样本 2 字节 × 2 通道 = 4 字节 / 帧。// 32 位浮点立体声:每个样本 4 字节 × 2 通道 = 8 字节 / 帧。size_t sampleSize = sampleSizeFor(trackHolder);// 4. 数据转码与分段写入int transcodedCount = 0;do {// 转码:将输入数据(如 SBC 解码后的 PCM)转为 AAudio 所需的浮点格式transcodedCount += transcodeToPcmFloat(((uint8_t*)audioBuffer) + transcodedCount,  // 输入数据指针(按转码进度递增)bufferLength - transcodedCount,             // 剩余待转码数据长度trackHolder                                 // 轨道句柄(含编码格式、通道数等信息));// 写入 AAudio 流:参数为流句柄、目标缓冲区、样本数量、超时时间retval = AAudioStream_write(trackHolder->stream,          // AAudio 流句柄trackHolder->buffer,          // 转码后的浮点 PCM 缓冲区transcodedCount / (sampleSize * trackHolder->channelCount),  // 样本数量(总字节数 / 单样本字节数)kTimeoutNanos                // 写入超时时间(纳秒级));log::verbose("Track.cpp: btWriteData len = {} ret = {}", bufferLength,retval);} while (transcodedCount < bufferLength);return transcodedCount;
}

BtifAvrcpAudioTrackWriteData 是 AVRCP 音频轨道的数据写入函数,负责将接收到的音频数据转换为可播放的 PCM 格式,并通过 AAudio 框架写入音频流,最终输出到音频设备。其核心逻辑包括 数据转码AAudio 流写入 和 调试数据 Dump

AAudio  |  Android NDK  |  Android Developers

 流程图

a2dp sink起播和播放的流程图

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

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

相关文章

抗量子算法验证工具

抗量子算法计算工具 抗量子算法验证工具ML-KEMML-DSASLH-DSA 抗量子算法验证工具 2024年末&#xff0c;美国NIST陆续公布了FIPS-203、FIPS-204、FIPS-205算法标准文档&#xff0c;抽空学习了一下&#xff0c;做了个算法计算工具。 ML-KEM ML-DSA SLH-DSA 需要的朋友可留言交流…

2025年PMP考试有哪些变化?难点在哪里?

PMP&#xff08;项目管理专业人士资格认证&#xff09;考试因其广泛的行业认可度和实用性&#xff0c;成为许多专业人士提升职业竞争力的重要选择。然而&#xff0c;对于初次接触PMP考试的考生来说&#xff0c;其广度与深度的平衡、理论与实践的结合&#xff0c;以及跨文化思维…

Docker学习笔记-docker安装、删除

一、在centOS 7中docker的默认安装目录 # Docker 主配置文件目录 ls /etc/docker# Docker 数据目录&#xff08;镜像、容器、卷等&#xff09; ls /var/lib/docker# Docker 可执行文件路径 which docker # 输出类似 /usr/bin/docker 二、docker文件目录说明 目录/文件用途/…

MATLAB求和∑怎么用?

MATLAB求和∑怎么用&#xff1f; 一&#xff1a;题目&#xff1a;求下列方程的和 二、代码如下 1.syms函数 &#xff08;方法一) 代码如下&#xff08;示例&#xff09;&#xff1a; 1. syms x 2. symsum((x.^22*x).^3,1,100) 3. 2.直接用循环 (方法二) 代码如下&am…

每日算法-链表(2.两数相加、24.两两交换链表中的节点、143.重排链表)

一.两数相加 1.1题目描述 1.2题解思路 定义两个指针l1,l2依次遍历两个链表&#xff0c;用变量add存储l1加l2的值&#xff0c;将add的个位数取出来充当新节点的值&#xff0c;然后将add的个位数删去&#xff0c;即add /10&#xff0c;循环此操作。 重点分析&#xff1a; 1.跟…

Flutter学习 滚动组件(1):ListView基本使用

目录 一、ListView构造方法1.1 常规方法1.2 ListView.builder1.3 ListView.separated 二、自定义ListView样式和布局&#xff1a;三、ListView性能优化&#xff1a;总结&#xff1a; 一、ListView构造方法 主要以下几种方法&#xff1a; 常规方法&#xff0c;直接使用默认的构…

ESLint常见错误

1、Strings must use singlequote —— 字符串必须使用单引号 2、Extra semicolon semi——额外的分号&#xff1a;一行语句结尾不能添加分号 3、Unexpected trailing comma —— 行尾多了一个逗号 4、Newline required at end of file but not found ——文件结尾必须要新加…

Windows进行磁盘分区/扩容

Windows进行磁盘分区/扩容 导航 文章目录 Windows进行磁盘分区/扩容导航分区教程压缩卷教程 用Windows自带的磁盘管理进行分区/扩容&#xff0c;但有个东西需要说明下是&#xff1a; 物理特性限制 磁盘分区的物理特性决定了扩容操作的方向。在磁盘上&#xff0c;数据是线性存储…

获取类路径

分析 String pathThread.currentThread().getContextClassLoader().getResource("log").getPath(); 这行代码用于获取类路径(classpath)下名为"log"的资源的文件系统路径&#xff0c;我来详细解析它的执行过程和潜在问题&#xff1a; 1. 代码分解解析 j…

安装fvm可以让电脑同时管理多个版本的flutter、flutter常用命令、vscode连接模拟器

打开 PowerShellfvm安装 dart pub global activate fvm安装完成后&#xff0c;如果显示FVM无法识别&#xff0c;那么需要去添加环境变量path添加这个&#xff1a;C:\Users\Administrator\AppData\Local\Pub\Cache\bin 常用命令 fvm releases 查看用户可以装的flutter版本fvm l…

Kaggle-Disaster Tweets-(二分类+NLP+模型融合)

Disaster Tweets 题意&#xff1a; 就是给出一个dataframe包含text这一列代表着文本&#xff0c;文本会有一些词&#xff0c;问对于每条记录中的text是真关于灾难的还是假关于灾难的。 比如我们说今天作业真多&#xff0c;这真是一场灾难。实际上这个灾难只是我们调侃而言的。…

Flutter 2025 Roadmap

2025 这个路线图是有抱负的。它主要代表了我们这些在谷歌工作的人收集的内容。到目前为止&#xff0c;非Google贡献者的数量超过了谷歌雇佣的贡献者&#xff0c;所以这并不是一个详尽的列表&#xff0c;列出了我们希望今年Flutter能够出现的所有令人兴奋的新事物&#xff01;在…

如何通过API接口获取淘宝商品价格?实操讲解

要通过API接口获取淘宝商品价格&#xff0c;需使用淘宝开放平台&#xff08;Taobao Open Platform, TOP&#xff09;提供的商品详情API&#xff08;如taobao.item.get或taobao.item_get&#xff09;。以下是完整的实操步骤&#xff1a; 一、前期准备 注册淘宝开放平台账号 访问…

按键精灵安卓/ios脚本辅助工具开发教程:如何把界面配置保存到服务器

在使用按键精灵工具辅助的时候&#xff0c;多配置的情况下&#xff0c;如果保存现有的配置&#xff0c;并且读取&#xff0c;尤其是游戏中多种任务并行情况下&#xff0c;更是需要界面进行保存&#xff0c;简单分享来自紫猫插件的配置保存服务器写法。 界面例子&#xff1a; …

DP34 【模板】前缀和 -- 前缀和

目录 一&#xff1a;题目 二&#xff1a;算法原理 三&#xff1a;代码实现 一&#xff1a;题目 题目链接&#xff1a;【模板】前缀和_牛客题霸_牛客网 二&#xff1a;算法原理 三&#xff1a;代码实现 #include <iostream> #include <vector> using namespac…

关于我的服务器

最近我买了台腾讯云服务器&#xff0c;然后新手小白只会用宝塔。。。 安装完之后默认的端口是8888&#xff0c;打开面板就会提示我有风险。然后 我改了端口之后&#xff0c;怎么都打不开。 于是 学到了几句命令可以使用&#xff1a; //查看端口是否已经修改成功 cat www/se…

机器学习常用算法总结

1. 概述 机器学习的定义是对于某类任务T和性能度量P&#xff0c;如果一个计算机程序在T上其性能P随着经验E而自我完善&#xff0c;那么我们就称这个系统从经验E中学习&#xff0c;机器学习是人工智能的一种方法&#xff0c;它通过在大量数据中学习隐藏的规则&#xff0c;模式和…

ns-3中UDP饱和流发包时间间隔设置最合理值

ns3的官方手册很全&#xff0c;相关书籍也是有的&#xff0c;官网先贴在这里&#xff1a; ns-3 | a discrete-event network simulator for internet systemsa discrete-event network simulator for internet systemshttps://www.nsnam.org/相关的脚本介绍也都有一些&#xf…

Windsurf代码依赖检查导入

目录 1. 在全局配置中根据需求设置检查的文件&#xff0c;以python为例 2. 执行命令生成requirements.txt文件&#xff0c;此操作可以将当前代码所需的依赖全部写入 3. 在Cascade对话窗口输入detect-dependencies查询 4. 根据查询出来的结果优化requirements.txt&#xff0c;可…

复变函数摘记3

复变函数摘记3 5. 留数5.1 可去奇点、极点、本性奇点5.2 零点与极点的关系5.3 在无穷远点处的情形5.4 留数 5. 留数 \quad 如果函数 f ( z ) f(z) f(z) 在 z 0 z_0 z0​ 及 z 0 z_0 z0​ 的邻域内处处可导&#xff0c;那么称 f ( z ) f(z) f(z) 在点 z 0 z_0 z0​ 处解析。…