X-Git-Url: https://git.kaliko.me/?a=blobdiff_plain;f=sima%2Fplugins%2Fcore%2Funiq.py;h=0f42718ed992b89f8516788ea525e275269d773c;hb=ac0d934fc127484a0ed14386e4c4ecd4f915b6ca;hp=1abdd62a8f492ee805f53f877afc4d34567f80ba;hpb=5a10f68f5d4b6bda63db74f205e6024d48c60e51;p=mpd-sima.git diff --git a/sima/plugins/core/uniq.py b/sima/plugins/core/uniq.py index 1abdd62..0f42718 100644 --- a/sima/plugins/core/uniq.py +++ b/sima/plugins/core/uniq.py @@ -42,14 +42,15 @@ class Uniq(Plugin): Plugin.__init__(self, daemon) self.chan = 'mpd_sima:{0}.{1}'.format(getfqdn(), getpid()) self.channels = [] - self.uniq = True + self._registred = False def start(self): if not self.is_capable(): self.log.warning('MPD does not provide client to client') return self.is_uniq() - self.sub_chan() + if not self._registred: + self.sub_chan() def is_capable(self): if {'channels', 'subscribe'}.issubset(set(self.player.commands())): @@ -67,11 +68,11 @@ class Uniq(Plugin): if channels: self.log.warning('Another instance is queueing on this MPD host') self.log.warning(' '.join(channels)) - self.uniq = False def sub_chan(self): self.log.debug('Registering as {}'.format(self.chan)) self.player.subscribe(self.chan) + self._registred = True def callback_need_track(self): if self.is_capable():