nemunaire/nemubot
1
0
Fork 0
Code Releases Activity

Handle multiple SIGTERM

Browse Source
This commit is contained in:
nemunaire 2017-06-23 20:07:22 +02:00
parent a624fca347
commit 1d554e0b0f
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
nemubot/bot.py
View File

@ -149,6 +149,8 @@ class Bot(threading.Thread):
def run(self): def run(self):
global sync_queue
self._poll.register(sync_queue._reader, select.POLLIN | select.POLLPRI) self._poll.register(sync_queue._reader, select.POLLIN | select.POLLPRI)
logger.info("Starting main loop") logger.info("Starting main loop")
@ -222,6 +224,7 @@ class Bot(threading.Thread):
c = Consumer(self) c = Consumer(self)
self.cnsr_thrd.append(c) self.cnsr_thrd.append(c)
c.start() c.start()
sync_queue = None
logger.info("Ending main loop") logger.info("Ending main loop")
@ -566,6 +569,7 @@ class Bot(threading.Thread):
self.datastore.close() self.datastore.close()
if self.stop is False or sync_queue is not None:
self.stop = True self.stop = True
sync_act("end") sync_act("end")
sync_queue.join() sync_queue.join()