Python Gstreamer: Internal data flow error porting program from 0.10 to 1.0

Higinio Martí Ribés hmarti at uji.es
Wed Jun 15 11:49:13 UTC 2016 

Hi!

I'm having problems to port a Python gstreamer 0.10 program to the 1.0
version. The program connects with a device (eye-tracking system) and tries
to reproduce the video sent by the scene camera. The live video from the
scene camera (full HD, 1920x1080, 25 fps), is encoded into the h.264
compression format with key-frames every 16 frames at ~5mbit and the audio
is encoded into the mp3 compressions format. It is transmitted via UDP as
mpeg-ts packets (188 bytes each).

The code for the 0.10 version, which works well is (I'm only posting the
function where the gstreamer pipeline is created, please ask if more
information is needed):

PIPELINE_DEF = "udpsrc do-timestamp=true name=src closefd=false !" \
               "mpegtsdemux !" \
               "queue !" \
               "ffdec_h264 max-threads=0 !" \
               "ffmpegcolorspace !" \
               "xvimagesink name=video"

# Create gstreamer pipeline to stream video
pipeline = gst.parse_launch(PIPELINE_DEF)

# Source element: video socket. Sockfd file for UDP reception.
socket.fileno() returns socket descriptor
src = pipeline.get_by_name("src")
src.set_property("sockfd", videoLive.fileno())

pipeline.set_state(gst.STATE_PLAYING)

For the 1.0 I'm building the pipeline using add and link instead of
parse_launch. My code is:

# Setting gstreamer pipeline
self.pipeline = Gst.Pipeline()

self.udpsrc = Gst.ElementFactory.make('udpsrc', 'src')
self.pipeline.add(self.udpsrc)
self.udpsrc.set_property('socket',
Gio.Socket().new_from_fd(self.videosocket.fileno()))

self.tsparse = Gst.ElementFactory.make('tsparse', None)
self.pipeline.add(self.tsparse)

self.demux = Gst.ElementFactory.make('tsdemux', None)
self.pipeline.add(self.demux)

self.queue = Gst.ElementFactory.make('queue', None)
self.pipeline.add(self.queue)

self.h264 = Gst.ElementFactory.make('avdec_h264', None)
self.pipeline.add(self.h264)

self.videoconvert = Gst.ElementFactory.make('videoconvert', None)
self.pipeline.add(self.videoconvert)

self.imagesink = Gst.ElementFactory.make('xvimagesink', None)
self.pipeline.add(self.imagesink)

self.udpsrc.link(self.tsparse)
self.tsparse.link(self.demux)
self.demux.link(self.queue)
self.queue.link(self.h264)
self.h264.link(self.videoconvert)
self.videoconvert.link(self.imagesink)

self.bus = self.pipeline.get_bus()
self.bus.add_signal_watch()
self.bus.connect('message::eos', self.on_eos)
self.bus.connect('message::error', self.on_error)

self.pipeline.set_state(Gst.State.PLAYING)

Nothing is shown when I execute it. I've set the debug to threshold 4,
and the output has some warnings before error is thrown:

0:00:01.937727762  9549      0x3047ca0 INFO               GST_EVENT
gstevent.c:709:gst_event_new_segment: creating segment event time
segment start=0:00:00.000000000, stop=99:99:99.999999999,
rate=1,000000, applied_rate=1,000000, flags=0x00,
time=0:00:00.000000000, base=0:00:00.000000000, position
0:00:00.000000000, duration 99:99:99.999999999
0:00:01.937776032  9549      0x3047ca0 INFO                 basesrc
gstbasesrc.c:2772:gst_base_src_loop:<src> marking pending DISCONT
0:00:02.097347324  9549      0x3047ca0 INFO        mpegtspacketizer
mpegtspacketizer.c:770:mpegts_try_discover_packet_size: have
packetsize detected: 188 bytes
0:00:02.097410369  9549      0x3047ca0 INFO              mpegtsbase
mpegtsbase.c:726:mpegts_base_apply_pat:<mpegtsparse2-0> PAT
0:00:02.098061088  9549      0x3047ca0 INFO        GST_ELEMENT_PADS
gstelement.c:897:gst_element_get_static_pad: found pad
mpegtsparse2-0:sink
0:00:02.098093377  9549      0x3047ca0 INFO               GST_EVENT
gstevent.c:628:gst_event_new_caps: creating caps event video/mpegts,
systemstream=(boolean)true, packetsize=(int)188
0:00:02.098133309  9549      0x3047ca0 INFO               GST_EVENT
gstevent.c:709:gst_event_new_segment: creating segment event time
segment start=0:00:00.000000000, stop=99:99:99.999999999,
rate=1,000000, applied_rate=1,000000, flags=0x00,
time=0:00:00.000000000, base=0:00:00.000000000, position
0:00:00.000000000, duration 99:99:99.999999999
0:00:02.098167255  9549      0x3047ca0 INFO        mpegtspacketizer
mpegtspacketizer.c:770:mpegts_try_discover_packet_size: have
packetsize detected: 188 bytes
0:00:02.098192084  9549      0x3047ca0 INFO              mpegtsbase
mpegtsbase.c:726:mpegts_base_apply_pat:<tsdemux0> PAT
0:00:02.098325493  9549      0x3047ca0 INFO        GST_ELEMENT_PADS
gstelement.c:897:gst_element_get_static_pad: found pad tsdemux0:sink
0:00:02.098340146  9549      0x3047ca0 INFO               GST_EVENT
gstevent.c:628:gst_event_new_caps: creating caps event audio/mpeg,
mpegversion=(int)1
0:00:02.098364200  9549      0x3047ca0 WARN                 default
descriptions.c:612:format_info_get_desc: Unexpected MPEG-1 layer in
audio/mpeg, mpegversion=(int)1
0:00:02.098403181  9549      0x3047ca0 INFO        GST_ELEMENT_PADS
gstelement.c:897:gst_element_get_static_pad: found pad tsdemux0:sink
0:00:02.098413243  9549      0x3047ca0 INFO               GST_EVENT
gstevent.c:628:gst_event_new_caps: creating caps event video/x-h264,
stream-format=(string)byte-stream, alignment=(string)nal
0:00:02.098489834  9549      0x3047ca0 INFO        GST_ELEMENT_PADS
gstelement.c:646:gst_element_add_pad:<tsdemux0> adding pad
'audio_0041'
0:00:02.098501372  9549      0x3047ca0 INFO               GST_EVENT
gstevent.c:709:gst_event_new_segment: creating segment event time
segment start=0:00:00.000000000, stop=99:99:99.999999999,
rate=1,000000, applied_rate=1,000000, flags=0x00,
time=0:00:00.000000000, base=0:00:00.000000000, position
0:00:00.000000000, duration 99:99:99.999999999
0:00:02.110068408  9549      0x3047ca0 INFO        GST_ELEMENT_PADS
gstelement.c:646:gst_element_add_pad:<tsdemux0> adding pad
'video_0040'
0:00:02.110145009  9549      0x3047ca0 INFO                 basesrc
gstbasesrc.c:2785:gst_base_src_loop:<src> pausing after gst_pad_push()
= not-linked
0:00:02.110162087  9549      0x3047ca0 WARN                 basesrc
gstbasesrc.c:2865:gst_base_src_loop:<src> error: Internal data flow
error.
0:00:02.110166484  9549      0x3047ca0 WARN                 basesrc
gstbasesrc.c:2865:gst_base_src_loop:<src> error: streaming task
paused, reason not-linked (-1)
0:00:02.110180920  9549      0x3047ca0 INFO        GST_ERROR_SYSTEM
gstelement.c:1835:gst_element_message_full:<src> posting message:
Internal data flow error.
0:00:02.110201183  9549      0x3047ca0 INFO        GST_ERROR_SYSTEM
gstelement.c:1858:gst_element_message_full:<src> posted error message:
Internal data flow error.
0:00:02.110291520  9549      0x3047ca0 INFO        GST_ELEMENT_PADS
gstelement.c:766:gst_element_remove_pad:<tsdemux0> removing pad
'audio_0041'
0:00:02.110323251  9549      0x3047ca0 INFO        GST_ELEMENT_PADS
gstelement.c:766:gst_element_remove_pad:<tsdemux0> removing pad
'video_0040'
0:00:02.110350647  9549      0x3047ca0 INFO                    task
gsttask.c:300:gst_task_func:<src:src> Task going to paused
('on_error():', (GError('Internal data flow error.',),
'gstbasesrc.c(2865): gst_base_src_loop ():
/GstPipeline:pipeline0/GstUDPSrc:src:\nstreaming task paused, reason
not-linked (-1)'))

I guess the warning "Unexpected MPEG-1 layer in audio/mpeg,
mpegversion=(int)1" has to do with the Internal data flow error, but I
don't know how to solve it.

Any help would be appreciate. Thanks in advance.
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <https://lists.freedesktop.org/archives/gstreamer-devel/attachments/20160615/59f84b14/attachment-0001.html>

More information about the gstreamer-devel mailing list