Ë
|
·^iÑ% ã ó´ d Z ddlZddlZddlZddlZddlZddlZddlmZm Z m
|
Z
|
m Z m Z ddl mZ ddlmZmZ ddddddde
|
e d e e
|
e d
|
e e d e e d e ej( d e e dej fdZ dd ej( deee eef ded e e
|
e de e ej d e e dej fdZ dde
|
e dedee fdZy)zBase implementation.é N)ÚListÚOptionalÚSequenceÚSetÚUnioné )Ú
|
_staggered)Ú AddrInfoTypeÚSocketFactoryType)Úlocal_addr_infosÚhappy_eyeballs_delayÚ
|
interleaveÚloopÚsocket_factoryÚ
|
addr_infosr r r r r Úreturnc óÆ K |xst j « t | « dk( }||d}|r|s t | |« } d}g ||r"| D ] } t |d« d{ } n| nzt « t j fd| D « |« d{ \ }} } D ]9 }
|
|
|
|ust j t « 5 |
|
j « ddd« ; d|êD cg c] } | D ] } | } } } | d }t | « dk( r|t |« t fd| D « « r|dj dj! d | D « « « }t# |t « r,|j$ t fd | D « « r9t |« t# |t
|
« r t d
|
| D « « r t |« t |« |S 7 q# t
|
t f$ r Y w xY w7 P# 1 sw Y RxY w# D ]E }
|
|
|
|ust j t « 5 |
|
j « ddd« ;# 1 sw Y DxY w dw xY wc c} } w # d} dw xY ww) aM
|
Connect to a TCP server.
|
|
Create a socket connection to a specified destination. The
|
destination is specified as a list of AddrInfoType tuples as
|
returned from getaddrinfo().
|
|
The arguments are, in order:
|
|
* ``family``: the address family, e.g. ``socket.AF_INET`` or
|
``socket.AF_INET6``.
|
* ``type``: the socket type, e.g. ``socket.SOCK_STREAM`` or
|
``socket.SOCK_DGRAM``.
|
* ``proto``: the protocol, e.g. ``socket.IPPROTO_TCP`` or
|
``socket.IPPROTO_UDP``.
|
* ``canonname``: the canonical name of the address, e.g.
|
``"www.python.org"``.
|
* ``sockaddr``: the socket address
|
|
This method is a coroutine which will try to establish the connection
|
in the background. When successful, the coroutine returns a
|
socket.
|
|
The expected use case is to use this method in conjunction with
|
loop.create_connection() to establish a connection to a server::
|
|
socket = await start_connection(addr_infos)
|
transport, protocol = await loop.create_connection(
|
MyProtocol, sock=socket, ...)
|
r Nc
|
3 ó\ K | ]# }t j t |« % y w©N)Ú functoolsÚpartialÚ _connect_sock)Ú.0ÚaddrinfoÚ current_loopÚ
|
exceptionsr Ú open_socketsr s õh H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\aiohappyeyeballs/impl.pyú <genexpr>z#start_connection.<locals>.<genexpr>X s; øè ø ò ð !ô ×%Ñ%Ü%Ø$Ø"Ø Ø(Ø$Ø&÷ñ ùs ),r c 3 ó: K | ] }t |« k( y wr ©Ústr)r ÚexcÚmodels r r z#start_connection.<locals>.<genexpr>~ s øè ø ÒC¨Ss3x 5Õ(ÑCùs zMultiple exceptions: {}z, c 3 ó2 K | ] }t |« y wr r! ©r r# s r r z#start_connection.<locals>.<genexpr> s è ø Ò A¨3c #hÑ Aùs c 3 ó` K | ]% }t |t « xr |j k( ' y wr )Ú
|
isinstanceÚOSErrorÚerrno)r r# Ú first_errnos r r z#start_connection.<locals>.<genexpr> s1 øè ø ò à ô # 3¬Ó0ÒM°S·Y±YÀ+Ñ5MÓMñùs +.c 3 ó< K | ] }t |t « y wr )r( Ú RuntimeErrorr& s r r z#start_connection.<locals>.<genexpr> s è ø ò GØ69Js¤L×1ñGùs )ÚasyncioÚget_running_loopÚlenÚ_interleave_addrinfosr r- r) Úsetr Ústaggered_raceÚ
|
contextlibÚsuppressÚcloser" ÚallÚformatÚjoinr( r* )r r r r r r Úsingle_addr_infoÚsockr Ú_ÚsÚsubr# Úall_exceptionsÚfirst_exceptionÚmsgr r r+ r$ r s ` ` @@@@@r Ústart_connectionrB s¸ þè ø ðN !Ð LÐ Ü ×/Ñ/Ó1 ä:¨!Ñ+ÐàÐ'¨JÐ,>à
|
áÑ*Ü*¨:°zÓB
|
à$(Dà;=JØÐ#Ñ'7à"ò Hð Ü *Ø Ø Ø Ø$ØØ"ó ÷ ñ ñ ô ,/«5 ð Ü )× 8Ñ 8÷ ð %/ô ð %ó ÷ JD!Qð0 "ò "ØD=Ü#×,Ñ,¬WÓ5ñ "Ø ÷"ð "ð "ð Là |Ø)3×C #¸sÒC¸#ÐC#ÐCÑCð! Ø ,¨QÑ /OÜ>Ó" aÒ'Ø%Ð%ô OÓ,ÜÓC°NÔCÔCØ)Ð)ð 0×6Ñ6ØIIÑ A°.Ô AÓAóô
|
o¬wÔ7Ø"1×"7Ñ"7KÜó à#1ôô ô & k°3Ó 7Ð7Ü ´ Ô>Ä3ñ GØ=KôGô Dô ' sÓ+Ð+ô clÐ"ð
|
Kðcúô !¤'Ð*ò Úð úð
|
ù÷4"ñ "ûð "ò "ØD=Ü#×,Ñ,¬WÓ5ñ "Ø ÷"÷ "ñ "úð "ð Lüó DøðB "NØ JüsÇ A
|
I!ÁGÁ'GÁ(GÁ,I!Á;&H Â!G1Â"H Â* I!Â4I!Ã G4Ã I!Ã1IÄI!ÄCI ÇI!ÇGÇG.Ç*I!Ç-G.Ç.I!Ç1H Ç4G> Ç9I!È
|
IÈ IÈ%H? È6 IÈ?I É IÉ I!ÉI É I!r Ú addr_infor c óú K g }|j |« |\ }}} }
|
} d} | ||« } nt j ||| ¬« } ||j | « | j d« |G|D ]! \ } }
|
}
|
}
|
}| |k7 r | j |« n" |r|j « t d|d« | j | | « d{ | dx}}S # t
|
$ rU}d|d|j xs dj « }t |j |« }|j |« Y d}~¾d}~ww xY w7 k# t t
|
f$ ra}|j |« | H||j | « | j « # t
|
$ r}|j |« d}~ww xY w d}~w | H||j | « | j « # t
|
$ r}|j |« d}~ww xY w xY w# dx}}w xY ww) aq
|
Create, bind and connect one socket.
|
|
If open_sockets is passed, add the socket to the set of open sockets.
|
Any failure caught here will remove the socket from the set and close it.
|
|
Callers can use this set to close any sockets that are not the winner
|
of all staggered tasks in the result there are runner up sockets aka
|
multiple winners.
|
N)ÚfamilyÚtypeÚprotoFz*error while attempting to bind on address z: Ú z&no matching local address with family=z found)ÚappendÚsocketÚaddÚ setblockingÚbindr) ÚstrerrorÚlowerr* ÚpopÚ sock_connectr- Úremover6 )r r rC r r r Ú my_exceptionsrE Útype_rG r< Úaddressr; ÚlfamilyÚladdrr# rA Úes r r r sH è ø ð$ 9;MØ×ÑmÔ$Ø'0Ñ$FE5!WØ Dð5*Ø Ð %Ù! )Ó,Dä==¨°UÀ%ÔHDØ Ð #Ø × Ñ TÔ "Ø ×ÑÔ Ø Ð 'Ø+;ò UÑ'Aq %àfÒ$Ø ð
|
.ØIIeÔ$Ùð Uñ !Ø'×+Ñ+Ó-Ð-ä!Ð$KÀFÀ9ÈFÐ"SÓTÐTØ× Ñ gÓ.×.Ð.Øð. &*Ð)
|
]øôK ò .ð#Ø#( )¨2Ø LLÒ .¨B×5Ñ5Ó7Ð8ð:ð ô
|
" #§)¡)¨SÓ1CØ!×(Ñ(¨×-Ñ-ûð.úð /ùä 'Ð "ò
|
Ø× Ñ SÔ!Ø Ð ØÐ'Ø ×#Ñ# DÔ)ð Ø
|
|
ð øô ò Ø ×$Ñ$ QÔ'Øûð úð ûð Ø Ð ØÐ'Ø ×#Ñ# DÔ)ð Ø
|
|
ð øô ò Ø ×$Ñ$ QÔ'Øûð úð ûà%)Ð)
|
]üs´ G;¡AD4 Á<CÂ 9D4 ÃD2ÃD4 Ã G;Ã D/ÃA D*Ä%D4 Ä*D/Ä/D4 Ä4G/Å&F Å*E;Å:F Å; FÆFÆFÆF Æ G/Æ:G Ç
|
G/Ç G+ÇG&Ç&G+Ç+G/Ç/G2 Ç2G8Ç8G;Ú addrinfosÚfirst_address_family_countc ó t j « }| D ]$ }|d }||vrg ||< || j |« & t |j « « }g }|dkD r%|j |d d|dz
|
« |d d|dz
|
= |j d t j j t j | « D « « |S )z-Interleave list of addrinfo tuples by family.r r Nc 3 ó$ K | ] }||
|
y wr © )r Úas r r z(_interleave_addrinfos.<locals>.<genexpr>þ s è ø ò à Ø =ô
|
ñùs )
|
Ú collectionsÚ OrderedDictrI ÚlistÚvaluesÚextendÚ itertoolsÚchainÚ from_iterableÚ zip_longest)rY rZ Úaddrinfos_by_familyÚaddrrE Úaddrinfos_listsÚ reordereds r r1 r1 ë sð ô × Ñ Ó!ð ð ò 1ØaØ Ð,Ñ ,Ø*,Ð Ñ 'ØFÑ#×*Ñ*¨4Õ0ð 1ô
|
Ð.×5Ñ5Ó7Ó8Oà$&IØ! AÒ%Ø×Ñ ¨Ñ+Ð,LÐ.HÈ1Ñ.LÐMÔNØ AÑ Ð ?Ð!;¸aÑ!?Ð ?Ð @Ø ×Ññ ä ×.Ñ.¬y×/DÑ/DÀoÐ/VÓWôô ð
|
Ðó )NNN)r )Ú__doc__r. r_ r4 r rd rJ Útypingr r r r r rH r Útypesr
|
r ÚfloatÚintÚAbstractEventLooprB r) r- r r1 r] rl r ú<module>rs sz ðÙ ã Û Û Û Û Û ß 7Õ 7å ß 2ð :>Ø,0Ø $Ø04Ø26òKØ Ñ&ðKð x¨ Ñ 5Ñ6ðKð # 5/ð Kð
|
ð Kð 7×,Ñ,Ñ
|
-ð Kð Ð .Ñ/ðKð ]]óKðd :>Ø15Ø26ñ K*Ø
|
×
|
#Ñ
|
#ðK*àT% ¨ Ð 5Ñ6Ñ7Ñ8ðK*ð ðK*ð x¨ Ñ 5Ñ6ð K*ð
|
3v}}Ñ-Ñ.ð K*ð Ð .Ñ/ð K*ð ]]óK*ð^ JKñØ Ñ%ðØCFðà ,Ñôrl
|
