gstreamer/examples/pipeline-tester
Andy Wingo b27e9ba001 examples/: Updates for bus API.
Original commit message from CVS:
2005-09-29  Andy Wingo  <wingo@pobox.com>

* examples/pipeline-tester (Window.play):
* examples/vumeter.py (Window.run): Updates for bus API.
2005-09-29 16:38:06 +00:00

264 lines
8.7 KiB
Python
Executable file

#!/usr/bin/env python
#
# gst-python
# Copyright (C) 2005 Andy Wingo <wingo@pobox.com>
#
# This library is free software; you can redistribute it and/or
# modify it under the terms of the GNU Library General Public
# License as published by the Free Software Foundation; either
# version 2 of the License, or (at your option) any later version.
#
# This library is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
# Library General Public License for more details.
#
# You should have received a copy of the GNU Library General Public
# License along with this library; if not, write to the
# Free Software Foundation, Inc., 59 Temple Place - Suite 330,
# Boston, MA 02111-1307, USA.
# A test more of gst-plugins than of gst-python.
import sys
import pygtk
pygtk.require('2.0')
import gtk
import gtk.gdk
import pango
import gobject
import pygst
pygst.require('0.9')
import gst
import debugslider
data = (('Video capture via V4L',
'v4lsrc name=source \n'
' ! videorate \n'
' ! xvimagesink'),
('Video capture via V4L, fixed frame rate',
'v4lsrc name=source autoprobe=false autoprobe-fps=false \n'
' ! video/x-raw-yuv,format=(fourcc)I420,framerate=(double)7.5 \n'
' ! videorate \n'
' ! ffmpegcolorspace \n'
' ! xvimagesink'),
('Sound capture via ALSA',
'alsasrc\n'
' ! audio/x-raw-int,rate=22050,depth=16,channels=1,width=16,signed=(boolean)TRUE,endianness=1234\n'
' ! level message=true\n'
' ! fakesink'),
('Streaming Ogg/Theora+Vorbis playback, tee to disk',
'gnomevfssrc location=http://gstreamer.freedesktop.org/media/small/cooldance.ogg \n'
' ! tee name=tee \n'
' tee. ! oggdemux name=demux \n'
' demux. ! queue ! theoradec ! xvimagesink \n'
' demux. ! queue ! vorbisdec ! audioconvert ! alsasink \n'
' tee. ! queue ! filesink location=cooldance.ogg'),
('Video test, YUV format',
'videotestsrc \n'
' ! video/x-raw-yuv,format=(fourcc)I420 \n'
' ! xvimagesink'),
('Video test, RGB format',
'videotestsrc \n'
' ! video/x-raw-rgb,red_mask=0xff00 \n'
' ! ximagesink'),
('Reencode Vorbis to mulaw, play via ALSA',
'filesrc location=cooldance.ogg \n'
' ! oggdemux \n'
' ! vorbisdec ! audioconvert \n'
' ! mulawenc ! mulawdec ! alsasink'),
('Capture DV via firewire, transcode into Ogg',
'dv1394src \n'
' ! dvdemux name=demux \n'
' ! queue \n'
' ! video/x-dv,systemstream=(boolean)false \n'
' ! dvdec drop-factor=2 \n'
' ! videorate \n'
' ! videoscale \n'
' ! video/x-raw-yuv,width=360,height=288 \n'
' ! videoscale \n'
' ! video/x-raw-yuv,width=240,height=192,framerate=10.0,format=(fourcc)YUY2 \n'
' ! ffmpegcolorspace \n'
' ! theoraenc \n'
' ! oggmux name=mux \n'
' ! filesink location=dv.ogg \n'
' \n'
' demux. \n'
' ! audio/x-raw-int \n'
' ! queue \n'
' ! audioconvert \n'
' ! vorbisenc \n'
' ! mux.'))
def escape(s, chars, escaper='\\'):
for c in chars:
s = s.replace(c, '%s%s' % (escaper, c))
return s
def make_model():
m = gtk.ListStore(str, str)
for pair in data:
i = m.append()
m.set_value(i, 0, pair[0])
m.set_value(i, 1, pair[1])
return m
class Window(gtk.Window):
def __init__(self):
gtk.Window.__init__(self, gtk.WINDOW_TOPLEVEL)
self.playing = False
self.selected_pipe = None
self.pipeline = None
self.prepare_ui()
def prepare_ui(self):
self.set_default_size(300,400)
self.set_title('GStreamer Pipeline Tester')
self.set_type_hint(gtk.gdk.WINDOW_TYPE_HINT_DIALOG)
self.connect('delete-event', lambda *x: gtk.main_quit())
self.set_border_width(18)
b = gtk.VBox(False, 12)
b.show()
self.add(b)
l = gtk.Label()
l.set_markup('<big><b>GStreamer Pipeline Tester</b></big>')
l.show()
b.pack_start(l, False, False, 6)
l = gtk.Label('Choose a pipeline below to run.')
l.show()
b.pack_start(l, False, False, 0)
sw = gtk.ScrolledWindow()
sw.set_policy(gtk.POLICY_NEVER, gtk.POLICY_NEVER)
sw.set_shadow_type(gtk.SHADOW_IN)
sw.show()
b.pack_start(sw, True, True, 6)
tv = gtk.TreeView(make_model())
tv.set_property('can-default', False)
r = gtk.CellRendererText()
r.set_property('xalign', 0.5)
c = gtk.TreeViewColumn('System', r, text=0)
tv.append_column(c)
tv.set_headers_visible(False)
tv.show()
sw.add(tv)
ds = debugslider.DebugSlider()
ds.show()
b.pack_start(ds, False, False, 0)
l = gtk.Label()
l.set_selectable(True)
l.show()
b.pack_start(l, False, False, 0)
bb = gtk.HButtonBox()
bb.set_layout(gtk.BUTTONBOX_SPREAD)
bb.show()
b.pack_start(bb, False, False, 0)
bu = gtk.Button(stock=gtk.STOCK_MEDIA_PLAY)
bu.set_property('can-default', True)
bu.set_focus_on_click(False)
bu.show()
bb.pack_start(bu, True, False, 0)
bu.set_property('has-default', True)
self.button = bu
def on_changed(s):
m, i = s.get_selected()
if m:
self.selected_pipe = m.get_value(i, 1)
pasteable = escape(self.selected_pipe, '\n)(')
l.set_markup('<small><tt>%s</tt></small>' % pasteable)
else:
self.selected_pipe = None
l.set_markup('')
tv.get_selection().connect('changed', on_changed)
tv.connect('row-activated', lambda *x: self.play_toggled())
bu.connect('clicked', lambda *x: self.play_toggled())
def error(self, message, secondary=None):
m = gtk.MessageDialog(self,
gtk.DIALOG_MODAL | gtk.DIALOG_DESTROY_WITH_PARENT,
gtk.MESSAGE_ERROR,
gtk.BUTTONS_OK,
message)
if secondary:
m.format_secondary_text(secondary)
m.run()
m.destroy()
def on_message(self, bus, message):
t = message.type
if t == gst.MESSAGE_STATE_CHANGED:
pass
elif t == gst.MESSAGE_ERROR:
err, debug = message.parse_error()
self.error("%s" % err, debug)
elif t == gst.MESSAGE_EOS:
self.play_toggled()
else:
print '%s: %s:' % (message.src.get_path_string(),
message.type.value_nicks[1])
if message.structure:
print ' %s' % message.structure.to_string()
else:
print ' (no structure)'
return True
def play(self):
pipestr = self.selected_pipe
try:
self.set_sensitive(False)
pipeline = gst.parse_launch(pipestr)
self.set_sensitive(True)
except gobject.GError, e:
self.set_sensitive(True)
self.error('Could not create pipeline', str(e))
return False
bus = pipeline.get_bus()
bus.add_signal_watch()
watch_id = bus.connect('message', self.on_message)
if pipeline.set_state(gst.STATE_PLAYING) != gst.STATE_CHANGE_SUCCESS:
# make sure we get error messages
while gtk.events_pending():
gtk.main_iteration()
pipeline.set_state(gst.STATE_NULL)
bus.remove_signal_watch()
bus.disconnect(watch_id)
return False
else:
self.pipeline = pipeline
self.watch_id = watch_id
return True
def stop(self):
bus = self.pipeline.get_bus()
bus.disconnect(self.watch_id)
bus.remove_signal_watch()
self.pipeline.set_state(gst.STATE_NULL)
self.pipeline = None
del self.watch_id
def play_toggled(self):
if self.playing:
self.stop()
self.button.set_label(gtk.STOCK_MEDIA_PLAY)
self.playing = False
else:
if self.play():
self.playing = True
self.button.set_label(gtk.STOCK_MEDIA_STOP)
if __name__ == '__main__':
w = Window()
w.show()
gtk.main()