LBRYCommunity/lbry-sdk
1
0
Fork 1
Code Issues Pull requests Projects Releases 282 Packages Wiki Activity

use timeout in Daemon._download_blob()

Browse source
This commit is contained in:
Kay Kurokawa 2017-06-21 13:35:15 -04:00
parent 73927e2b57
commit 36dea2afbf
1 changed files with 1 additions and 15 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
lbrynet/daemon/Daemon.py
View file

@ -599,26 +599,12 @@ class Daemon(AuthJSONRPCServer):
:param timeout (int): blob timeout :param timeout (int): blob timeout
:return: BlobFile :return: BlobFile
""" """
def cb(blob):
if not finished_d.called:
finished_d.callback(blob)
def eb():
if not finished_d.called:
finished_d.errback(Exception("Blob (%s) download timed out" %
blob_hash[:SHORT_ID_LEN]))
if not blob_hash: if not blob_hash:
raise Exception("Nothing to download") raise Exception("Nothing to download")
rate_manager = rate_manager or self.session.payment_rate_manager rate_manager = rate_manager or self.session.payment_rate_manager
timeout = timeout or 30 timeout = timeout or 30
finished_d = defer.Deferred(None) return download_sd_blob(self.session, blob_hash, rate_manager, timeout)
reactor.callLater(timeout, eb)
d = download_sd_blob(self.session, blob_hash, rate_manager)
d.addCallback(cb)
return finished_d
@defer.inlineCallbacks @defer.inlineCallbacks
def _download_name(self, name, claim_dict, claim_id, timeout=None, file_name=None): def _download_name(self, name, claim_dict, claim_id, timeout=None, file_name=None):