o .jr'@sddlmZddlZddlZddlZddlmZmZddlmZm Z ddlm Z ddl m Z mZddlmZdd lmZmZmZmZmZmZmZdd lmZmZmZmZmZmZm Z dd l!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(dd l)m*Z*m+Z+m,Z,dd l-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4ddl5m6Z6m7Z7m8Z8ddl9m:Z:ddl;mZ>m?Z?m@Z@mAZAddlBmCZCmDZDddl=mEZEmFZFmGZGejHrddlImJZJe,ZKGdddeEZLdS)) annotationsN)datetimetimezone) SOCK_DGRAM SOCK_STREAM)timeout)ssl Certificate)HTTPHeaderDict)DEFAULT_BLOCKSIZEDEFAULT_KEEPALIVE_DELAYUDP_DEFAULT_BLOCKSIZE responsesHTTP1_ONLY_HEADERSDEFAULT_BACKGROUND_WATCH_WINDOWDEFAULT_KEEPALIVE_IDLE_WINDOW) HTTP1Protocol HTTP2Protocol HTTP3ProtocolHTTPOverQUICProtocolHTTPOverTCPProtocolHTTPProtocolFactory QuicTLSConfig)ConnectionTerminated DataReceivedEarlyHeadersReceivedEventHandshakeCompletedHeadersReceivedStreamResetReceived) AsyncSocketSSLAsyncSocket_has_complete_support_dgram) EarlyResponseIncompleteRead InvalidHeaderMustDowngradeError ProtocolErrorResponseNotReadySSLError) parse_alt_svcresolve_cert_reqs parse_url)enable_keepalive)AsyncSubTimeout)ConnectionInfo HttpVersionQuicPreemptiveCacheTypeResponsePromise)_HAS_HTTP3_SUPPORT_HAS_SYS_AUDIT)AsyncBaseBackendAsyncDirectStreamAccessAsyncLowLevelResponse)_TYPE_SOCKET_OPTIONScseZdZejejejgZdddefe j dde e e ddfddZedddZedddZedd d!Zedd"d#Zdd%d&Zdd(d)Z            dddF)r5_HAS_DGRAM_SUPPORTsetaddr2h3super__init___proxy_protocol _protocol_svn _stream_id_AsyncHfaceBackend__headers(_AsyncHfaceBackend__expected_body_length)_AsyncHfaceBackend__remaining_body_length%_AsyncHfaceBackend__authority_bit_set%_AsyncHfaceBackend__legacy_host_entry$_AsyncHfaceBackend__protocol_bit_set'_AsyncHfaceBackend__custom_tls_settings!_AsyncHfaceBackend__alt_authority_AsyncHfaceBackend__origin_port _max_tolerable_delay_for_upgrade) selfrErGrrJrLr?r@rArBrCrD __class__Q/home/thesage/.local/lib/python3.10/site-packages/urllib3/backend/_async/hface.pyrWGs>   zAsyncHfaceBackend.__init__returnboolcCs(|jdurdS|js|j SdSNF)rY is_available has_expiredrfririrj is_saturateds   zAsyncHfaceBackend.is_saturatedcCs|jdurdS|jSrm)rY expect_pongrpririrjrrs  zAsyncHfaceBackend.expect_pongcCs|jduo|jjSN)rY multiplexedrpririrjis_multiplexedsz AsyncHfaceBackend.is_multiplexedcCsL|jdur|jSz|j}Wn ty|jYSw|j|kr#|S|jS)z The remote may require us to a lower blocksize than defined. This property will avoid relying too much on defined blocksize. N)rYrLmax_frame_sizeNotImplementedError)rfremote_max_sizeririrjrvs   z AsyncHfaceBackend.max_frame_sizeAsyncSocket | Nonecs"|jdurVtj|jvrV|jdkrV|jr7|j|jf|jvr7|j|j|jp%df|_|jr6tj|_|jd|_ntj |jvrVtj |jvrV|j|jpIdf|_tj|_|jd|_|jtjkr|j t krdt |_ t|_|jr|jj|jkrd|_d|_|j t krt |_ t|_dS|j t krt |_ t|_dS)Nhttpsr7)rZr2rU _disabled_svnscheme_preemptive_quic_cacherErGrch11h2rLr rr socket_kind _response authorityrrpririrj _new_connsD           zAsyncHfaceBackend._new_connNonecs|jdus Jd|jdusJ|jdusJ|jdurdSt}t|jtu}tj|j v}tj |j v}d}|rN|sA|jtj krCdStj }|j dd|_n)|jtjkrVdS|sd|rdtj}|j dd|_|jsw|jtj krwtj }|j dd|_|jr|j dur|j jdur|j j|_|j jdur|j|j j7_t|jd|_nd|_|tjkr|jdur|j|j|j|jpdf<|j|jpdf|jvrdS||_|jpd|_|jd|_|IdHdSdS) Nzd}Ynw|sa|dura|dura|dura|sat tj }t |dr_| nd}|rt |ddpjd} |jtjkrsd}|dur|dur|durz|d}Wn ttfyg}Ynw|rdd d |D}| durt |d r|jdurd} t |d rz|Wnty|d Yn tyYnwt|jd|t|||t|tr|n|||| | | t| tr| ndt| tr| nd|jpd|jd |_|jj |_ dS)z^Meant to support TLS over QUIC meanwhile cpython does not ship with its native implementation.FTNx509_carload_default_certshostname_checks_common_name css|]}t|VqdSrs)r DER_cert_to_PEM_cert).0certririrj vs  z0AsyncHfaceBackend._custom_tls..check_hostnameset_fingerprintz chrome:stablecontextgr@) insecurecafilecapathcadatacertfilekeyfile keypasswordrcert_use_common_nameverify_hostnamer idle_timeoutech_config_list)!rZr2rUr,r CERT_NONEcert_store_statsAttributeErrorrw SSLContextPROTOCOL_TLS_CLIENThasattrrgetattr verify_mode get_ca_certsjoinrhttp_header_for_fingerprint ValueErrorrsetattrrr isinstancerFencoderl_keepalive_delay _ech_configrbr is_verified)rfrrrrrrrrrrrrrallow_insecure cert_statsssl_ctx_have_certsctx_root_certificatesririrj _custom_tls-s                 zAsyncHfaceBackend._custom_tlsrUrc Cs|jdusJ|jjdD]3}t|D],\}}||krq|d\}}|r,||jkr,qz |t|fWSty@YqwqdS)zFDetermine if remote yield support for an alternative service protocol.Nzalt-svc:)rmsggetlistr+splitrErMr)rfralt_svcprotocol alt_authorityserverrGririrj__altsvc_probes z AsyncHfaceBackend.__altsvc_probec sX|jdur d|_d|_n |jdusJd|jdusJd|jdurt|jt}|r|j}|dur[|dkrDtt |_t j |_n|dkrStt |_t j |_ntd|dt j |jvrltt |_t j |_nt j |jvr}tt |_t j |_nptdt j |jvrtt |_t j |_n[t j |jvrtt |_t j |_nJtd|jt j krtt |_n9|jt jkr|jdusJ|jdur|j\}}|j}n|j|j}}tjt|jjr|jjn|t|f||jd |_t|_|j|j_t|d r|jr|jd |j_|jd |j_|jt jurHd}t|jd rt|jj dr0|jj j!dk|j_"nt|jj drA|jj #|j_"nd|j_"|jj j$dd|j_%z |jj j$dd|j_&Wnt'yid|j_&Ynwd|j_(|jj )}t|jj drt|jj j*dr|jj j*+}t,|}t-durt.dd|Dnd} | r|jj&s|r|d /|j_&|d kr|d 0} t| t1r| |j_2n tt3drt34| |j_2|d /|j_5n |d kr|d |j_2|r/|d |j_)|d dkrt3j6j7|j_8n.|d dkrt3j6j9|j_8n |d dkrt3j6j:|j_8n|d dkr+t3j6j;|j_8nd|j_8|jj(durHt|jdrH|j<dd|j_(|jdusU|jt j kr|jdurmt j |jvrmtt |_t j |_ntt |_t j |_|j=r|j>rt?|jt|j>t|j=|j|j_|jj%rt|d r|jrt@jAtBjCd|jd |j_DtEF|_GdS|jHdur|jI|jHz |jJtKdd!IdHWnXttLtMtNtOfy&} zF|jdur!|jt jkr|jPdur|j|jQpd"f} | |jPvr|jP| =d|_t j |jRvst j |jRvr!tSd#|jd$|jd%| d} ~ wwtEF|_G|jHdur9|jI|jTd|_Ht|jtUr|jj$dd|j_%|jj$dd|j_&|j<dd|j_(|j)|j_)t3j6j;|j_8|j#|j_"|jjVdd|j_5|jjVdd|j_2|jj%rt|d r|jjDst@jAtBjCd|jd |j_DdSdSdSdS)&Nz:_post_conn() must be called when socket is closed or unsetzEprobable attempt to call _post_conn() prior to successful _new_conn()rzhttp/1.1zUnsupported ALPN 'z<' during handshake. Did you try to reach a non-HTTP server ?zNo compatible protocol are enabled to emit request. You currently are connected using TCP TLS and must have HTTP/1.1 or/and HTTP/2 enabled to pursue.zNo compatible protocol are enabled to emit request. You currently are connected using TCP Unencrypted and must have HTTP/1.1 or/and HTTP/2 enabled to pursue.)remote_address server_name tls_config_connect_timingsrr7sslobj ech_statusaccepted ech_acceptedFT) binary_form_sslobjget_verified_chaincs|]}t|tVqdSrs)rr )rcrtririrjrAz/AsyncHfaceBackend._post_conn..PEM_cert_to_DER_certzTLSv1.0zTLSv1.1zTLSv1.2zTLSv1.3 getpeernamer0tzr=) receive_firstr{z#The server yielded its support for z[ through the Alt-Svc header while unable to do so. To remediate that issue, either disable z" or reach out to the server admin.)W _tunnel_hostrZrYrrr"selected_alpn_protocolrnewrr2rrrr(r| RuntimeErrorrUrbrcrErGrrrMr1r http_versionrrresolution_latencyrrrtls_ech_acceptedr getpeercertcertificate_dercertificate_dictrdestination_addresscipherrrlenr allget_info public_bytesbytesissuer_certificate_derr rissuer_certificate_dict TLSVersionTLSv1 tls_versionTLSv1_1TLSv1_2TLSv1_3r_background_watch_delay_keepalive_idle_windowr.rnowrutcrtime monotonic _connected_atre settimeout"_AsyncHfaceBackend__exchange_untilr TimeoutError SocketTimeoutConnectionRefusedErrorConnectionResetErrorr~rdr@r'rr getissuercert) rfis_tcp_tls_connalpn_rGr cipher_tuplechaincert_in_chain_count parsed_certsissuer_public_bytesealt_keyririrj _post_conns                                                     !       zAsyncHfaceBackend._post_connhttpheaderstyping.Mapping[str, str] | Noner}cCsL|jrtdtj|jvr|jtj||_||_|r!||_dSi|_dS)Nz.Can't set up tunnel for established connection) rrr2rUr|rTr _tunnel_port_tunnel_headers)rfrErGr%r}ririrj set_tunnels   zAsyncHfaceBackend.set_tunnelc s|jdusJ|jdusJ|jdusJ|jdusJ|jtjkr'td|j|_ dd|jd|j dfg}|j D]\}}| | | dfqB|j|j |d|jtdtfdd IdH}d}|D]}t|tr|jD]\}}|d krt|}nqyqo|duod |kod kn} | s|IdH|r|tvrt|nd } td|d| d|_d|_d|_dS)Nz7Unable to establish a tunnel using other than HTTP/1.1.):methodCONNECT :authorityrascii iso-8859-1TF)revent_type_collectablerespect_end_stream_signal:status,UnknownzTunnel connection failed:  )rYrrr'rZr2rrwget_available_stream_idr[rr(itemsappendlowersubmit_headersrrrr%rMdecoderrOSError_protocol_factory) rf req_contextheadervalueeventsstatusevent raw_header raw_valuetunnel_acceptedmessageririrj_tunnels\       zAsyncHfaceBackend._tunnelF expect_framec s`|jdus |jdur dS|j}|j|sdndz2z |j|jIdH}Wnty:YW|j|dSttfyFd}YnwW|j|n|j|w|s_|j dSzt |t rq|D]}|j |qgn|j |Wn |j yYdSw |j}|snz |j|IdHWn tyYdSwqt|_|jS)aThis method should be called by a thread using TrafficPolice when it is idle. Multiplexed protocols can receive incoming data unsolicited. Like when using QUIC or when reaching a WebSocket. This method return True if there is any event ready to unpack for the connection. Some server implementation may be aggressive toward "idle" session this is especially true when using QUIC. For example, google/quiche expect regular ACKs, otherwise will deduct that network conn is dead. see: https://github.com/google/quiche/commit/c4bb0723f0a03e135bc9328b59a39382761f3de6 https://github.com/google/quiche/blob/92b45f743288ea2f43ae8cdc4a783ef252e41d93/quiche/quic/core/quic_connection.cc#L6322 NFgMbP?g?)rrY gettimeoutrrecvrLrConnectionAbortedErrorrconnection_lostrlistbytes_received exceptions bytes_to_sendsendallr<rr _last_used_athas_pending_event)rfrI bck_timeout peek_data gro_segmentdata_outririrjpeek_and_react1sP         z AsyncHfaceBackend.peek_and_reactT)rr/r0maximal_data_in_readdata_in_len_from stream_id event_type%type[Event] | tuple[type[Event], ...]rr/,type[Event] | tuple[type[Event], ...] | Noner0r[r\$typing.Callable[[Event], int] | Noner] list[Event]c s|jdur |jdus J|j|j|j}|jtjutd} } d(fdd } |dur<|dks<|dks.send_pendingrr=FTr]rJ eof_receivedexpected_length actual_length)partialexpectedgffffff?g333333?r] end_streamcsrrs)rrrr!ririrjr,rz5AsyncHfaceBackend.__exchange_until..z-Remote end closed connection without responseir?i*zQTLS over QUIC did not succeed (Error 298). Chain certificate verification failed.z%without sending complete message bodyz=peer closed connection without sending complete message body z()css,|]}tddd|DVqdS)rrcss|] }|r|VqdSrs)isdigit)rcririrjrMsz?AsyncHfaceBackend.__exchange_until...N)rMrstrip)rrririrjrLs  z, iz8The remote server is unable to serve this resource over zStream z# was reset by remote peer. Reason: .rkr)8rrYrLrZr2rUrrQrUrcr/rLrMrrrrtuple timer_firedrrjr(rNrOrrPr%rlrk_recv_size_emarArr error_coderr8ranyrGr&r*replacerurr IndexErrorr rrr@r'r]hexrrpreshelve)rfr^rr/r0r[r\r]rL_has_next_timer _proto_excrh data_in_lenrAreshelve_events reach_socketrcsubdata_inr!udp_gro_segmentincoming_buffer_sizerCstream_related_eventrreceivedrntarget_cap_reachedrirfrj__exchange_untiljs       (                                       z"AsyncHfaceBackend.__exchange_untilmethodurl skip_hostskip_accept_encodingc Cs$g|_d|_d|_d|_d|_d|_tjtj d|_ |j dur'|j |j }}n|j |j}}|drFt|}|j |krF|j |jpC|j}}d|dfg|_|ss|d}|jd||jksc|dure|n|d |fd |_|jd |jdfd |dfg|s|jd dSdS)zNInternally fhace translate this into what putrequest does. e.g. initial trame.NFrr$r*r-idnar,rTs:schemes:path)saccept-encodingsidentity)r\r]r^r`r_rarr rr_start_last_requestrr'rErG startswithr- default_portrr8extendr}) rfrrrrrErG parsed_urlrririrj putrequestsL        zAsyncHfaceBackend.putrequestr?valuesc Gs|}t|tr|dn|}|jtjk}|s|tvrdS|jdurB|dkrBz t |d|_WnEt yAt d|ddw|j durv|dkrvt|dtr\|dd|_ dSt|dt rj|d|_ dSt|dd|_ dS|D]_}t|tr|d}nt|t r|}nt|d}|d r|d krd |_d}|jD]\}} |d sn ||kr|| f}nq|dur|j||jd||fqx|j||fqxdS) Nr-scontent-lengthrz#Invalid content-length set. Given 'z' when only digits are allowed.shostrr.:s :protocolT)r9rrFrrZr2rrr]rMrr(r`rrrar\removeinsertr8) rfr?rencoded_headersupport_te_chunkedr@ encoded_valueitem_to_remove_k_vririrj putheadersl         zAsyncHfaceBackend.putheader)encode_chunkedexpect_body_afterward message_body bytes | NonerrResponsePromise | Nonec sF|jdur |IdH|jdur|IdH|jdur#|jdus%J|j|_| o1|j }|jdurid}|jD]\}}|dkrJ||f}n| dsQnq<|dur\|j ||j dd|jfd|_ |j spt dz |jj|j|j|dWn|jy}zt ||d}~wwz7g} |j} | sn| | q|jtjurt| dkr|j| IdHn| D] } |j| IdHqWn%ty}zt||j|j} | |j| j<| |j| j<| |_|d}~wwt|_ |s!|j!r |j"r t#j$t%j&d|j!|j"_'t||j|j} | |j| j<| |j| j<| SdS) Nr,rrT)zOurllib3.future do not support emitting HTTP requests without the `Host` header zKIt was only permitted in HTTP/1.0 and prior. This client support HTTP/1.1+.ror7r)(rconnectrYr#r6r[rar`r\rrrr_r(r:rQrRr8rZr2rUrrSBrokenPipeErrorr4 _promisesuid_promises_per_streamr]promiserrrTrrrr rrrequest_sent_latency) rfrrrshould_end_streamexisting_authority cursor_header cursor_valuer!rdbufrerpririrj endheaders+s                zAsyncHfaceBackend.endheaders_AsyncHfaceBackend__bufr_AsyncHfaceBackend__stream_id _AsyncHfaceBackend__close_streamc sXjdusJjdusJtjd}dfdd }j|t|dur|r.jnd}tj||}|4IdHjjIdH}WdIdHn 1IdHsXwY|j raqt |t rr|D]} j | qhnj ||IdHj|t|dus'jj |||d j} | sn j| IdHqt_dS) Nrcrkrc* j}|s dSj|IdHqrsrYrRrrSrYrprirjrh z2AsyncHfaceBackend.__write_st..send_pendingTrorx)rYrrshould_wait_remote_flow_controlrrcr/rLrLrzrrOrP submit_datarRrSrrrT) rfrrrrrhrcrrrXrYrirprj __write_stsH (    zAsyncHfaceBackend.__write_stcs|jdusJ|jdusJ|jj|d |j}|sn |j|IdHqz|j|=Wn ty8Ynw|jrE|IdHt |_ dS)zKill a stream properly.Nri) rYrsubmit_stream_resetrRrS_pending_responsesKeyErrorrorrrrT)rfrrYririrj __abort_sts$    zAsyncHfaceBackend.__abort_st_AsyncHfaceBackend__amt&_AsyncHfaceBackend__respect_end_signal#_AsyncHfaceBackend__dummy_operation/tuple[list[bytes], bool, HTTPHeaderDict | None]c s|r.z|j|=Wn tyYnw|jdur)|jr)|jr)|IdHgddfSd}|jtdttf|dd||dIdH}t |_ |r|dj rd}z|j|=Wn ty`Ynw|jdur|jrx|jrx|IdHn |jr| IdHd}|rd}t|dtrd}nt|dkrt|d trd }|durt}||jD]\} } | d d krq|| d | d q|||sgd|fSdd|D||fS)afAllows us to defer the body loading after constructing the response object. Returns the body as a list of per-frame chunks (not concatenated): the caller feeds them straight into its ``BytesQueueBuffer`` so contiguity is produced lazily and, for frame-aligned reads, zero-copy. Joining here would defeat that buffer. NTFcSs t|jSrs)rdata)xririrjs z-AsyncHfaceBackend.__read_st..)rr/r[r\r]r0r=r0r:r-r.cSsg|]}|jqSri)rrqririrj 4sz/AsyncHfaceBackend.__read_st..)rrrYis_idlerorrrrrrrTrprrrr r%rTr;pop) rfrrrreotrAtrailersidxrDrEririrj __read_stst            zAsyncHfaceBackend.__read_strearly_response_callbackrrGtyping.Callable[[AsyncLowLevelResponse], typing.Awaitable[None]] | Noner:c s|jdus|jdus|jstt}d}|js|j}n|r"|jnd}|jt t fdt t fd|dIdH }t |_|jD]#\}}|durV|ddkrV|dkrUt|}q?||d|dq?t|t ok|d k} |durz| rz|j|j}n|j |j}Wnty} z td |jd | d} ~ ww| s|j|j=|durtd |j} d } |jD] \}}|dkr|} nq|d ks| dkrd|krdkrnn t|j|j|j} nd} zt|}Wn tyd}Ynw| r |durt| d||j||d|j|j |jd }||_!||IdHt"j#|||dIdHSt| d||j||| s5| dur5|jnd|j|j |j| |j$d |_%|j%|_&||j%_!|j|j'=| rq|j(rc|)IdH|j%S|j*rn|+IdH|j%S|j%|j,|j<|j%S)NTF)rr/r0r]rrr1r-r.ezResponse received (stream: z) but no promise in-flightz@Got an HTTP response without a status code. This is a violation.rJr*r+r2r3r4)bodyrrGr]r)rrGr]dsa stream_abort)-rrYrr)r rur[r]rrrrrrrTr%rMrTr;rrrr(rprequest_headersr9_AsyncHfaceBackend__read_st_AsyncHfaceBackend__write_strr: _http_vsnrErG from_promiser< getresponse_AsyncHfaceBackend__abort_strresponserrorrrr)rfrrr%rBr] head_eventrDrEis_early_responser!r http_verbrreasonearly_responseririrjr9s      (       zAsyncHfaceBackend.getresponse)rrbytes | bytearrayrc sjdusjdusjdurtdjdur"jdur"j_tjd}dfdd }z,jjt|dur|rDj nd}t j||}|4IdHj j IdH}WdIdHn 1IdHsnwY|j rwq1t|tsj|n |D]}j|qjjjtfd rÈjrjrtjtjd jj_tjj} | j| j<| j| j<t | d |IdHjjt|dus=jrjt|8_jj!j||d t"rt#$d |d} j%} | sn"z j&| IdHWnt'y} z| } WYd} ~ nd} ~ wwq|s'| rZjr;jr;tjtjd jj_tjj} | j| j<| j| j<| rW| | _(| | WSWdSj)yq} zt*| | d} ~ ww)z4We might be receiving a chunk constructed downstreamNz,Trying to send data from a closed connectionrcrkrcrrsrrrprirjrhrz,AsyncHfaceBackend.send..send_pendingT)r] excl_eventr)rrozhttp.client.sendrx)+rr[rYrr^r]rrrrcr/rLrLrzrrOrPrUrrrrr rrrr4r\rrrr]r$rr6sysauditrRrSrrrQr() rfrrrrhrcrrrXrremote_pipe_shutdownrYr!rirprjsends    (       $    zAsyncHfaceBackend.sendc s|jdus |jdur dS|jrdSz|jWnty%YdS|jy1YdSw |j}|s;nz |j|IdHWn tt j fyRYnwq3t |_ dS)z8Send a ping frame if possible. Otherwise, fail silently.N)rrYropingrwrQrRrSr<r r*rrrT)rf ping_frameririrjr?s4    zAsyncHfaceBackend.pingc s"|jr`|jdurGz|jWn|jy$}zt||d}~ww |j}|s.nz |j|IdHWn ttj fyEYnwq&z|j |j IdHWn ty_Ynwd|_d|_ i|_ i|_i|_d|_d|_d|_d|_d|_d|_d|_t|_d|_d|_dS)NTg)rrY submit_closerQr(rRrSr<r SSLEOFErrorrwait_for_closer[rrrrbrr]r^r_cached_http_vsnrrrrTr{r)rfr! goodbye_frameririrjr^sV        zAsyncHfaceBackend.close)rErFrGrHrrIrJrKrLrMr?rNr@rOrArPrBrQrCrIrDrI)rkrl)rkrM)rkryrx) NNNNNNNNNNNN)rrrrrrrrrrHrrHrrrrrrrrrrrrrkrl)rU)rrFrkrK)NNr$) rErFrGrHr%r&r}rFrkr)F)rIrlrkrl)r^r_rrlr/r`r0rlr[rHr\rar]rHrkrb)FF) rrFrrFrrlrrlrkr)r?rFrrFrkrrs)rrrrlrrlrkr)rrrrMrrlrkr)rrMrkr)TF) rrHrrHrrlrrlrkr)rrrrrkr:)rrrrlrkr)(__name__ __module__ __qualname__r2rrrU supported_svnr r8default_socket_optionsr rrrWpropertyrqrrrurvrrrrr#r)rHrZrrrrrrrrrrr __classcell__ririrgrjr<Ds ;      .Z }   >=< BK` 3 e sr<)M __future__rrrtypingrrsocketrrrrcontrib.anytlsr r _collectionsr _constantr r rrrrr contrib.hfacerrrrrrrcontrib.hface.eventsrrrrrrr contrib.ssar!r"r#rQr$r%r&r'r(r)r*utilr+r,r-util.socket_stater.util.sub_timeoutr/_baser1r2r3r4hfacer5r6r8r9r: TYPE_CHECKING_typingr;rRr<riririrjs0   $$ $  $