Madiator2011/lbry-sdk
1
0
Fork 0
forked from LBRYCommunity/lbry-sdk
Code Pull requests Activity

check that the stored blob is at least 1 prefix byte close to peer id

Browse source
This commit is contained in:
Victor Shyba 2022-02-11 16:18:14 -03:00
parent 4fd1fe0046
commit 4be346d0bb
1 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
lbry/extras/daemon/components.py
View file

@ -413,7 +413,8 @@ class BackgroundDownloaderComponent(Component):
self.space_available = await self.space_manager.get_free_space_mb(True) self.space_available = await self.space_manager.get_free_space_mb(True)
if not self.is_busy and self.space_available > 10: if not self.is_busy and self.space_available > 10:
blob_hash = next((key.hex() for key in self.dht_node.stored_blob_hashes if blob_hash = next((key.hex() for key in self.dht_node.stored_blob_hashes if
key.hex() not in self.blob_manager.completed_blob_hashes), None) key[0] == self.dht_node.protocol.node_id[0]
and key.hex() not in self.blob_manager.completed_blob_hashes), None)
if blob_hash: if blob_hash:
self.ongoing_download = asyncio.create_task(self.background_downloader.download_blobs(blob_hash)) self.ongoing_download = asyncio.create_task(self.background_downloader.download_blobs(blob_hash))
await asyncio.sleep(self.download_loop_delay_seconds) await asyncio.sleep(self.download_loop_delay_seconds)