Linux Pulseaudio深度解析之pa_stream_begin_write用流程与实战(二十九)

Android系统攻城狮

31人浏览 · 2026-05-30 06:00:00

Android系统攻城狮 · 2026-05-30 06:00:00 发布

简介： CSDN博客专家、《Android系统多媒体进阶实战》作者

博主新书推荐：《Android系统多媒体进阶实战》🚀
Android Audio工程师专栏地址： Audio工程师进阶系列【原创干货持续更新中……】🚀
Android多媒体专栏地址： 多媒体系统工程师系列【原创干货持续更新中……】🚀
专题一二：AAOS车载系统+AOSP14系统攻城狮入门视频实战课 🚀
专题三：Android14 Binder之HIDL与AIDL通信实战课 🚀
专题四：Android15快速自定义与集成音效实战课 🚀
专题五：Android15音频策略实战课 🚀
专题六：Android15音频性能实战课(无声/杂音/断音/爆音实战案例) 🚀

人生格言： 人生从来没有捷径，只有行动才是治疗恐惧和懒惰的唯一良药.

更多原创,欢迎关注：Android系统攻城狮

欢迎关注Android系统攻城狮

🌻1. 前言

本篇目的：Linux PulseAudio 深度解析之 pa_stream_begin_write 调用流程与实战。

要点概括

核心功能：向 PulseAudio 申请一块可直接写入的共享内存缓冲区。
工作机制：libpulse 从 Stream 写缓存中分配可写区域，应用层直接填充 PCM 数据，从而减少一次内存拷贝。

🌻2. 用法与应用场景

pa_stream_begin_write
是 PulseAudio 中非常重要的零拷贝写音频接口。

普通写数据：

pa_stream_write(...)

通常需要：

用户缓冲区
    ↓ memcpy
PulseAudio 缓冲区

而：

pa_stream_begin_write(...)

则允许：

应用层直接写入 PulseAudio 内部缓冲区。

从而减少：

memcpy
CPU 开销
内存带宽消耗

特别适合：

大块 PCM 数据
高吞吐音频
低延迟播放

函数原型

int pa_stream_begin_write(
        pa_stream *p,
        void **data,
        size_t *nbytes);

参数说明

p:
目标 pa_stream

data:
返回可直接写入的缓冲区地址

nbytes:
输入期望写入大小
输出实际可写大小

返回值

0:
成功

<0:
失败

应用场景

1. 大块 PCM 写入

pa_stream_begin_write(...)

适合：

音乐播放器
视频播放器
游戏音频

2. 低延迟音频输出

减少：

用户态 memcpy
Buffer Copy

降低：

CPU 占用
音频延迟

3. 高性能音频引擎

例如：

DAW
实时音频工作站
VoIP
音频服务器

都会大量使用：

begin_write

实现零拷贝写入。

🌻3. 调用流程剖析

🌻3.1 核心步骤

1. 应用层调用

pa_stream_begin_write(
        stream,
        &buf,
        &size);

2. libpulse 检查 Stream 状态

内部检查：

stream 是否 READY
stream 是否可写
SHM 是否可用

3. 从 SHM Buffer 分配写区域

libpulse 内部从：

共享内存 RingBuffer

中申请：

可写区域

4. 返回缓冲区地址

例如：

buf = writable_ptr;

同时：

size = writable_bytes;

5. 应用层直接写 PCM 数据

例如：

memcpy(buf, pcm, size);

6. 提交写入

随后调用：

pa_stream_write(...)

正式提交数据。

🌻3.2 调用流程图

🌻3.3 SHM 零拷贝生命周期图

🌻4. 实战应用案例

#include <pulse/pulseaudio.h>
#include <stdio.h>
#include <string.h>

void write_pcm_zero_copy(
        pa_stream *stream,
        const void *pcm,
        size_t pcm_size) {

    void *buf = NULL;

    size_t writable_size;

    writable_size = pcm_size;

    /*
     * 申请可写 SHM Buffer
     */
    if (pa_stream_begin_write(
                stream,
                &buf,
                &writable_size) < 0) {

        fprintf(stderr,
                "begin_write failed\n");
        return;
    }

    /*
     * 直接写入 PulseAudio Buffer
     */
    memcpy(buf,
           pcm,
           writable_size);

    /*
     * 提交数据
     */
    if (pa_stream_write(
                stream,
                buf,
                writable_size,
                NULL,
                0,
                PA_SEEK_RELATIVE) < 0) {

        fprintf(stderr,
                "stream_write failed\n");
    }

    printf("write pcm size = %zu\n",
           writable_size);
}

int main() {

    pa_stream *stream;

    char pcm_data[4096];

    memset(pcm_data, 0,
           sizeof(pcm_data));

    /*
     * 假设 stream 已 READY
     */

    write_pcm_zero_copy(
            stream,
            pcm_data,
            sizeof(pcm_data));

    return 0;
}

🌻5. 源码层核心原理

pa_stream_begin_write
在 libpulse 中本质是：

“申请 SHM RingBuffer 可写区域”。

内部逻辑类似：

int pa_stream_begin_write(
        pa_stream *p,
        void **data,
        size_t *nbytes) {

    /*
     * 从 shm ringbuffer
     * 分配 writable chunk
     */

    *data = writable_ptr;

    *nbytes = writable_size;

    return 0;
}