File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/ext/tornado/__pycache__/curl_httpclient.cpython-310.pyc
Back
o ;j/[ � @ s� d Z ddlmZmZmZ ddlZddlZddlZddlZddl Z ddl Z ddl Z ddl m Z ddlmZ ddlmZ ddlmZ ddlmZmZ dd lmZmZmZmZ e�d �Ze � d �Z G d d � d e�Z G dd� de�Z e dkr|e�!e � e� dS dS )z5Non-blocking HTTP client implementation using pycurl.� )�absolute_import�division�print_functionN)�BytesIO)�httputil)�ioloop)� stack_context)�utf8� native_str)� HTTPResponse� HTTPError�AsyncHTTPClient�mainztornado.curl_httpclients | c s� e Zd Zd#� fdd� Z� fdd�Zdd� Zd d � Zd d � Zd d� Zdd� Z dd� Z dd� Z dd� Z d$dd�Z dd� Zdd � Zd d � Zd d � Zd!d"� Z� ZS )%�CurlAsyncHTTPClient� Nc s� t t� �j||d� t�� � _� j�tj� j� � j�tj � j � � fdd�t |�D �� _ � j d d � � _ t�� � _i � _d � _tj� jd|d�� _� j�� t�� }� j�|� � j�|� d S )N)�defaultsc s g | ]}� � � �qS � )� _curl_create)�.0�i��selfr �T/opt/saltstack/salt/lib/python3.10/site-packages/salt/ext/tornado/curl_httpclient.py� <listcomp>0 s z2CurlAsyncHTTPClient.initialize.<locals>.<listcomp>�� )�io_loop)�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 Z max_clientsr Zdummy_curl_handle�� __class__r r r + s � z CurlAsyncHTTPClient.initializec sR | j �� | jd ur| j�| j� | jD ]}|�� q| j�� tt | ��� d S �N) r, �stopr* r �remove_timeoutr$ �closer r r �r �curlr1 r r r6 G s zCurlAsyncHTTPClient.closec C s& | j �||f� | �� | �d� d S �Nr )r( �append�_process_queuer! )r �request�callbackr r r � fetch_implP s z CurlAsyncHTTPClient.fetch_implc 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) r Zremove_handlerZ add_handler�_handle_events)r �event�fdZmulti�dataZ event_mapZ ioloop_eventr r r r" U s" � � �z"CurlAsyncHTTPClient._handle_socketc C s< | j dur | j�| j � | j�| j�� |d | j�| _ dS )z(Called by libcurl to schedule a timeout.Ng @�@)r* r r5 Z add_timeout�time�_handle_timeout)r �msecsr r r r! s s �z CurlAsyncHTTPClient._set_timeoutc 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 r? r@ r Z CSELECT_INrA Z CSELECT_OUTr � socket_action�error�args�E_CALL_MULTI_PERFORM�_finish_pending_requests)r rD �events�action�ret� num_handles�er r r rB z s �� � z"CurlAsyncHTTPClient._handle_eventsc C s� t �� �< d| _ z | j�tjd�\}}W n tjy- } z |jd }W Y d}~nd}~ww |tj kr4nq | � � W d � n1 sCw Y | j� � }|dkrX| � |� dS dS )z7Called by IOLoop when the requested timeout has passed.NTr ) r � NullContextr* r rI r ZSOCKET_TIMEOUTrJ rK rL rM �timeoutr! )r rP rQ rR Z new_timeoutr r r rG � s( ��� � � �z#CurlAsyncHTTPClient._handle_timeoutc C s� t �� �7 z | j�� \}}W n tjy' } z |jd }W Y d}~nd}~ww |tjkr.nq| �� W d � dS 1 s>w Y dS )zpCalled by IOLoop periodically to ask libcurl to process any events it may have forgotten about. Tr N) r rS r Z socket_allr rJ rK rL rM )r rP rQ rR r r r r+ � s �� � "�z)CurlAsyncHTTPClient._handle_force_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_listr8 Zerrnum�errmsgr r r rM � s � z,CurlAsyncHTTPClient._finish_pending_requestsc C s t �� �r d}| jrj| jrj|d7 }| j�� }| j�� \}}t�� t� ||t � � d�|_ z| � |||j d |j d � W n! t y] } z| j� |� |t|d|d�� W Y d }~n d }~ww | j�|� | jrj| js|smnqW d � d S 1 syw Y d S ) NTr � )�headers�bufferr< r= �curl_start_timerY rX �W )r< �coderJ )r rS r% r( �pop�popleftr Z HTTPHeadersr rF �info�_curl_setup_request� Exceptionr: r r r/ )r �startedr8 r< r= rR r r r r; � sD � � ��� � �#"�z"CurlAsyncHTTPClient._process_queuec C s8 |j }d |_ | j�|� | j�|� |d }|r)t||�}|j}d }|�� d }nd }|�t j �}|�t j �}|� d� t |d |d j |�t j�|�t j�|�t j�|�t j�|�t j�|�t j�d�} z$|d t|d ||d ||||d �dd �t�� |d | d � � W d S ty� | �|d � Y d S w ) NrY r rZ r< )�queueZ namelookup�connectZ pretransferZ starttransfer�totalZredirectr= rX z X-Http-Reason) r< r\ rX rY � effective_urlrJ �reasonZ request_time� time_info)r_ r r0 r% r: � CurlErrorr\ r6 Zgetinfor Z HTTP_CODEZ EFFECTIVE_URL�seek�dictZ start_timeZNAMELOOKUP_TIMEZ CONNECT_TIMEZPRETRANSFER_TIMEZSTARTTRANSFER_TIMEZ TOTAL_TIMEZ REDIRECT_TIMEr �getrF ra �handle_callback_exception) r r8 Z curl_errorZ curl_messager_ rY rJ r\ rf rh r r r rU � sF � � �zCurlAsyncHTTPClient._finishc C s | j �|� d S r3 )r rm )r r= r r r rm s z-CurlAsyncHTTPClient.handle_callback_exceptionc C sl t �� }t�tj�r|�t jd� |�t j| j � t t d�r4|�t j t j t j B � |�t jt j t j B � |S )NrW � PROTOCOLS)r r. �curl_log� isEnabledFor�logging�DEBUGr �VERBOSEZ DEBUGFUNCTION� _curl_debug�hasattrrn Z PROTO_HTTPZ PROTO_HTTPSZREDIR_PROTOCOLSr7 r r r r s z CurlAsyncHTTPClient._curl_createc s� � � tjt�j�� d�jvrd�jd< d�jvr d�jd< dd� �j�� D �}|D ] }t�|�r7t d| ��q*� � tj |� � � tj t � �j|�j�� �jrX��fdd��n|j�ttu rg� � tj�� n � � tj�fd d �� � � tj�j� � � tj�j� � � tjtd �j �� � � tj td �j �� �j r�� � tj t�j �� n� � tj d � �j r�� � tj!�j � �j"rň � tj#d � n� � tj#d� �j$�r!�j%�r!� � tj&�j$� � � tj'�j%� �j(r�d�j(�j)f }� � tj*|� �j+d u �s�j+dk�r � � tj,tj-� n#�j+dk�r� � tj,tj.� nt d�j+ ��� � tj&d� � �/tj*� �j0�rA� � tj1d� � � tj2d� n� � tj1d� � � tj2d� �j3d u�r^� � tj4�j3� n �j5du �rn� � tj6tj7� n� � tj6tj8� tj9tj:tj;tj<d�}t=g d��} |�>� D ] } � � | d� �q��j?|v �r�� �/tj@� � � |�j? d� n�jA�s��j?| v �r�� � tj@�j?� ntBd�j? ���j?dv } �jCd u} �jA�s�| �r�| �r�| �r�| �s�t d | �r�d nd�j?f ��| �s�| �rE�j?d k�r�t d ��tDtE�jC�pd���� �fd d!�} � � tjF�jG� � � tjH| � �j?d"k�r1� � tjItJ�jC�p-d�� n� � tj;d� � � tjKtJ�jC�pBd�� �jLd u�r�d�jL�jM�pSdf }�jNd u �sb�jNdk�rk� � tjOtj-� n�jNdk�rz� � tjOtj.� nt d#�jN ��� � tjPt|�� tQ�Rd$�j?�j�jL� n� �/tjP� tQ�Rd%�j?�j� �jSd u�r�� � tjT�jS� �jUd u�r�� � tjV�jU� �jWd u�r�t d&��tX�Y� dk�rو � tjZd� �j[d u�r��[� � d S d S )'NZExpect� 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 3 s ���z;CurlAsyncHTTPClient._curl_setup_request.<locals>.<listcomp>z+Illegal characters in header (CR or LF): %rc s �j �� j| � d S r3 )r � add_callback�streaming_callback)�chunk)r< r r r �write_functionA s z?CurlAsyncHTTPClient._curl_setup_request.<locals>.write_functionc s � t | ��S r3 )r )�s)r~ r r �<lambda>O s z9CurlAsyncHTTPClient._curl_setup_request.<locals>.<lambda>r z Mozilla/5.0 (compatible; pycurl)z gzip,deflate�nonez%s:%sZbasic�digestz Unsupported proxy_auth_mode %srW � r F)�GET�POST�PUT�HEAD)ZDELETEZOPTIONS�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 requestc s | � j kr ��d� d S d S r9 )ZIOCMD_RESTARTREADrj )�cmd)r8 �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 ZURLr �urlrX �get_all� CR_OR_LF_RE�search� ValueErrorZ HTTPHEADERZHEADERFUNCTION� functools�partial�_curl_header_callback�header_callbackr| �write�bytes�strZ WRITEFUNCTIONZFOLLOWLOCATIONZfollow_redirectsZ MAXREDIRSZ max_redirectsZCONNECTTIMEOUT_MS�intZconnect_timeoutZ TIMEOUT_MSZrequest_timeoutZ user_agentZ USERAGENTZnetwork_interfaceZ INTERFACEZdecompress_response�ENCODINGZ proxy_hostZ proxy_portZPROXYZ PROXYPORTZproxy_usernameZproxy_passwordZ PROXYUSERPWDZproxy_auth_modeZ PROXYAUTHZHTTPAUTH_BASICZHTTPAUTH_DIGESTZunsetoptZ 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 POSTFIELDSIZE�lenZ INFILESIZEZ auth_usernameZ auth_passwordZ auth_modeZHTTPAUTHZUSERPWDro �debugZ client_certZSSLCERTZ client_keyZSSLKEYZ ssl_options� threading� activeCountZNOSIGNALZprepare_curl_callback)r r8 r< rY rX Zencoded_headers�lineZ credentialsZ curl_optionsZcustom_methods�oZ body_expectedZ body_presentr� Zuserpwdr )r8 r< r� r r~ r r` ! s� � ��� � � � ���� � �z'CurlAsyncHTTPClient._curl_setup_requestc 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 �decoder r{ �rstrip� startswith�clearr Zparse_response_start_lineZHTTPInputErrorZ parse_line)r rX r� Z header_line�__rg r r r r� � s �z)CurlAsyncHTTPClient._curl_header_callbackc C sv d}t |�}|dkrt�d|�� � d S |dv r*|�� D ] }t�d|| |� q d S |dkr9t�d|| |� d S d S )N)�I�<�>r� r� r z%s)rW r� r� � z%s %r)r ro r� �strip� splitlines)r Z debug_typeZ debug_msgZ debug_typesr� r r r rt � s ��z CurlAsyncHTTPClient._curl_debug)r N)NN)�__name__� __module__� __qualname__r r6 r> r" r! rB rG r+ rM r; rU rm r r` r� rt � __classcell__r r r1 r r * s$ '& Er c @ s e Zd Zdd� ZdS )ri c C s t �| d|� || _d S )Nr[ )r �__init__�errno)r r� �messager r r r� s zCurlError.__init__N)r� r� r� r� r r r r ri s ri �__main__)"�__doc__� __future__r r r r& r� rq r �rer� rF �ior Zsalt.ext.tornador r r Zsalt.ext.tornado.escaper r Zsalt.ext.tornado.httpclientr r r r � getLoggerro �compiler� r ri r� Z configurer r r r �<module> s4 \ �
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings