FM / __pycache_

/usr/local/lib64/python3.6/site-packages/aiohttp/__pycache__/

/usr/local/lib64/python3.6/site-packages/aiohttp/__pycache__

Name	Size	Mode	Actions
abc.cpython-36.pyc	8528	0644	edit dl rm
base_protocol.cpython-36.pyc	2824	0644	edit dl rm
client.cpython-36.pyc	29965	0644	edit dl rm
client_exceptions.cpython-36.pyc	11369	0644	edit dl rm
client_proto.cpython-36.pyc	6041	0644	edit dl rm
client_reqrep.cpython-36.pyc	27700	0644	edit dl rm
client_ws.cpython-36.pyc	8824	0644	edit dl rm
connector.cpython-36.pyc	35273	0644	edit dl rm
cookiejar.cpython-36.pyc	10852	0644	edit dl rm
formdata.cpython-36.pyc	4440	0644	edit dl rm
hdrs.cpython-36.pyc	4473	0644	edit dl rm
helpers.cpython-36.pyc	26037	0644	edit dl rm
http.cpython-36.pyc	1422	0644	edit dl rm
http_exceptions.cpython-36.pyc	4396	0644	edit dl rm
http_parser.cpython-36.pyc	19182	0644	edit dl rm
http_websocket.cpython-36.pyc	14942	0644	edit dl rm
http_writer.cpython-36.pyc	5493	0644	edit dl rm
locks.cpython-36.pyc	1582	0644	edit dl rm
log.cpython-36.pyc	423	0644	edit dl rm
multipart.cpython-36.pyc	26312	0644	edit dl rm
payload.cpython-36.pyc	13433	0644	edit dl rm
payload_streamer.cpython-36.pyc	3182	0644	edit dl rm
pytest_plugin.cpython-36.pyc	9870	0644	edit dl rm
resolver.cpython-36.pyc	3940	0644	edit dl rm
streams.cpython-36.pyc	18605	0644	edit dl rm
tcp_helpers.cpython-36.pyc	1076	0644	edit dl rm
test_utils.cpython-36.pyc	21667	0644	edit dl rm
tracing.cpython-36.pyc	14857	0644	edit dl rm
typedefs.cpython-36.pyc	1482	0644	edit dl rm
web.cpython-36.pyc	10744	0644	edit dl rm
web_app.cpython-36.pyc	15118	0644	edit dl rm
web_exceptions.cpython-36.pyc	12766	0644	edit dl rm
web_fileresponse.cpython-36.pyc	5935	0644	edit dl rm
web_log.cpython-36.pyc	7182	0644	edit dl rm
web_middlewares.cpython-36.pyc	3863	0644	edit dl rm
web_protocol.cpython-36.pyc	15761	0644	edit dl rm
web_request.cpython-36.pyc	23874	0644	edit dl rm
web_response.cpython-36.pyc	21093	0644	edit dl rm
web_routedef.cpython-36.pyc	7973	0644	edit dl rm
web_runner.cpython-36.pyc	11755	0644	edit dl rm
web_server.cpython-36.pyc	2681	0644	edit dl rm
web_urldispatcher.cpython-36.pyc	42230	0644	edit dl rm
web_ws.cpython-36.pyc	13281	0644	edit dl rm
worker.cpython-36.pyc	6963	0644	edit dl rm
__init__.cpython-36.pyc	4270	0644	edit dl rm

Edit: /usr/local/lib64/python3.6/site-packages/aiohttp/__pycache__/connector.cpython-36.pyc (35273B)

3 8%Eg��@sRddlZddlZddlZddlZddlZddlZddlmZmZddl m Z ddlmZddl mZmZddlmZddlmZddlmZmZmZmZmZmZmZmZmZmZmZm Z m!Z!m"Z"ddl#Z#d d l$m%Z%m&Z&d dl'm(Z(d dl)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3d d l4m5Z5d dl6m7Z7m8Z8m9Z9d dl&m:Z:m;Z;mZ>m?Z?d dl@mAZAd dlBmCZCd dlDmEZEyddlFZFeFjGZGWneHk �r�dZFeIZGYnXd&ZJe�r�d dlKmLZLd dl6mMZMd dlNmOZOGdd�d�ZPGdd�d�ZQGdd�d�ZRGd d�d�ZSGd!d"�d"�ZTGd#d�deS�ZUGd$d�deS�ZVGd%d�deS�ZWdS)'�N)�defaultdict�deque)�suppress)�SimpleCookie)�cycle�islice)� monotonic)� TracebackType)� TYPE_CHECKING�Any� Awaitable�Callable�DefaultDict�Dict�Iterator�List�Optional�Set�Tuple�Type�Union�cast�)�hdrs�helpers)�AbstractResolver) �ClientConnectionError�ClientConnectorCertificateError�ClientConnectorError�ClientConnectorSSLError�ClientHttpProxyError�ClientProxyConnectionError�ServerFingerprintMismatch�UnixClientConnectorError�cert_errors� ssl_errors)�ResponseHandler)� ClientRequest�Fingerprint�_merge_ssl_params)�PY_36�ceil_timeout�get_running_loop� is_ip_address�noop�sentinel)� RESPONSES)�EventResultOrError)�DefaultResolver� BaseConnector�TCPConnector� UnixConnector�NamedPipeConnector)� ClientTimeout)� ConnectionKey)�Tracec@s@eZdZdZeedd�dd�Zed�dd �Zdd�d d�ZdS) �_DeprecationWaiter� _awaitable�_awaitedN)� awaitable�returncCs||_d|_dS)NF)r;r<)�selfr=�r@�=/usr/local/lib64/python3.6/site-packages/aiohttp/connector.py�__init__Qsz_DeprecationWaiter.__init__)r>cCsd|_|jj�S)NT)r<r;� __await__)r?r@r@rArCUsz_DeprecationWaiter.__await__cCs|jstjdt�dS)NzDConnector.close() is a coroutine, please use await connector.close())r<�warnings�warn�DeprecationWarning)r?r@r@rA�__del__Ysz_DeprecationWaiter.__del__)r;r<) �__name__� __module__�__qualname__� __slots__rrrBrCrGr@r@r@rAr:Nsr:c@s�eZdZdZdZddeejdd�dd�Ze d�dd �Z efedd �dd�Z eejd�d d��Zeeejd�dd��Zeeed�dd��Zegdfdd�dd�Zdd�dd�Zdd�dd�Zdd�dd�Zeed�dd��ZdS)� ConnectionNr3r8)� connector�key�protocol�loopr>cCs<||_||_||_||_g|_|j�r8tjtj d��|_ dS)Nr)�_key� _connector�_loop� _protocol� _callbacks� get_debug� traceback� extract_stack�sys� _getframe�_source_traceback)r?rMrNrOrPr@r@rArBgszConnection.__init__)r>cCsd|j�d�S)NzConnection<�>)rQ)r?r@r@rA�__repr__wszConnection.__repr__)� _warningsr>cCs�|jdk r�trd|i}ni}|jd|��tf|�|jj�r@dS|jj|j|jdd�|dd�}|j dk rt|j |d<|jj |�dS)N�sourcezUnclosed connection T)�should_closezUnclosed connection)Zclient_connection�message�source_traceback)rTr*rE�ResourceWarningrS� is_closedrR�_releaserQr[�call_exception_handler)r?r^�kwargs�contextr@r@rArGzs zConnection.__del__cCstjdtdd�|jS)Nz%connector.loop property is deprecated�)� stacklevel)rDrErFrS)r?r@r@rArP�szConnection.loopcCs|jdkrdS|jjS)N)rT� transport)r?r@r@rArk�s zConnection.transportcCs|jS)N)rT)r?r@r@rArO�szConnection.protocol)�callbackr>cCs|dk r|jj|�dS)N)rU�append)r?rlr@r@rA�add_callback�szConnection.add_callbackc CsB|jdd�g}|_x&|D]}tt��|�WdQRXqWdS)N)rUr� Exception)r?� callbacks�cbr@r@rA�_notify_release�s zConnection._notify_releasecCs2|j�|jdk r.|jj|j|jdd�d|_dS)NT)r`)rrrTrRrerQ)r?r@r@rA�close�s zConnection.closecCs6|j�|jdk r2|jj|j|j|jjd�d|_dS)N)r`)rrrTrRrerQr`)r?r@r@rA�release�s zConnection.releasecCs|jdkp|jj�S)N)rT�is_connected)r?r@r@rA�closed�szConnection.closed)rHrIrJr[� _transportr&�asyncio�AbstractEventLooprB�strr]rDrrG�propertyrPr� TransportrkrOr rnrrrsrt�boolrvr@r@r@rArLbs* rLc@seZdZdZdd�dd�ZdS)�_TransportPlaceholderz.placeholder for BaseConnector.connect functionN)r>cCsdS)Nr@)r?r@r@rArs�sz_TransportPlaceholder.close)rHrIrJ�__doc__rsr@r@r@rAr~�sr~c @s�eZdZdZdZdZdZedddddd�ee de feeeee ejdd �d d�Zefedd�d d�Zdd�dd�Zedd�dd�Zdd�dd�ZdDe eee ee edd�dd�Zeed�dd��Zeed�dd��Zeed�dd��Zdd�d d!�Zd"e dd#�d$d%�Z!dd�d&d'�Z"e#dd�d(d)�Z$dd�d*d+�Z%eed�d,d-��Z&d"ed.�d/d0�Z'd1e(d2d3e)d4�d5d6�Z*d"e e d.�d7d8�Z+dd�d9d:�Z,d"e dd;�d�d"e edd?�d@dA�Z.d1e(d2d3e d4�dBdC�Z/dS)Er3a�Base connector class. keepalive_timeout - (optional) Keep-alive timeout. force_close - Set to True to force close and do reconnect after each request (and between redirects). limit - The total number of simultaneous connections. limit_per_host - Number of simultaneous connections to one host. enable_cleanup_closed - Enables clean-up closed ssl transports. Disabled by default. loop - Optional event loop. TNg@F�dr)�keepalive_timeout�force_close�limit�limit_per_host�enable_cleanup_closedrP)r�r�r�r�r�rPr>cCs�|r|dk r*|tk r*td��n|tkr*d}t|�}d|_|j�rRtjtjd��|_ i|_ ||_||_t �|_tt �|_tt|�|_||_tt�|_||_tjt|d�|_t�|_d|_d|_||_ g|_!|j"�dS)Nz6keepalive_timeout cannot be set if force_close is Trueg.@Fr)rP)#r/� ValueErrorr,�_closedrVrWrXrYrZr[�_conns�_limit�_limit_per_host�set� _acquiredr�_acquired_per_hostr�float�_keepalive_timeout�_force_closer�_waitersrS� functools�partialr&�_factoryr�cookies�_cleanup_handle�_cleanup_closed_handle�_cleanup_closed_disabled�_cleanup_closed_transports�_cleanup_closed)r?r�r�r�r�r�rPr@r@rArB�s4 zBaseConnector.__init__)r^r>cCs�|jr dS|jsdSdd�|jj�D�}|j�tr>d|i}ni}|jd|��tf|�||dd�}|jdk rx|j|d<|jj |�dS)NcSsg|]}t|��qSr@)�repr)�.0�cr@r@rA� sz)BaseConnector.__del__..r_zUnclosed connector zUnclosed connector)rM�connectionsrarb) r�r��values�_closer*rErcr[rSrf)r?r^�connsrgrhr@r@rArGs zBaseConnector.__del__)r>cCstjdt�|S)NzH"with Connector():" is deprecated, use "async with Connector():" instead)rDrErF)r?r@r@rA� __enter__#szBaseConnector.__enter__)�excr>cGs|j�dS)N)r�)r?r�r@r@rA�__exit__+szBaseConnector.__exit__c�s|S)Nr@)r?r@r@rA� __aenter__.szBaseConnector.__aenter__)�exc_type� exc_value� exc_tracebackr>c�s|j�IdHdS)N)rs)r?r�r�r�r@r@rA� __aexit__1szBaseConnector.__aexit__cCs|jS)z1Ultimately close connection on releasing if True.)r�)r?r@r@rAr�9szBaseConnector.force_closecCs|jS)z�The total number for simultaneous connections. If limit is 0 the connector has no limit. The default limit size is 100. )r�)r?r@r@rAr�>szBaseConnector.limitcCs|jS)z�The limit for simultaneous connections to the same endpoint. Endpoints are the same if they are have equal (host, port, is_ssl) triple. )r�)r?r@r@rAr�GszBaseConnector.limit_per_hostcCs|jr|jj�d|_|jj�}|j}|jr�i}||}x�|jj�D]�\}}g}x�|D]~\}} |j�r�| |dkr�|j} |j �|j r�|jr�|jj | �q�|j || f�qV|j} |j �|j rV|jrV|jj | �qVW|rD|||<qDW||_|j�r tj|d||j�|_dS)zCleanup unused transports.Nr�_cleanup)r��cancelrS�timer�r��itemsrurkrs�is_sslr�r�rmr�weakref_handle)r?�now�timeoutr��deadlinerNr��alive�protoZuse_timerkr@r@rAr�Ps8 zBaseConnector._cleanupr8)rN�valr>cCs4|j}||krdS||}|j|�|s0|j|=dS)N)r��remove)r?rNr�Zacquired_per_hostr�r@r@rA�_drop_acquired_per_hostys z%BaseConnector._drop_acquired_per_hostcCsV|jr|jj�x|jD]}|dk r|j�qWg|_|jsRtj|d|j|j�|_dS)z~Double confirmation for transport close. Some broken ssl servers may leave socket open without proper close. Nr�) r�r�r��abortr�rr��_cleanup_closed_periodrS)r?rkr@r@rAr��s zBaseConnector._cleanup_closedcCs|j�tt��S)zClose all opened transports.)r�r:r.)r?r@r@rArs�szBaseConnector.closecCs�|jr dSd|_z�|jj�r dS|jr0|jj�|jr@|jj�x,|jj�D]}x|D]\}}|j�qVWqLWx|j D]}|j�qvWx|j D]}|dk r�|j�q�WWd|jj�|j j�|j j�d|_|j j�d|_XdS)NT)r�rSrdr�r�r�r�r�rsr�r�r��clearr�)r?�datar��t0rkr@r@rAr��s0 zBaseConnector._closecCs|jS)z;Is connector closed. A readonly property. )r�)r?r@r@rArv�szBaseConnector.closed)rNr>cCs�|jrV|jt|j�}|jr�|dkr�||jkr�|jj|�}|dk sFt�|jt|�}n<|jr�||jkr�|jj|�}|dk s~t�|jt|�}nd}|S)z� Return number of available connections. The limit, limit_per_host and the connection key are taken into account. If it returns less than 1 means that there are no connections available. rNr)r��lenr�r�r��get�AssertionError)r?rN� availableZacquiredr@r@rA�_available_connections�s z$BaseConnector._available_connectionsr'r9r7)�req�tracesr�r>c'�s�|j}|j|�}|dks$||jk�r|jj�}|j|j|�|r^x|D]}|j�IdHqHWzny|IdHWnZtk r�}z>||jkr�y|j|j|�Wnt k r�YnX|�WYdd}~XnXWd||jkr�|j|r�|j|=X|�rx|D]}|j �IdHq�W|j|�} | dk�r(tt t��} |jj| �|j|j| �|�rpx|D]}|j�IdH�qXWy0|j|||�IdH} |j�r�| j�td��Wn@tk �r�|j�s�|jj| �|j|| �|j��Yn"X|j�s|jj| �|j|| �|�r�x�|D]}|j�IdH�qWnd|�r�tt t��} |jj| �|j|j| �x|D]}|j�IdH�q\W|jj| �|j|| �|jj| �|j|j| �t||| |j�S)z'Get from pool or create new connection.rNzConnector is closed.)�connection_keyr�r�rS� create_futurermZsend_connection_queued_start� BaseExceptionr�r�Zsend_connection_queued_end�_getrr&r~r��addr�Zsend_connection_create_start�_create_connectionr�rsrr��_release_waiterZsend_connection_create_endZsend_connection_reuseconnrL)r?r�r�r�rNr��fut�trace�er��placeholderr@r@rA�connect�st zBaseConnector.connectcCs�y|j|}Wntk r"dSX|jj�}x�|r�|j�\}}|j�r�|||jkr�|j}|j�|j r�|j r�|jj|�q�|s�|j|=|Sq0|j}|j�|j r0|j r0|jj|�q0W|j|=dS)N) r��KeyErrorrSr��poprur�rkrsr�r�r�rm)r?rNr��t1r�r�rkr@r@rAr�=s, zBaseConnector._getcCsv|js dSt|jj��}tj|�xN|D]F}|j|�dkrcCsH|jr dSy|jj|�|j||�Wntk r:Yn X|j�dS)N)r�r�r�r�r�r�)r?rNr�r@r@rA�_release_acquiredvszBaseConnector._release_acquired)r`)rNrOr`r>cCs�|jr dS|j||�|jr d}|s*|jrT|j}|j�|jr�|jr�|jj |�nV|j j|�}|dkrvg}|j |<|j ||jj �f�|jdkr�tj|d|j|j�|_dS)NTr�)r�r�r�r`rkrsr�r�r�rmr�r�rSr�r�rr�r�)r?rNrOr`rkr�r@r@rAre�s" zBaseConnector._releasec�s t��dS)N)�NotImplementedError)r?r�r�r�r@r@rAr��sz BaseConnector._create_connection)NNN)0rHrIrJrr�r[r�r/r�objectr�r}�intrrxryrBrDrrGr�r�r�rr�r r�r{r�r�r�r�r&r�r�rrsr�rvr�rrLr�r�r�r�rer�r@r@r@rAr3�sV",* %" Q c@s�eZdZdeedd�dd�Zeed�dd�Ze e efee e efdd�d d �Ze e efdd�dd �Zdd�dd�Ze e efee e efd�dd�Ze e efed�dd�ZdS)�_DNSCacheTableN)�ttlr>cCsi|_i|_||_dS)N)� _addrs_rr�_timestamps�_ttl)r?r�r@r@rArB�sz_DNSCacheTable.__init__)�hostr>cCs ||jkS)N)r�)r?r�r@r@rA�__contains__�sz_DNSCacheTable.__contains__)rN�addrsr>cCs,t|�t|�f|j|<|jr(t�|j|<dS)N)rr�r�r�rr�)r?rNr�r@r@rAr��sz_DNSCacheTable.add)rNr>cCs&|jj|d�|jr"|jj|d�dS)N)r�r�r�r�)r?rNr@r@rAr��sz_DNSCacheTable.remove)r>cCs|jj�|jj�dS)N)r�r�r�)r?r@r@rAr��s z_DNSCacheTable.clearcCs(|j|\}}tt||��}t|�|S)N)r�r�r�next)r?rNrP�lengthr�r@r@rA� next_addrs�sz_DNSCacheTable.next_addrscCs$|jdkrdS|j||jt�kS)NF)r�r�r)r?rNr@r@rA�expired�s z_DNSCacheTable.expired)N)rHrIrJrr�rBr�r}r�rrzr�rrrr�r�r�r�r�r@r@r@rAr��s&$r�cs`eZdZdZdddddddddedddddd�eeeeeeeee e deee feee efeee deefeeeeeejd��fd d �Zedd��fdd �Zeed�dd��Zeed�dd��Zdr4a/TCP connector. verify_ssl - Set to True to check ssl certifications. fingerprint - Pass the binary sha256 digest of the expected certificate in DER format to verify that the certificate the server presents matches. See also https://en.wikipedia.org/wiki/Transport_Layer_Security#Certificate_pinning resolver - Enable DNS lookups and use this resolver use_dns_cache - Use memory cache for DNS lookups. ttl_dns_cache - Max seconds having cached a DNS entry, None forever. family - socket address family local_addr - local tuple of (host, port) to bind socket to keepalive_timeout - (optional) Keep-alive timeout. force_close - Set to True to force close and do reconnect after each request (and between redirects). limit - The total number of simultaneous connections. limit_per_host - Number of simultaneous connections to one host. enable_cleanup_closed - Enables clean-up closed ssl transports. Disabled by default. loop - Optional event loop. TN� rFr�)� verify_ssl�fingerprint� use_dns_cache� ttl_dns_cache�family�ssl_context�ssl� local_addr�resolverr�r�r�r�r�rPcsjt�j| ||| ||d�t||||�|_| dkrcs&x|jj�D]}|j�qWt�j�S)zClose all ongoing DNS calls.)r�r�r�r�rs)r?Zev)rr@rArsszTCPConnector.closecCs|jS)zSocket family like AF_INET.)r�)r?r@r@rAr�szTCPConnector.familycCs|jS)z%True if local DNS caching is enabled.)r�)r?r@r@rAr�szTCPConnector.use_dns_cache)r��portr>cCsJ|dk r"|dk r"|jj||f�n$|dk s2|dk rc�s:t|�r||||jddd�gS|js�|rFx|D]}|j|�IdHq.W|jj|||jd�IdH}|r�x|D]}|j|�IdHqjW|S||f}||jkr�|jj|�r�|jj |�}|r�x|D]}|j |�IdHq�W|S||jk�r$|j|}|�rx|D]}|j |�IdHq�W|j�IdH�n t |j�|j|<|�rZx|D]}|j|�IdH�q@Wz�y�|�r�x|D]}|j|�IdH�qjW|jj|||jd�IdH} |�r�x|D]}|j|�IdH�q�W|jj|| �|j|j�Wn8tk �r} z|j|j| d��WYdd} ~ XnXWd|jj|�X|jj |�S)Nr)�hostnamer�rr�r��flags)r�)r�)r-r�r�Zsend_dns_resolvehost_startr��resolveZsend_dns_resolvehost_endr�r�r�Zsend_dns_cache_hitr��waitr1rSZsend_dns_cache_missr�r�r�r�)r?r�rr�r��resrN�result�eventr�r�r@r@rA� _resolve_host/s` zTCPConnector._resolve_hostr'r7)r�r�r�r>c�s<|jr |j|||�IdH\}}n|j|||�IdH\}}|S)zcCreate connection. Has same keyword arguments as BaseEventLoop.create_connection. N)�proxy�_create_proxy_connection�_create_direct_connection)r?r�r�r��_r�r@r@rAr�{szTCPConnector._create_connection)�verifiedr>cCs�|rtj�Stjtj�}|jtjO_|jtjO_d|_tj|_ y|jtj O_Wn2tk r�}ztj dj|��WYdd}~XnX|j�|SdS)NFz�{!s}: The Python interpreter is compiled against OpenSSL < 1.0.0. Ref: https://docs.python.org/3/library/ssl.html#ssl.OP_NO_COMPRESSION)r��create_default_context� SSLContext�PROTOCOL_TLS_CLIENT�options�OP_NO_SSLv2�OP_NO_SSLv3�check_hostname� CERT_NONE�verify_mode�OP_NO_COMPRESSION�AttributeErrorrDrE�format�set_default_verify_paths)r� sslcontextZattr_errr@r@rA�_make_ssl_context�szTCPConnector._make_ssl_context)r�r>cCsz|j�rrtdkrtd��|j}t|tj�r.|S|dk r@|jd�S|j}t|tj�rV|S|dk rh|jd�S|jd�SdSdS)a*Logic to get the correct SSL context 0. if req.ssl is false, return None 1. if ssl_context is specified in req, use it 2. if _ssl_context is specified in self, use it 3. otherwise: 1. if verify_ssl is not specified in req, use self.ssl_context (will generate a default context according to self.verify_ssl) 2. if verify_ssl is True in req, generate a default SSL context 3. if verify_ssl is False in req, generate a SSL context that won't verify NzSSL is not supported.FT)r�r��RuntimeError� isinstancerrr�)r?r�rr@r@rA�_get_ssl_context�s zTCPConnector._get_ssl_contextr(cCs,|j}t|t�r|S|j}t|t�r(|SdS)N)r�r r(r�)r?r��retr@r@rA�_get_fingerprint�s zTCPConnector._get_fingerprint)�client_error)�argsr�r�r$rgr>c�s�y8t|j�4IdH�|jj||�IdHSQIdHRXWn�tk rh}zt|j|�|�WYdd}~Xnvtk r�}zt|j|�|�WYdd}~XnHt k r�}z,|j dkr�t|tj �r��||j|�|�WYdd}~XnXdS)N)r+�sock_connectrS�create_connectionr$rr�r%r�OSError�errnor rx�TimeoutError)r?r�r�r$r%rgr�r@r@rA�_wrap_create_connection�s$z$TCPConnector._wrap_create_connectioncCs8|j�sdS|j}|dk st�|jdkr,dS|j�dS)aWRaise a :py:exc:`RuntimeError` on missing ``start_tls()``. One case is that :py:meth:`asyncio.loop.start_tls` is not yet implemented under Python 3.6. It is necessary for TLS-in-TLS so that it is possible to send HTTPS queries through HTTPS proxies. This doesn't affect regular HTTP requests, though. N�https)r�rr��scheme�_check_loop_for_start_tls)r?r�� proxy_urlr@r@rA�_fail_on_no_start_tls�s z"TCPConnector._fail_on_no_start_tlscCs>y|jjWn,tk r8}ztd�|�WYdd}~XnXdS)Na�An HTTPS request is being sent through an HTTPS proxy. This needs support for TLS in TLS but it is not implemented in your runtime for the stdlib asyncio. Please upgrade to Python 3.7 or higher. For more details, please see: * https://bugs.python.org/issue37179 * https://github.com/python/cpython/pull/28073 * https://docs.aiohttp.org/en/stable/client_advanced.html#proxy-support * https://github.com/aio-libs/aiohttp/discussions/6044 )rS� start_tlsrr)r?Zattr_excr@r@rAr.�s z&TCPConnector._check_loop_for_start_tlscCs*y|j�Wntk r dSXdSdS)NFT)r.r)r?r@r@rA�_loop_supports_start_tlss z%TCPConnector._loop_supports_start_tls)�underlying_transportr�r>cCs<|jjjdkrdSt|dd�}|r&dStjdt|dd�dS)z6Issue a warning if the requested URL has HTTPS scheme.r,NZ_start_tls_compatibleFaAn HTTPS request is being sent through an HTTPS proxy. This support for TLS in TLS is known to be disabled in the stdlib asyncio. This is why you'll probably see an error in the log below. It is possible to enable it via monkeypatching under Python 3.7 or higher. For more details, see: * https://bugs.python.org/issue37179 * https://github.com/python/cpython/pull/28073 You can temporarily patch this as follows: * https://docs.aiohttp.org/en/stable/client_advanced.html#proxy-support * https://github.com/aio-libs/aiohttp/discussions/6044 �)r_rj)�request_info�urlr-�getattrrDrE�RuntimeWarning)r?r3r�Zasyncio_supports_tls_in_tlsr@r@rA�_warn_about_tls_in_tls sz#TCPConnector._warn_about_tls_in_tls)r3r�r�r$r>c�s�|j�}ttj|j|��}ynt|j�4IdH�Jy$|jj||||j |j d�IdH}Wntk rr|j��YnXWdQIdHRXW�nt k r�}zt|j|�|�WYdd}~X�ntk r�}zt|j|�|�WYdd}~Xn�tk �r4}z0|jdk�rt|tj��r�||j|�|�WYdd}~Xn�tk �r�} z@td|j �d|jd�d|j�d|j�pnd�d | �d ��| �WYdd} ~ Xn*X|dk�r�d} ||jt| ��|j|�||fS)z$Wrap the raw TCP transport with TLS.N)�server_hostnameZssl_handshake_timeoutz2Cannot initialize a TLS-in-TLS connection to host �:�dz4 through an underlying connection to an HTTPS proxy z ssl:�defaultz [�]z:Failed to start TLS (possibly caused by closing transport))r�rr�rr!r+r&rSr1r��totalr�rsr$rr�r%rr(r)r rxr*� TypeErrorrrr�connection_made)r?r3r�r�r$Z tls_protorZ tls_transportr�Ztype_err�msgr@r@rA�_start_tls_connection/s@ 4 z"TCPConnector._start_tls_connection)r�r�r�r$r>c-�s|j|�}|j|�}|jj}|dk s(t�|j}|dk s:t�tj|j|||d�|j d�} ytj | �IdH} Wnxtjk r�ddd�dd�}| j|��YnHt k r�}z,|jdkr�t|tj�rĂt|j|�|�WYdd}~XnXd} �x| D]�}|d}|d}yN|j|j|||||d |d |d|�r6|dnd|j||d �IdH\}}Wn*tk �r|}z|} w�WYdd}~XnX|j��r�|�r�y|j|�WnFtk �r�}z(|j�|j�s�|jj|�|} w�WYdd}~XnX||fSW| dk �s�t�| �dS)N)r�)rPz$asyncio.Future[List[Dict[str, Any]]])r�r>c Ss$tttj��|j�WdQRXdS)N)rrorx�CancelledErrorr)r�r@r@rA�drop_exception�sz>TCPConnector._create_direct_connection..drop_exceptionr�rr�r�rr) r�r�r�r�rr:r�r�r$)r!r#r6Zraw_hostr�rrx� ensure_futurer rS�shieldrD�add_done_callbackr(r)r r*rr�r+r�r�r��checkr"rsr�r�rm)r?r�r�r�r$rr�r�rZ host_resolved�hostsrEr��last_excZhinfo�transpr�r@r@rAr msf z&TCPConnector._create_direct_connectionc$�s�|j|�|j�}i}|jdk r&|j}|jtj|tj<|j}|dk sJt�ttj |||j |j|jd�}|j |g|td�IdH\}} | j�|jjtjd�} | dk r�|j�s�| |jtj<n| |jtj<|j��r�|r�|j||�tj|_|j|_tj|jdddd�}t||| |j�}|j|�IdH} �zdy4|j}|dk �s|j!�X|�sp|j,|�}|j-|j.||||j/|d�IdHS|j0|||d�IdHSWd| j!�X|| fS) N)�headers�authrPr�)r$)r� proxy_authZproxy_headers_hash)Zread_until_eof��r)�statusrarM�socket)r=z)Transport does not expose socket instance)r�r��sockr:r�)r�r�)1r0r2� proxy_headersrMrZHOSTrr�r'ZMETH_GETrOrSr�r r!r�r�Z AUTHORIZATIONr�ZPROXY_AUTHORIZATIONr9ZMETH_CONNECT�methodr6�attrZevolver�rL�sendrTZset_response_params�startr�rsrwrQ�reasonr0r r5�history�get_extra_infor�dupr!r+r�r�rC)r?r�r�r�Zruntime_has_start_tlsrMr6Z proxy_reqrkr�rNrN�connZ proxy_resprO�respra�rawsockrr@r@rAr�s� z%TCPConnector._create_proxy_connection)NN)N)4rHrIrJrr/r}r�bytesr�rrr(rrzrr�r�rxryrBrrsr{r�r�rrrrr r&r��staticmethodr�� lru_cacherr!r#rrror|r+r0r.r2r9� BaseTransportrCr r� __classcell__r@r@)rrAr4�s^l K ! &>H c sxeZdZdZdedddfeeeee dfe e eej dd��fdd� Zeed �d d��Zded ded�dd�Z�ZS)r5a�Unix socket connector. path - Unix socket path. keepalive_timeout - (optional) Keep-alive timeout. force_close - Set to True to force close and do reconnect after each request (and between redirects). limit - The total number of simultaneous connections. limit_per_host - Number of simultaneous connections to one host. loop - Optional event loop. Fr�rN)�pathr�r�r�r�rPr>cs t�j|||||d�||_dS)N)r�r�r�r�rP)r�rB�_path)r?rer�r�r�r�rP)rr@rArBIs zUnixConnector.__init__)r>cCs|jS)zPath to unix socket.)rf)r?r@r@rAre[szUnixConnector.pathr'r9r7)r�r�r�r>c�s�yDt|j�4IdH�"|jj|j|j�IdH\}}WdQIdHRXWnLtk r�}z0|jdkrnt|t j �rn�t|j|j |�|�WYdd}~XnXtt|�S)N)r+r&rS�create_unix_connectionr�rfr(r)r rxr*r#rer�rr&)r?r�r�r�rr�r�r@r@rAr�`s*$z UnixConnector._create_connection)rHrIrJrr/rzr}rr�r�r�rrxryrBr{rerr&r�rdr@r@)rrAr5=s c sxeZdZdZdedddfeeeee dfe e eej dd��fdd� Zeed �d d��Zded ded�dd�Z�ZS)r6aNamed pipe connector. Only supported by the proactor event loop. See also: https://docs.python.org/3.7/library/asyncio-eventloop.html path - Windows named pipe path. keepalive_timeout - (optional) Keep-alive timeout. force_close - Set to True to force close and do reconnect after each request (and between redirects). limit - The total number of simultaneous connections. limit_per_host - Number of simultaneous connections to one host. loop - Optional event loop. Fr�rN)rer�r�r�r�rPr>cs6t�j|||||d�t|jtj�s,td��||_dS)N)r�r�r�r�rPz9Named Pipes only available in proactor loop under windows)r�rBr rSrxZProactorEventLooprrf)r?rer�r�r�r�rP)rr@rArBs zNamedPipeConnector.__init__)r>cCs|jS)zPath to the named pipe.)rf)r?r@r@rAre�szNamedPipeConnector.pathr'r9r7)r�r�r�r>c�s�yTt|j�4IdH�2|jj|j|j�IdH\}}tjd�IdHWdQIdHRXWnHtk r�}z,|j dkr~t |tj�r~�t|j |�|�WYdd}~XnXtt|�S)Nr)r+r&rSZcreate_pipe_connectionr�rfrx�sleepr(r)r r*rr�rr&)r?r�r�r�rr�r�r@r@rAr��s$ z%NamedPipeConnector._create_connection)rHrIrJrr/rzr}rr�r�r�rrxryrBr{rerr&r�rdr@r@)rrAr6ps )r3r4r5r6)Xrxr�r�rYrWrD�collectionsrr� contextlibr�http.cookiesr� itertoolsrrr�r�typesr �typingr rrr rrrrrrrrrrrV�rr�abcrZclient_exceptionsrrrrr r!r"r#r$r%Zclient_protor&Z client_reqrepr'r(r)r*r+r,r-r.r/�httpr0�locksr1r�r2r�r�ImportErrorr��__all__�clientr7r8Ztracingr9r:rLr~r3r�r4r5r6r@r@r@rA�s`@0 Zl'n3