Python get bus message reconnection

[philippe renon]

About not receiving messages:
You are not showing how you instantiate GstWidget and getting everything up and running.So from your code (as share), you are missing a main loop.You are also missing some important initialization steps.gobject.threads_init()
Gst.init(None)

Googling "gstreamer python tkinter" brings loads of examples with the missing parts.
 

    Le Mardi 19 septembre 2017 15h00, WisdomPill <anas.el.amraoui at live.com> a écrit :
 

 I have Tkinter application with some gstreamer pipelines to display different
streams and I'd like to detect when one of the pipelines loses connection. I
tried with bus messages but it seems to me that it doesn't post the message
at all. I created a widget to manage the gstreamer logic and the code for
the widget is the following.

    from tkinter.ttk import Widget
    
    import gi
    
    # Needed for set_window_handle():
    gi.require_version('GstVideo', '1.0')
    gi.require_version('Gst', '1.0')
    from gi.repository import Gst, GstVideo
    
    
    class GstWidget(Widget):
        def __init__(self, gst_launch_string, x, y, width, height,
master=None, **kw):
            super(GstWidget, self).__init__(master, 'frame', **kw)
    
            self.place(x=x, y=y, width=width, height=height)
    
            self.frame_id = self.winfo_id()
    
            self.player = Gst.parse_launch(gst_launch_string)
            self.player.set_state(Gst.State.PLAYING)
    
            self.bus = self.player.get_bus()
            self.bus.add_signal_watch()
            self.bus.connect('message::error', self.on_error)
            self.bus.connect('message::state-changed',
self.on_status_changed)
            self.bus.connect('message::eos', self.on_eos)
            self.bus.connect('message::info', self.on_info)
            self.bus.enable_sync_message_emission()
            self.bus.connect('sync-message::element', self.set_frame_handle)
    
        def on_status_changed(self, bus, message):
            print('status_changed message -> {}'.format(message))
    
        def on_eos(self, bus, message):
            print('eos message -> {}'.format(message))
    
        def on_info(self, bus, message):
            print('info message -> {}'.format(message))
    
        def on_error(self, bus, message):
            print('error message -> {}'.format(message.parse_error()))
    
        def play(self):
            print('Current state of my pipeline is
{}'.format(self.player.current_state))
            print('setting pipeline state to playing')
            self.player.set_state(Gst.State.PLAYING)
    
        def close(self):
            self.player.set_state(Gst.State.NULL)
    
        def is_playing(self):
            print('\t\t{}'.format(self.player.current_state))
            return self.player.current_state is not Gst.State.PLAYING
    
        def set_frame_handle(self, bus, message):
            if message.get_structure().get_name() ==
'prepare-window-handle':
                frame = message.src
                frame.set_property('force-aspect-ratio', True)
                frame.set_window_handle(self.frame_id)

Can anyone point to me where I'm wrong?
I've put breakpoints to all events and also it's not printing anything from
the events that I'd like to watch.
And also can you point me if there's any way to retry to connect the
pipeline on a lost connection?



--
Sent from: http://gstreamer-devel.966125.n4.nabble.com/
_______________________________________________
gstreamer-devel mailing list
gstreamer-devel at lists.freedesktop.org
https://lists.freedesktop.org/mailman/listinfo/gstreamer-devel


   
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <https://lists.freedesktop.org/archives/gstreamer-devel/attachments/20170919/45baae40/attachment.html>