- #!/usr/bin/python3
- import gi
- import signal
- from termcolor import colored
- # import GStreamer and GTK-Helper classes
- gi.require_version('Gst', '1.0')
- from gi.repository import GLib, Gst, Gtk, GObject
- # init GObject before importing local classes
- GObject.threads_init()
- Gst.init(None)
- loop = GLib.MainLoop()
- def busfunc(bus, message):
- print(colored(message.src.get_name(), 'green'), message.type, message)
- if message.type == Gst.MessageType.ERROR:
- (err, debug) = message.parse_error()
- print(colored(err, 'red'))
- print(colored(debug, 'yellow'))
-
- if message.src.get_name() == 'http':
- failover = p.get_by_name('failover')
- failover.set_property('active-pad', failover.get_static_pad('sink_1'))
- # make killable by ctrl-c
- signal.signal(signal.SIGINT, signal.SIG_DFL)
- print("parse_launch")
- p = Gst.parse_launch("""
- input-selector name=failover ! autovideosink
- videotestsrc ! video/x-raw,width=1280,height=720 ! failover.sink_1
- souphttpsrc name=http location="http://localhost/~peter/ED_1280.avi" ! decodebin ! failover.sink_0
- """)
- print("add_watch")
- bus = p.get_bus()
- bus.add_signal_watch()
- bus.connect('message', busfunc)
- # print("add_watch")
- # httpbus = p.get_by_name('http').get_bus()
- # httpbus.add_watch(0, busfunc, None)
- print("set_state(PLAYING)")
- p.set_state(Gst.State.PLAYING)
- loop.run()
|
