From 5c217f154400aca0e578a166e0a7c5f844229d99 Mon Sep 17 00:00:00 2001 From: Victor Shyba Date: Fri, 15 Feb 2019 18:56:57 -0300 Subject: [PATCH] resovle reflector IP before adding it --- lbrynet/stream/downloader.py | 24 +++++++++++++----------- 1 file changed, 13 insertions(+), 11 deletions(-) diff --git a/lbrynet/stream/downloader.py b/lbrynet/stream/downloader.py index 45c82d838..fda968234 100644 --- a/lbrynet/stream/downloader.py +++ b/lbrynet/stream/downloader.py @@ -74,19 +74,21 @@ class StreamDownloader(StreamAssembler): def add_fixed_peers(self): async def _add_fixed_peers(): - self.peer_queue.put_nowait([ - KademliaPeer(self.loop, address=(await resolve_host(url, port + 1, proto='tcp')), tcp_port=port + 1) + addresses = [ + (await resolve_host(url, port + 1, proto='tcp'), port) for url, port in self.config.reflector_servers - ]) + ] + delay = self.config.fixed_peer_delay if ( + 'dht' not in self.config.components_to_skip + and self.node and len(self.node.protocol.routing_table.get_peers()) + ) else 0.0 + self.loop.call_later(delay, lambda: + self.peer_queue.put_nowait([ + KademliaPeer(self.loop, address=address, tcp_port=port + 1) + for address, port in addresses + ])) if self.config.reflector_servers: - self.fixed_peers_handle = self.loop.call_later( - self.config.fixed_peer_delay if ( - 'dht' not in self.config.components_to_skip - and self.node - and len(self.node.protocol.routing_table.get_peers()) - ) else 0.0, - lambda: self.loop.create_task(_add_fixed_peers()) - ) + self.loop.create_task(_add_fixed_peers()) def download(self, node: typing.Optional['Node'] = None): self.node = node