mj-saunders
/
epicyon
forked from indymedia/epicyon
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Cloning the inbox thread

master
Bob Mottram 2019-09-03 11:24:15 +01:00
parent 2f85939c1d
commit ad5fb99ea7
2 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
inbox.py
View File

@ -1140,11 +1140,13 @@ def runInboxQueueWatchdog(projectVersion: str,httpd) -> None:
"""This tries to keep the inbox thread running even if it dies """This tries to keep the inbox thread running even if it dies
""" """
print('Starting inbox queue watchdog') print('Starting inbox queue watchdog')
inboxQueueOriginal=httpd.thrInboxQueue.clone()
httpd.thrInboxQueue.start() httpd.thrInboxQueue.start()
while True: while True:
time.sleep(20) time.sleep(20)
if not httpd.thrInboxQueue.isAlive(): if not httpd.thrInboxQueue.isAlive():
httpd.thrInboxQueue.kill() httpd.thrInboxQueue.kill()
httpd.thrInboxQueue=inboxQueueOriginal.clone()
httpd.thrInboxQueue.start() httpd.thrInboxQueue.start()
print('Restarting inbox queue...') print('Restarting inbox queue...')

8
threads.py
View File

@ -13,7 +13,8 @@ import time
class threadWithTrace(threading.Thread): class threadWithTrace(threading.Thread):
def __init__(self, *args, **keywords): def __init__(self, *args, **keywords):
threading.Thread.__init__(self, *args, **keywords) self._args, self._keywords = args, keywords
threading.Thread.__init__(self, *self._args, **self._keywords)
self.killed = False self.killed = False
def start(self): def start(self):
@ -40,3 +41,8 @@ class threadWithTrace(threading.Thread):
def kill(self): def kill(self):
self.killed = True self.killed = True
def clone(self):
return threadWithTrace(target=self, \
args=(self._args, self._keywords),daemon=True)
#return threadWithTrace(self, *self._args, **self._keywords)