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

improve logging from review

Browse source
This commit is contained in:
Victor Shyba 2018-07-16 16:48:46 -03:00
parent 66982c86a9
commit f510c2a433
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
lbrynet/core/HTTPBlobDownloader.py
View file

@ -45,9 +45,7 @@ class HTTPBlobDownloader(object):
@defer.inlineCallbacks
def download_blob(self, blob):
try:
blob_hash = yield self._download_blob(blob)
if blob_hash:
log.debug('Mirror completed download for %s', blob_hash)
yield self._download_blob(blob)
self.failures = 0
except Exception as exception:
self.failures += 1
@ -61,15 +59,17 @@ class HTTPBlobDownloader(object):
if not blob.get_is_verified() and not blob.is_downloading() and 'mirror' not in blob.writers:
response = yield self.client.get(url_for(choice(self.servers), blob.blob_hash))
if response.code != 200:
log.error('[Mirror] Missing a blob: %s', blob.blob_hash)
self.blob_hashes.remove(blob.blob_hash)
log.debug('[Mirror] Missing a blob: %s', blob.blob_hash)
if blob.blob_hash in self.blob_hashes:
self.blob_hashes.remove(blob.blob_hash)
defer.returnValue(blob.blob_hash)
log.debug('[Mirror] Download started: %s', blob.blob_hash)
blob.set_length(response.length)
writer, finished_deferred = blob.open_for_writing('mirror')
try:
yield self.client.collect(response, writer.write)
except Exception, e:
log.info('Mirror completed download for %s', blob.blob_hash)
except Exception as e:
writer.close(e)
yield finished_deferred
defer.returnValue(blob.blob_hash)