functions, you may want to use the getmod() function in this module.
"""
-import os, threading, types, importlib
+import sys, os, threading, types, logging, importlib, getopt
from . import wsgiutil
__all__ = ["application", "wmain", "getmod", "cachedmod", "chain"]
+log = logging.getLogger("wsgidir")
+
class cachedmod(object):
"""Cache entry for modules loaded by getmod()
if path in modcache:
entry = modcache[path]
else:
- entry = cachedmod()
+ entry = [threading.Lock(), None]
modcache[path] = entry
- with entry.lock:
- if entry.mod is None or sb.st_mtime > entry.mtime:
+ with entry[0]:
+ if entry[1] is None or sb.st_mtime > entry[1].mtime:
with open(path, "rb") as f:
text = f.read()
code = compile(text, path, "exec")
mod = types.ModuleType(mangle(path))
mod.__file__ = path
exec(code, mod.__dict__)
- entry.mod = mod
- entry.mtime = sb.st_mtime
- return entry
+ entry[1] = cachedmod(mod, sb.st_mtime)
+ return entry[1]
class handler(object):
def __init__(self):
def handle(self, env, startreq):
if not "SCRIPT_FILENAME" in env:
+ log.error("wsgidir called without SCRIPT_FILENAME set")
return wsgiutil.simpleerror(env, startreq, 500, "Internal Error", "The server is erroneously configured.")
path = env["SCRIPT_FILENAME"]
if not os.access(path, os.R_OK):
+ log.error("%s: not readable" % path)
return wsgiutil.simpleerror(env, startreq, 500, "Internal Error", "The server is erroneously configured.")
if "HTTP_X_ASH_PYTHON_HANDLER" in env:
- handler = self.resolve(env["HTTP_X_ASH_PYTHON_HANDLER"])
+ try:
+ handler = self.resolve(env["HTTP_X_ASH_PYTHON_HANDLER"])
+ except Exception:
+ log.error("could not load handler %s" % env["HTTP_X_ASH_PYTHON_HANDLER"], exc_info=sys.exc_info())
+ return wsgiutil.simpleerror(env, startreq, 500, "Internal Error", "The server is erroneously configured.")
else:
base = os.path.basename(path)
p = base.rfind('.')
if p < 0:
+ log.error("wsgidir called with neither X-Ash-Python-Handler nor a file extension: %s" % path)
return wsgiutil.simpleerror(env, startreq, 500, "Internal Error", "The server is erroneously configured.")
ext = base[p + 1:]
if not ext in self.exts:
+ log.error("unregistered file extension: %s" % ext)
return wsgiutil.simpleerror(env, startreq, 500, "Internal Error", "The server is erroneously configured.")
handler = self.exts[ext]
return handler(env, startreq)
Returns the `application' function. If any arguments are given,
they are parsed according to the module documentation.
"""
- ret = handler()
- for arg in argv:
+ hnd = handler()
+ ret = hnd.handle
+
+ opts, args = getopt.getopt(argv, "-V")
+ for o, a in opts:
+ if o == "-V":
+ import wsgiref.validate
+ ret = wsgiref.validate.validator(ret)
+
+ for arg in args:
if arg[0] == '.':
p = arg.index('=')
- ret.addext(arg[1:p], arg[p + 1:])
- return ret.handle
+ hnd.addext(arg[1:p], arg[p + 1:])
+ return ret
def chain(env, startreq):
"""Chain-loading WSGI handler
object.
"""
path = env["SCRIPT_FILENAME"]
- mod = getmod(path)
+ try:
+ mod = getmod(path)
+ except Exception:
+ log.error("Exception occurred when loading %s" % path, exc_info=sys.exc_info())
+ return wsgiutil.simpleerror(env, startreq, 500, "Internal Error", "Could not load WSGI handler.")
entry = None
if mod is not None:
with mod.lock: