LBRYFoundation/lbry-sdk
1
0
Fork 0
mirror of https://github.com/LBRYFoundation/lbry-sdk.git synced 2025-08-30 17:01:28 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

logging

Browse source
This commit is contained in:
Jack Robison 2019-02-04 16:09:50 -05:00
parent c85991704d
commit 8883587cc7
No known key found for this signature in database
GPG key ID: DF25C68FE0239BB2
2 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
lbrynet/blob_exchange/client.py
View file

@ -105,8 +105,8 @@ class BlobExchangeClientProtocol(asyncio.Protocol):
log.debug(msg) log.debug(msg)
msg = f"downloaded {self.blob.blob_hash[:8]} from {self.peer_address}:{self.peer_port}" msg = f"downloaded {self.blob.blob_hash[:8]} from {self.peer_address}:{self.peer_port}"
await asyncio.wait_for(self.writer.finished, self.peer_timeout, loop=self.loop) await asyncio.wait_for(self.writer.finished, self.peer_timeout, loop=self.loop)
await self.blob.finished_writing.wait()
log.info(msg) log.info(msg)
await self.blob.finished_writing.wait()
return True, True return True, True
except asyncio.CancelledError: except asyncio.CancelledError:
return False, True return False, True

2
lbrynet/blob_exchange/downloader.py
View file

@ -87,7 +87,7 @@ class BlobDownloader:
if task and not task.done(): if task and not task.done():
task.cancel() task.cancel()
await blob.close() await blob.close()
log.info("downloaded %s", blob_hash[:8]) log.debug("downloaded %s", blob_hash[:8])
return blob return blob
except asyncio.CancelledError: except asyncio.CancelledError:
while self.active_connections: while self.active_connections: