File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/tornado/__pycache__/simple_httpclient.cpython-310.pyc
Back
o ;j-u � @ s� d dl mZ d dlmZmZ d dlmZmZmZm Z m Z m Z d dlm Z d dl mZmZ d dlmZ d dlmZmZ d dlmZmZmZmZ d d lmZ d d l m 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/m0Z0m1Z1 d dl2m3Z3 d d l+Z+e+j4r�d dl+m5Z5m6Z6m7Z7 G dd� de�Z8G dd� de�Z9G dd� de�Z:G dd� de j;�Z<e=dkr�e�>e:� e � d S d S )� )�_unicode)�gen�version)� 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 �8 e Zd ZdZdeddf� fdd� Zdefdd�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 �message�returnNc � t � jd|d� d S �N�W �r$ ��super�__init__��selfr$ �� __class__� �M/opt/saltstack/salt/lib/python3.10/site-packages/tornado/simple_httpclient.pyr, 5 � zHTTPTimeoutError.__init__c C � | j pdS )N�Timeoutr) �r. r1 r1 r2 �__str__8 � zHTTPTimeoutError.__str__��__name__� __module__� __qualname__�__doc__�strr, r7 � __classcell__r1 r1 r/ r2 r# , s r# c r" ) �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 r$ r% Nc r& r' r* r- r/ r1 r2 r, H r3 z HTTPStreamClosedError.__init__c C r4 )N� Stream closedr) r6 r1 r1 r2 r7 K r8 z HTTPStreamClosedError.__str__r9 r1 r1 r/ r2 r@ < s r@ c s( e Zd ZdZ d%dedeeeef dedee d eeee f d ee d ee d df� fd d� Z d&� fdd� Z de de egdf d dfdd�Zd&dd�Zd efdd�Zde de g df de egdf d dfdd �Zd ed dfd d �Zd ed dfd d!�Zd'd ed"ee d dfd#d$�Z� ZS )(�SimpleAsyncHTTPClienta� 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. This implementation supports the following arguments, which can be passed to ``configure()`` to control the global singleton, or to the constructor when ``force_instance=True``. ``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``. ``defaults`` is a dict of parameters that will be used as defaults on all `.HTTPRequest` objects submitted to this client. ``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). ``resolver`` is similar, but using the `.Resolver` interface instead of a simple mapping. ``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. � N� @� max_clients�hostname_mapping�max_buffer_size�resolver�defaults�max_header_size� max_body_sizer% c s� t � j|d� || _t�� | _i | _i | _|| _|| _ || _ |r'|| _ d| _ nt � | _ d| _ |d ur:t| j |d�| _ t| j d�| _d S )N)rI FT)rH �mapping)rH )r+ � initializerE � collections�deque�queue�active�waitingrG rJ rK rH � own_resolverr r r � tcp_client)r. rE rF rG rH rI rJ rK r/ r1 r2 rM v s* ����z SimpleAsyncHTTPClient.initializec s( t � �� | jr | j�� | j�� d S �N)r+ �closerS rH rT r6 r/ r1 r2 rV � s zSimpleAsyncHTTPClient.close�request�callbackc C s� t � }| j�|||f� |jd usJ �|jd usJ �d }t| j�| jkrEt|j|j�p0|jp0|j}|rE| j � | j � � | t � | j|d��}|||f| j|< | �� | jret�dt| j�t| j�f � d S d S )Nzin request queuezImax_clients limit reached, request queued. %d active, %d queued requests.)�objectrP �append�connect_timeout�request_timeout�lenrQ rE �min�io_loop� add_timeout�time� functools�partial� _on_timeoutrR �_process_queuer �debug)r. rW rX �key�timeout_handle�timeoutr1 r1 r2 � fetch_impl� s2 �� ����z SimpleAsyncHTTPClient.fetch_implc C s� | j r@t| j�| jk rB| j �� \}}}|| jvrq | �|� ||f| j|< t�| j |�}| � |||� | j rDt| j�| jk s d S d S d S d S rU ) rP r] rQ rE �popleftrR �_remove_timeoutrb rc �_release_fetch�_handle_request)r. rg rW rX �release_callbackr1 r1 r2 re � s &�z$SimpleAsyncHTTPClient._process_queuec C s t S rU )�_HTTPConnectionr6 r1 r1 r2 �_connection_class� s z'SimpleAsyncHTTPClient._connection_classro �final_callbackc C s& | � � | |||| j| j| j| j� d S rU )rq rG rT rJ rK )r. rW ro rr r1 r1 r2 rn � s �z%SimpleAsyncHTTPClient._handle_requestrg c C s | j |= | �� d S rU )rQ re )r. rg r1 r1 r2 rm � s z$SimpleAsyncHTTPClient._release_fetchc C s> || j v r | j | \}}}|d ur| j�|� | j |= d S d S rU )rR r_ �remove_timeout)r. rg rW rX rh r1 r1 r2 rl � s �z%SimpleAsyncHTTPClient._remove_timeout�infoc C sn | j | \}}}| j�|||f� |rd|� �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 r5 r( )�error� request_timeN) rR rP �remover r# r_ ra � start_time� add_callback)r. rg rt rW rX rh � error_messageZtimeout_responser1 r1 r2 rd � s � z!SimpleAsyncHTTPClient._on_timeout)rC NrD NNNN�r% NrU )r: r; r< r= �intr r r> r r rM rV r r r rj re �typerq rn rY rm rl rd r? r1 r1 r/ r2 rB O s` (�������� �&� � � � � � �$rB c @ sn e Zd Zh d�Zdee dedeg df deegdf de de d e d e d dfd d �Z d8dd�Z de d edee ef ejf fdd�Zd9dee d dfdd�Zd8dd�Zded efdd�Zded dfd d �Zd8d d �Zd ed dfd!d"�Z d#d$d%ee d&ee d efd'd(�Z d8d)d*�Z d+ee!j"e!j#f d,e!j$d dfd-d.�Z%d efd/d0�Z&d8d1d2�Z'd8d3d4�Z(d5e)d dfd6d7�Z*dS ):rp > ZOPTIONS�HEAD�PATCH�PUTZDELETE�POST�GET�clientrW ro Nrr rG rT rJ rK r% c C s� t �� | _| j�� | _t�� | _|| _|| _|| _|| _ || _ || _ || _ || _ d | _d | _g | _d | _d | _d | _t �� �t�| �� �dd� � d S )Nc S s | � � S rU ��result��fr1 r1 r2 �<lambda> s z*_HTTPConnection.__init__.<locals>.<lambda>)r �currentr_ ra ry �start_wall_timer� rW ro rr rG rT rJ rK �code�headers�chunks� _decompressor�_timeout� _sockaddrZ add_futurer Zconvert_yielded�run) r. r� rW ro rr rG rT rJ rK r1 r1 r2 r, � s( �z_HTTPConnection.__init__c � s. ��z�t j�t| jj��| _| jjdvr td| jj ��| jj }d|v r,|� d�\}}}t � |�\}}|d u rA| jjdkr?dnd}t �d|�rM|dd � }|| _| jjd u rZtj}ntj}| �| jj�}d }| jjr~t| jj�ru| jj}n td | jjf ��| jjr�| jjr�t| jj| jj�} n| jjr�| jj} n | jjr�| jj} nd } | r�| j�| j | t � | j d ��| _ | j!j"||||| j#|d�I d H } | j$d u r�| �%� W d S | | _&| j&�'| j(� | �)� | j$d u r�W d S | jjr�| j�| j | jj t � | j d��| _ | jj*| j+v�r| jj,�st-d| jj* ��dD ]} t.| j| d ��r%t/d| ���qd| jj0v�r4d| jj0d< d| jj0v�rXd| jj v �rP| jj � d�d | jj0d< n| jj | jj0d< d\} } | jj1d u�rm| 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 < n| jj0�:d �d u �r�d t;� �| jj0d < | jj,�s�| jj*d v }| jj<d u�p�| jj=d u}|�r�|�r�|�r�|�s�td |�r�d nd| jj*f ��| jj>�r d!| jj0d"< | jj<d u�r t?t@| jj<��| jj0d#< | jj*d$k�r0d%| jj0v�r0d&| jj0d%< | jjA�r;d'| jj0d(< | jjB�pAd)| jjC�rLd*| jjC nd }| �D| �| _Et �F| jj*|d�}| jE�G|| jj0� | jj>�rx| jE�H| �I d H W d S | �Id+�I d H W d S tJ�y� | jKtL�M� � �s�� Y d S w ),N)�http�httpszUnsupported url scheme: %s�@r� i� �P z^\[.*\]$� ���Fz?Unrecognized IPv4 or IPv6 address for network_interface, got %rr zwhile connecting)�af� ssl_optionsrG � source_ipzduring requestzunknown method %s)Z proxy_hostZ proxy_portZproxy_usernameZproxy_passwordZproxy_auth_modez%s not supportedZ ConnectionrV �Host)NN� )NZbasiczunsupported auth_mode %szBasic � Authorizationz User-AgentzTornado/)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)N�urllib�parse�urlsplitr rW �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[ r\ r^ r_ r` ry rb rc rd r� rT �connectrG rr rV �streamZset_close_callback�on_connection_closerl �method�_SUPPORTED_METHODSZallow_nonstandard_methods�KeyError�getattr�NotImplementedErrorr� �username�password� auth_username� auth_passwordZ auth_mode�base64� b64encodeZencode_username_passwordZ user_agent�getr �body� body_producer�expect_100_continuer> r] �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� ri r� rg r� r� Z body_expectedZ body_presentZreq_pathZ start_liner1 r1 r2 r� s � �� � � � �� � � �� � ���� � � ��z_HTTPConnection.runr� c C s� |dkr[| j jd ur| j jS | j jr&| j jd u r&| j jd u r&| j jd u r&tS tjtj j | j jd�}| j js<d|_ tj |_ | j jd urL|�| j j| j j� ttd�rY| jtjO _|S d S )Nr� )�cafileF�OP_NO_COMPRESSION)rW r� Z validate_cert�ca_certsZ 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_ctxr1 r1 r2 r� � s. � � � z _HTTPConnection._get_ssl_optionsrt c C s< d| _ |r d|� �nd}| jdur | �tt|�d� dS dS )z�Timeout callback of _HTTPConnection instance. Raise a `HTTPTimeoutError` when a timeout occurs. :info string key: More detailed timeout information. Nru r5 )r� rr r� r# )r. rt r{ r1 r1 r2 rd � s ��z_HTTPConnection._on_timeoutc C s& | j d ur| j�| j � d | _ d S d S rU )r� r_ rs r6 r1 r1 r2 rl � s �z _HTTPConnection._remove_timeoutr� c C s6 |� d� t|dtd| j| jt| jj�d�| j�}|S )NT)Z no_keep_aliverJ rK � decompress) Z set_nodelayr r rJ rK �boolrW r� r� )r. r� r� r1 r1 r2 r� � s �� z"_HTTPConnection._create_connection� start_readc � s� �| j jd ur| j�| j j� n| j jd ur'| j �| jj�}|d ur'|I d H | j�� |rMz | j�| �I d H W d S tyL | jt � � � sI� Y d S w d S rU ) rW r� r� �writer� �finishr� r r� r� r� )r. r� �futr1 r1 r2 r� s" � ���z_HTTPConnection._write_bodyc C s$ | j d ur| j }d | _ |� d S d S rU )ro )r. ro r1 r1 r2 �_release s �z_HTTPConnection._release�responsec C s4 | � � | jd ur| j}d | _| j�||� d S d S rU )r� rr r_ rz )r. r� rr r1 r1 r2 � _run_callback s �z _HTTPConnection._run_callback�typz Optional[Type[BaseException]]�value�tbc C s� | j d ur;| �� t|t�r|jd u rtd�}n|j}| �t| jd|| j � � | j | j d�� t | d�r9| j�� dS t|t�S )NrA r( )rv rw ry r� T)rr rl � isinstancer Z real_errorr@ r� r rW r_ ra ry r� r� r� rV )r. r� r� r� r1 r1 r2 r� s& �� z!_HTTPConnection._handle_exceptionc C sN | j d ur%d}| jjr| jj�zt|�� ty$ | jt�� � Y d S w d S )NzConnection closed)rr r� rv r@ r� r� r� r- r1 r1 r2 r� B s ��z#_HTTPConnection.on_connection_close� first_liner� c � s� �t |tj�s J �| jjr |jdkr | �d�I d H d S |j| _|j| _|| _| � � r-d S | jj d urY| j� d| � | j� � D ]\}}| j� |� d|� d�� q@| j� d� d S d S )N�d Fz %s %s %s z: z ) r� r �ResponseStartLinerW r� r� r� �reasonr� �_should_follow_redirectZheader_callback�get_all)r. r� r� �k�vr1 r1 r2 �headers_receivedL s � �z _HTTPConnection.headers_receivedc C sL | j jr$| j jd us J �| jdv o#| j jdko#| jd uo#| j�d�d uS dS )N)�- �. �/ i3 i4 r �LocationF)rW Zfollow_redirects� max_redirectsr� r� r� r6 r1 r1 r2 r� c s ���z'_HTTPConnection._should_follow_redirectc s� | j d usJ �d�| j�}| �� t| jd| j�}| �� �rt| jt�s&J �| j d us-J �t � | jj�}t j � | jj| j d �|_| jj � � |_ t j �|j�}t j �|j�}|j|jksb|j|jkr�d |_d |_d|jv r�|jd ur||j� d|j� �}n |jd us�J �|j}|j|d�}t j �|�|_dD ]}z|j |= W q� ty� Y q�w | jjd us�J �| jjd |_|j d = | j d kr�| jjd ks�| j d v r�| jjd kr�d|_d |_dD ]}z|j |= W q� ty� Y q�w ||_ | j � d | _ | � � | j d us�J �| j j |dd�}|�!� fdd�� | �"� d S | jj#�r t$� } nt$|�} t%|| j t| dd �| j | j&�'� | j( | j)| | jjd�} | �*| � | �"� d S )N� �original_requestr� r� �:)r� )r� ZCookier� r� r� r )r� r� r� r� )r� r� zContent-EncodingzTransfer-EncodingF)Z raise_errorc s � | � � �S rU r� r� �rr r1 r2 r� � s z(_HTTPConnection.finish.<locals>.<lambda>r� )r� r� rw ry �bufferZ effective_url)+r� �joinr� rl r� rW r� r� r r� �copyr� r� �urljoinr� r� r� r� r� r� r� �hostname�_replace� urlunsplitr� r� r� r� r� rr r� r� ZfetchZadd_done_callback�_on_end_request�streaming_callbackr r r_ ra ry r� r� ) r. �datar� Z new_requestZparsed_orig_urlZparsed_new_urlZ new_netloc�hr� r r� r1 r� r2 r� n s� � � � � z_HTTPConnection.finishc C s | j �� d S rU )r� rV r6 r1 r1 r2 r � s z _HTTPConnection._on_end_request�chunkc C s8 | � � rd S | jjd ur| j�|� d S | j�|� d S rU )r� rW r r� rZ )r. r r1 r1 r2 � data_received� s z _HTTPConnection.data_receivedr| rU )+r: r; r< r� r rB r r r r} r r, r� r> r r r r� � SSLContextr� rd rl r r r� r� r� r� r� � BaseExceptionr r� r� r r� r� Z HTTPHeadersr� r� r� r �bytesr r1 r1 r1 r2 rp � sn �� � ���� � � ! "� � ��� � $ �� � erp �__main__)?Ztornado.escaper Ztornador r 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� rN r rb r� r� r� r� ra �ior � urllib.parser� �typingr r r r r r �typesr � TYPE_CHECKINGr r r! r# r@ rB ZHTTPMessageDelegaterp r: Z configurer1 r1 r1 r2 �<module> sL . g �
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings