X-Git-Url: http://dolda2000.com/gitweb/?a=blobdiff_plain;f=wrw%2Fdispatch.py;fp=wrw%2Fdispatch.py;h=e51559e1fbe4b477a847af6bc1ea985a588393f2;hb=3614ca8353a5f2055fdcc086e6bc9dc993b49b42;hp=709cfe4e18dedad2921de5e7390e4a601c313f29;hpb=f9e9a7b5b192adfc7318e7f3ba0153668eef3bc1;p=wrw.git diff --git a/wrw/dispatch.py b/wrw/dispatch.py index 709cfe4..e51559e 100644 --- a/wrw/dispatch.py +++ b/wrw/dispatch.py @@ -1,3 +1,6 @@ +import sys, traceback +from . import env + __all__ = ["restart"] class restart(Exception): @@ -39,7 +42,20 @@ class iterproxy(object): if hasattr(self.bk, "close"): self.bk.close() +def defaulterror(req, excinfo): + from . import resp + traceback.print_exception(*excinfo) + raise resp.httperror(500) + +def wraphandler(handler, excinfo): + def wrapped(req): + return handler(req, excinfo) + return wrapped + +errorhandler = env.var(defaulterror) + def handle(req, startreq, handler): + eh = errorhandler.val try: resp = [""] while True: @@ -48,6 +64,11 @@ def handle(req, startreq, handler): break except restart as i: handler = i.handle + except Exception as i: + if eh is None: + raise + handler = wraphandler(eh, sys.exc_info()) + eh = None req.commit(startreq) return resp finally: