From 4cffc3232890bdaba376c5c29f5cb065d5dc2cc9 Mon Sep 17 00:00:00 2001 From: Jack Date: Tue, 1 Nov 2016 13:05:19 -0400 Subject: [PATCH] catch availability check error --- lbrynet/reflector/client/client.py | 2 +- lbrynet/reflector/reupload.py | 5 +++++ 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/lbrynet/reflector/client/client.py b/lbrynet/reflector/client/client.py index 3f855af90..5c8516633 100644 --- a/lbrynet/reflector/client/client.py +++ b/lbrynet/reflector/client/client.py @@ -99,7 +99,7 @@ class EncryptedFileReflectorClient(Protocol): log.debug('Finished sending data via reflector') self.factory.finished_deferred.callback(True) else: - log.debug('reflector finished: %s', reason) + log.debug('Reflector finished: %s', reason) self.factory.finished_deferred.callback(reason) # IConsumer stuff diff --git a/lbrynet/reflector/reupload.py b/lbrynet/reflector/reupload.py index 97e401c6c..df1be0b41 100644 --- a/lbrynet/reflector/reupload.py +++ b/lbrynet/reflector/reupload.py @@ -39,7 +39,12 @@ def _reflect_if_unavailable(reflector_has_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): 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.addErrback(_catch_error) return d