当前位置: 首页 > news >正文

Gstreamer之”pad-added“事件

"pad-added" 事件详解

"pad-added" 是 GStreamer 中一个非常重要的信号,当元素动态创建一个新的 pad(连接点)时会发出此信号。

基本概念:

  • Pad:GStreamer 中元素之间的连接点,数据通过 pad 流动

  • 动态 Pad:某些元素(如 rtspsrc、decodebin)在运行时才会创建 pad,而不是在初始化时就存在

  • 典型应用场景:RTSP 源、解码器等元素经常使用动态 pad

为什么需要处理 "pad-added":

  1. 对于像 rtspsrc 这样的源元素,你无法预先知道它会提供多少个流(视频、音频等)

  2. 对于像 decodebin 这样的解码元素,你无法预先知道输入媒体的类型

  3. 必须在 pad 可用时才能建立元素间的连接

典型回调函数签名:

void callback(GstElement *src, GstPad *new_pad, gpointer user_data);

rtspsrc 的常见信号

除了 "pad-added",rtspsrc 还提供以下重要信号:

1. 连接相关信号

  • "error":发生错误时触发

    void callback(GstElement *src, guint error_code, gchar *error_msg, gpointer user_data);
  • "warning":发生警告时触发

    void callback(GstElement *src, guint warning_code, gchar *warning_msg, gpointer user_data);
  • "state-changed":元素状态改变时触发

    void callback(GstElement *src, GstState old_state, GstState new_state, GstState pending_state, gpointer user_data);

2. 流管理信号

  • "new-stream":检测到新流时触发

    void callback(GstElement *src, GstPad *pad, gpointer user_data);
  • "select-stream":允许应用程序选择特定流

    gboolean callback(GstElement *src, guint stream_id, GstCaps *caps, gpointer user_data);
  • "pad-removed":当 pad 被移除时触发

    void callback(GstElement *src, GstPad *pad, gpointer user_data);

3. 媒体处理信号

  • "eos":流结束时触发(End Of Stream)

    void callback(GstElement *src, gpointer user_data);
  • "enough-streams":当收集到足够多流时触发

    void callback(GstElement *src, gpointer user_data);

其他常用 GStreamer 元素的信号

decodebin 信号

  • "pad-added":当解码器创建新 pad 时

  • "autoplug-continue":决定是否继续自动插件

  • "autoplug-select":选择自动插件类型

  • "drained":元素已排空

appsrc 信号

  • "need-data":需要新数据时触发

  • "enough-data":有足够数据时触发

  • "seek-data":请求定位时触发

videosink 信号

  • "preroll-handoff":第一帧显示前触发

  • "handoff":每帧显示时触发

完整示例:处理多个 rtspsrc 信号

#include <gst/gst.h>// pad-added 回调
static void on_pad_added(GstElement *src, GstPad *new_pad, gpointer data) {GstElement *pipeline = (GstElement *)data;GstElement *queue = gst_bin_get_by_name(GST_BIN(pipeline), "queue");GstPad *sink_pad = gst_element_get_static_pad(queue, "sink");if (gst_pad_is_linked(sink_pad)) {gst_object_unref(sink_pad);return;}GstPadLinkReturn ret = gst_pad_link(new_pad, sink_pad);if (GST_PAD_LINK_FAILED(ret)) {g_printerr("Pad link failed.\n");}gst_object_unref(sink_pad);
}// 错误处理回调
static void on_error(GstElement *src, guint error_code, gchar *error_msg, gpointer user_data) {g_printerr("RTSP Error %d: %s\n", error_code, error_msg);// 可以在这里实现重连逻辑
}// 新流回调
static void on_new_stream(GstElement *src, GstPad *pad, gpointer user_data) {g_print("New stream detected on pad %s\n", GST_PAD_NAME(pad));
}// EOS回调
static void on_eos(GstElement *src, gpointer user_data) {g_print("End of stream reached\n");// 可以在这里实现流重启逻辑
}int main(int argc, char *argv[]) {gst_init(&argc, &argv);GstElement *pipeline = gst_pipeline_new("rtsp-pipeline");GstElement *rtspsrc = gst_element_factory_make("rtspsrc", "source");GstElement *queue = gst_element_factory_make("queue", "queue");// ... 其他元素创建// 设置RTSP URLg_object_set(rtspsrc, "location", "rtsp://example.com/stream", NULL);// 添加元素到管道gst_bin_add_many(GST_BIN(pipeline), rtspsrc, queue, /* 其他元素 */, NULL);// 连接信号g_signal_connect(rtspsrc, "pad-added", G_CALLBACK(on_pad_added), pipeline);g_signal_connect(rtspsrc, "error", G_CALLBACK(on_error), NULL);g_signal_connect(rtspsrc, "new-stream", G_CALLBACK(on_new_stream), NULL);g_signal_connect(rtspsrc, "eos", G_CALLBACK(on_eos), NULL);// 启动管道并运行主循环...return 0;
}

信号处理的最佳实践

  1. 保持回调简洁:不要在回调中执行耗时操作

  2. 线程安全:GStreamer 信号可能来自不同的线程

  3. 错误处理:始终处理错误信号

  4. 资源管理:正确管理 pad 和元素的引用计数

  5. 状态检查:在回调中检查管道/元素状态

理解这些信号及其用途对于构建健壮的 GStreamer 应用程序至关重要,特别是在处理网络流媒体时。

http://www.lryc.cn/news/588407.html

相关文章:

  • 并发编程核心概念详解:进程、线程与协程的本质与差异
  • 融合竞争学习与高斯扰动的多目标加权平均算法(MOWAA)求解多无人机协同路径规划(多起点多终点,起始点、无人机数、障碍物可自定义),提供完整MATLAB代码
  • 【抖音滑动验证码风控分析】
  • 【人工智能99问】什么是深度学习?(2/99)
  • RK3568/3588 Android 12 源码默认使用蓝牙mic录音
  • 显示器核心三要素详解:刷新率、分辨率、色深
  • PHP password_get_info() 函数
  • 渗透笔记1-4
  • Java 树形结构、层级结构数据构建
  • 【LeetCode 热题 100】94. 二叉树的中序遍历——DFS
  • 第四章 uniapp实现兼容多端的树状族谱关系图,剩余组件
  • 用基础模型构建应用(第九章)AI Engineering: Building Applications with Foundation Models学习笔记
  • GaussDB in的用法
  • Elasticsearch 9.x 升级变化
  • C++后端面试八股文
  • 【postgresql数据库实现表的树结构查询】
  • 乳化硅油市场报告:深度解析与未来趋势
  • 信息收集的基本流程
  • 非阻塞写入核心:asyncio.StreamWriter 的流量控制与数据推送之道
  • 电流驱动和电压驱动的区别
  • UV vs Pip:Python 包管理的革命性进化
  • redis实现红锁
  • 迅为八核高算力RK3576开发板摄像头实时推理测试 ppyoloe目标检测
  • Java 大视界 -- 基于 Java 的大数据可视化在城市地下管网管理与风险预警中的应用
  • ThreadLocal结构
  • 在Maven多模块项目中进行跨模块的SpringBoot单元测试
  • 考研408《计算机组成原理》复习笔记,第三章(4)——主存与CPU连接(字、位扩展)
  • 研究人员利用提示注入漏洞绕过Meta的Llama防火墙防护
  • 开源软著源代码生成工具(自制)
  • Java行为型模式---模板方法模式