1

我正在用 C 语言为 gstreamer 1.0 编写一个自定义插件。
这个插件对帧执行一些处理，并且在满足某些条件时应该向应用程序发送一个事件。它不应该阻塞管道不干扰它，只是一个信号，以便应用程序可以触发与管道无关的操作。

处理运行良好，但......我不知道下一步该做什么。有很多已经存在的消息，例如 EOS 或 seek 但我如何创建自己的消息？该消息应包含自定义数据，因此我必须自己创建一个可以发送的消息。

通过发送事件或信号，我找不到任何关于如何处理来自插件的自定义事件的示例/文档/说明。

我什至没有示例代码开始。

任何见解将不胜感激。

4

2 回答 2

2

看一下fpsdisplaysink元素：

https://github.com/GStreamer/gst-plugins-bad/blob/master/gst/debugutils/fpsdisplaysink.c

这个发出应用程序可以连接的信号。最有趣的可能是信号创建：

g_signal_new ("fps-measurements", G_TYPE_FROM_CLASS (klass),
      G_SIGNAL_RUN_LAST, 0, NULL, NULL, NULL,
      G_TYPE_NONE, 3, G_TYPE_DOUBLE, G_TYPE_DOUBLE, G_TYPE_DOUBLE);

以及所述信号的周期性触发：

g_signal_emit (G_OBJECT (self),
        fpsdisplaysink_signals[SIGNAL_FPS_MEASUREMENTS], 0, rr, dr,
        average_fps);

详细信息应在 GLib 信号文档中找到：

https://developer.gnome.org/gobject/stable/gobject-Signals.html

#

或者，您可以创建自己的GstMessage并将其发布在公共汽车上。请参阅 GstMessage 文档：

https://gstreamer.freedesktop.org/data/doc/gstreamer/head/gstreamer/html/GstMessage.html

GstMessage *gst_message_new_application (GstObject *src,
    GstStructure *structure);

然后，您可以将数据包装在GstStructure. 然后将消息发布到总线上gst_bus_post()。

于 2017-12-13T00:19:26.657 回答
0

感谢 Florian 的洞察力，这对我帮助很大。
我最终使用了 gst_message_new 和 gst_post_bus。

对于那些可能对这里感兴趣的人来说，我在 python 中实现了一个运行循环的代码。

def connect(bus, name):
    def _connect(f):
        bus.connect(name, f)
        return f
    return _connect

....
    bus = self.pipeline.get_bus()
    bus.add_signal_watch()

    ret = self.pipeline.set_state(Gst.State.PLAYING)
    if ret == Gst.StateChangeReturn.FAILURE:
        logger.error("ERROR: Unable to set the pipeline to the playing state")

    loop = GObject.MainLoop()

    print()

    @connect(bus, "message::"+Gst.MessageType.get_name(Gst.MessageType.ERROR))
    def on_error(bus, message):
        err, dbg = message.parse_error()
        print("ERROR:", message.src.get_name().encode('utf-8'), ":", err.message.encode('utf-8'))
        if dbg:
            print("debugging info:", dbg)

        loop.quit()

    @connect(bus, "message::"+Gst.MessageType.get_name(Gst.MessageType.EOS))
    def on_eos(bus, message):
        logger.info("End-Of-Stream reached")
        loop.quit()

    .... other events

    try:
        loop.run()
    except KeyboardInterrupt:
        pass

    print("START : Pipeline has stopped")
    self.pipeline.set_state(Gst.State.NULL)
于 2017-12-18T12:53:17.467 回答