File manager - Edit - /usr/local/CyberCP/lib/python3.10/site-packages/tornado/__pycache__/http1connection.cpython-310.pyc
Back
o �h8� � @ sj 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� de!�Z"G dd� de!�Z#G dd� dej$�Z%G dd� dej&�Z'G dd� de!�Z(e� d�Z)e� d�Z*de+de,fd d �Z-de+de,fd d �Z.d ej/de0fd!d"�Z1dS )#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 �J/usr/local/CyberCP/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 s2 |d ur|d us J �| 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 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)r5 r6 r7 r8 r9 r: r; )r r5 r6 r7 r8 r9 r: r; r r r r L s z"HTTP1ConnectionParameters.__init__)FNNNNNF) r r r! r. �boolr �int�floatr r r r r r4 I s4 �������� �r4 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)rA r@ r4 rB rC r5 r9 �max_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 r@ rA rB rC r r r r q s. �� zHTTP1Connection.__init__�delegatec C s | j jr t|| 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. )rB r; �_GzipMessageDelegater6 � _read_message)r rR 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 ? ? �� max_bytes)�quiet_exceptionsT�HEAD�0 �d �� �Content-Length�Transfer-Encodingz!Response code %d cannot have body�Expectz 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@ �read_until_regexrB r7 r8 r � with_timeout�io_loop�timer �StreamClosedError� TimeoutError�closer" r �on_connection_closerK �_parse_headersrA r �parse_response_start_linerM rJ �parse_request_start_linerL rN �_can_keep_alive�headers_received� isinstance�ResponseStartLine�method�code�HTTPInputErrorrT �getrG �write� _read_bodyrF r �inforC rH �finishrI �done�closed�set_close_callback�_on_connection_close)r rR �need_delegate_close� header_future� header_data�start_line_str�headers�resp_start_line� start_line�req_start_line�header_recv_future� skip_bodyrp � body_future�er r r rT � 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_callbackr@ ry r r r r rK 3 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)r� �r r� r r r ry ? s z"HTTP1Connection.set_close_callbackc C s> | j d ur| j }d | _ |� | j�� st| jd � | �� d S r )r� rI rw r rK r� r r r rz M s z$HTTP1Connection._on_connection_closec C s: | j d ur | j �� | �� | j�� st| jd � d S d S r )r@ rf rK rI rw r r r r r rf Y 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)rK r@ rI rw r )r r@ r r r �detach` s zHTTP1Connection.detach�timeoutc C r� )ztSets the body timeout for a single request. Overrides the value from `.HTTP1ConnectionParameters`. N)rF )r r� r r r �set_body_timeouto � z HTTP1Connection.set_body_timeoutr9 c C r� )zwSets the body size limit for a single request. Overrides the value from `.HTTP1ConnectionParameters`. N)rE )r r9 r r r �set_max_body_sizev r� z!HTTP1Connection.set_max_body_sizer� r �chunk� Future[None]c C sH g }| j r*t|tj�s J �|| _|�td|d |d f �� |jdv o'd|v| _njt|tj �s2J �| jdus9J �| j dus@J �|| _ |�td|d |d f �� | jj d kop| jjd kop|j d vop|j d k pl|j d kopd|v| _| jj d kr| jrd|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`.z%s %s HTTP/1.1r � )�POST�PUT�PATCHr] NzHTTP/1.1 %d %s� �HTTP/1.1rY )�� rZ r[ r\ rf � ConnectionzHTTP/1.0� � keep-alivez Keep-Alive�chunkedr^ rZ 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 )'rA rm r �RequestStartLinerL �appendr ro rO rn rN rM �versionrp rJ rr �lowerr rP � parse_int�get_all�extend� CR_OR_LF_RE�search� ValueErrorr@ rx r r� � set_exceptionr rd � exception�join� _format_chunkrs rQ r �_on_write_complete) r r� r r� �lines� 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� )rP �lenr@ rf r �HTTPOutputErrorrO 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) r@ rx r r� r� r rd r� rs r� rQ r r� )r r� r� r r r rs � 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)rP r@ rx rf r r� rO rs rQ �add_done_callbackr� rG rH rJ � set_nodelay�_finish_requestr r r r r rv � 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� rm r rd �resultr� r@ rb � add_callbackr� r )r r� �excr� 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� rf r] ro )rY �GETr� )rB r5 rr r� r� � is_transfer_encoding_chunked�getattr)r r� r �connection_headerr r r rk # 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) rK rA rJ rf r@ r� rI rw r )r r� r r r r� 7 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� �data_str�eolr� r r r r rh B s z HTTP1Connection._parse_headersrp 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� Z 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 rq r� r� r r= rE r� �_read_chunked_body�_read_fixed_bodyrA �_read_body_until_close)r rp r rR �content_length� is_chunkedr r� r rt N 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) r@ � read_bytes�minrB r6 r� rG rA r" r � data_received)r r� rR �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� �@ rV ���zinvalid chunk sizer� z%improperly terminated chunked requestzchunked body too larger� )r@ � read_until� parse_hex_intr r� r rq r� rE r� rB r6 r� rG rA r" r r� ) r rR � total_size� chunk_len_str� chunk_len�crlf� 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 )r@ �read_until_closerG rA r" r r� )r rR 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! r. r �IOStreamr< r r4 �objectr r �HTTPMessageDelegater rU rT rK r ry rz rf r� r> r� r= r� r r� rn r� �bytesr� r� rs rv r� rk r� r �strrh rt r� r� r� r r r r r? j s� ����� �9 z ���� �W �� � ��� �5�� �"��r? c @ sz e Zd ZdZdejdeddfdd�Zdeej ej f d ej de e d fd d �Zd eddfd d�Zddd�Zddd�ZdS )rS zDWraps an `HTTPMessageDelegate` to decode ``Content-Encoding: gzip``.rR r6 r Nc C s || _ || _d | _d S r )� _delegate� _chunk_size� _decompressor)r rR r6 r r r r � s z _GzipMessageDelegate.__init__r� r c C s@ |� dd��� dkrt� | _|�d|d � |d= | j�||�S )NzContent-Encodingr� �gzipzX-Consumed-Content-Encoding)rr r� r r� �addr� rl )r r� r r r r rl � s z%_GzipMessageDelegate.headers_receivedr� c � s� �| j r4|}|r2| j �|| j�}|r!| j�|�}|d ur!|I d H | j j}|r.|s.t�d��|sd S d S | j�|�}|d urE|I d H d S d S )Nz8encountered unconsumed gzip data without making progress)r� r; r� r� r� �unconsumed_tailr rq )r r� �compressed_data� decompressedr� r r r r� � s* �� � � �z"_GzipMessageDelegate.data_receivedc C s* | j d ur| j �� }|rtd��| j�� S )Nz:decompressor.flush returned data; possible truncated input)r� �flushr� r� rv )r �tailr r r rv � s � z_GzipMessageDelegate.finishc C s | j �� S r )r� rg r r r r rg � r$ z(_GzipMessageDelegate.on_connection_closer )r r r! r. r r� r= r r r� rn r� r r rl r� r� rv rg r r r r rS � s �� � rS 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.Nr@ rB rC 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)r@ r4 rB rC �_serving_future)r r@ rB rC 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)r@ rf r � Exceptionr r r r rf s � �zHTTP1ServerConnection.closerR 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>) s z5HTTP1ServerConnection.start_serving.<locals>.<lambda>N) rm r � HTTPServerConnectionDelegater �convert_yielded�_server_request_loopr r@ rb � add_future)r rR �futr 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 )r? r@ rB rC � start_requestrU r rd �UnsatisfiableReadError�asyncio�CancelledError�on_closer rf r r r, �sleep)r rR �conn�request_delegater� r r r r + s< � � � ���� z*HTTP1ServerConnection._server_request_loopr� r )r r r! r. r r� r r4 r� r rf 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� M 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� T s r� r 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 rq r� )r r r r r� [ s � �r� )2r. r r/ r� r2 �tornado.concurrentr r r �tornado.escaper r �tornador r r � tornado.logr r � tornado.utilr �typingr r r r r r r �compiler� r r r� r" r4 �HTTPConnectionr? r� rS r� r r r� r= r� r� r� r< r� r r r r �<module> s: $ ! X> M
| ver. 1.4 |
Github
|
.
| PHP 8.2.28 | Generation time: 0.02 |
proxy
|
phpinfo
|
Settings