python (3.12.0)
Browse
Usage
Versions
Αe# d Z ddlZddlZddlZddlZddlZddlZ eed s ej d G d dej Z
e dk( r ej yy)z
Tests for kqueue wrapper.
Nkqueueztest works only on BSDc 6 e Zd Zd Zd Zd Zd Zd Zd Zd Z y)
TestKQueuec \ t j }| j |j dkD |j | j |j |j | j |j | j
t |j y Nr )selectr
assertTruefilenoclosedclose assertRaises
ValueError)selfkqs D/BuggyBox/python/3.12.0/bootstrap/lib/python3.12/test/test_kqueue.pytest_create_queuez TestKQueue.test_create_queue sj
]]_ a5 BII
&
" *bii0 c f ddl m}m}m}m} t j t
j t
j }| j t
j | t j | }t j d }| j |j | | j |j t j | j |j" t j$ | j |j& d | j |j( d | j |j* d | j || | j- || | j/ ||k | j/ ||k\ ||||fD ]J }| j1 t2 ||d | j1 t2 ||d | j1 t2 ||d L t j |t j4 }| j |j | | j |j t j4 | j |j" t j$ | j |j& d | j |j( d | j |j* d | j || | j- || t j |t j4 t j6 }| j |j | | j |j t j4 | j |j" t j6 | j |j& d | j |j( d | j |j* d | j || | j- || t j ddddd d
}| j |j d | j |j d | j |j" d | j |j& d | j |j( d | j |j* d
| j || | j- || d } t j | ddd| dz
| }| j |j | | j |j d | j |j" d | j |j& d | j |j( | dz
| j |j* | | j || | j- || d } t j dd| }| j |j d | j |j d | j |j" | | j |j& d | j |j( d | j |j* d | j || | j- || d
} t j ddd| }| j |j d | j |j d | j |j" d | j |j& | | j |j( d | j |j* d | j || | j- || y )Nr )ltlegtgei ev i i l ) operatorr r r r osopendevnullO_WRONLY
addCleanupr r kevent assertEqualidentfilterKQ_FILTER_READflags KQ_EV_ADDfflagsdataudataassertNotEqualr r
TypeErrorKQ_FILTER_WRITE
KQ_EV_ONESHOT)
r r r r r fdr otheropbignums
r test_create_eventz TestKQueue.test_create_event s ++
WWRZZ
- "%
]]2
d# 2& F$9$9: 6#3#34 A& !$ 1% R B& U
# $b"b. 7B iR 6 iR 3 iR 6 7
]]2v 5 5
6 2& F$:$:; 6#3#34 A& !$ 1% R B&
]]2v 5 5v7K7K
L 2& F$:$:; 6#7#78 A& !$ 1% R B&
]]1aAq!
, 1% A& 1% A& !$ 1% R B&
]]61aFQJ
? 6* A& 1% A& &1*- 6* R B&
]]1a
( 1% A& 6* A& !$ 1% R B&
]]1aF
+ 1% A& 1% F+ !$ 1% R B&r c
x t j d }t j }|j d |j d|j d f |j \ }}t j }t j j |j }t j |j t j t j" t j$ z }|j' |gd t j |j t j( t j" t j$ z }|j' |gd t j |j t j t j" t j$ z }|j' |gd t j |j t j( t j" t j$ z }|j' |gd |j' d dd } t+ d | D } | j
| t+ |j t j f|j t j fg |j- d |j- d t/ d
D ]: }
|j' d dd } t1 | dk( r n(t3 j4 d < | j7 d t+ d
| D } | j
| t+ |j t j f|j t j( f|j t j f|j t j( fg t j |j t j t j8 }|j' |gd t j |j t j( t j8 }|j' |gd t j |j t j( t j8 }|j' |gdd |j' g dd } t+ d | D } | j
| t+ |j t j fg |j; |j; |j; y # t
$ r8}| j
|j d t j Y d }~Sd }~ww xY w)N) 127.0.0.1r Fr: r r r c 3 L K | ] }|j |j f y wNr( r) .0es r <genexpr>z.TestKQueue.test_queue_event.<locals>.<genexpr> 9Qaggqxx(9 "$s Hello!s world!!!
g ?z'timeout waiting for event notificationsc 3 L K | ] }|j |j f y wr< r= r> s r rA z.TestKQueue.test_queue_event.<locals>.<genexpr> rB rC gGz?c 3 L K | ] }|j |j f y wr< r= r> s r rA z.TestKQueue.test_queue_event.<locals>.<genexpr> rB rC ) socket
create_server setblockingconnect getsocknameOSErrorr' argserrno EINPROGRESSacceptr r fromfdr
r& r2 r, KQ_EV_ENABLEcontrolr* setsendrangelentimesleepfail KQ_EV_DELETEr ) r serverSocketclientr@ serveraddrr kq2r eventsis r test_queue_eventzTestKQueue.test_queue_eventp sJ ++,<= 5! NNK )A)A)CA)FG H
#**,
]]_mm""299;/
]]6==?!11!++f.A.AAC
B4
]]6==?!00!++f.A.AAC
B4
]]6==?!11!++f.A.AAC RD!
]]6==?!00!++f.A.AAC RD! D!Q'9&99
]]_f 4 4 5
]]_f 4 4 5&7 "8 9 I K r AAZZa+F6{a JJsO A
II? @9&99
]]_f 4 4 5
]]_f 3 3 4
]]_f 4 4 5
]]_f 3 3 4 &6 "7 8 ]]6==?!11!..0
B4
]]6==?!00!..0
B4
]]6==?!00!..0
B4A B4(9&99
]]_f 4 4 5&7 "8 9 S ; QVVAY(9(9 : : ;s $U8 8 V9-V44V9c t j }t j \ }}|j d t j
|t j t j t j z }t j
|t j t j t j z }|j ||gdd }| j | | j |d j t j z | j |j |d j d |j# |j# |j# y )Ns foor r )r r rG
socketpairrU r& r* r, rR rS r assertFalser+ KQ_EV_ERRORr' recvr. r )r r abevent1event2rs r testPairzTestKQueue.testPair s
]]_ "1 v q&"7"79I9IFL_L_9_` q&"7"79I9IFL_L_9_` JJ'A . 1f&8&889 ! *F3
r c t j }t j \ }}t j |t j
t j t j z |j gd |j fd G fdd }|j | d |j t g d |j |j |j y )Nr c e Zd Zd Z fdZy)+TestKQueue.test_issue30058.<locals>.BadListc yr )r s r __len__z3TestKQueue.test_issue30058.<locals>.BadList.__len__ s r c 3 6 K t d D ] } y w)Nd )rV )r rb r s r __iter__z4TestKQueue.test_issue30058.<locals>.BadList.__iter__ s s A H s N)__name__
__module__ __qualname__rt rw )r s r BadListrq s
r r{ ) r r rG re r& r* r, rR rS iterr )r r ri rj r{ r s @r test_issue30058zTestKQueue.test_issue30058 s
]]_ "1
]]1f 3 3V5E5EH[H[5[
\
B4
B5!
79a
4:q!
r c t t d }| j |j |j }t j }| j |j t | j |j |j | j |j | j t |j |j | j t |j d d y )Nrbr )r" __file__r% r r
r r assertIsInstanceintrf r r r
r rS )r open_filer4 r s r
test_closezTestKQueue.test_close s 4( (
fmmos3 '
& *fmm4
*fnndA>r c t j }| j |j | j t j |j d y )NF)r r r% r r' r! get_inheritabler
)r r s r test_fd_non_inheritablez"TestKQueue.test_fd_non_inheritable s> % ++FMMO<eDr N)
rx ry rz r r8 rc rn r} r r rs r r r r s* 1V'rO b 0?*Er r __main__)
__doc__rN r! r rG rX unittesthasattrSkipTestTestCaser rx mainrs r r <module>r sm
vx
(
4
55sE"" sEl zHMMO r