U
|
Z ±d! ã @ sp d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZ ddl
|
m Z m Z ddl mZ ddl mZ ddl mZ ddlmZmZ ddlmZmZ G d d
|
d
|
Zejd d Zd d Zdd Zdd Z dd Z dd Z dd Z dd Z ej!j"e#ed d d d d Z$d d! Z%e d"d# Z&ej!j"e j'd$k d%d d&d' Z(d(d) Z)d*d+ Z*d,d- Z+ej! ,d.d/ej-fej.d0ej/e d1g¡d2d3 Z0d4d5 Z1d6d7 Z2ej3G d8d9 d9Z4ej! ,d:ej-e4d;d/d<d=d>fej.ej/e4d?d0d@dAd>e d1g¡dBdC Z5dDdE Z6dFdG Z7dHdI Z8dJdK Z9dLdM Z:dNdO Z;dPdQ Z<dRdS Z=dTdU Z>dVdW Z?ej!j"e#edX dYd dZd[ Z@d\d] ZAd^d_ ZBdS )`é Né )Ú creates_ipv6Ú
|
binds_ipv6)Ú_core)Ú_socket)Úsocket)Ú _NUMERIC_ONLYÚ _try_sync)Úassert_checkpointsÚwait_all_tasks_blockedc @ s, e Zd Zdd Zdd Zdd Zdd Zd S )
|
ÚMonkeypatchedGAIc C s || _ i | _g | _d S ©N)Ú_orig_getaddrinfoÚ
|
_responsesÚrecord)ÚselfZorig_getaddrinfo© r úMd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\trio/tests/test_socket.pyÚ__init__ s zMonkeypatchedGAI.__init__c O s4 t | j¡}|j||}| ¡ |j}|jr0t|S r )ÚinspectÚ signaturer ÚbindÚapply_defaultsÚargsÚkwargsÚAssertionError)r r r ÚsigÚboundZ frozenboundr r r Ú _frozenbind s
|
z MonkeypatchedGAI._frozenbindc O s || j | j||< d S r )r r )r Úresponser r r r r Úset& s zMonkeypatchedGAI.setc O sX | j ||}| j |¡ || jkr,| j| S |d tj@ rF| j||S td |¡d S )Néÿÿÿÿz'gai called with unexpected arguments {}) r r Úappendr Ú stdlib_socketÚAI_NUMERICHOSTr Ú RuntimeErrorÚformat)r r r r r r r Ú getaddrinfo) s
|
|
z MonkeypatchedGAI.getaddrinfoN)Ú__name__Ú
|
__module__Ú __qualname__r r r r' r r r r r s r c C s t tj}| td|j¡ |S )Nr' )r r# r' Úsetattr)Z monkeypatchÚ
|
controllerr r r Ú monkeygai4 s
|
r- c à s" t & t 4 I d H W 5 Q I d H R X W 5 Q R X t @ t t¡* t 4 I d H
|
tW 5 Q I d H R X W 5 Q R X W 5 Q R X t 4 I d H
|
tW 5 Q I d H R X dd } t| 4 I d H
|
tW 5 Q I d H R X t B t t¡, t| 4 I d H
|
tW 5 Q I d H R X W 5 Q R X W 5 Q R X d S )Nc S s
|
t | tS r )Ú
|
isinstanceÚ
|
ValueError)Úexcr r r Ú_is_ValueErrorH s z&test__try_sync.<locals>._is_ValueError)r
|
r ÚpytestÚraisesÚKeyErrorÚBlockingIOErrorr/ )r1 r r r Útest__try_sync; s ( r6 c C sD t jtjkstt jtjks tt jtjks0tt jtjks@td S r )ÚtsocketÚ
|
SOL_SOCKETr# r Ú TCP_NODELAYÚgaierrorÚntohsr r r r Ú test_socket_has_some_reexportsY s r< c
|
à sª dd }t tjddtjdI d H }W 5 Q R X ||tjtjtjddfg t tjddtjdI d H }W 5 Q R X ||tjtjtjdd fg | j d
|
d d d d d d d t t dd ¡I d H }W 5 Q R X |d
|
ksÜt
|
| j d dksît
|
t 4 t tj¡ }tjddddI d H W 5 Q R X W 5 Q R X tjh}| tj¡ ttdrZ| tj¡ |jj|kslt
|
t . t t¡ t dd¡I d H W 5 Q R X W 5 Q R X d S )Nc s, dd fdd}|| ||ks(t d S )Nc S s | \}}}}}|||fS r r )Úgai_tupÚfamilyÚtypeÚprotoÚ canonnameÚsockaddrr r r Úinteresting_fieldsl s z;test_getaddrinfo.<locals>.check.<locals>.interesting_fieldsc s fdd| D S )Nc s g | ] } |qS r r )Ú.0r= ©rC r r Ú
|
<listcomp>r s zEtest_getaddrinfo.<locals>.check.<locals>.filtered.<locals>.<listcomp>r )Zgai_listrE r r Úfilteredq s z1test_getaddrinfo.<locals>.check.<locals>.filtered©r )ÚgotÚexpectedrG r rE r Úcheckf s z test_getaddrinfo.<locals>.checkú 127.0.0.1Z12345©r? Ú )rL é90 ú::1)rP rO r r Úxó hostÚportr ©r> r? r@ ÚflagsÚhostr! )rR rS r r r r Ú EAI_BADHINTSÚasdf)r
|
r7 r' Ú SOCK_STREAMÚAF_INETÚ IPPROTO_TCPÚ
|
SOCK_DGRAMÚAF_INET6Ú IPPROTO_UDPr r r r2 r3 r: Ú EAI_SOCKTYPEÚaddÚ EAI_SERVICEÚhasattrrW ÚvalueÚerrnor% )r- rK ÚresÚexcinfoÚexpected_errnosr r r Útest_getaddrinfoe sR "ûÿþ "ûÿþ * rh c
|
à s6 t jt jB } t t d| ¡I d H }W 5 Q R X |dks<tt 0 t tj ¡ t dd¡I d H W 5 Q R X W 5 Q R X t 0 t tj ¡ t dd¡I d H W 5 Q R X W 5 Q R X t dd¡\}}t dd¡I d H }|||fksætt dtj¡I d H }|d|fks tt dtj¡I d H }||dfks2td S ) N)rL iÒ )rL Z1234)z
|
google.coméP r )Ú localhostri ©rL ri rL Ú80)
|
r# ÚNI_NUMERICHOSTÚNI_NUMERICSERVr
|
r7 Ú getnameinfor r2 r3 r: )Z
|
ni_numericrI rV Zservicer r r Útest_getnameinfo± s" &&rp c
|
à sô t ¡ \} }t| tjr t| f |V t | ¡}t|tjsBt| ¡ | ¡ ksVt| d¡I d H | d¡dksxtW 5 Q R X W 5 Q R X t
|
t ¡ t d¡ W 5 Q R X G dd dt j }| &}t
|
t ¡ t |¡ W 5 Q R X W 5 Q R X d S )Nó xé c @ s e Zd ZdS )z)test_from_stdlib_socket.<locals>.MySocketN)r( r) r* r r r r ÚMySocketâ s rs )r# Ú
|
socketpairr. r7 Ú
|
SocketTyper Úfrom_stdlib_socketÚfilenoÚsendÚrecvr2 r3 Ú TypeErrorr )ÚsaÚsbÚtars Zmysockr r r Útest_from_stdlib_socketÔ s
|
& r~ c à s t ¡ \} }t | ¡ | j| j| j¡}| \ |L |< | ¡ | ¡ ksLt| d¡I d H |
|
d¡dksntW 5 Q R X W 5 Q R X W 5 Q R X d S )Nrq é ) r# rt r7 Úfromfdrw r> r? r@ r rx ry )r{ r| r} r r r Ú test_from_fdê s r c à sr dd } t ¡ \}}|P |@ t ¡ 4 I d H }| | |¡ | | |¡ W 5 Q I d H R X W 5 Q R X W 5 Q R X d S )Nc Ó s4 t d | d¡I d H | d¡I d H dks0td S )Nz sending helloó hrr )Úprintrx ry r )Úsockr r r Úchildô s z%test_socketpair_simple.<locals>.child)r7 rt r Ú open_nurseryÚ
|
start_soon)r
ÚaÚbÚnurseryr r r Útest_socketpair_simpleó s r Ú fromsharez windows only)Úreasonc à s t ¡ \} }| z |j | t ¡ ¡}t |¡}|B | ¡ | ¡ ksJt| d¡I d H | d¡I d H dksrtW 5 Q R X W 5 Q R X W 5 Q R X d S ©Nrq rr )
|
r7 rt ÚshareÚosÚgetpidr rw r rx ry )r r ZsharedÚa2r r r Útest_fromshare s
|
r c à s8 t ¡ &} t| t jst| jt jks*tW 5 Q R X d S r )r7 r r. ru r r> rZ ©Úsr r r Ú test_socket s
|
r c à s@ t t jt j¡&} t| t js"t| jt jks2tW 5 Q R X d S r )r7 r r] r\ r. ru r r> r r r r Útest_socket_v6 s r Úlinuxz
|
linux onlyc
|
à sÒ ddl m} m}m}m} g }| |fD ]$}||fD ]}| t ||¡¡ q0q$|D ]~}tj | ¡ d}|j |j ksrt
|
|j |j kst
|
| ¡ t | ¡ | |¡} | j |j ks¬t
|
| j |j ks¼t
|
| ¡ | ¡ qNd S )Nr )rZ r] r\ rY ©rw )r rZ r] r\ rY r" r# r7 rw r> r r? Údetachr Úclose)
|
rZ r] r\ rY Úsocketsr> r? r Ztsocket_socketZtsocket_from_fdr r r Útest_sniff_sockopts s r c à sØ t ¡ } | }|| kstt| ¡ ts,t| ¡ r8t| d¡ | ¡ sNt| t j t j
|
d¡ | t j t j
|
¡rtt| t j t j
|
d¡ | t j t j
|
¡stW 5 Q R X | ¡ dks´tt | t ¡ .} | ¡ }| ¡ |ksÞt| ¡ dksîtW 5 Q R X t ¡ } | ¡ dkst| ¡ | ¡ dks,tdt| ks>tdt| ksPtdt| ksbtt t¡ | j W 5 Q R X t ¡ }t |¡} | jt |j¡ks¨t| j|jksºt| j|jksÌt| ¡ d S )NTFr! r r> ry Ú
|
setsockopt)r7 r r r. rw ÚintÚget_inheritableÚset_inheritabler r[ r9 Ú
|
getsockoptÚreprr r Údirr2 r3 ÚAttributeErrorrX r# rv r? Ú_tsocketZreal_socket_typer> r@ )r Zcm_enter_valueÚfdZ stdlib_sockr r r Útest_SocketType_basics: s@
|
|
|
r¨ c à s t ¡ \} }| |r | ¡ }|Z t|t js6t| ¡ | ¡ ksJt| ¡ | d¡I d H | d¡I d H dksztW 5 Q R X W 5 Q R X W 5 Q R X d S r )
|
r7 rt Údupr. ru r rw r rx ry )r r r r r r Útest_SocketType_dupm s rª c
|
à sj t ¡ \} }| ² |¢ | d¡I d H | d¡I d H dks@t| jrJt|jrTt| t j¡ | jsjt|jrtt| d¡I d H dkst| d¡I d H | d¡I d H dks´tW 5 Q R X W 5 Q R X t ¡ \} }| 8 |( | jrêt| t j¡ | jrtW 5 Q R X W 5 Q R X t ¡ \} }| : |* | jr:t| t j ¡ | jsRtW 5 Q R X W 5 Q R X d S )Nrq rr ó ó y)
|
r7 rt rx ry r Zdid_shutdown_SHUT_WRÚshutdownÚSHUT_WRÚSHUT_RDÚ SHUT_RDWR©r r r r r Útest_SocketType_shutdowny s,
|
|
|
|
,
|
r² zaddress, socket_typerL rP )Zmarksc à s t |¡}t |¡}|à |Ð | | df¡I d H | d¡ | ¡ d d
}t ¡ 4 I d H &}| |j|¡ | ¡ I d H \}}W 5 Q I d H R X |P ||
|
¡ kr²| ¡ ks¸n t | d¡I d H | d¡I d H dksàt W 5 Q R X W 5 Q R X W 5 Q R X d S )Nr é r rq rr )r7 r r ÚlistenÚ getsocknamer r r ÚconnectÚacceptÚ getpeernamer rx ry )ÚaddressÚ socket_typeÚlistenerÚclientÚaddrr ÚserverÚ client_addrr r r Ú test_SocketType_simple_server s
|
|
|
""rÀ c
|
à s t ¡ \} }| r |b | ¡ r$t| d¡I d H t | ¡I d H | ¡ sPt| d¡I d H dksht| ¡ rttW 5 Q R X W 5 Q R X d S r )r7 rt Z is_readabler rx r Ú wait_readablery r± r r r Útest_SocketType_is_readable¬ s r c C s8 zt jddt jd W n t jk
|
r. Y dS X dS d S )Nú1.2.3.4r ©r> FT)r# r' r] r: r r r r Ú gai_without_v4mapped_is_buggyº s
|
rÅ c @ s, e Zd Ze ¡ Ze ¡ Ze ¡ Ze ¡ ZdS )Ú AddressesN) r( r) r* ÚattrÚibÚbind_allrj Ú arbitraryÚ broadcastr r r r rÆ Ã s rÆ zsocket_type, addrsz0.0.0.0rà z255.255.255.255)rÉ rj rÊ rË z::ú1::2z::ffff:255.255.255.255c s4 | t jkfddfdd}t j| dúdD ]T}j|dfdd I d H }|||jdf j|dfd
|
d I d H }|||jdf q6d D ] fd d }|||jdfI d H |jdf r¸||dI d H d ||dI d H d ||dI d H d ||dI d H d ||dI d H d ||dI d H d ||dI d H d ||dI d H d ||dI d H d ||dI d H d t jt j d
|
¡ ||dI d H d ||d I d H |j
|
d f rJt sJ t jt j d¡ t t j¡}|d I d H W 5 Q R X t jh}tt d r8| t j¡ |jj|ksJtzt jt jt jd }W n ttfk
|
rz Y n(X |jd! d I d H d!kst| ¡ t t¡ |d"I d H W 5 Q R X t t¡ |d#I d H W 5 Q R X t t¡* r |d$I d H n|d%I d H W 5 Q R X qW 5 Q R X d S )&Nc s rt | dk r| d7 } q| S )Né )r )Úlen)r½ )Úv6r r Úpadç s
|
z$test_SocketType_resolve.<locals>.padc s | | kst d S r rH )ÚactualrJ )rÐ r r Ú assert_eqí s z*test_SocketType_resolve.<locals>.assert_eqrÄ )NrN ri T)ÚlocalF)FTc s j | d iI d H S )NrÓ )Ú_resolve_address_nocp)r )rÓ r r r re þ s z$test_SocketType_resolve.<locals>.resÚhttp)rÌ ri )rÌ ri r r )rÌ ri r )rÌ ri rr )rÌ ri rr r )rÌ ri rr r )rÌ rl )rÌ rl r )rÌ rl r r )rÌ rl rr )rÌ rl rr r )rà rÕ )z::ffff:1.2.3.4ri )z <broadcast>é{ rÖ )rà ri ÚEAI_ADDRFAMILY)r> r? rX rà )rà )rà ri r r r )rà ri r r ) r7 r] r rÔ rÉ rj rÊ r Ú IPPROTO_IPV6Ú IPV6_V6ONLYrË rÅ r2 r3 r: Ú
|
EAI_NONAMErb r` r× rc rd r Z
|
AF_NETLINKr\ r¥ ÚOSErrorr r/ ) rº ÚaddrsrÒ ÚnullrI re rf rg Z netlink_sockr )rÓ rÐ r rÏ r Útest_SocketType_resolveÌ sl
|
|
ÿ
|
ÿÿ rÞ c
|
à sÆ t ¡ x} | d¡I d H | ¡ d dks.t| d¡ t ¡ 6}| d| ¡ d f¡I d H | ¡ | ¡ ksrtW 5 Q R X W 5 Q R X t ¡ .} t t j
|
¡ | d¡I d H W 5 Q R X W 5 Q R X d S )N)rj r r rL é
|
rj rr )z1.2:3r! ) r7 r r rµ r r´ r¶ r¸ r2 r3 r: )r Zsock2r r r Ú test_SocketType_unresolved_namesC s
|
|
|
(
|
rà c s> t ¡ \} }| " | t | ¡ | d¡ | d¡ t ¡ H}| ¡ t . t
|
tj ¡ d¡I d H W 5 Q R X W 5 Q R X W 5 Q R X t d¡I d H dk W 5 Q R X t , t
|
t¡ d¡I d H W 5 Q R X W 5 Q R X fdd}t ¡ 4 I d H &}| |¡ t I d H | d¡ W 5 Q I d H R X fdd }t ¡ 4 I d H &}| |¡ t I d H |j ¡ W 5 Q I d H R X t |¡ fd
|
d } fd d }t ¡ 4 I d H Z}| |¡ | |¡ t I d H | d¡ | d¡ t I d H | d¡ | d¡ W 5 Q I d H R X W 5 Q R X W 5 Q R X d S )NFó 1rß Zhahac s. t d¡I d H dks tW 5 Q R X d S )Nrß ó 2©r
|
ry r r ©r} r r Údo_successful_blocking_recvm s zGtest_SocketType_non_blocking_paths.<locals>.do_successful_blocking_recvrâ c
|
s> t . t tj¡ d¡I d H W 5 Q R X W 5 Q R X d S )Nrß )r
|
r2 r3 r Ú Cancelledry r rä r r Údo_cancelled_blocking_recvw s zFtest_SocketType_non_blocking_paths.<locals>.do_cancelled_blocking_recvc sX t d¡I d H dks tW 5 Q R X t d¡I d H dksJtW 5 Q R X d S )Nrr ó aó brã r ©r} Útbr r Út1 s "z.test_SocketType_non_blocking_paths.<locals>.t1c sX t d¡I d H dks tW 5 Q R X t d¡I d H dksJtW 5 Q R X d S )Nrr ré rè rã r rê r r Út2 s "z.test_SocketType_non_blocking_paths.<locals>.t2ré rè )r# rt r7 rv Ú setblockingrx r Ú CancelScopeÚcancelr
|
r2 r3 ræ ry rz r r r Ú cancel_scope)r r Zcscoperå r rç rì rí r rê r Ú"test_SocketType_non_blocking_pathsV sJ
|
|
|
|
. $
|
|
|
|
|
|
|
|
rò c s t ¡ ,t t¡ d¡I d H W 5 Q R X W 5 Q R X t ¡ Jt ¡ 6 ¡ t tj ¡ d¡I d H W 5 Q R X W 5 Q R X W 5 Q R X t ¡ À t ¡ ¬t ¡ } |
|
d¡I d H | ¡ G fdddt j}j ¡ | _ t 2 t tj ¡ | ¡ ¡I d H W 5 Q R X W 5 Q R X ¡ dksBtW 5 Q R X W 5 Q R X W 5 Q R X t ¡ ,t t¡ d¡I d H W 5 Q R X W 5 Q R X d S )Nrj rk ©rL r c s e Zd Z fddZdS )z3test_SocketType_connect_paths.<locals>.CancelSocketc s6 ¡ t | ¡ | j| j¡_jj|| td S r ) rð r# r r r> r? Ú_sockr¶ r5 ©r r r ©rñ r r r r¶ ¸ s ÿz;test_SocketType_connect_paths.<locals>.CancelSocket.connectN)r( r) r* r¶ r rö r r Ú CancelSocket· s r÷ r! )rL r )r7 r r2 r3 r/ r¶ r rï rð ræ r r´ r# rô r r
|
rµ rw r rÛ )r» r÷ r rö r Ú test_SocketType_connect_paths¡ s,
|
$
|
|
.
|
|
|
(0
|
rø c s t ¡ v t ¡ b} fdd}|| _t . t t j¡ | d¡I d H W 5 Q R X W 5 Q R X |
|
¡ dkspt W 5 Q R X W 5 Q R X d S )Nc s ¡ t ¡ I d H d S r )rð r Ú
|
checkpointrõ ©rñ r r rÔ Û s zVtest_resolve_address_exception_in_connect_closes_socket.<locals>._resolve_address_nocprN r! ) r rï r7 r rÔ r
|
r2 r3 ræ r¶ rw r )r rÔ r rú r Ú7test_resolve_address_exception_in_connect_closes_socketÖ s
|
|
$rû c
|
à sü t ¡ \} }| Ô |Ä | d¡I d H dks0t| dt j¡I d H dksLt| d¡I d H dksdt| d¡I d H td}| |¡I d H |dkstt| drÖ| dgg ¡I d H dks¾t| d¡I d H dksÖtW 5 Q R X W 5 Q R X t j
|
t j d} t j
|
t j d}| 2 | | d ¡I d H | d ¡I d H | ¡ d
|
| ¡ d fg}|D ]V}| d|¡I d H dksrt| d¡I d H \}}|dkst|| ¡ ksRtqRtt d r4| dt j| ¡ ¡I d H | d t j| ¡ ¡I d H | d | ¡ ¡I d H | d¡I d H \}}|dks"t|| ¡ ks4t| d| ¡ ¡I d H dksTttd}| |¡I d H \}}|dks~t|dkst|| ¡ kstt|dr | d| ¡ ¡I d H dksÊt| d¡I d H \}}} }|dksðt|g ksþt| dks t|| ¡ ks tt|drÒ| d| ¡ ¡I d H dksJttd}
|
td} | |
|
| g¡I d H } | \}}} }|dkst|
|
dkst| dks¤t|g ks²t| dksÀt|| ¡ ksÒtt| dr0|D ]L}| ddgg d|¡I d H dks
|
t| d¡I d H d| ¡ fksâtqâW 5 Q R X W 5 Q R X t j
|
t j d} t j
|
t j d}| |~ | d ¡I d H | | ¡ ¡I d H | d¡I d H | d ¡I d H | d¡I d H dksÊt| d¡I d H d ksätW 5 Q R X W 5 Q R X d S )Nrq rr rß s
|
x Úsendmsgs xxxr rM ró rj ÚMSG_MOREs yyys zzzs xxxyyyzzzs
|
xxx Úrecvmsgr Ú recvmsg_intos xyzwrÍ r s xys zw s yzs xyz)r7 rt rx r ry ÚMSG_PEEKÚ bytearrayÚ recv_intorb rü r r\ r rµ ÚsendtoÚrecvfromrý Ú recvfrom_intorþ rÿ r¶ ) r r ÚbufÚtargetsÚtargetÚdatar½ ÚnbytesZancdataZ msg_flagsZbuf1Úbuf2Úretr r r Útest_send_recv_variantsæ s
|
,
|
$: r c à sÔ | ddd¡ | j dddtd | j dddtd | dd d¡ | dd
|
d¡ dt dd¡I d H kshtdt dd¡I d H kstdt d d¡I d H kstdt d
|
d¡I d H ks¶tdt dd¡I d H ksÐtd S ) Nu
|
ok faÃ.des xn--fa-hia.deri zok ::1rP )rU s ::1Úbadzfass.dez xn--fa-hia.deu faÃ.de)r r r7 r' r )r- r r r Ú test_idnaF s r c à s4 t d¡I d H dkstt d¡I d H dks0td S )NZudpé Ztcpé )r7 Úgetprotobynamer r r r r Útest_getprotobynameX s r c à s G dd d}| }t |¡d ks&tt jdddfdt jddfddt jdfdddt jffD ]$}t jd| I d H d|ksZtqZt dd¡I d H }d }||ks¢tt d
|
d¡I d H d ks¼tt d ¡|ksÎt| j d d dddddd t dd¡I d H d kstd S )Nc @ s e Zd Zdd Zdd ZdS )z5test_custom_hostname_resolver.<locals>.CustomResolverc Ó s d||||||fS )NÚ
|
custom_gair )r rV rS r> r? r@ rU r r r r' a s zAtest_custom_hostname_resolver.<locals>.CustomResolver.getaddrinfoc Ó s
|
d||fS )NÚ
|
custom_gnir )r rB rU r r r ro d s zAtest_custom_hostname_resolver.<locals>.CustomResolver.getnameinfoN)r( r) r* r' ro r r r r ÚCustomResolver` s r r rj Úfoor ó localhostu föö)r s
|
xn--f-1gaar r r r r r )r r r rQ rR rS rT rV )rj r )r r r )
|
r7 Z set_custom_hostname_resolverr rZ rY r[ Ú AI_CANONNAMEr' ro r )r- r ZcrÚvalsrI rJ r r r Ú test_custom_hostname_resolver_ s, ü ýü r c
|
à sä G dd d} | }t |¡d ks&tt ¡ dt jt jdfksBtt ddd¡dksXtt ¡ ¡ }t j|d }t|d
|
s~t| ¡ t
|
¡ \}}|2 |" t|d
|
s¬tt|d
|
sºtW 5 Q R X W 5 Q R X t d ¡|ksàtd S ) Nc @ s e Zd Zdd ZdS )z7test_custom_socket_factory.<locals>.CustomSocketFactoryc S s d|||fS )NÚhir )r r> r? r@ r r r r s z>test_custom_socket_factory.<locals>.CustomSocketFactory.socketN)r( r) r* r r r r r ÚCustomSocketFactory s r r r rr r r )r rr r r r r ) r7 Zset_custom_socket_factoryr r rZ rY r# r rb r rt )r Zcsfr§ Úwrappedr r r r r Útest_custom_socket_factory s "r c à s" t t¡ t ¡ W 5 Q R X d S r )r2 r3 rz r7 ru r r r r Útest_SocketType_is_abstract¦ s r ÚAF_UNIXzno unix domain socketsc à sx dd } t ¡ }d |¡}| |I d H W 5 Q R X z*t d¡ ¡ d¡}| d| I d H W n tk
|
rr Y nX d S )Nc Ó s¬ t jt jd}| | ¡I d H | d¡ t jt jd`}| | ¡I d H | ¡ I d H \}}|. | d¡I d H | d¡I d H dkst W 5 Q R X W 5 Q R X W 5 Q R X d S )NrÄ rß rq rr )
|
r7 r r! r r´ r¶ r· rx ry r )ÚpathÚlsockÚcsockÚssockÚ_r r r Ú check_AF_UNIX° s
|
z.test_unix_domain_socket.<locals>.check_AF_UNIXz{}/sockr³ Úasciis trio-test-)ÚtempfileÚTemporaryDirectoryr& r ÚurandomÚhexÚencodeÚFileNotFoundError)r' Ztmpdirr" Úcookier r r Útest_unix_domain_socket« s
|
|
r0 c sÖ t ¡ \} }| ¼ |¬ | d¡ dd z| ¡ q,W n tk
|
rN Y nX t | ¡ fdd} fdd}t ¡ 4 I d H .}| |¡ | |¡ t
|
I d H ¡ W 5 Q I d H R X W 5 Q R X W 5 Q R X d S )NFrq i c s, t tj¡ ¡I d H W 5 Q R X d S r )r2 r3 r ÚClosedResourceErrorrx r ©r r r r ÚsenderØ s z)test_interrupted_by_close.<locals>.senderc s, t tj¡ d¡I d H W 5 Q R X d S )Nrr )r2 r3 r r1 ry r )r r r ÚreceiverÜ s z+test_interrupted_by_close.<locals>.receiver) r# rt rî rx r5 r7 rv r r r r r )Za_stdlibZb_stdlibr3 r4 r r r2 r Útest_interrupted_by_closeÉ s
|
|
|
|
r5 c à s d} g }t | d D ]d}zt ¡ \}}W nB tk
|
rj } z$|jtjtjfksPtW Y ¢ qzW 5 d }~X Y nX |||g7 }qt ¡ 4 I d H 6}|D ]}|
|
tj |¡ qt ¡ I d H |j ¡ W 5 Q I d H R X |D ] }| ¡ qÐ|| d d krtd|d d d d S )Ni r rr zUnable to open more than z sockets.)Úranger# rt rÛ rd ZEMFILEZENFILEr r r r rÁ r rñ rð r r ) Útotalr rQ r r Úer r r r r r Útest_many_socketsç s$
|
r9 )Crd r2 rÇ r r r# r r) ÚsysÚ_sysZ_core.tests.tutilr r rN r r r¦ r7 r r Ztestingr
|
r r Zfixturer- r6 r< rh rp r~ r r ÚmarkZskipifrb r r r Úplatformr r¨ rª r² Z parametrizerZ Úparamr] rÀ r rÅ r rÆ rÞ rà rò rø rû r r r r r r r0 r5 r9 r r r r Ú<module> s¢
|
L#
|
|
|
3 þþ
|
üþ üøöþ
|
_K5`,
|
|
