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

bug fix: looping calls

Browse source
This commit is contained in:
Job Evers-Meltzer 2016-09-30 14:03:32 -05:00
parent 76fb7697ff
commit 48a61605de
1 changed files with 4 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
lbrynet/lbrynet_daemon/Daemon.py
View file

@ -143,7 +143,9 @@ class LoopingCallManager(object):
self.calls[name] = LoopingCall(*args) self.calls[name] = LoopingCall(*args)
def start(self, name, *args): def start(self, name, *args):
self.calls[name].start(*args) lcall = self.calls[name]
if not lcall.running:
lcall.start(*args)
def stop(self, name): def stop(self, name):
self.calls[name].stop() self.calls[name].stop()
@ -888,8 +890,6 @@ class Daemon(jsonrpc.JSONRPC):
self.analytics_manager.shutdown() self.analytics_manager.shutdown()
if self.lbry_ui_manager.update_checker.running: if self.lbry_ui_manager.update_checker.running:
self.lbry_ui_manager.update_checker.stop() self.lbry_ui_manager.update_checker.stop()
if self.pending_claim_checker.running:
self.pending_claim_checker.stop()
self._clean_up_temp_files() self._clean_up_temp_files()
@ -1962,8 +1962,7 @@ class Daemon(jsonrpc.JSONRPC):
if not os.path.isfile(file_path): if not os.path.isfile(file_path):
return defer.fail(Exception("Specified file for publish doesnt exist: %s" % file_path)) return defer.fail(Exception("Specified file for publish doesnt exist: %s" % file_path))
if not self.pending_claim_checker.running: self.looping_call_manager.start('pending_claim_checker', 30)
self.pending_claim_checker.start(30)
d = self._resolve_name(name, force_refresh=True) d = self._resolve_name(name, force_refresh=True)
d.addErrback(lambda _: None) d.addErrback(lambda _: None)