gst_pad_add_probe使用笔记

gst_pad_add_probe  是 GStreamer 中的一个函数，用于在 pad 上添加探针（probe）函数，以便监控或者修改流经该 pad 的数据。通过探针，可以在数据流的不同阶段执行自定义操作，如修改、丢弃或分析数据。

函数原型

gulong gst_pad_add_probe (GstPad *pad, GstPadProbeType mask, GstPadProbeCallback callback, gpointer user_data, GDestroyNotify destroy_data);

参数说明

• pad : 要添加探针的  GstPad  对象。
• mask : 探针类型，决定探针何时触发，常见的类型包括：

* GST_PAD_PROBE_TYPE_BUFFER: 当 buffer 通过 pad 时触发。
* GST_PAD_PROBE_TYPE_EVENT_DOWNSTREAM: 当下游事件通过 pad 时触发。
* GST_PAD_PROBE_TYPE_EVENT_UPSTREAM: 当上游事件通过 pad 时触发。
* GST_PAD_PROBE_TYPE_QUERY_DOWNSTREAM: 当下游查询通过 pad 时触发。
* GST_PAD_PROBE_TYPE_QUERY_UPSTREAM: 当上游查询通过 pad 时触发。

• callback : 探针回调函数，触发时调用，函数原型为：

GstPadProbeReturn (*GstPadProbeCallback) (GstPad *pad, GstPadProbeInfo *info, gpointer user_data);

• user_data : 传递给回调函数的用户数据。
• destroy_data : 用于释放  user_data  的销毁通知函数。

返回值

返回一个gulong类型的探针 ID，可用于后续移除探针。
回调函数返回GstPadProbeReturn类型，常见返回值包括：

* GST_PAD_PROBE_OK: 继续正常流程。
* GST_PAD_PROBE_DROP: 丢弃当前 buffer 或事件。
* GST_PAD_PROBE_REMOVE: 移除探针。

示例

在 pad 上添加一个探针，打印每个通过的 buffer 的 PTS：

static GstPadProbeReturn buffer_probe_cb(GstPad *pad, GstPadProbeInfo *info, gpointer user_data) 
{GstBuffer *buffer = GST_PAD_PROBE_INFO_BUFFER (info);if (buffer) {GstClockTime pts = GST_BUFFER_PTS (buffer);g_print ("Buffer PTS: %" GST_TIME_FORMAT "\n", GST_TIME_ARGS (pts));}return GST_PAD_PROBE_OK;
}// 添加探针
gulong probe_id = gst_pad_add_probe (pad, GST_PAD_PROBE_TYPE_BUFFER, buffer_probe_cb, NULL, NULL);