andpp/mopidy
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

block gstreamer loop to avoid 100% cpu and avoid C-threads to freeze

Browse Source
This commit is contained in:
Johannes Knutsen 2010-08-10 14:52:16 +02:00
parent 2c8234f505
commit ae46832e62
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
mopidy/backends/libspotify.py
View File

@ -1,4 +1,5 @@
import datetime as dt
import gobject
import logging
import os
import multiprocessing
@ -203,14 +204,15 @@ class GstreamerMessageBusProcess(threading.Thread):
self.bus = pipeline.get_bus()
def run(self):
loop = gobject.MainLoop()
gobject.threads_init()
context = loop.get_context()
while True:
message = self.bus.pop()
message = self.bus.pop_filtered(gst.MESSAGE_EOS)
if message is not None:
logger.debug('Got Gstreamer message of type: %s' % message.type)
if message is not None and (
message.type == gst.MESSAGE_EOS
or message.type == gst.MESSAGE_ERROR):
self.core_queue.put({'command': 'end_of_track'})
logger.debug('Got and handled Gstreamer message of type: %s' % message.type)
context.iteration(True)
class LibspotifySessionManager(SpotifySessionManager, threading.Thread):
cache_location = os.path.expanduser(settings.SPOTIFY_LIB_CACHE)