Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/tornado/__pycache__/http1connection.cpython-39.pyc
Ðазад
a _�h�� � @ s d Z ddlZddlZddlZddlZddlmZmZmZ ddl m Z m Z ddl m Z ddl mZ ddl mZ ddlmZmZ dd lmZ dd lmZmZmZmZmZmZm Z G d d � d e �Z G d d� de �Z G dd� de �Z!G dd� dej"�Z#G dd� dej$�Z%G dd� de �Z&dS )zFClient and server implementations of HTTP/1.x. .. versionadded:: 4.0 � N)�Future�future_add_done_callback�"future_set_result_unless_cancelled)� native_str�utf8)�gen)�httputil)�iostream)�gen_log�app_log)�GzipDecompressor)�cast�Optional�Type� Awaitable�Callable�Union�Tuplec @ s e Zd Zdd�dd�ZdS )�_QuietExceptionN��returnc C s d S �N� ��selfr r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/tornado/http1connection.py�__init__+ s z_QuietException.__init__)�__name__� __module__� __qualname__r r r r r r * s r c @ sJ e Zd ZdZejdd�dd�Zdd�dd�Zd ee e j dd �d d �Z dS ) �_ExceptionLoggingContextz�Used with the ``with`` statement when calling delegate methods to log any exceptions with the given logger. Any exceptions caught are converted to _QuietException N)�loggerr c C s || _ d S r )r! )r r! r r r r 5 s z!_ExceptionLoggingContext.__init__r c C s d S r r r r r r � __enter__8 s z"_ExceptionLoggingContext.__enter__z Optional[Type[BaseException]])�typ�value�tbr c C s2 |d ur.|d usJ �| j jd|||fd� t�d S )N�Uncaught exception��exc_info)r! �errorr )r r# r$ r% r r r �__exit__; s z!_ExceptionLoggingContext.__exit__) r r r �__doc__�logging�Loggerr r" r � BaseException�types� TracebackTyper* r r r r r / s �r c @ s. e Zd ZdZdeeeeeeedd�dd�ZdS )�HTTP1ConnectionParameterszDParameters for `.HTTP1Connection` and `.HTTP1ServerConnection`. FN)� no_keep_alive� chunk_size�max_header_size�header_timeout� max_body_size� body_timeout� decompressr c C s6 || _ |p d| _|pd| _|| _|| _|| _|| _dS )a; :arg bool no_keep_alive: If true, always close the connection after one request. :arg int chunk_size: how much data to read into memory at once :arg int max_header_size: maximum amount of data for HTTP headers :arg float header_timeout: how long to wait for all headers (seconds) :arg int max_body_size: maximum amount of data for body :arg float body_timeout: how long to wait while reading body (seconds) :arg bool decompress: if true, decode incoming ``Content-Encoding: gzip`` i N)r2 r3 r4 r5 r6 r7 r8 )r r2 r3 r4 r5 r6 r7 r8 r r r r K s z"HTTP1ConnectionParameters.__init__)FNNNNNF)r r r r+ �bool�int�floatr r r r r r1 G s$ ��r1 c @ s� e Zd ZdZd>ejeeedd�dd�Z e j e e d�dd�Z e j ed�d d �Zdd �d d �Zeeg df dd�dd�Zdd �dd�Zdd �dd�Zejd �dd�Zedd�dd�Zedd�dd �Zd?ee je j f e j e d d �d d �Z e e d!�d"d#�Z e d d!�d$d%�Z!dd �d&d'�Z"d dd(�d)d*�Z#e je j ed+�d,d-�Z$d.dd(�d/d0�Z%e e&e'e j f d1�d2d3�Z(ee j e j ee d d4�d5d6�Z)ee j dd7�d8d9�Z*e j dd�d:d;�Z+e j dd�d<d=�Z,dS )@�HTTP1Connectionz�Implements the HTTP/1.x protocol. This class can be on its own for clients, or via `HTTP1ServerConnection` for servers. N)�stream� is_client�params�contextr c C s� || _ || _|du rt� }|| _|| _|j| _| jjp<| jj| _| jj | _ d| _ d| _ t � | _d| _| �� d| _d| _d| _d| _d| _d| _dS )a :arg stream: an `.IOStream` :arg bool is_client: client or server :arg params: a `.HTTP1ConnectionParameters` instance or ``None`` :arg context: an opaque application-defined object that can be accessed as ``connection.context``. NF)r> r= r1 r? r@ r2 r6 �max_buffer_size�_max_body_sizer7 � _body_timeout�_write_finished�_read_finishedr �_finish_future�_disconnect_on_finish�_clear_callbacks�_request_start_line�_response_start_line�_request_headers�_chunking_output�_expected_content_remaining�_pending_write)r r= r> r? r@ r r r r p s( zHTTP1Connection.__init__��delegater c C s | j jrt|| j j�}| �|�S )az Read a single HTTP response. Typical client-mode usage is to write a request using `write_headers`, `write`, and `finish`, and then call ``read_response``. :arg delegate: a `.HTTPMessageDelegate` Returns a `.Future` that resolves to a bool after the full response has been read. The result is true if the stream is still open. )r? r8 �_GzipMessageDelegater3 � _read_message)r rP r r r � read_response� s z HTTP1Connection.read_responsec � s� d}�zP�zb| j jd| jjd�}| jjd u r8|I d H }n�z,tj| j j�� | jj |t j d�I d H }W nb tj y� | � � Y W W |r�t t�� |�� W d � n1 s�0 Y d }| �� dS 0 | �|�\}}| jr�t�|�}|| _|}d| _n*t�|�} | | _|| _| }| �| |� | _d}t t��0 |�||�} | d u�rP| I d H W d � n1 �sf0 Y | j d u �r�d}W W |�r�t t�� |�� W d � n1 �s�0 Y d }| �� dS d} | j�rdt |tj ��s�J �| jd u�r| jj dk�rd} |j } | dk�r d} | dk�r�| d k �r�d |v �sDd |v �rRt� d | ��| �!|�I d H n$|�"d �dk�r�| j#�s�| j �$d� | �sp| �%| j�r�|j nd||�} | d u�rp| j&d u �r�| I d H n�z*tj| j j�� | j& | t j d�I d H W nx tj �yn t'�(d| j)� | j � � Y W W |�r^t t�� |�� W d � n1 �sT0 Y d }| �� dS 0 d| _*| j#�r�| j�r�d}t t�� |�+� W d � n1 �s�0 Y | j,�-� �s�| j d u�r�| j �.� �s�| j �/| j0� | j,I d H | j�r| j�r| � � | j d u �rjW W |�rZt t�� |�� W d � n1 �sP0 Y d }| �� dS W n� tj �y } z�t'�(d| j)|� | j�s�| j �$d�I d H | � � W Y d }~W |�r�t t�� |�� W d � n1 �s�0 Y d }| �� dS d }~0 0 W |�rJt t�� |�� W d � n1 �s@0 Y d }| �� nF|�r�t t�� |�� W d � n1 �s�0 Y d }| �� 0 dS )NFs ? ? �Z max_bytes)Zquiet_exceptionsT�HEAD�0 �d �� �Content-Length�Transfer-Encodingz!Response code %d cannot have bodyZExpectz 100-continues HTTP/1.1 100 (Continue) r z Timeout reading body from %sz"Malformed HTTP message from %s: %ss HTTP/1.1 400 Bad Request )1r= Zread_until_regexr? r4 r5 r Z with_timeout�io_loop�timer �StreamClosedError� TimeoutError�closer r �on_connection_closerH �_parse_headersr> r Zparse_response_start_linerJ rG Zparse_request_start_linerI rK �_can_keep_alive�headers_received� isinstance�ResponseStartLine�method�code�HTTPInputErrorrR �getrD �write� _read_bodyrC r �infor@ rE �finishrF �done�closed�set_close_callback�_on_connection_close)r rP Zneed_delegate_closeZ header_futureZ header_dataZstart_line_str�headersZresp_start_line� start_lineZreq_start_lineZheader_recv_futureZ skip_bodyrg Z body_future�er r r rR � s � �b &� � � * H (�� � � � � (� (��� (� (� ( � ( z HTTP1Connection._read_messager c C s, d| _ d| _d| _| jdur(| j�d� dS )z�Clears the callback attributes. This allows the request handler to be garbage collected more quickly in CPython by breaking up reference cycles. N)�_write_callback� _write_future�_close_callbackr= rp r r r r rH . s z HTTP1Connection._clear_callbacks)�callbackr c C s || _ dS )a$ Sets a callback that will be run when the connection is closed. Note that this callback is slightly different from `.HTTPMessageDelegate.on_connection_close`: The `.HTTPMessageDelegate` method is called when the connection is closed while recieving a message. This callback is used when there is not an active delegate (for example, on the server side this callback is used if the client closes the connection after sending its request but before receiving all the response. N)rw �r rx r r r rp : s z"HTTP1Connection.set_close_callbackc C s> | j d ur | j }d | _ |� | j�� s2t| jd � | �� d S r )rw rF rn r rH ry r r r rq H s z$HTTP1Connection._on_connection_closec C s6 | j d ur| j �� | �� | j�� s2t| jd � d S r )r= r_ rH rF rn r r r r r r_ T s zHTTP1Connection.closec C s. | � � | j}d| _| j�� s*t| jd� |S )a> Take control of the underlying stream. Returns the underlying `.IOStream` object and stops all further HTTP processing. May only be called during `.HTTPMessageDelegate.headers_received`. Intended for implementing protocols like websockets that tunnel over an HTTP handshake. N)rH r= rF rn r )r r= r r r �detach[ s zHTTP1Connection.detach)�timeoutr c C s || _ dS )ztSets the body timeout for a single request. Overrides the value from `.HTTP1ConnectionParameters`. N)rC )r r{ r r r �set_body_timeoutj s z HTTP1Connection.set_body_timeout)r6 r c C s || _ dS )zwSets the body size limit for a single request. Overrides the value from `.HTTP1ConnectionParameters`. N)rB )r r6 r r r �set_max_body_sizeq s z!HTTP1Connection.set_max_body_sizez Future[None])rs rr �chunkr c C sp g }| j rht|tj�sJ �|| _|�td|d |d f �� |jdv obd|vobd|vpb|d dk| _n�t|tj �sxJ �| jdus�J �| j dus�J �|| _ |�td |d |d f �� | jj d ko�|j d vo�|j d k s�|j dko�d|vo�d|v| _| jj d k�r| j�rd|d< | jj dk�r@| j �dd��� dk�r@d|d< | j�rPd|d< | j �s�| jjdk�szttj |�j dk�r�d| _n d|v �r�t|d �| _nd| _dd� |�� D �}|�dd� |D �� |D ] }d|v �r�tdt|� ���q�d}| j�� �r"t� }| _|� t � � � |� � nJt� }| _d � |�d }|�rP|| �!|�7 }| j�"|�| _#t$| j#| j%� |S ) z+Implements `.HTTPConnection.write_headers`.z%s %s HTTP/1.1r � )�POST�PUT�PATCHrY rZ �chunkedNzHTTP/1.1 %d %s� �HTTP/1.1)�� rV rW rX r_ � ConnectionzHTTP/1.0� � keep-alivez Keep-AliverU rV c s s& | ] \}}t |�d t |� V qdS )z: N)r )�.0�n�vr r r � <genexpr>� s z0HTTP1Connection.write_headers.<locals>.<genexpr>c s s | ]}|� d �V qdS )�latin1N)�encode)r� �lr r r r� � � � zNewline in header: � s )&r> rd r �RequestStartLinerI �appendr rf rL re rK rJ �versionrg rG ri �lowerr rM r: �get_all�extend� ValueError�reprr= ro r rv � set_exceptionr r] � exception�join� _format_chunkrj rN r �_on_write_complete) r rs rr r~ �linesZ header_lines�line�future�datar r r � write_headersx s� � � ��� � �� �� �� � z HTTP1Connection.write_headers�r~ r c C sh | j d ur:| j t|�8 _ | j dk r:| j�� t�d��| jr`|r`tdt|� �d | d S |S d S )Nr z,Tried to write more data than Content-Lengthz%xr� )rM �lenr= r_ r �HTTPOutputErrorrL r )r r~ r r r r� � s � z HTTP1Connection._format_chunkc C sh d}| j �� r6t� }| _| j�t�� � | j�� n.t� }| _| j �| � |��| _ t | j | j � |S )z�Implements `.HTTPConnection.write`. For backwards compatibility it is allowed but deprecated to skip `write_headers` and instead call `write()` with a pre-encoded header block. N) r= ro r rv r� r r] r� rj r� rN r r� )r r~ r� r r r rj � s zHTTP1Connection.writec C s� | j dur8| j dkr8| j�� s8| j�� t�d| j ��| jrd| j�� sd| j�d�| _| j� | j � d| _ | j svd| _ | j�d� | jdu r�| �d� nt| j| j� dS )z$Implements `.HTTPConnection.finish`.Nr z0Tried to write %d bytes less than Content-Lengths 0 T)rM r= ro r_ r r� rL rj rN Zadd_done_callbackr� rD rE rG � set_nodelay�_finish_requestr r r r r rm � s. ��� �� zHTTP1Connection.finish)r� r c C sl |� � }|d ur$t|tj�s$|�� | jd urH| j}d | _| jj�|� | j d urh| j }d | _ t |d � d S r ) r� rd r r] �resultru r= r[ Z add_callbackrv r )r r� �excrx r r r r� s z"HTTP1Connection._on_write_complete�rs rr r c C sp | j jr dS |�d�}|d ur&|�� }|jdkr8|dkS d|v sd|�dd��� dksdt|d d �d v rl|d kS dS ) NFr� r� r_ rY rZ r� r� rf )rU �GETr� )r? r2 ri r� r� �getattr)r rs rr Zconnection_headerr r r rb " s ���z HTTP1Connection._can_keep_alivezOptional[Future[None]]c C sF | � � | js | jr | �� d S | j�d� | j�� sBt| jd � d S )NF) rH r> rG r_ r= r� rF rn r )r r� r r r r� 6 s z HTTP1Connection._finish_request)r� r c C sL t |�d���d�}|�d�}|d |� �d�}tj�||d � �}||fS )Nr� z � � )r �decode�lstrip�find�rstripr � HTTPHeaders�parse)r r� Zdata_str�eolrs rr r r r ra A s z HTTP1Connection._parse_headers)rg rr rP r c s4 d|v r�d|v rt �d��d|d v rjt�d|d �� t� fdd�� D ��r^t �d|d ��� d |d< zt|d �}W n$ ty� t �d |d ��Y n0 tt|�| jkr�t �d ��nd }|d kr�d|v s�|d vr�t �d| ��d }|d ur�| � ||�S |� dd�� � dk�r | � |�S | j �r0| �|�S d S )NrY rZ z7Response with both Transfer-Encoding and Content-Length�,z,\s*c 3 s | ]}|� d kV qdS )r Nr )r� �i��piecesr r r� ` r� z-HTTP1Connection._read_body.<locals>.<genexpr>z$Multiple unequal Content-Lengths: %rr z*Only integer Content-Length is allowed: %szContent-Length too longr� )Nr z*Response with code %d should not have bodyr� r� )r rh �re�split�anyr: r� r rB �_read_fixed_bodyri r� �_read_chunked_bodyr> �_read_body_until_close)r rg rr rP �content_lengthr r� r rk M sL � �� �� � zHTTP1Connection._read_body)r� rP r c � s� |dkr�| j jt| jj|�dd�I d H }|t|�8 }| jr@| jr tt ��, |� |�}|d urf|I d H W d � q 1 sz0 Y q d S )Nr T��partial) r= � read_bytes�minr? r3 r� rD r> r r � data_received)r r� rP �body�retr r r r� � s � z HTTP1Connection._read_fixed_bodyc � s d}| j jddd�I d H }t|�� d�}|dkrX| j �d�I d H }|dkrTt�d��d S ||7 }|| jkrtt�d��|}|r�| j jt|| j j �d d �I d H }|t |�8 }| j r�| j rxtt��, |�|�}|d ur�|I d H W d � qx1 s�0 Y qx| j �d�I d H }|dksJ �qd S ) Nr r� �@ rT � r� z%improperly terminated chunked requestzchunked body too largeTr� )r= Z read_untilr: �stripr� r rh rB r� r? r3 r� rD r> r r r� ) r rP Z total_sizeZ chunk_len_strZ chunk_lenZcrlfZ bytes_to_readr~ r� r r r r� � s4 � � *z"HTTP1Connection._read_chunked_bodyc � sd | j �� I d H }| jr | jr`tt��, |�|�}|d urB|I d H W d � n1 sV0 Y d S r )r= Zread_until_closerD r> r r r� )r rP r� r� r r r r� � s z&HTTP1Connection._read_body_until_close)NN)N)-r r r r+ r �IOStreamr9 r1 �objectr r �HTTPMessageDelegater rS rR rH r r rp rq r_ rz r; r| r: r} r r� re r� �bytesr� r� rj rm r� rb r� r �strra rk r� r� r� r r r r r< i s^ �� 5z �� [ � � ;� �r< c @ sx e Zd ZdZejedd�dd�Zeej ej f ej e e d d�dd�Zedd �d d �Zdd �d d�Zdd �dd�ZdS )rQ zIWraps an `HTTPMessageDelegate` to decode ``Content-Encoding: gzip``. N)rP r3 r c C s || _ || _d | _d S r )� _delegate� _chunk_size� _decompressor)r rP r3 r r r r � s z _GzipMessageDelegate.__init__r� c C s: |� d�dkr,t� | _|�d|d � |d= | j�||�S )NzContent-Encoding�gzipzX-Consumed-Content-Encoding)ri r r� �addr� rc )r rs rr r r r rc � s z%_GzipMessageDelegate.headers_receivedr� c � sn | j rL|}|rj| j �|| j�}|r@| j�|�}|d ur@|I d H | j j}q n | j�|�}|d urj|I d H d S r )r� r8 r� r� r� �unconsumed_tail)r r~ Zcompressed_data� decompressedr� r r r r� � s � z"_GzipMessageDelegate.data_receivedr c C s* | j d ur | j �� }|r td��| j�� S )Nz9decompressor.flush returned data; possile truncated input)r� �flushr� r� rm )r �tailr r r rm � s �z_GzipMessageDelegate.finishc C s | j �� S r )r� r` r r r r r` � s z(_GzipMessageDelegate.on_connection_close)r r r r+ r r� r: r r r� re r� r r rc r� r� rm r` r r r r rQ � s � rQ c @ sZ e Zd ZdZdejeedd�dd�Zdd�dd�Z e j dd �d d �Z e j dd �d d �Z dS )�HTTP1ServerConnectionzAn HTTP/1.x server.N)r= r? r@ r c C s* || _ |du rt� }|| _|| _d| _dS )z� :arg stream: an `.IOStream` :arg params: a `.HTTP1ConnectionParameters` or None :arg context: an opaque application-defined object that is accessible as ``connection.context`` N)r= r1 r? r@ �_serving_future)r r= r? r@ r r r r � s z HTTP1ServerConnection.__init__r c � s@ | j �� | jdusJ �z| jI dH W n ty: Y n0 dS )zmCloses the connection. Returns a `.Future` that resolves after the serving loop has exited. N)r= r_ r� � Exceptionr r r r r_ s zHTTP1ServerConnection.closerO c C s> t |tj�sJ �t�| �|��}|| _| jj� |dd� � dS )znStarts serving requests on this connection. :arg delegate: a `.HTTPServerConnectionDelegate` c S s | � � S r )r� )�fr r r �<lambda>' r� z5HTTP1ServerConnection.start_serving.<locals>.<lambda>N) rd r � HTTPServerConnectionDelegater Zconvert_yielded�_server_request_loopr� r= r[ Z add_future)r rP Zfutr r r � start_serving s z#HTTP1ServerConnection.start_servingc � s z�t | jd| j| j�}|�| |�}z|�|�I d H }W n� tjtjt j fyb Y W |� | � d S t y� |� � Y W |� | � d S ty� tjddd� |� � Y W |� | � d S 0 |s�W |� | � d S t �d�I d H qW |� | � n |� | � 0 d S )NFr& Tr' r )r< r= r? r@ Z start_requestrS r r] ZUnsatisfiableReadError�asyncioZCancelledErrorZon_closer r_ r� r r) �sleep)r rP �connZrequest_delegater� r r r r� ) s< � � � � �z*HTTP1ServerConnection._server_request_loop)NN)r r r r+ r r� r1 r� r r_ r r� r� r� r r r r r� � s �� �r� )'r+ r� r, r� r/ Ztornado.concurrentr r r Ztornado.escaper r �tornador r r Z tornado.logr r Z tornado.utilr �typingr r r r r r r r� r r� r r1 �HTTPConnectionr< r� rQ r� r r r r �<module> s, $" Z;
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка