GStreamer 1.8.3中appsrc预滚阻塞致EOS无法传递问题求助

针对你遇到的GStreamer 1.8.3管道中，发送EOS后线程卡在预滚等待、总线无法收到EOS的问题，我们可以从预滚机制和事件传递两个方向入手解决，具体方案如下：

原因分析 #

你的管道使用了appsrc is-live=true（实时源）+audiorate skip-to-first=true，当下游sink处于预滚等待状态时，appsrc已经停止写入数据，此时发送的EOS事件因为下游未完成预滚无法传递，导致线程卡在gst_base_sink_wait_preroll。

可行解决方案 #

1. 禁用Sink的异步预滚 #

实时源场景下，sink的async属性默认是true，会等待预滚完成才进入PLAYING状态。我们可以在关闭管道前将该属性设为false，让sink不再等待预滚，直接处理EOS事件：

// 获取filesink元素
GstElement *sink = gst_bin_get_by_name(GST_BIN(pipeline), "filesink");
if (sink) {
    g_object_set(sink, "async", FALSE, NULL);
    g_object_unref(sink);
}
// 再发送EOS到appsrc
gst_element_send_event(appsrc, gst_event_new_eos());

2. 直接向下游Sink发送EOS事件 #

如果appsrc的EOS无法通过卡住的预滚环节，我们可以绕过中间元素，直接给最末端的sink发送EOS，强制它退出预滚等待并处理终止逻辑：

GstElement *sink = gst_bin_get_by_name(GST_BIN(pipeline), "filesink");
if (sink) {
    gst_element_send_event(sink, gst_event_new_eos());
    g_object_unref(sink);
}

3. 先切换管道状态到PAUSED再发送EOS #

在发送EOS前，先将管道从PLAYING切换到PAUSED状态，等待状态变更完成后再发送EOS，这可以打破预滚的阻塞：

// 切换到PAUSED
gst_element_set_state(pipeline, GST_STATE_PAUSED);
// 等待状态变更完成（可选，增加稳定性）
gst_element_get_state(pipeline, NULL, NULL, GST_CLOCK_TIME_NONE);
// 发送EOS
gst_element_send_event(appsrc, gst_event_new_eos());
// 最后切换到NULL状态清理资源
gst_element_set_state(pipeline, GST_STATE_NULL);

4. 监听总线消息并处理预滚超时 #

你可以给总线添加消息监听器，当检测到预滚超时（比如自定义超时时间），主动触发EOS或状态切换：

// 在总线回调中处理
gboolean bus_callback(GstBus *bus, GstMessage *msg, gpointer data) {
    GstElement *pipeline = GST_ELEMENT(data);
    switch (GST_MESSAGE_TYPE(msg)) {
        case GST_MESSAGE_STATE_CHANGED:
            // 可在这里检查sink是否长时间卡在预滚状态，触发超时处理
            break;
        case GST_MESSAGE_ERROR:
            // 处理错误，避免阻塞管道
            gst_element_set_state(pipeline, GST_STATE_NULL);
            break;
        case GST_MESSAGE_EOS:
            // 收到EOS后清理资源
            gst_element_set_state(pipeline, GST_STATE_NULL);
            break;
        default:
            break;
    }
    return TRUE;
}
// 注册总线回调
gst_bus_add_watch(gst_element_get_bus(pipeline), bus_callback, pipeline);

注意事项 #

• 确保所有操作都在GStreamer的线程安全上下文执行，避免多线程竞态问题
• 操作完成后记得调用gst_element_set_state(pipeline, GST_STATE_NULL)释放所有资源

内容的提问来源于stack exchange，提问作者Velkan