commit 316c9185ca3e1c79002a8e59bc9da116f3a32327
author Scott Baker <smbaker@gmail.com> Tue May 05 10:18:17 2015 -0700
committer Scott Baker <smbaker@gmail.com> Tue May 05 10:18:17 2015 -0700
tree 0ce14e00b617751ce0cbf1334aaf656e2e7b2d6b
parent e05a42fa7677e1b3d4100f8b19ead90debfb3321

make observers stoppable by keyboard interrupt

xos/openstack_observer/backend.py

diff --git a/xos/openstack_observer/backend.py b/xos/openstack_observer/backend.py
index 48dae2e..23ec352 100644
--- a/xos/openstack_observer/backend.py
+++ b/xos/openstack_observer/backend.py
@@ -1,3 +1,5 @@
+import os
+import sys
 import threading
 import time
 from observer.event_loop import XOSObserver
@@ -22,6 +24,7 @@
             model_policy_thread = threading.Thread(target=run_policy)
             model_policy_thread.start()
         else:
+            model_policy_thread = None
             print "Skipping model policies thread for service observer."
 
 
@@ -29,3 +32,16 @@
         #event_manager = EventListener(wake_up=observer.wake_up)
         #event_manager_thread = threading.Thread(target=event_manager.run)
         #event_manager_thread.start()
+
+        print "entering keyboard wait loop"
+        while True:
+            try:
+                time.sleep(1000)
+            except KeyboardInterrupt:
+                print "exiting due to keyboard interrupt"
+                # TODO: See about setting the threads as daemons
+                observer_thread._Thread__stop()
+                if model_policy_thread:
+                    model_policy_thread._Threat__stop()
+                sys.exit(1)
+