File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/tornado/__pycache__/curl_httpclient.cpython-310.pyc
Back
o ;j�] � @ s& d Z ddlZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z ddl m Z ddl mZmZ ddlmZmZmZmZmZ ddlmZ dd lmZmZmZm Z m Z ddlZej ridd lm Z m Z e�!d �Z"e�#d �Z$G d d� de�Z%G dd� de�Z&e'dkr�e�(e%� e� dS 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�Optional)�Deque�Tupleztornado.curl_httpclients | c sv e Zd Z d5dedeeeef ddf� fdd� Zd6� fdd � Z d e d e e gdf ddfd d �Z dededededdf dd�Zdeddfdd�Zdededdfdd�Zd6dd�Zd6d d �Zd6d d �Z d7d ejd!ee d"ee ddfd#d$�Zd eddfd%d&�Zdejfd'd(�Zd ejd e d)ed*ej ddf d+d,�Z d*ej d-e egdf d.eddfd/d0�Z d1ed2eddfd3d4�Z � Z S )8�CurlAsyncHTTPClient� N� max_clients�defaults�returnc s� t � j|d� t�� � _� j�tj� j� � j�tj� j � � fdd�t |�D �� _ � j d d � � _ t �� � _i � _d � _t�� }� j�|� � j�|� d S )N)r c s g | ]}� � � �qS � )� _curl_create)�.0�i��selfr �K/opt/saltstack/salt/lib/python3.10/site-packages/tornado/curl_httpclient.py� <listcomp>< s z2CurlAsyncHTTPClient.initialize.<locals>.<listcomp>)�super� initialize�pycurlZ CurlMulti�_multi�setoptZM_TIMERFUNCTION� _set_timeoutZM_SOCKETFUNCTION�_handle_socket�range�_curls� _free_list� collections�deque� _requests�_fds�_timeout�Curl� add_handle� remove_handle)r r r Zdummy_curl_handle�� __class__r r r" 4 s � z CurlAsyncHTTPClient.initializec sJ | j d ur | j�| j � | jD ]}|�� q| j�� t� �� d | _d S �N)r/ �io_loop�remove_timeoutr) �closer$ r! )r �curlr3 r r r8 M s zCurlAsyncHTTPClient.close�request�callbackc C s. | j �||| j�� f� | �� | �d� d S )Nr )r- �appendr6 �time�_process_queuer& )r r: r; r r r � fetch_implZ s z CurlAsyncHTTPClient.fetch_impl�event�fd�multi�datac C s� t jtjjt jtjjt jtjjt j tjjtjjB i}|t j kr2|| j v r0| j � |� | j |= dS dS || }|| j v rA| 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 �IOLoopZNONEZPOLL_IN�READZPOLL_OUT�WRITEZ POLL_INOUTZ POLL_REMOVEr. r6 Zremove_handlerZ add_handler�_handle_events)r r@ rA rB rC Z event_mapZ ioloop_eventr r r r' a s � � z"CurlAsyncHTTPClient._handle_socket�msecsc C s< | j dur | j�| j � | j�| j�� |d | j�| _ dS )z(Called by libcurl to schedule a timeout.Ng @�@)r/ r6 r7 Z add_timeoutr= �_handle_timeout)r rH r r r r& ~ s �z CurlAsyncHTTPClient._set_timeout�eventsc C s� d}|t jj@ r |tjO }|t jj@ r|tjO } z | j�||�\}}W n tj y< } z |j d }W Y d}~nd}~ww |tj krCnq| � � dS )zXCalled by IOLoop when there is activity on one of our file descriptors. r TN) r rD rE r# Z CSELECT_INrF Z CSELECT_OUTr$ � socket_action�error�args�E_CALL_MULTI_PERFORM�_finish_pending_requests)r rA rJ �action�ret� num_handles�er r r rG � s �� � z"CurlAsyncHTTPClient._handle_eventsc C s� d| _ z | j�tjd�\}}W n tjy( } z |jd }W Y d}~nd}~ww |tjkr/nq| �� | j� � }|dkrD| � |� dS dS )z7Called by IOLoop when the requested timeout has passed.NTr ) r/ r$ rK r# ZSOCKET_TIMEOUTrL rM rN rO �timeoutr& )r rQ rR rS Z new_timeoutr r r rI � s �� � �z#CurlAsyncHTTPClient._handle_timeoutc C s\ | j �� \}}}|D ]}| �|� q |D ] \}}}| �|||� q|dkr'nq| �� dS )zbProcess any requests that were completed by the last call to multi.socket_action. Tr N)r$ Z info_read�_finishr> )r Znum_qZok_listZerr_listr9 Zerrnum�errmsgr r r rO � s � z,CurlAsyncHTTPClient._finish_pending_requestsc C s� d}| j rq| jrq|d7 }| j �� }| j�� \}}}t�� t� |||t�� | j� � �� d�|_ z| � |||j d |j d � W n% t yd } z|� � | j �|� |t|d|d�� W Y d }~n d }~ww | j�|� | j rq| js |sud S q) NTr � )�headers�bufferr: r; �queue_start_time�curl_start_time�curl_start_ioloop_timerY rX �W )r: �coderL )r* r- �pop�popleftr � HTTPHeadersr r= r6 �current�info�_curl_setup_request� Exception�resetr< r r$ r1 )r �startedr9 r: r; rZ rS r r r r> � s@ � � �� �$�z"CurlAsyncHTTPClient._process_queuer9 � curl_error� curl_messagec C sh |j }d |_ | j�|� |d }|r/|d usJ �t||�}|d us#J �|j}d }|�� d }nd }|�tj�}|�tj �}|� d� t |d |d |�tj �|�tj �|�tj�|�tj�|�tj�|�tj�|�tj�d�} z'|d t|d ||d ||||d �d d �| j�� |d |d | d � � W n ty� | �|d � Y nw |�� | j�|� d S ) NrY r r\ rZ )�queueZ namelookup�connectZ appconnectZ pretransferZ starttransfer�totalZredirectr; r: rX z X-Http-Reasonr[ ) r: r^ rX rY � effective_urlrL �reasonZ request_timeZ start_time� time_info) rc r$ r2 � CurlErrorr^ r8 Zgetinfor# Z HTTP_CODEZ EFFECTIVE_URL�seek�dictZNAMELOOKUP_TIMEZ CONNECT_TIMEZAPPCONNECT_TIMEZPRETRANSFER_TIMEZSTARTTRANSFER_TIMEZ TOTAL_TIMEZ REDIRECT_TIMEr �getr6 r= re �handle_callback_exceptionrf r* r< ) r r9 rh ri rc rY rL r^ rm ro r r r rU � s\ � �� �zCurlAsyncHTTPClient._finishc C s t jd|dd� d S )NzException in callback %rT)�exc_info)r rL )r r; r r r rt $ s z-CurlAsyncHTTPClient.handle_callback_exceptionc C s t �� S r5 )r# r0 r r r r r ' s z CurlAsyncHTTPClient._curl_createrY rX c s� t �tj�r|�tjd� |�tj�j� t td�r0|�tj tj tj B � |�tj tj tj B � |�tjt� j�� d� jvrDd� jd< d� jvrNd� jd< dd� � j�� D �}|D ] }t�|�rgtd| ��qZ|�tj|� |�tjt��j|� j�� � j r�d t t t f d t f� �fd d � }n|j!}|�tj"|� |�tj#� j$� |�tj%� j&� � j'd us�J �|�tj(t d � j' �� � j)d us�J �|�tj*t d � j) �� � j+r�|�tj,t� j+�� n|�tj,d� � j-r�|�tj.� j-� � j/r�|�tj0d� n|�tj0d � � j1�ra� j2�ra|�tj3� j1� |�tj4� j2� � j5�r6� j6d u�s'J �t7�8� j5� j6�}|�tj9|� � j:d u �sB� j:dk�rK|�tj;tj<� n6� j:dk�rZ|�tj;tj=� n'td� j: ��z|�>tj3� W n t?�yz |�tj3d� Y nw |�>tj9� � j@�r�|�tjAd� |�tjBd� n|�tjAd� |�tjBd� � jCd u�r�|�tjD� jC� n � jEdu �r�|�tjFtjG� n|�tjFtjH� tjItjJtjKtjLd�} h d�} | �M� D ] } |�| d� �q܈ jN| v �r�|�>tjO� |�| � jN d� n� jP�s� jN| v �r|�tjO� jN� ntQd� jN ��� jNdv } � jRd u} � jP�s>| �r*| �r0| �r>| �s>td| �r7d nd� jNf ��| �sD| �r�� jNd k�rNtd ��tStT� jR�pUd���d t d t d t f�fd!d"� }|�tjU�jV� |�tjW|� � jNd#k�r�|�tjXtY� jR�p�d�� n|�tjKd� |�tjZtY� jR�p�d�� � j[d u�r� j\d u�s�J �� j]d u �s�� j]dk�r�|�tj^tj<� n� j]dk�r�|�tj^tj=� ntd$� j] ��t7�8� j[� j\�}|�tj_|� t �`d%� jN� j� j[� n|�>tj_� t �`d&� jN� j� � jad u�r |�tjb� ja� � jcd u�r|�tjd� jc� � jed u�r%td'��tf�g� dk�r3|�tjhd� � jid u�r@� �i|� d S d S )(NrW � PROTOCOLSZExpect� ZPragmac S s0 g | ]\}}d t |��d�t |��d�f �qS )s %s: %s�ASCIIz ISO8859-1)r �encode)r �k�vr r r r K s ���z;CurlAsyncHTTPClient._curl_setup_request.<locals>.<listcomp>z+Illegal characters in header (CR or LF): %r�br c s& � j d usJ ��j�� j | � t| �S r5 )�streaming_callbackr6 � add_callback�len)r| )r: r r r �write_function] s z?CurlAsyncHTTPClient._curl_setup_request.<locals>.write_functioni� z Mozilla/5.0 (compatible; pycurl)z gzip,deflateZbasic�digestz Unsupported proxy_auth_mode %s� r F)�GET�POST�PUT�HEAD> ZOPTIONS�PATCHZDELETETzunknown 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�offset�originc s � � | |� tjS r5 )rq r# Z SEEKFUNC_OK)r� r� )�request_bufferr r rq � s z5CurlAsyncHTTPClient._curl_setup_request.<locals>.seekr� zUnsupported auth_mode %sz%s %s (username: %r)�%s %sz,ssl_options not supported in curl_httpclient)j�curl_log� isEnabledFor�logging�DEBUGr% r# �VERBOSEZ DEBUGFUNCTION� _curl_debug�hasattrrv Z PROTO_HTTPZ PROTO_HTTPSZREDIR_PROTOCOLSZURLr �urlrX �get_all� CR_OR_LF_RE�search� ValueErrorZ HTTPHEADERZHEADERFUNCTION� functools�partial�_curl_header_callback�header_callbackr} r �bytes� bytearray�int�writeZ WRITEFUNCTIONZFOLLOWLOCATIONZfollow_redirectsZ MAXREDIRSZ max_redirectsZconnect_timeoutZCONNECTTIMEOUT_MSZrequest_timeoutZ TIMEOUT_MSZ user_agentZ USERAGENTZnetwork_interfaceZ INTERFACEZdecompress_response�ENCODINGZ proxy_hostZ proxy_portZPROXYZ PROXYPORTZproxy_usernameZproxy_passwordr Zencode_username_passwordZ PROXYUSERPWDZproxy_auth_modeZ PROXYAUTHZHTTPAUTH_BASICZHTTPAUTH_DIGESTZunsetopt� TypeErrorZ validate_certZSSL_VERIFYPEERZSSL_VERIFYHOST�ca_certsZCAINFOZ allow_ipv6Z IPRESOLVEZ IPRESOLVE_V4ZIPRESOLVE_WHATEVERZHTTPGETr� ZUPLOADZNOBODY�values�methodZ CUSTOMREQUESTZallow_nonstandard_methods�KeyError�bodyr r Z READFUNCTION�readZ SEEKFUNCTIONZ POSTFIELDSIZEr Z INFILESIZEZ auth_usernameZ auth_passwordZ auth_modeZHTTPAUTHZUSERPWD�debugZ client_certZSSLCERTZ client_keyZSSLKEYZ ssl_options� threading� active_countZNOSIGNALZprepare_curl_callback)r r9 r: rY rX Zencoded_headers�liner� Z credentialsZ curl_optionsZcustom_methods�oZ body_expectedZ body_presentrq Zuserpwdr )r: r� r r rd * s$ � � � ��"� �� � ���� �� �z'CurlAsyncHTTPClient._curl_setup_requestr� �header_line_bytesc C s� t |�d��}|d ur| j�||� |�� }|�d�r9|�� zt�|�\}}}d| }W n tj y8 Y d S w |s=d S |� |� d S )N�latin1zHTTP/zX-Http-Reason: %s) r �decoder6 r~ �rstrip� startswith�clearr Zparse_response_start_lineZHTTPInputErrorZ parse_line)r rX r� r� Z header_line�_version�_codern r r r r� s" � �z)CurlAsyncHTTPClient._curl_header_callback� debug_type� debug_msgc C s~ d}|dkrt |�}t�d|�� � d S |dv r.t |�}|�� D ] }t�d|| |� q d S |dkr=t�d|| |� d S d S )N)�I�<�>r� r� r z%s)rW r� r� � z%s %r)r r� r� �strip� splitlines)r r� r� Z debug_typesr� r r r r� # s ��z CurlAsyncHTTPClient._curl_debug)r N)r N)NN)!�__name__� __module__� __qualname__r� r r �strr r" r8 r r r r? r� r' r& rG rI rO r> r# r0 rU rt r r r ra rd r� r� � __classcell__r r r3 r r 3 st ���� � � � -���� �7���� � a� �� � r c @ s" e Zd Zdededdfdd�ZdS )rp �errno�messager Nc C s t �| d|� || _d S )Nr] )r �__init__r� )r r� r� r r r r� 1 s zCurlError.__init__)r� r� r� r� r� r� r r r r rp 0 s rp �__main__))�__doc__r+ r� r� r# �rer� r= �ior Ztornador r Ztornado.escaper r Ztornado.httpclientr r r r r Z tornado.logr �typingr r r r r � TYPE_CHECKINGr r � getLoggerr� �compiler� r rp r� Z configurer r r r �<module> s< �
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings