Преобразовать команда GStreamer в код C

Question

У меня есть основная команда GStreamer для воспроизведения аудио потока, полученных от сети:

gst-launch-1.0 tcpserversrc host=127.0.0.1 port=5000 ! decodebin ! audioconvert ! alsasink 

Я попытался преобразовать его в программу C, но когда я бег это я получаю " Ошибка внутреннего потока данных ".

#include <gst/gst.h> 


static gboolean bus_call (GstBus *bus, GstMessage *msg, gpointer data) 
{ 
    GMainLoop *loop = (GMainLoop *) data; 

    switch (GST_MESSAGE_TYPE (msg)) { 

    case GST_MESSAGE_EOS: 
     g_print ("End of stream\n"); 
     g_main_loop_quit (loop); 
     break; 

    case GST_MESSAGE_ERROR: { 
     gchar *debug; 
     GError *error; 

     gst_message_parse_error (msg, &error, &debug); 
     g_free (debug); 

     g_printerr ("Error: %s\n", error->message); 
     g_error_free (error); 

     g_main_loop_quit (loop); 
     break; 
    } 
    default: 
     break; 
    } 

    return TRUE; 
} 


gint main (gint argc, gchar *argv[]) 
{ 
    GMainLoop *loop; 
    GstElement *pipeline, *src, *dec, *conv, *sink; 
    GstBus *bus; 

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

    /* setup */ 
    pipeline = gst_pipeline_new ("pipeline"); 

    bus = gst_pipeline_get_bus (GST_PIPELINE (pipeline)); 
    gst_bus_add_watch (bus, bus_call, loop); 
    gst_object_unref (bus); 

    src = gst_element_factory_make ("tcpserversrc", "source"); 
    g_object_set (G_OBJECT (src), "host", "127.0.0.1",NULL); 
    g_object_set (G_OBJECT (src), "port", 5000 ,NULL); 


    dec = gst_element_factory_make ("decodebin", "decoder"); 
    conv = gst_element_factory_make ("audioconvert", "aconv"); 
    sink = gst_element_factory_make ("alsasink", "sink"); 

    gst_bin_add_many (GST_BIN (pipeline), src, dec, conv, sink, NULL); 

    gst_element_link (src, dec); 
    gst_element_link (dec, conv); 
    gst_element_link (conv, sink); 

    /* run */ 

    gst_element_set_state (pipeline, GST_STATE_PLAYING); 
    g_main_loop_run (loop); 

    /* cleanup */ 
    gst_element_set_state (pipeline, GST_STATE_NULL); 
    gst_object_unref (GST_OBJECT (pipeline)); 

    return 0; 
} 

Вот команда, которую я использую для тестирования сервера:

gst-launch-1.0 filesrc location="file.wav" ! tcpclientsink host=127.0.0.1 port=5000 

Спасибо.

Answer 1

Поскольку decodebin src pad - a dynamic (sometimes) pad. Вы должны соединить decodebin с audioconvert, когда decodebin получил исходную площадку.

Вы можете увидеть его с gst-inspect-1.0:

$ gst-inspect-1.0 decodebin 
    : 
    : 
Pad Templates: 
    SRC template: 'src_%u' 
    Availability: Sometimes 
    Capabilities: 
     ANY 
    : 
    : 

Добавить функцию обратного вызова для pad-added в decodebin и ссылку на audioconvert в функции обратного вызова. Требуемое изменение в основном это:

--- orig.c 2017-01-18 13:35:50.434605255 +0900 
+++ new.c 2017-01-18 14:04:16.428847528 +0900 
@@ -31,6 +31,21 @@ 
    return TRUE; 
} 

+static void cb_new_pad (GstElement *element, GstPad *pad, gpointer data) 
+{ 
+ gchar *name; 
+ GstElement *other = data; 
+ 
+ name = gst_pad_get_name (pad); 
+ g_print ("A new pad %s was created for %s\n", name, gst_element_get_name(element)); 
+ g_free (name); 
+ 
+ g_print ("element %s will be linked to %s\n", 
+   gst_element_get_name(element), 
+   gst_element_get_name(other)); 
+ gst_element_link(element, other); 
+} 
+ 
gint main (gint argc, gchar *argv[]) 
{ 
    GMainLoop *loop; 
@@ -59,9 +74,13 @@ 
    gst_bin_add_many (GST_BIN (pipeline), src, dec, conv, sink, NULL); 

    gst_element_link (src, dec); 
- gst_element_link (dec, conv); 
    gst_element_link (conv, sink); 

+ /* you don't link them here */ 
+ /* gst_element_link (dec, conv); */ 
+ /* add call-back, instead */ 
+ g_signal_connect (dec, "pad-added", G_CALLBACK (cb_new_pad), conv); 
+ 
    /* run */ 
    gst_element_set_state (pipeline, GST_STATE_PLAYING); 
    g_main_loop_run (loop); 

Вот a link to a working code.

Кстати, вам не обязательно это делать самостоятельно, но пусть gst_parse_launch() справится со всем вышеперечисленным.

int main(int argc, char *argv[]) 
{ 
    GstElement *pipeline; 
    GError *err = NULL; 
    GstBus *bus; 
    GMainLoop *loop; 

    gst_init(&argc, &argv); 

    loop = g_main_loop_new(NULL, FALSE); 
    pipeline = gst_parse_launch("tcpserversrc host=127.0.0.1 port=5000 ! decodebin ! audioconvert ! alsasink", &err); 
    gst_element_set_state(pipeline, GST_STATE_PLAYING); 
    bus = gst_element_get_bus(pipeline); 
    gst_bus_add_watch (bus, bus_call, loop); 
    g_main_loop_run(loop); 

    return 0; 
} 

Есть некоторые вопросы о динамических пэдов на StackOverflow:

• GStreamer: how to connect dynamic pads
• g_signal_connect "pad-added" doesn't work