class WSGIRequestHandler(BaseHTTPRequestHandler, object):"""A request handler that implements WSGI dispatching."""@propertydef server_version(self):return 'Werkzeug/' + werkzeug.__version__def make_environ(self):request_url = url_parse(self.path)def shutdown_server():self.server.shutdown_signal = Trueurl_scheme = self.server.ssl_context is None and 'http' or 'https'path_info = url_unquote(request_url.path)environ = {'wsgi.version':         (1, 0),'wsgi.url_scheme':      url_scheme,'wsgi.input':           self.rfile,'wsgi.errors':          sys.stderr,'wsgi.multithread':     self.server.multithread,'wsgi.multiprocess':    self.server.multiprocess,'wsgi.run_once':        False,'werkzeug.server.shutdown': shutdown_server,'SERVER_SOFTWARE':      self.server_version,'REQUEST_METHOD':       self.command,'SCRIPT_NAME':          '','PATH_INFO':            wsgi_encoding_dance(path_info),'QUERY_STRING':         wsgi_encoding_dance(request_url.query),'CONTENT_TYPE':         self.headers.get('Content-Type', ''),'CONTENT_LENGTH':       self.headers.get('Content-Length', ''),'REMOTE_ADDR':          self.client_address[0],'REMOTE_PORT':          self.client_address[1],'SERVER_NAME':          self.server.server_address[0],'SERVER_PORT':          str(self.server.server_address[1]),'SERVER_PROTOCOL':      self.request_version}for key, value in self.headers.items():key = 'HTTP_' + key.upper().replace('-', '_')if key not in ('HTTP_CONTENT_TYPE', 'HTTP_CONTENT_LENGTH'):environ[key] = valueif request_url.netloc:environ['HTTP_HOST'] = request_url.netlocreturn environdef run_wsgi(self):if self.headers.get('Expect', '').lower().strip() == '100-continue':self.wfile.write(b'HTTP/1.1 100 Continue\r\n\r\n')self.environ = environ = self.make_environ()headers_set = []headers_sent = []def write(data):assert headers_set, 'write() before start_response'if not headers_sent:status, response_headers = headers_sent[:] = headers_settry:code, msg = status.split(None, 1)except ValueError:code, msg = status, ""self.send_response(int(code), msg)header_keys = set()for key, value in response_headers:self.send_header(key, value)key = key.lower()header_keys.add(key)if 'content-length' not in header_keys:self.close_connection = Trueself.send_header('Connection', 'close')if 'server' not in header_keys:self.send_header('Server', self.version_string())if 'date' not in header_keys:self.send_header('Date', self.date_time_string())self.end_headers()assert isinstance(data, bytes), 'applications must write bytes'self.wfile.write(data)self.wfile.flush()def start_response(status, response_headers, exc_info=None):if exc_info:try:if headers_sent:reraise(*exc_info)finally:exc_info = Noneelif headers_set:raise AssertionError('Headers already set')headers_set[:] = [status, response_headers]return writedef execute(app):application_iter = app(environ, start_response)try:for data in application_iter:write(data)if not headers_sent:write(b'')finally:if hasattr(application_iter, 'close'):application_iter.close()application_iter = Nonetry:execute(self.server.app)except (socket.error, socket.timeout) as e:self.connection_dropped(e, environ)except Exception:if self.server.passthrough_errors:raisefrom werkzeug.debug.tbtools import get_current_tracebacktraceback = get_current_traceback(ignore_system_exceptions=True)try:# if we haven't yet sent the headers but they are set# we roll back to be able to set them again.if not headers_sent:del headers_set[:]execute(InternalServerError())except Exception:passself.server.log('error', 'Error on request:\n%s',traceback.plaintext)def handle(self):"""Handles a request ignoring dropped connections."""rv = Nonetry:rv = BaseHTTPRequestHandler.handle(self)except (socket.error, socket.timeout) as e:self.connection_dropped(e)except Exception:if self.server.ssl_context is None or not is_ssl_error():raiseif self.server.shutdown_signal:self.initiate_shutdown()return rvdef initiate_shutdown(self):"""A horrible, horrible way to kill the server for Python 2.6 andlater.  It's the best we can do."""# Windows does not provide SIGKILL, go with SIGTERM then.sig = getattr(signal, 'SIGKILL', signal.SIGTERM)# reloader activeif os.environ.get('WERKZEUG_RUN_MAIN') == 'true':os.kill(os.getpid(), sig)# python 2.7self.server._BaseServer__shutdown_request = True# python 2.6self.server._BaseServer__serving = Falsedef connection_dropped(self, error, environ=None):"""Called if the connection was closed by the client.  By defaultnothing happens."""def handle_one_request(self):"""Handle a single HTTP request."""self.raw_requestline = self.rfile.readline()if not self.raw_requestline:self.close_connection = 1elif self.parse_request():return self.run_wsgi()def send_response(self, code, message=None):"""Send the response header and log the response code."""self.log_request(code)if message is None:message = code in self.responses and self.responses[code][0] or ''if self.request_version != 'HTTP/0.9':hdr = "%s %d %s\r\n" % (self.protocol_version, code, message)self.wfile.write(hdr.encode('ascii'))def version_string(self):return BaseHTTPRequestHandler.version_string(self).strip()def address_string(self):return self.environ['REMOTE_ADDR']def log_request(self, code='-', size='-'):self.log('info', '"%s" %s %s', self.requestline, code, size)def log_error(self, *args):self.log('error', *args)def log_message(self, format, *args):self.log('info', format, *args)def log(self, type, message, *args):_log(type, '%s - - [%s] %s\n' % (self.address_string(),self.log_date_time_string(),message % args))