镜像自地址
https://github.com/tuna/tunasync.git
已同步 2025-12-08 15:36:47 +00:00
fix process control bug
这个提交包含在:
@@ -3,6 +3,7 @@
|
|||||||
import sh
|
import sh
|
||||||
import sys
|
import sys
|
||||||
import signal
|
import signal
|
||||||
|
import Queue
|
||||||
|
|
||||||
|
|
||||||
def run_job(sema, child_q, manager_q, provider):
|
def run_job(sema, child_q, manager_q, provider):
|
||||||
@@ -56,7 +57,7 @@ def run_job(sema, child_q, manager_q, provider):
|
|||||||
if msg == "terminate":
|
if msg == "terminate":
|
||||||
manager_q.put((provider.name, "QUIT"))
|
manager_q.put((provider.name, "QUIT"))
|
||||||
break
|
break
|
||||||
except:
|
except Queue.Empty:
|
||||||
pass
|
pass
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -207,10 +207,7 @@ class TUNASync(object):
|
|||||||
signal.signal(signal.SIGUSR2, self.reload_mirrors_force)
|
signal.signal(signal.SIGUSR2, self.reload_mirrors_force)
|
||||||
|
|
||||||
while 1:
|
while 1:
|
||||||
try:
|
|
||||||
name, status = self.channel.get()
|
name, status = self.channel.get()
|
||||||
except:
|
|
||||||
continue
|
|
||||||
|
|
||||||
if status == "QUIT":
|
if status == "QUIT":
|
||||||
print("New configuration applied to {}".format(name))
|
print("New configuration applied to {}".format(name))
|
||||||
|
|||||||
在新工单中引用
屏蔽一个用户