Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/tornado/__pycache__/curl_httpclient.cpython-39.pyc
Ðазад
a _�hu` � @ s d Z ddlZddlZddlZddlZddlZddlZddlmZ ddl m Z ddl m Z ddl m Z mZ ddlmZmZmZmZmZ ddlmZ dd lmZmZmZmZ ddlZej r�dd lm Z m Z m Z e� d �Z!G d d � d e�Z"G dd� de�Z#e$dk�re�%e"� e� dS )z5Non-blocking HTTP client implementation using pycurl.� N)�BytesIO)�httputil)�ioloop)�utf8� native_str)� HTTPRequest� HTTPResponse� HTTPError�AsyncHTTPClient�main)�app_log)�Dict�Any�Callable�Union)�Deque�Tuple�Optionalztornado.curl_httpclientc sR e Zd Zd.eeeef dd�� fdd� Zdd�� fdd� Ze e e gdf dd �d d �Z eeee dd �d d�Zedd�dd�Zeedd�dd�Zdd�dd�Zdd�dd�Zdd�dd�Zdd�dd �Zd/ejeedd �d d �Zedd �d!d"�Zejd�d#d$�Zeje eej dd%�d&d'�Z ej e egdf e dd(�d)d*�Z eedd+�d,d-�Z � Z S )0�CurlAsyncHTTPClient� N)� max_clients�defaults�returnc s� t t� �j|d� t�� � _� j�tj� j� � j�tj � j � � fdd�t |�D �� _ � j d d � � _ t�� � _i � _d � _t�� jd�� _� j�� t�� }� j�|� � j�|� d S )N)r c s g | ] }� � � �qS � )� _curl_create)�.0�i��selfr ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/tornado/curl_httpclient.py� <listcomp>8 � z2CurlAsyncHTTPClient.initialize.<locals>.<listcomp>�� )�superr � initialize�pycurlZ CurlMulti�_multi�setoptZM_TIMERFUNCTION� _set_timeoutZM_SOCKETFUNCTION�_handle_socket�range�_curls� _free_list� collections�deque� _requests�_fds�_timeoutr ZPeriodicCallback�_handle_force_timeout�_force_timeout_callback�start�Curl� add_handle� remove_handle)r r r Zdummy_curl_handle�� __class__r r r$ 1 s" �� z CurlAsyncHTTPClient.initialize)r c s^ | j �� | jd ur"| j�| j� | jD ] }|�� q(| j�� tt | ��� d | _ d | _d S �N) r3 �stopr1 �io_loop�remove_timeoutr+ �closer& r# r �r �curlr8 r r r> R s zCurlAsyncHTTPClient.close)�request�callbackr c C s. | j �||| j�� f� | �� | �d� d S �Nr )r/ �appendr< �time�_process_queuer( )r rA rB r r r � fetch_impla s z CurlAsyncHTTPClient.fetch_impl)�event�fd�multi�datar c C s� t jtjjt jtjjt jtjjt j tjjtjjB i}|t j kr^|| j v r�| j � |� | j |= n:|| }|| j v r|| j � |� | j �|| j|� || j |< dS )z_Called by libcurl when it wants to change the file descriptors it cares about. N)r% Z POLL_NONEr �IOLoop�NONEZPOLL_IN�READZPOLL_OUT�WRITEZ POLL_INOUTZ POLL_REMOVEr0 r< Zremove_handler� add_handler�_handle_events)r rH rI rJ rK Z event_mapZ ioloop_eventr r r r) h s � z"CurlAsyncHTTPClient._handle_socket)�msecsr c C s< | j dur| j�| j � | j�| j�� |d | j�| _ dS )z(Called by libcurl to schedule a timeout.Ng @�@)r1 r< r= Z add_timeoutrE �_handle_timeout)r rR r r r r( � s �z CurlAsyncHTTPClient._set_timeout)rI �eventsr c C s� d}|t jj@ r|tjO }|t jj@ r0|tjO }z| j�||�\}}W n0 tj yv } z|j d }W Y d}~n d}~0 0 |tj kr0q�q0| � � dS )zXCalled by IOLoop when there is activity on one of our file descriptors. r N) r rL rN r% Z CSELECT_INrO Z CSELECT_OUTr& � socket_action�error�args�E_CALL_MULTI_PERFORM�_finish_pending_requests)r rI rT �action�ret� num_handles�er r r rQ � s z"CurlAsyncHTTPClient._handle_eventsc C s� d| _ z| j�tjd�\}}W n0 tjyN } z|jd }W Y d}~n d}~0 0 |tjkrq^q| �� | j� � }|dkr�| � |� dS )z7Called by IOLoop when the requested timeout has passed.Nr ) r1 r& rU r% ZSOCKET_TIMEOUTrV rW rX rY �timeoutr( )r r[ r\ r] Z new_timeoutr r r rS � s z#CurlAsyncHTTPClient._handle_timeoutc C s^ z| j �� \}}W n0 tjyB } z|jd }W Y d}~n d}~0 0 |tjkr qRq | �� dS )zpCalled by IOLoop periodically to ask libcurl to process any events it may have forgotten about. r N)r& Z socket_allr% rV rW rX rY )r r[ r\ r] r r r r2 � s z)CurlAsyncHTTPClient._handle_force_timeoutc C sZ | j �� \}}}|D ]}| �|� q|D ]\}}}| �|||� q(|dkr qNq | �� dS )zbProcess any requests that were completed by the last call to multi.socket_action. r N)r& Z info_read�_finishrF )r Znum_qZok_listZerr_listr@ Zerrnum�errmsgr r r rY � s z,CurlAsyncHTTPClient._finish_pending_requestsc C s� d}| j r�| jr�|d7 }| j �� }| j�� \}}}t�� t� |||t�� | j� � �� d�|_ z | � |||j d |j d � W nB t y� } z*| j � |� |t|d|d�� W Y d }~qd }~0 0 | j�|� q|s q�q d S )Nr � )�headers�bufferrA rB �queue_start_time�curl_start_time�curl_start_ioloop_timerc rb �W )rA �coderV )r, r/ �pop�popleftr � HTTPHeadersr rE r< �current�info�_curl_setup_request� ExceptionrD r r& r6 )r �startedr@ rA rB rd r] r r r rF � s. � � (z"CurlAsyncHTTPClient._process_queue)r@ � curl_error� curl_messager c C sb |j }d |_ | j�|� | j�|� |d }|rj|d us<J �t||�}|d usRJ �|j}d }|�� d }n&d }|�t j �}|�t j �}|� d� t |d |d |�t j�|�t j�|�t j�|�t j�|�t j�|�t j�|�t j�d�} zN|d t|d ||d ||||d �d d �| j�� |d |d | d � � W n" t�y\ | �|d � Y n0 d S ) Nrc r rf rd )�queueZ namelookup�connectZ appconnectZ pretransferZ starttransfer�total�redirectrB rA rb z X-Http-Reasonre ) rA rh rb rc � effective_urlrV �reasonZ request_time� start_time� time_info)rm r& r7 r, rD � CurlErrorrh r> �getinfor% Z HTTP_CODEZ EFFECTIVE_URL�seek�dictZNAMELOOKUP_TIMEZ CONNECT_TIMEZAPPCONNECT_TIMEZPRETRANSFER_TIMEZSTARTTRANSFER_TIMEZ TOTAL_TIMEZ REDIRECT_TIMEr �getr< rE ro �handle_callback_exception) r r@ rq rr rm rc rV rh rw rz r r r r_ � sX � ��zCurlAsyncHTTPClient._finish)rB r c C s t jd|dd� d S )NzException in callback %rT)�exc_info)r rV )r rB r r r r� / s z-CurlAsyncHTTPClient.handle_callback_exceptionc C sl t �� }t�tj�r2|�t jd� |�t j| j � t t d�rh|�t j t j t j B � |�t jt j t j B � |S )Nra � PROTOCOLS)r% r5 �curl_log� isEnabledFor�logging�DEBUGr' �VERBOSEZ DEBUGFUNCTION� _curl_debug�hasattrr� Z PROTO_HTTPZ PROTO_HTTPSZREDIR_PROTOCOLSr? r r r r 2 s �z CurlAsyncHTTPClient._curl_create)r@ rA rc rb r c s� � � tjt�j�� d�jvr(d�jd< d�jvr<d�jd< � � tjdd� �j�� D �� � � tjt � �j |�j �� �j r�tttf td���fdd� }n|j}� � tj|� � � tj�j� � � tj�j� �jd us�J �� � tjtd �j �� �jd u�sJ �� � tjtd �j �� �j �r<� � tj t�j �� n� � tj d � �j �rb� � tj �j � �j �rz� � tj!d � n� � tj!d � �j"�rF�j#�rF� � tj$�j"� � � tj%�j#� �j&�r�j'd u�s�J �t(�)�j&�j'�}� � tj*|� �j+d u �s�j+d k�r� � tj,tj-� n,�j+dk�r6� � tj,tj.� nt/d�j+ ��n� � tj$d� � �0tj*� �j1�r�� � tj2d� � � tj3d� n � � tj2d� � � tj3d� �j4d u�r�� � tj5�j4� n �j6du �rވ � tj7tj8� n� � tj7tj9� tj:tj;tj<tj=d�}t>g d��}|�?� D ]} � � | d� �q�j@|v �rX� �0tjA� � � |�j@ d� n4�jB�sl�j@|v �r~� � tjA�j@� ntCd�j@ ���j@dv } �jDd u} �jB�s�| �r�| �r�| �r�| �s�t/d| �r�dnd�j@f ��| �s�| �r��j@dk�r�t/d ��tEtF�jD�p d���td d �� �fd d � } � � tjG�jH� � � tjI| � �j@d k�rl� � tjJtK�jD�pdd�� n(� � tj<d� � � tjLtK�jD�p�d�� �jMd u�r<�jNd u�s�J ��jOd u �sȈjOd k�rڈ � tjPtj-� n,�jOdk�r�� � tjPtj.� nt/d!�jO ��t(�)�jM�jN�} � � tjQ| � tR�Sd"�j@�j�jM� n � �0tjQ� tR�Sd#�j@�j� �jTd u�rv� � tjU�jT� �jVd u�r�� � tjW�jV� �jXd u�r�t/d$��tY�Z� dk�r � tj[d� �j\d u�r؈�\� � d S )%NZExpect� ZPragmac S s$ g | ] \}}d t |�t |�f �qS )z%s: %s)r )r �k�vr r r r X s �z;CurlAsyncHTTPClient._curl_setup_request.<locals>.<listcomp>)�br c s& � j d usJ ��j�� j | � t| �S r: )�streaming_callbackr< � add_callback�len)r� )rA r r r �write_functionf s z?CurlAsyncHTTPClient._curl_setup_request.<locals>.write_functionr" z Mozilla/5.0 (compatible; pycurl)z gzip,deflate�none�basic�digestz Unsupported proxy_auth_mode %sra � r F)�GET�POST�PUT�HEAD)�DELETE�OPTIONS�PATCHTzunknown method )r� r� r� zLBody must %sbe None for method %s (unless allow_nonstandard_methods is true)znot r� z!Body must be None for GET request)�cmdr c s | � j kr��d� d S rC )ZIOCMD_RESTARTREADr} )r� )r@ �request_bufferr r �ioctl� s z6CurlAsyncHTTPClient._curl_setup_request.<locals>.ioctlr� zUnsupported auth_mode %sz%s %s (username: %r)�%s %sz,ssl_options not supported in curl_httpclient)]r' r% �URLr �urlrb Z HTTPHEADER�get_allZHEADERFUNCTION� functools�partial�_curl_header_callback�header_callbackr� r �bytes� bytearray�int�writeZ WRITEFUNCTIONZFOLLOWLOCATIONZfollow_redirectsZ MAXREDIRS� max_redirects�connect_timeoutZCONNECTTIMEOUT_MS�request_timeoutZ TIMEOUT_MS� user_agentZ USERAGENTZnetwork_interfaceZ INTERFACEZdecompress_response�ENCODINGZ proxy_hostZ proxy_portZPROXYZ PROXYPORTZproxy_usernameZproxy_passwordr Zencode_username_passwordZ PROXYUSERPWDZproxy_auth_modeZ PROXYAUTHZHTTPAUTH_BASICZHTTPAUTH_DIGEST� ValueErrorZunsetoptZ validate_certZSSL_VERIFYPEERZSSL_VERIFYHOST�ca_certsZCAINFOZ allow_ipv6Z IPRESOLVEZ IPRESOLVE_V4ZIPRESOLVE_WHATEVERZHTTPGETr� ZUPLOADZNOBODY�set�values�methodZ CUSTOMREQUESTZallow_nonstandard_methods�KeyError�bodyr r Z READFUNCTION�readZ IOCTLFUNCTIONZ POSTFIELDSIZEr� Z INFILESIZEZ auth_usernameZ auth_passwordZ auth_modeZHTTPAUTHZUSERPWDr� �debug� client_certZSSLCERTZ client_keyZSSLKEYZ ssl_options� threading� active_countZNOSIGNALZprepare_curl_callback)r r@ rA rc rb r� � credentialsZ curl_optionsZcustom_methods�oZ body_expectedZ body_presentr� Zuserpwdr )r@ rA r� r r rn > s �� �� � � � ���� �� z'CurlAsyncHTTPClient._curl_setup_request)rb r� �header_line_bytesr c C s� t |�d��}|d ur$| j�||� |�� }|�d�rr|�� z t�|�\}}}d| }W n tj yp Y d S 0 |szd S |� |� d S )N�latin1zHTTP/zX-Http-Reason: %s) r �decoder< r� �rstrip� startswith�clearr Zparse_response_start_lineZHTTPInputError� parse_line)r rb r� r� Z header_line�__rx r r r r� s z)CurlAsyncHTTPClient._curl_header_callback)� debug_type� debug_msgr c C sv d}|dkr&t |�}t�d|�� � nL|dv rXt |�}|�� D ]}t�d|| |� q>n|dkrrt�d|| |� d S )N)�I�<�>r� r� r z%s)ra r� r� � z%s %r)r r� r� �strip� splitlines)r r� r� Z debug_types�liner r r r� ' s z CurlAsyncHTTPClient._curl_debug)r N)NN)!�__name__� __module__� __qualname__r� r �strr r$ r> r r r rG r� r) r( rQ rS r2 rY rF r% r5 r_ r� r r r rk rn r� r� � __classcell__r r r8 r r 0 sH � �!� & �� 3� U � r c @ s e Zd Zeedd�dd�ZdS )r{ N)�errno�messager c C s t �| d|� || _d S )Nrg )r �__init__r� )r r� r� r r r r� 5 s zCurlError.__init__)r� r� r� r� r� r� r r r r r{ 4 s r{ �__main__)&�__doc__r- r� r� r% r� rE �ior �tornador r Ztornado.escaper r Ztornado.httpclientr r r r r Z tornado.logr �typingr r r r � TYPE_CHECKINGr r r � getLoggerr� r r{ r� � configurer r r r �<module> s4
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка