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

catch IOError when writing

Browse source
This commit is contained in:
Kay Kurokawa 2017-09-15 14:17:34 -04:00 committed by Jack Robison
parent 85f25a8d99
commit ea49cddf52
No known key found for this signature in database
GPG key ID: 284699E7404E3CFF
1 changed files with 8 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
lbrynet/core/client/ClientProtocol.py
View file

@ -51,7 +51,14 @@ class ClientProtocol(Protocol, TimeoutMixin):
self.setTimeout(None) self.setTimeout(None)
self._rate_limiter.report_dl_bytes(len(data)) self._rate_limiter.report_dl_bytes(len(data))
if self._downloading_blob is True: if self._downloading_blob is True:
try:
self._blob_download_request.write(data) self._blob_download_request.write(data)
except IOError as e:
#TODO: we need to fix this so that we do not even
#attempt to download the same blob from different peers
msg = "Failed to write, blob is likely closed by another peer finishing download"
log.warn(msg)
self.transport.loseConnection()
else: else:
self._response_buff += data self._response_buff += data
if len(self._response_buff) > conf.settings['MAX_RESPONSE_INFO_SIZE']: if len(self._response_buff) > conf.settings['MAX_RESPONSE_INFO_SIZE']: