<html xmlns:v="urn:schemas-microsoft-com:vml" xmlns:o="urn:schemas-microsoft-com:office:office" xmlns:w="urn:schemas-microsoft-com:office:word" xmlns:st1="urn:schemas-microsoft-com:office:smarttags" 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)"> <o:SmartTagType namespaceuri="urn:schemas-microsoft-com:office:smarttags" name="PersonName"/>  <style>  </style> </head> <body lang=DE link=blue vlink=purple> <div class=Section1> Hi again,<o:p></o:p> <o:p> </o:p> Now I’ve learned that mpegtsmux needs a ‚pad on request’ and I’ve change something a little bit simpler:<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_mux = gst_element_factory_make ("mpegtsmux", "dvb-mux");<o:p></o:p> dvb_sink = gst_element_factory_make ("tcpserversink", "tcp-output");<o:p></o:p> <o:p> </o:p> if (!dvb_pipe || !dvb_source || !dvb_demux || !dvb_mux || !dvb_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_mux) g_printerr("DVB-Mux not created\n");<o:p></o:p> else if(!dvb_sink) g_printerr("DVB-Sink 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_mux, dvb_sink, NULL);<o:p></o:p> gst_element_link_many (dvb_source, dvb_demux, dvb_mux, dvb_sink, NULL);<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> <o:p> </o:p> <o:p> </o:p> return 1;<o:p></o:p> }<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 *muxpad;<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) <o:p></o:p> {<o:p></o:p> g_print ("Dynamic Video-pad created, linking %s to TS-Demuxer/TS-muxer\n", name);<o:p></o:p> syslog(LOG_NOTICE,"Dynamic pad created, linking %s to TS-Demuxer/TS-Muxer\n", name);<o:p></o:p> muxpad = gst_element_get_request_pad(dvb_mux, "sink_%d");<o:p></o:p> g_print("muxpad: %s ", gst_pad_get_name (muxpad));<o:p></o:p> if (gst_pad_link (pad, muxpad) == GST_PAD_LINK_OK) g_print ("linked\n"); <o:p></o:p> else g_print ("NOT linked\n");<o:p></o:p> gst_object_unref (muxpad);<o:p></o:p> }<o:p></o:p> else if (strncmp (caps_string, "audio/mpeg", 10) == 0) <o:p></o:p> {<o:p></o:p> g_print ("Dynamic Audio-pad created, linking %s to TS-Demuxer/TS-muxer\n", name);<o:p></o:p> syslog(LOG_NOTICE,"Dynamic pad created, linking %s to TS-Demuxer/TS-Muxer\n", name);<o:p></o:p> muxpad = gst_element_get_request_pad(dvb_mux, "sink_%d");<o:p></o:p> g_print("muxpad: %s ", gst_pad_get_name (muxpad));<o:p></o:p> if (gst_pad_link (pad, muxpad) == GST_PAD_LINK_OK) g_print ("linked\n"); <o:p></o:p> else g_print ("NOT linked\n");<o:p></o:p> gst_object_unref (muxpad);<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> <o:p> </o:p> The result is:<o:p></o:p> <o:p> </o:p> Running...<o:p></o:p> A new pad video_01ff was created<o:p></o:p> Capability: video/mpeg, mpegversion=(int)2, systemstream=(boolean)false<o:p></o:p> Dynamic Video-pad created, linking video_01ff to TS-Demuxer/TS-muxer<o:p></o:p> muxpad: sink_65 linked<o:p></o:p> A new pad private_0021 was created<o:p></o:p> Capability: private/teletext<o:p></o:p> A new pad audio_0200 was created<o:p></o:p> Capability: audio/mpeg, mpegversion=(int)1<o:p></o:p> Dynamic Audio-pad created, linking audio_0200 to TS-Demuxer/TS-muxer<o:p></o:p> muxpad: sink_66 linked<o:p></o:p> <o:p> </o:p> So it’s looks not so bad. But I don’t get a stream on the client (on gstreamer as well as on vlc, something misses?).<o:p></o:p> Someone out there to help?<o:p></o:p> <o:p> </o:p> Thanks again.<o:p></o:p> Bernhard<o:p></o:p> <o:p> </o:p> <div> <div class=MsoNormal align=center style='text-align:center'> <hr size=2 width="100%" align=center tabindex=-1> </div> Von: gstreamer-devel-bounces+bernhard.graaf=gmx.de@lists.freedesktop.org [mailto:gstreamer-devel-bounces+bernhard.graaf=gmx.de@lists.freedesktop.org] Im Auftrag von Bernhard Graaf Gesendet: Sonntag, 30. Dezember 2012 11:19 An: '<st1:PersonName w:st="on">Discussion of the development of and with GStreamer</st1:PersonName>' Betreff: mpegtsmux (need help!)<o:p></o:p> </div> <o:p> </o:p> 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='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='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>