<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,<o:p></o:p> <o:p> </o:p> I’ve try to remux a mpegts-stream from satellite to a file with demuxing and muxing from/to a mpegts stream.<o:p></o:p> I thought that this should be easy and build following simple C-Code:<o:p></o:p> <o:p> </o:p> #include <stdio.h><o:p></o:p> #include <unistd.h><o:p></o:p> #include <string.h><o:p></o:p> #include <gst/gst.h><o:p></o:p> #include <glib.h><o:p></o:p> <o:p> </o:p> <o:p> </o:p> static gboolean<o:p></o:p> bus_call (GstBus *bus,<o:p></o:p> GstMessage *msg,<o:p></o:p> gpointer data)<o:p></o:p> {<o:p></o:p> GMainLoop *loop = (GMainLoop *) data;<o:p></o:p> <o:p> </o:p> switch (GST_MESSAGE_TYPE (msg)) {<o:p></o:p> <o:p> </o:p> case GST_MESSAGE_EOS:<o:p></o:p> g_print ("End of stream\n");<o:p></o:p> g_main_loop_quit (loop);<o:p></o:p> break;<o:p></o:p> <o:p> </o:p> case GST_MESSAGE_ERROR: {<o:p></o:p> gchar *debug;<o:p></o:p> GError *error;<o:p></o:p> <o:p> </o:p> gst_message_parse_error (msg, &error, &debug);<o:p></o:p> g_free (debug);<o:p></o:p> <o:p> </o:p> g_printerr ("Error: %s\n", error->message);<o:p></o:p> g_error_free (error);<o:p></o:p> <o:p> </o:p> g_main_loop_quit (loop);<o:p></o:p> break;<o:p></o:p> }<o:p></o:p> /* case GST_MESSAGE_ELEMENT: <o:p></o:p> {<o:p></o:p> const GstStructure *str;<o:p></o:p> <o:p> </o:p> str = gst_message_get_structure (msg);<o:p></o:p> const gchar *name = gst_structure_get_name (str);<o:p></o:p> <o:p> </o:p> printf("got message from %s\n", name);<o:p></o:p> } */<o:p></o:p> default:<o:p></o:p> break;<o:p></o:p> }<o:p></o:p> <o:p> </o:p> return TRUE;<o:p></o:p> }<o:p></o:p> <o:p> </o:p> <o:p> </o:p> static void link_to_mux (GstPad *tolink_pad, GstElement *mux)<o:p></o:p> {<o:p></o:p> GstPad *pad;<o:p></o:p> gchar *srcname, *sinkname;<o:p></o:p> <o:p> </o:p> srcname = gst_pad_get_name (tolink_pad);<o:p></o:p> pad = gst_element_get_compatible_pad (mux, tolink_pad, NULL);<o:p></o:p> gst_pad_link (tolink_pad, pad);<o:p></o:p> sinkname = gst_pad_get_name (pad);<o:p></o:p> gst_object_unref (GST_OBJECT (pad));<o:p></o:p> <o:p> </o:p> g_print ("A new pad %s was created and linked to %s\n", srcname, sinkname);<o:p></o:p> g_free (sinkname);<o:p></o:p> g_free (srcname);<o:p></o:p> }<o:p></o:p> <o:p> </o:p> static void<o:p></o:p> on_pad_added (GstElement *element,<o:p></o:p> GstPad *pad,<o:p></o:p> gpointer data)<o:p></o:p> {<o:p></o:p> GstElement *mux = (GstElement *) data;<o:p></o:p> GstCaps *caps;<o:p></o:p> gchar *caps_string;<o:p></o:p> gchar *name;<o:p></o:p> <o:p> </o:p> name = gst_pad_get_name (pad);<o:p></o:p> printf("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> g_print (" Capability: %s\n", caps_string);<o:p></o:p> <o:p> </o:p> // if ((strstr(caps_string, "audio")) || (strstr(caps_string, "video"))) <o:p></o:p> link_to_mux(pad, mux);<o:p></o:p> <o:p> </o:p> gst_caps_unref (caps);<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> void no_more_pads (GstElement* object, gpointer user_data)<o:p></o:p> {<o:p></o:p> g_print("No more pads event from %s\n", gst_element_get_name(object));<o:p></o:p> }<o:p></o:p> <o:p> </o:p> int<o:p></o:p> main ()<o:p></o:p> {<o:p></o:p> GMainLoop *loop;<o:p></o:p> <o:p> </o:p> GstElement *pipeline, *source, *parse, *demux, *mux, *sink;<o:p></o:p> GstBus *bus;<o:p></o:p> <o:p> </o:p> gst_init (0, NULL);<o:p></o:p> <o:p> </o:p> loop = g_main_loop_new (NULL, FALSE);<o:p></o:p> <o:p> </o:p> pipeline = gst_pipeline_new ("DVB-Filesave");<o:p></o:p> source = gst_element_factory_make ("dvbbasebin", "dvb-source");<o:p></o:p> parse = gst_element_factory_make ("tsparse", "dvb-parse");<o:p></o:p> demux = gst_element_factory_make ("tsdemux", "dvb-demux");<o:p></o:p> mux = gst_element_factory_make ("mpegtsmux", "dvb-mux");<o:p></o:p> sink = gst_element_factory_make ("filesink", "file-output");<o:p></o:p> <o:p> </o:p> if (!pipeline || !source || !parse || !demux || !mux || !sink) {<o:p></o:p> g_printerr ("One element could not be created. Exiting.\n");<o:p></o:p> if(!pipeline) g_printerr("Pipeline not created\n");<o:p></o:p> else if(!source) g_printerr("Source not created\n");<o:p></o:p> else if(!sink) g_printerr("Sink not created\n");<o:p></o:p> return -1;<o:p></o:p> }<o:p></o:p> <o:p> </o:p> g_object_set (G_OBJECT (source), "adapter", 2, NULL);<o:p></o:p> g_object_set (G_OBJECT (source), "frequency", 12544000, NULL);<o:p></o:p> g_object_set (G_OBJECT (source), "program-numbers", "17501", NULL); <o:p></o:p> g_object_set (G_OBJECT (source), "polarity", "h", NULL);<o:p></o:p> g_object_set (G_OBJECT (source), "symbol-rate", 22000, NULL);<o:p></o:p> <o:p> </o:p> g_object_set (G_OBJECT (sink), "location", "remux_test.mpg", NULL);<o:p></o:p> <o:p> </o:p> bus = gst_pipeline_get_bus (GST_PIPELINE (pipeline));<o:p></o:p> gst_bus_add_watch (bus, bus_call, loop);<o:p></o:p> gst_object_unref (bus);<o:p></o:p> <o:p> </o:p> gst_bin_add_many (GST_BIN (pipeline), source, parse, demux, mux, sink, NULL);<o:p></o:p> <o:p> </o:p> gst_element_link_many (source, parse, demux, NULL);<o:p></o:p> gst_element_link (mux, sink);<o:p></o:p> <o:p> </o:p> g_signal_connect (demux, "pad-added", G_CALLBACK (on_pad_added), mux);<o:p></o:p> g_signal_connect (demux, "no-more-pads", G_CALLBACK (on_pad_added), NULL); <o:p></o:p> <o:p> </o:p> <o:p> </o:p> g_print ("Now playing: ");<o:p></o:p> gst_element_set_state (pipeline, GST_STATE_PLAYING);<o:p></o:p> <o:p> </o:p> g_print ("Running...\n");<o:p></o:p> g_main_loop_run (loop);<o:p></o:p> <o:p> </o:p> return 0;<o:p></o:p> }<o:p></o:p> <o:p> </o:p> But I get following error running with GST_DEBUG=5:<o:p></o:p> <o:p> </o:p> <snipe><o:p></o:p> 0:00:01.482668761 5432 0x14c52d0 DEBUG task gsttask.c:663:gst_task_set_state:<dvbsrc0:src> Changing task 0x14ae290 to state 2<o:p></o:p> 0:00:01.482684269 5432 0x14c52d0 DEBUG GST_EVENT gstevent.c:301:gst_event_new_custom: creating new event 0x7fbca0003490 eos 28174<o:p></o:p> 0:00:01.482706379 5432 0x14c52d0 WARN basesrc gstbasesrc.c:2933:gst_base_src_loop:<dvbsrc0> error: Internal data flow error.<o:p></o:p> 0:00:01.482720791 5432 0x14c52d0 WARN basesrc gstbasesrc.c:2933:gst_base_src_loop:<dvbsrc0> error: streaming task paused, reason not-negotiated (-4)<o:p></o:p> 0:00:01.482736371 5432 0x14c52d0 DEBUG GST_MESSAGE gstelement.c:1804:gst_element_message_full:<dvbsrc0> start<o:p></o:p> 0:00:01.482766019 5432 0x14c52d0 INFO GST_ERROR_SYSTEM gstelement.c:1835:gst_element_message_full:<dvbsrc0> posting message: Internal data flow error.<o:p></o:p> 0:00:01.482797146 5432 0x14c52d0 DEBUG GST_BUS gstbus.c:310:gst_bus_post:<bus2> [msg 0x7fbca80022c0] posting on bus error message: 0x7fbca80022c0, time 99:99:99.999999999, seq-num 149, element 'dvbsrc0', GstMessageError, gerror=(GError)NULL, debug=(string)"gstbasesrc.c\(2933\):\ gst_base_src_loop\ \(\):\ /GstPipeline:DVB-Filesave/DvbBaseBin:dvb-source/GstDvbSrc:dvbsrc0:\012streaming\ task\ paused\,\ reason\ not-negotiated\ \(-4\)";<o:p></o:p> 0:00:01.482830109 5432 0x14c52d0 DEBUG bin gstbin.c:3409:gst_bin_handle_message_func:<dvb-source> [msg 0x7fbca80022c0] handling child dvbsrc0 message of type error<o:p></o:p> 0:00:01.482846629 5432 0x14c52d0 DEBUG bin gstbin.c:3416:gst_bin_handle_message_func:<dvb-source> got ERROR message, unlocking state change<o:p></o:p> 0:00:01.482860232 5432 0x14c52d0 DEBUG bin gstbin.c:3744:gst_bin_handle_message_func:<dvb-source> posting message upward<o:p></o:p> 0:00:01.482873804 5432 0x14c52d0 DEBUG GST_BUS gstbus.c:310:gst_bus_post:<bus0> [msg 0x7fbca80022c0] posting on bus error message: 0x7fbca80022c0, time 99:99:99.999999999, seq-num 149, element 'dvbsrc0', GstMessageError, gerror=(GError)NULL, debug=(string)"gstbasesrc.c\(2933\):\ gst_base_src_loop\ \(\):\ /GstPipeline:DVB-Filesave/DvbBaseBin:dvb-source/GstDvbSrc:dvbsrc0:\012streaming\ task\ paused\,\ reason\ not-negotiated\ \(-4\)";<o:p></o:p> 0:00:01.482900244 5432 0x14c52d0 DEBUG bin gstbin.c:3409:gst_bin_handle_message_func:<DVB-Filesave> [msg 0x7fbca80022c0] handling child dvbsrc0 message of type error<o:p></o:p> 0:00:01.482915307 5432 0x14c52d0 DEBUG bin gstbin.c:3416:gst_bin_handle_message_func:<DVB-Filesave> got ERROR message, unlocking state change<o:p></o:p> 0:00:01.482928669 5432 0x14c52d0 DEBUG bin gstbin.c:3744:gst_bin_handle_message_func:<DVB-Filesave> posting message upward<o:p></o:p> 0:00:01.482941762 5432 0x14c52d0 DEBUG GST_BUS gstbus.c:310:gst_bus_post:<bus1> [msg 0x7fbca80022c0] posting on bus error message: 0x7fbca80022c0, time 99:99:99.999999999, seq-num 149, element 'dvbsrc0', GstMessageError, gerror=(GError)NULL, debug=(string)"gstbasesrc.c\(2933\):\ gst_base_src_loop\ \(\):\ /GstPipeline:DVB-Filesave/DvbBaseBin:dvb-source/GstDvbSrc:dvbsrc0:\012streaming\ task\ paused\,\ reason\ not-negotiated\ \(-4\)";<o:p></o:p> 0:00:01.482965819 5432 0x14c52d0 DEBUG GST_BUS gstbus.c:345:gst_bus_post:<bus1> [msg 0x7fbca80022c0] pushing on async queue<o:p></o:p> 0:00:01.482985839 5432 0x14c52d0 DEBUG GST_BUS gstbus.c:348:gst_bus_post:<bus1> [msg 0x7fbca80022c0] pushed on async queue<o:p></o:p> 0:00:01.483001254 5432 0x14c52d0 DEBUG GST_BUS gstbus.c:341:gst_bus_post:<bus0> [msg 0x7fbca80022c0] dropped<o:p></o:p> 0:00:01.483001424 5432 0x13a0800 DEBUG GST_BUS gstbus.c:505:gst_bus_timed_pop_filtered:<bus1> got message 0x7fbca80022c0, error from dvbsrc0, type mask is 4294967295<o:p></o:p> 0:00:01.483018949 5432 0x14c52d0 DEBUG GST_BUS gstbus.c:341:gst_bus_post:<bus2> [msg 0x7fbca80022c0] dropped<o:p></o:p> 0:00:01.483073809 5432 0x14c52d0 INFO GST_ERROR_SYSTEM gstelement.c:1858:gst_element_message_full:<dvbsrc0> posted error message: Internal data flow error.<o:p></o:p> 0:00:01.483039739 5432 0x13a0800 DEBUG GST_BUS gstbus.c:773:gst_bus_source_dispatch:<bus1> source 0x14dfe40 calling dispatch with error message: 0x7fbca80022c0, time 99:99:99.999999999, seq-num 149, element 'dvbsrc0', GstMessageError, gerror=(GError)NULL, debug=(string)"gstbasesrc.c\(2933\):\ gst_base_src_loop\ \(\):\ /GstPipeline:DVB-Filesave/DvbBaseBin:dvb-source/GstDvbSrc:dvbsrc0:\012streaming\ task\ paused\,\ reason\ not-negotiated\ \(-4\)";<o:p></o:p> 0:00:01.483095819 5432 0x14c52d0 DEBUG GST_PADS gstpad.c:3498:check_sticky:<dvbsrc0:src> pushing all sticky events<o:p></o:p> Error: Internal data flow error.<o:p></o:p> 0:00:01.483145094 5432 0x14c52d0 DEBUG GST_PADS gstpad.c:3431:push_sticky:<dvbsrc0:src> event stream-start was already received<o:p></o:p> 0:00:01.483165454 5432 0x13a0800 DEBUG GST_BUS gstbus.c:778:gst_bus_source_dispatch:<bus1> source 0x14dfe40 handler returns 1<o:p></o:p> 0:00:01.483177839 5432 0x14c52d0 DEBUG GST_PADS gstpad.c:3431:push_sticky:<dvbsrc0:src> event caps was already received<o:p></o:p> 0:00:01.483224132 5432 0x14c52d0 DEBUG GST_PADS gstpad.c:3431:push_sticky:<dvbsrc0:src> event segment was already received<o:p></o:p> 0:00:01.483241264 5432 0x14c52d0 DEBUG GST_EVENT gstpad.c:5098:gst_pad_send_event_unchecked:<queue0:sink> have event type eos event: 0x7fbca0003490, time 99:99:99.999999999, seq-num 39, (NULL)<o:p></o:p> <o:p> </o:p> Someone with any idea?<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> </div> </body> </html>