home *** CD-ROM | disk | FTP | other *** search
/ Mac Easy 2010 May / Mac Life Ubuntu.iso / casper / filesystem.squashfs / usr / share / pyshared / gst-0.10 / gst / extend / sources.py < prev    next >
Encoding:
Python Source  |  2009-02-21  |  5.0 KB  |  166 lines
  1. #!/usr/bin/env python
  2. # -*- Mode: Python -*-
  3. # vi:si:et:sw=4:sts=4:ts=4
  4. #
  5. # GStreamer python bindings
  6. # Copyright (C) 2005 Edward Hervey <edward at fluendo dot com>
  7.  
  8. # This library is free software; you can redistribute it and/or
  9. # modify it under the terms of the GNU Lesser General Public
  10. # License as published by the Free Software Foundation; either
  11. # version 2.1 of the License, or (at your option) any later version.
  12. # 
  13. # This library is distributed in the hope that it will be useful,
  14. # but WITHOUT ANY WARRANTY; without even the implied warranty of
  15. # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  16. # Lesser General Public License for more details.
  17. # 
  18. # You should have received a copy of the GNU Lesser General Public
  19. # License along with this library; if not, write to the Free Software
  20. # Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
  21.  
  22. import os
  23. import sys
  24.  
  25. import gobject
  26. import pygst
  27. pygst.require('0.10')
  28. import gst
  29.  
  30. from pygobject import gsignal
  31.  
  32. EOS = 'EOS'
  33. ERROR = 'ERROR'
  34. WRONG_TYPE = 'WRONG_TYPE'
  35. UNKNOWN_TYPE = 'UNKNOWN_TYPE'
  36.  
  37. class AudioSource(gst.Bin):
  38.     """A bin for audio sources with proper audio converters"""
  39.  
  40.     gsignal('done', str)
  41.     gsignal('prerolled')
  42.  
  43.     def __init__(self, filename, caps="audio/x-raw-int,channels=2,rate=44100"):
  44.         # with pygtk 2.4 this call is needed for the gsignal to work
  45.         gst.Bin.__init__(self)
  46.  
  47.         self.filename = filename
  48.         self.outcaps = caps
  49.  
  50.         self.filesrc = gst.element_factory_make("filesrc")
  51.         self.filesrc.set_property("location", self.filename)
  52.         self.dbin = gst.element_factory_make("decodebin")
  53.         self.audioconvert = gst.element_factory_make("audioconvert")
  54.         self.audioresample = gst.element_factory_make("audioresample")
  55.         self.volume = gst.element_factory_make("volume")
  56.         
  57.         self.add(self.filesrc, self.dbin,
  58.                  self.audioconvert, self.audioresample, self.volume)
  59.         self.filesrc.link(self.dbin)
  60.         self.audioconvert.link(self.audioresample)
  61.         self.audioresample.link(self.volume, caps)
  62.         
  63.         self.dbin.connect("new-decoded-pad", self._new_decoded_pad_cb)
  64.         self.dbin.connect("unknown-type", self._unknown_type_cb)
  65.  
  66.         self._srcpad = None
  67.  
  68.     def __repr__(self):
  69.         return "<AudioSource for %s>" % self.filename
  70.         
  71.     def set_volume(self, volume):
  72.         gst.debug("setting volume to %f" % volume)
  73.         self.volume.set_property("volume", volume)
  74.  
  75.     def _new_decoded_pad_cb(self, dbin, pad, is_last):
  76.         gst.debug("new decoded pad: pad %r [%s]" % (pad, pad.get_caps().to_string()))
  77.         if not "audio" in pad.get_caps().to_string() or self._srcpad:
  78.             return
  79.  
  80.         gst.debug("linking pad %r to audioconvert" % pad)
  81.         pad.link(self.audioconvert.get_pad("sink"))
  82.  
  83.         self._srcpad = gst.GhostPad("src", self.volume.get_pad("src"))
  84.         self._srcpad.set_active(True)
  85.         self.add_pad(self._srcpad)
  86.  
  87.     def _unknown_type_cb(self, pad, caps):
  88.         self.emit('done', UNKNOWN_TYPE)
  89.  
  90.     def stop(self):
  91.         self.set_state(gst.STATE_NULL)
  92.  
  93.     def clean(self):
  94.         self.stop()
  95.         self.remove(self.filesrc)
  96.         self.remove(self.dbin)
  97.         self.remove(self.audioconvert)
  98.         self.remove(self.audioresample)
  99.         self.remove(self.volume)
  100.         self.filesrc = None
  101.         self.dbin = None
  102.         self.audioconvert = None
  103.         self.volume = None
  104.         
  105. gobject.type_register(AudioSource)
  106.  
  107.        
  108. # run us to test
  109. if __name__ == "__main__":
  110.     main = gobject.MainLoop()
  111.  
  112.     def _done_cb(source, reason):
  113.         print "Done"
  114.         sys.stdout.flush()
  115.         if reason != EOS:
  116.             print "Some error happened: %s" % reason
  117.         main.quit()
  118.  
  119.     def _error_cb(source, element, gerror, message):
  120.         print "Error: %s" % gerror
  121.         main.quit()
  122.         
  123.     try:
  124.         source = AudioSource(sys.argv[1])
  125.     except IndexError:
  126.         sys.stderr.write("Please give a filename to play\n")
  127.         sys.exit(1)
  128.  
  129.     pipeline = gst.Pipeline("playing")
  130.     # connecting on the source also catches eos emit when
  131.     # no audio pad
  132.     source.connect('done', _done_cb)
  133.     pipeline.connect('error', _error_cb)
  134.  
  135.     p = "osssink"
  136.     if len(sys.argv) > 2:
  137.         p = " ".join(sys.argv[2:])
  138.     
  139.     pipeline.add(source)
  140.     sink = gst.parse_launch(p)
  141.     pipeline.add(sink)
  142.     source.link(sink)
  143.  
  144.     # we schedule this as a timeout so that we are definately in the main
  145.     # loop when it goes to PLAYING, and errors make main.quit() work correctly
  146.     def _start(pipeline):
  147.         print "setting pipeline to PLAYING"
  148.         pipeline.set_state(gst.STATE_PLAYING)
  149.         print "set pipeline to PLAYING"
  150.  
  151.     gobject.timeout_add(0, _start, pipeline)
  152.     gobject.idle_add(pipeline.iterate)
  153.  
  154.     print "Going into main loop"
  155.     main.run()
  156.     print "Left main loop"
  157.  
  158.     pipeline.set_state(gst.STATE_NULL)
  159.     pipeline.remove(source)
  160.     pipeline.remove(sink)
  161.     utils.gc_collect('cleaned out pipeline')
  162.     source.clean()
  163.     utils.gc_collect('cleaned up source')
  164.     source = None
  165.     utils.gc_collect('set source to None')
  166.