Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/cheroot/__pycache__/wsgi.cpython-39.pyc
Ðазад
a p�h�7 � @ s� d Z ddlZddlmZ ddlmZ ddlmZmZ G dd� dej �Z G d d � d ej �Z G d d � d e �Z G d d� de �Z e �� ZG dd� d�Ze� je e e e ed� dS )a� This class holds Cheroot WSGI server implementation. Simplest example on how to use this server:: from cheroot import wsgi def my_crazy_app(environ, start_response): status = '200 OK' response_headers = [('Content-type','text/plain')] start_response(status, response_headers) return [b'Hello world!'] addr = '0.0.0.0', 8070 server = wsgi.Server(addr, my_crazy_app) server.start() The Cheroot WSGI server can serve as many WSGI applications as you want in one instance by using a PathInfoDispatcher:: path_map = { '/': my_crazy_app, '/blog': my_blog_app, } d = wsgi.PathInfoDispatcher(path_map) server = wsgi.Server(addr, d) � N� )�server)� threadpool)�ntob�btonc s@ e Zd ZdZdZd � fdd � Zed d � �Zejd d � �Z� Z S )�Serverz8A subclass of HTTPServer which calls a WSGI application.�r r � N���� Fc sX t t| �j|t| j || | | d� || _|| _|| _|| _t j | |pFd|| | d�| _ dS )a� Initialize WSGI Server instance. Args: bind_addr (tuple): network interface to listen to wsgi_app (callable): WSGI application callable numthreads (int): number of threads for WSGI thread pool server_name (str): web server name to be advertised via Server HTTP header max (int): maximum number of worker threads request_queue_size (int): the 'backlog' arg to socket.listen(); max queued connections timeout (int): the timeout in seconds for accepted connections shutdown_timeout (int): the total time, in seconds, to wait for worker threads to cleanly exit accepted_queue_size (int): maximum number of active requests in queue accepted_queue_timeout (int): timeout for putting request into queue )Zgateway� server_name�peercreds_enabled�peercreds_resolve_enabled� reuse_portr )�min�max�accepted_queue_size�accepted_queue_timeoutN) �superr �__init__� wsgi_gateways� wsgi_version�wsgi_app�request_queue_size�timeout�shutdown_timeoutr Z ThreadPool�requests)�self� bind_addrr � numthreadsr r r r r r r r r r �� __class__� �|/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/cheroot/wsgi.pyr ) s" � �zServer.__init__c C s | j jS )z Set minimum number of threads.�r r �r r" r" r# r U s zServer.numthreadsc C s || j _d S )Nr$ )r �valuer" r" r# r Z s ) r Nr r r r r r FFF) �__name__� __module__� __qualname__�__doc__r r �propertyr �setter� __classcell__r" r" r r# r # s �, r c sZ e Zd ZdZ� fdd�Zedd� �Zdd� Zdd � Zdd d �Z e d d� �Z dd� Z � Z S )�Gatewayz/A base class to interface HTTPServer with WSGI.c s* t t| ��|� d| _| �� | _d| _dS )zzInitialize WSGI Gateway instance with request. Args: req (HTTPRequest): current HTTP request FN)r r. r �started_response� get_environ�env�remaining_bytes_out)r �reqr r" r# r b s zGateway.__init__c C s dd� | � � D �S )z�Create a mapping of gateways and their versions. Returns: dict[tuple[int,int],class]: map of gateway version and corresponding class c S s i | ] }|j |�qS r" )�version)�.0Zgwr" r" r# � <dictcomp>v � z'Gateway.gateway_map.<locals>.<dictcomp>)�__subclasses__)�clsr" r" r# � gateway_mapm s zGateway.gateway_mapc C s t �dS )�;Return a new environ dict targeting the given wsgi.version.N)�NotImplementedErrorr% r" r" r# r0 x s zGateway.get_environc C s� | j j�| j| j�}zLtd|�D ] }t|t�s6td��| � |� q W | j � � t |d�r�|� � n | j � � t |d�r~|� � 0 dS )a� Process the current request. From :pep:`333`: The start_response callable must not actually transmit the response headers. Instead, it must store them for the server or gateway to transmit only after the first iteration of the application return value that yields a NON-EMPTY string, or upon the application's first invocation of the write() callable. Nz"WSGI Applications must yield bytes�close) r3 r r r1 �start_response�filter� isinstance�bytes� ValueError�write�ensure_headers_sent�hasattrr= )r �response�chunkr" r" r# �respond| s � zGateway.respondNc C s� | j r|std��d| _ | jjr,|d }|�| �|�| j_|D ]h\}}t|t�s\td| ��t|t�srtd| ��|� � dkr�t |�| _ t |�t |�f}| jj �|� q>| jS )z)WSGI callable to begin the HTTP response.z:WSGI start_response called a second time with no exc_info.Tr z/WSGI response header key %r is not of type str.z1WSGI response header value %r is not of type str.zcontent-length)r/ � RuntimeErrorr3 � sent_headers�_encode_status�statusr@ �str� TypeError�lower�intr2 r Z outheaders�appendrC )r rL �headers�exc_infor& �k�vZ out_headerr" r" r# r> � s. � � � zGateway.start_responsec C s t | t�std��| �d�S )a: Cast status to bytes representation of current Python version. According to :pep:`3333`, when using Python 3, the response status and headers must be bytes masquerading as Unicode; that is, they must be of type "str" but are restricted to code points in the "Latin-1" set. z(WSGI response status is not of type str.� ISO-8859-1)r@ rM rN �encode)rL r" r" r# rK � s zGateway._encode_statusc C s� | j std��t|�}| j}|durP||krP| jjsD| j�dd� n |d|� }| j�� | j�|� |dur�||8 }|dk r�t d��dS )z�WSGI callable to write unbuffered data to the client. This method is also used internally by start_response (to write data from the iterable returned by the WSGI application). z(WSGI write called before start_response.Nz500 Internal Server ErrorzLThe requested resource returned more bytes than the declared Content-Length.r z2Response body exceeds the declared Content-Length.) r/ rI �lenr2 r3 rJ Zsimple_responserD rC rB )r rG ZchunklenZrbor" r" r# rC � s& � �z Gateway.write)N)r' r( r) r* r � classmethodr: r0 rH r> � staticmethodrK rC r- r" r" r r# r. _ s $ r. c @ s e Zd ZdZdZdd� ZdS )� Gateway_10z8A Gateway class to interface HTTPServer with WSGI 1.0.x.r c C s� | j }|j}|jjt|j�t|j�|jp*dt|j p4d�t|j �t|j �d|jj t|j �|jjtj|jt|j�dddt|j�| jd�}t|jjt��r d|d< zVt|j�|d< t|j�|d< t|j�|d< t|j�|d < t|j �|d < |d |d < W n t �y Y n0 nt|jjd �|d< |� d d� |j � � D �� |�!dd�}|du�rV||d< |�!dd�}|du�rt||d< |jj"�r�|� |jj"� |S )r; � FT)ZACTUAL_SERVER_PROTOCOL� PATH_INFO� QUERY_STRINGZ REMOTE_ADDRZ REMOTE_PORT�REQUEST_METHODZ REQUEST_URI� SCRIPT_NAMEZ SERVER_NAMEZSERVER_PROTOCOL�SERVER_SOFTWAREz wsgi.errorsz wsgi.inputzwsgi.input_terminatedzwsgi.multiprocesszwsgi.multithreadz wsgi.run_oncezwsgi.url_schemez wsgi.versionZ SERVER_PORTZ X_REMOTE_PIDZ X_REMOTE_UIDZ X_REMOTE_GIDZ X_REMOTE_USERZX_REMOTE_GROUPZ REMOTE_USERr c s s6 | ].\}}d j t|��� �dd�d�t|�fV qdS )zHTTP_{header_name!s}�-�_)� header_nameN)�formatr �upper�replace)r5 rT rU r" r" r# � <genexpr># s ���z)Gateway_10.get_environ.<locals>.<genexpr>ZHTTP_CONTENT_TYPENZ CONTENT_TYPEZHTTP_CONTENT_LENGTHZCONTENT_LENGTH)#r3 �connr �protocolr �path�qsZ remote_addrrM Z remote_port�method�urir Zrequest_protocolZsoftware�sys�stderr�rfile�boolZ chunked_read�schemer4 r@ r Zpeer_pidZpeer_uidZpeer_gidZ peer_userZ peer_grouprI �updateZ inheaders�items�popZssl_env)r r3 Zreq_connr1 �ct�clr" r" r# r0 � s\ � � zGateway_10.get_environN)r' r( r) r* r4 r0 r" r" r" r# r[ � s r[ c s$ e Zd ZdZdZ� fdd�Z� ZS )� Gateway_u0z�A Gateway class to interface HTTPServer with WSGI u.0. WSGI u.0 is an experimental protocol, which uses Unicode for keys and values in both Python 2 and Python 3. )�ur c s� | j }tt| ��� }t|�� �}|�dd�}z$|j�|�|d< |j �|�|d< W n2 t y� d|d< |d |d< |d |d< Y n0 |� |�� � |S )r; zwsgi.url_encodingzutf-8r] r^ rV ) r3 r ry r0 �dictru � setdefaultrk �decoderl �UnicodeDecodeErrorrt )r r3 Zenv_10r1 �encr r" r# r0 C s zGateway_u0.get_environ)r' r( r) r* r4 r0 r- r" r" r r# ry : s ry c @ s e Zd ZdZdd� Zdd� ZdS )�PathInfoDispatcherz6A WSGI dispatcher for dispatch based on the PATH_INFO.c C sN zt |�� �}W n ty" Y n0 dd� }|j|dd� dd� |D �| _dS )z�Initialize path info WSGI app dispatcher. Args: apps (dict[str,object]|list[tuple[str,object]]): URI prefix and WSGI app pairs c S s t | d �S )Nr )rX )�appr" r" r# � by_path_lenl s z0PathInfoDispatcher.__init__.<locals>.by_path_lenT)�key�reversec S s g | ]\}}|� d �|f�qS )�/)�rstrip)r5 �p�ar" r" r# � <listcomp>r r7 z/PathInfoDispatcher.__init__.<locals>.<listcomp>N)�listru �AttributeError�sort�apps)r r� r� r" r" r# r _ s zPathInfoDispatcher.__init__c C s� |d p d}| j D ]`\}}|�dj|d��s4||kr|�� }|�dd�| |d< |t|�d� |d< |||� S q|dd d g� dgS ) a Process incoming WSGI request. Ref: :pep:`3333` Args: environ (Mapping): a dict containing WSGI environment variables start_response (callable): function, which sets response status and headers Returns: list[bytes]: iterable containing bytes to be returned in HTTP response body r] r� z {path!s}/)rk r` r\ Nz 404 Not Found)z Content-Typez text/plain)zContent-Length�0)r� � startswithre �copy�getrX )r �environr> rk r� r� r" r" r# �__call__t s ��zPathInfoDispatcher.__call__N)r' r( r) r* r r� r" r" r" r# r� \ s r� )Z WSGIServerZ WSGIGatewayZWSGIGateway_u0ZWSGIGateway_10ZWSGIPathInfoDispatcher)r* ro r\ r �workersr �_compatr r Z HTTPServerr r. r[ ry r: r r� �globalsrt r" r" r" r# �<module> s$ < Q :�
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка