mirror of
https://github.com/LBRYFoundation/LBRY-Vault.git
synced 2025-08-31 17:31:36 +00:00
interface: minor clean-up re timeouts
This commit is contained in:
parent
6b9a83ae80
commit
518c6280e9
1 changed files with 4 additions and 2 deletions
|
@ -284,7 +284,9 @@ class Interface(PrintError):
|
||||||
return None
|
return None
|
||||||
|
|
||||||
async def get_block_header(self, height, assert_mode):
|
async def get_block_header(self, height, assert_mode):
|
||||||
res = await self.session.send_request('blockchain.block.header', [height], timeout=5)
|
# use lower timeout as we usually have network.bhi_lock here
|
||||||
|
timeout = 5 if not self.proxy else 10
|
||||||
|
res = await self.session.send_request('blockchain.block.header', [height], timeout=timeout)
|
||||||
return blockchain.deserialize_header(bytes.fromhex(res), height)
|
return blockchain.deserialize_header(bytes.fromhex(res), height)
|
||||||
|
|
||||||
async def request_chunk(self, idx, tip):
|
async def request_chunk(self, idx, tip):
|
||||||
|
@ -317,7 +319,7 @@ class Interface(PrintError):
|
||||||
async def ping(self):
|
async def ping(self):
|
||||||
while True:
|
while True:
|
||||||
await asyncio.sleep(300)
|
await asyncio.sleep(300)
|
||||||
await self.session.send_request('server.ping', timeout=10)
|
await self.session.send_request('server.ping')
|
||||||
|
|
||||||
def close(self):
|
def close(self):
|
||||||
self.fut.cancel()
|
self.fut.cancel()
|
||||||
|
|
Loading…
Add table
Reference in a new issue