golden hour
/opt/saltstack/salt/lib/python3.10/site-packages/salt/ext/tornado/__pycache__
⬆️ Go Up
Upload
File/Folder
Size
Actions
__init__.cpython-310.pyc
378 B
Del
OK
_locale_data.cpython-310.pyc
3.23 KB
Del
OK
auth.cpython-310.pyc
39.18 KB
Del
OK
autoreload.cpython-310.pyc
7.02 KB
Del
OK
concurrent.cpython-310.pyc
17.24 KB
Del
OK
curl_httpclient.cpython-310.pyc
12.8 KB
Del
OK
escape.cpython-310.pyc
9.89 KB
Del
OK
gen.cpython-310.pyc
38.39 KB
Del
OK
http1connection.cpython-310.pyc
19.47 KB
Del
OK
httpclient.cpython-310.pyc
25.19 KB
Del
OK
httpserver.cpython-310.pyc
11.45 KB
Del
OK
httputil.cpython-310.pyc
29.84 KB
Del
OK
ioloop.cpython-310.pyc
33.19 KB
Del
OK
iostream.cpython-310.pyc
42.97 KB
Del
OK
locale.cpython-310.pyc
15.22 KB
Del
OK
locks.cpython-310.pyc
16.61 KB
Del
OK
log.cpython-310.pyc
8.07 KB
Del
OK
netutil.cpython-310.pyc
14.32 KB
Del
OK
options.cpython-310.pyc
19.63 KB
Del
OK
process.cpython-310.pyc
10.27 KB
Del
OK
queues.cpython-310.pyc
11.29 KB
Del
OK
routing.cpython-310.pyc
21.08 KB
Del
OK
simple_httpclient.cpython-310.pyc
16.08 KB
Del
OK
stack_context.cpython-310.pyc
10.65 KB
Del
OK
tcpclient.cpython-310.pyc
6.49 KB
Del
OK
tcpserver.cpython-310.pyc
10.06 KB
Del
OK
template.cpython-310.pyc
30.52 KB
Del
OK
testing.cpython-310.pyc
24.61 KB
Del
OK
util.cpython-310.pyc
13.72 KB
Del
OK
web.cpython-310.pyc
105.22 KB
Del
OK
websocket.cpython-310.pyc
39.08 KB
Del
OK
wsgi.cpython-310.pyc
11.5 KB
Del
OK
Edit: simple_httpclient.cpython-310.pyc
o �xea � @ s� d dl mZmZmZ d dlmZmZ d dlmZ d dl m Z m Z m Z m Z mZ d dlmZ d dlmZmZ d dlmZ d dlmZmZmZ d d lmZ d d lmZ d d l m Z 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 dl'm(Z( e r�d d l)m*Z+ nd d l+Z+zd d l,Z,W n e-y� d Z,Y nw zd d l.Z.W n e-y� d Z.Y nw dd� Z/G dd� de �Z0G dd� dej1�Z2e3dkr�e �4e0� e � d S d S )� )�absolute_import�division�print_function)�utf8�_unicode)�gen)� HTTPResponse� HTTPError�AsyncHTTPClient�main� _RequestProxy)�httputil)�HTTP1Connection�HTTP1ConnectionParameters)�StreamClosedError)�Resolver�OverrideResolver�_client_ssl_defaults)�gen_log)� stack_context)� TCPClient)�PY3N)�BytesIOc C s t d u rtd��t �� S )NzCThe 'certifi' package is required to use https in simple_httpclient)�certifi� Exception�where� r r �V/opt/saltstack/salt/lib/python3.10/site-packages/salt/ext/tornado/simple_httpclient.py�_default_ca_certs, s r c sp e Zd ZdZ d� fdd� Z� fdd�Zd d � Zd d � Zd d� Zdd� Z dd� Z dd� Z ddd�Z � Z S )�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� @c s� t t| �j||d� || _t�� | _i | _i | _|| _ || _ || _ |r*|| _ d| _ n t|d�| _ d| _ |dur?t| 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. )�defaultsF)�io_loopTN)�resolver�mapping)r$ r# )�superr � initialize� max_clients� collections�deque�queue�active�waiting�max_buffer_size�max_header_size� max_body_sizer$ � own_resolverr r r � tcp_client) �selfr# r( Zhostname_mappingr. r$ r" r/ r0 �� __class__r r r' < s( $� �z SimpleAsyncHTTPClient.initializec s, t t| ��� | jr| j�� | j�� d S �N)r& r �closer1 r$ r2 �r3 r4 r r r7 v s zSimpleAsyncHTTPClient.closec C s� t � }| j�|||f� t| j�| jk s,| j�| j�� t |j |j � t � | j|d��}nd }|||f| j|< | �� | jrNt�dt| j�t| j�f � d S d S )Nzin request queuezImax_clients limit reached, request queued. %d active, %d queued requests.)�objectr+ �append�lenr, r( r# � add_timeout�time�min�connect_timeout�request_timeout� functools�partial� _on_timeoutr- �_process_queuer �debug)r3 �request�callback�key�timeout_handler r r � fetch_impl| s$ ��� ��z SimpleAsyncHTTPClient.fetch_implc C s� t �� �_ | jrKt| j�| jk rS| j�� \}}}|| jvr q| �|� ||f| j|< t � | j |�}| � |||� | jr[t| j�| jk sW d � d S W d � d S W d � d S W d � d S 1 sfw Y d S r6 ) r Z NullContextr+ r; r, r( �popleftr- �_remove_timeoutrA rB �_release_fetch�_handle_request)r3 rH rF rG �release_callbackr r r rD � s" ����"�z$SimpleAsyncHTTPClient._process_queuec C s t S r6 )�_HTTPConnectionr8 r r r �_connection_class� s z'SimpleAsyncHTTPClient._connection_classc C s* | � � | j| |||| j| j| j| j� d S r6 )rQ r# r. r2 r/ r0 )r3 rF rO �final_callbackr r r rN � s �z%SimpleAsyncHTTPClient._handle_requestc C s | j |= | �� d S r6 )r, rD )r3 rH r r r rM � s z$SimpleAsyncHTTPClient._release_fetchc C s> || j v r | j | \}}}|d ur| j�|� | j |= d S d S r6 )r- r# �remove_timeout)r3 rH rF rG rI r r r rL � s �z%SimpleAsyncHTTPClient._remove_timeoutc C sp | j | \}}}| j�|||f� |rd�|�nd}t|dtd|�| 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}�Timeout�W ��error� request_timeN) r- r+ �remove�formatr r r# r= � start_time� add_callback)r3 rH �inforF rG rI � error_messageZtimeout_responser r r rC � s � z!SimpleAsyncHTTPClient._on_timeout)r Nr! NNNNr6 )�__name__� __module__� __qualname__�__doc__r' r7 rJ rD rQ rN rM rL rC � __classcell__r r r4 r r 3 s � : r c @ s� e Zd Zeg d��Zdd� Zdd� Zd%dd�Zd d � Zd d � Z d d� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� ZdS )&rP )�GET�HEAD�POST�PUTZDELETE�PATCHZOPTIONSc C s� |� � | _|| _|| _|| _|| _|| _|| _|| _|| _ | | _ d | _ d | _ g | _ d | _d | _d | _t�| j��� t�t| jj��| _| jjdvrQtd| jj ��| jj} d| v ra| � d�\} } } t � | �\} }|d u rv| jjdkrtdnd}t � d| �r�| dd � } | | _!|j"d u r�t#j$}nt#j%}| �&| jj�}t'| jj(| jj)�}|r�| j�*| j| t�+t,�-| j.d ���| _| jj/| |||| j| j0d � W d � d S 1 s�w Y d S ) N)�http�httpszUnsupported url scheme: %s�@rk i� �P z^\[.*\]$� ���Fzwhile connecting)�af� ssl_optionsr. rG )1r= r\ r# �clientrF rO rR r. r2 r/ r0 �code�headers�chunks� _decompressor�_timeout� _sockaddrr ZExceptionStackContext�_handle_exception�urlparse�urlsplitr �url�parsed�scheme� ValueError�netloc� rpartitionr Zsplit_host_and_port�re�matchZparsed_hostnameZ allow_ipv6�socket�AF_INET� AF_UNSPEC�_get_ssl_optionsr> r? r@ r< �wraprA rB rC �connect� _on_connect)r3 r# rr rF rO rR r. r2 r/ r0 r� Zuserpass�_�host�portrp rq �timeoutr r r �__init__� s^ � � �"�z_HTTPConnection.__init__c C s� |dkrr| j jd ur| j jS | j jr&| j jd u r&| j jd u r&| j jd u r&tS i }| j jr1tj|d< | j jd ur>| j j|d< n t td�sHt � |d< | j jd urT| j j|d< | j jd ur`| j j|d< t j dkrkd|d < |S tj |d < |S d S ) Nrk � cert_reqs�ca_certs�create_default_context�keyfile�certfile)� � zDEFAULT:!SSLv2:!EXPORT:!DES�ciphers� ssl_version)rF rq Z validate_certr� Z client_certZ client_keyr �ssl� CERT_REQUIRED�hasattrr �sys� version_info�PROTOCOL_TLSv1)r3 r~ rq r r r r� � s2 �z _HTTPConnection._get_ssl_optionsNc C s0 d| _ |r d�|�nd}| jdurtd|��dS )z�Timeout callback of _HTTPConnection instance. Raise a timeout HTTPError when a timeout occurs. :info string key: More detailed timeout information. NrT rU rV )rw r[ rR r )r3 r^ r_ r r r rC * s �z_HTTPConnection._on_timeoutc C s& | j d ur| j�| j � d | _ d S d S r6 )rw r# rS r8 r r r rL 6 s �z _HTTPConnection._remove_timeoutc C s | j d u r |�� d S || _| j�| j� | �� | j d u r d S | jjr9| j� | j | jj t � t �| jd���| _| jj| jvrL| jjsLtd| jj ��dD ]}t| j|d �r]td| ��qNd| jjvrjd| jjd< d| jjvr�d| jjv r�| jj�d�d | jjd< n| jj| jjd< d \}}| jjd ur�| jj| jj }}n| jj d ur�| jj }| jj p�d }|d ur�| jj d vr�t d | jj ��t!|�d t!|� }dt"�#|� | jjd< | jj$r�| jj$| jjd< | jj�s| jjdv }| jj%d up�| jj&d u}|r�|�r|�r|�st d|�r dnd | jjf ��| jj'�r d| jjd< | jj%d u�r1t(t)| jj%��| jjd< | jjdk�rEd| jjv�rEd| jjd< | jj*�rPd| jjd < | jj+�pVd | jj,�rad | jj, nd }| �-|�| _.t/�0| jj|d �} | j.�1| | jj� | jj'�r�| �2� d S | �3d � d S ) Nzduring requestzunknown method %s)Znetwork_interfaceZ proxy_hostZ proxy_portZproxy_usernameZproxy_passwordZproxy_auth_modez%s not supportedZ Connectionr7 �Hostrl ro )NN� )NZbasiczunsupported auth_mode %s� :s Basic Z Authorizationz User-Agent)rg ri rh zLBody must %sbe None for method %s (unless allow_nonstandard_methods is true)znot z 100-continueZExpect�Content-Lengthrg � Content-Typez!application/x-www-form-urlencoded�gzipzAccept-Encoding�/�?T)4rR r7 �streamZset_close_callback�on_connection_closerL rF r@ r# r< r\ r r� rA rB rC rw �method�_SUPPORTED_METHODSZallow_nonstandard_methods�KeyError�getattr�NotImplementedErrorrt r} r� r� �username�passwordZ auth_usernameZ auth_passwordZ auth_moder r �base64� b64encodeZ user_agent�body� body_producer�expect_100_continue�strr; �decompress_response�path�query�_create_connection� connectionr ZRequestStartLineZ write_headers�_read_response� _write_body) r3 r� rH r� r� ZauthZ body_expectedZ body_presentZreq_pathZ start_liner r r r� ; s� �� � � � � ���� � � � z_HTTPConnection._on_connectc C s2 |� d� t|dtd| j| j| jjd�| j�}|S )NT)Z no_keep_aliver/ r0 � decompress)Z set_nodelayr r r/ r0 rF r� rx )r3 r� r� r r r r� � s ��z"_HTTPConnection._create_connectionc s� � j jd ur� j�� j j� n'� j jd ur6� j �� jj�}|d ur6t�|�}� �fdd�}� j�||� d S � j� � �rC� � � d S d S )Nc s& | � � � j�� �r� �� d S d S r6 )�resultr� �finishr� )�fut�r3 � start_readr r �on_body_written� s �z4_HTTPConnection._write_body.<locals>.on_body_written) rF r� r� �writer� r Zconvert_yieldedr# � add_futurer� r� )r3 r� r� r� r r� r r� � s �z_HTTPConnection._write_bodyc C s | j �| j�| �dd� � d S )Nc S s | � � S r6 )r� )�fr r r �<lambda>� s z0_HTTPConnection._read_response.<locals>.<lambda>)r# r� r� Z read_responser8 r r r r� � s �z _HTTPConnection._read_responsec C s$ | j d ur| j }d | _ |� d S d S r6 )rO )r3 rO r r r �_release� s �z_HTTPConnection._releasec C s4 | � � | jd ur| j}d | _| j�||� d S d S r6 )r� rR r# r] )r3 �responserR r r r � _run_callback� s �z _HTTPConnection._run_callbackc C sz | j r8| �� t|t�r|jd u rtdd�}n|j}| �t| jd|| j � � | j d�� t | d�r6| j �� dS t|t�S )NrV z Stream closedrW r� T)rR rL � isinstancer Z real_errorr r� r rF r# r= r\ r� r� r7 )r3 �typ�value�tbr r r ry � s � z!_HTTPConnection._handle_exceptionc C sP | j d ur&d}| jjr| jj�ztd|�� ty% | jt�� � Y d S w d S )NzConnection closedrV )rR r� rX r ry r� �exc_info)r3 �messager r r r� � s ��z#_HTTPConnection.on_connection_closec C s� | j jr|jdkr| �d� d S |j| _|j| _|| _| �� r!d S | j jd urK| j �d| � | j�� D ]\}}| j �d||f � q4| j �d� d S d S )N�d Fz %s %s %s z%s: %s z ) rF r� rs r� �reasonrt �_should_follow_redirectZheader_callback�get_all)r3 � first_linert �k�vr r r �headers_received� s �z _HTTPConnection.headers_receivedc C s | j jo| j jdko| jdv S )Nr )i- �. �/ i3 i4 )rF Zfollow_redirects� max_redirectsrs r8 r r r r� � s ��z'_HTTPConnection._should_follow_redirectc C sL d� | j�}| �� t| jd| j�}| �� rvt| jt�s J �t�| jj�}t � | jj | j d �|_ | jj d |_ |j d= | jdv r\d|_d |_dD ]}z| jj |= W qI ty[ Y qIw ||_| j}d | _| �� | j�||� | �� d S | jjr~t� }nt|�}t|| jt| d d �| j | j� � | j || jj d �}| � |� | �� d S ) N� �original_requestZLocationrn r� )r� r� re )r� r� zContent-EncodingzTransfer-Encodingr� )r� rt rY �bufferZ effective_url) �joinru rL r� rF r� r� r �copyrz �urljoinr| rt r� rs r� r� r� r� rR r� rr Zfetch�_on_end_request�streaming_callbackr r r# r= r\ r� )r3 �datar� Z new_request�hrR r� r� r r r r� � sR � � �� z_HTTPConnection.finishc C s | j �� d S r6 )r� r7 r8 r r r r� ) s z _HTTPConnection._on_end_requestc C s8 | � � rd S | jjd ur| j�|� d S | j�|� d S r6 )r� rF r� ru r: )r3 �chunkr r r � data_received, s z _HTTPConnection.data_receivedr6 )r` ra rb �setr� r� r� rC rL r� r� r� r� r� r� ry r� r� r� r� r� r� r r r r rP � s& 7 1 Q 0 rP �__main__)5Z __future__r r r Zsalt.ext.tornado.escaper r Zsalt.ext.tornador Zsalt.ext.tornado.httpclientr r r r r r Z salt.ext.tornado.http1connectionr r Zsalt.ext.tornado.iostreamr Zsalt.ext.tornado.netutilr r r Zsalt.ext.tornado.logr r Zsalt.ext.tornado.tcpclientr Zsalt.ext.tornado.utilr r� r) r� rA r� r� r� �ior � urllib.parse�parserz r� � ImportErrorr r r ZHTTPMessageDelegaterP r` Z configurer r r r �<module> sV � � y �
Save