From: Antonio Ospite Date: Wed, 17 Sep 2014 10:54:56 +0000 (+0200) Subject: gst-trick-mode.py: port to GStreamer 1.0 X-Git-Url: https://git.ao2.it/experiments/gstreamer.git/commitdiff_plain/d6c6f1da71c2d875f82a829c63af0a6131b83932 gst-trick-mode.py: port to GStreamer 1.0 --- diff --git a/python/gst-trick-mode.py b/python/gst-trick-mode.py index a4e063f..e50e252 100755 --- a/python/gst-trick-mode.py +++ b/python/gst-trick-mode.py @@ -5,10 +5,13 @@ import sys -import gobject -gobject.threads_init() +import gi +gi.require_version('Gst', '1.0') +from gi.repository import Gst +Gst.init(None) -import gst +from gi.repository import GObject +GObject.threads_init() class Player: @@ -16,7 +19,7 @@ class Player: self._filename = filename self._rate = rate - self._player = gst.element_factory_make("playbin2", "player") + self._player = Gst.ElementFactory.make("playbin", "player") self._player.set_property("uri", filename) bus = self._player.get_bus() @@ -24,8 +27,8 @@ class Player: bus.connect('message::state-changed', self.on_state_changed) def run(self): - self._player.set_state(gst.STATE_PLAYING) - loop = gobject.MainLoop() + self._player.set_state(Gst.State.PLAYING) + loop = GObject.MainLoop() loop.run() def on_state_changed(self, bus, msg): @@ -35,35 +38,35 @@ class Player: print 'on_state_changed' old_state, new_state, pending = msg.parse_state_changed() print "%s -> %s" % (old_state, new_state) - if old_state == gst.STATE_READY and new_state == gst.STATE_PAUSED: + if old_state == Gst.State.READY and new_state == Gst.State.PAUSED: self.set_rate(self._rate) def set_rate(self, rate): self._rate = rate try: - position, format = self._player.query_position(gst.FORMAT_TIME) + position, fmt = self._player.query_position(Gst.Format.TIME) except: position = 0 # Create the seek event if rate > 0: - seek_event = gst.event_new_seek(rate, - gst.FORMAT_TIME, - gst.SEEK_FLAG_FLUSH | gst.SEEK_FLAG_ACCURATE, - gst.SEEK_TYPE_SET, position, - gst.SEEK_TYPE_NONE, 0) + seek_event = Gst.Event.new_seek(rate, + Gst.Format.TIME, + Gst.SeekFlags.FLUSH | Gst.SeekFlags.ACCURATE, + Gst.SeekType.SET, position, + Gst.SeekType.NONE, 0) else: - seek_event = gst.event_new_seek(rate, - gst.FORMAT_TIME, - gst.SEEK_FLAG_FLUSH | gst.SEEK_FLAG_ACCURATE, - gst.SEEK_TYPE_SET, 0, - gst.SEEK_TYPE_SET, position) + seek_event = Gst.Event.new_seek(rate, + Gst.Format.TIME, + Gst.SeekFlags.FLUSH | Gst.SeekFlags.ACCURATE, + Gst.SeekType.SET, 0, + Gst.SeekType.SET, position) if seek_event: self._player.send_event(seek_event) - gst.info("rate set to %s" % rate) + Gst.info("rate set to %s" % rate) else: - gst.warining("change rate failed") + Gst.warining("change rate failed") def main(args): @@ -74,7 +77,7 @@ def main(args): usage() sys.exit(1) - if not gst.uri_is_valid(args[1]): + if not Gst.uri_is_valid(args[1]): sys.stderr.write("Error: Invalid URI: %s\n" % args[1]) sys.exit(1)