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: curl_httpclient.cpython-310.pyc
o �xe Z � @ s� d Z ddlmZmZmZ ddlZddlZddlZddlZddl Z ddl Z ddl m Z ddl mZ ddl mZ ddl mZ ddlmZmZ dd lmZmZmZmZ e�d �ZG d d � d e�ZG d d� de�Z e dkrse� 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_httpclientc 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>. 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 E s zCurlAsyncHTTPClient.closec C s& | j �||f� | �� | �d� d S �Nr )r( �append�_process_queuer! )r �request�callbackr r r � fetch_implN 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" S 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 Zmsecsr r r r! q 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 x 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 rH r ZSOCKET_TIMEOUTrI rJ rK rL �timeoutr! )r rO rP rQ 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 rR r Z socket_allr rI rJ rK rL )r rO rP rQ 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 rL � 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_timerX rW �W )r< �coderI )r rR r% r( �pop�popleftr Z HTTPHeadersr rF �info�_curl_setup_request� Exceptionr: r r r/ )r �startedr8 r< r= rQ 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 ) NrX r rY r< )�queueZ namelookup�connectZ pretransferZ starttransfer�totalZredirectr= rW z X-Http-Reason) r< r[ rW rX � effective_urlrI �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 r` �handle_callback_exception) r r8 Z curl_errorZ curl_messager^ rX rI r[ re rg r r r rT � sF � � �zCurlAsyncHTTPClient._finishc C s | j �|� d S r3 )r rl )r r= r r r rl 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 )NrV � PROTOCOLS)r r. �curl_logZ isEnabledFor�logging�DEBUGr �VERBOSEZ DEBUGFUNCTION� _curl_debug�hasattrrm 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< � � tjdd� �j�� D �� � � tjt � �j |�j �� �j rF��fdd��n|j�ttu rU� � tj�� n � � tj�fdd �� � � tj�j� � � tj�j� � � tjtd �j �� � � tjtd �j �� �jr�� � 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(dkr�� � tj)tj*� n#�j(dk�r� � tj)tj+� nt,d�j( ��� � tj#d� � �-tj'� �j.�r-� � tj/d� � � tj0d� n� � tj/d� � � tj0d� �j1d u�rJ� � tj2�j1� n �j3du �rZ� � tj4tj5� n� � tj4tj6� tj7tj8tj9tj:d�}t;g d��}|�<� D ] }� � |d� �qw�j=|v �r�� �-tj>� � � |�j= d� n�j?�s��j=|v �r�� � tj>�j=� nt@d�j= ���j=dv } �jAd u} �j?�s�| �r�| �r�| �r�| �s�t,d| �r�d nd�j=f ��| �s�| �r1�j=d k�r�t,d ��tBtC�jA�p�d���� �fd d �} � � tjD�jE� � � tjF| � �j=d!k�r � � tjGtH�jA�pd�� n� � tj9d� � � tjItH�jA�p.d�� �jJd u�r�d�jJ�jK�p?df } �jLd u �sN�jLdk�rW� � tjMtj*� n�jLdk�rf� � tjMtj+� nt,d"�jL ��� � tjNt| �� tO�Pd#�j=�j�jJ� n� �-tjN� tO�Pd$�j=�j� �jQd u�r�� � tjR�jQ� �jSd u�r�� � tjT�jS� �jUd u�r�t,d%��tV�W� dk�rň � tjXd� �jYd u�r҈�Y� � d S d S )&NZExpect� ZPragmac S s$ g | ]\}}d t |�t |�f �qS )z%s: %s)r )r �k�vr r r r 2 s �z;CurlAsyncHTTPClient._curl_setup_request.<locals>.<listcomp>c s �j �� j| � d S r3 )r � add_callback�streaming_callback)�chunk)r< r r r �write_function9 s z?CurlAsyncHTTPClient._curl_setup_request.<locals>.write_functionc s � t | ��S r3 )r )�s)rz r r �<lambda>G s z9CurlAsyncHTTPClient._curl_setup_request.<locals>.<lambda>r z Mozilla/5.0 (compatible; pycurl)z gzip,deflateZnonez%s:%sZbasic�digestz Unsupported proxy_auth_mode %srV � 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_RESTARTREADri )�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)Zr r ZURLr �urlrW Z HTTPHEADER�get_allZHEADERFUNCTION� functools�partial�_curl_header_callback�header_callbackrx �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_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 POSTFIELDSIZE�lenZ INFILESIZEZ auth_usernameZ auth_passwordZ auth_modeZHTTPAUTHZUSERPWDrn �debugZ client_certZSSLCERTZ client_keyZSSLKEYZ ssl_options� threading� activeCountZNOSIGNALZprepare_curl_callback) r r8 r< rX rW Z credentialsZ curl_optionsZcustom_methods�oZ body_expectedZ body_presentr� Zuserpwdr )r8 r< r� r rz 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 rw �rstrip� startswith�clearr Zparse_response_start_lineZHTTPInputErrorZ parse_line)r rW r� Z header_line�__rf 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)rV r~ r� � z%s %r)r rn r� �strip� splitlines)r Z debug_typeZ debug_msgZ debug_types�liner r r rr � s ��z CurlAsyncHTTPClient._curl_debug)r N)NN)�__name__� __module__� __qualname__r r6 r> r" r! rB rG r+ rL r; rT rl r r_ r� rr � __classcell__r r r1 r r ( s$ '& ?r c @ s e Zd Zdd� ZdS )rh c C s t �| d|� || _d S )NrZ )r �__init__�errno)r r� �messager r r r� � s zCurlError.__init__N)r� r� r� r� r r r r rh � s rh �__main__) �__doc__Z __future__r r r r& r� ro r r� rF �ior Zsalt.ext.tornador r r Zsalt.ext.tornado.escaper r Zsalt.ext.tornado.httpclientr r r r Z getLoggerrn r rh r� Z configurer r r r �<module> s0 V �
Save