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

fix stop_lbry_files

Browse source
This commit is contained in:
Jack Robison 2018-08-12 22:04:55 -04:00
parent 153022a1a7
commit 5b7f7c87bf
No known key found for this signature in database
GPG key ID: DF25C68FE0239BB2
1 changed files with 3 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
lbrynet/file_manager/EncryptedFileManager.py
View file

@ -147,11 +147,10 @@ class EncryptedFileManager(object):
finally: finally:
defer.returnValue(None) defer.returnValue(None)
@defer.inlineCallbacks
def _stop_lbry_files(self): def _stop_lbry_files(self):
log.info("Stopping %i lbry files", len(self.lbry_files)) log.info("Stopping %i lbry files", len(self.lbry_files))
lbry_files = self.lbry_files yield defer.DeferredList([self._stop_lbry_file(lbry_file) for lbry_file in list(self.lbry_files)])
for lbry_file in lbry_files:
yield self._stop_lbry_file(lbry_file)
@defer.inlineCallbacks @defer.inlineCallbacks
def add_published_file(self, stream_hash, sd_hash, download_directory, payment_rate_manager, blob_data_rate): def add_published_file(self, stream_hash, sd_hash, download_directory, payment_rate_manager, blob_data_rate):
@ -251,6 +250,6 @@ class EncryptedFileManager(object):
@defer.inlineCallbacks @defer.inlineCallbacks
def stop(self): def stop(self):
safe_stop_looping_call(self.lbry_file_reflector) safe_stop_looping_call(self.lbry_file_reflector)
yield defer.DeferredList(list(self._stop_lbry_files())) yield self._stop_lbry_files()
log.info("Stopped encrypted file manager") log.info("Stopped encrypted file manager")
defer.returnValue(True) defer.returnValue(True)