389 logger_queues.append(lqueue) |
389 logger_queues.append(lqueue) |
390 cprocess = TweetProcess(SessionProcess, queue, options, access_token, stop_event, lqueue) |
390 cprocess = TweetProcess(SessionProcess, queue, options, access_token, stop_event, lqueue) |
391 tweet_processes.append(cprocess) |
391 tweet_processes.append(cprocess) |
392 |
392 |
393 def interupt_handler(signum, frame): |
393 def interupt_handler(signum, frame): |
|
394 utils.get_logger().debug("shutdown asked " + repr(signum) + " " + repr(frame)) |
394 stop_event.set() |
395 stop_event.set() |
395 |
396 |
396 signal.signal(signal.SIGINT, interupt_handler) |
397 signal.signal(signal.SIGINT , interupt_handler) |
|
398 signal.signal(signal.SIGHUP , interupt_handler) |
|
399 signal.signal(signal.SIGALRM, interupt_handler) |
|
400 signal.signal(signal.SIGTERM, interupt_handler) |
397 |
401 |
398 log_thread = threading.Thread(target=process_log, name="loggingThread", args=(logger_queues,stop_event,)) |
402 log_thread = threading.Thread(target=process_log, name="loggingThread", args=(logger_queues,stop_event,)) |
399 log_thread.daemon = True |
403 log_thread.daemon = True |
400 |
404 |
401 sprocess.start() |
405 sprocess.start() |