File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/ext/tornado/__pycache__/http1connection.cpython-310.pyc
Back
o ;j� � @ s d Z ddlmZmZmZ ddlZddlmZ ddlm Z m Z ddl m Z ddl m Z ddl mZ dd lmZmZ dd l mZ dd lmZmZ e�d �ZG d d� de�ZG dd� de�ZG dd� de�Z G dd� de j �Z G dd� de j �Z G dd� de�Z!de j"de#fdd �Z$dS ) zFClient and server implementations of HTTP/1.x. .. versionadded:: 4.0 � )�absolute_import�division�print_functionN)�Future)� native_str�utf8)�gen)�httputil)�iostream)�gen_log�app_log)� stack_context)�GzipDecompressor�PY3s | c @ s e Zd Zdd� ZdS )�_QuietExceptionc C � d S �N� ��selfr r �T/opt/saltstack/salt/lib/python3.10/site-packages/salt/ext/tornado/http1connection.py�__init__) � z_QuietException.__init__N)�__name__� __module__� __qualname__r r r r r r ( s r c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) �_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 c C s || _ d S r )�logger)r r r r r r 2 � z!_ExceptionLoggingContext.__init__c C r r r r r r r � __enter__5 r z"_ExceptionLoggingContext.__enter__c C s& |d ur| j jd|||fd� t�d S )N�Uncaught exception��exc_info)r �errorr )r �typ�value�tbr r r �__exit__8 s �z!_ExceptionLoggingContext.__exit__N)r r r �__doc__r r r' r r r r r - s r c @ s e Zd ZdZ ddd�ZdS )�HTTP1ConnectionParameterszDParameters for `.HTTP1Connection` and `.HTTP1ServerConnection`. FNc 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)� no_keep_alive� chunk_size�max_header_size�header_timeout� max_body_size� body_timeout� decompress)r r* r+ r, r- r. r/ r0 r r r r A s z"HTTP1ConnectionParameters.__init__)FNNNNNF)r r r r( r r r r r r) > s �r) c @ s� e Zd ZdZd/dd�Zdd� Zejdd� �Zd d � Z d d � Z d d� Z dd� Z dd� Z dd� Zdd� Zd/dd�Zdd� Zd0dd �Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zejd)d*� �Zejd+d,� �Zejd-d.� �ZdS )1�HTTP1Connectionz�Implements the HTTP/1.x protocol. This class can be on its own for clients, or via `HTTP1ServerConnection` for servers. Nc C s� || _ || _|du r t� }|| _|| _|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)� is_client�streamr) �params�contextr* 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 r3 r2 r4 r5 r r r r ^ s, � zHTTP1Connection.__init__c C s | j jr t|| j j�}| �|�S )aH 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 None after the full response has been read. )r4 r0 �_GzipMessageDelegater+ � _read_message�r �delegater r r � read_response� s z HTTP1Connection.read_responsec c s� � d}�z̐z�| j jd| jjd�}| jjd u r|V }n)ztj| j j�� | jj || j jt j d�V }W n tj yC | � � t� d��w | �|�\}}| jrWt�|�}|| _n t�|�}|| _|| _| �||� | _d}tt�� |�||�}|d ur~|V W d � n1 s�w Y | j d u r�d}t� d��d}| jr�| jd ur�| jjdkr�d}|j }|dkr�d}|dkr�|d k r�d |v s�d |v r�t� d | ��| � |�V n|� d �dkr�| j s�| j �!d� |�s2| �"| jr�|j nd||�} | d u�r2| j#d u �r| V n1ztj| j j�� | j# | | j jt j d�V W n tj �y1 t$�%d| j&� | j � � t� d��w d| _'| j �r=| j�rXd}tt�� |�(� W d � n 1 �sSw Y | j)�*� �su| j d u�ru| j �+� �su| j �,| j-� | j)V | j�r�| j�r�| � � | j d u �r�t� d��W n tj �y� } zt$�%d| j&| � | � � t� d��d } ~ ww W |�r�tt�� |�.� W d � n 1 �s�w Y d }| �/� n#|�r�tt�� |�.� W d � n 1 �s�w Y d }| �/� w t� d��)NFs ? ? �Z max_bytes)�io_loop�quiet_exceptionsT�HEAD�0 �d �� �Content-Length�Transfer-Encodingz!Response code %d cannot have bodyZExpectz 100-continues HTTP/1.1 100 (Continue) r )rJ z Timeout reading body from %sz"Malformed HTTP message from %s: %s)0r3 Zread_until_regexr4 r, r- r Z with_timeoutrI �timer �StreamClosedError� TimeoutError�closeZReturn�_parse_headersr2 r Zparse_response_start_liner> Zparse_request_start_liner= r? �_can_keep_aliver; r r �headers_received�method�code�HTTPInputErrorrD �getr8 �write� _read_bodyr7 r �infor5 r9 �finishr: �done�closed�set_close_callback�_on_connection_close�on_connection_closer< ) r rF Zneed_delegate_closeZ header_futureZ header_data� start_line�headersZ skip_bodyrY Z body_future�er r r rD � s� �� � � � � � � �� � �� � � � �� ��� � � � 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_callbackr3 rb r r r r r< s �z HTTP1Connection._clear_callbacksc C s t �|�| _dS )z�Sets a callback that will be run when the connection is closed. .. deprecated:: 4.0 Use `.HTTPMessageDelegate.on_connection_close` instead. N)r �wraprj �r �callbackr r r rb s z"HTTP1Connection.set_close_callbackc C s> | j d ur| j }d | _ |� | j�� s| j�d � | �� d S r )rj r: r` � set_resultr< rl r r r rc s z$HTTP1Connection._on_connection_closec C s: | j d ur | j �� | �� | j�� s| j�d � d S d S r )r3 rT r< r: r` rn r r r r rT , s �zHTTP1Connection.closec C s. | � � | j}d| _| j�� s| j�d� |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)r< r3 r: r` rn )r r3 r r r �detach3 s zHTTP1Connection.detachc C � || _ dS )ztSets the body timeout for a single request. Overrides the value from `.HTTP1ConnectionParameters`. N)r7 )r �timeoutr r r �set_body_timeoutB � z HTTP1Connection.set_body_timeoutc C rp )zwSets the body size limit for a single request. Overrides the value from `.HTTP1ConnectionParameters`. N)r6 )r r. r r r �set_max_body_sizeI rs z!HTTP1Connection.set_max_body_sizec C s g }| j r"|| _|�td|d |d f �� |jdv o d|v| _nE|| _|�td|d |d f �� | jjdkoP|jd voP|jd k pH|jd koPd|voPd |v| _| jjd krg| j � dd�� � dkrgd|d< | jrnd|d < | j s�| jjdks||jdkr�d| _ nd|v r�t |d �| _ nd| _ dd� |�� D �}tr�|�dd� |D �� n|�|� |D ] }t�|�r�td| ��q�d}| j�� r�t� }| _|�t�� � |�� |S |dur�t � |�| _ nt� }| _d� |�d } |r�| | � |�7 } | j�!| �| _"| j"�#| j$� |S ) z+Implements `.HTTPConnection.write_headers`.z%s %s HTTP/1.1r � )�POST�PUT�PATCHrO zHTTP/1.1 %d %s� �HTTP/1.1)�� rL rM rN rP zHTTP/1.0� Connection� � keep-alivez Keep-Alive�chunkedrK rL Nc 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� � s � z+Illegal characters (CR or LF) in header: %r� s )%r2 r= �appendr rX r@ r> �versionrY r? r[ �lowerrA �int�get_allr �extend� CR_OR_LF_RE�search� ValueErrorr3 ra r ri � set_exceptionr rR � exceptionr rk rh �join� _format_chunkr\ rB �add_done_callback�_on_write_complete) r re rf �chunkrm �linesZ header_lines�line�future�datar r r � write_headersP sn � ��� � � � � 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� )rA �lenr3 rT r �HTTPOutputErrorr@ r )r r� r r r r� � s � z HTTP1Connection._format_chunkc C s� d}| j �� r t� }| _| j�t�� � | j�� |S |dur't� |�| _ nt� }| _| j � | � |��| _ | j �| j� |S )z�Implements `.HTTPConnection.write`. For backwards compatibility is is allowed but deprecated to skip `write_headers` and instead call `write()` with a pre-encoded header block. N)r3 ra r ri r� r rR r� r rk rh r\ r� rB r� r� )r r� rm r� r r r r\ � 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 | j� | j� dS )z$Implements `.HTTPConnection.finish`.Nr z0Tried to write %d bytes less than Content-Lengths 0 T)rA r3 ra rT r r� r@ r\ rB r� r� r8 r9 r; � set_nodelay�_finish_requestr r r r r_ � s* � �� zHTTP1Connection.finishc C sp |� � }|d urt|tj�s|�� | jd ur$| j}d | _| jj�|� | j d ur6| j }d | _ |� d � d S d S r ) r� � isinstancer rR �resultrh r3 rI Z add_callbackri rn )r r� �excrm 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| rz rT rO rX )rK ZGETr~ )r4 r* r[ r� r� � is_transfer_encoding_chunked�getattr)r re rf Zconnection_headerr r r rV � s �z HTTP1Connection._can_keep_alivec C sJ | � � | js| jr| �� d S | j�d� | j�� s#| j�d � d S d S )NF) r< r2 r; rT r3 r� r: r` rn )r r� r r r r� � s �z HTTP1Connection._finish_requestc C st t |�d���d�}|�d�}|d |� �d�}ztj�||d � �}W ||fS ty9 t� d||d� ��w )Nr� z � � zMalformed HTTP headers: %rrM ) r �decode�lstrip�find�rstripr � HTTPHeaders�parser� rZ )r r� �eolre rf r r r rU s � ��z HTTP1Connection._parse_headersc s d|v rPd|d v r,t �d|d �� t� fdd�� D ��r&t�d|d ��� d |d< zt|d �}W n tyD t�d|d ��w || jkrOt�d ��nd }t|�}|d kri|s`|d vrgt�d | ��d}|rp| � |�S |d urz| � ||�S | j r�| � |�S d S ) NrO �,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 rZ r� r� r6 r� �_read_chunked_body�_read_fixed_bodyr2 �_read_body_until_close)r rY rf rF �content_lengthZ is_chunkedr r� r r] sF �� �� � � zHTTP1Connection._read_bodyc c s� � |dkrE| j jt| jj|�dd�V }|t|�8 }| jr | jr?tt �� |� |�}|d ur0|V W d � n1 s:w Y |dksd S d S )Nr T��partial) r3 � read_bytes�minr4 r+ r� r8 r2 r r � data_received)r r� rF �body�retr r r r� @ s �� � ��z HTTP1Connection._read_fixed_bodyc c s � d} | j jddd�V }t|�� d�}|dkr*| j �d�V }|dkr(t�d��d S ||7 }|| jkr8t�d ��|}|rx| j jt|| j j �dd �V }|t |�8 }| j rV| j rvtt�� |�|�}|d urg|V W d � n1 sqw Y |s<| j �d�V }|dks�J �q) Nr Tr� �@ rH � ry z%improperly terminated chunked requestzchunked body too larger� )r3 Z read_untilr� �stripr� r rZ r6 r� r4 r+ r� r8 r2 r r r� )r rF Z total_sizeZ chunk_lenZcrlfZ bytes_to_readr� r� r r r r� L s< � � � �� �z"HTTP1Connection._read_chunked_bodyc c sV � | j �� V }| jr | jr)tt�� |�|� W d � d S 1 s"w Y d S d S r )r3 Zread_until_closer8 r2 r r r� )r rF r� r r r r� i s � "��z&HTTP1Connection._read_body_until_close�NNr ) r r r r( r rG r � coroutinerD r< rb rc rT ro rr rt r� r� r\ r_ r� rV r� rU r] r� r� r� r r r r r1 X s8 0 n H . r1 c @ s> e Zd ZdZdd� Zdd� Zejdd� �Zdd � Z d d � Z d S ) rC zIWraps an `HTTPMessageDelegate` to decode ``Content-Encoding: gzip``. c C s || _ || _d | _d S r )� _delegate� _chunk_size� _decompressor)r rF r+ r r r r t s z _GzipMessageDelegate.__init__c C s: |� d�dkrt� | _|�d|d � |d= | j�||�S )NzContent-Encoding�gzipzX-Consumed-Content-Encoding)r[ r r� �addr� rW )r re rf r r r rW y s �z%_GzipMessageDelegate.headers_receivedc c st � | j r)|}|r'| j �|| j�}|r | j�|�}|d ur |V | j j}|sd S d S | j�|�}|d ur8|V d S d S r )r� r0 r� r� r� �unconsumed_tail)r r� Zcompressed_dataZ decompressedr� r r r r� � s" �� � �z"_GzipMessageDelegate.data_receivedc C s. | j d ur| j �� }|r| j�|� | j�� S r )r� �flushr� r� r_ )r �tailr r r r_ � s z_GzipMessageDelegate.finishc C s | j �� S r )r� rd r r r r rd � r z(_GzipMessageDelegate.on_connection_closeN) r r r r( r rW r r� r� r_ rd r r r r rC q s rC c @ s> e Zd ZdZd dd�Zejdd� �Zdd� Zejd d � �Z dS ) �HTTP1ServerConnectionzAn HTTP/1.x server.Nc 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)r3 r) r4 r5 �_serving_future)r r3 r4 r5 r r r r � s z HTTP1ServerConnection.__init__c c s0 � | j �� z| jV W dS ty Y dS w )zmCloses the connection. Returns a `.Future` that resolves after the serving loop has exited. N)r3 rT r� � Exceptionr r r r rT � s � �zHTTP1ServerConnection.closec C s6 t |tj�sJ �| �|�| _| jj�| jdd� � 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)r� r Z HTTPServerConnectionDelegate�_server_request_loopr� r3 rI Z add_futurerE r r r � start_serving� s �z#HTTP1ServerConnection.start_servingc c s� � zj t | jd| j| j�}|�| |�}z|�|�V }W nA tjtjfy/ Y W |� | � d S t yB |� � Y W |� | � d S t y\ t jddd� |� � Y W |� | � d S w |sgW |� | � d S tjV q|� | � w )NTFr r! )r1 r3 r4 r5 Z start_requestrG r rR ZUnsatisfiableReadErrorZon_closer rT r� r r# r Zmoment)r rF �connZrequest_delegater� r r r r� � s< �� � � ���� z*HTTP1ServerConnection._server_request_loopr� ) r r r r( r r r� rT r� r� r r r r r� � s r� rf �returnc 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. rP FrO z6Message with both Transfer-Encoding and Content-Lengthr Tz Unsupported Transfer-Encoding %s)r rZ r� )rf r r r r� � s � �r� )%r( � __future__r r r r� Zsalt.ext.tornado.concurrentr Zsalt.ext.tornado.escaper r Zsalt.ext.tornador r r Zsalt.ext.tornado.logr r r Zsalt.ext.tornado.utilr r �compiler� r� r �objectr r) �HTTPConnectionr1 ZHTTPMessageDelegaterC r� r� �boolr� r r r r �<module> s. 4D
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings