add fixed peers immediately if dht is skipped
This commit is contained in:
parent
34776e7eb9
commit
e8a1953815
1 changed files with 4 additions and 2 deletions
|
@ -82,8 +82,10 @@ class StreamDownloader(StreamAssembler):
|
||||||
for url, port in self.config.reflector_servers
|
for url, port in self.config.reflector_servers
|
||||||
])
|
])
|
||||||
if self.config.reflector_servers:
|
if self.config.reflector_servers:
|
||||||
self.fixed_peers_handle = self.loop.call_later(self.config.fixed_peer_delay, self.loop.create_task,
|
self.fixed_peers_handle = self.loop.call_later(
|
||||||
_add_fixed_peers())
|
self.config.fixed_peer_delay if 'dht' not in self.config.components_to_skip else 0.0,
|
||||||
|
self.loop.create_task, _add_fixed_peers()
|
||||||
|
)
|
||||||
|
|
||||||
def download(self, node: typing.Optional['Node'] = None):
|
def download(self, node: typing.Optional['Node'] = None):
|
||||||
self.node = node
|
self.node = node
|
||||||
|
|
Loading…
Reference in a new issue