lukmangrd/platypush
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Lazy inizialitation for the Redis object in light.hue to prevent race conditions on start/stop animation

Browse source
This commit is contained in:
Fabio Manganiello 2019-01-20 00:29:58 +01:00
parent 122978c6f0
commit c7decd81f2
1 changed files with 11 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
platypush/plugins/light/hue/__init__.py
View file

@ -575,7 +575,8 @@ class LightHuePlugin(LightPlugin):
"""
if self.animation_thread and self.animation_thread.is_alive():
self.redis.rpush(self.ANIMATION_CTRL_QUEUE_NAME, 'STOP')
redis = self._get_redis()
redis.rpush(self.ANIMATION_CTRL_QUEUE_NAME, 'STOP')
@action
def animate(self, animation, duration=None,
@ -659,7 +660,8 @@ class LightHuePlugin(LightPlugin):
def _should_stop():
try:
self.redis.blpop(self.ANIMATION_CTRL_QUEUE_NAME)
redis = self._get_redis()
redis.blpop(self.ANIMATION_CTRL_QUEUE_NAME)
return True
except QueueTimeoutError:
return False
@ -707,10 +709,6 @@ class LightHuePlugin(LightPlugin):
self.animation_thread = None
self.redis = None
redis_args = get_backend('redis').redis_args
redis_args['socket_timeout'] = transition_seconds
self.redis = Redis(**redis_args)
if groups:
groups = [g for g in self.bridge.groups if g.name in groups]
lights = lights or []
@ -725,6 +723,13 @@ class LightHuePlugin(LightPlugin):
args=(lights,))
self.animation_thread.start()
def _get_redis(self):
if not self.redis:
redis_args = get_backend('redis').redis_args
redis_args['socket_timeout'] = transition_seconds
self.redis = Redis(**redis_args)
return self.redis
# vim:sw=4:ts=4:et: