--- a/script/stream/recorder_tweetstream.py Thu Aug 18 00:30:15 2011 +0200
+++ b/script/stream/recorder_tweetstream.py Wed Aug 24 18:04:26 2011 +0200
@@ -391,9 +391,13 @@
tweet_processes.append(cprocess)
def interupt_handler(signum, frame):
+ utils.get_logger().debug("shutdown asked " + repr(signum) + " " + repr(frame))
stop_event.set()
- signal.signal(signal.SIGINT, interupt_handler)
+ signal.signal(signal.SIGINT , interupt_handler)
+ signal.signal(signal.SIGHUP , interupt_handler)
+ signal.signal(signal.SIGALRM, interupt_handler)
+ signal.signal(signal.SIGTERM, interupt_handler)
log_thread = threading.Thread(target=process_log, name="loggingThread", args=(logger_queues,stop_event,))
log_thread.daemon = True