light9 Changeset - fc14e2e87e9e

Changeset - fc14e2e87e9e

Parent rev.

Child rev.

[Not reviewed]

default

0 1 0

drewp@bigasterisk.com - 15 years ago 2010-06-15 05:44:32
drewp@bigasterisk.com

add preload safety to ascoltami2
Ignore-this: e60dad9c288f05ed91acd2a2ed827389

1 file changed with 14 insertions and 0 deletions:

light9/ascoltami/player.py

0 comments (0 inline, 0 general)

light9/ascoltami/player.py

➞

Show inline comments

@@ @@ -18,90 +18,104 @@ class Player(object): @@
         # before playbin2:
         #self.pipeline = gst.parse_launch("filesrc name=file location=%s ! wavparse name=src ! audioconvert ! alsasink name=out" % songFile)
         gobject.timeout_add(50, self.watchTime)
         bus = self.pipeline.get_bus()
         bus.add_signal_watch()
         def on_any(bus, msg):
             print bus, msg
         #bus.connect('message', on_any)
         def onStreamStatus(bus, message):
             (statusType, _elem) = message.parse_stream_status()
             if statusType == gst.STREAM_STATUS_TYPE_ENTER:
                 self.setupAutostop()
         bus.connect('message::stream-status', onStreamStatus)
     def watchTime(self):
         try:
             try:
                 t = self.currentTime()
             except gst.QueryError:
                 return True
             log.debug("watch %s < %s < %s",
                       self.lastWatchTime, self.autoStopTime, t)
             if self.lastWatchTime < self.autoStopTime < t:
                 log.info("autostop")
                 self.pause()
             self.lastWatchTime = t
         except:
             traceback.print_exc()
         return True
     def seek(self, t):
         assert self.playbin.seek_simple(
             gst.FORMAT_TIME,
             gst.SEEK_FLAG_FLUSH | gst.SEEK_FLAG_ACCURATE | gst.SEEK_FLAG_SKIP,
             t * gst.SECOND)
         self.playStartTime = time.time()
     def setSong(self, songUri):
         """
         uri like file:///my/proj/light9/show/dance2010/music/07.wav
         """
         log.info("set song to %r" % songUri)
         self.pipeline.set_state(gst.STATE_READY)
         self.preload(songUri)
         self.pipeline.set_property("uri", songUri)
         # todo: don't have any error report yet if the uri can't be read
         self.pipeline.set_state(gst.STATE_PLAYING)
         self.playStartTime = time.time()
     def preload(self, songUri):
         """
         to avoid disk seek stutters, which happened sometimes (in 2007) with the
         non-gst version of this program, we read the whole file to get
         more OS caching.
         i don't care that it's blocking.
         """
         assert songUri.startswith('file://')
         p = songUri[len('file://'):]
         log.info("preloading %s", p)
         open(p).read()
     def currentTime(self):
         try:
             cur, _format = self.playbin.query_position(gst.FORMAT_TIME)
         except gst.QueryError:
             return 0
         return cur / gst.SECOND
     def duration(self):
         try:
             return self.playbin.query_duration(gst.FORMAT_TIME)[0] / gst.SECOND
         except gst.QueryError:
             return 0
     def pause(self):
         self.pipeline.set_state(gst.STATE_PAUSED)
     def resume(self):
         self.pipeline.set_state(gst.STATE_PLAYING)
         pos = self.currentTime()
         autoStop = self.duration() - self.autoStopOffset
         if abs(pos - autoStop) < .01:
             self.releaseAutostop()
     def setupAutostop(self):
         dur = self.duration()
         self.autoStopTime = (dur - self.autoStopOffset)
         log.info("autostop will be at %s", self.autoStopTime)
         # pipeline.seek can take a stop time, but using that wasn't
         # working out well. I'd get pauses at other times that were
         # hard to remove.
     def isPlaying(self):
         _, state, _ = self.pipeline.get_state()
         return state == gst.STATE_PLAYING

0 comments (0 inline, 0 general)