LBRYFoundation/LBRY-Vault
1
0
Fork 0
mirror of https://github.com/LBRYFoundation/LBRY-Vault.git synced 2025-08-29 16:31:29 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

network: set .oneserver in __init__

Browse source 
fixes #6135
This commit is contained in:
SomberNight 2020-05-01 03:27:31 +02:00
parent 6f7a4ab048
commit 9ac41be1e8
No known key found for this signature in database
GPG key ID: B33B5F232C6271E9
1 changed files with 5 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
electrum/network.py
View file

@ -317,6 +317,7 @@ class Network(Logger, NetworkRetryManager[ServerAddr]):
self.auto_connect = self.config.get('auto_connect', True) self.auto_connect = self.config.get('auto_connect', True)
self._connecting = set() self._connecting = set()
self.proxy = None self.proxy = None
self._maybe_set_oneserver()
# Dump network messages (all interfaces). Set at runtime from the console. # Dump network messages (all interfaces). Set at runtime from the console.
self.debug = False self.debug = False
@ -609,9 +610,10 @@ class Network(Logger, NetworkRetryManager[ServerAddr]):
else: else:
await self.switch_lagging_interface() await self.switch_lagging_interface()
def _set_oneserver(self, oneserver: bool): def _maybe_set_oneserver(self) -> None:
oneserver = bool(self.config.get('oneserver', False))
self.oneserver = oneserver
self.num_server = NUM_TARGET_CONNECTED_SERVERS if not oneserver else 0 self.num_server = NUM_TARGET_CONNECTED_SERVERS if not oneserver else 0
self.oneserver = bool(oneserver)
async def _switch_to_random_interface(self): async def _switch_to_random_interface(self):
'''Switch to a random connected server other than the current one''' '''Switch to a random connected server other than the current one'''
@ -1135,7 +1137,7 @@ class Network(Logger, NetworkRetryManager[ServerAddr]):
self.logger.info('starting network') self.logger.info('starting network')
self._clear_addr_retry_times() self._clear_addr_retry_times()
self._set_proxy(deserialize_proxy(self.config.get('proxy'))) self._set_proxy(deserialize_proxy(self.config.get('proxy')))
self._set_oneserver(self.config.get('oneserver', False)) self._maybe_set_oneserver()
await self.taskgroup.spawn(self._run_new_interface(self.default_server)) await self.taskgroup.spawn(self._run_new_interface(self.default_server))
async def main(): async def main():