运行(gstreamer)管道中的动态(非)链接元素？

Question

运行(gstreamer)管道中的动态(非)链接元素？

gstreamer文档中有很多关于构造和运行静态管道的例子.然而,在实时管道中改变/重新链接元素并没有多少- 而媒体实际上正在流动.这绝对是可能的,所以问题是:

在尝试之前我应该理解什么gstreamer概念/机制？
有什么陷阱需要注意吗？
什么是基本程序,还是一个很好的例子？

接受的答案将是勺子喂,全面,并与源代码

Answer 1

我倾向于根据情况使用输出选择器或输入选择器箱，而不是填充阻塞的复杂性（我在另一篇文章中回答了填充阻塞http://gstreamer-devel.966125.n4.nabble.com/Dynamically-adding- and-removing-branches-of-a-tee-td973635.html#a4656812）。并在不使用时将选择器连接到 fakesrc 或 fakesink bins。另外，在以下如果一个使用GTK的例子则一个可替换行g_timeout_add (SWITCH_TIMEOUT, switch_cb, osel);用gtk_toggle_button和把所有的代码目前在switch_cb函数转换为切换按钮回调函数。在这段代码中，可以在两个图像接收器之间切换。我会用 fakesink 替换一个图像接收器以保持管道运行，以防将来我想在文件接收器中添加一个 T 恤，我想在其中录制视频，同时为播放器提供打开（图像接收器上的选择器）/关闭（选择器在 fakesink 上）显示器。这允许在运行时使用选择器添加/删除垃圾箱。

#include <gst/gst.h>

#define SWITCH_TIMEOUT 1000
#define NUM_VIDEO_BUFFERS 500

static GMainLoop *loop;

/* Output selector src pads */
static GstPad *osel_src1 = NULL;
static GstPad *osel_src2 = NULL;

static gboolean
my_bus_callback (GstBus * bus, GstMessage * message, gpointer data)
{
  g_print ("Got %s message\n", GST_MESSAGE_TYPE_NAME (message));

  switch (GST_MESSAGE_TYPE (message)) {
    case GST_MESSAGE_ERROR:{
      GError *err;
      gchar *debug;

      gst_message_parse_error (message, &err, &debug);
      g_print ("Error: %s\n", err->message);
      g_error_free (err);
      g_free (debug);

      g_main_loop_quit (loop);
      break;
    }
    case GST_MESSAGE_EOS:
      /* end-of-stream */
      g_main_loop_quit (loop);
      break;
    default:
      /* unhandled message */
      break;
  }
  /* we want to be notified again the next time there is a message
   * on the bus, so returning TRUE (FALSE means we want to stop watching
   * for messages on the bus and our callback should not be called again)
   */
  return TRUE;
}

static gboolean
switch_cb (gpointer user_data)
{
  GstElement *sel = GST_ELEMENT (user_data);
  GstPad *old_pad, *new_pad = NULL;

  g_object_get (G_OBJECT (sel), "active-pad", &old_pad, NULL);

  if (old_pad == osel_src1)
    new_pad = osel_src2;
  else
    new_pad = osel_src1;

  g_object_set (G_OBJECT (sel), "active-pad", new_pad, NULL);

  g_print ("switched from %s:%s to %s:%s\n", GST_DEBUG_PAD_NAME (old_pad),
      GST_DEBUG_PAD_NAME (new_pad));

  gst_object_unref (old_pad);

  return TRUE;

}

gint
main (gint argc, gchar * argv[])
{
  GstElement *pipeline, *src, *toverlay, *osel, *sink1, *sink2, *convert;
  GstPad *sinkpad1;
  GstPad *sinkpad2;
  GstBus *bus;

  /* init GStreamer */
  gst_init (&argc, &argv);
  loop = g_main_loop_new (NULL, FALSE);

  /* create elements */
  pipeline = gst_element_factory_make ("pipeline", "pipeline");
  src = gst_element_factory_make ("videotestsrc", "src");
  toverlay = gst_element_factory_make ("timeoverlay", "timeoverlay");
  osel = gst_element_factory_make ("output-selector", "osel");
  convert = gst_element_factory_make ("ffmpegcolorspace", "convert");
  sink1 = gst_element_factory_make ("xvimagesink", "sink1");
  sink2 = gst_element_factory_make ("ximagesink", "sink2");

  if (!pipeline || !src || !toverlay || !osel || !convert || !sink1 || !sink2) {
    g_print ("missing element\n");
    return -1;
  }

  /* add them to bin */
  gst_bin_add_many (GST_BIN (pipeline), src, toverlay, osel, convert, sink1,
      sink2, NULL);

  /* set properties */
  g_object_set (G_OBJECT (src), "is-live", TRUE, NULL);
  g_object_set (G_OBJECT (src), "do-timestamp", TRUE, NULL);
  g_object_set (G_OBJECT (src), "num-buffers", NUM_VIDEO_BUFFERS, NULL);
  g_object_set (G_OBJECT (sink1), "sync", FALSE, "async", FALSE, NULL);
  g_object_set (G_OBJECT (sink2), "sync", FALSE, "async", FALSE, NULL);
  g_object_set (G_OBJECT (osel), "resend-latest", TRUE, NULL);

  /* link src ! timeoverlay ! osel */
  if (!gst_element_link_many (src, toverlay, osel, NULL)) {
    g_print ("linking failed\n");
    return -1;
  }

  /* link output 1 */
  sinkpad1 = gst_element_get_static_pad (sink1, "sink");
  osel_src1 = gst_element_get_request_pad (osel, "src%d");
  if (gst_pad_link (osel_src1, sinkpad1) != GST_PAD_LINK_OK) {
    g_print ("linking output 1 failed\n");
    return -1;
  }
  gst_object_unref (sinkpad1);

  /* link output 2 */
  sinkpad2 = gst_element_get_static_pad (convert, "sink");
  osel_src2 = gst_element_get_request_pad (osel, "src%d");
  if (gst_pad_link (osel_src2, sinkpad2) != GST_PAD_LINK_OK) {
    g_print ("linking output 2 failed\n");
    return -1;
  }
  gst_object_unref (sinkpad2);

  if (!gst_element_link (convert, sink2)) {
    g_print ("linking output 2 failed\n");
    return -1;
  }

  /* add switch callback */
  g_timeout_add (SWITCH_TIMEOUT, switch_cb, osel);

  /* change to playing */
  bus = gst_pipeline_get_bus (GST_PIPELINE (pipeline));
  gst_bus_add_watch (bus, my_bus_callback, loop);
  gst_object_unref (bus);

  gst_element_set_state (pipeline, GST_STATE_PLAYING);

  /* now run */
  g_main_loop_run (loop);

  /* also clean up */
  gst_element_set_state (pipeline, GST_STATE_NULL);
  gst_element_release_request_pad (osel, osel_src1);
  gst_element_release_request_pad (osel, osel_src2);
  gst_object_unref (GST_OBJECT (pipeline));

  return 0;
}

Run Code Online (Sandbox Code Playgroud)

Answer 2

Hav*_*aff 6

我最喜欢的用于理解链接(和动态链接)的"概念",正在考虑将管道作为一个真正的管道,通过它流水.一旦你这样做,有些事情会变得非常明显.比如,"你在链接元素之前将源设置为播放吗？",变成"在连接软管之前你打开水吗？",它本身就是一种解答.通过动态链接更是如此,你如何确保没有水"泄漏"(这很糟糕,GStreamer中的"泄漏"相当于获得GST_FLOW_NOT_LINKED,并且会停止你的来源和乐趣)或被堵塞(可以导致数据包丢失或拥塞).
是.许多.有一点免责声明,我目前仍在使用0.10,其中一些可能已经修复了1.0,遗憾的是非常非常难以动态链接和取消与GStreamer 0.10的链接.让我解释一下:假设您正在使用Tee,并且想要取消一个分支的链接.你可以从释放Tees srcpad开始(不要忘记取消链接,这是发布垫的一部分),现在你应该能够安全地拆除该垫下游的元素.(水当量是你在发球台后关闭一个阀门,现在应该能够在阀门之后拆除管道,除非你想弄湿,否则你不会在没有关闭阀门的情况下开始拆除管道......)大部分时间都会工作,但这里有一场比赛.因为你释放了垫后,
我做了很多实验,发现如果你需要稳定性,偶尔崩溃/冻结不是一个选项,你需要一个元素作为你的动态安全网.一个元素,可以保证在释放/取消链接后,在pad上绝对不会发生任何活动.唯一的方法是打破另一个GStreamer范例,即在按住锁定时不要按下:你需要在按下/发送事件/ pad-allocation时按住一个锁.我在这里做了一段时间.(测试用例当然是最重要的,因为它允许你测试你自己/其他元素的安全性)你还可以想象一个无锁的元素会吞下所有不好的FlowReturns,并且只是为它的上游,但是你需要绝对确保你的所有下游元素都是"在关闭时接收推送或填充分配"-safe,因为你的元素不能保证一旦"停止流动" (发布/取消链接)已经执行,稍微下降不会挤过去.

当然,你必须将其中的一部分放在一边.我所谈论的这些可怕的竞争条件的窗口实际上是非常非常小的,并且可能只发生在你运行程序的每1000或10.000次.但对于专业应用来说,这当然是不可接受的.我做了谈话,我介绍了一些这方面的东西在这里

归档时间：	15 年，6 月前
查看次数：	12368 次
最近记录：	10 年前