c++ - Gstreamer 动态更改源元素
问题描述
我有一个从 rtspsrc 元素中提取视频的 GStreamer 管道。rtspsrc 元素连接到 rtpjpegdepay 元素。我希望能够即时更改 RTSP URL。到目前为止,我一直在做的是:
1) 解除 rtspsrc 与 depay 元素的链接
2) 使用新的 RTSP URL 创建新的源元素
3)并链接到depay元素。
我遇到的问题是新的 RTSP 源元素没有正确链接到 depay 元素,导致段错误。我需要一些帮助来弄清楚如何动态更改 rtspsrc URL(当管道仍在播放时)。
管道创建:
GstBus *bus;
guint busWatchId;
GstElement *src, *depay, *parser, *decoder, *vpe, *filter, *sink;
GstCaps *vpeCaps;
m_loop = g_main_loop_new(NULL, FALSE);
//create pipeline elements
m_cameraStream = gst_pipeline_new("display_pipeline");
src = gst_element_factory_make("rtspsrc", "rtspsrc");
depay = gst_element_factory_make("rtpjpegdepay", "depay");
parser = gst_element_factory_make("jpegparse", NULL);
decoder = gst_element_factory_make("ducatijpegdec", NULL);
vpe = gst_element_factory_make("vpe", NULL);
filter = gst_element_factory_make("capsfilter", NULL);
sink = gst_element_factory_make("waylandsink", NULL);
if(!(m_cameraStream || src || depay || parser || decoder || vpe || filter || sink)){
qFatal("could not create pipeline elements");
exit(1);
}
g_object_set(G_OBJECT(src), "location", "rtsp://192.168.50.29/av0_1", "latency", 0, NULL);
g_signal_connect(src, "pad-added", G_CALLBACK(on_rtsp_pad_added), depay);
//add src caps?
vpeCaps = gst_caps_from_string("video/x-raw, format=NV12, width=800, height=480"); //change this when Tomas' patch hits
if(!vpeCaps){
qFatal("cannot create caps");
exit(1);
}
g_object_set(G_OBJECT(filter), "caps", vpeCaps, NULL);
g_object_set(G_OBJECT(sink), "sync", false, NULL);
//add and link elements to create full pipeline
gst_bin_add_many(GST_BIN(m_cameraStream), src, depay, parser, decoder, vpe, sink, NULL);
if(!gst_element_link_many(depay, parser, decoder, vpe, sink, NULL)){
qFatal("cannot link elements");
exit(1);
}
gst_caps_unref(vpeCaps);
bus = gst_pipeline_get_bus(GST_PIPELINE(m_cameraStream));
busWatchId = gst_bus_add_watch(bus, GstBusFunc(bus_call), m_loop);
gst_object_unref(bus);
rtsp->depay 链接回调函数:
gchar *name;
GstElement *depay;
GstCaps *caps;
qDebug("on_rtsp_pad_added");
caps = gst_caps_from_string("application/x-rtp");
name = gst_pad_get_name(pad);
qDebug("on_rtsp_pad_added, rtspsrc pad name: %s", name);
depay = GST_ELEMENT(data);
if(!gst_element_link_pads_filtered(element, name, depay, "sink", caps)){
qFatal("pad_added: failed to link elements");
}
g_free(name);
gst_element_set_state(m_cameraStream, GST_STATE_PLAYING);
g_main_loop_run(m_loop);
换源功能:
qDebug("slot_changeSource");
//gst_element_set_state(m_cameraStream, GST_STATE_PAUSED); //GST_STATE_NULL: segfault in pad_added
//GST_STATE_PAUSED: pauses, never returns to playing or on_rtsp_pad_added
//GST_STATE_PLAYING(left playing): same as NULL
GstElement* rtspsrc = gst_bin_get_by_name(GST_BIN(m_cameraStream), "rtspsrc");
if(rtspsrc){
qDebug("rtspsrc found");
GstElement* depay = gst_bin_get_by_name(GST_BIN(m_cameraStream), "depay");
if(depay){
qDebug("depay found");
gst_element_unlink(rtspsrc, depay);
gst_bin_remove(GST_BIN(m_cameraStream), rtspsrc);
GstElement* newSource = gst_element_factory_make("rtspsrc", "rtspsrc");
g_object_set(G_OBJECT(newSource), "location", "rtsp://192.168.50.29/av0_1", "latency", 0, NULL);
g_signal_connect(newSource, "pad-added", G_CALLBACK(on_rtsp_pad_added), depay); //needed in the same way as the previous rtspsrc
gst_bin_add(GST_BIN(m_cameraStream), newSource);
gst_element_sync_state_with_parent(newSource);
//gst_element_set_state(m_cameraStream, GST_STATE_PLAYING);
}
gst_element_set_state(rtspsrc, GST_STATE_NULL);
gst_object_unref(rtspsrc);
}
我尝试过的其他事情:
1)探测rtsp元素的src pad,确保元素中没有任何数据。这似乎是个坏主意,因为此时 rtsp 元素将是新创建的。
2) 将管道设置为 PAUSED 或 NULL,然后更改源元素。这会导致管道永远暂停。
参考:
解决方案
好的,所以我相信我已经找到了答案,我将在此处发布此内容,以节省任何偶然发现此问题的人。
答案是创建一对焊盘探针来处理从管道中清除数据。我通过创建两个填充探测回调来做到这一点:一个用于捕获管道以开始刷新过程,另一个用于在刷新管道后处理 rtspsrc 元素的重新创建。第一个焊盘探针可以放在任何地方,所以我把它放在我的 depay 元件上。第二个焊盘探针必须位于最后一个数据处理元件的源头上。所以不是最终的水槽元素。对于上面的管道,这是“vpe”元素。
我通过将流结束 (EOS) 信号传递给 depay 元素来做到这一点,然后在 vpe 元素的 src 焊盘处进行焊盘探测回调,以在 EOS 退出 VPE 时捕获它。如果 EOS 到达 waylandsink,管道将简单地关闭,您将不得不重新启动整个过程。
vpe = gst_bin_get_by_name(GST_BIN(data), "vpe");
srcPad = gst_element_get_static_pad(vpe, "src");
gst_pad_add_probe(srcPad, GST_PAD_PROBE_TYPE_BLOCK_DOWNSTREAM, event_probe, data, NULL);
//push EOS into the element, wait for the EOS to appear on the srcpad
depay = gst_bin_get_by_name(GST_BIN(data), "depay");
sinkPad = gst_element_get_static_pad(depay, "sink");
gst_pad_send_event(sinkPad, gst_event_new_eos());
return GST_PAD_PROBE_OK;
以及处理该 EOS 的回调:
static GstPadProbeReturn event_probe(GstPad *pad, GstPadProbeInfo *info, gpointer data){
GstElement *rtspsrcOld, *rtspsrcNew, *depay;
qDebug("event_probe");
if(GST_EVENT_TYPE(GST_PAD_PROBE_INFO_DATA(info)) != GST_EVENT_EOS){
return GST_PAD_PROBE_PASS;
}
gst_pad_remove_probe(pad, GST_PAD_PROBE_INFO_ID(info));
rtspsrcOld = gst_bin_get_by_name(GST_BIN(data), "rtspsrc");
if(rtspsrcOld){
qDebug("found rtspsrcOld");
depay = gst_bin_get_by_name(GST_BIN(data), "depay");
gst_element_unlink(rtspsrcOld, depay);
gst_bin_remove(GST_BIN(data), rtspsrcOld); //remove old rtspsrc from pipeline, should unlink from depay automatically.
rtspsrcNew = gst_element_factory_make("rtspsrc", "rtspsrc");
g_object_set(rtspsrcNew, "location", NEW_URI, "latency", 0, NULL);
g_signal_connect(G_OBJECT(rtspsrcNew), "pad-added", G_CALLBACK(on_rtsp_pad_added), data);
gst_bin_add(GST_BIN(data), rtspsrcNew);
gst_element_set_state(GST_ELEMENT(data), GST_STATE_PLAYING);
return GST_PAD_PROBE_DROP;
}
return GST_PAD_PROBE_DROP;
}
推荐阅读
- mysql - 访问两个表的数据 SQL
- java - 如何将我的字符串日期转换为 Cloud Firestore 的时间戳
- javascript - 移动设备上 PrimeNG Carousel 宽度上的越野车
- c# - C# WebClient 下载字符串时不会超时
- flutter - 颤动中的气泡按钮
- user-interface - Tkinter - 要求按顺序标记复选框
- solr - 将日期存储为字符串的 Solr 相关数据搜索
- python - tkinter python中的弹出滑块
- scikit-learn - 关于 scikit-Learn 中 fetch_openml 的问题
- sql - 如何使用窗口优化复杂的 SQL 任务?