yacloud/tunasync
1
0
Fork 0
mirror of https://github.com/tuna/tunasync.git synced 2025-06-13 04:17:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

bug fix

Browse Source
This commit is contained in:
bigeagle 2014-10-18 11:22:59 +08:00
parent 95e546c9f0
commit e4a0790c66
1 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
tunasync/jobs.py
View File

@ -1,7 +1,6 @@
#!/usr/bin/env python2 #!/usr/bin/env python2
# -*- coding:utf-8 -*- # -*- coding:utf-8 -*-
import sys import sys
import time
import signal import signal
@ -36,18 +35,18 @@ def run_job(sema, child_q, manager_q, provider):
sema.release() sema.release()
aquired = False aquired = False
print("syncing {} finished, sleep {} minutes for the next turn".format(
provider.name, provider.interval
))
try: try:
msg = child_q.get(timeout=1) msg = child_q.get(timeout=provider.interval * 60)
if msg == "terminate": if msg == "terminate":
manager_q.put((provider.name, "QUIT")) manager_q.put((provider.name, "QUIT"))
break break
except: except:
pass pass
print("syncing {} finished, sleep {} minutes for the next turn".format(
provider.name, provider.interval
))
time.sleep(provider.interval * 60)
# vim: ts=4 sw=4 sts=4 expandtab # vim: ts=4 sw=4 sts=4 expandtab