<html xmlns:o="urn:schemas-microsoft-com:office:office" xmlns:w="urn:schemas-microsoft-com:office:word" xmlns="http://www.w3.org/TR/REC-html40"> <head> <meta http-equiv=Content-Type content="text/html; charset=us-ascii"> <meta name=Generator content="Microsoft Word 11 (filtered medium)"> <style>  </style> </head> <body lang=DE link=blue vlink=purple> <div class=Section1> Hi @ all,<o:p></o:p> <o:p> </o:p> I have a problem with mpegtsmux under gstreamer 1.0:<o:p></o:p> <o:p> </o:p> I try to exclude the only relevant streams out of dvbbasebin (mpeg-video and mpeg-audio) and send it over a server to a client.<o:p></o:p> I use tsdemux, look into the generated pads and use mpegtsmux to generate a stream. But it’s not simple. I’m working on it since a lot of time.<o:p></o:p> I don’t know who has tried to do the same. I think I forgot to link a pad.<o:p></o:p> I know that this kind of help is usually frowned upon in this forum, but I hope that someone has a heart of gold today.<o:p></o:p> <o:p> </o:p> <div style='mso-element:para-border-div;border:none;border-bottom:solid windowtext 1.0pt; padding:0cm 0cm 1.0pt 0cm'> The code:<o:p></o:p> </div> <o:p> </o:p> <o:p> </o:p> int init_tv() /* Initiating DVB-Streamer variables */<o:p></o:p> {<o:p></o:p> <o:p></o:p> printf("init_tv\n");<o:p></o:p> <o:p> </o:p> dvb_pipe = gst_pipeline_new ("DVB-Streamer");<o:p></o:p> dvb_source = gst_element_factory_make ("dvbbasebin", "dvb-source");<o:p></o:p> dvb_demux = gst_element_factory_make ("tsdemux", "dvb-demux");<o:p></o:p> dvb_v_queue = gst_element_factory_make ("queue", "dvb-v-queue");<o:p></o:p> dvb_v_parse = gst_element_factory_make ("mpegvideoparse","dvb-v-parse");<o:p></o:p> dvb_a_queue = gst_element_factory_make ("queue", "dvb-a-queue");<o:p></o:p> dvb_a_parse = gst_element_factory_make ("mpegaudioparse","dvb-a-parse");<o:p></o:p> dvb_mux = gst_element_factory_make ("mpegtsmux", "dvb-mux");<o:p></o:p> dvb_v_queue2 = gst_element_factory_make ("queue", "dvb-v-queue2");<o:p></o:p> dvb_a_queue2 = gst_element_factory_make ("queue", "dvb-a-queue2");<o:p></o:p> dvb_sink = gst_element_factory_make ("tcpserversink", "tcp-output");<o:p></o:p> dvb_f_queue = gst_element_factory_make ("queue", "dvb-f-queue");<o:p></o:p> dvb_f_sink = gst_element_factory_make ("fakesink", "fake-output");<o:p></o:p> <o:p> </o:p> if (!dvb_pipe || !dvb_source || !dvb_demux || !dvb_v_queue || !dvb_v_parse || !dvb_a_queue|| !dvb_a_parse || !dvb_mux || !dvb_v_queue2 || !dvb_a_queue2 || !dvb_sink || !dvb_f_queue || !dvb_f_sink) <o:p></o:p> {<o:p></o:p> g_printerr ("One element could not be created. Exiting.\n");<o:p></o:p> syslog(LOG_ERR, "One element could not be created. Exiting.\n");<o:p></o:p> if(!dvb_pipe) g_printerr("DVB-Pipeline not created\n");<o:p></o:p> else if(!dvb_source) g_printerr("DVB-Source not created\n");<o:p></o:p> else if(!dvb_demux) g_printerr("DVB-Demux not created\n");<o:p></o:p> else if(!dvb_v_queue) g_printerr("DVB-Video Queue not created\n");<o:p></o:p> else if(!dvb_v_parse) g_printerr("DVB-Video Parse not created\n");<o:p></o:p> else if(!dvb_a_queue) g_printerr("DVB-Audio Queue not created\n");<o:p></o:p> else if(!dvb_a_parse) g_printerr("DVB-Audio Parse not created\n");<o:p></o:p> else if(!dvb_mux) g_printerr("DVB-Mux not created\n");<o:p></o:p> else if(!dvb_v_queue2) g_printerr("DVB-V-Queue2 not created\n");<o:p></o:p> else if(!dvb_a_queue2) g_printerr("DVB-A-Queue2 not created\n");<o:p></o:p> else if(!dvb_sink) g_printerr("DVB-Sink not created\n");<o:p></o:p> else if(!dvb_f_queue) g_printerr("DVB-F-Queue not created\n");<o:p></o:p> else if(!dvb_f_sink) g_printerr("DVB-Fakesink not created\n");<o:p></o:p> return -1;<o:p></o:p> }<o:p></o:p> <o:p> </o:p> <o:p> </o:p> dvb_bus = gst_pipeline_get_bus (GST_PIPELINE (dvb_pipe));<o:p></o:p> gst_bus_add_watch (dvb_bus, dvb_bus_call, NULL);<o:p></o:p> gst_object_unref (dvb_bus); <o:p></o:p> <o:p> </o:p> gst_bin_add_many (GST_BIN (dvb_pipe), dvb_source, dvb_demux, dvb_v_queue, dvb_v_parse, dvb_a_queue, dvb_a_parse, dvb_v_queue2, dvb_a_queue2, dvb_mux, dvb_sink, dvb_f_queue, dvb_f_sink, NULL);<o:p></o:p> gst_element_link (dvb_source, dvb_demux);<o:p></o:p> gst_element_link_many(dvb_v_queue, dvb_v_parse, dvb_mux, dvb_v_queue2, dvb_sink, NULL);<o:p></o:p> gst_element_link_many(dvb_a_queue, dvb_a_parse, dvb_mux, dvb_a_queue2, dvb_sink, NULL);<o:p></o:p> gst_element_link_many(dvb_f_queue, dvb_f_sink, NULL);<o:p></o:p> <o:p> </o:p> <o:p> </o:p> <o:p> </o:p> g_signal_connect (dvb_demux, "pad-added", G_CALLBACK (dvb_pad_added), NULL); <o:p></o:p> g_signal_connect (dvb_mux, "pad-added", G_CALLBACK (dvb_mux_pad_added), NULL); <o:p></o:p> <o:p> </o:p> return 1;<o:p></o:p> }<o:p></o:p> <o:p> </o:p> static void dvb_pad_added (GstElement *element, GstPad *pad, gpointer data) /* Demuxer pad_added */<o:p></o:p> {<o:p></o:p> GstPad *sinkpad;<o:p></o:p> gchar *name;<o:p></o:p> GstCaps *caps;<o:p></o:p> gchar *caps_string;<o:p></o:p> <o:p> </o:p> name = gst_pad_get_name (pad);<o:p></o:p> g_print ("A new pad %s was created\n", name);<o:p></o:p> <o:p> </o:p> caps = gst_pad_query_caps (pad, NULL);<o:p></o:p> caps_string = gst_caps_to_string (caps);<o:p></o:p> gst_caps_unref (caps);<o:p></o:p> g_print (" Capability: %s\n", caps_string);<o:p></o:p> syslog(LOG_NOTICE, " Capability of %s: %s\n", name, caps_string);<o:p></o:p> <o:p></o:p> if (strncmp (caps_string, "video/mpeg", 10) == 0) /* Only mpeg-video */<o:p></o:p> {<o:p></o:p> sinkpad = gst_element_get_static_pad (dvb_v_queue, "sink");<o:p></o:p> g_print ("Dynamic pad created, linking %s to TS-Demuxer/Video-Queue\n", name);<o:p></o:p> syslog(LOG_NOTICE,"Dynamic pad created, linking %s to TS-Demuxer/Video-Queue\n", name);<o:p></o:p> gst_pad_link (pad, sinkpad);<o:p></o:p> gst_object_unref (sinkpad);<o:p></o:p> }<o:p></o:p> else if (strncmp (caps_string, "audio/mpeg", 10) == 0) /* Only mpeg-audio */<o:p></o:p> {<o:p></o:p> sinkpad = gst_element_get_static_pad (dvb_a_queue, "sink");<o:p></o:p> g_print ("Dynamic pad created, linking pad %s to TS-Demuxer/Audio-Queue\n",name);<o:p></o:p> syslog(LOG_NOTICE,"Dynamic pad created, linking pad %s to TS-Demuxer/Audio-Queue\n",name);<o:p></o:p> gst_pad_link (pad, sinkpad);<o:p></o:p> gst_object_unref (sinkpad);<o:p></o:p> } <o:p></o:p> else /* Rest to fake */<o:p></o:p> {<o:p></o:p> sinkpad = gst_element_get_static_pad (dvb_f_queue, "sink"); <o:p></o:p> g_print ("Dynamic pad created, linking %s to TS-Demuxer/Fake-Queue\n", name);<o:p></o:p> syslog(LOG_NOTICE,"Dynamic pad created, linking %s to TS-Demuxer/Fake-Queue\n", name);<o:p></o:p> gst_pad_link (pad, sinkpad);<o:p></o:p> gst_object_unref (sinkpad);<o:p></o:p> }<o:p></o:p> g_free (name);<o:p></o:p> g_free (caps_string);<o:p></o:p> <o:p></o:p> }<o:p></o:p> <o:p> </o:p> static void dvb_mux_pad_added (GstElement *element, GstPad *pad, gpointer data) /* Muxer pad_added */<o:p></o:p> {<o:p></o:p> GstPad *sinkpad;<o:p></o:p> gchar *name;<o:p></o:p> GstCaps *caps;<o:p></o:p> gchar *caps_string;<o:p></o:p> <o:p> </o:p> name = gst_pad_get_name (pad);<o:p></o:p> g_print ("A new MUX-pad %s was created\n", name);<o:p></o:p> <o:p> </o:p> caps = gst_pad_query_caps (pad, NULL);<o:p></o:p> caps_string = gst_caps_to_string (caps);<o:p></o:p> gst_caps_unref (caps);<o:p></o:p> g_print (" Capability: %s\n", caps_string);<o:p></o:p> syslog(LOG_NOTICE, " Capability of %s: %s\n", name, caps_string);<o:p></o:p> <o:p></o:p> if (strncmp (caps_string, "audio/mpeg", 10) == 0)<o:p></o:p> {<o:p></o:p> sinkpad = gst_element_get_static_pad (dvb_a_queue2, "sink");<o:p></o:p> g_print ("Dynamic pad created, linking pad %s to TS-Demuxer/Audio-Queue\n",name);<o:p></o:p> syslog(LOG_NOTICE,"Dynamic pad created, linking pad %s to TS-Muxer/Audio-Queue\n",name);<o:p></o:p> gst_pad_link (pad, sinkpad);<o:p></o:p> gst_object_unref (sinkpad);<o:p></o:p> }<o:p></o:p> else if (strncmp (caps_string, "video/mpeg", 10) == 0) <o:p></o:p> {<o:p></o:p> sinkpad = gst_element_get_static_pad (dvb_v_queue2, "sink");<o:p></o:p> g_print ("Dynamic pad created, linking %s to TS-Demuxer/Video-Queue\n", name);<o:p></o:p> syslog(LOG_NOTICE,"Dynamic pad created, linking %s to TS-Muxer/Video-Queue\n", name);<o:p></o:p> gst_pad_link (pad, sinkpad);<o:p></o:p> gst_object_unref (sinkpad);<o:p></o:p> } <o:p></o:p> g_free (name);<o:p></o:p> g_free (caps_string);<o:p></o:p> <o:p></o:p> }<o:p></o:p> <o:p> </o:p> int tv_send(int http_port, char *ip_adr) /* Call to run */<o:p></o:p> {<o:p></o:p> char tmp_str[254];<o:p></o:p> <o:p> </o:p> g_print("tv_send from %s\n", ip_adr);<o:p></o:p> <o:p> </o:p> g_object_set (G_OBJECT (dvb_sink), "host", ip_adr, NULL);<o:p></o:p> <o:p> </o:p> gst_element_set_state (dvb_pipe, GST_STATE_NULL); <o:p></o:p> <o:p> </o:p> g_object_set (G_OBJECT (dvb_source), "adapter", ad_ad, NULL);<o:p></o:p> g_object_set (G_OBJECT (dvb_source), "frontend", ad_fe, NULL);<o:p></o:p> <o:p> </o:p> sprintf(tmp_str,"%s000", freq);<o:p></o:p> g_object_set (G_OBJECT (dvb_source), "frequency", atoi(tmp_str), NULL);<o:p></o:p> g_object_set (G_OBJECT (dvb_source), "program_numbers", s_prog, NULL);<o:p></o:p> g_object_set (G_OBJECT (dvb_source), "polarity", pol, NULL);<o:p></o:p> <o:p> </o:p> g_object_set (G_OBJECT (dvb_source), "symbol-rate", atoi(s_rate), NULL);<o:p></o:p> <o:p> </o:p> g_object_set (G_OBJECT (dvb_sink), "port", http_port, NULL);<o:p></o:p> <o:p> </o:p> g_print ("Now playing: %s on %i\n", tmp_str, http_port);<o:p></o:p> gst_element_set_state (dvb_pipe, GST_STATE_PLAYING);<o:p></o:p> <o:p></o:p> g_print ("Running...\n");<o:p></o:p> <o:p> </o:p> return 0;<o:p></o:p> }<o:p></o:p> <div style='mso-element:para-border-div;border:none;border-bottom:solid windowtext 1.0pt; padding:0cm 0cm 1.0pt 0cm'> <o:p> </o:p> </div> <o:p> </o:p> The pipe ‘dvbbasebin -> tcpserversink’ (without ‘demux -> parser -> mux’) runs fine.<o:p></o:p> <o:p> </o:p> The result of this pipe is: The Demuxer pad_added will call without any problems and the pad link runs as expected. The Muxer pad_added will never be called.<o:p></o:p> On the client a get only the first frame of the Video-Stream and see the video-pad_added on it, but I never get the Audio-Stream and the client is waiting.<o:p></o:p> On VLC on the client I have the same result.<o:p></o:p> I think, I forgot something like static pad definitions, but I don’t know which one.<o:p></o:p> <o:p> </o:p> I know, that I shouldn’t use this forum to solve my problems, but I will be very happy if someone has a some pity with me.<o:p></o:p> <o:p> </o:p> Thanks a lot<o:p></o:p> Bernhard<o:p></o:p> <o:p> </o:p> <o:p> </o:p> <o:p> </o:p> <o:p> </o:p> <o:p> </o:p> <o:p> </o:p> </div> </body> </html>