Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/gunicorn/http/__pycache__/message.cpython-39.pyc
Ðазад
a j�h�0 � @ s� d dl Z d dlZd dlZd dlmZ d dlmZ d dlmZm Z m Z m Z d dl m Z mZmZmZmZmZmZmZ d dl mZmZ d dl mZ d dlmZmZ d Zd Z d Z e� d �Z e� d �Z e� d �Z!G dd� de"�Z#G dd� de#�Z$dS )� N)�ENOTCONN)�SocketUnreader)� ChunkedReader� LengthReader� EOFReader�Body)� InvalidHeader�InvalidHeaderName� NoMoreData�InvalidRequestLine�InvalidRequestMethod�InvalidHTTPVersion�LimitRequestLine�LimitRequestHeaders)�InvalidProxyLine�ForbiddenProxyRequest)�InvalidSchemeHeaders)� bytes_to_str�split_request_urii� i � z%[\x00-\x1F\x7F()<>@,;:\[\]={} \t\\\"]z[A-Z0-9$-_.]{3,20}zHTTP/(\d+)\.(\d+)c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd S ) �Messagec C s� || _ || _d | _g | _g | _d | _|jr.dnd| _|j| _| jdksP| jt krVt | _|j | _ | j dk rnt | _ | j pvt }| j|d d | _ | � | j�}| j�|� | �� d S )N�https�httpr � � )�cfg�unreader�version�headersZtrailers�bodyZis_ssl�scheme�limit_request_fields� MAX_HEADERS�limit_request_field_size� DEFAULT_MAX_HEADERFIELD_SIZE�max_buffer_headers�parse�unread�set_body_reader)�selfr r Zmax_header_field_sizeZunused� r) ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/gunicorn/http/message.py�__init__ s0 � �� zMessage.__init__c C s t � �d S �N)�NotImplementedError)r( r r) r) r* r% 9 s z Message.parsec C s( | j }g }dd� |�d�D �}d}i }d|jv r8|j}n^t| jt�r�| jj�� }| jjj t j t j fv r�|d }||jv r�|j}n| jjj t j kr�|j}|�r$t|�| jkr�td��|�d�} t| �} | �d�dk r�t| �� ��| �dd �\} } | j j�r| �d ��� } n| �� } t�| ��r$t| ��| �� | �� g } } |�r�|d � d ��r�|�d�} | t| �7 } | | j k�r~dk�r�n ntd ��| � | � �q8d � | ��� } | | j k�r�dk�r�n ntd ��| |v �r| || k} | �r�dnd}|�r || j k�rt!� �n d}|| _ |� | | f� q�|S )Nc S s g | ]}t |�d �qS )z �r )�.0�liner) r) r* � <listcomp>A � z)Message.parse_headers.<locals>.<listcomp>� F�*r z limit request headers fields�:� z )� � z!limit request headers fields size� r r T)"r �splitZforwarded_allow_ips�secure_scheme_headers� isinstancer r �sock� getpeername�family�socket�AF_INET�AF_INET6�AF_UNIX�lenr r �pop�findr �stripZstrip_header_spaces�rstrip�upper� HEADER_RE�searchr �lstrip� startswithr" �append�joinr r )r( �datar r �linesZ scheme_headerr; Z remote_addr� remote_host�curr� header_length�name�value�securer r) r) r* � parse_headers< s` zMessage.parse_headersc C s� d}d }| j D ]P\}}|dkr8|d ur2td| d��|}q|dkrR|�� dkr^d}q|dkrd}q|rxtt| | j��| _nl|d ur�z t|�}W n ty� td| d��Y n0 |d k r�td| d��tt | j|��| _ntt | j��| _d S ) NFzCONTENT-LENGTH)�reqzTRANSFER-ENCODING�chunkedTzSEC-WEBSOCKET-KEY1� r ) r r �lowerr r r r �int� ValueErrorr r )r( rZ �content_lengthrU rV r) r) r* r' � s. zMessage.set_body_readerc C sN | j D ]<\}}|dkr|�� �� }|dkr0 dS |dkr> dS qDq| jdkS )NZ CONNECTION�closeTz keep-aliveF)r6 r )r r\ rG r )r( �h�vr) r) r* � should_close� s zMessage.should_closeN)�__name__� __module__� __qualname__r+ r% rX r' rc r) r) r) r* r s E r c sf e Zd Zd� fdd� Zddd�Zdd� Zdd d �Zd d � Zdd� Zdd� Z dd� Z � fdd�Z � Z S )�Requestr6 c s^ d | _ d | _d | _d | _d | _|j| _| jdk s:| jtkr@t| _|| _d | _t � � ||� d S �Nr ) �method�uri�path�query�fragment�limit_request_line�MAX_REQUEST_LINE� req_number�proxy_protocol_info�superr+ )r( r r rp �� __class__r) r* r+ � s �zRequest.__init__Fc C s0 |� � }|s"|rt� �t|�� ��|�|� d S r, )�read� StopIterationr �getvalue�write)r( r �buf�stoprP r) r) r* �get_data� s zRequest.get_datac C s> t �� }| j||dd� | �||| j�\}}| �t|��r`t �� }|�|� | �||| j�\}}| �|� t �� }|�|� |� � }|� d�}|d d� dk}|� d�}|d d� dk}|dk r�|s�| �||� |� � }t |�| j kr�t d��q�q�q�|�r| j�|dd � � dS | �|d |� �| _||d d � }d }|S ) NT)rz s r r3 r zmax buffer headersr2 r )�io�BytesIOr{ � read_linern �proxy_protocolr rx �parse_request_linerw rF rD r$ r r r& rX r ) r( r ry r0 ZrbufrP �idx�done�retr) r) r* r% � s8 z Request.parser c C s� |� � }|�d�}|dkr>|| kr.dkr�n q�t||��q�t|�d | krZdkrln ntt|�|��| �||� |� � }q|d |� ||d d � fS )Nr3 r r )rw rF r rD r{ )r( r ry �limitrP r� r) r) r* r~ � s �zRequest.read_linec C s> | j js dS | jdkrdS |�d�s(dS | �� | �|� dS )z� Detect, check and parse proxy protocol. :raises: ForbiddenProxyRequest, InvalidProxyLine. :return: True for proxy protocol line else False Fr6 ZPROXYT)r r rp rM �proxy_protocol_access_check�parse_proxy_protocol)r( r0 r) r) r* r s zRequest.proxy_protocolc C s� t | jt�r�z| jj�� d }W n> tjy^ } z$|jd tkrHt d��� W Y d }~n d }~0 0 d| j j vr�|| j j vr�t |��d S )Nr ZUNKNOWr4 ) r< r r r= r> r@ �error�argsr r r Zproxy_allow_ips)r( rR �er) r) r* r� s �z#Request.proxy_protocol_access_checkc C sl |� � }t|�dkr t|��|d }|d }|d }|dvrHtd| ��|dkr�z t�tj|� t�tj|� W q� tjy� t|��Y q�0 nF|dkr�z t�tj|� t�tj|� W n tjy� t|��Y n0 z t|d �}t|d �}W n t �y td | ��Y n0 d | k�r,d k�rJn nd | k�rHd k�sVn td | ��|||||d�| _ d S )N� r6 r � )�TCP4�TCP6zprotocol '%s' not supportedr� r� r � zinvalid port %sr i�� )r � client_addrZ client_portZ proxy_addrZ proxy_port) r: rD r r@ � inet_ptonrA r� rB r] r^ rq )r( r0 �bits�protoZs_addrZd_addrZs_portZd_portr) r) r* r� % sB 6 �z Request.parse_proxy_protocolc C s� dd� |� d d�D �}t|�dkr.tt|���t�|d �sHt|d ��|d �� | _|d | _ zt | j �}W n t y� tt|���Y n0 |j p�d| _ |j p�d| _ |jp�d| _t�|d �}|d u r�t|d ��t|�d��t|�d��f| _d S )Nc S s g | ] }t |��qS r) r. )r/ �bitr) r) r* r1 S r2 z.Request.parse_request_line.<locals>.<listcomp>r r� r r6 r9 )r: rD r r �METH_RE�matchr rI ri rj r r^ rk rl rm � VERSION_REr r] �groupr )r( Z line_bytesr� �partsr� r) r) r* r� R s$ zRequest.parse_request_linec s. t � �� t| jjt�r*tt| jd��| _d S rh ) rr r' r< r �readerr r r r )r( rs r) r* r' m s zRequest.set_body_reader)r6 )F)r ) rd re rf r+ r{ r% r~ r r� r� r� r' � __classcell__r) r) rs r* rg � s - -rg )%r| �rer@ �errnor Zgunicorn.http.unreaderr Zgunicorn.http.bodyr r r r Zgunicorn.http.errorsr r r r r r r r r r r Z gunicorn.utilr r ro r! r# �compilerJ r� r� �objectr rg r) r) r) r* �<module> s$ (
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка