From 6386815a29f354feb7d704dc7be4361f678e8806 Mon Sep 17 00:00:00 2001 From: Jack Robison Date: Fri, 8 Feb 2019 20:13:26 -0500 Subject: [PATCH] fix reflect_streams not being followed --- lbrynet/stream/stream_manager.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/lbrynet/stream/stream_manager.py b/lbrynet/stream/stream_manager.py index 2b140d669..b31882793 100644 --- a/lbrynet/stream/stream_manager.py +++ b/lbrynet/stream/stream_manager.py @@ -168,7 +168,7 @@ class StreamManager: async def reflect_streams(self): while True: - if self.config.reflector_servers: + if self.config.reflect_streams and self.config.reflector_servers: sd_hashes = await self.storage.get_streams_to_re_reflect() streams = list(filter(lambda s: s.sd_hash in sd_hashes, self.streams)) batch = [] @@ -205,7 +205,7 @@ class StreamManager: stream = await ManagedStream.create(self.loop, self.blob_manager, file_path, key, iv_generator) self.streams.add(stream) self.storage.content_claim_callbacks[stream.stream_hash] = lambda: self._update_content_claim(stream) - if self.config.reflector_servers: + if self.config.reflect_streams and self.config.reflector_servers: host, port = random.choice(self.config.reflector_servers) self.loop.create_task(stream.upload_to_reflector(host, port)) return stream