diff options
Diffstat (limited to 'paste/servers/scgi_server/scgiserver.py')
| -rw-r--r-- | paste/servers/scgi_server/scgiserver.py | 149 |
1 files changed, 0 insertions, 149 deletions
diff --git a/paste/servers/scgi_server/scgiserver.py b/paste/servers/scgi_server/scgiserver.py deleted file mode 100644 index fabeeda..0000000 --- a/paste/servers/scgi_server/scgiserver.py +++ /dev/null @@ -1,149 +0,0 @@ -#! /usr/bin/env python -""" -SCGI-->WSGI application proxy, "SWAP". - -(Originally written by Titus Brown.) - -This lets an SCGI front-end like mod_scgi be used to execute WSGI -application objects. To use it, subclass the SWAP class like so: - - - class TestAppHandler(swap.SWAP): - def __init__(self, *args, **kwargs): - self.prefix = '/canal' - self.app_obj = TestAppClass - swap.SWAP.__init__(self, *args, **kwargs) - -where 'TestAppClass' is the application object from WSGI and '/canal' -is the prefix for what is served by the SCGI Web-server-side process. - -Then execute the SCGI handler "as usual" by doing something like this - - scgi_server.SCGIServer(TestAppHandler, port=4000).serve() - -and point mod_scgi (or whatever your SCGI front end is) at port 4000. - -Kudos to the WSGI folk for writing a nice PEP & the Quixote folk for -writing a nice extensible SCGI server for Python! -""" - -import sys -import time -import os -from scgi import scgi_server - -def debug(msg): - timestamp = time.strftime("%Y-%m-%d %H:%M:%S", - time.localtime(time.time())) - sys.stderr.write("[%s] %s\n" % (timestamp, msg)) - -class SWAP(scgi_server.SCGIHandler): - """ - SCGI->WSGI application proxy: let an SCGI server execute WSGI - application objects. - """ - app_obj = None - prefix = None - - def __init__(self, *args, **kwargs): - assert self.app_obj, "must set app_obj" - assert self.prefix, "must set prefix" - args = (self,) + args - scgi_server.SCGIHandler.__init__(*args, **kwargs) - - def handle_connection(self, conn): - """ - Handle an individual connection. - """ - input = conn.makefile("r") - output = conn.makefile("w") - - environ = self.read_env(input) - environ['wsgi.input'] = input - environ['wsgi.errors'] = sys.stderr - environ['wsgi.version'] = (1,0) - environ['wsgi.multithread'] = False - environ['wsgi.multiprocess'] = True - environ['wsgi.run_once'] = False - - # dunno how SCGI does HTTPS signalling; can't test it myself... @CTB - if environ.get('HTTPS','off') in ('on','1'): - environ['wsgi.url_scheme'] = 'https' - else: - environ['wsgi.url_scheme'] = 'http' - - ## SCGI does some weird environ manglement. We need to set - ## SCRIPT_NAME from 'prefix' and then set PATH_INFO from - ## REQUEST_URI. - - prefix = self.prefix - path = environ['REQUEST_URI'][len(prefix):] - path = path.split('?', 1)[0] - - environ['SCRIPT_NAME'] = prefix - environ['PATH_INFO'] = path - - headers_set = [] - headers_sent = [] - chunks = [] - def write(data): - chunks.append(data) - - def start_response(status,response_headers,exc_info=None): - if exc_info: - try: - if headers_sent: - # Re-raise original exception if headers sent - raise exc_info[0], exc_info[1], exc_info[2] - finally: - exc_info = None # avoid dangling circular ref - elif headers_set: - raise AssertionError("Headers already set!") - - headers_set[:] = [status,response_headers] - return write - - ### - - result = self.app_obj(environ, start_response) - try: - for data in result: - chunks.append(data) - - # Before the first output, send the stored headers - if not headers_set: - # Error -- the app never called start_response - status = '500 Server Error' - response_headers = [('Content-type', 'text/html')] - chunks = ["XXX start_response never called"] - else: - status, response_headers = headers_sent[:] = headers_set - - output.write('Status: %s\r\n' % status) - for header in response_headers: - output.write('%s: %s\r\n' % header) - output.write('\r\n') - - for data in chunks: - output.write(data) - finally: - if hasattr(result,'close'): - result.close() - - # SCGI backends use connection closing to signal 'fini'. - try: - input.close() - output.close() - conn.close() - except IOError, err: - debug("IOError while closing connection ignored: %s" % err) - - -def serve_application (application, prefix, port): - class SCGIAppHandler(SWAP): - def __init__ (self, *args, **kwargs): - self.prefix = prefix - self.app_obj = application - SWAP.__init__(self, *args, **kwargs) - - scgi_server.SCGIServer(SCGIAppHandler, port=port).serve() |
