Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/tornado/__pycache__/simple_httpclient.cpython-39.pyc
Ðазад
a _�hun � @ s� d dl mZ d dlmZ d dlmZmZmZmZm Z m Z d dlm Z d dl m Z mZ d dlmZ d dlmZmZ d dlmZmZmZmZ d d lmZ d d lm Z d d l Z d d l Z d d l Z d d l Z d d l!Z!d d l"Z"d d l#Z#d d l$Z$d d l%Z%d d l&m'Z' d d l(Z)d d l*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0 d dl1m2Z2 d d l*Z*e*j3�rLd dl*m4Z4m5Z5m6Z6 G dd� de�Z7G dd� de�Z8G dd� de�Z9G dd� de j:�Z;e<dk�r�e�=e9� e� d S )� )�_unicode)�gen)� HTTPResponse� HTTPError�AsyncHTTPClient�main� _RequestProxy� HTTPRequest)�httputil)�HTTP1Connection�HTTP1ConnectionParameters)�IOLoop)�StreamClosedError�IOStream)�Resolver�OverrideResolver�_client_ssl_defaults� is_valid_ip)�gen_log)� TCPClientN)�BytesIO)�Dict�Any�Callable�Optional�Type�Union)� TracebackType)�Deque�Tuple�Listc s6 e Zd ZdZedd�� fdd� Zed�dd�Z� ZS ) �HTTPTimeoutErrorz�Error raised by SimpleAsyncHTTPClient on timeout. For historical reasons, this is a subclass of `.HTTPClientError` which simulates a response code of 599. .. versionadded:: 5.1 N��message�returnc s t t| �jd|d� d S �N�W �r# )�superr! �__init__��selfr# �� __class__� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/tornado/simple_httpclient.pyr) 5 s zHTTPTimeoutError.__init__�r$ c C s | j pdS )N�Timeoutr' �r+ r. r. r/ �__str__8 s zHTTPTimeoutError.__str__��__name__� __module__� __qualname__�__doc__�strr) r3 � __classcell__r. r. r, r/ r! , s r! c s6 e Zd ZdZedd�� fdd� Zed�dd�Z� ZS ) �HTTPStreamClosedErroraZ Error raised by SimpleAsyncHTTPClient when the underlying stream is closed. When a more specific exception is available (such as `ConnectionResetError`), it may be raised instead of this one. For historical reasons, this is a subclass of `.HTTPClientError` which simulates a response code of 599. .. versionadded:: 5.1 Nr" c s t t| �jd|d� d S r% )r( r; r) r* r, r. r/ r) H s z HTTPStreamClosedError.__init__r0 c C s | j pdS )N� Stream closedr' r2 r. r. r/ r3 K s z HTTPStreamClosedError.__str__r4 r. r. r, r/ r; < s r; c s� e Zd ZdZd eeeef eeeeef eedd�� fdd� Z dd�� fd d � Z e e e gdf dd �d d �Zdd�dd�Zed�dd�Ze e g df e e gdf dd�dd�Zedd�dd�Zedd�dd�Zd eedd�dd �Z� ZS ) �SimpleAsyncHTTPClientai Non-blocking HTTP client with no external dependencies. This class implements an HTTP 1.1 client on top of Tornado's IOStreams. Some features found in the curl-based AsyncHTTPClient are not yet supported. In particular, proxies are not supported, connections are not reused, and callers cannot select the network interface to be used. � N� @)� max_clients�hostname_mapping�max_buffer_size�resolver�defaults�max_header_size� max_body_sizer$ c s� t t| �j|d� || _t�� | _i | _i | _|| _ || _ || _ |rR|| _ d| _ nt� | _ d| _ |durxt| j |d�| _ t| j d�| _dS )a Creates a AsyncHTTPClient. Only a single AsyncHTTPClient instance exists per IOLoop in order to provide limitations on the number of pending connections. ``force_instance=True`` may be used to suppress this behavior. Note that because of this implicit reuse, unless ``force_instance`` is used, only the first call to the constructor actually uses its arguments. It is recommended to use the ``configure`` method instead of the constructor to ensure that arguments take effect. ``max_clients`` is the number of concurrent requests that can be in progress; when this limit is reached additional requests will be queued. Note that time spent waiting in this queue still counts against the ``request_timeout``. ``hostname_mapping`` is a dictionary mapping hostnames to IP addresses. It can be used to make local DNS changes when modifying system-wide settings like ``/etc/hosts`` is not possible or desirable (e.g. in unittests). ``max_buffer_size`` (default 100MB) is the number of bytes that can be read into memory at once. ``max_body_size`` (defaults to ``max_buffer_size``) is the largest response body that the client will accept. Without a ``streaming_callback``, the smaller of these two limits applies; with a ``streaming_callback`` only ``max_body_size`` does. .. versionchanged:: 4.2 Added the ``max_body_size`` argument. )rD FTN)rC �mapping)rC )r( r= � initializer@ � collections�deque�queue�active�waitingrB rE rF rC � own_resolverr r r � tcp_client)r+ r@ rA rB rC rD rE rF r, r. r/ rH Y s* *����z SimpleAsyncHTTPClient.initializer0 c s, t t| ��� | jr | j�� | j�� d S �N)r( r= �closerN rC rO r2 r, r. r/ rQ � s zSimpleAsyncHTTPClient.close)�request�callbackr$ c C s� t � }| j�|||f� t| j�| jk st|jd us6J �|jd usDJ �| j� | j� � t |j|j� t � | j|d��}nd }|||f| j|< | �� | jr�t�dt| j�t| j�f � d S )Nzin request queuezImax_clients limit reached, request queued. %d active, %d queued requests.)�objectrK �append�lenrL r@ �connect_timeout�request_timeout�io_loop� add_timeout�time�min� functools�partial� _on_timeoutrM �_process_queuer �debug)r+ rR rS �key�timeout_handler. r. r/ � fetch_impl� s( ����z SimpleAsyncHTTPClient.fetch_implc C sl | j rht| j�| jk rh| j �� \}}}|| jvr2q | �|� ||f| j|< t�| j |�}| � |||� q d S rP ) rK rV rL r@ �popleftrM �_remove_timeoutr] r^ �_release_fetch�_handle_request)r+ rb rR rS �release_callbackr. r. r/ r` � s z$SimpleAsyncHTTPClient._process_queuec C s t S rP )�_HTTPConnectionr2 r. r. r/ �_connection_class� s z'SimpleAsyncHTTPClient._connection_class)rR ri �final_callbackr$ c C s& | � � | |||| j| j| j| j� d S rP )rk rB rO rE rF )r+ rR ri rl r. r. r/ rh � s �z%SimpleAsyncHTTPClient._handle_request)rb r$ c C s | j |= | �� d S rP )rL r` )r+ rb r. r. r/ rg � s z$SimpleAsyncHTTPClient._release_fetchc C s: || j v r6| j | \}}}|d ur.| j�|� | j |= d S rP )rM rY �remove_timeout)r+ rb rR rS rc r. r. r/ rf � s z%SimpleAsyncHTTPClient._remove_timeout)rb �infor$ c C sn | j | \}}}| j�|||f� |r0d�|�nd}t|dt|�| j�� |j d�}| j� ||� | j |= dS )z�Timeout callback of request. Construct a timeout HTTPResponse when a timeout occurs. :arg object key: A simple object to mark the request. :info string key: More detailed timeout information. � Timeout {0}r1 r& )�error� request_timeN) rM rK �remove�formatr r! rY r[ � start_time� add_callback)r+ rb rn rR rS rc � error_messageZtimeout_responser. r. r/ r_ � s �z!SimpleAsyncHTTPClient._on_timeout)r> Nr? NNNN)N)r5 r6 r7 r8 �intr r9 r r rH rQ r r r rd r` �typerk rh rT rg rf r_ r: r. r. r, r/ r= O s@ � �F� � r= c @ s` e Zd Zeg d��Zee eeg df ee gdf e e e e dd� dd�Z dd�dd�Z eedeeef ejf d �d d �Zd.edd �d d�Zdd�dd�Zeed�dd�Zedd�dd�Zdd�dd�Z e dd�dd�Z d ee ee ed �d d �Z dd�d d!�Z!ee"j#e"j$f e"j%dd"�d#d$�Z&ed�d%d&�Z'dd�d'd(�Z(dd�d)d*�Z)e*dd+�d,d-�Z+dS )/rj )�GET�HEAD�POST�PUT�DELETE�PATCH�OPTIONSN) �clientrR ri rl rB rO rE rF r$ c C s� t �� | _| j�� | _t�� | _|| _|| _|| _|| _ || _ || _ || _ || _ d | _d | _g | _d | _d | _d | _t �� �t�| �� �dd� � d S )Nc S s | � � S rP ��result��fr. r. r/ �<lambda> � z*_HTTPConnection.__init__.<locals>.<lambda>)r �currentrY r[ rt �start_wall_timer� rR ri rl rB rO rE rF �code�headers�chunks� _decompressor�_timeout� _sockaddrZ add_futurer Zconvert_yielded�run) r+ r� rR ri rl rB rO rE rF r. r. r/ r) s( �z_HTTPConnection.__init__r0 c � s� �z�t j�t| jj��| _| jjdvr6td| jj ��| jj }d|v rV|� d�\}}}t � |�\}}|d u r�| jjdkr|dnd}t �d|�r�|dd � }|| _| jjd u r�tj}ntj}| �| jj�}d }| jjr�t| jj�r�| jj}ntd | jjf ��t| jj| jj�} | �r�| j�| j | t � | j d ��| _ | j!j"||||| j#|d �I d H } | j$d u �rl| �%� W d S | | _&| j&�'| j(� | �)� | j$d u �r�W d S | jj�r�| j�| j | jj t � | j d��| _ | jj*| j+v�r�| jj,�s�t-d| jj* ��dD ]"} t.| j| d ��r�t/d| ���q�d| jj0v�r4d| jj0d< d| jj0v�r|d| jj v �rl| jj � d�d | jj0d< n| jj | jj0d< d\} } | jj1d u�r�| jj1| jj2 } } n$| jj3d u�r�| jj3} | jj4�p�d} | d u�r | d u�s�J �| jj5dv�r�td| jj5��dtt6�7t �8| | ��� | jj0d< | jj9�r:| jj9| jj0d< | jj,�s�| jj*d v }| jj:d u�ph| jj;d u}|�rv|�r�|�r�|�s�td |�r�d nd| jj*f ��| jj<�r�d | jj0d < | jj:d u�r�t=t>| jj:��| jj0d!< | jj*d"k�rd#| jj0v�rd$| jj0d#< | jj?�rd%| jj0d&< | jj@�p&d'| jjA�r<d(| jjA nd }| �B| �| _Ct �D| jj*|d�}| jC�E|| jj0� | jj<�r�| jC�F| �I d H n| �Gd)�I d H W n& tH�y� | jItJ�K� � �sà Y n0 d S )*N)�http�httpszUnsupported url scheme: %s�@r� i� �P z^\[.*\]$� ���Fz?Unrecognized IPv4 or IPv6 address for network_interface, got %rzwhile connecting)�af� ssl_optionsrB � source_ipzduring requestzunknown method %s)Z proxy_hostZ proxy_portZproxy_usernameZproxy_passwordZproxy_auth_modez%s not supported� ConnectionrQ �Host)NN� )N�basiczunsupported auth_mode %szBasic � Authorizationz User-Agent)r{ r~ r| zLBody must %sbe None for method %s (unless allow_nonstandard_methods is true)znot z 100-continueZExpect�Content-Lengthr{ � Content-Typez!application/x-www-form-urlencoded�gzipzAccept-Encoding�/�?T)L�urllib�parse�urlsplitr rR �url�parsed�scheme� ValueError�netloc� rpartitionr Zsplit_host_and_port�re�matchZparsed_hostnameZ allow_ipv6�socket�AF_INET� AF_UNSPEC�_get_ssl_optionsZnetwork_interfacer r\ rW rX rY rZ rt r] r^ r_ r� rO �connectrB rl rQ �streamZset_close_callback�on_connection_closerf �method�_SUPPORTED_METHODSZallow_nonstandard_methods�KeyError�getattr�NotImplementedErrorr� �username�passwordZ auth_usernameZ auth_passwordZ auth_mode�base64� b64encodeZencode_username_password� user_agent�body� body_producer�expect_100_continuer9 rV �decompress_response�path�query�_create_connection� connection�RequestStartLineZ write_headers� read_response� _write_body� Exception�_handle_exception�sys�exc_info)r+ r� Zuserpass�_�host�portr� r� r� �timeoutr� rb r� r� Z body_expectedZ body_present�req_path� start_liner. r. r/ r� ! s �� �� � �� �� � �� � ���� � ��� � � z_HTTPConnection.run)r� r$ c C s� |dkr�| j jd ur | j jS | j jrL| j jd u rL| j jd u rL| j jd u rLtS tjtj j | j jd�}| j jsxd|_ tj |_ | j jd ur�|�| j j| j j� ttd�r�| jtjO _|S d S )Nr� )�cafileF�OP_NO_COMPRESSION)rR r� Z validate_cert�ca_certs� client_certZ client_keyr �ssl�create_default_context�Purpose� SERVER_AUTH�check_hostname� CERT_NONE� verify_mode�load_cert_chain�hasattr�optionsr� )r+ r� Zssl_ctxr. r. r/ r� � s4 � � � � � � z _HTTPConnection._get_ssl_options)rn r$ c C s8 d| _ |rd�|�nd}| jdur4| �tt|�d� dS )z�Timeout callback of _HTTPConnection instance. Raise a `HTTPTimeoutError` when a timeout occurs. :info string key: More detailed timeout information. Nro r1 )r� rs rl r� r! )r+ rn rv r. r. r/ r_ � s �z_HTTPConnection._on_timeoutc C s" | j d ur | j�| j � d | _ d S rP )r� rY rm r2 r. r. r/ rf � s z _HTTPConnection._remove_timeout)r� r$ c C s6 |� d� t|dtd| j| jt| jj�d�| j�}|S )NT)Z no_keep_aliverE rF � decompress) Z set_nodelayr r rE rF �boolrR r� r� )r+ r� r� r. r. r/ r� � s �� z"_HTTPConnection._create_connection)� start_readr$ c � s� | j jd ur | j�| j j� n.| j jd urL| j �| jj�}|d urL|I d H | j�� |r�z| j�| �I d H W n" ty� | jt � � � s�� Y n0 d S rP ) rR r� r� �writer� �finishr� r r� r� r� )r+ r� �futr. r. r/ r� � s z_HTTPConnection._write_bodyc C s | j d ur | j }d | _ |� d S rP )ri )r+ ri r. r. r/ �_release s z_HTTPConnection._release)�responser$ c C s0 | � � | jd ur,| j}d | _| j�||� d S rP )r� rl rY ru )r+ r� rl r. r. r/ � _run_callback s z _HTTPConnection._run_callbackz Optional[Type[BaseException]])�typ�value�tbr$ c C s� | j rr| �� t|t�r2|jd u r,td�}n|j}| �t| jd|| j � � | j | j d�� t | d�rn| j�� dS t|t�S d S )Nr< r& )rp rq rt r� T)rl rf � isinstancer Z real_errorr; r� r rR rY r[ rt r� r� r� rQ )r+ r� r� r� r. r. r/ r� s& �� z!_HTTPConnection._handle_exceptionc C sP | j d urLd}| jjr | jj�z t|��W n tyJ | jt�� � Y n0 d S )NzConnection closed)rl r� rp r; r� r� r� r* r. r. r/ r� < s z#_HTTPConnection.on_connection_close)� first_liner� r$ c � s� t |tj�sJ �| jjr6|jdkr6| �d�I d H d S |j| _|j| _|| _| � � rXd S | jj d ur�| j� d| � | j� � D ] \}}| j� d||f � q~| j� d� d S )N�d Fz %s %s %s z%s: %s z ) r� r �ResponseStartLinerR r� r� r� �reasonr� �_should_follow_redirectZheader_callback�get_all)r+ r� r� �k�vr. r. r/ �headers_receivedF s z _HTTPConnection.headers_receivedc C sL | j jrH| j jd usJ �| jdv oF| j jdkoF| jd uoF| j�d�d uS dS )N)�- �. �/ i3 i4 r �LocationF)rR Zfollow_redirects� max_redirectsr� r� �getr2 r. r. r/ r� ] s ���z'_HTTPConnection._should_follow_redirectc s� | j d usJ �d�| j�}| �� t| jd| j�}| �� �r t| jt�sLJ �t � | jj�}t j � | jj | jd �|_ | jjd |_|jd= | j dv r�| jjdkr�d|_d |_d D ]&}z| jj|= W q� ty� Y q�0 q�||_| j� d | _| �� | jj|d d �}|�� fd d �� | �� d S | jj�r2t� }nt|�}t || j t| dd �| j| j � � | j | j || jj d�}| �!|� | �� d S )Nr� �original_requestr� r� r� )r� r� r� r{ ry )r� r� zContent-EncodingzTransfer-EncodingF)Z raise_errorc s � | � � �S rP r� r� �rl r. r/ r� � r� z(_HTTPConnection.finish.<locals>.<lambda>r� )r� r� rq rt �bufferZ effective_url)"r� �joinr� rf r� rR r� r� r �copyr� r� �urljoinr� r� r� r� r� r� r� rl r� r� �fetchZadd_done_callback�_on_end_request�streaming_callbackr r rY r[ rt r� r� )r+ �datar� Z new_request�hr� r r� r. r� r/ r� h sV � � z_HTTPConnection.finishc C s | j �� d S rP )r� rQ r2 r. r. r/ r � s z _HTTPConnection._on_end_request)�chunkr$ c C s6 | � � r d S | jjd ur&| j�|� n | j�|� d S rP )r� rR r r� rU )r+ r r. r. r/ � data_received� s z _HTTPConnection.data_received)N),r5 r6 r7 �setr� r r= r r r rw r r) r� r9 r r r r� � SSLContextr� r_ rf r r r� r� r� r� r� � BaseExceptionr r� r� r r� r� Z HTTPHeadersr� r� r� r �bytesr r. r. r. r/ rj � sL � � ! � � $ � =rj �__main__)>Ztornado.escaper �tornador Ztornado.httpclientr r r r r r r Ztornado.http1connectionr r Ztornado.ioloopr Ztornado.iostreamr r Ztornado.netutilr r r r Z tornado.logr Ztornado.tcpclientr r� rI r r] r� r� r� r� r[ �ior � urllib.parser� �typingr r r r r r �typesr � TYPE_CHECKINGr r r r! r; r= ZHTTPMessageDelegaterj r5 � configurer. r. r. r/ �<module> sH - :
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка