U ;g@sddlZddlZddlZddlZddlZddlZddlZddlmZm Z ddl m Z ddl m Z ddlmZmZmZddlmZddlmZddlmZmZmZmZmZmZmZmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&ddl'Z'ddl(Z(d d l)m*Z*m+Z+d d l,m-Z-m.Z.d d l/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:d d l;mZ>m?Z?m@Z@d dl+mAZAmBZBmCZCmDZDmEZEmFZFd dlGmHZHzddlIZIeIjJZJWneKk rdZIeLZJYnXeMdhZNeMddhZOeMddhZPeOeNBZQeQePBZRdejSkodknpejSdkZTdZUer>d dlVmWZWd dl=mXZXd dlYmZZZGdddZ[Gdd d Z\Gd!d"d"Z]Gd#d$d$Z^Gd%d&d&Z_e`eJd'd(d)Zaead*Zbead+ZcGd,d-d-e^ZdGd.d/d/e^ZeGd0d1d1e^ZfdS)2N) OrderedDict defaultdict)suppress) HTTPStatus)chaincycleislice) monotonic) TracebackType) TYPE_CHECKINGAny AwaitableCallable DefaultDictDictIteratorListLiteralOptionalSequenceSetTupleTypeUnioncast)hdrshelpers)AbstractResolver ResolveResult) ClientConnectionErrorClientConnectorCertificateErrorClientConnectorDNSErrorClientConnectorErrorClientConnectorSSLErrorClientHttpProxyErrorClientProxyConnectionErrorServerFingerprintMismatchUnixClientConnectorError cert_errors ssl_errors)ResponseHandler) ClientRequest Fingerprint_merge_ssl_params) ceil_timeout is_ip_addressnoopsentinel set_exception set_result)DefaultResolverhttphttpswswss) r)r;r<r)r; ) BaseConnector TCPConnector UnixConnectorNamedPipeConnector) ClientTimeout) ConnectionKey)Tracec@s@eZdZdZeeddddZedddZddd d ZdS) _DeprecationWaiter _awaitable_awaitedN) awaitablereturncCs||_d|_dSNFrG)selfrJrNQ/opt/bot/vods_filmes/script/venv/lib/python3.8/site-packages/aiohttp/connector.py__init__dsz_DeprecationWaiter.__init__rKcCsd|_|jSNT)rIrH __await__rMrNrNrOrShsz_DeprecationWaiter.__await__cCs|jstdtdS)NzDConnector.close() is a coroutine, please use await connector.close())rIwarningswarnDeprecationWarningrTrNrNrO__del__ls z_DeprecationWaiter.__del__) __name__ __module__ __qualname__ __slots__r r rPrSrXrNrNrNrOrFasrFc@seZdZdZddeejddddZeddd Z e fe dd d d Z e d dddZeejdddZeeejdddZeeedddZegdfddddZddddZddddZddddZeeddd ZdS)! ConnectionNr?rD) connectorkeyprotocollooprKcCs<||_||_||_||_g|_|r8tt d|_ dS)Nr) _key _connector_loop _protocol _callbacks get_debug traceback extract_stacksys _getframe_source_traceback)rMr^r_r`rarNrNrOrPyszConnection.__init__rQcCsd|jdS)Nz Connection<>)rbrTrNrNrO__repr__szConnection.__repr__ _warningsrKcCsz|jdk rvd|i}|jd|tf||jr6dS|jj|j|jdd|dd}|jdk rj|j|d<|j |dS)NsourcezUnclosed connection T should_closezUnclosed connection)Zclient_connectionmessagesource_traceback) rerVResourceWarningrd is_closedrc_releaserbrlcall_exception_handler)rMrpkwargscontextrNrNrOrXs     zConnection.__del__TcCsdS)z9Force subclasses to not be falsy, to make checks simpler.TrNrTrNrNrO__bool__szConnection.__bool__cCstjdtdd|jS)Nz%connector.loop property is deprecated stacklevel)rUrVrWrdrTrNrNrOras zConnection.loopcCs|jdkrdS|jjSN)re transportrTrNrNrOrs zConnection.transportcCs|jSr)rerTrNrNrOr`szConnection.protocol)callbackrKcCs|dk r|j|dSr)rfappend)rMrrNrNrO add_callbackszConnection.add_callbackc Cs>|jddg}|_|D]}tt |W5QRXqdSr)rfr Exception)rM callbackscbrNrNrO_notify_releases zConnection._notify_releasecCs2||jdk r.|jj|j|jddd|_dS)NTrrrrercrxrbrTrNrNrOcloses zConnection.closecCs.||jdk r*|j|j|jd|_dSrrrTrNrNrOreleases zConnection.releasecCs|jdkp|j Sr)re is_connectedrTrNrNrOclosedszConnection.closed)rYrZr[rlr+asyncioAbstractEventLooprPstrrnrUr rXrr|propertyrar Transportrr`rrrrrboolrrNrNrNrOr]us, r]c@s"eZdZdZdZddddZdS)_TransportPlaceholderz.placeholder for BaseConnector.connect functionrNNrQcCsdS)z Close the placeholder transport.NrNrTrNrNrOrsz_TransportPlaceholder.close)rYrZr[__doc__r\rrNrNrNrOrsrc @seZdZdZdZdZdZeZe ddddddd e e de fe eee eeje dd d d Zefedd ddZddddZeddddZddddZdDeeeeeeeddddZee dddZeedddZeeddd Z ddd!d"Z!ddd#d$Z"e#ddd%d&Z$ddd'd(Z%ee dd)d*Z&d+ed,d-d.Z'e(e)d/d0e*d1d2d3Z+d+e)d/dd4d5d6Z,d+e)d/ee*d4d7d8Z-ddd9d:Z.d+e/dd;dd+e/e dd?d@dAZ1e(e)d/d0e/d1dBdCZ2dS)Er?a\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. timeout_ceil_threshold - Trigger ceiling of timeout values when it's above timeout_ceil_threshold. loop - Optional event loop. TNg@Fdrkeepalive_timeout force_closelimitlimit_per_hostenable_cleanup_closedratimeout_ceil_threshold)rrrrrrarrKcCs|r|dk r*|tk r*tdn |tkr*d}|p4t}||_d|_|r\tt d|_ i|_ ||_ ||_t|_tt|_tt||_||_tt|_||_tjt|d|_d|_d|_|rt st!j"dt j#t$ddd}| |_%g|_&|'dS) Nz6keepalive_timeout cannot be set if force_close is Trueg.@Frrazoenable_cleanup_closed ignored because https://github.com/python/cpython/pull/118960 is fixed in Python version r}r~)(r2 ValueErrorrget_running_loop_timeout_ceil_threshold_closedrgrhrirjrkrl_conns_limit_limit_per_hostset _acquiredr_acquired_per_hostrfloat_keepalive_timeout _force_closer_waitersrd functoolspartialr+_factory_cleanup_handle_cleanup_closed_handleNEEDS_CLEANUP_CLOSEDrUrV version_inforW_cleanup_closed_disabled_cleanup_closed_transports_cleanup_closed)rMrrrrrrarrNrNrOrPsH    zBaseConnector.__init__rocCs~|jr dS|jsdSdd|jD}|d|i}|jd|tf|||dd}|jdk rn|j|d<|j|dS)NcSsg|] }t|qSrN)repr).0crNrNrO 7sz)BaseConnector.__del__..rqzUnclosed connector zUnclosed connector)r^ connectionsrtru) rrvalues_closerVrvrlrdry)rMrpconnsrzr{rNrNrOrX1s  zBaseConnector.__del__rQcCstdt|S)NzH"with Connector():" is deprecated, use "async with Connector():" instead)rUrVrWrTrNrNrO __enter__Fs zBaseConnector.__enter__)excrKcGs |dSr)r)rMrrNrNrO__exit__NszBaseConnector.__exit__cs|SrrNrTrNrNrO __aenter__QszBaseConnector.__aenter__)exc_type exc_value exc_tracebackrKcs|IdHdSr)r)rMrrrrNrNrO __aexit__TszBaseConnector.__aexit__cCs|jS)z1Ultimately close connection on releasing if True.)rrTrNrNrOr\szBaseConnector.force_closecCs|jS)zThe total number for simultaneous connections. If limit is 0 the connector has no limit. The default limit size is 100. )rrTrNrNrOraszBaseConnector.limitcCs|jS)zThe limit for simultaneous connections to the same endpoint. Endpoints are the same if they are have equal (host, port, is_ssl) triple. )rrTrNrNrOrjszBaseConnector.limit_per_hostc Cs|jr|jd|_t}|j}|jri}||}|jD]p\}}g}|D]R\}} |rz| |dkrz||| fqN|j} | |j sN|j rN|j | qN|r>|||<q>||_|jrt j|d||j|jd|_dS)zCleanup unused transports.Nr_cleanupr)rcancelr rritemsrrrrris_sslrrweakref_handlerdr) rMnowtimeoutrdeadliner_raliveprotoZuse_timerrNrNrOrss:    zBaseConnector._cleanupcCsX|jr|j|jD]}|dk r|qg|_|jsTtj|d|j|j|j d|_dS)z~Double confirmation for transport close. Some broken ssl servers may leave socket open without proper close. Nrr) rrrabortrrr_cleanup_closed_periodrdr)rMrrNrNrOrs   zBaseConnector._cleanup_closedcCs|ttS)zClose all opened transports.)rrFr1rTrNrNrOrszBaseConnector.closec Cs|jr dSd|_z|j r$W~dS|jr4|j|j rD|j |jD]}|D]\}}| qVqN|jD] }| qp|jD]}|dk r| qW5|j|j|jD]}|D] }|qq|jd|_|jd|_ XdSrR)rrclearrrrrrrrrdrwrr)rM keyed_waitersZ keyed_waiterdatart0rrNrNrOrs6             zBaseConnector._closecCs|jS)z;Is connector closed. A readonly property. )rrTrNrNrOrszBaseConnector.closedrDr_rKcCs\d}|jr&|jt|j}dkr&|S|j}rX|j|}rL|t|8}||krX|S|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. rr)rlenrrrget)rMr_Z total_remainZ host_remainZacquiredrNrNrO_available_connectionss   z$BaseConnector._available_connectionsrErCreqtracesrrKc s|j}|||IdH}dk r$|St|j|j4IdH||dkr|||IdH|||IdH}dk r|W5QIdHRSttt }|j ||j | |zR|r|D]}| IdHq||||IdH}|r|D]}|IdHqWn$tk r,|||YnX|jrF|tdW5QIdHRX|j |} |j || ||j || |t||||jS)z'Get from pool or create new connection.NrzConnector is closed.)connection_key_getr/connectceil_thresholdr_wait_for_available_connectionrr+rraddrZsend_connection_create_start_create_connectionZsend_connection_create_end BaseException_release_acquiredrrr remover]rd) rMrrrr_conn placeholdertracerZacquired_per_hostrNrNrOrs>        zBaseConnector.connect)r_rrKc sd}|j}|j|}d||<|r2|j|ddzF|rP|D]}|IdHq<|IdH|rv|D]}|IdHqbW5||d|j|ds|j|=X||dkrq|d7}qdS)z&Wait for an available connection slot.rNFlastTr) rd create_futurer move_to_endpoprZsend_connection_queued_startZsend_connection_queued_endr)rMr_rZattemptsfutrrrNrNrOr2s(      z,BaseConnector._wait_for_available_connectionc sz|j|}Wntk r$YdSXt}|r|\}}|r|||jkr|s^|j|=|j||j|||r|D]:}z| IdHWqt k r| ||YqXqt ||||j S|j}||js,|jr,|j|q,|j|=dS)znGet next reusable connection for the key or None. The connection will be marked as acquired. N)rKeyErrorr rrrrrrZsend_connection_reuseconnrrr]rdrrrrrr) rMr_rrt1rrrrrNrNrOr\s4     zBaseConnector._getcCst|js dSt|j}t||D]L}||dkr6q"|j|}|r"|jdd\}}|s@|ddSq@q"dS)z Iterates over all waiters until one to be released is found. The one to be released is not finished and belongs to a host that has available connections. NrFr)rlistrandomshufflerpopitemdoner4)rMZqueuesr_waiterswaiter_rNrNrO_release_waiters    zBaseConnector._release_waiter)r_rrKcCsH|jr dS|j||j|}r<|||s<|j|=|dS)zRelease acquired connection.N)rrdiscardrrr)rMr_rrrNrNrOrs  zBaseConnector._release_acquiredrr)r_r`rsrKcCs|jr dS||||jr d}|s*|jrT|j}||jrP|jsP|j |dS|j |}|dkrvg}|j |<| |t f|j dkrtj|d|j|j|jd|_ dS)NTrr)rrrrsrrrrrrrrr rrrrrdr)rMr_r`rsrrrNrNrOrxs.      zBaseConnector._releasecs tdSr)NotImplementedError)rMrrrrNrNrOrsz BaseConnector._create_connection)NNN)3rYrZr[rrrlrHIGH_LEVEL_SCHEMA_SETallowed_protocol_schema_setr2robjectrrintrrrrPrUr rXrrrrrr rrrrrrrr rrrrr,rr]rrrrr+rrxrrNrNrNrOr?s  D  '( 4 + + 'r?c@seZdZdeeddddZeedddZe e e fe e ddd d Ze e e fdd d d ZddddZe e e fe e d ddZe e e fed ddZdS)_DNSCacheTableN)ttlrKcCsi|_i|_||_dSr) _addrs_rr _timestamps_ttl)rMrrNrNrOrPsz_DNSCacheTable.__init__)hostrKcCs ||jkSr)r)rMr rNrNrO __contains__sz_DNSCacheTable.__contains__)r_addrsrKcCs0t|t|f|j|<|jdk r,t|j|<dSr)rrrrr r)rMr_r rNrNrOrs z_DNSCacheTable.addrcCs*|j|d|jdk r&|j|ddSr)rrrrrMr_rNrNrOrs z_DNSCacheTable.removerQcCs|j|jdSr)rrrrTrNrNrOrs z_DNSCacheTable.clearcCs(|j|\}}tt||}t||Sr)rrrnext)rMr_ralengthr rNrNrO next_addrssz_DNSCacheTable.next_addrscCs$|jdkrdS|j||jtkSrL)rrr r rNrNrOexpireds z_DNSCacheTable.expired)N)rYrZr[rrrPrrr rrrrrrrrrrrNrNrNrOrsr)verifiedrKcCsntdkr dS|rtSttj}|jtjO_|jtjO_d|_tj|_ |jtj O_| |S)zCreate SSL context. This method is not async-friendly and should be called from a thread because it will load certificates from disk and do other blocking I/O. NF) sslcreate_default_context SSLContextPROTOCOL_TLS_CLIENToptions OP_NO_SSLv2 OP_NO_SSLv3check_hostname CERT_NONE verify_modeOP_NO_COMPRESSIONset_default_verify_paths)r sslcontextrNrNrO_make_ssl_contexts rTFcseZdZdZeedhBZddddejj dddde dddddd d dd e e e e e eeje eee eefe eeefe eedeefe eee e ejee ee ed fd d Zeddfdd ZeedddZee dddZdFe ee eddddZdGeee e de!e"dddZ#eeefeee$de e de!e"dddZ%e&e!dd e'd!d"d#Z(e&e ed$d%d&Z)e&e d'd$d(d)Z*e+d*e,e!e-j.e&d e/e0e,eej1e'fd+d,d-Z2e+d*e,e&d e/e0e,eej1e'fd.d/d0Z3d1dd$d2d3Z4ddd4d5Z5e dd6d7Z6ej1e&dd8d9d:Z7e+fej1e&d e/e0eej8e'fd;dd?d@Z:e+d*e&e!dd e/e0eej1e'fdAdBdCZ;e&e!dd eej8e'fd!dDdEZ<Z=S)Hr@u-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/HTTP_Public_Key_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. happy_eyeballs_delay - This is the “Connection Attempt Delay” as defined in RFC 8305. To disable the happy eyeballs algorithm, set to None. interleave - “First Address Family Count” as defined in RFC 8305 loop - Optional event loop. ZtcpTN Frrrg?) verify_ssl fingerprint use_dns_cache ttl_dns_cachefamily ssl_contextr local_addrresolverrrrrrrarhappy_eyeballs_delay interleavec stj| | | | |||dt|||||_| dkr>t|jd} | |_||_t|d|_ i|_ ||_ t ||_||_||_t|_dS)Nrr)r)superrPr._sslr5rd _resolver_use_dns_cacher _cached_hosts_throttle_dns_futures_familyaiohappyeyeballsZaddr_to_addr_infos_local_addr_infos_happy_eyeballs_delay _interleaver_resolve_host_tasks)rMr!r"r#r$r%r&rr'r(rrrrrrarr)r* __class__rNrOrP=s,    zTCPConnector.__init__rQcs<t|jD] }|q|jD] }|q$tS)zClose all ongoing DNS calls.)r from_iterabler0rrr6r+r)rMrtr7rNrOrms    zTCPConnector.closecCs|jS)zSocket family like AF_INET.)r1rTrNrNrOr%wszTCPConnector.familycCs|jS)z%True if local DNS caching is enabled.)r.rTrNrNrOr#|szTCPConnector.use_dns_cache)r portrKcCsJ|dk r"|dk r"|j||fn$|dk s2|dk r.drop_exception)r0r1r.send_dns_resolvehost_startr-resolvesend_dns_resolvehost_endr/rrZsend_dns_cache_hitr0rdrrrr_resolve_host_with_throttlerrrjrTaskZ create_taskrr6Zadd_done_callbackshieldr@)rMr r;rrresr_rAfuturesfuturecororaZresolved_host_taskrBrNrNrO _resolve_hostsf             zTCPConnector._resolve_hostzasyncio.Future[None])r_r r;rJrrKc s|r|D]}||IdHqzz||r@|D]}||IdHq*|jj|||jdIdH}|rx|D]}||IdHqb|j |||D]}t |dqWn8t k r} z|D]}t || qW5d} ~ XYnXW5|j|X|j |S)zResolve host and set result for all waiters. This method must be run in a task and shielded from cancellation to avoid cancelling the underlying lookup. Nr?)Zsend_dns_cache_missr0rrCr-rDr1rEr/rr4rr3r) rMr_r r;rJrrr rerNrNrOrFs(  z(TCPConnector._resolve_host_with_throttlerCrcs<|jr ||||IdH\}}n||||IdH\}}|S)zcCreate connection. Has same keyword arguments as BaseEventLoop.create_connection. N)proxy_create_proxy_connection_create_direct_connection)rMrrrrrrNrNrOrszTCPConnector._create_connection)rrKcCsd|s dStdkrtd|j}t|tjr2|S|dk r>tS|j}t|tjrT|S|dk r`tStS)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.T)rr RuntimeError isinstancer_SSL_CONTEXT_UNVERIFIEDr,_SSL_CONTEXT_VERIFIED)rMrrrNrNrO_get_ssl_contexts  zTCPConnector._get_ssl_contextr-cCs,|j}t|tr|S|j}t|tr(|SdSr)rrSr-r,)rMrretrNrNrO_get_fingerprint?s  zTCPConnector._get_fingerprint client_error)args addr_infosrrrZrzrKc s,z|t|j|jd4IdHTtj||j|j|j|jdIdH}|jj ||d|iIdHW5QIdHRWSQIdHRXWnt k r}zt |j ||W5d}~XYn|t k r}zt|j ||W5d}~XYnNtk r&}z.|jdkrt|tjr||j ||W5d}~XYnXdS)Nr)r\Zlocal_addr_infosr)r*rasock)r/ sock_connectrr2Zstart_connectionr3r4r5rdcreate_connectionr)r!rr*r$OSErrorerrnorSr TimeoutError) rMr\rrrZr[rzr^rrNrNrO_wrap_create_connectionHs*  @z$TCPConnector._wrap_create_connection)r[rrrZrzrKc szRt|j|jd4IdH*|jj||IdHW5QIdHRWSQIdHRXWntk r}zt|j||W5d}~XYnvtk r}zt |j||W5d}~XYnHt k r}z*|j dkrt |t jr؂||j||W5d}~XYnXdSNr])r/r_rrdr`r)r!rr*r$rarbrSrrc)rMrrrZr[rzrrNrNrO_wrap_existing_connectionfs8z&TCPConnector._wrap_existing_connectionr,cCs8|s dS|j}|dk st|jdkr,dS|dS)zRaise a :py:exc:`RuntimeError` on missing ``start_tls()``. 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. Nr8)rrOAssertionErrorscheme_check_loop_for_start_tls)rMr proxy_urlrNrNrO_fail_on_no_start_tls|s  z"TCPConnector._fail_on_no_start_tlsc Cs>z |jjWn,tk r8}ztd|W5d}~XYnXdS)NaAn 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.11 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 )rd start_tlsAttributeErrorrR)rMZattr_excrNrNrOris  z&TCPConnector._check_loop_for_start_tlscCs,z |Wntk r"YdSXdSdS)NFT)rirRrTrNrNrO_loop_supports_start_tlss  z%TCPConnector._loop_supports_start_tls)underlying_transportrrKcCs<|jjjdkrdSt|dd}|r&dStjdt|dddS)z6Issue a warning if the requested URL has HTTPS scheme.r8NZ_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 (Python <3.11). This is why you'll probably see an error in the log below. It is possible to enable it via monkeypatching. 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;)rqr) request_infourlrhgetattrrUrVRuntimeWarning)rMrorZasyncio_supports_tls_in_tlsrNrNrO_warn_about_tls_in_tlss z#TCPConnector._warn_about_tls_in_tls)rorrrZrKc s|}||}tr"|dk s"tzzt|j|jd4IdHPz*|jj||||j pV|j |j dIdH}Wnt k r| YnXW5QIdHRXWntk r}zt|j||W5d}~XYntk r}zt|j||W5d}~XYntk rH}z.|jdkr*t|tjr*||j||W5d}~XYntk r} z>td|j d|jdd|jd|jpd d | d | W5d} ~ XYn*X|dkrd } ||jt| ||||fS) z$Wrap the raw TCP transport with TLS.Nr])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))rrVr rgr/r_rrdrlrur totalrrr)r!rr*r$rarbrSrrc TypeErrorr r;rOrZconnection_made) rMrorrrZZ tls_protorZ tls_transportrZtype_errmsgrNrNrO_start_tls_connectionsR    2 z"TCPConnector._start_tls_connection)hostsrKcCs|g}|D]n}|d}d|k}|r&tjntj}|jr>|j|kr>q|rR||dddfn ||df}||tjtjd|fq|S)zConverts the list of hosts to a list of addr_infos. The list of hosts is the result of a DNS lookup. The list of addr_infos is the result of a call to `socket.getaddrinfo()`. r rvr;rr6)socketAF_INET6AF_INETr1r SOCK_STREAM IPPROTO_TCP)rMr~r\Zhinfor is_ipv6r%addrrNrNrO_convert_hosts_to_addr_infos s z)TCPConnector._convert_hosts_to_addr_infos)rrrrZrKc s||}||}|jj}|dk s(t|dr@|dd}|j}|dk sRtz|j|||dIdH} WnHt k r} z*| j dkrt | t j rt|j| | W5d} ~ XYnXd} || } | r|r|jp|dnd} z(|j|j||| | ||dIdH\}}WnDtt j fk rN} z| } t| |jWYqW5d} ~ XYnX|r|rz||Wnjtk r} zJ||js|j|| } |d}| }t!| |WYqW5d} ~ XYnX||fS| dk st| dS)Nz...)r)rrr\rurrZr)"rVrXrqZraw_hostrgendswithrstripr;rMrarbrSrrcr"rrrurdrr#r2Zpop_addr_infos_interleaver5rcheckr'rrrrget_extra_info getpeernameZremove_addr_infos)rMrrrrZrr"r r;r~rlast_excr\ruZtransprr^Zbad_peerrNrNrOrQs`           z&TCPConnector._create_direct_connectioncs|||}i}|jdk r&|j}|jtj|tj<|j}|dk sJtttj |||j |j |j d}|j |g|tdIdH\}} | |jtjd} | dk r|s| |jtj<n | |jtj<|r|r|||tj|_|j|_tj|jdddd} t|| | |j } || IdH} zhz8| j}|dk srYrZr[rr frozensetrr AddressFamily AF_UNSPECr2rrbytesrrrr-rrrrrrrrPr rrr%r#r<rrrrMrrFr,r+rrVrXr#r r2Z AddrInfoTyperrrrdrfrkrirnrtZ BaseTransportr}rrQrP __classcell__rNrNr7rOr@s  0    ]   * ! #   * ?  L r@c seZdZdZeedhBZdedddfee e e e dfe e eejddfdd Zeed d d Zeed dedddZZS)rAaUnix 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. unixFrrNpathrrrrrarKcs tj|||||d||_dS)Nrrrrra)r+rP_pathrMrrrrrrar7rNrOrPs zUnixConnector.__init__rQcCs|jS)zPath to unix socket.rrTrNrNrOrszUnixConnector.pathrErCrc szJt|j|jd4IdH"|j|j|jIdH\}}W5QIdHRXWnLtk r}z.|jdkrtt |t j rtt |j |j||W5d}~XYnX|Sre)r/r_rrdZcreate_unix_connectionrrrarbrSrrcr(rrrMrrrrrrrNrNrOrs"$z UnixConnector._create_connectionrYrZr[rrrrr2rrrrrrrrrrPrrr,rr+rrrNrNr7rOrAs.  rAc seZdZdZeedhBZdedddfee e e e dfe e eejddfdd Zeed d d Zeed dedddZZS)rBaNamed pipe connector. Only supported by the proactor event loop. See also: https://docs.python.org/3/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. ZnpipeFrrNrcs6tj|||||dt|jtjs,td||_dS)Nrz9Named Pipes only available in proactor loop under windows)r+rPrSrdrZProactorEventLooprRrrr7rNrOrP6s zNamedPipeConnector.__init__rQcCs|jS)zPath to the named pipe.rrTrNrNrOrNszNamedPipeConnector.pathrErCrc szZt|j|jd4IdH2|j|j|jIdH\}}tdIdHW5QIdHRXWnHt k r}z*|j dkrt |tj rt |j||W5d}~XYnXtt|S)Nr]r)r/r_rrdZcreate_pipe_connectionrrrsleeprarbrSrcr#rrr+rrNrNrOrSs$ z%NamedPipeConnector._create_connectionrrNrNr7rOrB%s. rB)grrrrrjrhrU collectionsrr contextlibrr7r itertoolsrrrtimer typesr typingr r r rrrrrrrrrrrrrr2rr6rrabcrrZclient_exceptionsr r!r"r#r$r%r&r'r(r)r*Z client_protor+Z client_reqrepr,r-r.r/r0r1r2r3r4r(r5rr ImportErrorrrZEMPTY_SCHEMA_SETZHTTP_SCHEMA_SETZ WS_SCHEMA_SETZHTTP_AND_EMPTY_SCHEMA_SETrrr__all__clientrCrDtracingrErFr]rr?rrrrUrTr@rArBrNrNrNrOsz    H4            X 'U7