stop LoopingCall()s all running at once

lowleveltgfilter v1.2.14
Simon 4 years ago
parent e3fa3265f1
commit 198377c05a
No known key found for this signature in database
GPG Key ID: 6ACF11630B5D8F82

@ -2721,7 +2721,7 @@ if __name__ == '__main__':
# Initialize the rule timer -- this if for user activated stuff # Initialize the rule timer -- this if for user activated stuff
rule_timer_task = task.LoopingCall(rule_timer_loop) rule_timer_task = task.LoopingCall(rule_timer_loop)
rule_timer = rule_timer_task.start(60) rule_timer = rule_timer_task.start(52)
rule_timer.addErrback(loopingErrHandle) rule_timer.addErrback(loopingErrHandle)
# Initialize the stream trimmer # Initialize the stream trimmer
@ -2732,25 +2732,25 @@ if __name__ == '__main__':
# Ident # Ident
#This runs in a thread so as not to block the reactor #This runs in a thread so as not to block the reactor
ident_task = task.LoopingCall(threadIdent) ident_task = task.LoopingCall(threadIdent)
identa = ident_task.start(900) identa = ident_task.start(914)
identa.addErrback(loopingErrHandle) identa.addErrback(loopingErrHandle)
#Options parsing #Options parsing
options_task = task.LoopingCall(options_config) options_task = task.LoopingCall(options_config)
options = options_task.start(30) options = options_task.start(26)
options.addErrback(loopingErrHandle) options.addErrback(loopingErrHandle)
#Mysql config checker #Mysql config checker
#This runs in a thread so as not to block the reactor #This runs in a thread so as not to block the reactor
if CONFIG['MYSQL']['USE_MYSQL'] == True: if CONFIG['MYSQL']['USE_MYSQL'] == True:
mysql_task = task.LoopingCall(threadedMysql) mysql_task = task.LoopingCall(threadedMysql)
mysql = mysql_task.start(30) mysql = mysql_task.start(33)
mysql.addErrback(loopingErrHandle) mysql.addErrback(loopingErrHandle)
#STAT trimmer - once every hour #STAT trimmer - once every hour (roughly - shifted so all timed tasks don't run at once
if CONFIG['GLOBAL']['GEN_STAT_BRIDGES']: if CONFIG['GLOBAL']['GEN_STAT_BRIDGES']:
stat_trimmer_task = task.LoopingCall(statTrimmer) stat_trimmer_task = task.LoopingCall(statTrimmer)
stat_trimmer = stat_trimmer_task.start(3600)#3600 stat_trimmer = stat_trimmer_task.start(3700)#3600
stat_trimmer.addErrback(loopingErrHandle) stat_trimmer.addErrback(loopingErrHandle)
#KA Reporting #KA Reporting

Loading…
Cancel
Save

Powered by TurnKey Linux.