GStreamer 似乎没有调用我的回调

Question

我有一个 Qt 应用程序，它在单独的线程中执行与 GStreamer 相关的工作。虽然我认为我遵循了设置信号回调的规则，但我指定的回调函数似乎没有被调用。

回调函数如下，它试图做的只是将一些内容记录到控制台以进行调试：

static gboolean Cb(GstBus *bus, GstMessage *msg, gpointer data)
{
    std::cout << "g_sig, bus = " << (void*)bus
              << ", msg = "      << (void*)msg
              << ", data = "     << (void*)data
              << std::endl;
    return TRUE;
}

我用来启动和监控流（来自 IP 摄像机的实时 RTSP/H.264 馈送）的顺序是：

GstElement *playBin = gst_parse_launch("<gstreamer pipeline>");
GstBus *bus = gst_pipeline_get_bus(GST_PIPELINE(playBin));
gst_bus_add_signal_watch(bus);
g_signal_connect(bus, "message::state-changed", (GCallback)Cb, NULL);
gst_element_set_state(playBin, GST_STATE_PLAYING);

GMainLoop *mainLoop = g_main_loop_new(NULL, FALSE);
g_main_loop_run(mainLoop);

现在流 正在 实际播放（视频出现）所以我假设那里没有问题。但是，我希望在管道开始播放时发布状态更改消息。这似乎没有发生，因为我没有看到来自 Cb() 的输出。

即使我也捕获了message::eos、message::error 和message::element 信号，我也没有得到任何输出。

我不确定这是否会成为问题，但为了以防万一，上面的代码稍微简化了一些。实际上有 两个 流正在播放，所以上面代码的第一个 sn-p 发生了两次，每个 playbin 一次（每个 playbin 的序列都是准确的，我只是看到没有必要使代码复杂化）。

然后主循环被创建并运行。

如上所述，我没有看到回调函数的输出，那么我的消息去哪里了？

附录：对于它的价值，我还尝试了gst_bus_add_watch 方法来捕获所有消息而不是特定信号，但仍然没有任何显示。我还应该提到，作为一个 Qt 应用程序，我在代码中没有 gtk_init - 我只是从主线程调用 gst_init。

Answer 1

我对gstreamer的了解有限，很久以前就搞砸了。

我做了一个小测试，这似乎有效：

#include <stdio.h>
#include <gstreamer-1.0/gst/gst.h>

static gboolean Cb(GstBus *bus, GstMessage *msg, gpointer data)
{
        printf("g_sig, bus = %x, msg = %s, data = %x\n",
          bus,
          gst_message_type_get_name(GST_MESSAGE_TYPE(msg)),
          data);

        return TRUE;
}

int main(int argc, char *argv[]) {
        GstElement *pipeline;
        GstBus *bus;
        GstMessage *msg;

        /* Initialize GStreamer */
        gst_init (&argc, &argv);

        /* Build the pipeline */
        pipeline = gst_parse_launch ("playbin uri=https://www.freedesktop.org/software/gstreamer-sdk/data/media/sintel_trailer-480p.webm", NULL);

        /* Wait until error or EOS */
        bus = gst_element_get_bus (pipeline);

        /* use the sync signal handler to link elements while the pipeline is still
         * doing the state change */
        gst_bus_set_sync_handler (bus, gst_bus_sync_signal_handler, pipeline, NULL);
        g_object_connect (bus, "signal::sync-message::state-changed", G_CALLBACK (Cb), pipeline, NULL);

        /* Start playing */
        gst_element_set_state (pipeline, GST_STATE_PLAYING);

        msg = gst_bus_timed_pop_filtered (bus, GST_CLOCK_TIME_NONE, GST_MESSAGE_ERROR | GST_MESSAGE_EOS);

        /* Free resources */
        if (msg != NULL)
                gst_message_unref (msg);

        gst_object_unref (bus);
        gst_element_set_state (pipeline, GST_STATE_NULL);
        gst_object_unref (pipeline);

        return 0;
}

但是虽然message::state-changed:

一条消息已发布在公共汽车上。这个信号是从一个发出的 GSource 添加到主循环。这个信号只会在 有一个主循环正在运行。

signal::sync-message::state-changed 改为：

一条消息已发布在公共汽车上。这个信号是从发出的 发布消息的线程，因此必须小心锁定。

所以同步消息也在主循环之外发出。

两个信号的docs。