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

add error handling to blobs creation

Browse source
This commit is contained in:
Victor Shyba 2017-07-17 02:14:01 -03:00 committed by Jack Robison
parent 84bd4fdc3e
commit 5bbb29fd79
No known key found for this signature in database
GPG key ID: 284699E7404E3CFF
2 changed files with 6 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
lbrynet/core/StreamCreator.py
View file

@ -51,13 +51,18 @@ class StreamCreator(object):
current_blob = self.current_blob current_blob = self.current_blob
d = current_blob.close() d = current_blob.close()
d.addCallback(self._blob_finished) d.addCallback(self._blob_finished)
d.addErrback(self._error)
self.finished_deferreds.append(d) self.finished_deferreds.append(d)
self.current_blob = None self.current_blob = None
self._finalize() self._finalize()
dl = defer.DeferredList(self.finished_deferreds) dl = defer.DeferredList(self.finished_deferreds)
dl.addCallback(lambda _: self._finished()) dl.addCallback(lambda _: self._finished())
dl.addErrback(self._error)
return dl return dl
def _error(self, error):
log.error(error)
def _finalize(self): def _finalize(self):
pass pass

1
lbrynet/cryptstream/CryptStreamCreator.py
View file

@ -80,6 +80,7 @@ class CryptStreamCreator(StreamCreator):
def close_blob(blob): def close_blob(blob):
d = blob.close() d = blob.close()
d.addCallback(self._blob_finished) d.addCallback(self._blob_finished)
d.addErrback(self._error)
self.finished_deferreds.append(d) self.finished_deferreds.append(d)
while len(data) > 0: while len(data) > 0: