Manage the invocation of a WSGI application
| 92 | |
| 93 | |
| 94 | class BaseHandler: |
| 95 | """Manage the invocation of a WSGI application""" |
| 96 | |
| 97 | # Configuration parameters; can override per-subclass or per-instance |
| 98 | wsgi_version = (1,0) |
| 99 | wsgi_multithread = True |
| 100 | wsgi_multiprocess = True |
| 101 | wsgi_run_once = False |
| 102 | |
| 103 | origin_server = True # We are transmitting direct to client |
| 104 | http_version = "1.0" # Version that should be used for response |
| 105 | server_software = None # String name of server software, if any |
| 106 | |
| 107 | # os_environ is used to supply configuration from the OS environment: |
| 108 | # by default it's a copy of 'os.environ' as of import time, but you can |
| 109 | # override this in e.g. your __init__ method. |
| 110 | os_environ= read_environ() |
| 111 | |
| 112 | # Collaborator classes |
| 113 | wsgi_file_wrapper = FileWrapper # set to None to disable |
| 114 | headers_class = Headers # must be a Headers-like class |
| 115 | |
| 116 | # Error handling (also per-subclass or per-instance) |
| 117 | traceback_limit = None # Print entire traceback to self.get_stderr() |
| 118 | error_status = "500 Internal Server Error" |
| 119 | error_headers = [('Content-Type','text/plain')] |
| 120 | error_body = b"A server error occurred. Please contact the administrator." |
| 121 | |
| 122 | # State variables (don't mess with these) |
| 123 | status = result = None |
| 124 | headers_sent = False |
| 125 | headers = None |
| 126 | bytes_sent = 0 |
| 127 | |
| 128 | def run(self, application): |
| 129 | """Invoke the application""" |
| 130 | # Note to self: don't move the close()! Asynchronous servers shouldn't |
| 131 | # call close() from finish_response(), so if you close() anywhere but |
| 132 | # the double-error branch here, you'll break asynchronous servers by |
| 133 | # prematurely closing. Async servers must return from 'run()' without |
| 134 | # closing if there might still be output to iterate over. |
| 135 | try: |
| 136 | self.setup_environ() |
| 137 | self.result = application(self.environ, self.start_response) |
| 138 | self.finish_response() |
| 139 | except (ConnectionAbortedError, BrokenPipeError, ConnectionResetError): |
| 140 | # We expect the client to close the connection abruptly from time |
| 141 | # to time. |
| 142 | return |
| 143 | except: |
| 144 | try: |
| 145 | self.handle_error() |
| 146 | except: |
| 147 | # If we get an error handling an error, just give up already! |
| 148 | self.close() |
| 149 | raise # ...and let the actual server figure it out. |
| 150 | |
| 151 |