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

Don't fail on GStreamer EOS if no backend is running

Browse Source 
This removes the printed AssertionError when running
ScannerTest.test_data_is_set()
This commit is contained in:
Stein Magnus Jodal 2012-09-08 23:01:08 +02:00
parent f97ce0f06a
commit e57a71729a
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
mopidy/gstreamer.py
View File

@ -133,9 +133,7 @@ class GStreamer(ThreadingActor):
def _on_message(self, bus, message):
if message.type == gst.MESSAGE_EOS:
logger.debug(u'GStreamer signalled end-of-stream. '
'Telling backend ...')
self._get_backend().playback.on_end_of_track()
self._notify_backend_of_eos()
elif message.type == gst.MESSAGE_ERROR:
error, debug = message.parse_error()
logger.error(u'%s %s', error, debug)
@ -144,10 +142,14 @@ class GStreamer(ThreadingActor):
error, debug = message.parse_warning()
logger.warning(u'%s %s', error, debug)
def _get_backend(self):
def _notify_backend_of_eos(self):
backend_refs = ActorRegistry.get_by_class(Backend)
assert len(backend_refs) == 1, 'Expected exactly one running backend.'
return backend_refs[0].proxy()
assert len(backend_refs) <= 1, 'Expected at most one running backend.'
if backend_refs:
logger.debug(u'Notifying backend of end-of-stream.')
backend_refs[0].proxy().playback.on_end_of_track()
else:
logger.debug(u'No backend to notify of end-of-stream found.')
def set_uri(self, uri):
"""