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

catch availability check error

Browse source
This commit is contained in:
Jack 2016-11-01 13:05:19 -04:00
parent d1b23e25d9
commit 4cffc32328
2 changed files with 6 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
lbrynet/reflector/client/client.py
View file

@ -99,7 +99,7 @@ class EncryptedFileReflectorClient(Protocol):
log.debug('Finished sending data via reflector') log.debug('Finished sending data via reflector')
self.factory.finished_deferred.callback(True) self.factory.finished_deferred.callback(True)
else: else:
log.debug('reflector finished: %s', reason) log.debug('Reflector finished: %s', reason)
self.factory.finished_deferred.callback(reason) self.factory.finished_deferred.callback(reason)
# IConsumer stuff # IConsumer stuff

5
lbrynet/reflector/reupload.py
View file

@ -39,7 +39,12 @@ def _reflect_if_unavailable(reflector_has_stream, lbry_file, reflector_server):
return _reflect_stream(lbry_file, reflector_server) return _reflect_stream(lbry_file, reflector_server)
def _catch_error(err):
log.error(err.getTraceback())
def check_and_restore_availability(lbry_file, reflector_server): def check_and_restore_availability(lbry_file, reflector_server):
d = _check_if_reflector_has_stream(lbry_file, reflector_server) d = _check_if_reflector_has_stream(lbry_file, reflector_server)
d.addCallback(lambda send_stream: _reflect_if_unavailable(send_stream, lbry_file, reflector_server)) d.addCallback(lambda send_stream: _reflect_if_unavailable(send_stream, lbry_file, reflector_server))
d.addErrback(_catch_error)
return d return d