File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/tornado/__pycache__/http1connection.cpython-310.pyc
Back
o ;j`� � @ sd d Z ddlZddlZddlZddlZddlmZmZmZ ddl m Z m Z ddl m Z ddl mZ ddl mZ ddlmZmZ dd lmZ dd lmZmZmZmZmZmZm Z e� d �Z G d d � d e �Z G dd� d�Z!G dd� d�Z"G dd� dej#�Z$G dd� dej%�Z&G dd� d�Z'e� d�Z(e� d�Z)de*de+fd d �Z,de*de+fd d �Z-d ej.de/fd!d"�Z0dS )#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�Tuples | c @ s e Zd Zddd�ZdS )�_QuietException�returnNc C � d S �N� ��selfr r �K/opt/saltstack/salt/lib/python3.10/site-packages/tornado/http1connection.py�__init__- � z_QuietException.__init__�r N)�__name__� __module__� __qualname__r r r r r r , s r c @ sN e Zd ZdZdejddfdd�Zddd�Zd d d ee d e j ddfd 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 �loggerr Nc C s || _ d S r )r# )r r# r r r r 7 � z!_ExceptionLoggingContext.__init__c C r r r r r r r � __enter__: r z"_ExceptionLoggingContext.__enter__�typz Optional[Type[BaseException]]�value�tbc C sB |d ur |d us J �t |tj�rd S | jjd|||fd� t�d S )N�Uncaught exception��exc_info)� isinstancer �HTTPInputErrorr# �errorr )r r& r' r( r r r �__exit__= s �z!_ExceptionLoggingContext.__exit__r ) r r r! �__doc__�logging�Loggerr r% r � BaseException�types� TracebackTyper/ r r r r r" 1 s ����r" c @ s^ e Zd ZdZ ddedee dee dee dee d ee d ed dfd d �ZdS )�HTTP1ConnectionParametersz?Parameters for `.HTTP1Connection` and `.HTTP1ServerConnection`.FN� no_keep_alive� chunk_size�max_header_size�header_timeout� max_body_size� body_timeout� decompressr c C s6 || _ |pd| _|p d| _|| _|| _|| _|| _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)r7 r8 r9 r: r; r< r= )r r7 r8 r9 r: r; r< r= r r r r O s z"HTTP1ConnectionParameters.__init__)FNNNNNF) r r r! r0 �boolr �int�floatr r r r r r6 L s4 �������� �r6 c @ s� e Zd ZdZ dAdejdedee dee ddf dd �Z d e j de e fd d �Zd e j defd d�ZdBdd�Zdeeg df ddfdd�ZdBdd�ZdBdd�Zdejfdd�Zdeddfdd �Zd eddfd d �Z dCd ee je j f d!e j d"ee dd#fd$d%�Z d"e de fd&d'�Z d"e dd#fd(d)�Z!dBd*d+�Z"dDd-d.�Z#d e jd!e j defd/d0�Z$dEd2d3�Z%d4e de&e'e j f fd5d6�Z(d7ed!e j d e j dee d fd8d9�Z)d:ed e j ddfd;d<�Z*d e j ddfd=d>�Z+d e j ddfd?d@�Z,dS )F�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 r t� }|| _|| _|j| _| jjdur!| jjn| 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)rC rB r6 rD rE r7 r; Zmax_buffer_size�_max_body_sizer< � _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 rB rC rD rE r r r r t s. �� zHTTP1Connection.__init__�delegatec C s$ | j jr t|| j 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. )rD r= �_GzipMessageDelegater8 rF � _read_message)r rS r r r � read_response� s � z HTTP1Connection.read_responsec � s� �d}�z��z-| j jd| jjd�}| jjd u r |I d H }nHztj| j j�� | jj |t j d�I d H }W n1 tj yd | � � Y W W |r\t t�� |�� W d � n1 sWw Y d }| �� dS w | �|�\}}| jr}t�|�}|| _|}d| _nt�|�} | | _|| _| }| �| |� | _d}t t�� |�||�} | d ur�| I d H W d � n1 s�w Y | j d u r�d}W W |r�t t�� |�� W d � n1 s�w Y d }| �� dS d} | j�r/t |tj �s�J �| jd ur�| jj dkr�d} |j } | dk�rd} d| k�rd k �r.n n,d |v �s d |v �r&t� d | ��| �!|�I d H n|�"d �dk�rA| j#�sA| j �$d� | �s�| �%| j�rM|j nd||�} | d u�r�| j&d u �rc| I d H nRztj| j j�� | j& | t j d�I d H W n< tj �y� t'�(d| j)� | j � � Y W W |�r�t t�� |�� W d � n 1 �s�w Y d }| �� dS w d| _*| j#�r�| j�r�d}t t�� |�+� W d � n 1 �s�w Y | j,�-� �s�| j d u�r�| j �.� �s�| j �/| j0� | j,I d H | j�r| j�r| � � | j d u �r2W W |�r*t t�� |�� W d � n 1 �s%w Y d }| �� dS W nQ tj �y� } zCt'�(d| j)|� | j�sR| j �$d�I d H | � � W Y d }~W |�rxt t�� |�� W d � n 1 �ssw Y d }| �� dS d }~ww W |�r�t t�� |�� W d � n 1 �s�w Y d }| �� dS |�r�t t�� |�� W d � n 1 �s�w Y d }| �� w )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 )1rB Zread_until_regexrD r9 r: r Z with_timeout�io_loop�timer �StreamClosedError� TimeoutError�closer" r �on_connection_closerL �_parse_headersrC r Zparse_response_start_linerN rK Zparse_request_start_linerM rO �_can_keep_alive�headers_receivedr, �ResponseStartLine�method�coder- rU �getrH �write� _read_bodyrG r �inforE rI �finishrJ �done�closed�set_close_callback�_on_connection_close)r rS Zneed_delegate_closeZ header_futureZ header_dataZstart_line_str�headersZresp_start_line� start_lineZreq_start_lineZheader_recv_futureZ skip_bodyri Z body_future�er r r rU � s( �� �b � � � � � � H � � �� � � � � �� � � � � ��� �� � z HTTP1Connection._read_messagec C s0 d| _ d| _d| _| jdur| j�d� dS 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_callbackrB rq r r r r rL 8 s �z HTTP1Connection._clear_callbacks�callbackc C � || _ 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 receiving 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)rx �r ry r r r rq D s z"HTTP1Connection.set_close_callbackc C s> | j d ur| j }d | _ |� | j�� st| jd � | �� d S r )rx rJ ro r rL r{ r r r rr R s z$HTTP1Connection._on_connection_closec C s: | j d ur | j �� | �� | j�� st| jd � d S d S r )rB rb rL rJ ro r r r r r rb ^ s �zHTTP1Connection.closec C s. | � � | j}d| _| j�� st| 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)rL rB rJ ro r )r rB r r r �detache s zHTTP1Connection.detach�timeoutc C rz )ztSets the body timeout for a single request. Overrides the value from `.HTTP1ConnectionParameters`. N)rG )r r} r r r �set_body_timeoutt � z HTTP1Connection.set_body_timeoutr; c C rz )zwSets the body size limit for a single request. Overrides the value from `.HTTP1ConnectionParameters`. N)rF )r r; r r r �set_max_body_size{ r z!HTTP1Connection.set_max_body_sizert rs �chunk� Future[None]c C sL g }| j r,t|tj�s J �|| _|�t|d � d|d � d��� |jdv o)d|v| _njt|tj �s4J �| jdus;J �| j dusBJ �|| _ |�td|d |d f �� | jj d kor| jjd kor|j d vor|j d k pn|j dkord|v| _| jj d kr�| jr�d|d< | jj dkr�| j �dd��� dkr�d|d< | jr�d|d< | j s�| jjd ks�ttj |�j dkr�d| _nd|v r�t|d �| _nd| _dd� |�� D �}|�dd� |D �� |D ] }t�|�r�td| ��q�d}| j�� r�t� }| _ |� t � � � |� � |S t� }| _ d �!|�d }|�r|| �"|�7 }| j�#|�| _$t%| j$| j&� |S ) z+Implements `.HTTPConnection.write_headers`.r � � z HTTP/1.1)�POST�PUT�PATCHr\ NzHTTP/1.1 %d %s� �HTTP/1.1rX )�� rY rZ r[ rb � ConnectionzHTTP/1.0� � keep-alivez Keep-Alive�chunkedr] rY 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� �liner r r r� � s � z+Illegal characters (CR or LF) in header: %r� s )'rC r, r �RequestStartLinerM �appendr rh rP rg rO rN �versionri rK rj �lowerr rQ � parse_int�get_all�extend� CR_OR_LF_RE�search� ValueErrorrB rp r rw � set_exceptionr r` � exception�join� _format_chunkrk rR r �_on_write_complete) r rt rs r� �linesZ header_linesr� �future�datar r r � write_headers� sv " � ��� � � � � �z HTTP1Connection.write_headersc C sd | j d ur | j t|�8 _ | j dk r | j�� t�d��| jr0|r0tdt|� �d | d S |S )Nr z,Tried to write more data than Content-Lengthz%xr� )rQ �lenrB rb r �HTTPOutputErrorrP r )r r� r r r r� � s � z HTTP1Connection._format_chunkc C sj d}| j �� r t� }| _| j�t�� � | j�� |S 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) rB rp r rw r� r r` r� rk r� rR r r� )r r� r� r r r rk � s �zHTTP1Connection.writec C s� | j dur | j dkr | j�� s | j�� t�d| j ��| jr2| j�� s2| j�d�| _| j� | j � d| _ | j s;d| _ | j�d� | jdu rM| �d� dS t| j| j� dS )z$Implements `.HTTPConnection.finish`.Nr z0Tried to write %d bytes less than Content-Lengths 0 T)rQ rB rp rb r r� rP rk rR Zadd_done_callbackr� rH rI rK � set_nodelay�_finish_requestr r r r r rn � s* � �� zHTTP1Connection.finishr� c C sp |� � }|d urt|tj�s|�� | jd ur$| j}d | _| jj�|� | j d ur6| j }d | _ t |d � d S d S r ) r� r, r r` �resultrv rB r^ Z add_callbackrw r )r r� �excry r r r r� s �z"HTTP1Connection._on_write_completec C sd | j jrdS |�d�}|d ur|�� }|jdkr |dkS d|v s,t|�s,t|dd �dv r0|dkS dS ) NFr� r� rb r\ rh )rX ZGETr� )rD r7 rj r� r� � is_transfer_encoding_chunked�getattr)r rt rs Zconnection_headerr r r re ( s �z HTTP1Connection._can_keep_alive�Optional[Future[None]]c C sJ | � � | js| jr| �� d S | j�d� | j�� s#t| jd � d S d S )NF) rL rC rK rb rB r� rJ ro r )r r� r r r r� < s �z HTTP1Connection._finish_requestr� 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�eolrt rs r r r rd G s z HTTP1Connection._parse_headersri c s d|v rSd|d v r,t �d|d �� t� fdd�� D ��r&t�d|d ��� d |d< zt|d �}W n tyD t�d|d ��w tt|�| j krRt�d ��nd }t |�}|d krl|sc|d vrjt�d | ��d}|rs| � |�S |d ur}| � ||�S | j r�| �|�S d S ) Nr\ �,z,\s*c 3 s � | ] }|� d kV qdS )r Nr )r� �i��piecesr r r� _ s � 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 body)�re�split�anyr r- r� r� r r? rF r� �_read_chunked_body�_read_fixed_bodyrC �_read_body_until_close)r ri rs rS �content_lengthZ is_chunkedr r� r rl S sJ �� ��� � � zHTTP1Connection._read_bodyr� c � s� �|dkrI| j jt| jj|�dd�I d H }|t|�8 }| jr!| jrCtt �� |� |�}|d ur4|I d H W d � n1 s>w Y |dksd S d S )Nr T��partial) rB � read_bytes�minrD r8 r� rH rC r" r � data_received)r r� rS �body�retr r r r� � s � � � ��z HTTP1Connection._read_fixed_bodyc � sD �d} | j jddd�I d H }z tt|d d� ��}W n ty' t�d��w |dkr@| j �d�I d H }|dkr>t�d ��d S ||7 }|| jkrNt�d ��|}|r�| j jt || j j �dd �I d H }|t |�8 }| j rn| jr�tt�� |�|�}|d ur�|I d H W d � n1 s�w Y |sR| j �d�I d H }|dks�J �q) Nr Tr� �@ rW ���zinvalid chunk sizer� z%improperly terminated chunked requestzchunked body too larger� )rB Z read_until� parse_hex_intr r� r r- r� rF r� rD r8 r� rH rC r" r r� ) r rS Z total_sizeZ chunk_len_strZ chunk_lenZcrlfZ bytes_to_readr� r� r r r r� � sH � �� � � �� �z"HTTP1Connection._read_chunked_bodyc � s| �| j �� I d H }| jr| jr<tt�� |�|�}|d ur*|I d H W d � d S W d � d S 1 s5w Y d S d S r )rB Zread_until_closerH rC r" r r� )r rS r� r� r r r r� � s � �"��z&HTTP1Connection._read_body_until_close�NNr r )r� r� r N)r� r� r N)-r r r! r0 r �IOStreamr> r r6 �objectr r �HTTPMessageDelegater rV rU rL r rq rr rb r| r@ r~ r? r� r r� rg r� �bytesr� r� rk rn r� re r� r �strrd rl r� r� r� r r r r rA m s� ����� �9 z ���� �W �� � ��� �5�� �"��rA c @ s~ e Zd ZdZdejdededdfdd�Zd eej ej f d ej de e d fd d �Zd eddfdd�Zddd�Zddd�ZdS )rT zDWraps an `HTTPMessageDelegate` to decode ``Content-Encoding: gzip``.rS r8 r; r Nc C s" || _ || _|| _d| _d | _d S r� )� _delegate� _chunk_sizerF �_decompressed_body_size� _decompressor)r rS r8 r; r r r r � s z _GzipMessageDelegate.__init__rt rs c C s@ |� dd��� dkrt� | _|�d|d � |d= | j�||�S )NzContent-Encodingr� �gzipzX-Consumed-Content-Encoding)rj r� r r� �addr� rf )r rt rs r r r rf � s z%_GzipMessageDelegate.headers_receivedr� c � s� �| j rH|}|rF| j �|| j�}|r5| jt|�7 _| j| jkr&t�d��| j� |�}|d ur5|I d H | j j }|rB|sBt�d��|sd S d S | j� |�}|d urY|I d H d S d S )Nzdecompressed body too largez8encountered unconsumed gzip data without making progress) r� r= r� r� r� rF r r- r� r� �unconsumed_tail)r r� Zcompressed_dataZ decompressedr� r r r r� � s0 �� � � �z"_GzipMessageDelegate.data_receivedc C s* | j d ur| j �� }|rtd��| j�� S )Nz:decompressor.flush returned data; possible truncated input)r� �flushr� r� rn )r �tailr r r rn � s � z_GzipMessageDelegate.finishc C s | j �� S r )r� rc r r r r rc r$ z(_GzipMessageDelegate.on_connection_closer )r r r! r0 r r� r? r r r� rg r� r r rf r� r� rn rc r r r r rT � s* ��� � �� � rT c @ sl e Zd ZdZ ddejdee dee ddfdd�Z dd d �Z d e j ddfd d �Z d e j ddfdd�ZdS )�HTTP1ServerConnectionzAn HTTP/1.x server.NrB rD rE r c C s* || _ |du r t� }|| _|| _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)rB r6 rD rE �_serving_future)r rB rD rE r r r r s z HTTP1ServerConnection.__init__c � sB �| j �� | jdus J �z | jI dH W dS ty Y dS w )zmCloses the connection. Returns a `.Future` that resolves after the serving loop has exited. N)rB rb r� � Exceptionr r r r rb ! s � �zHTTP1ServerConnection.closerS 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>8 s z5HTTP1ServerConnection.start_serving.<locals>.<lambda>N) r, r � HTTPServerConnectionDelegater Zconvert_yielded�_server_request_loopr� rB r^ Z add_future)r rS Zfutr r r � start_serving/ s z#HTTP1ServerConnection.start_servingc � s� �zr t | jd| j| j�}|�| |�}z |�|�I d H }W nC tjtjt j fy3 Y W |� | � d S t yF |� � Y W |� | � d S ty` tjddd� |� � Y W |� | � d S w |skW |� | � d S t �d�I d H q|� | � w )NTFr) r* r )rA rB rD rE Z start_requestrV r r` ZUnsatisfiableReadError�asyncioZCancelledErrorZon_closer rb r� r r. �sleep)r rS �connZrequest_delegater� r r r r� : s< � � � ���� z*HTTP1ServerConnection._server_request_loopr� r )r r r! r0 r r� r r6 r� r rb r r� r� r� r r r r r� s( ���� � ��r� z[0-9]+z [0-9a-fA-F]+�sr c C s" t �| �du r td| ��t| �S )z+Parse a non-negative integer from a string.Nznot an integer: %r)�DIGITS� fullmatchr� r? �r� r r r r� \ s r� c C s$ t �| �du r td| ��t| d�S )z7Parse a non-negative hexadecimal integer from a string.Nz not a hexadecimal integer: %r� )� HEXDIGITSr� r� r? r� r r r r� c s r� rs c C sD d| vrdS d| v rt �d��| d �� dkrdS t �d| d ��)z�Returns true if the headers specify Transfer-Encoding: chunked. Raise httputil.HTTPInputError if any other transfer encoding is used. r] Fr\ z6Message with both Transfer-Encoding and Content-Lengthr� Tz Unsupported Transfer-Encoding %s)r r- r� )rs r r r r� j s � �r� )1r0 r� r1 r� r4 Ztornado.concurrentr r r Ztornado.escaper r Ztornador r r Z tornado.logr r Z tornado.utilr �typingr r r r r r r �compiler� r� r r" r6 �HTTPConnectionrA r� rT r� r� r� r� r? r� r� r� r> r� r r r r �<module> s: $ ! ZH M
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings