forked from platypush/platypush
Don't go crazy with plugin reload logic in the mpd backend in case of corrupted received messages
This commit is contained in:
parent
544979e7ff
commit
156e2e8b5a
1 changed files with 16 additions and 17 deletions
|
@ -50,25 +50,24 @@ class MusicMpdBackend(Backend):
|
|||
plugin = None
|
||||
|
||||
while not self.should_stop():
|
||||
success = False
|
||||
try:
|
||||
plugin = get_plugin('music.mpd')
|
||||
if not plugin:
|
||||
raise StopIteration
|
||||
|
||||
while not success:
|
||||
try:
|
||||
plugin = get_plugin('music.mpd')
|
||||
status = plugin.status().output
|
||||
track = plugin.currentsong().output
|
||||
state = status['state'].lower()
|
||||
playlist = status['playlist']
|
||||
success = True
|
||||
except Exception as e:
|
||||
self.logger.exception(e)
|
||||
self.logger.info('Reloading crashed MPD plugin')
|
||||
try:
|
||||
plugin = get_plugin('music.mpd', reload=True)
|
||||
except:
|
||||
pass
|
||||
status = plugin.status().output
|
||||
if not status or status.get('state') is None:
|
||||
raise StopIteration
|
||||
|
||||
time.sleep(self.poll_seconds)
|
||||
track = plugin.currentsong().output
|
||||
state = status['state'].lower()
|
||||
playlist = status['playlist']
|
||||
except StopIteration:
|
||||
pass
|
||||
except Exception as e:
|
||||
self.logger.debug(e)
|
||||
finally:
|
||||
time.sleep(self.poll_seconds)
|
||||
|
||||
if state != last_state:
|
||||
if state == 'stop':
|
||||
|
|
Loading…
Reference in a new issue