From 36593a8d40cd1417d2927a78cdbe621090b6e8a5 Mon Sep 17 00:00:00 2001
From: ianb <devnull@localhost>
Date: Fri, 22 Apr 2005 03:18:20 +0000
Subject: Renamed package itself

---
 paste/reloader.py | 111 ++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 111 insertions(+)
 create mode 100644 paste/reloader.py

(limited to 'paste/reloader.py')

diff --git a/paste/reloader.py b/paste/reloader.py
new file mode 100644
index 0000000..4753f90
--- /dev/null
+++ b/paste/reloader.py
@@ -0,0 +1,111 @@
+"""
+Use this like::
+
+    import reloader
+    reloader.install()
+
+Then make sure your server is installed with a shell script like::
+
+    err=3
+    while test "$err" -eq 3 ; do
+        python server.py
+        err="$?"
+    done
+
+or restart in Python (server.py does this).  Use the watch_file(filename)
+function to cause a reload/restart for other other non-Python files (e.g.,
+configuration files).
+"""
+
+import os
+import sys
+import time
+import threading
+import atexit
+from paste.util.classinstance import classinstancemethod
+
+def install(poll_interval=1, raise_keyboard_interrupt=True):
+    mon = Monitor(poll_interval=poll_interval,
+                  raise_keyboard_interrupt=raise_keyboard_interrupt)
+    t = threading.Thread(target=mon.periodic_reload)
+    t.start()
+    
+class Monitor:
+
+    instances = []
+
+    def __init__(self, poll_interval, raise_keyboard_interrupt):
+        self.module_mtimes = {}
+        atexit.register(self.atexit)
+        self.keep_running = True
+        self.poll_interval = poll_interval
+        self.raise_keyboard_interrupt = raise_keyboard_interrupt
+        self.extra_files = []
+        self.instances.append(self)
+
+    def atexit(self):
+        self.keep_running = False
+        if self.raise_keyboard_interrupt:
+            # This exception is somehow magic, because it applies
+            # to more threads and situations (like socket.accept)
+            # that a mere SystemExit will not.
+            raise KeyboardInterrupt("Exiting process")
+
+    def periodic_reload(self):
+        while 1:
+            if not self.keep_running:
+                break
+            if not self.check_reload():
+                os._exit(3)
+                break
+            time.sleep(self.poll_interval)
+
+    def check_reload(self):
+        filenames = self.extra_files[:]
+        for name, module in sys.modules.items():
+            try:
+                filenames.append(module.__file__)
+            except AttributeError:
+                continue
+        for filename in filenames:
+            mtime = os.stat(filename).st_mtime
+            if filename.endswith('.pyc') and os.path.exists(filename[:-1]):
+                mtime = max(os.stat(filename[:-1]).st_mtime, mtime)
+            if not self.module_mtimes.has_key(filename):
+                self.module_mtimes[filename] = mtime
+            elif self.module_mtimes[filename] < mtime:
+                print >> sys.stderr, (
+                    "%s changed; reloading..." % filename)
+                return False
+        return True
+
+    def watch_file(self, cls, filename):
+        filename = os.path.abspath(filename)
+        if self is None:
+            for instance in cls.instances:
+                instance.watch_file(filename)
+        else:
+            self.extra_files.append(filename)
+
+    watch_file = classinstancemethod(watch_file)
+
+watch_file = Monitor.watch_file
+
+def awake_select(addrs):
+    """
+    When using socket.select(), processes will not quit.  By connecting
+    to the addresses locally we move the code out of the select, where
+    it can terminate properly.
+
+    (For now, KeyboardInterrupt seems to terminate these selects
+    properly)
+    """
+    
+    for addr in addrs:
+        sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+        try:
+            sock.connect(addr)
+            sock.close()
+        except:
+            pass
+        
-- 
cgit v1.2.1