如何在动态管道中使用 splitmuxsink

Question

在动态管道中使用 splitmuxsink 的正确方法是什么？

以前我使用filesink来记录（没有问题），但是需要将文件分段保存，所以我尝试在动态管道中使用splitmuxsink（记录中有异步时间）。这样做时，我遇到了两个问题：

1. 当我尝试停止录制时，我使用空闲垫来阻止录制队列并启动回调函数来执行取消链接录制分支的步骤（发送 eos，在将 bin 记录为 NULL，然后将 bin 出队）。我已经设置了一个下游数据探针来通知我在尝试执行步骤 2 之前 eos 已到达 splitmuxsink 接收器..（将 elemets 设置为 null）

   但是，最终结果是我仍然有一个空的最后一个文件（o 字节）。管道似乎尚未关闭或出现问题。我做了一个解决方法，在录制停止时立即分割视频（尽管我丢失了几帧）

   如何在动态分支中停止？

2. 当我尝试在开始录音时创建录音箱（在创建打击垫连接录音箱时利用打击垫添加的信号）。之前我已经按正常顺序创建了记录箱（不是在我创建的 glib 循环期间创建它们）。上一步工作正常，但当前步骤使 splitmuxsink 的 filesink 处于锁定状态

   我应该如何解决这个问题？是什么导致了锁定状态？

这是我的代码：

/// create record bin
static void
pad-added(GstElement * self,
               GstPad * new_pad,
               gpointer user_data)
{
    char* pad_name = gst_pad_get_name(new_pad);
    if(g_str_equal(pad_name,"src"))
    {
   
        //RECORD records;
        records.recording    = gst_bin_new("recording");
        records.queue       = gst_element_factory_make("queue","queue");
        records.enc         = gst_element_factory_make("vpuenc_h264","enc");
        records.parser       = gst_element_factory_make("h264parse","parser");
        records.sink        = gst_element_factory_make("splitmuxsink","sink");
  

        // Add it to the main pipeline
        gst_bin_add_many(GST_BIN(records.recording),
                                 records.queue,
                                 records.enc,
                                 records.parser,
                                 records.sink,NULL);

        // link up the recording elements queue
        gst_element_link_many(records.queue,
                                  records.enc,
                                  records.parser,
                                  records.sink,NULL)
    
        
        g_object_set(G_OBJECT(records.fsink),
                     //"location","video_%d.mp4",
                     "max-size-time", (guint64) 10L * GST_SECOND,
                     "async-handling", TRUE,
                     "async-finalize", TRUE,
                     NULL);

        records.queue_sink_pad = gst_element_get_static_pad (records.queue, "sink");
        records.ghost_pad = gst_ghost_pad_new ("sink", records.queue_sink_pad);
        gst_pad_set_active(records.ghost_pad, TRUE);

        gst_element_add_pad(GST_ELEMENT(records.recording),records.ghost_pad);

        g_signal_connect (records.sink, "format-location",
                         (GCallback)format_location_callback,
                         &records);
        
    }
}

gboolean cmd_loop()
{
   // other cmd not shown here

   if(RECORD)
   {
      //create tee sink pad
      // this step will trigger the pad-added function
      tee_sink_pad = gst_element_get_request_pad (tee,"src");

      // ....other function
   }
} 

int main()
{
   // add the pad-added signal response
   g_signal_connect(tee, "pad-added", G_CALLBACK(pad-added), NULL);

  // use to construct the loop (cycle every 1s)
   GSource* source = g_timeout_source_new(1000);

   // set function to watch for command 
   g_source_set_callback(source,
                          (GSourceFunc)cmd_loop,
                          NULL,
                          NULL);
}